Class AnalyzeService

Represents the analyze service.

Constructors

constructor

new AnalyzeService(
messageRepository: MessageRepository,
storage: Storage,
): AnalyzeService
Creates a new service instance.
Parameters
- messageRepository: MessageRepository
  The message repository instance.
- storage: Storage
  The storage instance.
Returns AnalyzeService
- Defined in modules/analyze/analyze.service.ts:41

Methods

readMessage

readMessage(
data: { campaignId: string; messageId: string },
): Promise<FullMessageModel>
Reads a full message from the database.
Parameters
- data: { campaignId: string; messageId: string }
  The job data.
Returns Promise<FullMessageModel>
The full message model.

Throws
ConsumerError If the message is not found.
- Defined in modules/analyze/analyze.service.ts:53

saveMessage

saveMessage(message: FullMessageModel): Promise<void>
Saves a processed message to storage.
Parameters
- message: FullMessageModel
  The full message model to save.
Returns Promise<void>

Throws
StorageError If saving to storage fails.
- Defined in modules/analyze/analyze.service.ts:71

`Static`register

register(container: DIContainer): void
Registers the service as a singleton in the DI container.
Parameters
- container: DIContainer
  The DI container to register in.
Returns void
- Defined in modules/analyze/analyze.service.ts:24