commands

Documentation

Index

• Constants
• Variables
• type SaveMessageCommand
  • func (SaveMessageCommand) Type() icommands.Type
• type SaveMessageCommandHandler
  • func NewSaveMessageCommandHandler(idp idn.Provider, stge messages.Storage, pub pubsub.Publisher, ...) *SaveMessageCommandHandler
  • func (h *SaveMessageCommandHandler) Handle(ctx context.Context, cmd icommands.Command) (reply icommands.Reply, err error)

Constants

const (
	SaveMessageCommandType icommands.Type = "save_message"
)

Variables

var (
	ErrInvalidCommandType = errors.New("invalid command type")
)

Types

type SaveMessageCommand

type SaveMessageCommand struct {
	ID          string
	RoomID      string
	UserID      string
	Text        string
	Metadata    messages.Metadata
	PublishedAt time.Time
}

func (SaveMessageCommand) Type

func (SaveMessageCommand) Type() icommands.Type

type SaveMessageCommandHandler

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

func NewSaveMessageCommandHandler

func NewSaveMessageCommandHandler(idp idn.Provider, stge messages.Storage, pub pubsub.Publisher, logger *zerolog.Logger) *SaveMessageCommandHandler

func (*SaveMessageCommandHandler) Handle

func (h *SaveMessageCommandHandler) Handle(ctx context.Context, cmd icommands.Command) (reply icommands.Reply, err error)