| author |  Julius Marminge <julius0216@outlook.com> 2026-02-27 20:35:31-08:00 |
| committer |  Julius Marminge <jmarminge@gmail.com> 2026-02-27 21:30:46-08:00 |
| log | 35817601ff3f3d4f2e27ea8c5c8a08a8b0926dc3 |
| tree | b1816797208825d9b52c14ea9d13c7d01d8b98fa |
| parent | 2b154db9385e505080578903b9aaffac92514f7a |
fixxx
2 files changed, 15 insertions(+), 12 deletions(-)
apps
server
src
orchestration
persistence
apps/server/src/orchestration/Layers/ProjectionSnapshotQuery.ts+6-5
| ... | ... | @@ -43,12 +43,13 @@ const ProjectionProjectDbRowSchema = ProjectionProject.mapFields( |
| 43 | 43 | scripts: Schema.fromJsonString(Schema.Array(ProjectScript)), |
| 44 | 44 | }), |
| 45 | 45 | ); |
| 46 | const ProjectionThreadMessageDbRowSchema = ProjectionThreadMessage.mapFields( | |
| 47 | Struct.assign({ | |
| 48 | isStreaming: Schema.Number, | |
| 49 | attachments: Schema.NullOr(Schema.fromJsonString(Schema.Array(ChatAttachment))), | |
| 50 | }), | |
| 51 | ); | |
| 46 | 52 | const ProjectionThreadDbRowSchema = ProjectionThread; |
| 47 | const ProjectionThreadMessageDbRowSchema = Schema.Struct({ | |
| 48 | ...ProjectionThreadMessage.fields, | |
| 49 | isStreaming: Schema.Number, | |
| 50 | attachments: Schema.NullOr(Schema.fromJsonString(Schema.Array(ChatAttachment))), | |
| 51 | }); | |
| 52 | 53 | const ProjectionThreadActivityDbRowSchema = ProjectionThreadActivity.mapFields( |
| 53 | 54 | Struct.assign({ |
| 54 | 55 | payload: Schema.fromJsonString(Schema.Unknown), |
apps/server/src/persistence/Layers/ProjectionThreadMessages.ts+9-7
| ... | ... | @@ -1,6 +1,6 @@ |
| 1 | 1 | import * as SqlClient from "effect/unstable/sql/SqlClient"; |
| 2 | 2 | import * as SqlSchema from "effect/unstable/sql/SqlSchema"; |
| 3 | import { Effect, Layer, Schema } from "effect"; | |
| 3 | import { Effect, Layer, Schema, Struct } from "effect"; | |
| 4 | 4 | import { ChatAttachment } from "@t3tools/contracts"; |
| 5 | 5 | |
| 6 | 6 | import { toPersistenceSqlError } from "../Errors.ts"; |
| ... | ... | @@ -12,11 +12,12 @@ import { |
| 12 | 12 | ProjectionThreadMessage, |
| 13 | 13 | } from "../Services/ProjectionThreadMessages.ts"; |
| 14 | 14 | |
| 15 | const ProjectionThreadMessageDbRowSchema = Schema.Struct({ | |
| 16 | ...ProjectionThreadMessage.fields, | |
| 17 | isStreaming: Schema.Number, | |
| 18 | attachments: Schema.NullOr(Schema.fromJsonString(Schema.Array(ChatAttachment))), | |
| 19 | }); | |
| 15 | const ProjectionThreadMessageDbRowSchema = ProjectionThreadMessage.mapFields( | |
| 16 | Struct.assign({ | |
| 17 | isStreaming: Schema.Number, | |
| 18 | attachments: Schema.NullOr(Schema.fromJsonString(Schema.Array(ChatAttachment))), | |
| 19 | }), | |
| 20 | ); | |
| 20 | 21 | |
| 21 | 22 | const makeProjectionThreadMessageRepository = Effect.gen(function* () { |
| 22 | 23 | const sql = yield* SqlClient.SqlClient; |
| ... | ... | @@ -24,7 +25,8 @@ const makeProjectionThreadMessageRepository = Effect.gen(function* () { |
| 24 | 25 | const upsertProjectionThreadMessageRow = SqlSchema.void({ |
| 25 | 26 | Request: ProjectionThreadMessage, |
| 26 | 27 | execute: (row) => { |
| 27 | const nextAttachmentsJson = row.attachments !== undefined ? JSON.stringify(row.attachments) : null; | |
| 28 | const nextAttachmentsJson = | |
| 29 | row.attachments !== undefined ? JSON.stringify(row.attachments) : null; | |
| 28 | 30 | return sql` |
| 29 | 31 | INSERT INTO projection_thread_messages ( |
| 30 | 32 | message_id, |