chatservice

Documentation

Index

• type CreateBody
• type MessagesPage
• type PreparedMessage
• type Service
  • func New(s storage.ChatStore, fs *fileservice.Service) *Service
  • func (ms *Service) AddMessage(body *CreateBody) (*PreparedMessage, error)
  • func (s *Service) CheckChatAccess(chatId, botId, userId string) (*chat.Chat, error)
  • func (s *Service) CreateChat(userId string, botId string) (*chat.Chat, error)
  • func (s *Service) DeleteChat(id string) error
  • func (ms *Service) DeleteMessagesByChat(chatId string) error
  • func (s *Service) GetChat(id string) (*chat.Chat, error)
  • func (s *Service) GetChats(userId string, botId string) ([]*chat.Chat, error)
  • func (s *Service) GetMessage(id string) (*chat.Message, error)
  • func (ms *Service) GetMessagesByChat(chatId, senderId string, page, limit int, since int64) (*MessagesPage, error)

Types

type CreateBody

type CreateBody struct {
	chat.Message
	Id        struct{} `json:"-"`
	Timestamp struct{} `json:"-"`
}

type MessagesPage

type MessagesPage struct {
	ChatId   string             `json:"chatId"`
	Total    int                `json:"total"`
	Page     int                `json:"page"`
	Limit    int                `json:"limit"`
	Messages []*PreparedMessage `json:"messages"`
}

type PreparedMessage

type PreparedMessage struct {
	Id          string       `json:"id"`
	ChatId      string       `json:"chatId,omitempty"`
	SenderId    string       `json:"senderId"`
	Body        string       `json:"body"`
	Attachments []*file.File `json:"attachments,omitempty"`
	Timestamp   int64        `json:"timestamp"`
}

type Service

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

func New

func New(s storage.ChatStore, fs *fileservice.Service) *Service

func (*Service) AddMessage

func (ms *Service) AddMessage(body *CreateBody) (*PreparedMessage, error)

func (*Service) CheckChatAccess

func (s *Service) CheckChatAccess(chatId, botId, userId string) (*chat.Chat, error)

func (*Service) CreateChat

func (s *Service) CreateChat(userId string, botId string) (*chat.Chat, error)

func (*Service) DeleteChat

func (s *Service) DeleteChat(id string) error

func (*Service) DeleteMessagesByChat

func (ms *Service) DeleteMessagesByChat(chatId string) error

func (*Service) GetChat

func (s *Service) GetChat(id string) (*chat.Chat, error)

func (*Service) GetChats

func (s *Service) GetChats(userId string, botId string) ([]*chat.Chat, error)

func (*Service) GetMessage

func (s *Service) GetMessage(id string) (*chat.Message, error)

func (*Service) GetMessagesByChat

func (ms *Service) GetMessagesByChat(chatId, senderId string, page, limit int, since int64) (*MessagesPage, error)