Files
supabase/apps/studio/data/database/database-size-query.ts
Andrew Valleteau 31aad403de fix(studio): early fail query when x-connection-encrypted is invalid (#35331)
* fix(studio): early fail query when x-connection-encrypted is invalid

* fix(studio): uniformize readDatabase and projectDetails connString handling

* chore: update api types

* chore: add connectionString null option

* fix: only enforce x-connection-encrypted on platform

* chore: refactor connString check in a single point

* chore: fix guard logic

* chore: fix pgMetaGuard

* chore: fix types
2025-05-08 12:11:03 +02:00

57 lines
1.5 KiB
TypeScript

import { useQuery, UseQueryOptions } from '@tanstack/react-query'
import { executeSql, ExecuteSqlError } from '../sql/execute-sql-query'
import { databaseKeys } from './keys'
export const getDatabaseSizeSql = () => {
const sql = /* SQL */ `
select sum(pg_database_size(pg_database.datname))::bigint as db_size from pg_database;
`.trim()
return sql
}
export type DatabaseSizeVariables = {
projectRef?: string
connectionString?: string | null
}
export async function getDatabaseSize(
{ projectRef, connectionString }: DatabaseSizeVariables,
signal?: AbortSignal
) {
const sql = getDatabaseSizeSql()
const { result } = await executeSql(
{
projectRef,
connectionString,
sql,
queryKey: ['database-size'],
},
signal
)
const dbSize = result?.[0]?.db_size
if (typeof dbSize !== 'number') {
throw new Error('Error fetching dbSize')
}
return dbSize
}
export type DatabaseSizeData = Awaited<ReturnType<typeof getDatabaseSize>>
export type DatabaseSizeError = ExecuteSqlError
export const useDatabaseSizeQuery = <TData = DatabaseSizeData>(
{ projectRef, connectionString }: DatabaseSizeVariables,
{ enabled = true, ...options }: UseQueryOptions<DatabaseSizeData, DatabaseSizeError, TData> = {}
) =>
useQuery<DatabaseSizeData, DatabaseSizeError, TData>(
databaseKeys.databaseSize(projectRef),
({ signal }) => getDatabaseSize({ projectRef, connectionString }, signal),
{
enabled: enabled && typeof projectRef !== 'undefined',
...options,
}
)