stream

Documentation

Index

• func NewIntegrationEventHandlers(messages MessagesController, threads ThreadsController, files FilesController, ...) am.RawMessageHandler
• func RegisterIntegrationEventHandlers(subscriber am.RawMessageSubscriber, handlers am.RawMessageHandler) (err error)
• type FilesController
• type MessagesController
• type ThreadsController
• type TranslationsController

Functions

func NewIntegrationEventHandlers

func NewIntegrationEventHandlers(messages MessagesController, threads ThreadsController,
	files FilesController, translations TranslationsController, log *logger.Logger) am.RawMessageHandler

func RegisterIntegrationEventHandlers

func RegisterIntegrationEventHandlers(subscriber am.RawMessageSubscriber, handlers am.RawMessageHandler) (err error)

Types

type FilesController

type FilesController interface {
	SaveFile(ctx context.Context, id, userID int64, name, description, mime string, private bool, size int64, createdAt, updatedAt string) error
	PublishFiles(ctx context.Context, ids []int64, userID int64, updatedAt string) error
	PrivateFiles(ctx context.Context, ids []int64, userID int64, updatedAt string) error
	DeleteFiles(ctx context.Context, ids []int64, userID int64) error
}

type MessagesController

type MessagesController interface {
	SaveMessage(ctx context.Context, id, userID int64, name, title, text string, private bool, createdAt, updatedAt string) error
	UpdateMessage(ctx context.Context, id, userID int64, name, title, text *string, updatedAt string) error
	PublishMessages(ctx context.Context, ids []int64, userID int64, updatedAt string) error
	PrivateMessages(ctx context.Context, ids []int64, userID int64, updatedAt string) error
	DeleteMessage(ctx context.Context, id, userID int64) error
}

type ThreadsController

type ThreadsController interface {
	SaveThread(ctx context.Context, id, userID, parentID int64, name, description string, private bool, createdAt, updatedAt string) error
	DeleteThread(ctx context.Context, id, userID int64) error
	UpdateThread(ctx context.Context, id, userID int64, name, description *string, updatedAt string) error
	ChangeThreadParent(ctx context.Context, id, userID, parentID int64) error
	PrivateThread(ctx context.Context, id, userID int64, updatedAt string) error
	PublishThread(ctx context.Context, id, userID int64, updatedAt string) error
}

type TranslationsController

type TranslationsController interface {
	SaveTranslation(ctx context.Context, userID, messageID int64, lang, title, text string, createdAt, updatedAt string) error
	DeleteTranslation(ctx context.Context, messageID int64, lang string) error
	UpdateTranslation(ctx context.Context, messageID int64, lang string, title, text *string, updatedAt string) error
}