controller

package
v0.0.0-...-5e664b8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 3, 2024 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateOpenAIMessageInBackground 

func CreateOpenAIMessageInBackground(
	logger *slog.Logger,
	amStorer am_s.AssistantMessageStorer,
	client *openai.Client,
	openAIAssistantID string,
	openAIThreadID string,
	message string,
	am *am_s.AssistantMessage,
) error

CreateOpenAIMessageInBackground function runs in background context to submit to OpenAI a `CreateMessage` API call and update our database with the latest response.

Types

type AssistantMessageController 

type AssistantMessageController interface {
	Create(ctx context.Context, requestData *AssistantMessageCreateRequestIDO) (*assistantmessage_s.AssistantMessage, error)
	GetByID(ctx context.Context, id primitive.ObjectID) (*assistantmessage_s.AssistantMessage, error)
	UpdateByID(ctx context.Context, requestData *AssistantMessageUpdateRequestIDO) (*assistantmessage_s.AssistantMessage, error)
	ListByFilter(ctx context.Context, f *assistantmessage_s.AssistantMessagePaginationListFilter) (*assistantmessage_s.AssistantMessagePaginationListResult, error)
	ListAsSelectOptionByFilter(ctx context.Context, f *assistantmessage_s.AssistantMessagePaginationListFilter) ([]*assistantmessage_s.AssistantMessageAsSelectOption, error)
	PublicListAsSelectOptionByFilter(ctx context.Context, f *assistantmessage_s.AssistantMessagePaginationListFilter) ([]*assistantmessage_s.AssistantMessageAsSelectOption, error)
	ArchiveByID(ctx context.Context, id primitive.ObjectID) (*assistantmessage_s.AssistantMessage, error)
	DeleteByID(ctx context.Context, id primitive.ObjectID) error
}

AssistantMessageController Interface for assistantmessage business logic controller.

func NewController 

func NewController(
	appCfg *config.Conf,
	loggerp *slog.Logger,
	uuidp uuid.Provider,
	s3 s3_storage.S3Storager,
	passwordp password.Provider,
	kmux kmutex.Provider,
	temailer templatedemailer.TemplatedEmailer,
	client *mongo.Client,
	t_storer tenant_s.TenantStorer,
	usr_storer user_s.UserStorer,
	af_storer assistantfile.AssistantFileStorer,
	a_storer assistant_s.AssistantStorer,
	at_storer assistantthread_s.AssistantThreadStorer,
	am_storer assistantmessage_s.AssistantMessageStorer,
) AssistantMessageController

type AssistantMessageControllerImpl 

type AssistantMessageControllerImpl struct {
	Config                 *config.Conf
	Logger                 *slog.Logger
	UUID                   uuid.Provider
	S3                     s3_storage.S3Storager
	Password               password.Provider
	Kmutex                 kmutex.Provider
	DbClient               *mongo.Client
	TenantStorer           tenant_s.TenantStorer
	UserStorer             user_s.UserStorer
	TemplatedEmailer       templatedemailer.TemplatedEmailer
	AssistantFileStorer    assistantfile.AssistantFileStorer
	AssistantStorer        assistant_s.AssistantStorer
	AssistantThreadStorer  assistantthread_s.AssistantThreadStorer
	AssistantMessageStorer assistantmessage_s.AssistantMessageStorer
}

func (*AssistantMessageControllerImpl) ArchiveByID 

func (impl *AssistantMessageControllerImpl) ArchiveByID(ctx context.Context, id primitive.ObjectID) (*assistantmessage_s.AssistantMessage, error)

func (*AssistantMessageControllerImpl) Create 

func (impl *AssistantMessageControllerImpl) Create(ctx context.Context, requestData *AssistantMessageCreateRequestIDO) (*am_s.AssistantMessage, error)

func (*AssistantMessageControllerImpl) DeleteByID 

func (impl *AssistantMessageControllerImpl) DeleteByID(ctx context.Context, id primitive.ObjectID) error

func (*AssistantMessageControllerImpl) GetByID 

func (c *AssistantMessageControllerImpl) GetByID(ctx context.Context, id primitive.ObjectID) (*assistantmessage_s.AssistantMessage, error)

func (*AssistantMessageControllerImpl) ListAsSelectOptionByFilter 

func (c *AssistantMessageControllerImpl) ListAsSelectOptionByFilter(ctx context.Context, f *assistantmessage_s.AssistantMessagePaginationListFilter) ([]*assistantmessage_s.AssistantMessageAsSelectOption, error)

func (*AssistantMessageControllerImpl) ListByFilter 

func (c *AssistantMessageControllerImpl) ListByFilter(ctx context.Context, f *t_s.AssistantMessagePaginationListFilter) (*t_s.AssistantMessagePaginationListResult, error)

func (*AssistantMessageControllerImpl) PublicListAsSelectOptionByFilter 

func (c *AssistantMessageControllerImpl) PublicListAsSelectOptionByFilter(ctx context.Context, f *assistantmessage_s.AssistantMessagePaginationListFilter) ([]*assistantmessage_s.AssistantMessageAsSelectOption, error)

func (*AssistantMessageControllerImpl) UpdateByID 

func (impl *AssistantMessageControllerImpl) UpdateByID(ctx context.Context, requestData *AssistantMessageUpdateRequestIDO) (*assistantmessage_s.AssistantMessage, error)

type AssistantMessageCreateRequestIDO 

type AssistantMessageCreateRequestIDO struct {
	AssistantThreadID primitive.ObjectID `bson:"assistant_thread_id" json:"assistant_thread_id"`
	Text              string             `bson:"text" json:"text"`
}

type AssistantMessageUpdateRequestIDO 

type AssistantMessageUpdateRequestIDO struct {
	ID   primitive.ObjectID `bson:"id" json:"id"`
	Text string             `bson:"text" json:"text"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.