@@ -2,18 +2,17 @@ import { getOwner } from '@ember/application';
22
33import { applyStandardSourceInjections } from 'ember-orbit' ;
44
5- import type { RealtimeChannel , SupabaseClient } from '@supabase/supabase-js' ;
6-
75import { Orbit } from '@orbit/core' ;
86import { Source } from '@orbit/data' ;
97import type {
108 InitializedRecord ,
119 RecordIdentity ,
1210 RecordOperation ,
11+ RecordQuery ,
1312 RecordSchema ,
1413 RecordTransformResult ,
1514} from '@orbit/records' ;
16- import type { RecordQuery } from '@orbit/records ' ;
15+ import type { RealtimeChannel , SupabaseClient } from '@supabase/supabase-js ' ;
1716
1817import type SessionService from '../services/session.ts' ;
1918import type SupabaseService from '../services/supabase.ts' ;
@@ -114,7 +113,7 @@ export class SupabaseSource extends Source {
114113 const records = await this . findRecords ( type ) ;
115114 results . push ( ...records ) ;
116115 } else if ( expression . op === 'findRecord' ) {
117- const record = expression . record as RecordIdentity ;
116+ const record = expression . record ;
118117 const result = await this . findRecord ( record . type , record . id ) ;
119118 if ( result ) results . push ( result ) ;
120119 }
@@ -139,50 +138,48 @@ export class SupabaseSource extends Source {
139138 for ( const op of ops ) {
140139 switch ( op . op ) {
141140 case 'addRecord' : {
142- const record = await this . _addRecord ( op . record as InitializedRecord ) ;
141+ const record = await this . _addRecord ( op . record ) ;
143142 results . push ( record ) ;
144143 break ;
145144 }
146145 case 'updateRecord' : {
147- const record = await this . updateRecord (
148- op . record as InitializedRecord
149- ) ;
146+ const record = await this . updateRecord ( op . record ) ;
150147 results . push ( record ) ;
151148 break ;
152149 }
153150 case 'removeRecord' : {
154- await this . removeRecord ( op . record as RecordIdentity ) ;
151+ await this . removeRecord ( op . record ) ;
155152 break ;
156153 }
157154 case 'replaceRelatedRecords' : {
158155 await this . replaceRelatedRecords (
159- op . record as RecordIdentity ,
160- op . relationship as string ,
161- op . relatedRecords as RecordIdentity [ ]
156+ op . record ,
157+ op . relationship ,
158+ op . relatedRecords
162159 ) ;
163160 break ;
164161 }
165162 case 'replaceRelatedRecord' : {
166163 await this . replaceRelatedRecord (
167- op . record as RecordIdentity ,
168- op . relationship as string ,
169- op . relatedRecord as RecordIdentity | null
164+ op . record ,
165+ op . relationship ,
166+ op . relatedRecord
170167 ) ;
171168 break ;
172169 }
173170 case 'addToRelatedRecords' : {
174171 await this . addToRelatedRecords (
175- op . record as RecordIdentity ,
176- op . relationship as string ,
177- op . relatedRecord as RecordIdentity
172+ op . record ,
173+ op . relationship ,
174+ op . relatedRecord
178175 ) ;
179176 break ;
180177 }
181178 case 'removeFromRelatedRecords' : {
182179 await this . removeFromRelatedRecords (
183- op . record as RecordIdentity ,
184- op . relationship as string ,
185- op . relatedRecord as RecordIdentity
180+ op . record ,
181+ op . relationship ,
182+ op . relatedRecord
186183 ) ;
187184 break ;
188185 }
@@ -215,7 +212,9 @@ export class SupabaseSource extends Source {
215212
216213 if ( error ) throw new Error ( `Supabase query error: ${ error . message } ` ) ;
217214
218- return ( data as SupabaseColor [ ] ) . map ( ( c ) => this . transformColorToOrbit ( c ) ) ;
215+ return ( data as SupabaseColor [ ] ) . map ( ( c ) =>
216+ this . transformColorToOrbit ( c )
217+ ) ;
219218 }
220219 }
221220
@@ -259,7 +258,9 @@ export class SupabaseSource extends Source {
259258 }
260259
261260 // Add a record (internal implementation)
262- private async _addRecord ( record : InitializedRecord ) : Promise < InitializedRecord > {
261+ private async _addRecord (
262+ record : InitializedRecord
263+ ) : Promise < InitializedRecord > {
263264 const tableName = this . getTableName ( record . type ) ;
264265 const supabaseRecord = this . transformFromOrbit ( record ) ;
265266
@@ -277,7 +278,9 @@ export class SupabaseSource extends Source {
277278 }
278279
279280 // Update a record
280- private async updateRecord ( record : InitializedRecord ) : Promise < InitializedRecord > {
281+ private async updateRecord (
282+ record : InitializedRecord
283+ ) : Promise < InitializedRecord > {
281284 const tableName = this . getTableName ( record . type ) ;
282285 const supabaseRecord = this . transformFromOrbit ( record ) ;
283286
@@ -503,7 +506,9 @@ export class SupabaseSource extends Source {
503506}
504507
505508export default {
506- create ( injections : SupabaseSourceInjections = { schema : { } as RecordSchema } ) {
509+ create (
510+ injections : SupabaseSourceInjections = { schema : { } as RecordSchema }
511+ ) {
507512 applyStandardSourceInjections ( injections ) ;
508513
509514 injections . name = 'remote' ;
0 commit comments