| ... | @@ -1,8 +1,6 @@ | ... | @@ -1,8 +1,6 @@ |
| 1 | import { SchemaIssue, Schema } from "effect"; | 1 | import { SchemaIssue, Schema } from "effect"; |
| 2 | | 2 | |
| 3 | import type { | 3 | import type { ProjectionRepositoryError } from "../persistence/Errors.ts"; |
| 4 | ProjectionRepositoryError, | | |
| 5 | } from "../persistence/Errors.ts"; | | |
| 6 | | 4 | |
| 7 | export class OrchestrationCommandJsonParseError extends Schema.TaggedErrorClass<OrchestrationCommandJsonParseError>()( | 5 | export class OrchestrationCommandJsonParseError extends Schema.TaggedErrorClass<OrchestrationCommandJsonParseError>()( |
| 8 | "OrchestrationCommandJsonParseError", | 6 | "OrchestrationCommandJsonParseError", |
| ... | @@ -110,7 +108,7 @@ export function toProjectorDecodeError(eventType: string) { | ... | @@ -110,7 +108,7 @@ export function toProjectorDecodeError(eventType: string) { |
| 110 | | 108 | |
| 111 | export function toOrchestrationJsonParseError(cause: unknown) { | 109 | export function toOrchestrationJsonParseError(cause: unknown) { |
| 112 | return new OrchestrationCommandJsonParseError({ | 110 | return new OrchestrationCommandJsonParseError({ |
| 113 | detail: `Failed to parse orchestration command JSON: ${cause}`, | 111 | detail: `Failed to parse orchestration command JSON`, |
| 114 | cause, | 112 | cause, |
| 115 | }); | 113 | }); |
| 116 | } | 114 | } |
| ... | @@ -119,7 +117,7 @@ export function toListenerCallbackError(listener: "read-model" | "domain-event") | ... | @@ -119,7 +117,7 @@ export function toListenerCallbackError(listener: "read-model" | "domain-event") |
| 119 | return (cause: unknown): OrchestrationListenerCallbackError => | 117 | return (cause: unknown): OrchestrationListenerCallbackError => |
| 120 | new OrchestrationListenerCallbackError({ | 118 | new OrchestrationListenerCallbackError({ |
| 121 | listener, | 119 | listener, |
| 122 | detail: `Failed to invoke orchestration ${listener} listener: ${cause}`, | 120 | detail: `Failed to invoke orchestration ${listener} listener`, |
| 123 | cause, | 121 | cause, |
| 124 | }); | 122 | }); |
| 125 | } | 123 | } |