@@ -106,11 +106,11 @@ export const cacheEntriesRouter = base
106106 } ) ,
107107 )
108108 . handler ( async ( { input, context } ) => {
109- const query = context . db . selectFrom ( 'cache_entries' )
110- if ( input . key ) query . where ( 'key' , '=' , input . key )
111- if ( input . version ) query . where ( 'version' , '=' , input . version )
112- if ( input . scope ) query . where ( 'scope' , '=' , input . scope )
113- if ( input . repoId ) query . where ( 'repoId' , '=' , input . repoId )
109+ let query = context . db . selectFrom ( 'cache_entries' )
110+ if ( input . key ) query = query . where ( 'key' , '=' , input . key )
111+ if ( input . version ) query = query . where ( 'version' , '=' , input . version )
112+ if ( input . scope ) query = query . where ( 'scope' , '=' , input . scope )
113+ if ( input . repoId ) query = query . where ( 'repoId' , '=' , input . repoId )
114114
115115 const [ cacheEntries , countResult ] = await Promise . all ( [
116116 query
@@ -160,10 +160,10 @@ export const cacheEntriesRouter = base
160160 } ) ,
161161 )
162162 . handler ( async ( { input, context } ) => {
163- const query = context . db . deleteFrom ( 'cache_entries' )
164- if ( input . key ) query . where ( 'key' , '=' , input . key )
165- if ( input . version ) query . where ( 'version' , '=' , input . version )
166- if ( input . scope ) query . where ( 'scope' , '=' , input . scope )
163+ let query = context . db . deleteFrom ( 'cache_entries' )
164+ if ( input . key ) query = query . where ( 'key' , '=' , input . key )
165+ if ( input . version ) query = query . where ( 'version' , '=' , input . version )
166+ if ( input . scope ) query = query . where ( 'scope' , '=' , input . scope )
167167
168168 await query . execute ( )
169169 context . event . waitUntil ( runTask ( 'cleanup:storage-locations' ) )
0 commit comments