Function main

scripts/analytics/populate-test-data.js:192–254

()

}

async function main() {
	console.log("Fetching video IDs from database...");
	const { videoIds, orgMap } = await getVideoIds();

	if (videoIds.length === 0) {
		console.error("No video IDs found in database");
		process.exit(1);
	}

	console.log(`Found ${videoIds.length} video(s)`);

	const distribution = distributeViews(videoIds, MAX_VIEWS);
	console.log(
		`Generating ${MAX_VIEWS} test views across ${distribution.length} video(s)...`,
	);

	const events = [];
	for (const { videoId, views } of distribution) {
		const orgId = orgMap.get(videoId) || "";
		for (let i = 0; i < views; i++) {
			events.push(generateTestEvent(videoId, orgId, i));
		}
	}

	console.log(`Generated ${events.length} events`);

	const auth = resolveTinybirdAuth();
	const client = createTinybirdClient(auth);

	console.log(`Ingesting events into Tinybird (${auth.host})...`);

	let totalWritten = 0;
	const chunks = [];
	for (let i = 0; i < events.length; i += INGEST_CHUNK_SIZE) {
		chunks.push(events.slice(i, i + INGEST_CHUNK_SIZE));
	}

	for (let i = 0; i < chunks.length; i++) {
		const chunk = chunks[i];
		const ndjson = toNdjson(chunk);
		await tinybirdIngest({
			host: client.host,
			token: client.token,
			datasource: TB_DATASOURCE,
			ndjson,
		});
		totalWritten += chunk.length;
		console.log(
			`Ingested chunk ${i + 1}/${chunks.length} (${chunk.length} events)`,
		);
	}

	console.log(
		`\n✅ Successfully ingested ${totalWritten} events into Tinybird`,
	);
	console.log(`\nSummary:`);
	console.log(`  Videos: ${distribution.length}`);
	console.log(`  Total events: ${totalWritten}`);