(messageID: MessageID)
| 490 | } |
| 491 | |
| 492 | export function parts(messageID: MessageID) { |
| 493 | return Effect.gen(function* () { |
| 494 | const { db } = yield* Database.Service |
| 495 | const rows = yield* db |
| 496 | .select() |
| 497 | .from(PartTable) |
| 498 | .where(eq(PartTable.message_id, messageID)) |
| 499 | .orderBy(PartTable.id) |
| 500 | .all() |
| 501 | .pipe(Effect.orDie) |
| 502 | return rows.map(part) |
| 503 | }) |
| 504 | } |
| 505 | |
| 506 | export const get = Effect.fn("MessageV2.get")(function* (input: { sessionID: SessionID; messageID: MessageID }) { |
| 507 | const { db } = yield* Database.Service |