schdule.js

const { Pool } = require("pg");
const Cursor = require("pg-cursor");
const { processAndInsert2, batchSize, intervalQuery2 } = require("./common.js");
const dotenv = require("dotenv");
const cron = require("node-cron");
dotenv.config();

const pool = new Pool({
    user: process.env.PG_USER_LIVE,
    password: process.env.PG_PASSWORD_LIVE,
    host: process.env.PG_HOST_LIVE,
    port: process.env.PG_PORT_LIVE,
    database: process.env.PG_DATABASE_LIVE,
});

cron.schedule("*/1 * * * *", async () => {
    const client = await pool.connect();
    try {
        const cursor = client.query(new Cursor(intervalQuery2(2)));
        let rows = await cursor.read(batchSize);
        if (rows.length > 0) {
            await processAndInsert2("epivac", rows);
        }
        while (rows.length > 0) {
            rows = await cursor.read(batchSize);
            if (rows.length > 0) {
                await processAndInsert2("epivac", rows);
            }
        }
    } catch (error) {
        console.log(error.message);
    } finally {
        client.release();
    }
    console.log("Done");
});