用request重写了请求部分

This commit is contained in:
孟政元 2017-12-31 18:45:33 +08:00
parent 4cddeb6a2e
commit 602a4dbc4c
4 changed files with 111 additions and 139 deletions

2
app.js
View File

@ -248,7 +248,7 @@ app.use("/user/record", require("./router/user_playrecord"));
const port = process.env.PORT || 3000; const port = process.env.PORT || 3000;
app.listen(port, () => { app.listen(port, () => {
console.log(`server running @${port}`); console.log(`server running @ http://localhost:${port}`);
}); });
module.exports = app; module.exports = app;

View File

@ -1,27 +1,27 @@
const express = require('express') const express = require("express");
const router = express() const router = express();
const { createWebAPIRequest } = require('../util/util') const { createWebAPIRequest } = require("../util/util");
router.get('/', (req, res) => { router.get("/", (req, res) => {
const rid = req.query.id const rid = req.query.id;
const cookie = req.get('Cookie') ? req.get('Cookie') : '' const cookie = req.get("Cookie") ? req.get("Cookie") : "";
const data = { const data = {
offset: req.query.offset || 0, offset: req.query.offset || 0,
rid: rid, rid: rid,
limit: req.query.limit || 20, limit: req.query.limit || 20,
csrf_token: '' csrf_token: ""
} };
createWebAPIRequest( createWebAPIRequest(
'music.163.com', "music.163.com",
`/weapi/v1/resource/comments/R_SO_4_${rid}/?csrf_token=`, `/weapi/v1/resource/comments/R_SO_4_${rid}/?csrf_token=`,
'POST', "POST",
data, data,
cookie, cookie,
music_req => { music_req => {
res.send(music_req) res.send(music_req);
}, },
err => res.status(502).send('fetch error') err => res.status(502).send(err.message)
) );
}) });
module.exports = router module.exports = router;

View File

@ -1,32 +1,33 @@
const assert = require('assert') const assert = require("assert");
const crypto = require('crypto') const crypto = require("crypto");
const { createWebAPIRequest } = require('../util/util') const { createWebAPIRequest } = require("../util/util");
describe('测试获取歌曲是否正常', () => { describe("测试获取歌曲是否正常", () => {
it('歌曲的 url 不应该为空', done => { it("歌曲的 url 不应该为空", done => {
const id = 347230 const id = 462791935;
const br = 999000 const br = 999000;
const data = { const data = {
ids: [id], ids: [id],
br: br, br: br,
csrf_token: '' csrf_token: ""
} };
const cookie = '' const cookie = "";
createWebAPIRequest( createWebAPIRequest(
'music.163.com', "music.163.com",
'/weapi/song/enhance/player/url', "/weapi/song/enhance/player/url",
'POST', "POST",
data, data,
cookie, cookie,
music_req => { music_req => {
console.log(JSON.parse(music_req).data[0].url) console.log(music_req);
assert(!!JSON.parse(music_req).data[0].url) console.log(JSON.parse(music_req).data[0].url);
done() assert(!!JSON.parse(music_req).data[0].url);
done();
}, },
err => { err => {
done(err) done(err);
} }
) );
}) });
}) });

View File

