mirror of
https://github.com/qist/tvbox.git
synced 2025-10-31 04:02:22 +00:00
902 lines
30 KiB
JavaScript
902 lines
30 KiB
JavaScript
/*
|
||
* @File : spider.js
|
||
* @Author : jade
|
||
* @Date : 2023/12/25 17:19
|
||
* @Email : jadehh@1ive.com
|
||
* @Software : Samples
|
||
* @Desc :
|
||
*/
|
||
|
||
import {JadeLogging} from "../lib/log.js";
|
||
import * as Utils from "../lib/utils.js";
|
||
import {VodDetail, VodShort} from "../lib/vod.js";
|
||
import {_, load, Uri} from "../lib/cat.js";
|
||
import * as HLS from "../lib/hls.js";
|
||
import {hlsCache, tsCache} from "../lib/ffm3u8_open.js";
|
||
import {DanmuSpider} from "../lib/danmuSpider.js";
|
||
import { initCloud } from "../lib/cloud.js";
|
||
class Result {
|
||
constructor() {
|
||
this.class = []
|
||
this.list = []
|
||
this.filters = []
|
||
this.header = {"User-Agent": Utils.CHROME};
|
||
this.format = "";
|
||
this.danmaku = "";
|
||
this.url = "";
|
||
this.subs = [];
|
||
this.parse = 0
|
||
this.jx = 0;
|
||
this.page = 0
|
||
this.pagecount = 0
|
||
this.limit = 0;
|
||
this.total = 0;
|
||
this.extra = {}
|
||
|
||
}
|
||
|
||
get() {
|
||
return new Result()
|
||
}
|
||
|
||
home(classes, list, filters) {
|
||
return JSON.stringify({
|
||
"class": classes, "list": list, "filters": filters
|
||
})
|
||
}
|
||
|
||
homeVod(vod_list) {
|
||
return JSON.stringify({"page": this.page, "list": vod_list, "pagecount": this.page, "total": this.page})
|
||
}
|
||
|
||
category(vod_list, page, count, limit, total) {
|
||
return JSON.stringify({
|
||
page: parseInt(page), pagecount: count, limit: limit, total: total, list: vod_list,
|
||
});
|
||
}
|
||
|
||
search(vod_list) {
|
||
return JSON.stringify({"list": vod_list,"page":this.page,"pagecount":this.pagecount,"total":this.total})
|
||
}
|
||
|
||
detail(vod_detail) {
|
||
return JSON.stringify({"list": [vod_detail]})
|
||
}
|
||
|
||
play(url) {
|
||
if (!_.isEmpty(this.danmaku)) {
|
||
return JSON.stringify({
|
||
"url": url,
|
||
"parse": this.parse,
|
||
"header": this.header,
|
||
"format": this.format,
|
||
"subs": this.subs,
|
||
"danmaku": this.danmaku,
|
||
"extra": this.extra,
|
||
"jx": this.jx
|
||
})
|
||
} else {
|
||
return JSON.stringify({
|
||
"url": url,
|
||
"parse": this.parse,
|
||
"header": this.header,
|
||
"format": this.format,
|
||
"subs": this.subs,
|
||
"extra": this.extra,
|
||
"jx": this.jx
|
||
})
|
||
}
|
||
}
|
||
|
||
playTxt(url) {
|
||
return url
|
||
}
|
||
|
||
errorCategory(error_message) {
|
||
let vodShort = new VodShort()
|
||
vodShort.vod_name = "错误:打开无效"
|
||
vodShort.vod_id = "error"
|
||
vodShort.vod_pic = Utils.RESOURCEURL + "/resources/error.png"
|
||
vodShort.vod_remarks = error_message
|
||
return JSON.stringify({
|
||
page: parseInt(0), pagecount: 0, limit: 0, total: 0, list: [vodShort],
|
||
})
|
||
}
|
||
|
||
setClass(classes) {
|
||
this.class = classes;
|
||
return this;
|
||
}
|
||
|
||
setVod(list) {
|
||
if (typeof list === "object" && Array.isArray(list)) {
|
||
this.list = list;
|
||
} else if (list !== undefined) {
|
||
this.list = [list]
|
||
}
|
||
return this;
|
||
}
|
||
|
||
setFilters(filters) {
|
||
this.filters = filters;
|
||
return this;
|
||
}
|
||
|
||
setHeader(header) {
|
||
this.header = header;
|
||
return this;
|
||
}
|
||
|
||
setParse(parse) {
|
||
this.parse = parse;
|
||
return this;
|
||
}
|
||
|
||
setJx() {
|
||
this.jx = 1;
|
||
return this;
|
||
}
|
||
|
||
setUrl(url) {
|
||
this.url = url;
|
||
return this;
|
||
}
|
||
|
||
danmu(danmaku) {
|
||
this.danmaku = danmaku;
|
||
return this;
|
||
}
|
||
|
||
setFormat(format) {
|
||
this.format = format;
|
||
return this;
|
||
}
|
||
|
||
setSubs(subs) {
|
||
this.subs = subs;
|
||
return this;
|
||
}
|
||
|
||
dash() {
|
||
this.format = "application/dash+xml";
|
||
return this;
|
||
}
|
||
|
||
m3u8() {
|
||
this.format = "application/x-mpegURL";
|
||
return this;
|
||
}
|
||
|
||
rtsp() {
|
||
this.format = "application/x-rtsp";
|
||
return this;
|
||
}
|
||
|
||
octet() {
|
||
this.format = "application/octet-stream";
|
||
return this;
|
||
}
|
||
|
||
|
||
setPage(page, count, limit, total) {
|
||
this.page = page
|
||
this.limit = limit
|
||
this.total = total
|
||
this.pagecount = count
|
||
return this;
|
||
}
|
||
|
||
toString() {
|
||
return JSON.stringify(this);
|
||
}
|
||
}
|
||
|
||
class Spider {
|
||
constructor() {
|
||
this.siteKey = ""
|
||
this.siteType = 0
|
||
this.jadeLog = new JadeLogging(this.getAppName(), "DEBUG")
|
||
this.classes = []
|
||
this.filterObj = {}
|
||
this.result = new Result()
|
||
this.catOpenStatus = true
|
||
this.danmuStaus = false
|
||
this.reconnectTimes = 0
|
||
this.maxReconnectTimes = 5
|
||
this.siteUrl = ""
|
||
this.vodList = []
|
||
this.homeVodList = []
|
||
this.count = 0
|
||
this.limit = 0
|
||
this.total = 0
|
||
this.page = 0
|
||
this.vodDetail = new VodDetail()
|
||
this.playUrl = ""
|
||
this.header = {}
|
||
this.remove18 = false
|
||
this.type_id_18 = 0
|
||
this.type_name_18 = "伦理片"
|
||
this.episodeObj = {}
|
||
this.danmuUrl = ""
|
||
this.cfgObj = {}
|
||
|
||
}
|
||
|
||
async reconnnect(reqUrl, params, headers, redirect_url, return_cookie, buffer) {
|
||
await this.jadeLog.error("请求失败,请检查url:" + reqUrl + ",两秒后重试")
|
||
Utils.sleep(2)
|
||
if (this.reconnectTimes < this.maxReconnectTimes) {
|
||
this.reconnectTimes = this.reconnectTimes + 1
|
||
return await this.fetch(reqUrl, params, headers, redirect_url, return_cookie, buffer)
|
||
} else {
|
||
await this.jadeLog.error("请求失败,重连失败")
|
||
return null
|
||
}
|
||
}
|
||
|
||
getClassIdList() {
|
||
let class_id_list = []
|
||
for (const class_dic of this.classes) {
|
||
class_id_list.push(class_dic["type_id"])
|
||
}
|
||
return class_id_list
|
||
}
|
||
|
||
getTypeDic(type_name, type_id) {
|
||
return {"type_name": type_name, "type_id": type_id}
|
||
}
|
||
getFliterDic(type_name, type_id) {
|
||
return {"n": type_name, "v": type_id}
|
||
}
|
||
|
||
|
||
async getHtml(url = this.siteUrl, proxy = false, headers = this.getHeader()) {
|
||
let html = await this.fetch(url, null, headers, false, false, 0, proxy)
|
||
if (!_.isEmpty(html)) {
|
||
return load(html)
|
||
} else {
|
||
await this.jadeLog.error(`html获取失败`, true)
|
||
}
|
||
}
|
||
|
||
getClassNameList() {
|
||
let class_name_list = []
|
||
for (const class_dic of this.classes) {
|
||
class_name_list.push(class_dic["type_name"])
|
||
}
|
||
return class_name_list
|
||
}
|
||
|
||
async postReconnect(reqUrl, params, headers,postType,buffer) {
|
||
await this.jadeLog.error("请求失败,请检查url:" + reqUrl + ",两秒后重试")
|
||
Utils.sleep(2)
|
||
if (this.reconnectTimes < this.maxReconnectTimes) {
|
||
this.reconnectTimes = this.reconnectTimes + 1
|
||
return await this.post(reqUrl, params, headers,postType,buffer)
|
||
} else {
|
||
await this.jadeLog.error("请求失败,重连失败")
|
||
return null
|
||
}
|
||
}
|
||
|
||
getHeader() {
|
||
return {"User-Agent": Utils.CHROME, "Referer": this.siteUrl + "/"};
|
||
}
|
||
|
||
async getResponse(reqUrl, params, headers, redirect_url, return_cookie, buffer, response,proxy) {
|
||
{
|
||
if (response.headers["location"] !== undefined) {
|
||
if (redirect_url) {
|
||
await this.jadeLog.debug(`返回重定向连接:${response.headers["location"]}`)
|
||
return response.headers["location"]
|
||
} else {
|
||
return this.fetch(response.headers["location"], params, headers, redirect_url, return_cookie, buffer,proxy)
|
||
}
|
||
} else if (response.content.length > 0) {
|
||
this.reconnectTimes = 0
|
||
if (return_cookie) {
|
||
return {"cookie": response.headers["set-cookie"], "content": response.content}
|
||
} else {
|
||
return response.content
|
||
}
|
||
} else if (buffer === 1) {
|
||
this.reconnectTimes = 0
|
||
return response.content
|
||
} else {
|
||
await this.jadeLog.error(`请求失败,请求url为:${reqUrl},回复内容为:${JSON.stringify(response)}`)
|
||
return await this.reconnnect(reqUrl, params, headers, redirect_url, return_cookie, buffer,proxy)
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
async fetch(reqUrl, params, headers, redirect_url = false, return_cookie = false, buffer = 0, proxy = false) {
|
||
let data = Utils.objectToStr(params)
|
||
let url = reqUrl
|
||
if (!_.isEmpty(data)) {
|
||
url = reqUrl + "?" + data
|
||
}
|
||
let uri = new Uri(url);
|
||
let response;
|
||
if (redirect_url) {
|
||
response = await req(uri.toString(), {
|
||
method: "get", headers: headers, buffer: buffer, data: null, redirect: 2, proxy: proxy
|
||
})
|
||
} else {
|
||
response = await req(uri.toString(), {method: "get", headers: headers, buffer: buffer, data: null,proxy:proxy,timeout:10000});
|
||
}
|
||
if (response.code === 200 || response.code === 302 || response.code === 301 || return_cookie) {
|
||
return await this.getResponse(reqUrl, params, headers, redirect_url, return_cookie, buffer, response,proxy)
|
||
} else {
|
||
await this.jadeLog.error(`请求失败,失败原因为:状态码出错,请求url为:${uri},回复内容为:${JSON.stringify(response)}`)
|
||
return await this.reconnnect(reqUrl, params, headers, redirect_url, return_cookie, buffer, response,proxy)
|
||
}
|
||
}
|
||
|
||
async redirect(response) {
|
||
|
||
}
|
||
|
||
|
||
async post(reqUrl, params, headers, postType = "form",buffer = 0) {
|
||
let uri = new Uri(reqUrl);
|
||
let response = await req(uri.toString(), {
|
||
method: "post", headers: headers, data: params, postType: postType,buffer: buffer
|
||
});
|
||
if (response.code === 200 || response.code === undefined || response.code === 302) {
|
||
// 重定向
|
||
if (response.headers["location"] !== undefined) {
|
||
return await this.redirect(response)
|
||
} else if (!_.isEmpty(response.content)) {
|
||
this.reconnectTimes = 0
|
||
return response.content
|
||
} else {
|
||
return await this.postReconnect(reqUrl, params, headers,postType,buffer)
|
||
}
|
||
} else {
|
||
await this.jadeLog.error(`请求失败,请求url为:${reqUrl},回复内容为${JSON.stringify(response)}`)
|
||
return await this.postReconnect(reqUrl, params, headers,postType,buffer)
|
||
|
||
}
|
||
}
|
||
|
||
|
||
getName() {
|
||
return `🍥┃基础┃🍥`
|
||
}
|
||
|
||
getAppName() {
|
||
return `基础`
|
||
}
|
||
|
||
getJSName() {
|
||
return "base"
|
||
}
|
||
|
||
getType() {
|
||
return 3
|
||
}
|
||
|
||
async parseVodShortListFromDoc($) {
|
||
|
||
}
|
||
|
||
async parseVodShortListFromJson(obj) {
|
||
|
||
}
|
||
|
||
parseVodShortFromElement($, element) {
|
||
|
||
}
|
||
|
||
async parseVodShortListFromDocByCategory($) {
|
||
|
||
}
|
||
|
||
async getFilter($) {
|
||
|
||
}
|
||
|
||
async setClasses() {
|
||
|
||
}
|
||
|
||
async setFilterObj() {
|
||
|
||
}
|
||
|
||
async parseVodShortListFromDocBySearch($) {
|
||
return []
|
||
}
|
||
|
||
async parseVodDetailFromDoc($) {
|
||
|
||
}
|
||
|
||
async parseVodDetailfromJson(obj) {
|
||
|
||
}
|
||
|
||
|
||
async parseVodPlayFromUrl(flag, play_url) {
|
||
|
||
}
|
||
|
||
async parseVodPlayFromDoc(flag, $) {
|
||
|
||
}
|
||
|
||
async SpiderInit(cfg) {
|
||
try {
|
||
this.siteKey = cfg["skey"]
|
||
this.siteType = parseInt(cfg["stype"].toString())
|
||
let extObj = null;
|
||
if (typeof cfg.ext === "string") {
|
||
await this.jadeLog.info(`读取配置文件,ext为:${cfg.ext}`)
|
||
extObj = JSON.parse(cfg.ext)
|
||
|
||
} else if (typeof cfg.ext === "object") {
|
||
await this.jadeLog.info(`读取配置文件,所有参数为:${JSON.stringify(cfg)}`)
|
||
await this.jadeLog.info(`读取配置文件,ext为:${JSON.stringify(cfg.ext)}`)
|
||
extObj = cfg.ext
|
||
} else {
|
||
await this.jadeLog.error(`不支持的数据类型,数据类型为${typeof cfg.ext}`)
|
||
}
|
||
let boxType = extObj["box"]
|
||
extObj["CatOpenStatus"] = boxType === "CatOpen";
|
||
return extObj
|
||
} catch (e) {
|
||
await this.jadeLog.error("初始化失败,失败原因为:" + e.message)
|
||
return {"token": null, "CatOpenStatus": false, "code": 0}
|
||
}
|
||
|
||
}
|
||
|
||
async initCloud(token) {
|
||
await initCloud(token)
|
||
}
|
||
|
||
async spiderInit() {
|
||
}
|
||
|
||
async init(cfg) {
|
||
this.danmuSpider = new DanmuSpider()
|
||
this.cfgObj = await this.SpiderInit(cfg)
|
||
await this.jadeLog.debug(`初始化参数为:${JSON.stringify(cfg)}`)
|
||
this.catOpenStatus = this.cfgObj.CatOpenStatus
|
||
this.danmuStaus = this.cfgObj["danmu"] ?? this.danmuStaus
|
||
try {
|
||
if (await this.loadFilterAndClasses()) {
|
||
await this.jadeLog.debug(`读取缓存列表和二级菜单成功`)
|
||
} else {
|
||
await this.jadeLog.warning(`读取缓存列表和二级菜单失败`)
|
||
await this.writeFilterAndClasses()
|
||
}
|
||
} catch (e) {
|
||
await local.set(this.siteKey, "classes", JSON.stringify([]));
|
||
await local.set(this.siteKey, "filterObj", JSON.stringify({}));
|
||
await this.jadeLog.error("读取缓存失败,失败原因为:" + e)
|
||
}
|
||
this.jsBase = await js2Proxy(true, this.siteType, this.siteKey, 'img/', {});
|
||
this.douBanjsBase = await js2Proxy(true, this.siteType, this.siteKey, 'douban/', {});
|
||
this.baseProxy = await js2Proxy(true, this.siteType, this.siteKey, 'img/', this.getHeader());
|
||
this.videoProxy = await js2Proxy(true, this.siteType, this.siteKey, 'm3u8/', {});
|
||
this.detailProxy = await js2Proxy(true, this.siteType, this.siteKey, 'detail/', this.getHeader());
|
||
|
||
}
|
||
|
||
async loadFilterAndClasses() {
|
||
// 强制清空
|
||
// await local.set(this.siteKey, "classes", JSON.stringify([]));
|
||
// await local.set(this.siteKey, "filterObj", JSON.stringify({}));
|
||
this.classes = await this.getClassesCache()
|
||
this.filterObj = await this.getFiletObjCache()
|
||
if (this.classes.length > 0) {
|
||
return true
|
||
} else {
|
||
await local.set(this.siteKey, "classes", JSON.stringify([]));
|
||
await local.set(this.siteKey, "filterObj", JSON.stringify({}));
|
||
return false
|
||
}
|
||
}
|
||
|
||
async writeFilterAndClasses() {
|
||
if (this.catOpenStatus) {
|
||
this.classes.push({"type_name": "最近更新", "type_id": "最近更新"})
|
||
}
|
||
await this.setClasses()
|
||
await this.setFilterObj()
|
||
await local.set(this.siteKey, "classes", JSON.stringify(this.classes));
|
||
await local.set(this.siteKey, "filterObj", JSON.stringify(this.filterObj));
|
||
}
|
||
|
||
async getClassesCache() {
|
||
let cacheClasses = await local.get(this.siteKey, "classes")
|
||
if (!_.isEmpty(cacheClasses)) {
|
||
return JSON.parse(cacheClasses)
|
||
} else {
|
||
return this.classes
|
||
}
|
||
}
|
||
|
||
async getFiletObjCache() {
|
||
let cacheFilterObj = await local.get(this.siteKey, "filterObj")
|
||
if (!_.isEmpty(cacheFilterObj)) {
|
||
return JSON.parse(cacheFilterObj)
|
||
} else {
|
||
return this.filterObj
|
||
}
|
||
}
|
||
|
||
|
||
async setHome(filter) {
|
||
}
|
||
|
||
async home(filter) {
|
||
this.vodList = []
|
||
await this.jadeLog.info("正在解析首页类别", true)
|
||
await this.setHome(filter)
|
||
await this.jadeLog.debug(`首页类别内容为:${this.result.home(this.classes, [], this.filterObj)}`)
|
||
await this.jadeLog.info("首页类别解析完成", true)
|
||
return this.result.home(this.classes, [], this.filterObj)
|
||
}
|
||
|
||
async setHomeVod() {
|
||
|
||
}
|
||
|
||
async homeVod() {
|
||
await this.jadeLog.info("正在解析首页内容", true)
|
||
await this.setHomeVod()
|
||
await this.jadeLog.debug(`首页内容为:${this.result.homeVod(this.homeVodList)}`)
|
||
await this.jadeLog.info("首页内容解析完成", true)
|
||
return this.result.homeVod(this.homeVodList)
|
||
}
|
||
|
||
async setCategory(tid, pg, filter, extend) {
|
||
|
||
}
|
||
|
||
async category(tid, pg, filter, extend) {
|
||
this.page = parseInt(pg)
|
||
await this.jadeLog.info(`正在解析分类页面,tid = ${tid},pg = ${pg},filter = ${filter},extend = ${JSON.stringify(extend)}`)
|
||
if (tid === "最近更新") {
|
||
this.page = 0
|
||
return await this.homeVod()
|
||
} else {
|
||
try {
|
||
this.vodList = []
|
||
await this.setCategory(tid, pg, filter, extend)
|
||
await this.jadeLog.debug(`分类页面内容为:${this.result.category(this.vodList, this.page, this.count, this.limit, this.total)}`)
|
||
await this.jadeLog.info("分类页面解析完成", true)
|
||
return this.result.category(this.vodList, this.page, this.count, this.limit, this.total)
|
||
} catch (e) {
|
||
await this.jadeLog.error(`分类页解析失败,失败原因为:${e}`)
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
|
||
async setDetail(id) {
|
||
|
||
}
|
||
|
||
|
||
setEpisodeCache() {
|
||
// 记录每个播放链接的集数
|
||
let episodeObj = {
|
||
"vodDetail": this.vodDetail.to_dict(),
|
||
}
|
||
let vod_url_channels_list = this.vodDetail.vod_play_url.split("$$$")
|
||
for (const vodItemsStr of vod_url_channels_list) {
|
||
let vodItems = vodItemsStr.split("#")
|
||
for (const vodItem of vodItems) {
|
||
let episodeName = vodItem.split("$")[0].split(" ")[0]
|
||
let episodeUrl = vodItem.split("$")[1]
|
||
let matchers = episodeName.match(/\d+/g)
|
||
if (matchers !== null && matchers.length > 0) {
|
||
episodeName = matchers[0]
|
||
}
|
||
episodeObj[episodeUrl] = {"episodeName": episodeName, "episodeId": episodeName}
|
||
}
|
||
}
|
||
return episodeObj
|
||
}
|
||
|
||
async detail(id) {
|
||
this.vodDetail = new VodDetail();
|
||
await this.jadeLog.info(`正在获取详情页面,id为:${id}`)
|
||
try {
|
||
await this.setDetail(id)
|
||
await this.jadeLog.debug(`详情页面内容为:${this.result.detail(this.vodDetail)}`)
|
||
await this.jadeLog.info("详情页面解析完成", true)
|
||
this.vodDetail.vod_id = id
|
||
if (this.siteType === 3) {
|
||
this.episodeObj = this.setEpisodeCache()
|
||
}
|
||
|
||
return this.result.detail(this.vodDetail)
|
||
} catch (e) {
|
||
await this.jadeLog.error("详情界面获取失败,失败原因为:" + e)
|
||
}
|
||
|
||
}
|
||
|
||
async setPlay(flag, id, flags) {
|
||
this.playUrl = id
|
||
}
|
||
|
||
async setDanmu(id) {
|
||
await this.jadeLog.debug(`${JSON.stringify(this.episodeObj)}`)
|
||
let episodeId = this.episodeObj[id]
|
||
let vodDetail = JSON.parse(this.episodeObj["vodDetail"])
|
||
delete vodDetail.vod_content;
|
||
delete vodDetail.vod_play_from;
|
||
delete vodDetail.vod_play_url;
|
||
delete vodDetail.vod_pic;
|
||
await this.jadeLog.debug(`正在加载弹幕,视频详情为:${JSON.stringify(vodDetail)},集数:${JSON.stringify(this.episodeObj[id])}`)
|
||
//区分电影还是电视剧
|
||
return await this.danmuSpider.getDammu(vodDetail, episodeId)
|
||
}
|
||
|
||
async play(flag, id, flags) {
|
||
await this.jadeLog.info(`正在解析播放页面,flag:${flag},id:${id},flags:${flags}`, true)
|
||
try {
|
||
let return_result;
|
||
await this.setPlay(flag, id, flags)
|
||
if (this.playUrl["content"] !== undefined) {
|
||
return_result = this.result.playTxt(this.playUrl)
|
||
} else {
|
||
if (this.danmuStaus && !this.catOpenStatus) {
|
||
if (!_.isEmpty(this.danmuUrl)) {
|
||
await this.jadeLog.debug("播放详情页面有弹幕,所以不需要再查找弹幕")
|
||
return_result = this.result.danmu(this.danmuUrl).play(this.playUrl)
|
||
} else {
|
||
let danmuUrl;
|
||
try {
|
||
danmuUrl = await this.setDanmu(id)
|
||
} catch (e) {
|
||
await this.jadeLog.error(`弹幕加载失败,失败原因为:${e}`)
|
||
}
|
||
return_result = this.result.danmu(danmuUrl).play(this.playUrl)
|
||
}
|
||
|
||
} else {
|
||
await this.jadeLog.debug("不需要加载弹幕", true)
|
||
return_result = this.result.play(this.playUrl)
|
||
}
|
||
}
|
||
await this.jadeLog.info("播放页面解析完成", true)
|
||
await this.jadeLog.debug(`播放页面内容为:${return_result}`)
|
||
return return_result;
|
||
|
||
} catch (e) {
|
||
await this.jadeLog.error("解析播放页面出错,失败原因为:" + e)
|
||
}
|
||
|
||
}
|
||
|
||
async setSearch(wd, quick) {
|
||
|
||
}
|
||
|
||
async search(wd, quick) {
|
||
this.vodList = []
|
||
await this.jadeLog.info(`正在解析搜索页面,关键词为 = ${wd},quick = ${quick}`)
|
||
await this.setSearch(wd, quick,1)
|
||
if (this.vodList.length === 0) {
|
||
if (wd.indexOf(" ") > -1) {
|
||
await this.jadeLog.debug(`搜索关键词为:${wd},其中有空格,去除空格在搜索一次`)
|
||
await this.search(wd.replaceAll(" ", "").replaceAll("", ""), quick)
|
||
}
|
||
}
|
||
await this.jadeLog.debug(`搜索页面内容为:${this.result.search(this.vodList)}`)
|
||
await this.jadeLog.info("搜索页面解析完成", true)
|
||
return this.result.search(this.vodList)
|
||
}
|
||
|
||
async getImg(url, headers) {
|
||
let resp;
|
||
let vpn_proxy = headers["Proxy"] // 使用代理不需要加headers
|
||
if (_.isEmpty(headers)) {
|
||
headers = {Referer: url, 'User-Agent': Utils.CHROME}
|
||
}
|
||
resp = await req(url, {buffer: 2, headers: headers,proxy:vpn_proxy});
|
||
try {
|
||
//二进制文件是不能使用Base64编码格式的
|
||
Utils.base64Decode(resp.content)
|
||
if (vpn_proxy){
|
||
await this.jadeLog.error(`使用VPN代理,图片地址为:${url},headers:${JSON.stringify(headers)},代理失败,准备重连,输出内容为:${JSON.stringify(resp)}`)
|
||
}else {
|
||
await this.jadeLog.error(`使用普通代理,图片地址为:${url},headers:${JSON.stringify(headers)},代理失败,准备重连,输出内容为:${JSON.stringify(resp)}`)
|
||
}
|
||
if (this.reconnectTimes < this.maxReconnectTimes){
|
||
this.reconnectTimes = this.reconnectTimes + 1
|
||
return await this.getImg(url,headers)
|
||
}else{
|
||
return {"code": 500, "headers": headers, "content": "加载失败"}
|
||
}
|
||
} catch (e) {
|
||
await this.jadeLog.debug("图片代理成功", true)
|
||
this.reconnectTimes = 0
|
||
return resp
|
||
}
|
||
}
|
||
|
||
async proxy(segments, headers) {
|
||
await this.jadeLog.debug(`正在设置反向代理 segments = ${segments.join(",")},headers = ${JSON.stringify(headers)}`)
|
||
let what = segments[0];
|
||
let url = Utils.base64Decode(segments[1]);
|
||
await this.jadeLog.debug(`反向代理参数为:${url}`)
|
||
if (what === 'img') {
|
||
await this.jadeLog.debug("通过代理获取图片", true)
|
||
let resp = await this.getImg(url, headers)
|
||
return JSON.stringify({
|
||
code: resp.code, buffer: 2, content: resp.content, headers: resp.headers,
|
||
});
|
||
} else if (what === "douban") {
|
||
let vod_list = await this.doubanSearch(url)
|
||
if (vod_list !== null) {
|
||
let vod_pic = vod_list[0].vod_pic
|
||
let resp;
|
||
if (!_.isEmpty(headers)) {
|
||
resp = await req(vod_pic, {
|
||
buffer: 2, headers: headers
|
||
});
|
||
} else {
|
||
resp = await req(vod_pic, {
|
||
buffer: 2, headers: {
|
||
Referer: vod_pic, 'User-Agent': Utils.CHROME,
|
||
},
|
||
});
|
||
}
|
||
return JSON.stringify({
|
||
code: resp.code, buffer: 2, content: resp.content, headers: resp.headers,
|
||
});
|
||
}
|
||
} else if (what === "m3u8") {
|
||
let content;
|
||
|
||
if (!_.isEmpty(headers)) {
|
||
content = await this.fetch(url, null, headers, false, false, 2)
|
||
} else {
|
||
content = await this.fetch(url, null, {"Referer": url, 'User-Agent': Utils.CHROME}, false, false, 2)
|
||
}
|
||
await this.jadeLog.debug(`m3u8返回内容为:${Utils.base64Decode(content)}`)
|
||
if (!_.isEmpty(content)) {
|
||
return JSON.stringify({
|
||
code: 200, buffer: 2, content: content, headers: {},
|
||
});
|
||
} else {
|
||
return JSON.stringify({
|
||
code: 500, buffer: 2, content: content, headers: {},
|
||
})
|
||
|
||
}
|
||
|
||
} else if (what === 'hls') {
|
||
function hlsHeader(data, hls) {
|
||
let hlsHeaders = {};
|
||
if (data.headers['content-length']) {
|
||
Object.assign(hlsHeaders, data.headers, {'content-length': hls.length.toString()});
|
||
} else {
|
||
Object.assign(hlsHeaders, data.headers);
|
||
}
|
||
delete hlsHeaders['transfer-encoding'];
|
||
if (hlsHeaders['content-encoding'] == 'gzip') {
|
||
delete hlsHeaders['content-encoding'];
|
||
}
|
||
return hlsHeaders;
|
||
}
|
||
|
||
const hlsData = await hlsCache(url, headers);
|
||
if (hlsData.variants) {
|
||
// variants -> variants -> .... ignore
|
||
const hls = HLS.stringify(hlsData.plist);
|
||
return {
|
||
code: hlsData.code, content: hls, headers: hlsHeader(hlsData, hls),
|
||
};
|
||
} else {
|
||
const hls = HLS.stringify(hlsData.plist, (segment) => {
|
||
return js2Proxy(false, this.siteType, this.siteKey, 'ts/' + encodeURIComponent(hlsData.key + '/' + segment.mediaSequenceNumber.toString()), headers);
|
||
});
|
||
return {
|
||
code: hlsData.code, content: hls, headers: hlsHeader(hlsData, hls),
|
||
};
|
||
}
|
||
} else if (what === 'ts') {
|
||
const info = url.split('/');
|
||
const hlsKey = info[0];
|
||
const segIdx = parseInt(info[1]);
|
||
return await tsCache(hlsKey, segIdx, headers);
|
||
} else if (what === "detail") {
|
||
let $ = await this.getHtml(this.siteUrl + url)
|
||
let vodDetail = await this.parseVodDetailFromDoc($)
|
||
let resp = await this.getImg(vodDetail.vod_pic, headers)
|
||
return JSON.stringify({
|
||
code: resp.code, buffer: 2, content: resp.content, headers: resp.headers,
|
||
});
|
||
} else {
|
||
return JSON.stringify({
|
||
code: 500, content: '',
|
||
});
|
||
}
|
||
}
|
||
|
||
|
||
getSearchHeader() {
|
||
const UserAgents = ["api-client/1 com.douban.frodo/7.22.0.beta9(231) Android/23 product/Mate 40 vendor/HUAWEI model/Mate 40 brand/HUAWEI rom/android network/wifi platform/AndroidPad", "api-client/1 com.douban.frodo/7.18.0(230) Android/22 product/MI 9 vendor/Xiaomi model/MI 9 brand/Android rom/miui6 network/wifi platform/mobile nd/1", "api-client/1 com.douban.frodo/7.1.0(205) Android/29 product/perseus vendor/Xiaomi model/Mi MIX 3 rom/miui6 network/wifi platform/mobile nd/1", "api-client/1 com.douban.frodo/7.3.0(207) Android/22 product/MI 9 vendor/Xiaomi model/MI 9 brand/Android rom/miui6 network/wifi platform/mobile nd/1"]
|
||
let randomNumber = Math.floor(Math.random() * UserAgents.length); // 生成一个介于0到9之间的随机整数
|
||
return {
|
||
'User-Agent': UserAgents[randomNumber]
|
||
|
||
}
|
||
}
|
||
|
||
async parseDoubanVodShortListFromJson(obj) {
|
||
let vod_list = []
|
||
for (const item of obj) {
|
||
let vod_short = new VodShort()
|
||
vod_short.vod_id = "msearch:" + item["id"]
|
||
if (item["title"] === undefined) {
|
||
vod_short.vod_name = item["target"]["title"]
|
||
} else {
|
||
vod_short.vod_name = item["title"]
|
||
}
|
||
if (item["pic"] === undefined) {
|
||
vod_short.vod_pic = item["target"]["cover_url"]
|
||
} else {
|
||
vod_short.vod_pic = item["pic"]["normal"]
|
||
}
|
||
if (item["rating"] === undefined) {
|
||
vod_short.vod_remarks = "评分:" + item["target"]["rating"]["value"].toString()
|
||
} else {
|
||
vod_short.vod_remarks = "评分:" + item["rating"]["value"].toString()
|
||
}
|
||
vod_list.push(vod_short);
|
||
}
|
||
return vod_list
|
||
}
|
||
|
||
sign(url, ts, method = 'GET') {
|
||
let _api_secret_key = "bf7dddc7c9cfe6f7"
|
||
let url_path = "%2F" + url.split("/").slice(3).join("%2F")
|
||
let raw_sign = [method.toLocaleUpperCase(), url_path, ts.toString()].join("&")
|
||
return CryptoJS.HmacSHA1(raw_sign, _api_secret_key).toString(CryptoJS.enc.Base64)
|
||
}
|
||
|
||
async doubanSearch(wd) {
|
||
try {
|
||
let _api_url = "https://frodo.douban.com/api/v2"
|
||
let _api_key = "0dad551ec0f84ed02907ff5c42e8ec70"
|
||
let url = _api_url + "/search/movie"
|
||
let date = new Date()
|
||
let ts = date.getFullYear().toString() + (date.getMonth() + 1).toString() + date.getDate().toString()
|
||
let params = {
|
||
'_sig': this.sign(url, ts),
|
||
'_ts': ts,
|
||
'apiKey': _api_key,
|
||
'count': 20,
|
||
'os_rom': 'android',
|
||
'q': encodeURIComponent(wd),
|
||
'start': 0
|
||
}
|
||
let content = await this.fetch(url, params, this.getSearchHeader())
|
||
if (!_.isEmpty(content)) {
|
||
let content_json = JSON.parse(content)
|
||
await this.jadeLog.debug(`豆瓣搜索结果:${content}`)
|
||
return await this.parseDoubanVodShortListFromJson(content_json["items"])
|
||
}
|
||
return null
|
||
|
||
} catch (e) {
|
||
await this.jadeLog.error("反向代理出错,失败原因为:" + e)
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
|
||
export {Spider, Result}
|