diff --git a/src/features/reporting/reporting-service.ts b/src/features/reporting/reporting-service.ts index 07dcb3b5..661c8d02 100644 --- a/src/features/reporting/reporting-service.ts +++ b/src/features/reporting/reporting-service.ts @@ -6,15 +6,17 @@ import { MESSAGE_ATTRIBUTE, } from "../chat/chat-services/models"; import { initDBContainer } from "../common/cosmos"; +import { userHashedId } from "../auth/helpers"; export const FindAllChatThreadsForReporting = async ( pageSize = 10, pageNumber = 0 ) => { const container = await initDBContainer(); + const userId = await userHashedId(); const querySpec: SqlQuerySpec = { - query: `SELECT * FROM root r WHERE r.type=@type ORDER BY r.createdAt DESC OFFSET ${ + query: `SELECT * FROM root r WHERE r.type=@type and r.userId=@userId ORDER BY r.createdAt DESC OFFSET ${ pageNumber * pageSize } LIMIT ${pageSize}`, parameters: [ @@ -22,6 +24,10 @@ export const FindAllChatThreadsForReporting = async ( name: "@type", value: CHAT_THREAD_ATTRIBUTE, }, + { + name: "@userId", + value: userId, + }, ], };