Function getInitialStats

packages/database/migrations/orgid_backfill.ts:133–179

()

}

async function getInitialStats(): Promise<void> {
	console.log("📈 Getting initial stats...");

	const totalVideos = await db()
		.select({ count: sql<number>`count(*)` })
		.from(videos);

	const videosWithOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(videos)
		.where(isNotNull(videos.orgId));

	const videosNeedingOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(videos)
		.innerJoin(users, eq(videos.ownerId, users.id))
		.where(and(isNull(videos.orgId), isNotNull(users.activeOrganizationId)));

	const totalUsers = await db()
		.select({ count: sql<number>`count(*)` })
		.from(users);

	const usersWithDefaultOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(users)
		.where(isNotNull(users.defaultOrgId));

	const usersNeedingDefaultOrgId = await db()
		.select({ count: sql<number>`count(*)` })
		.from(users)
		.where(
			and(isNull(users.defaultOrgId), isNotNull(users.activeOrganizationId)),
		);

	console.log("📊 Initial stats:");
	console.log(`  Total videos: ${totalVideos[0]?.count || 0}`);
	console.log(`  Videos with orgId: ${videosWithOrgId[0]?.count || 0}`);
	console.log(`  Videos needing orgId: ${videosNeedingOrgId[0]?.count || 0}`);
	console.log(`  Total users: ${totalUsers[0]?.count || 0}`);
	console.log(
		`  Users with defaultOrgId: ${usersWithDefaultOrgId[0]?.count || 0}`,
	);
	console.log(
		`  Users needing defaultOrgId: ${usersNeedingDefaultOrgId[0]?.count || 0}`,
	);
	console.log("");
}

export async function runOrgIdBackfill() {
	console.log("🚀 Starting orgId backfill script");