X-Git-Url: https://git.r.bdr.sh/rbdr/forum/blobdiff_plain/852ee620f0a2f6a83cf83eba860ca951b66bb7e2..3d65cb04707cf3af11885995fd1110a5971d8b00:/src/lib/stores/supabase.ts diff --git a/src/lib/stores/supabase.ts b/src/lib/stores/supabase.ts index 804141f..5bcd941 100644 --- a/src/lib/stores/supabase.ts +++ b/src/lib/stores/supabase.ts @@ -5,34 +5,36 @@ import type { Readable } from 'svelte/store'; import type { PostgrestFilterBuilder } from '@supabase/postgrest-js'; import type { StoreState } from './response_builder'; -export function collection (query: PostgrestFilterBuilder, initialValue: T[]): Readable> { - - return readable(initialResponse(initialValue), (set) => { - - (async function() { - const { data, error } = await query; - - if (error) { - return set(errorResponse(error)); - } - - set(response(data)); - })() - }); +export function collection( + query: PostgrestFilterBuilder, + initialValue: T[] +): Readable> { + return readable(initialResponse(initialValue), (set) => { + (async function () { + const { data, error } = await query; + + if (error) { + return set(errorResponse(error)); + } + + set(response(data)); + })(); + }); } -export function single (query: PostgrestFilterBuilder, initialValue: T): Readable> { - - return readable(initialResponse(initialValue), (set) => { - - (async function() { - const { data, error } = await query.single(); - - if (error) { - return set(errorResponse(error)); - } - - set(response(data)); - })() - }); +export function single( + query: PostgrestFilterBuilder, + initialValue: T +): Readable> { + return readable(initialResponse(initialValue), (set) => { + (async function () { + const { data, error } = await query.single(); + + if (error) { + return set(errorResponse(error)); + } + + set(response(data)); + })(); + }); }