message

type CreateRequest struct {
	SenderId   string `json:"sender_id" validate:"required"`
	SenderType string `json:"sender_type,omitempty" validate:"omitempty"`

	ReceiverId   string `json:"receiver_id"  validate:"required"`
	ReceiverType string `json:"receiver_type,omitempty"  validate:"omitempty"`

	Content string `json:"content"  validate:"required"`
}

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

type MessageDB struct {
	ID        string `bson:"_id"`
	MessageId string `bson:"message_id"`
	Type      string `bson:"type,omitempty"`

	SenderType string `bson:"sender_type,omitempty"`
	SenderId   string `bson:"sender_id"`

	ReceiverType string `bson:"receiver_type,omitempty"`
	ReceiverId   string `bson:"receiver_id"`

	Content   string     `bson:"content"`
	CreatedAt *time.Time `bson:"created_at,omitempty"`
	UpdatedAt *time.Time `bson:"updated_at,omitempty"`
}

type MessageInfo struct {
	MessageId string `json:"message_id" bson:"message_id"`
	Type      string `json:"type,omitempty"`

	SenderType string `json:"sender_type,omitempty"`
	SenderId   string `json:"sender_id"`

	ReceiverType string `json:"receiver_type,omitempty"`
	ReceiverId   string `json:"receiver_id"`

	Content   string     `json:"content" bson:"content"`
	CreatedAt *time.Time `json:"created_at,omitempty"`
	UpdatedAt *time.Time `json:"updated_at,omitempty"`
}

type MessageQueueSvc interface {
	Close()
	Start() <-chan []byte
	Listen(queueName string, routeKeys []string) (<-chan []byte, error)
}

type MsgStoreSvc interface {
	Insert(context.Context, *MessageDB) (string, error)
}

type UpdateRequest struct {
	Content string `json:"content"  validate:"required"`
}