FM / whatsapp

/opt/mawid/apps/api/src/whatsapp

Name	Size	Mode	Actions
owner-notifier.service.ts	1745	0644	edit dl rm
wa-core.module.ts	1352	0644	edit dl rm
wa-http.client.ts	1736	0644	edit dl rm
wa-inbound.service.spec.ts	5066	0644	edit dl rm
wa-inbound.service.ts	5431	0644	edit dl rm
wa-outbound.worker.ts	2723	0644	edit dl rm
wa-queue.ts	447	0644	edit dl rm
wa-sender.service.ts	4959	0644	edit dl rm
wa-signature.spec.ts	1264	0644	edit dl rm
wa-signature.ts	662	0644	edit dl rm
wa-types.ts	1683	0644	edit dl rm
wa-webhook.controller.spec.ts	2684	0644	edit dl rm
wa-webhook.controller.ts	2308	0644	edit dl rm
wa-window.spec.ts	860	0644	edit dl rm
wa-window.ts	509	0644	edit dl rm
whatsapp.module.ts	579	0644	edit dl rm

Edit: /opt/mawid/apps/api/src/whatsapp/wa-http.client.ts (1736B)

import { Logger } from '@nestjs/common';
import { randomUUID } from 'node:crypto';
import type { WaOutboundRequest, WaSendResponse } from './wa-types';

export const WA_HTTP_CLIENT = Symbol('WA_HTTP_CLIENT');

/**
 * Transport for the Meta Cloud API. Kept behind an interface so uncertain
 * Meta details stay in one place and tests/dev can stub it (PROJECT_PLAN §7.6).
 */
export interface WaHttpClient {
  send(phoneNumberId: string, body: WaOutboundRequest): Promise<WaSendResponse>;
}

const GRAPH_BASE = 'https://graph.facebook.com/v21.0';

export class MetaWaHttpClient implements WaHttpClient {
  constructor(private readonly accessToken: string) {}

async send(phoneNumberId: string, body: WaOutboundRequest): Promise<WaSendResponse> {
    const res = await fetch(`${GRAPH_BASE}/${phoneNumberId}/messages`, {
      method: 'POST',
      headers: {
        Authorization: `Bearer ${this.accessToken}`,
        'Content-Type': 'application/json',
      },
      body: JSON.stringify(body),
    });
    if (!res.ok) {
      const text = await res.text().catch(() => '');
      // Thrown errors are retried by the BullMQ worker with backoff.
      throw new Error(`WhatsApp send failed (${res.status}): ${text}`);
    }
    return (await res.json()) as WaSendResponse;
  }
}

/** Used when WA_ACCESS_TOKEN is not configured (local dev / tests). */
export class StubWaHttpClient implements WaHttpClient {
  private readonly logger = new Logger(StubWaHttpClient.name);

async send(phoneNumberId: string, body: WaOutboundRequest): Promise<WaSendResponse> {
    this.logger.log(`[stub] would send to ${body.to} via ${phoneNumberId}: ${JSON.stringify(body)}`);
    return { messages: [{ id: `stub-wamid-${randomUUID()}` }] };
  }
}

import { Logger } from '@nestjs/common'; import { randomUUID } from 'node:crypto'; import type { WaOutboundRequest, WaSendResponse } from './wa-types'; export const WA_HTTP_CLIENT = Symbol('WA_HTTP_CLIENT'); /** * Transport for the Meta Cloud API. Kept behind an interface so uncertain * Meta details stay in one place and tests/dev can stub it (PROJECT_PLAN §7.6). */ export interface WaHttpClient { send(phoneNumberId: string, body: WaOutboundRequest): Promise; } const GRAPH_BASE = 'https://graph.facebook.com/v21.0'; export class MetaWaHttpClient implements WaHttpClient { constructor(private readonly accessToken: string) {} async send(phoneNumberId: string, body: WaOutboundRequest): Promise { const res = await fetch(`${GRAPH_BASE}/${phoneNumberId}/messages`, { method: 'POST', headers: { Authorization: `Bearer ${this.accessToken}`, 'Content-Type': 'application/json', }, body: JSON.stringify(body), }); if (!res.ok) { const text = await res.text().catch(() => ''); // Thrown errors are retried by the BullMQ worker with backoff. throw new Error(`WhatsApp send failed (${res.status}): ${text}`); } return (await res.json()) as WaSendResponse; } } /** Used when WA_ACCESS_TOKEN is not configured (local dev / tests). */ export class StubWaHttpClient implements WaHttpClient { private readonly logger = new Logger(StubWaHttpClient.name); async send(phoneNumberId: string, body: WaOutboundRequest): Promise { this.logger.log(`[stub] would send to ${body.to} via ${phoneNumberId}: ${JSON.stringify(body)}`); return { messages: [{ id: `stub-wamid-${randomUUID()}` }] }; } }