Skip to content

Commit

Permalink
Stop saving discussion
Browse files Browse the repository at this point in the history
  • Loading branch information
wxh06 committed Sep 14, 2023
1 parent 44c6151 commit c5e522c
Showing 1 changed file with 7 additions and 3 deletions.
10 changes: 7 additions & 3 deletions packages/archive/src/plugins/cron.ts
Original file line number Diff line number Diff line change
@@ -1,18 +1,21 @@
import { once } from "node:events";
// import { once } from "node:events";
import type { FastifyPluginCallback } from "fastify";
import fastifyPlugin from "fastify-plugin";
import saveActivities from "../lib/activity";
/*
import delay from "../utils/delay";
import getDiscussionList from "../lib/list";
import { emitters, startTask } from "../lib/discussion";
import saveActivities from "../lib/activity";
const AUTO_SAVE_PAGES = 5;
*/
const AUTO_SAVE_INTERVAL = 1000;

export default fastifyPlugin(
function cron(fastify, options, done) {
const logger = fastify.log.child({ type: "cron" });
const save = (): Promise<unknown> =>
/*
Array.from(Array(AUTO_SAVE_PAGES))
.reduce(
(prev: Promise<number[]>, curr, i) =>
Expand Down Expand Up @@ -48,7 +51,8 @@ export default fastifyPlugin(
Promise.resolve(),
);
})
.then(() => saveActivities(logger, fastify.prisma))
*/
saveActivities(logger, fastify.prisma)
.catch((err) => logger.error(err))
.finally(() =>
setTimeout(() => {
Expand Down

0 comments on commit c5e522c

Please sign in to comment.