🏭 ReplayFilter

Methods

isReplayOrExpired
cleanup

⚙ isReplayOrExpired

Checks if a packet is a replay or has an expired timestamp. Returns true if packet is invalid (replay or expired). If valid, records the nonce and returns false.

Method	Type
`isReplayOrExpired`	`(packet: WirePacket, now?: number) => boolean`

⚙ cleanup

Purges nonces whose expiration timestamp has passed

Method	Type
`cleanup`	`(now?: number) => void`

🏭 ProtocolEngine

⚙ isReplayOrExpired

Checks if an incoming packet is a duplicate replay or expired

Method	Type
`isReplayOrExpired`	`(packet: WirePacket) => boolean`

⚙ getReplayFilter

Returns the internal ReplayFilter instance

Method	Type
`getReplayFilter`	`() => ReplayFilter`

⚙ createRequestPacket

Packs an RPC Request into an Encrypted WirePacket envelope.

Method	Type
`createRequestPacket`	`(targetId: string, action: string, params: Record<string, unknown>, keyHex: string) => { packet: WirePacket; nonce: string; }`

⚙ unpackPayload

Unpacks and decrypts an incoming packet’s inner payload.

Method	Type
`unpackPayload`	`<T>(packet: WirePacket, keyHex: string) => T or null`

⚙ registerPendingRequest

Registers a callback listener for a specific request nonce

Method	Type
`registerPendingRequest`	`(nonce: string, callback: (res: RPCResponsePayload) => void) => void`

⚙ handleResponse

Resolves a pending RPC promise when a matching response arrives

Method	Type
`handleResponse`	`(responsePayload: RPCResponsePayload) => void`

⚙ createResponsePacket

Constructs an encrypted Response WirePacket.

Method	Type
`createResponsePacket`	`(targetId: string, replyToNonce: string, success: boolean, data?: unknown, error?: string or undefined, keyHex?: string or undefined) => WirePacket`

⚙ createDataPacket

Constructs an encrypted Data WirePacket (direct message / chat).

Method	Type
`createDataPacket`	`(targetId: string, payload: DirectMessagePayload, keyHex: string) => WirePacket`

⚙ createHandshakePacket

Constructs a P2P Ticket Handshake Signal WirePacket. Delivered to target peer so target can decrypt the ticket using their master key.

Method	Type
`createHandshakePacket`	`(targetId: string, ticket: string, ticketIv: string) => WirePacket`

⚙ createTestPacket

Constructs an unencrypted SIGNAL Test Request WirePacket.

Method	Type
`createTestPacket`	`(targetId: string, seq?: number, data?: string) => WirePacket`

⚙ createTestResponsePacket

Constructs an unencrypted SIGNAL Test Response WirePacket with constant “pong” payload data.

Method	Type
`createTestResponsePacket`	`(requestPacket: WirePacket, seq?: number) => WirePacket`

🍹 Interfaces

RPCRequestPayload
RPCResponsePayload
DirectMessagePayload
P2PTicket
TicketResponseBody
P2PHandshakePayload
TestPacketPayload

⚙ RPCRequestPayload

Property	Type	Description
`action`	`string`
`params`	`Record<string, unknown> or undefined`

⚙ RPCResponsePayload

Property	Type	Description
`replyToNonce`	`string`
`success`	`boolean`
`data`	`unknown`
`error`	`string or undefined`

⚙ DirectMessagePayload

Property	Type	Description
`contentType`	`"text" or "json" or "binary"`
`content`	`string`

⚙ P2PTicket

Property	Type	Description
`sessionKey`	`string`
`initiatorId`	`string`
`timestamp`	`number`
`ttl`	`number`

⚙ TicketResponseBody

Property	Type	Description
`targetId`	`string`
`sessionKey`	`string`
`ticketForTarget`	`string`
`ticketIv`	`string`

⚙ P2PHandshakePayload

Property	Type	Description
`ticket`	`string`
`iv`	`string`

⚙ TestPacketPayload

Property	Type	Description
`seq`	`number`
`data`	`string`
`ts`	`number`