messaging

Documentation

Index

• type Service
  • func NewLoggingService(logger log.Logger, s Service, verbose bool) Service
  • func NewService(messageRepo core.MessageRepo, conversationRepo core.ConversationRepo) Service

Types

type Service

type Service interface {
	ListAllMessages(userID, conversationID, beforeInSequence, limit int, mType core.MessageType) ([]interface{}, error)
	ListProgrammingLanguages() ([]core.ProgrammingLanguage, error)
	GetMediaObject(userCtx, conversationID int, fileName, pathPrefix string) (core.MediaObject, *os.File, error)
	GetMessage(userCtx, conversationID, messageID int) (interface{}, error)
	GetCodeOfMessage(userCtx, conversationID, messageID int) (string, error)
	BroadcastUserIsTyping(userCtx, conversationID int, pusher core.Pusher, ctx context.Context) error

	// Mutations
	SendMessage(target, userID int, message json.RawMessage, pusher core.Pusher, ctx context.Context) (interface{}, error)
	ReadMessages(userID int, message json.RawMessage) error
	EditMessage(userCtx, conversationID int, message json.RawMessage, pusher core.Pusher, ctx context.Context) (int, error)
	LiveEditMessage(userCtx, conversationID int, message json.RawMessage, pusher core.Pusher, ctx context.Context) (int, error)
	ToggleLiveSession(userCtx, conversationID int, state bool, message json.RawMessage, pusher core.Pusher, ctx context.Context) (int, error)
	CompleteMessage(id int, err error) error

	// AddFileToMessage adds a media object to a media message.
	AddFileToMessage(userCtx, conversationID, messageID int, fileBuffer []byte, pathPrefix, fileName, fileType string) error
}

func NewLoggingService

func NewLoggingService(logger log.Logger, s Service, verbose bool) Service

func NewService

func NewService(messageRepo core.MessageRepo, conversationRepo core.ConversationRepo) Service