aboutsummaryrefslogtreecommitdiff
path: root/src/lib/stores/supabase.ts
diff options
context:
space:
mode:
authorRuben Beltran del Rio <ruben@unlimited.pizza>2022-05-31 01:09:58 +0200
committerRuben Beltran del Rio <ruben@unlimited.pizza>2022-05-31 01:09:58 +0200
commit6ccc6f60fc85e665c8a07a169efbe8d09c9d9e8e (patch)
tree87c397af49b7820b5fb2c0fa3037be2ac4a587e8 /src/lib/stores/supabase.ts
parent852ee620f0a2f6a83cf83eba860ca951b66bb7e2 (diff)
Lint, rm unused code
Diffstat (limited to 'src/lib/stores/supabase.ts')
-rw-r--r--src/lib/stores/supabase.ts50
1 files changed, 26 insertions, 24 deletions
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<T> (query: PostgrestFilterBuilder<T>, initialValue: T[]): Readable<StoreState<T[]>> {
+export function collection<T>(
+ query: PostgrestFilterBuilder<T>,
+ initialValue: T[]
+): Readable<StoreState<T[]>> {
+ return readable(initialResponse<T[]>(initialValue), (set) => {
+ (async function () {
+ const { data, error } = await query;
- return readable(initialResponse<T[]>(initialValue), (set) => {
+ if (error) {
+ return set(errorResponse<T[]>(error));
+ }
- (async function() {
- const { data, error } = await query;
-
- if (error) {
- return set(errorResponse<T[]>(error));
- }
-
- set(response<T[]>(data));
- })()
- });
+ set(response<T[]>(data));
+ })();
+ });
}
-export function single<T> (query: PostgrestFilterBuilder<T>, initialValue: T): Readable<StoreState<T>> {
-
- return readable(initialResponse<T>(initialValue), (set) => {
-
- (async function() {
- const { data, error } = await query.single();
+export function single<T>(
+ query: PostgrestFilterBuilder<T>,
+ initialValue: T
+): Readable<StoreState<T>> {
+ return readable(initialResponse<T>(initialValue), (set) => {
+ (async function () {
+ const { data, error } = await query.single();
- if (error) {
- return set(errorResponse<T>(error));
- }
+ if (error) {
+ return set(errorResponse<T>(error));
+ }
- set(response<T>(data));
- })()
- });
+ set(response<T>(data));
+ })();
+ });
}