wip: updated package deletion

packages/consumer/src/main.ts

@@ -83,7 +83,7 @@ while (true) {
 	for (const item of items) {
 		const result = exitRequested
 			? Result.ok('exit' as const)
-			: await processItem(item.name, item.revId);
+			: await processItem(item);
 
 		if (result.isErr()) {
 			logger.error(`packument store failed`, {

packages/consumer/src/process.ts

@@ -1,14 +1,67 @@
 import { processPackument } from './shared/packument';
 import { processVersion } from './pkv/version';
 import { processPackage } from './pkg/package';
+import { eq, notExists } from 'drizzle-orm';
+import { db } from '@npm.rest/db/server';
 import { Result } from 'better-result';
 import pLimit from 'p-limit';
+import {
+	type changeTable,
+	repositoryTable,
+	dependencyTable,
+	packumentTable,
+	specifierTable,
+	packageTable,
+	versionTable,
+} from '@npm.rest/db/schema';
 
-export async function process(name: string, rev: string) {
-	const packument = await processPackument(name, rev);
+export async function process(item: typeof changeTable.$inferSelect) {
+	if (item.deleted) {
+		await db.transaction(async (tx) => {
+			// Delete package (cascades to versions, dependencies, and publint)
+			await tx
+				.delete(packageTable)
+				.where(eq(packageTable.name, item.name));
+
+			await tx
+				.delete(packumentTable)
+				.where(eq(packumentTable.id, item.name));
+
+			// Clean up orphaned specifiers (no longer referenced by any dependency)
+			await tx
+				.delete(specifierTable)
+				.where(
+					notExists(
+						tx
+							.select({ id: dependencyTable.specifierId })
+							.from(dependencyTable)
+							.where(
+								eq(
+									dependencyTable.specifierId,
+									specifierTable.id,
+								),
+							),
+					),
+				);
+
+			// Clean up orphaned repositories (no longer referenced by any version)
+			await tx
+				.delete(repositoryTable)
+				.where(
+					notExists(
+						tx
+							.select({ id: versionTable.id })
+							.from(versionTable)
+							.where(eq(versionTable.repo, repositoryTable.id)),
+					),
+				);
+		});
+	}
+
+	const packument = await processPackument(item.name, item.revId);
 	if (packument.isErr()) return packument;
 
-	const packageId = await processPackage(packument.value, rev);
+	const packageId = await processPackage(packument.value, item.revId);
 	if (packageId.isErr()) return packageId;
 
 	if (packument.value.versions) {
@@ -22,7 +75,7 @@
 						packageId.value,
 						packument.value,
 						pkv,
-						rev,
+						item.revId,
 					);
 				});
 			}),

packages/consumer/test/pkv/types.test.ts

@@ -26,14 +26,6 @@ const createPackument = (name: string) => ({
 	},
 });
 
-vi.mock('@npm.rest/db/server', async () => {
-	const { drizzle } = await import('drizzle-orm/postgres-js');
-
-	return {
-		db: drizzle.mock({}),
-	};
-});
-
 vi.mock(import('../../src/shared/logger'), async () => {
 	const { getLogger } = await import('@logtape/logtape');