109 lines
4.1 KiB
JavaScript
109 lines
4.1 KiB
JavaScript
const http = require("http");
|
|
const url = require("url");
|
|
const { ServerModel } = require('./model/ServerModel');
|
|
const { SearchModel } = require('./model/SearchModel');
|
|
const { storeMusic, storeLrc, storePic } = require('./model/StoreModel');
|
|
const { SuccessResult, ErrorResult } = require('./model/ResultModel');
|
|
|
|
const { QQSource } = require('./source/QQSource');
|
|
const mfm = require('./source/MyFreemp3Source');
|
|
|
|
// 防止进程中断
|
|
// process.on('uncaughtException', function (err) {
|
|
// console.log('Caught exception: ' + err);
|
|
// });
|
|
// ***********************************************************************
|
|
// 注册源
|
|
const searcher = new SearchModel();
|
|
//searcher.registerSourceModel(new QQSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3QQSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3NeteaseSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3KugouSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3KuwoSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3MiguSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3QianqianSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3QingtingSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3XimalayaSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3LizhiSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp3KgSource());
|
|
searcher.registerSourceModel(new mfm.MyFreemp31tingSource());
|
|
// searcher.registerSourceModel(new mfm.MyFreemp35singycSource());
|
|
// searcher.registerSourceModel(new mfm.MyFreemp35singfcSource());
|
|
|
|
|
|
// ***********************************************************************
|
|
// 添加API接口
|
|
const _server = new ServerModel();
|
|
_server.get("/api/source/all", (req, res, query) => {
|
|
// 罗列都有哪些源
|
|
return new SuccessResult(searcher.getSourceList());
|
|
});
|
|
|
|
_server.get("/api/search", async (req, res, query) => {
|
|
//从源去进行搜索
|
|
let result = await searcher.searchMusic(query.source_name, query.keywords);
|
|
return new SuccessResult(result);
|
|
});
|
|
|
|
_server.get("/api/store", async (req, res, query) => {
|
|
//存储文件
|
|
let music_path = query.music_path;
|
|
let music_url = query.music_url;
|
|
let lrc_content = query.lrc_content;
|
|
let pic_url = query.pic_url;
|
|
let store_music = parseInt(query.store_music);
|
|
let store_lrc = parseInt(query.store_lrc);
|
|
let store_pic = parseInt(query.store_pic);
|
|
let path_name = music_path.split('.').slice(0,-1).join('.');
|
|
let pic_extension = pic_url.split('?')[0].split('.').pop();
|
|
let result = '';
|
|
if(store_music) {
|
|
await storeMusic(music_path, music_url);
|
|
result += '保存歌曲成功！ ';
|
|
}
|
|
if(store_lrc) {
|
|
await storeLrc(path_name + '.lrc', lrc_content);
|
|
result += '保存歌词成功！ ';
|
|
}
|
|
if(store_pic) {
|
|
await storePic(path_name + '.' + pic_extension, pic_url);
|
|
result += '保存封面成功！ ';
|
|
}
|
|
return new SuccessResult(result);
|
|
});
|
|
|
|
|
|
// ***********************************************************************
|
|
// 运行服务
|
|
const server = http.createServer(async (req, res) => {
|
|
let method = req.method;
|
|
let reqUrl = req.url;
|
|
let reqApi = reqUrl.split('?')[0];
|
|
console.log(method, reqUrl);
|
|
let result;
|
|
try {
|
|
if(method == "GET") {
|
|
let query = url.parse(reqUrl, true).query;
|
|
result = await _server.trigger(method, reqApi, req, res, query, null);
|
|
}else if(method == "POST") {
|
|
let query = url.parse(reqUrl, true).query;
|
|
let data = {};
|
|
result = await _server.trigger(method, reqApi, req, res, query, data);
|
|
}
|
|
}catch(err) {
|
|
console.error(err);
|
|
result = new ErrorResult(err);
|
|
}
|
|
res.setHeader('Access-Control-Allow-Origin', '*');
|
|
//res.setHeader('Access-Control-Allow-Methods', '*');
|
|
res.setHeader('Access-Control-Allow-Headers', '*');
|
|
res.setHeader('Content-type', 'application/json;charset=utf-8');
|
|
//res.writeHead(200, { 'Content-type': 'application/json;charset=utf-8' });
|
|
res.end(JSON.stringify(result));
|
|
});
|
|
|
|
server.listen(5000, () => {
|
|
console.log("server running at prot 5000");
|
|
});
|
|
|