jobs

type BankSyncJob struct {
	UserID       uuid.UUID `json:"user_id"`
	ConnectionID uuid.UUID `json:"connection_id"`
	SyncType     string    `json:"sync_type"` // "full" or "incremental"
}

type BankSyncWorker struct {
	river.WorkerDefaults[BankSyncJob]
	// contains filtered or unexported fields
}

type BankSyncWorkerDeps struct {
	DB             *pgxpool.Pool
	Queries        *repository.Queries
	FinanceManager *finance.ProviderManager
	Logger         *zerolog.Logger
}

type EmailJob struct {
	UserID    int64          `json:"user_id"`
	Email     string         `json:"email"`
	Template  string         `json:"template"`
	Variables map[string]any `json:"variables"`
}

type EmailWorker struct {
	river.WorkerDefaults[EmailJob]
	// contains filtered or unexported fields
}

type ExchangeRatesSyncJob struct {
	JobDate time.Time `json:"job_date"`
}

type ExchangeRatesSyncWorker struct {
	river.WorkerDefaults[ExchangeRatesSyncJob]
	// contains filtered or unexported fields
}

type ExchangeRatesWorkerDeps struct {
	DB      *pgxpool.Pool
	Queries *repository.Queries
	Logger  *zerolog.Logger
}

type ExportJob struct {
	UserID     int64  `json:"user_id"`
	ExportType string `json:"export_type"` // "csv", "pdf", etc.
	DateRange  struct {
		From time.Time `json:"from"`
		To   time.Time `json:"to"`
	} `json:"date_range"`
}

type ExportWorker struct {
	river.WorkerDefaults[ExportJob]
	// contains filtered or unexported fields
}

type HistoricalExchangeRateJob struct {
	BaseCurrency string    `json:"base_currency"`
	StartDate    time.Time `json:"start_date"`
	EndDate      time.Time `json:"end_date"`
}

type HistoricalExchangeRateWorker struct {
	river.WorkerDefaults[HistoricalExchangeRateJob]
	// contains filtered or unexported fields
}

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