worker

type DB interface {
	LoadRequest(ctx context.Context, id string) (*persistence.ReqData, error)
	LoadStatus(ctx context.Context, id string) (*persistence.Status, error)
	LoadWorkData(ctx context.Context, id string) (*persistence.WorkData, error)
	InsertWorkData(context.Context, *persistence.WorkData) error
	UpdateStatus(context.Context, *persistence.Status) error
	UpdateWorkData(context.Context, *persistence.WorkData) error
}

type Filer interface {
	LoadFile(ctx context.Context, fileName string) (io.ReadSeekCloser, error)
	SaveFile(ctx context.Context, name string, r io.Reader, fileSize int64) error
}

type MsgSender interface {
	SendMessage(context.Context, amessages.Message, *messages.Options) error
}

type ServiceData struct {
	GueClient        *gue.Client
	WorkerCount      int // ASR worker
	WorkerOtherCount int // for handling statuses, etc
	MsgSender        MsgSender
	DB               DB
	Filer            Filer
	TranscriberPr    TranscriberProvider
	UsageRestorer    UsageRestorer
	Testing          bool
	RetryDelay       time.Duration
}

type TranscriberProvider interface {
	Get(key string, allowOther bool) (tapi.Transcriber, string, error)
}

type UsageRestorer interface {
	Do(ctx context.Context, msgID, reqID, errStr string) error
}