Spaces:
Runtime error
Runtime error
File size: 2,890 Bytes
46252cd | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 | /**
* Sessions resource — lifecycle management for WhatsApp sessions.
*
* Backed by `src/modules/session/session.controller.ts`.
* @packageDocumentation
*/
import { encodeSegment } from '../http.js';
import type { OpenWAClient } from '../client.js';
import type {
CreateSessionRequest,
PairingCodeResponse,
QrCodeResponse,
RequestPairingCodeRequest,
SessionResponse,
SessionStatsOverview,
} from '../types.js';
export class SessionsResource {
constructor(private readonly client: OpenWAClient) {}
/** List all sessions (scoped to the API key's `allowedSessions`). */
list(): Promise<SessionResponse[]> {
return this.client.request<SessionResponse[]>({ method: 'GET', path: '/api/sessions' });
}
/** Get a single session by id. */
get(id: string): Promise<SessionResponse> {
return this.client.request<SessionResponse>({ method: 'GET', path: `/api/sessions/${encodeSegment(id)}` });
}
/** Create a new session. Requires an OPERATOR-level key. */
create(body: CreateSessionRequest): Promise<SessionResponse> {
return this.client.request<SessionResponse>({ method: 'POST', path: '/api/sessions', body });
}
/** Delete a session. Requires an OPERATOR-level key. */
delete(id: string): Promise<void> {
return this.client.request<void>({ method: 'DELETE', path: `/api/sessions/${encodeSegment(id)}` });
}
/** Start a session and initialize the WhatsApp connection. */
start(id: string): Promise<SessionResponse> {
return this.client.request<SessionResponse>({ method: 'POST', path: `/api/sessions/${encodeSegment(id)}/start` });
}
/** Stop a session and disconnect gracefully. */
stop(id: string): Promise<SessionResponse> {
return this.client.request<SessionResponse>({ method: 'POST', path: `/api/sessions/${encodeSegment(id)}/stop` });
}
/** Force-kill a stuck session (SIGKILL + teardown). */
forceKill(id: string): Promise<SessionResponse> {
return this.client.request<SessionResponse>({ method: 'POST', path: `/api/sessions/${encodeSegment(id)}/force-kill` });
}
/** Get the current QR code for authentication (live from the engine, not the DB). */
getQrCode(id: string): Promise<QrCodeResponse> {
return this.client.request<QrCodeResponse>({ method: 'GET', path: `/api/sessions/${encodeSegment(id)}/qr` });
}
/** Request an 8-character pairing code for phone-based login. */
requestPairingCode(id: string, body: RequestPairingCodeRequest): Promise<PairingCodeResponse> {
return this.client.request<PairingCodeResponse>({
method: 'POST',
path: `/api/sessions/${encodeSegment(id)}/pairing-code`,
body,
});
}
/** Aggregate statistics across the API key's sessions. */
stats(): Promise<SessionStatsOverview> {
return this.client.request<SessionStatsOverview>({
method: 'GET',
path: '/api/sessions/stats/overview',
});
}
}
|