Function validateTables

scripts/analytics/check-analytics.js:42–105

(client)

};

async function validateTables(client) {
	const issues = [];
	for (const table of TABLE_DEFINITIONS) {
		try {
			const datasource = await client.getDatasource(table.name);
			if (!datasource) {
				issues.push(`Missing data source ${table.name}`);
				continue;
			}

			const remoteSchema = datasource?.schema?.sql_schema;
			if (!remoteSchema) {
				issues.push(
					`Data source ${table.name} does not expose schema metadata`,
				);
				continue;
			}

			const remoteColumns = splitSchema(remoteSchema).map(normalizeColumnDef);
			const expectedColumns = buildExpectedSchema(table);

			let hasIssue = false;

			if (remoteColumns.length !== expectedColumns.length) {
				issues.push(
					`Schema mismatch for ${table.name}. Expected ${expectedColumns.length} columns, got ${remoteColumns.length}.`,
				);
				hasIssue = true;
			}

			const missingColumns = expectedColumns.filter(
				(column, index) => remoteColumns[index] !== column,
			);
			if (missingColumns.length > 0) {
				issues.push(
					`Schema mismatch for ${table.name}. Expected columns (${expectedColumns.join(", ")}), got (${remoteColumns.join(", ")}).`,
				);
				hasIssue = true;
			}

			if (table.engine) {
				const actualEngine =
					typeof datasource.engine === "string"
						? datasource.engine
						: datasource.engine?.engine;
				if (actualEngine && actualEngine !== table.engine) {
					issues.push(
						`Data source ${table.name} has engine ${actualEngine}, expected ${table.engine}.`,
					);
					hasIssue = true;
				}
			}

			if (!hasIssue) {
				console.log(`✔ Data source ${table.name} schema matches`);
			}
		} catch (error) {
			issues.push(