Stellar主题博客增加支持tg频道时间线

addEventListener('fetch', event => {
    event.respondWith(TelgramChannelStarter(event.request))
})

const ChannelNameList = ['thun888sthinks', 'Thun888sDraftArticles', 'thun888sgrocery'];
const deniedRegion = [""];
const baseproxyurl = "https://get-tg-channel-api.hzchu.top/?proxy="

async function TelgramChannelStarter(request) {
    const url = new URL(request.url);
    const Region = request.headers.get('cf-ipcountry');
    let denied = deniedRegion.includes(Region);
    const proxyUrl = url.searchParams.get('proxy');
    let mid = parseInt(url.searchParams.get('mid'));
    let cid = parseInt(url.searchParams.get('cid')) || 0;
    let tagname = url.searchParams.get('tag') || "DefaultTag";
    let showtag = url.searchParams.get('showtag') || "true";
    let usemd = url.searchParams.get('usemd') || "true";
    usemd = usemd === 'true';
    
showtag = showtag === 'true';
    let showview = url.searchParams.get('showview');
    showview = showview === 'true';

    let ChannelName = ChannelNameList[cid]

    if (!!proxyUrl) {
        if (!(proxyUrl.match(/\:\/\/(.*?)\.telegram\.org/g) || proxyUrl.match(/\:\/\/(.*)\.cdn\-telegram\.org/g) || proxyUrl.match(/\:\/\/telegram\.org/g))) {
            return new Response('Proxy URL is not valid');
        }
        return fetch(proxyUrl);
    }

const startbefore = url.searchParams.get('startbefore');
    const ChannelUrl = new URL(`https://t.me/s/${ChannelName}`);

    if (!!startbefore) {
        ChannelUrl.searchParams.set('before', startbefore);
    }

    let getDataFromTelegram = await fetch(ChannelUrl, {
        "headers": {
            "x-requested-with": "XMLHttpRequest"
        },
        "method": "POST"
    }).then(res => res.text())
        .then(res => res
            .replace(/\\n/g, '')
            .replace(/\\(.)/g, '$1')
            .replace(/(^\"|\"$)/g, '')
        );

    if (url.searchParams.get('rawHtml') === 'true') {
        return new Response(getDataFromTelegram, {
            headers: {
                "content-type": "text/html;charset=UTF-8",
                "Access-Control-Allow-Origin": "*"
            }
        });
    }

    const nextBeforeMatch = [...getDataFromTelegram.matchAll(/data-before="([0-9]+)"/g)];
    const nextBefore = nextBeforeMatch.length > 0 ? Number(nextBeforeMatch[0][1]) : 0;
    const ChannelMessages = ElementSpliter(getDataFromTelegram, '<div class="tgme_widget_message_wrap');

    const ChannelMessageData = {};
    ChannelMessages.forEach(ChannelMessage => {
        const MessageIdMatch = ChannelMessage.match(new RegExp(`data-post\="${ChannelName}\/(\\d+)"`));
        if (MessageIdMatch) {
            const MessageId = MessageIdMatch[1];

            // 确保消息ID是唯一的，并且没有重复
            if (!ChannelMessageData.hasOwnProperty(MessageId)) {
                const MessageTextMatch = ChannelMessage.match(/<div class="tgme_widget_message_text js-message_text"(.+?)<\/div>/s);
                const MessagePhotoMatches = [...ChannelMessage.matchAll(/background-image:url\('(.+?)'\)/g)];
                const MessageTimeMatch = ChannelMessage.match(/datetime="(.+?)"/);
                const MessageViewsMatch = ChannelMessage.match(/<span class="tgme_widget_message_views">\s*(\d+)\s*<\/span>/);

                let msg_views = MessageViewsMatch ? MessageViewsMatch[1] : "0";
                let msg_time = MessageTimeMatch ? Math.round(new Date(MessageTimeMatch[1]).getTime() / 1000) : Math.round(new Date().getTime() / 1000);



                let msg_text = MessageTextMatch[0].replace(/<div (.*?)>/g, '').replace(/<\/div>/g, '');
                msg_text = msg_text.replace(/href=\"\?q=(.+?)\"/g, function (match, p1) {
                    return 'href="https://t.me/s/' + ChannelName + '/' + p1 + '"';
                });
                // emoji处理
                msg_text = msg_text.replace(/<i class="emoji" style="background-image:url\(\'\/\/telegram.org\/img\/emoji\/40\/.+?\)\">/g, '')
                // msg_text = msg_text.replace(/<i class="emoji".*?url\(\'(.*?)\'\).*?<\/i>/g, function(match, p1) {
                //     // 此处代码结合stellar样式，但不太理想
                //     return `<span class="tag-plugin emoji"><img src="${baseproxyurl}https:${p1}"></span>`;
                //   });

                // 是否显示标签
                if (!showtag) {
                    msg_text = msg_text.replace(/<a href="https:\/\/t\.me\/s\/.+?\/%23.+?">#[^<]+<\/a>/g, '');
                }

                // 是否显示浏览量
                if (showview) {
                    msg_text = msg_text + '<br>(👀:' + msg_views + ')'
                }

                // 是否使用Markdown
                if (usemd) {
                    // 将<a>标签替换为md格式
                    msg_text = msg_text.replace(/<a href=\"(.*?)\">(.*?)<\/a>/g, (match, $1, $2) => {
                        if ($2.startsWith('#')) {
                            return `[${$2}](${$1})`;
                        } else {
                            return $2;
                        }
                    });
                    // 将&#33;替换为!
                    msg_text = msg_text.replace(/&#33;/g, '!');
                    // 将&#37;替换为%
                    msg_text = msg_text.replace(/&#37;/g, '%');
                    // 将<br/> 替换为换行
                    msg_text = msg_text.replace(/<br\/>/g, '\n');
                    // 将&lt;替换为<
                    msg_text = msg_text.replace(/&lt;/g, '<');
                    // 将&gt;替换为>
                    msg_text = msg_text.replace(/&gt;/g, '>');
                    // 将&amp;替换为&
                    msg_text = msg_text.replace(/&amp;/g, '&');
                    // 将&quot;	替换为"
                    msg_text = msg_text.replace(/&quot;/g, '"');
                }

                if (MessageTextMatch && (!denied && MessageTextMatch[0].includes('#' + tagname))) {
                    let resourceList = MessagePhotoMatches.filter(m => !m[1].includes('//telegram.org/img/emoji/'))
                        .map(m => ({
                            "createdTs": msg_time,
                            "externalLink": baseproxyurl + m[1],
                            "type": "image/jpeg",
                            "size": 0
                        }));


ChannelMessageData[MessageId] = {
                        id: MessageId,
                        name: MessageId,
                        rowStatus: "NORMAL",
                        creatorId: 1,
                        content: msg_text,
                        createdTs: msg_time,
                        updatedTs: msg_time,
                        displayTs: msg_time,
                        visibility: "PUBLIC",
                        pinned: false,
                        creatorName: ChannelName,
                        creatorUsername: ChannelName,
                        resourceList: resourceList,
                        relationList: [],
                        views: msg_views,
                    };
                }
            }
        }
    });


// 如果设置了limit参数，则按照时间倒序排序，并限制输出的消息数量
    let sortedMessages = Object.values(ChannelMessageData).sort((a, b) => b.createdTs - a.createdTs);
    const messagesCountParam = url.searchParams.get('limit');
    const messagesCount = messagesCountParam ? parseInt(messagesCountParam, 10) : sortedMessages.length;
    sortedMessages = sortedMessages.slice(0, messagesCount);

    return new Response(JSON.stringify(sortedMessages), {
        headers: {
            "content-type": "application/json;charset=UTF-8",
            "Access-Control-Allow-Origin": "*"
        }
    });
}



const ElementSpliter = (html, StartElement) => {
    const Elements = []
    const ElementSpliterOnce = (html, StartElement) => {
        let ElementName = [...StartElement.matchAll(/\<(?<ELENAME>[a-zA-Z0-9]+)\s/g)][0].groups.ELENAME
        let ElementContent = StartElement
        for (let Start = html.indexOf(StartElement) + StartElement.length; Start < html.length; Start++) {
            ElementContent += html[Start]
            if (ElementContent.endsWith(`</${ElementName}>`)) {
                const PrefixCount = Object.keys(ElementContent.match(new RegExp(`\<${ElementName}`, 'g'))).length
                const SuffixCount = Object.keys(ElementContent.match(new RegExp(`\<\/${ElementName}(.*?)>`, 'g')) || []).length
                if (
                    PrefixCount === SuffixCount &&
                    PrefixCount !== 0
                ) {
                    return ElementContent
                }
            }

        }
    }
    while (1) {
        if (html.indexOf(StartElement) === -1) break
        const SplitOnce = ElementSpliterOnce(html, StartElement)
        Elements.push(SplitOnce)
        html = html.replace(SplitOnce, '')
    }
    return Elements
}

const ChannelNameList = ['thun888sthinks']; //频道ID，可添加多个
const deniedRegion = [""]; 屏蔽区域，如CN,US
const baseproxyurl="https://get-tg-channel-api.hzchu.top/?proxy=" //将中间域名替换为你为worker绑定的域名