domain

type Comms interface {
	RequestChan() chan pb.Request
	SendRequest(req *pb.Request) error
}

type Config struct {
	SubmittedWith       string   `env:"SUBMITTED_WITH" envDefault:"api"`
	ApiHttpPort         int      `env:"API_HTTP_PORT" envDefault:"8080"`
	MinTextBlockSize    uint32   `env:"MIN_TEXT_BLOCK_SIZE" envDefault:"100"`
	WordsPerMinute      uint32   `env:"WORDS_PER_MINUTE" envDefault:"350"`
	EspeakVoice         string   `env:"ESPEAK_VOICE" envDefault:"f5"`
	Atempo              string   `env:"ATEMPO" envDefault:"2.0"`
	TitleLengthLimit    uint32   `env:"TITLE_LENGTH_LIMIT" envDefault:"40"`
	ChownTo             int      `env:"CHOWN_TO" envDefault:"1000"`
	LogLevel            string   `env:"LOG_LEVEL" envDefault:"debug"`
	LocalPath           string   `env:"LOCAL_PATH" envDefault:"./.docker/data"`
	TmpPath             string   `env:"TMP_PATH" envDefault:"/tmp"`
	Channels            []string `env:"CHANNELS" envDefault:"content"`
	RequestProcessorUri string   `env:"REQUEST_PROCESSOR_URI" envDefault:"http://localhost:8080/v1"`
	DDAgentHost         string   `env:"DD_AGENT_HOST" envDefault:"localhost"`
	DDAgentPort         int      `env:"DD_AGENT_PORT" envDefault:"8125"`
}

type Converter interface {
	Convert(*pb.Request) error
}

type Processor interface {
	Process(*pb.Request) error
}

type Storage interface {
	Store(*pb.Request) error
	Load(requestHash string) (*pb.Request, error)
	ListAll() []*pb.Request
	Close() error
}