(
event: N,
handler: (ctx: string, payload: KiloChatEventOf<N>) => void
)
| 337 | const res = await this.listMessagesPage(conversationId, opts); |
| 338 | return res.messages; |
| 339 | } |
| 340 | |
| 341 | async listMessagesPage( |
| 342 | conversationId: string, |
| 343 | opts?: z.input<typeof listMessagesQuerySchema> |
| 344 | ): Promise<MessageListResponse> { |
| 345 | const query = { |
| 346 | before: opts?.before, |
| 347 | limit: opts?.limit, |
| 348 | } satisfies z.input<typeof listMessagesQuerySchema>; |
| 349 | |
| 350 | return this.httpRequest(`/v1/conversations/${conversationId}/messages`, { |
| 351 | query, |
| 352 | schema: messageListResponseSchema, |