chats

Documentation

Index

• type ChatsServer
  • func NewChatsServer(logger *zap.Logger, ctrl *graph.ChatsController, ...) *ChatsServer
  • func (s *ChatsServer) ChangeDepartment(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) ChangeGateway(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) ChangeStatus(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) CloseInactiveChats(ctx context.Context, log *zap.Logger, conf TicketsSettingsConf, ...) error
  • func (s *ChatsServer) CloseInactiveChatsRoutine(_ctx context.Context, wg *sync.WaitGroup)
  • func (s *ChatsServer) Count(ctx context.Context, req *connect.Request[cc.CountChatsRequest]) (*connect.Response[cc.CountChatsResponse], error)
  • func (s *ChatsServer) Create(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) Delete(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) Get(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) GetBotState(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) List(ctx context.Context, req *connect.Request[cc.ListChatsRequest]) (*connect.Response[cc.ListChatsResponse], error)
  • func (s *ChatsServer) MergeChats(ctx context.Context, req *connect.Request[cc.Merge]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) SetBotState(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
  • func (s *ChatsServer) SyncChats(ctx context.Context, req *connect.Request[cc.Empty]) (*connect.Response[cc.Empty], error)
  • func (s *ChatsServer) Update(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)
• type TicketsSettingsConf
  • func MakeTicketsConf(ctx context.Context, log *zap.Logger, ...) (conf TicketsSettingsConf)

Types

type ChatsServer

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

func NewChatsServer

func NewChatsServer(logger *zap.Logger, ctrl *graph.ChatsController, users_ctrl *graph.UsersController, msgsCtrl *graph.MessagesController,
	ps *pubsub.PubSub, whmcsTickets bool, settingsClient settingspb.SettingsServiceClient, conn *amqp091.Connection) *ChatsServer

func (*ChatsServer) ChangeDepartment

func (s *ChatsServer) ChangeDepartment(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) ChangeGateway

func (s *ChatsServer) ChangeGateway(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) ChangeStatus

func (s *ChatsServer) ChangeStatus(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) CloseInactiveChats

func (s *ChatsServer) CloseInactiveChats(ctx context.Context, log *zap.Logger, conf TicketsSettingsConf, eventPublisher func(ctx context.Context, event *events.Event)) error

func (*ChatsServer) CloseInactiveChatsRoutine

func (s *ChatsServer) CloseInactiveChatsRoutine(_ctx context.Context, wg *sync.WaitGroup)

func (*ChatsServer) Count

func (s *ChatsServer) Count(ctx context.Context, req *connect.Request[cc.CountChatsRequest]) (*connect.Response[cc.CountChatsResponse], error)

func (*ChatsServer) Create

func (s *ChatsServer) Create(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) Delete

func (s *ChatsServer) Delete(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) Get

func (s *ChatsServer) Get(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) GetBotState

func (s *ChatsServer) GetBotState(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) List

func (s *ChatsServer) List(ctx context.Context, req *connect.Request[cc.ListChatsRequest]) (*connect.Response[cc.ListChatsResponse], error)

func (*ChatsServer) MergeChats

func (s *ChatsServer) MergeChats(ctx context.Context, req *connect.Request[cc.Merge]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) SetBotState

func (s *ChatsServer) SetBotState(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

func (*ChatsServer) SyncChats

func (s *ChatsServer) SyncChats(ctx context.Context, req *connect.Request[cc.Empty]) (*connect.Response[cc.Empty], error)

func (*ChatsServer) Update

func (s *ChatsServer) Update(ctx context.Context, req *connect.Request[cc.Chat]) (*connect.Response[cc.Chat], error)

type TicketsSettingsConf

type TicketsSettingsConf struct {
	RoutineFrequency             int    `json:"routine-frequency"`                // In seconds
	CloseInactiveChatsAfterHours int    `json:"close-inactive-chats-after-hours"` // In hours
	CloseMessageContent          string `json:"close-message-content"`
}

func MakeTicketsConf

func MakeTicketsConf(ctx context.Context, log *zap.Logger, settingsClient *settingspb.SettingsServiceClient) (conf TicketsSettingsConf)