processor

Documentation

Index

• type EmailProcessor
  • func NewEmailProcessor(cfg *config.Config, gmailClient *gmail.Client) *EmailProcessor
  • func (p *EmailProcessor) ProcessEmails(ctx context.Context) ([]gmail.Email, error)
  • func (p *EmailProcessor) UpdateLastProcessed() error
• type InvoiceProcessor
  • func NewInvoiceProcessor(openaiClient *openai.Client) *InvoiceProcessor
  • func (p *InvoiceProcessor) ProcessEmail(ctx context.Context, email gmail.Email) (*openai.InvoiceData, error)
• type MoneybirdProcessor
  • func NewMoneybirdProcessor(cfg *config.Config, moneybirdClient *moneybird.Client) *MoneybirdProcessor
  • func (p *MoneybirdProcessor) ProcessInvoice(ctx context.Context, invoiceData *openai.InvoiceData) error
• type Processor
  • func New(cfg *config.Config, gmailClient *gmail.Client, ...) *Processor
  • func (p *Processor) Run(ctx context.Context) error

Types

type EmailProcessor

type EmailProcessor struct {
	// contains filtered or unexported fields
}

func NewEmailProcessor

func NewEmailProcessor(cfg *config.Config, gmailClient *gmail.Client) *EmailProcessor

func (*EmailProcessor) ProcessEmails

func (p *EmailProcessor) ProcessEmails(ctx context.Context) ([]gmail.Email, error)

func (*EmailProcessor) UpdateLastProcessed

func (p *EmailProcessor) UpdateLastProcessed() error

type InvoiceProcessor

type InvoiceProcessor struct {
	// contains filtered or unexported fields
}

func NewInvoiceProcessor

func NewInvoiceProcessor(openaiClient *openai.Client) *InvoiceProcessor

func (*InvoiceProcessor) ProcessEmail

func (p *InvoiceProcessor) ProcessEmail(ctx context.Context, email gmail.Email) (*openai.InvoiceData, error)

type MoneybirdProcessor

type MoneybirdProcessor struct {
	// contains filtered or unexported fields
}

func NewMoneybirdProcessor

func NewMoneybirdProcessor(cfg *config.Config, moneybirdClient *moneybird.Client) *MoneybirdProcessor

func (*MoneybirdProcessor) ProcessInvoice

func (p *MoneybirdProcessor) ProcessInvoice(ctx context.Context, invoiceData *openai.InvoiceData) error

type Processor

type Processor struct {
	// contains filtered or unexported fields
}

func New

func New(cfg *config.Config, gmailClient *gmail.Client, moneybirdClient *moneybird.Client, openaiClient *openai.Client) *Processor

func (*Processor) Run

func (p *Processor) Run(ctx context.Context) error