@ -1,32 +1,35 @@
const Encrypt = require('./crypto.js') const Encrypt = require("./crypto.js");
const http = require('http') const request = require("request");
const querystring = require('querystring') request.debug = true;
const http = require("http");
const querystring = require("querystring");
function randomUserAgent() { function randomUserAgent() {
const userAgentList = [ const userAgentList = [
'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Safari/537.36', "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Safari/537.36",
'Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1', "Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1",
'Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1', "Mozilla/5.0 (iPhone; CPU iPhone OS 9_1 like Mac OS X) AppleWebKit/601.1.46 (KHTML, like Gecko) Version/9.0 Mobile/13B143 Safari/601.1",
'Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Mobile Safari/537.36', "Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Mobile Safari/537.36",
'Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Mobile Safari/537.36', "Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Mobile Safari/537.36",
'Mozilla/5.0 (Linux; Android 5.1.1; Nexus 6 Build/LYZ28E) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Mobile Safari/537.36', "Mozilla/5.0 (Linux; Android 5.1.1; Nexus 6 Build/LYZ28E) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Mobile Safari/537.36",
'Mozilla/5.0 (iPhone; CPU iPhone OS 10_3_2 like Mac OS X) AppleWebKit/603.2.4 (KHTML, like Gecko) Mobile/14F89;GameHelper', "Mozilla/5.0 (iPhone; CPU iPhone OS 10_3_2 like Mac OS X) AppleWebKit/603.2.4 (KHTML, like Gecko) Mobile/14F89;GameHelper",
'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_5) AppleWebKit/603.2.4 (KHTML, like Gecko) Version/10.1.1 Safari/603.2.4', "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_5) AppleWebKit/603.2.4 (KHTML, like Gecko) Version/10.1.1 Safari/603.2.4",
'Mozilla/5.0 (iPhone; CPU iPhone OS 10_0 like Mac OS X) AppleWebKit/602.1.38 (KHTML, like Gecko) Version/10.0 Mobile/14A300 Safari/602.1', "Mozilla/5.0 (iPhone; CPU iPhone OS 10_0 like Mac OS X) AppleWebKit/602.1.38 (KHTML, like Gecko) Version/10.0 Mobile/14A300 Safari/602.1",
'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/51.0.2704.103 Safari/537.36', "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/51.0.2704.103 Safari/537.36",
'Mozilla/5.0 (Macintosh; Intel Mac OS X 10.12; rv:46.0) Gecko/20100101 Firefox/46.0', "Mozilla/5.0 (Macintosh; Intel Mac OS X 10.12; rv:46.0) Gecko/20100101 Firefox/46.0",
'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:46.0) Gecko/20100101 Firefox/46.0', "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:46.0) Gecko/20100101 Firefox/46.0",
'Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 6.0)', "Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 6.0)",
'Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)', "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)",
'Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Trident/5.0)', "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Trident/5.0)",
'Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Win64; x64; Trident/6.0)', "Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Win64; x64; Trident/6.0)",
'Mozilla/5.0 (Windows NT 6.3; Win64, x64; Trident/7.0; rv:11.0) like Gecko', "Mozilla/5.0 (Windows NT 6.3; Win64, x64; Trident/7.0; rv:11.0) like Gecko",
'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/42.0.2311.135 Safari/537.36 Edge/13.10586', "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/42.0.2311.135 Safari/537.36 Edge/13.10586",
'Mozilla/5.0 (iPad; CPU OS 10_0 like Mac OS X) AppleWebKit/602.1.38 (KHTML, like Gecko) Version/10.0 Mobile/14A300 Safari/602.1' "Mozilla/5.0 (iPad; CPU OS 10_0 like Mac OS X) AppleWebKit/602.1.38 (KHTML, like Gecko) Version/10.0 Mobile/14A300 Safari/602.1"
] ];
const num = Math.floor(Math.random() * userAgentList.length) const num = Math.floor(Math.random() * userAgentList.length);
return userAgentList[num] return userAgentList[num];
} }
function createWebAPIRequest( function createWebAPIRequest(
host, host,
path, path,
@ -36,94 +39,62 @@ function createWebAPIRequest(
callback, callback,
errorcallback errorcallback
) { ) {
let music_req = '' const cryptoreq = Encrypt(data);
const cryptoreq = Encrypt(data) const options = {
const http_client = http.request( url: `http://${host}${path}`,
{
hostname: host,
method: method, method: method,
path: path,
headers: { headers: {
Accept: '*/*', Accept: "*/*",
'Accept-Language': 'zh-CN,zh;q=0.8,gl;q=0.6,zh-TW;q=0.4', "Accept-Language": "zh-CN,zh;q=0.8,gl;q=0.6,zh-TW;q=0.4",
Connection: 'keep-alive', Connection: "keep-alive",
'Content-Type': 'application/x-www-form-urlencoded', "Content-Type": "application/x-www-form-urlencoded",
Referer: 'http://music.163.com', Referer: "http://music.163.com",
Host: 'music.163.com', Host: "music.163.com",
Cookie: cookie, Cookie: cookie,
'User-Agent': randomUserAgent() "User-Agent": randomUserAgent()
}
}, },
function(res) { body: querystring.stringify({
res.on('error', function(err) {
errorcallback(err)
})
res.setEncoding('utf8')
if (res.statusCode != 200) {
createWebAPIRequest(host, path, method, data, cookie, callback)
return
} else {
res.on('data', function(chunk) {
music_req += chunk
})
res.on('end', function() {
if (music_req == '') {
createWebAPIRequest(host, path, method, data, cookie, callback)
return
}
if (res.headers['set-cookie']) {
callback(music_req, res.headers['set-cookie'])
} else {
callback(music_req)
}
})
}
}
)
http_client.write(
querystring.stringify({
params: cryptoreq.params, params: cryptoreq.params,
encSecKey: cryptoreq.encSecKey encSecKey: cryptoreq.encSecKey
}) })
) };
http_client.end()
request(options, function(error, res, body) {
if (error) {
errorcallback(error);
} else {
callback(body, res.headers["set-cookie"]);
}
});
} }
function createRequest(path, method, data, callback, errorcallback) { function createRequest(path, method, data) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
let ne_req = '' const options = {
const http_client = http.request( url: `http://music.163.com${path}`,
{
hostname: 'music.163.com',
method: method, method: method,
path: path,
headers: { headers: {
Referer: 'http://music.163.com', Referer: "http://music.163.com",
Cookie: 'appver=1.5.2', Cookie: "appver=1.5.2",
'Content-Type': 'application/x-www-form-urlencoded', "Content-Type": "application/x-www-form-urlencoded",
'User-Agent': randomUserAgent() "User-Agent": randomUserAgent()
} }
}, };
res => {
res.setEncoding('utf8') if (method.toLowerCase() === "post") {
res.on('error', err => { options.body = data;
reject(err)
})
res.on('data', chunk => {
ne_req += chunk
})
res.on('end', () => {
resolve(ne_req)
})
} }
)
if (method == 'POST') { request(options, function(error, res, body) {
http_client.write(data) if (error) {
reject(error);
} else {
resolve(body);
} }
http_client.end() });
}) });
} }
module.exports = { module.exports = {
createWebAPIRequest, createWebAPIRequest,
createRequest createRequest
} };