createdAt: timestamp("created_at", {precision: 3, mode: 'string' }).defaultNow().notNull()

createdAt: timestamp("created_at", {precision: 3, mode: 'string' }).defaultNow().notNull()

import { drizzle  } from 'drizzle-orm/neon-serverless';
import { Pool, neonConfig } from '@neondatabase/serverless';
import dotenv from "dotenv";
import * as schema from "./schema";
import ws from 'ws';

dotenv.config({ path: ".env.local" });
neonConfig.webSocketConstructor = ws; // here
const pool = new Pool({ connectionString: process.env.DB_URL });

export const db = drizzle(pool, { schema })

import { drizzle  } from 'drizzle-orm/neon-serverless';
import { Pool, neonConfig } from '@neondatabase/serverless';
import dotenv from "dotenv";
import * as schema from "./schema";
import ws from 'ws';

dotenv.config({ path: ".env.local" });
neonConfig.webSocketConstructor = ws; // here
const pool = new Pool({ connectionString: process.env.DB_URL });

export const db = drizzle(pool, { schema })

// add txid for each record in this transaction
records.forEach((r) => {
  r.idTx = createId();
});

// sql for setting idtx
const sqlSetChunks: SQL[] = [];
sqlSetChunks.push(sql`CASE`);
for (const record of records) {
  sqlSetChunks.push(sql` WHEN id = ${record.id} THEN ${record.idTx}`);
}
sqlSetChunks.push(sql`END`);
const sqlSet = sql.join(sqlSetChunks, sql.raw(" "));

// sql for match id and current lastModified date
const sqlWhereChunks: SQL[] = [];
records.forEach((r, i) => {
  sqlWhereChunks.push(
    sql`(${recordTable.id} = ${r.id} AND ${recordTable.lastModified} = ${r.lastModified})`
  );
  if (i < records.length - 1) {
    sqlWhereChunks.push(sql` OR `);
  }
});
const sqlWhere = sql.join(sqlWhereChunks, sql.raw(" "));

try {
  await db.transaction(async (tx) => {
    await tx
      .update(recordTable)
      .set({ statusId: status, idTx: sqlSet })
      .where(sqlWhere);

    // select records that were attempted to be updated
    const selectedRecordsPostUpdate = await tx
      .select()
      .from(recordTable)
      .where(
        inArray(
          recordTable.id,
          records.map((r) => r.id)
        )
      );

    // filter out records that were not updated by matching idTx with server idTx
    const updatedRecords = selectedRecordsPostUpdate.filter((r) =>
      records.find((r2) => r2.id === r.id && r2.idTx === r.idTx)
    );
    // if no records were updated, throw error
    if (updatedRecords.length === 0) {
      throw new Error("No records updated");
    }
    await tx.insert(statusLog).values(
      updatedRecords.map((r) => ({
        recordId: r.id,
        statusId: status,
        message: "bulk",
      }))
    );

    // if any records were not updated, throw error
    if (updatedRecords.length !== records.length) {
      throw new Error("Not all records updated");
    }
 });

// add txid for each record in this transaction
records.forEach((r) => {
  r.idTx = createId();
});

// sql for setting idtx
const sqlSetChunks: SQL[] = [];
sqlSetChunks.push(sql`CASE`);
for (const record of records) {
  sqlSetChunks.push(sql` WHEN id = ${record.id} THEN ${record.idTx}`);
}
sqlSetChunks.push(sql`END`);
const sqlSet = sql.join(sqlSetChunks, sql.raw(" "));

// sql for match id and current lastModified date
const sqlWhereChunks: SQL[] = [];
records.forEach((r, i) => {
  sqlWhereChunks.push(
    sql`(${recordTable.id} = ${r.id} AND ${recordTable.lastModified} = ${r.lastModified})`
  );
  if (i < records.length - 1) {
    sqlWhereChunks.push(sql` OR `);
  }
});
const sqlWhere = sql.join(sqlWhereChunks, sql.raw(" "));

try {
  await db.transaction(async (tx) => {
    await tx
      .update(recordTable)
      .set({ statusId: status, idTx: sqlSet })
      .where(sqlWhere);

    // select records that were attempted to be updated
    const selectedRecordsPostUpdate = await tx
      .select()
      .from(recordTable)
      .where(
        inArray(
          recordTable.id,
          records.map((r) => r.id)
        )
      );

    // filter out records that were not updated by matching idTx with server idTx
    const updatedRecords = selectedRecordsPostUpdate.filter((r) =>
      records.find((r2) => r2.id === r.id && r2.idTx === r.idTx)
    );
    // if no records were updated, throw error
    if (updatedRecords.length === 0) {
      throw new Error("No records updated");
    }
    await tx.insert(statusLog).values(
      updatedRecords.map((r) => ({
        recordId: r.id,
        statusId: status,
        message: "bulk",
      }))
    );

    // if any records were not updated, throw error
    if (updatedRecords.length !== records.length) {
      throw new Error("Not all records updated");
    }
 });