Function validateBackfill

packages/database/migrations/orgid_backfill.ts:76–131

()

}

async function validateBackfill(): Promise<void> {
	console.log("🔍 Validating backfill results...");

	// Count videos still missing orgId
	const videosWithoutOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(videos)
		.where(isNull(videos.orgId));

	// Count users still missing defaultOrgId where they have activeOrganizationId
	const usersWithoutDefaultOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(users)
		.where(
			and(isNull(users.defaultOrgId), isNotNull(users.activeOrganizationId)),
		);

	// Count videos with mismatched orgId (different from owner's activeOrganizationId)
	const videosWithMismatchedOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(videos)
		.innerJoin(users, eq(videos.ownerId, users.id))
		.where(
			and(
				isNotNull(videos.orgId),
				isNotNull(users.activeOrganizationId),
				sql`videos.orgId != users.activeOrganizationId`,
			),
		);

	// Count users with mismatched defaultOrgId (different from activeOrganizationId)
	const usersWithMismatchedDefaultOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(users)
		.where(
			and(
				isNotNull(users.defaultOrgId),
				isNotNull(users.activeOrganizationId),
				sql`users.defaultOrgId != users.activeOrganizationId`,
			),
		);

	console.log("📊 Validation results:");
	console.log(
		`  Videos still missing orgId: ${videosWithoutOrgId[0]?.count || 0}`,
	);
	console.log(
		`  Users still missing defaultOrgId: ${usersWithoutDefaultOrgId[0]?.count || 0}`,
	);
	console.log(
		`  Videos with mismatched orgId: ${videosWithMismatchedOrgId[0]?.count || 0}`,
	);
	console.log(
		`  Users with mismatched defaultOrgId: ${usersWithMismatchedDefaultOrgId[0]?.count || 0}`,
	);
}

async function getInitialStats(): Promise<void> {