getDbCurrentSnapshot() — astro Function Reference

Source Code

packages/db/src/core/cli/migration-queries.ts lines 433–470

async function getDbCurrentSnapshot(
	appToken: string,
	remoteUrl: string,
): Promise<DBSnapshot | undefined> {
	const client = createClient({
		token: appToken,
		url: remoteUrl,
	});

	try {
		const res = await client.get<{ snapshot: string }>(
			// Latest snapshot
			sql`select snapshot from _astro_db_snapshot order by id desc limit 1;`,
		);

		return JSON.parse(res.snapshot);
	} catch (error) {
		// Don't handle errors that are not from libSQL
		if (
			isDbError(error) &&
			// If the schema was never pushed to the database yet the table won't exist.
			// Treat a missing snapshot table as an empty table.

			// When connecting to a remote database in that condition
			// the query will fail with the following error code and message.
			((error.code === 'SQLITE_UNKNOWN' &&
				error.message === 'SQLITE_UNKNOWN: SQLite error: no such table: _astro_db_snapshot') ||
				// When connecting to a local or in-memory database that does not have a snapshot table yet
				// the query will fail with the following error code and message.
				(error.code === 'SQLITE_ERROR' &&
					error.message === 'SQLITE_ERROR: no such table: _astro_db_snapshot'))
		) {
			return;
		}

		throw error;
	}
}