API reference › @evolu/common › local‑first/Shared › DbWorkerQueuedResponse

type DbWorkerQueuedResponse =
  | {
      id: EvoluInstanceId;
      message:
        | {
            clock: Timestamp;
            messagesByOwnerId: ReadonlyMap<
              OwnerId,
              NonEmptyReadonlyArray<CrdtMessage>
            >;
            rowsByQuery: ReadonlyMap<
              Query,
              Result<ReadonlyArray<Row>, UnknownError>
            >;
            type: "Mutate";
          }
        | {
            error: UnknownError;
            type: "MutateFailed";
          }
        | {
            rowsByQuery: ReadonlyMap<
              Query,
              Result<ReadonlyArray<Row>, UnknownError>
            >;
            type: "Query";
          }
        | {
            file: Uint8Array<ArrayBuffer>;
            type: "Export";
          }
        | {
            error: UnknownError;
            type: "ExportFailed";
          };
      type: "ForEvolu";
    }
  | {
      message:
        | {
            failedOwnerIds: ReadonlySet<OwnerId>;
            protocolMessagesByOwnerId: ReadonlyMap<OwnerId, ProtocolMessage>;
            type: "CreateSyncMessages";
          }
        | {
            clock: Timestamp;
            didWriteMessages: boolean;
            ownerId: OwnerId;
            result: Result<
              ApplyProtocolMessageAsClientResult,
              ProtocolError | StorageWriteMessagesError
            >;
            skippedError:
              | DecryptWithXChaCha20Poly1305Error
              | ProtocolInvalidDataError
              | ProtocolTimestampMismatchError
              | ProtocolChangeTooLargeError
              | null;
            type: "ApplySyncMessage";
          };
      type: "ForSharedWorker";
    };

Defined in: packages/common/src/local-first/Shared.ts:1406