133 lines
6.8 KiB
JavaScript
133 lines
6.8 KiB
JavaScript
"use strict";
|
||
Object.defineProperty(exports, "__esModule", { value: true });
|
||
exports.WechatWebInstance = void 0;
|
||
var tslib_1 = require("tslib");
|
||
require('../../fetch');
|
||
var crypto_1 = tslib_1.__importDefault(require("crypto"));
|
||
var buffer_1 = require("buffer");
|
||
var WechatWebInstance = /** @class */ (function () {
|
||
function WechatWebInstance(appId, appSecret) {
|
||
this.appId = appId;
|
||
this.appSecret = appSecret;
|
||
this.refreshAccessToken();
|
||
}
|
||
WechatWebInstance.prototype.getAccessToken = function () {
|
||
return tslib_1.__awaiter(this, void 0, void 0, function () {
|
||
return tslib_1.__generator(this, function (_a) {
|
||
switch (_a.label) {
|
||
case 0:
|
||
if (!true) return [3 /*break*/, 2];
|
||
if (this.accessToken) {
|
||
return [2 /*return*/, this.accessToken];
|
||
}
|
||
return [4 /*yield*/, new Promise(function (resolve) { return setTimeout(function () { return resolve(0); }, 500); })];
|
||
case 1:
|
||
_a.sent();
|
||
return [3 /*break*/, 0];
|
||
case 2: return [2 /*return*/];
|
||
}
|
||
});
|
||
});
|
||
};
|
||
WechatWebInstance.prototype.access = function (url, mockData, init) {
|
||
return tslib_1.__awaiter(this, void 0, void 0, function () {
|
||
var response, headers, status, contentType, json, data;
|
||
return tslib_1.__generator(this, function (_a) {
|
||
switch (_a.label) {
|
||
case 0:
|
||
if (process.env.NODE_ENV === 'development') {
|
||
return [2 /*return*/, mockData];
|
||
}
|
||
return [4 /*yield*/, global.fetch(url, init)];
|
||
case 1:
|
||
response = _a.sent();
|
||
headers = response.headers, status = response.status;
|
||
if (![200, 201].includes(status)) {
|
||
throw new Error("\u5FAE\u4FE1\u670D\u52A1\u5668\u8FD4\u56DE\u4E0D\u6B63\u786E\u5E94\u7B54\uFF1A".concat(status));
|
||
}
|
||
contentType = headers['Content-Type'] || headers.get('Content-Type');
|
||
if (!contentType.includes('application/json')) return [3 /*break*/, 3];
|
||
return [4 /*yield*/, response.json()];
|
||
case 2:
|
||
json = _a.sent();
|
||
if (typeof json.errcode === 'number' && json.errcode !== 0) {
|
||
if (json.errcode === 40001) {
|
||
this.refreshAccessToken();
|
||
}
|
||
throw new Error("\u8C03\u7528\u5FAE\u4FE1\u63A5\u53E3\u8FD4\u56DE\u51FA\u9519\uFF0Ccode\u662F".concat(json.errcode, "\uFF0C\u4FE1\u606F\u662F").concat(json.errmsg));
|
||
}
|
||
return [2 /*return*/, json];
|
||
case 3:
|
||
if (!(contentType.includes('text') ||
|
||
contentType.includes('xml') ||
|
||
contentType.includes('html'))) return [3 /*break*/, 5];
|
||
return [4 /*yield*/, response.text()];
|
||
case 4:
|
||
data = _a.sent();
|
||
return [2 /*return*/, data];
|
||
case 5:
|
||
if (!contentType.includes('application/octet-stream')) return [3 /*break*/, 7];
|
||
return [4 /*yield*/, response.arrayBuffer()];
|
||
case 6: return [2 /*return*/, _a.sent()];
|
||
case 7: return [2 /*return*/, response];
|
||
}
|
||
});
|
||
});
|
||
};
|
||
WechatWebInstance.prototype.code2Session = function (code) {
|
||
return tslib_1.__awaiter(this, void 0, void 0, function () {
|
||
var result, _a, session_key, openid, unionid;
|
||
return tslib_1.__generator(this, function (_b) {
|
||
switch (_b.label) {
|
||
case 0: return [4 /*yield*/, this.access("https://api.weixin.qq.com/sns/oauth2/access_token?appid=".concat(this.appId, "&secret=").concat(this.appSecret, "&code=").concat(code, "&grant_type=authorization_code"), { session_key: 'aaa', openid: code, unionid: code })];
|
||
case 1:
|
||
result = _b.sent();
|
||
_a = typeof result === 'string' ? JSON.parse(result) : result, session_key = _a.session_key, openid = _a.openid, unionid = _a.unionid;
|
||
return [2 /*return*/, {
|
||
sessionKey: session_key,
|
||
openId: openid,
|
||
unionId: unionid,
|
||
}];
|
||
}
|
||
});
|
||
});
|
||
};
|
||
WechatWebInstance.prototype.refreshAccessToken = function () {
|
||
return tslib_1.__awaiter(this, void 0, void 0, function () {
|
||
var result, access_token, expires_in;
|
||
var _this = this;
|
||
return tslib_1.__generator(this, function (_a) {
|
||
switch (_a.label) {
|
||
case 0: return [4 /*yield*/, this.access("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".concat(this.appId, "&secret=").concat(this.appSecret), { access_token: 'mockToken', expires_in: 3600 * 1000 })];
|
||
case 1:
|
||
result = _a.sent();
|
||
access_token = result.access_token, expires_in = result.expires_in;
|
||
this.accessToken = access_token;
|
||
// 生成下次刷新的定时器
|
||
this.refreshAccessTokenHandler = setTimeout(function () {
|
||
_this.refreshAccessToken();
|
||
}, (expires_in - 10) * 1000);
|
||
return [2 /*return*/];
|
||
}
|
||
});
|
||
});
|
||
};
|
||
WechatWebInstance.prototype.decryptData = function (sessionKey, encryptedData, iv, signature) {
|
||
var skBuf = buffer_1.Buffer.from(sessionKey, 'base64');
|
||
// const edBuf = Buffer.from(encryptedData, 'base64');
|
||
var ivBuf = buffer_1.Buffer.from(iv, 'base64');
|
||
var decipher = crypto_1.default.createDecipheriv('aes-128-cbc', skBuf, ivBuf);
|
||
// 设置自动 padding 为 true，删除填充补位
|
||
decipher.setAutoPadding(true);
|
||
var decoded = decipher.update(encryptedData, 'base64', 'utf8');
|
||
decoded += decipher.final('utf8');
|
||
var data = JSON.parse(decoded);
|
||
if (data.watermark.appid !== this.appId) {
|
||
throw new Error('Illegal Buffer');
|
||
}
|
||
return data;
|
||
};
|
||
return WechatWebInstance;
|
||
}());
|
||
exports.WechatWebInstance = WechatWebInstance;
|