89 lines
2.4 KiB
TypeScript
89 lines
2.4 KiB
TypeScript
import prisma from '@prisma/prisma';
|
|
import axios from 'axios';
|
|
import { formatApiResponse } from '@utils/formatApiResponse';
|
|
import {
|
|
INTERNAL_SERVER_ERROR,
|
|
STATUS_INTERNAL_SERVER_ERROR,
|
|
STATUS_OK,
|
|
STATUS_UNAUTHORIZED
|
|
} from '@utils/statusCodes';
|
|
import { getSingleNews, getTopNews } from '@utils/urls';
|
|
import { NewsDatabaseSchema, NewsDatabaseType } from '@utils/validationSchemas';
|
|
import { NextRequest } from 'next/server';
|
|
|
|
export async function GET(request: NextRequest) {
|
|
if (
|
|
request.headers.get('Authorization') !== `Bearer ${process.env.CRON_SECRET}`
|
|
) {
|
|
return formatApiResponse(STATUS_UNAUTHORIZED, 'Unauthorized');
|
|
}
|
|
|
|
try {
|
|
const { data: topStories } = await axios.get<number[]>(getTopNews, {
|
|
headers: {
|
|
'Cache-Control': 'no-store'
|
|
}
|
|
});
|
|
|
|
console.info(`Top stories ids: ${topStories}`);
|
|
|
|
const newsPromises = topStories
|
|
.slice(0, Number(process.env.NEWS_LIMIT))
|
|
.map(id => axios.get<NewsDatabaseType>(getSingleNews(id)));
|
|
|
|
const newsResponses = await Promise.all(newsPromises);
|
|
const news: NewsDatabaseType[] = newsResponses.map(
|
|
response => response.data
|
|
);
|
|
|
|
const upsertPromises = news.map(async getSingleNews => {
|
|
const validation = NewsDatabaseSchema.safeParse(getSingleNews);
|
|
|
|
if (validation.success) {
|
|
console.info(
|
|
`Validated news N° ${getSingleNews.id} - ${getSingleNews.title}`
|
|
);
|
|
const result = await prisma.news.upsert({
|
|
create: {
|
|
...validation.data,
|
|
id: getSingleNews.id
|
|
},
|
|
update: {
|
|
...validation.data
|
|
},
|
|
where: {
|
|
id: getSingleNews.id
|
|
}
|
|
});
|
|
|
|
console.info(
|
|
`Imported N° ${getSingleNews.id} - ${getSingleNews.title}`
|
|
);
|
|
|
|
return result;
|
|
} else {
|
|
console.error(validation.error);
|
|
}
|
|
});
|
|
|
|
const result = await Promise.all(upsertPromises);
|
|
|
|
console.info(`Imported ${result.length} news.`);
|
|
|
|
return formatApiResponse(
|
|
STATUS_OK,
|
|
`Imported ${newsPromises.length} news.`
|
|
);
|
|
} catch (error) {
|
|
if (axios.isAxiosError(error)) {
|
|
console.error('Axios error:', error.response?.data || error.message);
|
|
} else {
|
|
console.error('Error:', error);
|
|
}
|
|
return formatApiResponse(
|
|
STATUS_INTERNAL_SERVER_ERROR,
|
|
INTERNAL_SERVER_ERROR
|
|
);
|
|
}
|
|
}
|