Function readNotificationPayload

src/core/dispatch-payload.ts:5–21

(
  payloadArg: string,
)

import { resolvePayloadInput } from '../utils/payload-input.ts';

export async function readNotificationPayload(
  payloadArg: string,
): Promise<Record<string, unknown>> {
  const source = resolvePayloadInput(payloadArg, { subject: 'Push payload' });
  const payloadText =
    source.kind === 'inline' ? source.text : await readPushPayloadFile(source.path);
  try {
    const parsed = JSON.parse(payloadText) as unknown;
    if (!parsed || typeof parsed !== 'object' || Array.isArray(parsed)) {
      throw new AppError('INVALID_ARGS', 'push payload must be a JSON object');
    }
    return parsed as Record<string, unknown>;
  } catch (error) {
    if (error instanceof AppError) throw error;
    throw new AppError('INVALID_ARGS', `Invalid push payload JSON: ${payloadArg}`);
  }
}

async function readPushPayloadFile(payloadPath: string): Promise<string> {
  try {