dvelo/mhsf-dev
1
0
Fork 0
mirror of https://github.com/DeveloLongScript/MHSF.git synced 2026-05-07 18:34:59 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: inngest is no longer broken i think

Browse Source
This commit is contained in:
dvelo 2024-08-13 17:24:58 -05:00
parent 77d5d6d1da
commit 579ce15832
1 changed files with 42 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/pages/api/inngest.ts
View File

@ -16,7 +16,8 @@ export default serve({
async ({ event, step }) => { async ({ event, step }) => {
const mongo = new MongoClient(process.env.MONGO_DB as string); const mongo = new MongoClient(process.env.MONGO_DB as string);
try { try {
const mh = await ( const mh = await step.run("grab-servers-from-api", async () => {
return await (
await fetch("https://api.minehut.com/servers", { await fetch("https://api.minehut.com/servers", {
headers: { headers: {
accept: "application/json", accept: "application/json",
@ -36,6 +37,7 @@ export default serve({
method: "GET", method: "GET",
}) })
).json(); ).json();
});
const mha = mongo.db("mhsf").collection("mh"); const mha = mongo.db("mhsf").collection("mh");
const meta = mongo.db("mhsf").collection("meta"); const meta = mongo.db("mhsf").collection("meta");
@ -44,9 +46,10 @@ export default serve({
await mha.insertOne({ await mha.insertOne({
total_players: mh.total_players, total_players: mh.total_players,
total_servers: mh.total_servers, total_servers: mh.total_servers,
unix: Date.now(), date: new Date(),
}); });
const completed = await step.run("listing-servers", async () => {
mh.servers.forEach(async (server: OnlineServer, i: number) => { mh.servers.forEach(async (server: OnlineServer, i: number) => {
const serverFavoritesObject = await meta.findOne({ const serverFavoritesObject = await meta.findOne({
server: server.name, server: server.name,
@ -61,13 +64,13 @@ export default serve({
server: server.name, server: server.name,
date: new Date(), date: new Date(),
}); });
console.log(i, mh.servers.length);
}); });
await mongo.close(); return true;
});
return { if (completed == true) {
event, return { event, body: "Finished!" };
body: "Finished adding " + mh.servers.length + " servers.", }
};
} catch (e) { } catch (e) {
await mongo.close(); await mongo.close();