zxz/JN/CATJS/js/alipansou.js

/*
* @File     : alipansou.js
* @Author   : jade
* @Date     : 2024/1/18 13:20
* @Email    : jadehh@1ive.com
* @Software : Samples
* @Desc     : 猫狸盘搜
*/

import {_, load} from "../lib/cat.js";
import {Spider} from "./spider.js";
import { detailContent,initCloud,playContent,getHeaders } from "../lib/cloud.js";
import {VodDetail, VodShort} from "../lib/vod.js";
import * as Utils from "../lib/utils.js";

class GitCafeSpider extends Spider {
    constructor() {
        super();
        this.siteUrl = "https://www.alipansou.com"
    }
    getHeaders(id) {
        let headers = this.getHeader()
        headers["Referer"] = this.siteUrl + id
        headers["_bid"] = "6d14a5dd6c07980d9dc089a693805ad8"
        headers["Cookie"] = "_egg=70463dec0ec843b682ce18c36ec9ce91e"
        return headers
    }


    getName() {
        return "😸┃阿里猫狸┃😸"
    }

    getAppName() {
        return "阿里猫狸"
    }
    getJSName() {
        return "alipansou"
    }

    getType() {
        return 3
    }

    getHeader() {
        return {
            "User-Agent":Utils.CHROME,
            "Connection": "keep-alive"
        }
    }

    async getContentHtml() {
        let html = await this.fetch(this.siteUrl, null, this.getHeader())
        if (!_.isEmpty(html)) {
            return load(html)
        }
    }

    async spiderInit() {
        this.content_html = await this.getContentHtml()
    }

    async init(cfg) {
        await this.spiderInit()
        await super.init(cfg);
        await initCloud(this.cfgObj);
    }

    async parseClassFromDoc($) {
        let tap_elemets = $($("[id=\"app\"]")[0]).find("van-tab")
        let index = 0
        for (const tap_element of tap_elemets) {
            let type_name = tap_element.attribs["title"]
            if (type_name.indexOf("热搜") === -1 && type_name !== "游戏" && type_name !== "小说") {
                this.classes.push({"type_name": type_name, "type_id": index})
            }
            index = index + 1
        }
    }

    async parseVodShortListFromDoc(doc) {
        let vod_list = []
        let elements = this.content_html(doc).find("a")
        for (const element of elements) {
            let vodShort = new VodShort()
            vodShort.vod_id = element.attribs["href"]
            vodShort.vod_name = this.content_html(element).text().split(".").slice(-1)[0]
            vod_list.push(vodShort)
        }
        return vod_list
    }

    async getAliUrl(id) {
        let url = this.siteUrl + id.replace("/s/", "/cv/")
        let headers = this.getHeaders(id)
        let content = await req(url,{postType:"get",headers:headers,redirect:2})
        await this.jadeLog.debug(`回复内容为:${JSON.stringify(content)}`)
        // let url = await this.fetch(this.siteUrl + id.replace("/s/", "/cv/"), null, headers, true)
        return content.headers.location
    }

    async parseVodDetailfromJson(obj) {
        let vodDetail = new VodDetail();
        vodDetail.vod_name = obj["name"]
        vodDetail.vod_remarks = obj["remarks"]
        let ali_url = await this.getAliUrl(obj["id"])
        await this.jadeLog.debug(`阿里分享链接为:${ali_url}`)
        if (!_.isEmpty(ali_url)) {
            let playVod = await detailContent([ali_url],vodDetail.type_name)
            vodDetail.vod_play_from = _.keys(playVod).join('$$$');
            vodDetail.vod_play_url = _.values(playVod).join('$$$');
        }
        return vodDetail
    }


    async parseVodShortListFromDocBySearch($) {
        let elements = $($($("[id=\"app\"]")[0]).find("van-row")).find("a")
        let vod_list = []
        for (const element of elements) {
            let id = element.attribs["href"]
            let matches = id.match(/(\/s\/[^"])/);
            if (!_.isEmpty(matches) && id.indexOf("https") === -1) {
                let text = $(element).text().replaceAll("\n", "").replaceAll(" ", "")
                if (text.indexOf("时间") > -1 && text.indexOf("文件夹") > -1) {
                    let textList = text.split("时间")
                    let vodShort = new VodShort()
                    vodShort.vod_name = textList[0]
                    vodShort.vod_remarks = textList[1].split("格式")[0].replaceAll(":", "").replaceAll(" ", "").replaceAll("", "").replaceAll(" ", "")
                    vodShort.vod_id = JSON.stringify({
                        "name": vodShort.vod_name, "remarks": vodShort.vod_remarks, "id": id
                    })
                    vod_list.push(vodShort)
                }
            }
        }
        return vod_list
    }

    async setClasses() {
        await this.parseClassFromDoc(this.content_html)
    }


    async setHomeVod() {
        let tap_elemets = this.content_html(this.content_html("[id=\"app\"]")[0]).find("van-tab")
        this.homeVodList = await this.parseVodShortListFromDoc(tap_elemets[0])
    }


    async setDetail(id) {
        if (id.indexOf("search") > -1) {
            let url = this.siteUrl + "/search"
            let params = {"k":decodeURIComponent(id.split("search?k=").slice(-1)[0]) }
            let html = await this.fetch(url, params, this.getHeader())
            if (!_.isEmpty(html)) {
                let $ = load(html)
                let vod_list = await this.parseVodShortListFromDocBySearch($)
                if (vod_list.length > 0) {
                    id = vod_list[0]["vod_id"]
                } else {
                    id = ""
                }
            }
        }
        if (!_.isEmpty(id)) {
            let json_content = JSON.parse(id)
            this.vodDetail = await this.parseVodDetailfromJson(json_content)
        }

    }

    async setCategory(tid, pg, filter, extend) {
        let tap_elemets = this.content_html(this.content_html("[id=\"app\"]")[0]).find("van-tab")
        this.vodList = await this.parseVodShortListFromDoc(tap_elemets[parseInt(tid)])
    }

    async setSearch(wd, quick) {
        let url = this.siteUrl + "/search"
        let params = {"k": wd}
        let html = await this.fetch(url, params, this.getHeader())
        if (!_.isEmpty(html)) {
            let $ = load(html)
            this.vodList = await this.parseVodShortListFromDocBySearch($)
        }
    }

    async setPlay(flag, id, flags) {
        this.playUrl = await playContent(flag, id, flags);
        this.result.setHeader(getHeaders(flag))
    }
}

let spider = new GitCafeSpider()

async function init(cfg) {
    await spider.init(cfg)
}

async function home(filter) {
    return await spider.home(filter)
}

async function homeVod() {
    return await spider.homeVod()
}

async function category(tid, pg, filter, extend) {
    return await spider.category(tid, pg, filter, extend)
}

async function detail(id) {
    return await spider.detail(id)
}

async function play(flag, id, flags) {
    return await spider.play(flag, id, flags)
}

async function search(wd, quick) {
    return await spider.search(wd, quick)
}

export function __jsEvalReturn() {
    return {
        init: init, home: home, homeVod: homeVod, category: category, detail: detail, play: play, search: search,
    };
}
export {spider}