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

fix: improvements to inngest

Browse Source
This commit is contained in:
dvelo 2024-08-08 16:16:32 -05:00
parent e3e2c85b37
commit 88fac002fd
1 changed files with 19 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -16,7 +16,7 @@ export default serve({
client: inngest, client: inngest,
functions: [ functions: [
inngest.createFunction( inngest.createFunction(
{ id: "every-30-min" }, { id: "short-term-data" },
[{ cron: "*/30 * * * *" }, { event: "test/30-min" }], [{ cron: "*/30 * * * *" }, { event: "test/30-min" }],
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);
@ -44,37 +44,34 @@ export default serve({
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");
const dbl = mongo.db("mhsf").collection("history"); const dbl = mongo.db("mhsf").collection("history");
mha.insertOne({ 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(), unix: Date.now(),
}); });
mh.servers.forEach(async (server: OnlineServer, i: number) => { mh.servers.forEach(async (server: OnlineServer, i: number) => {
const favorites = (async () => { const serverFavoritesObject = await meta.findOne({
const result = await meta.find({ server: server.name }).toArray();
if (result.length == 0) {
return 0;
}
return result[0].favorites;
})();
const result = await favorites;
dbl.insertOne({
player_count: server.playerData.playerCount,
favorites: result,
server: server.name, server: server.name,
time: Date.now(),
}); });
let favorites = 0;
if (serverFavoritesObject != undefined)
favorites = serverFavoritesObject.favorites;
if (i == mh.servers.length) { await dbl.insertOne({
mongo.close(); player_count: server.playerData.playerCount,
favorites,
return { server: server.name,
event, date: new Date(),
body: "Finished adding " + mh.servers.length + " servers.", });
};
}
}); });
mongo.close();
return {
event,
body: "Finished adding " + mh.servers.length + " servers.",
};
} catch (e) { } catch (e) {
mongo.close(); mongo.close();
return { event, body: "Cloudflare.. aborting " + e }; return { event, body: "Cloudflare.. aborting " + e };