RSSHub/lib/v2/odaily/post.js

69 lines
2.0 KiB
JavaScript

const got = require('@/utils/got');
const cheerio = require('cheerio');
const timezone = require('@/utils/timezone');
const { parseDate } = require('@/utils/parse-date');
const { rootUrl } = require('./utils');
const titles = {
280: '最新',
333: '新品',
331: 'DeFi',
334: 'NFT',
332: '存储',
330: '波卡',
297: '行情',
296: '活动',
};
module.exports = async (ctx) => {
const id = ctx.params.id ?? '280';
const currentUrl = `${rootUrl}/api/pp/api/app-front/feed-stream?feed_id=${id}&b_id=&per_page=${ctx.query.limit ?? 25}`;
const response = await got({
method: 'get',
url: currentUrl,
});
let items = response.data.data.items
.map((item) => ({
title: item.title,
author: item.user.name,
type: item.entity_type,
description: `<p>${item.summary}</p>`,
link: `${rootUrl}/${item.entity_type}/${item.entity_id}`,
pubDate: timezone(parseDate(item.published_at), +8),
}))
.filter((item) => item.type !== 'newsflash');
items = await Promise.all(
items.map(
async (item) =>
await ctx.cache.tryGet(item.link, async () => {
const detailResponse = await got({
method: 'get',
url: item.link,
});
const content = cheerio.load(detailResponse.data.match(item.type === 'post' ? /"content":"(.*)","extraction_tags":/ : /"description":"(.*?)","cover":/)[1]);
content('img').each(function () {
content(this).attr('src', content(this).attr('src').replace(/\\"/g, ''));
});
item.description = content.html();
delete item.type;
return item;
})
)
);
ctx.state.data = {
title: `${titles[id]} - Odaily星球日报`,
link: rootUrl,
item: items,
};
};