@@ -100,13 +100,14 @@ export class SupabaseCachingService extends BaseSupabaseService<CachingDatabase>
100100 . $if ( args . where ?. metadata , ( qb ) =>
101101 qb . innerJoin ( "metadata" , "metadata.uri" , "claims.uri" ) ,
102102 )
103- . $if ( args . where ?. supported_schemas , ( qb ) =>
103+ . $if ( args . where ?. eas_schema , ( qb ) =>
104104 qb . innerJoin (
105105 "supported_schemas" ,
106106 "supported_schemas.id" ,
107107 "attestations.supported_schemas_id" ,
108108 ) ,
109109 ) ;
110+ case "eas_schema" :
110111 case "supported_schemas" :
111112 case "attestation_schema" :
112113 return this . db . selectFrom ( "supported_schemas" ) . selectAll ( ) ;
@@ -172,7 +173,7 @@ export class SupabaseCachingService extends BaseSupabaseService<CachingDatabase>
172173 . $if ( args . where ?. metadata , ( qb ) =>
173174 qb . innerJoin ( "metadata" , "metadata.uri" , "claims.uri" ) ,
174175 )
175- . $if ( args . where ?. supported_schemas , ( qb ) =>
176+ . $if ( args . where ?. eas_schema , ( qb ) =>
176177 qb . innerJoin (
177178 "supported_schemas" ,
178179 "supported_schemas.id" ,
@@ -182,6 +183,7 @@ export class SupabaseCachingService extends BaseSupabaseService<CachingDatabase>
182183 . select ( ( expressionBuilder ) => {
183184 return expressionBuilder . fn . countAll ( ) . as ( "count" ) ;
184185 } ) ;
186+ case "eas_schema" :
185187 case "supported_schemas" :
186188 case "attestation_schema" :
187189 return this . db
0 commit comments