Compare commits

...

2 Commits

Author SHA1 Message Date
e11d941a93 Update embed style to reflect native embeds
All checks were successful
Build and Push Container / build (push) Successful in 49s
2025-04-30 19:36:01 +10:00
9eb25f706e Handle network requests failing more gracefully 2025-04-30 19:26:25 +10:00
3 changed files with 33 additions and 60 deletions

View File

@ -1,6 +1,5 @@
import { getAllChapters, getLatestChapter } from './mangadex/chapters';
import { getManga } from './mangadex/manga';
import { getCover } from './mangadex/cover';
import { lazyKv } from './db/lazyKv';
import { sendWebhook } from './utils/webhook';
import { ChapterId } from './types';
@ -22,34 +21,37 @@ void (async () => {
await getMangaToFetch(config);
for (const mangaId of uniqueMangaIds) {
const lastChapterId = await mangaHistory.get<ChapterId>(mangaId);
try {
const lastChapterId = await mangaHistory.get<ChapterId>(mangaId);
const manga = await getManga(mangaId, userAgent);
const chapters = await getAllChapters(mangaId, userAgent);
const latestChapter = getLatestChapter(chapters);
const cover = await getCover(manga, userAgent);
const title = getMangaTitle(manga);
const manga = await getManga(mangaId, userAgent);
const chapters = await getAllChapters(mangaId, userAgent);
const latestChapter = getLatestChapter(chapters);
const title = getMangaTitle(manga);
if (lastChapterId !== latestChapter.id) {
console.log('Update found for manga:', title);
if (lastChapterId !== latestChapter.id) {
console.log('Update found for manga:', title);
const webhooksForManga = mangaIdsToWebhooks[mangaId];
const webhooksForManga = mangaIdsToWebhooks[mangaId];
await Promise.all(
webhooksForManga.map(
async (webhookUrl) =>
await sendWebhook({
webhookUrl,
manga,
latestChapter,
cover,
}),
),
);
await Promise.all(
webhooksForManga.map(
async (webhookUrl) =>
await sendWebhook({
webhookUrl,
manga,
latestChapter,
}),
),
);
await mangaHistory.set(mangaId, latestChapter.id);
} else {
console.log('No Updates found for manga:', title);
await mangaHistory.set(mangaId, latestChapter.id);
} else {
console.log('No Updates found for manga:', title);
}
} catch (err) {
console.error(`Failed to fetch ${mangaId}!`);
console.error(err);
}
}
};

View File

@ -1,25 +0,0 @@
import axios from 'axios';
import { Manga } from '../types';
export const getCover = async (
manga: Manga,
userAgent: string,
): Promise<string> => {
const coverId = Object.values(manga.relationships).find(
(relationship) => relationship.type === 'cover_art',
)?.id;
if (!coverId) {
return '';
}
const response = await axios.get<{
data: { attributes: { fileName: string } };
}>(`https://api.mangadex.org/cover/${coverId}`, {
headers: {
'User-Agent': userAgent,
},
});
return `https://mangadex.org/covers/${manga.id}/${response.data.data.attributes.fileName}`;
};

View File

@ -7,25 +7,21 @@ export const sendWebhook = async (args: {
webhookUrl: string;
manga: Manga;
latestChapter: Chapter;
cover: string;
}) => {
const { webhookUrl, manga, latestChapter, cover } = args;
const { webhookUrl, manga, latestChapter } = args;
const title = getMangaTitle(manga);
await axios.post(webhookUrl, {
username: 'Manga Updates',
avatar_url: 'https://assets.pfy.ch/icons/manga.png',
content: `[New chapter for ${title}](https://mangadex.org/chapter/${latestChapter.id})`,
avatar_url: 'https://mangadex.org/pwa/icons/icon-180.png',
embeds: [
{
author: {
icon_url: 'https://assets.pfy.ch/icons/manga.png',
name: title,
url: `https://mangadex.org/chapter/${latestChapter.id}`,
image: {
url: `https://og.mangadex.org/og-image/chapter/${latestChapter.id}`,
},
thumbnail: {
url: cover,
},
description: `Chapter ${latestChapter.attributes.chapter}: "${latestChapter.attributes.title}"`,
title: `${title}`,
description: ` Ch. ${latestChapter.attributes.chapter} - ${latestChapter.attributes.title} `,
},
],
});