goweb/cqrs/option.go

87 lines
1.8 KiB
Go
Raw Normal View History

2020-04-16 16:32:02 +02:00
package cqrs
type Option struct {
CommandFactory CommandFactory
QueryFactory QueryFactory
CommandResultFactory CommandResultFactory
QueryResultFactory QueryResultFactory
}
type CommandFactory func(CommandRequest) (Command, error)
type QueryFactory func(QueryRequest) (Query, error)
type CommandResultFactory func(Command) (CommandResult, error)
type QueryResultFactory func(Query, interface{}) (QueryResult, error)
type OptionFunc func(*Option)
func DefaultOption() *Option {
funcs := []OptionFunc{
WithBaseQueryFactory(),
WithBaseCommandFactory(),
WithBaseQueryResultFactory(),
WithBaseCommandResultFactory(),
}
opt := &Option{}
for _, fn := range funcs {
fn(opt)
}
return opt
}
func CreateOption(funcs ...OptionFunc) *Option {
opt := DefaultOption()
for _, fn := range funcs {
fn(opt)
}
return opt
}
func WithCommandFactory(factory CommandFactory) OptionFunc {
return func(opt *Option) {
opt.CommandFactory = factory
}
}
func WithQueryFactory(factory QueryFactory) OptionFunc {
return func(opt *Option) {
opt.QueryFactory = factory
}
}
func WithBaseQueryFactory() OptionFunc {
return func(opt *Option) {
opt.QueryFactory = func(req QueryRequest) (Query, error) {
return NewBaseQuery(req), nil
}
}
}
func WithBaseCommandFactory() OptionFunc {
return func(opt *Option) {
opt.CommandFactory = func(req CommandRequest) (Command, error) {
return NewBaseCommand(req), nil
}
}
}
func WithBaseQueryResultFactory() OptionFunc {
return func(opt *Option) {
opt.QueryResultFactory = func(qry Query, data interface{}) (QueryResult, error) {
return NewBaseQueryResult(qry, data), nil
}
}
}
func WithBaseCommandResultFactory() OptionFunc {
return func(opt *Option) {
opt.CommandResultFactory = func(cmd Command) (CommandResult, error) {
return NewBaseCommandResult(cmd), nil
}
}
}