pangolin_mirror/pangolin
1
0
Fork 0
mirror of https://github.com/fosrl/pangolin.git synced 2026-10-15 09:09:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3898 from choksi2212/fix/pg-childtest-dbget-fixed

Browse Source 
fix(org): build the deleteOrg child test under the pg config
This commit is contained in:
Owen Schwartz
2026-10-14 14:28:11 -04:00
committed by GitHub
parent 1637f26144 9242c2c196
commit c5cbe96e04
1 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/lib/deleteOrg.childTest.ts
+17 -17
View File
@@ -16,7 +16,7 @@ import {
newtSessions,
clientSitesAssociationsCache
} from "@server/db";
import { sql } from "drizzle-orm";
import { count, eq } from "drizzle-orm";
const peerRemovals: string[] = [];
const server = http.createServer((req, res) => {
@@ -105,28 +105,28 @@ server.listen(0, "127.0.0.1", async () => {
const result = await deleteOrgById("org1");
const row = (await db.get(
sql`select
(select count(*) from sites) as sites,
(select count(*) from "newt") as newts,
(select count(*) from "newtSession") as sessions,
(select count(*) from clientSitesAssociationsCache where siteId = 3) as assoc`
)) as {
sites: number;
newts: number;
sessions: number;
assoc: number;
};
// Read the leftovers through the query builder, not db.get(): the
// pg build type-checks this file against the pg driver too, and
// .get() exists only on the sqlite driver.
const [sitesRow] = await db.select({ count: count() }).from(sites);
const [newtsRow] = await db.select({ count: count() }).from(newts);
const [sessionsRow] = await db
.select({ count: count() })
.from(newtSessions);
const [assocRow] = await db
.select({ count: count() })
.from(clientSitesAssociationsCache)
.where(eq(clientSitesAssociationsCache.siteId, 3));
console.log(
"OBSERVATIONS " +
JSON.stringify({
peerRemovals: peerRemovals.slice().sort(),
terminatedNewtIds: result.deletedNewtIds.slice().sort(),
sitesLeft: Number(row.sites),
newtsLeft: Number(row.newts),
sessionsLeft: Number(row.sessions),
associationRowsLeft: Number(row.assoc)
sitesLeft: sitesRow.count,
newtsLeft: newtsRow.count,
sessionsLeft: sessionsRow.count,
associationRowsLeft: assocRow.count
})
);
server.close();