gpatruno
53 lines
1.4 KiB
JavaScript
53 lines
1.4 KiB
JavaScript
/**
|
|
* Backfill CaseKeyProgress from open_case transactions.
|
|
* Run after: npx prisma db push
|
|
*
|
|
* npm run db:backfill-case-keys --prefix server
|
|
*/
|
|
import { prisma } from '../src/db.js';
|
|
import { progressFromTotalOpens } from '../src/caseKeys.js';
|
|
|
|
async function main() {
|
|
const txs = await prisma.transaction.findMany({
|
|
where: { type: 'open_case' },
|
|
select: { userId: true, meta: true },
|
|
orderBy: { createdAt: 'asc' },
|
|
});
|
|
|
|
const counts = new Map();
|
|
for (const tx of txs) {
|
|
let meta;
|
|
try {
|
|
meta = JSON.parse(tx.meta || '{}');
|
|
} catch {
|
|
continue;
|
|
}
|
|
const caseId = Number(meta.caseId);
|
|
if (!caseId) continue;
|
|
const key = `${tx.userId}:${caseId}`;
|
|
counts.set(key, (counts.get(key) || 0) + 1);
|
|
}
|
|
|
|
let upserted = 0;
|
|
for (const [key, totalOpens] of counts) {
|
|
const [userId, caseId] = key.split(':').map(Number);
|
|
const { keys, opensSinceLastKey } = progressFromTotalOpens(totalOpens);
|
|
|
|
await prisma.caseKeyProgress.upsert({
|
|
where: { userId_caseId: { userId, caseId } },
|
|
create: { userId, caseId, keys, opensSinceLastKey, totalOpens },
|
|
update: { keys, opensSinceLastKey, totalOpens },
|
|
});
|
|
upserted += 1;
|
|
}
|
|
|
|
console.log(`Backfilled ${upserted} user/case key progress rows from ${txs.length} open_case transactions`);
|
|
}
|
|
|
|
main()
|
|
.catch((err) => {
|
|
console.error(err);
|
|
process.exit(1);
|
|
})
|
|
.finally(() => prisma.$disconnect());
|