Function getVideoIds

scripts/analytics/populate-test-data.js:136–160

()

}

async function getVideoIds() {
	const dbUrl = process.env.DATABASE_URL;
	if (!dbUrl) {
		throw new Error("DATABASE_URL environment variable is required");
	}

	const config = parseDatabaseUrl(dbUrl);
	const connection = await mysql.createConnection(config);

	try {
		const [rows] = await connection.execute(
			"SELECT id, orgId FROM videos LIMIT 1000",
		);

		const videoIds = rows.map((r) => r.id);
		const orgMap = new Map();
		for (const row of rows) {
			orgMap.set(row.id, row.orgId || "");
		}

		return { videoIds, orgMap };
	} finally {
		await connection.end();
	}
}

function distributeViews(videoIds, totalViews) {
	if (videoIds.length === 0) return [];