File tree 2 files changed +12
-4
lines changed
2 files changed +12
-4
lines changed Original file line number Diff line number Diff line change @@ -171,8 +171,12 @@ export class PostgresDatabaseAdapter
171
171
. map ( ( _ , i ) => `$${ i + 3 } ` )
172
172
. join ( ", " ) ;
173
173
174
- let query = `SELECT * FROM memories WHERE type = $1 AND "agentId" = $2 AND "roomId" IN (${ placeholders } )` ;
175
- let queryParams = [ params . tableName , params . agentId , ...params . roomIds ] ;
174
+ const query = `SELECT * FROM memories WHERE type = $1 AND "agentId" = $2 AND "roomId" IN (${ placeholders } )` ;
175
+ const queryParams = [
176
+ params . tableName ,
177
+ params . agentId ,
178
+ ...params . roomIds ,
179
+ ] ;
176
180
177
181
const { rows } = await this . query ( query , queryParams ) ;
178
182
return rows . map ( ( row ) => ( {
Original file line number Diff line number Diff line change @@ -152,8 +152,12 @@ export class SqliteDatabaseAdapter
152
152
params . tableName = "messages" ;
153
153
}
154
154
const placeholders = params . roomIds . map ( ( ) => "?" ) . join ( ", " ) ;
155
- let sql = `SELECT * FROM memories WHERE type = ? AND agentId = ? AND roomId IN (${ placeholders } )` ;
156
- let queryParams = [ params . tableName , params . agentId , ...params . roomIds ] ;
155
+ const sql = `SELECT * FROM memories WHERE type = ? AND agentId = ? AND roomId IN (${ placeholders } )` ;
156
+ const queryParams = [
157
+ params . tableName ,
158
+ params . agentId ,
159
+ ...params . roomIds ,
160
+ ] ;
157
161
158
162
const stmt = this . db . prepare ( sql ) ;
159
163
const rows = stmt . all ( ...queryParams ) as ( Memory & {
You can’t perform that action at this time.
0 commit comments