application

Documentation

Index

• func NewTelegramEventHandler(log logger.Logger, bot *tgbotapi.BotAPI) mediator.EventHandler
• func NewWechatEventHandler(log logger.Logger, wechat *officialaccount.OfficialAccount) mediator.EventHandler
• type Application
  • func NewApplication(repo domain.Repository, mediator mediator.Mediator, api domain.ChatGTPService) *Application
  • func (app *Application) End(ctx context.Context, log logger.Logger, f domain.From)
  • func (app *Application) Get(ctx context.Context, log logger.Logger, f domain.From) (*Chat, error)
  • func (app *Application) GetByChatID(ctx context.Context, log logger.Logger, cid string) (*Chat, error)
  • func (app *Application) NewChat(ctx context.Context, log logger.Logger, f domain.From) error
  • func (app *Application) Prompt(ctx context.Context, log logger.Logger, f domain.From, q string, ...) error
• type Chat
  • func AssembleEntidy(entity *domain.Chat) *Chat
• type Converstaion
• type TelegramEventHandler
  • func (ev *TelegramEventHandler) Handle(ctx context.Context, event mediator.Event)
  • func (ev *TelegramEventHandler) Listening() []mediator.EventKind
• type WechatEventHandler
  • func (w *WechatEventHandler) Handle(ctx context.Context, ev mediator.Event)
  • func (w *WechatEventHandler) Listening() []mediator.EventKind

Functions

func NewTelegramEventHandler

func NewTelegramEventHandler(log logger.Logger, bot *tgbotapi.BotAPI) mediator.EventHandler

func NewWechatEventHandler

func NewWechatEventHandler(log logger.Logger, wechat *officialaccount.OfficialAccount) mediator.EventHandler

Types

type Application

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

func NewApplication

func NewApplication(repo domain.Repository, mediator mediator.Mediator, api domain.ChatGTPService) *Application

func (*Application) End

func (app *Application) End(ctx context.Context, log logger.Logger, f domain.From)

func (*Application) Get

func (app *Application) Get(ctx context.Context, log logger.Logger, f domain.From) (*Chat, error)

func (*Application) GetByChatID

func (app *Application) GetByChatID(ctx context.Context, log logger.Logger, cid string) (*Chat, error)

func (*Application) NewChat

func (app *Application) NewChat(ctx context.Context, log logger.Logger, f domain.From) error

func (*Application) Prompt

func (app *Application) Prompt(ctx context.Context, log logger.Logger, f domain.From, q string, msgID domain.ChannelMessageID) error

type Chat

type Chat struct {
	ID            string          `json:"id"`
	Channel       int             `json:"channel"`
	ChannelUserID string          `json:"channel_user_id"`
	Current       *Converstaion   `json:"current,omitempty"`
	Previous      []*Converstaion `json:"previous,omitempty"`
}

func AssembleEntidy

func AssembleEntidy(entity *domain.Chat) *Chat

type Converstaion

type Converstaion struct {
	Prompt     string `json:"prompt"`
	Completion string `json:"completion"`
}

type TelegramEventHandler

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

func (*TelegramEventHandler) Handle

func (ev *TelegramEventHandler) Handle(ctx context.Context, event mediator.Event)

func (*TelegramEventHandler) Listening

func (ev *TelegramEventHandler) Listening() []mediator.EventKind

type WechatEventHandler

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

func (*WechatEventHandler) Handle

func (w *WechatEventHandler) Handle(ctx context.Context, ev mediator.Event)

func (*WechatEventHandler) Listening

func (w *WechatEventHandler) Listening() []mediator.EventKind