From 38289918c2908f16bfc313fa73ca030a9d4aa2e5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?= Date: Thu, 8 Aug 2024 21:42:34 +0800 Subject: [PATCH] chore: requests --- src/common/utils/request.ts | 191 ++++++++++++++++++++++++++++++++++++ src/core/helper/rkey.ts | 42 ++++++++ 2 files changed, 233 insertions(+) create mode 100644 src/common/utils/request.ts create mode 100644 src/core/helper/rkey.ts diff --git a/src/common/utils/request.ts b/src/common/utils/request.ts new file mode 100644 index 00000000..8bd51e7f --- /dev/null +++ b/src/common/utils/request.ts @@ -0,0 +1,191 @@ +import https from 'node:https'; +import http from 'node:http'; +import { readFileSync } from 'node:fs'; +export class RequestUtil { + // 适用于获取服务器下发cookies时获取，仅GET + static async HttpsGetCookies(url: string): Promise<{ [key: string]: string }> { + const client = url.startsWith('https') ? https : http; + return new Promise((resolve, reject) => { + const req = client.get(url, (res) => { + let cookies: { [key: string]: string } = {}; + const handleRedirect = (res: http.IncomingMessage) => { + //console.log(res.headers.location); + if (res.statusCode === 301 || res.statusCode === 302) { + if (res.headers.location) { + const redirectUrl = new URL(res.headers.location, url); + RequestUtil.HttpsGetCookies(redirectUrl.href).then((redirectCookies) => { + // 合并重定向过程中的cookies + cookies = { ...cookies, ...redirectCookies }; + resolve(cookies); + }).catch((err) => { + reject(err); + }); + } else { + resolve(cookies); + } + } else { + resolve(cookies); + } + }; + res.on('data', () => { }); // Necessary to consume the stream + res.on('end', () => { + handleRedirect(res); + }); + if (res.headers['set-cookie']) { + //console.log(res.headers['set-cookie']); + res.headers['set-cookie'].forEach((cookie) => { + const parts = cookie.split(';')[0].split('='); + const key = parts[0]; + const value = parts[1]; + if (key && value && key.length > 0 && value.length > 0) { + cookies[key] = value; + } + }); + } + }); + req.on('error', (error: any) => { + reject(error); + }); + }); + } + + + + // 请求和回复都是JSON data传原始内容 自动编码json + static async HttpGetJson(url: string, method: string = 'GET', data?: any, headers: { [key: string]: string } = {}, isJsonRet: boolean = true, isArgJson: boolean = true): Promise { + const option = new URL(url); + const protocol = url.startsWith('https://') ? https : http; + const options = { + hostname: option.hostname, + port: option.port, + path: option.href, + method: method, + headers: headers + }; + // headers: { + // 'Content-Type': 'application/json', + // 'Content-Length': Buffer.byteLength(postData), + // }, + return new Promise((resolve, reject) => { + const req = protocol.request(options, (res: any) => { + let responseBody = ''; + res.on('data', (chunk: string | Buffer) => { + responseBody += chunk.toString(); + }); + + res.on('end', () => { + try { + if (res.statusCode && res.statusCode >= 200 && res.statusCode < 300) { + if (isJsonRet) { + const responseJson = JSON.parse(responseBody); + resolve(responseJson as T); + } else { + resolve(responseBody as T); + } + } else { + reject(new Error(`Unexpected status code: ${res.statusCode}`)); + } + } catch (parseError) { + reject(parseError); + } + }); + }); + + req.on('error', (error: any) => { + reject(error); + }); + if (method === 'POST' || method === 'PUT' || method === 'PATCH') { + if (isArgJson) { + req.write(JSON.stringify(data)); + } else { + req.write(data); + } + + } + req.end(); + }); + } + + // 请求返回都是原始内容 + static async HttpGetText(url: string, method: string = 'GET', data?: any, headers: { [key: string]: string } = {}) { + return this.HttpGetJson(url, method, data, headers, false, false); + } + + static async createFormData(boundary: string, filePath: string): Promise { + let type = 'image/png'; + if (filePath.endsWith('.jpg')) { + type = 'image/jpeg'; + } + const formDataParts = [ + `------${boundary}\r\n`, + `Content-Disposition: form-data; name="share_image"; filename="${filePath}"\r\n`, + 'Content-Type: ' + type + '\r\n\r\n' + ]; + + const fileContent = readFileSync(filePath); + const footer = `\r\n------${boundary}--`; + return Buffer.concat([ + Buffer.from(formDataParts.join(''), 'utf8'), + fileContent, + Buffer.from(footer, 'utf8') + ]); + } + + static async uploadImageForOpenPlatform(filePath: string,cookies:string): Promise { + return new Promise(async (resolve, reject) => { + type retType = { retcode: number, result?: { url: string } }; + try { + const options = { + hostname: 'cgi.connect.qq.com', + port: 443, + path: '/qqconnectopen/upload_share_image', + method: 'POST', + headers: { + 'Referer': 'https://cgi.connect.qq.com', + 'Cookie': cookies, + 'Accept': '*/*', + 'Connection': 'keep-alive', + 'Content-Type': 'multipart/form-data; boundary=----WebKitFormBoundary7MA4YWxkTrZu0gW' + } + }; + const req = https.request(options, async (res) => { + let responseBody = ''; + + res.on('data', (chunk: string | Buffer) => { + responseBody += chunk.toString(); + }); + + res.on('end', () => { + try { + if (res.statusCode && res.statusCode >= 200 && res.statusCode < 300) { + const responseJson = JSON.parse(responseBody) as retType; + resolve(responseJson.result!.url!); + } else { + reject(new Error(`Unexpected status code: ${res.statusCode}`)); + } + } catch (parseError) { + reject(parseError); + } + + }); + + }); + + req.on('error', (error) => { + reject(error); + console.error('Error during upload:', error); + }); + + const body = await RequestUtil.createFormData('WebKitFormBoundary7MA4YWxkTrZu0gW', filePath); + // req.setHeader('Content-Length', Buffer.byteLength(body)); + // console.log(`Prepared data size: ${Buffer.byteLength(body)} bytes`); + req.write(body); + req.end(); + return; + } catch (error) { + reject(error); + } + return undefined; + }); + } +} diff --git a/src/core/helper/rkey.ts b/src/core/helper/rkey.ts new file mode 100644 index 00000000..ae18419f --- /dev/null +++ b/src/core/helper/rkey.ts @@ -0,0 +1,42 @@ +import { LogWrapper } from '@/common/utils/log'; +import { RequestUtil } from '@/common/utils/request'; + +interface ServerRkeyData { + group_rkey: string; + private_rkey: string; + expired_time: number; +} + +class RkeyManager { + serverUrl: string = ''; + private rkeyData: ServerRkeyData = { + group_rkey: '', + private_rkey: '', + expired_time: 0 + }; + logger: LogWrapper; + constructor(serverUrl: string, logger: LogWrapper) { + this.logger = logger; + this.serverUrl = serverUrl; + } + async getRkey() { + if (this.isExpired()) { + try { + await this.refreshRkey(); + } catch (e) { + this.logger.logError('获取rkey失败', e); + } + } + return this.rkeyData; + } + + isExpired(): boolean { + const now = new Date().getTime() / 1000; + // console.log(`now: ${now}, expired_time: ${this.rkeyData.expired_time}`); + return now > this.rkeyData.expired_time; + } + async refreshRkey(): Promise { + //刷新rkey + this.rkeyData = await RequestUtil.HttpGetJson(this.serverUrl, 'GET'); + } +}