summaryrefslogtreecommitdiffhomepage
path: root/src/features/surface-host/logic/message-queue.ts
diff options
context:
space:
mode:
authorAdam Malczewski <[email protected]>2026-06-27 01:09:39 +0900
committerAdam Malczewski <[email protected]>2026-06-27 01:09:39 +0900
commit576f539670f406280f8398abf78a867d70b683b8 (patch)
treeeb6866df47b74c59fa97acd0617d862bc046dcec /src/features/surface-host/logic/message-queue.ts
parent4e5a1f9d402df09bab16714e3040b1e3c586153f (diff)
parent9b0b4e5ef52c5e4383d6c4a2041ca1a73ea4bc44 (diff)
downloaddispatch-web-576f539670f406280f8398abf78a867d70b683b8.tar.gz
dispatch-web-576f539670f406280f8398abf78a867d70b683b8.zip
Merge branch 'feature/indent-change' into dev
Diffstat (limited to 'src/features/surface-host/logic/message-queue.ts')
-rw-r--r--src/features/surface-host/logic/message-queue.ts38
1 files changed, 19 insertions, 19 deletions
diff --git a/src/features/surface-host/logic/message-queue.ts b/src/features/surface-host/logic/message-queue.ts
index a8e1567..79707a5 100644
--- a/src/features/surface-host/logic/message-queue.ts
+++ b/src/features/surface-host/logic/message-queue.ts
@@ -14,31 +14,31 @@ import type { QueuedMessage } from "@dispatch/wire";
* payload shape.
*/
export interface MessageQueueData {
- readonly messages: readonly QueuedMessage[];
+ readonly messages: readonly QueuedMessage[];
}
function isQueuedMessage(v: unknown): v is QueuedMessage {
- if (typeof v !== "object" || v === null) return false;
- const o = v as Record<string, unknown>;
- return (
- typeof o.id === "string" &&
- typeof o.text === "string" &&
- typeof o.queuedAt === "number" &&
- Number.isFinite(o.queuedAt)
- );
+ if (typeof v !== "object" || v === null) return false;
+ const o = v as Record<string, unknown>;
+ return (
+ typeof o.id === "string" &&
+ typeof o.text === "string" &&
+ typeof o.queuedAt === "number" &&
+ Number.isFinite(o.queuedAt)
+ );
}
export function parseMessageQueuePayload(payload: unknown): MessageQueueData | null {
- if (typeof payload !== "object" || payload === null) return null;
- const obj = payload as Record<string, unknown>;
- const raw = obj.messages;
- if (!Array.isArray(raw)) return null;
- const messages: QueuedMessage[] = [];
- for (const entry of raw) {
- if (!isQueuedMessage(entry)) return null;
- messages.push(entry);
- }
- return { messages };
+ if (typeof payload !== "object" || payload === null) return null;
+ const obj = payload as Record<string, unknown>;
+ const raw = obj.messages;
+ if (!Array.isArray(raw)) return null;
+ const messages: QueuedMessage[] = [];
+ for (const entry of raw) {
+ if (!isQueuedMessage(entry)) return null;
+ messages.push(entry);
+ }
+ return { messages };
}
/** The `rendererId` the message-queue extension's `custom` surface field uses. */