Class RedisMessageRepository

Redis message repository implementation.

Hierarchy (View Summary)

RedisBaseRepository
- RedisMessageRepository

Implements

MessageRepository

Constructors

constructor

new RedisMessageRepository(
    validator: Validator,
    config: Config<RedisDatabaseConfig>,
    logger: Logger,
    connector: DatabaseConnector,
): RedisMessageRepository
Creates a new message repository instance.
Parameters
- validator: Validator
  The validator instance
- config: Config<RedisDatabaseConfig>
  The database config instance
- logger: Logger
  The logger instance
- connector: DatabaseConnector
  The database connector instance
Returns RedisMessageRepository
Overrides RedisBaseRepository.constructor
- Defined in packages/database/src/modules/message/redis-message.repository.ts:54

Methods

create

create(
    campaignId: string,
    messageId: string,
    proxyId: string,
    targetId: string,
    sessionId: string,
    type:
        | "normal-simple"
        | "normal-stream-request"
        | "normal-stream-response"
        | "websocket",
    method: "HEAD" | "GET" | "POST" | "PUT" | "PATCH" | "DELETE" | "OPTIONS",
    url: string,
    requestHeaders: HttpHeaders,
    requestBody: HttpBody,
    status: number,
    responseHeaders: HttpHeaders,
    responseBody: HttpBody,
    connection: HttpConnection,
    payload: HttpPayload,
    errors: HttpError[],
    analyze: string,
    startTime: number,
    finishTime: number,
): Promise<void>
Creates a message with complete HTTP transaction details.
Parameters
- campaignId: string
  The ID of the campaign to create the message in
- messageId: string
  The unique identifier for the message
- proxyId: string
  The ID of the proxy that processed this message
- targetId: string
  The ID of the target that handled this message
- sessionId: string
  The ID of the session that generated this message
- type:
      | "normal-simple"
      | "normal-stream-request"
      | "normal-stream-response"
      | "websocket"
  The message type
- method: "HEAD" | "GET" | "POST" | "PUT" | "PATCH" | "DELETE" | "OPTIONS"
  The HTTP method
- url: string
  The request URL
- requestHeaders: HttpHeaders
  The request headers
- requestBody: HttpBody
  The request body
- status: number
  The HTTP status code
- responseHeaders: HttpHeaders
  The response headers
- responseBody: HttpBody
  The response body
- connection: HttpConnection
  Connection details
- payload: HttpPayload
  Payload information
- errors: HttpError[]
  Array of errors that occurred during processing
- analyze: string
  Analyze identifier
- startTime: number
  Start timestamp
- finishTime: number
  Finish timestamp
Returns Promise<void>
Throws
DatabaseError If any of the referenced entities does not exist

Throws
DatabaseError If a message with the same ID already exists
Implementation of MessageRepository.create
- Defined in packages/database/src/modules/message/redis-message.repository.ts:67

createDummy

createDummy(
    campaignId: string,
    messageId: string,
    proxyId: string,
    targetId: string,
    sessionId: string,
): Promise<void>
Creates a dummy message.
Parameters
- campaignId: string
  The ID of the campaign to create the message in
- messageId: string
  The unique identifier for the message
- proxyId: string
  The ID of the proxy that processed this message
- targetId: string
  The ID of the target that handled this message
- sessionId: string
  The ID of the session that generated this message
Returns Promise<void>
Throws
DatabaseError If any of the referenced entities does not exist

Throws
DatabaseError If a message with the same ID already exists
Implementation of MessageRepository.createDummy
- Defined in packages/database/src/modules/message/redis-message.repository.ts:125

read

read(campaignId: string, messageId: string): Promise<MessageModel | null>
Reads a message by its ID.
Parameters
- campaignId: string
  The ID of the campaign containing the message
- messageId: string
  The unique identifier of the message
Returns Promise<MessageModel | null>
The message model, or null if not found
Implementation of MessageRepository.read
- Defined in packages/database/src/modules/message/redis-message.repository.ts:154

readFull

readFull(
campaignId: string,
messageId: string,
): Promise<FullMessageModel | null>
Reads a full message by its ID.
Parameters
- campaignId: string
  The ID of the campaign containing the message
- messageId: string
  The unique identifier of the message
Returns Promise<FullMessageModel | null>
The full message model, or null if not found
Implementation of MessageRepository.readFull
- Defined in packages/database/src/modules/message/redis-message.repository.ts:168

`Static`register

register(container: DIContainer): void
Register message repository instance as singleton in DI container.
Parameters
- container: DIContainer
  DI container to register in
Returns void
- Defined in packages/database/src/modules/message/redis-message.repository.ts:33

Class RedisMessageRepository

Hierarchy (View Summary)

Implements

Constructors

constructor

Parameters

Returns RedisMessageRepository

Methods

create

Parameters

Returns Promise<void>

Throws

Throws

createDummy

Parameters

Returns Promise<void>

Throws

Throws

read

Parameters

Returns Promise<MessageModel | null>

readFull

Parameters

Returns Promise<FullMessageModel | null>

Staticregister

Parameters

Returns void

`Static`register