service

README

Service

Documentation

Index

• Constants
• Variables
• type AuthService
  • func NewAuthService(logger log.Logger, uc *biz.AuthUsecase, gg *biz.GoogleUseCase) *AuthService
  • func (s *AuthService) Auth(ctx context.Context, req *pb.AuthRequest) (*pb.AuthReply, error)
  • func (s *AuthService) AuthWithID(ctx context.Context, id int64) (string, error)
  • func (s *AuthService) Callback(ctx context.Context, req *pb.CallbackRequest) (*pb.CallbackReply, error)
  • func (s *AuthService) Login(_ context.Context, req *pb.LoginRequest) (*pb.LoginReply, error)
• type ChatService
  • func NewChatService(uc *biz.ChatUseCase, guc *biz.GoogleUseCase, uuc *biz.UserUseCase, ...) *ChatService
  • func (s *ChatService) TGChat(ctx context.Context, tguserID string, message string) (string, error)
  • func (s *ChatService) UserChat(ctx context.Context, req *pb.UserChatRequest) (*pb.UserChatResponse, error)
• type CronService
  • func NewCronService(c *conf.Cron, logger log.Logger, uuc *biz.UserUseCase, ...) *CronService
  • func (s *CronService) Init()
• type TGService
  • func NewTGService(logger log.Logger) *TGService
• type UserService
  • func NewUserService(logger log.Logger, uc *biz.UserUseCase, gg *biz.GoogleUseCase) *UserService
  • func (s *UserService) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserReply, error)

Constants

const (
	SYNC_LOOP_TIMEOUT = 10 * time.Minute
)

Variables

var Jobs = map[string]func(){}

var ProviderSet = wire.NewSet(
	NewAuthService,
	NewUserService,
	NewCronService,
	NewChatService,
	NewTGService,
)

ProviderSet is service providers.

Types

type AuthService

type AuthService struct {
	pb.UnimplementedAuthServiceServer
	// contains filtered or unexported fields
}

func NewAuthService

func NewAuthService(
	logger log.Logger,
	uc *biz.AuthUsecase,
	gg *biz.GoogleUseCase,
) *AuthService

func (*AuthService) Auth

func (s *AuthService) Auth(ctx context.Context, req *pb.AuthRequest) (*pb.AuthReply, error)

func (*AuthService) AuthWithID

func (s *AuthService) AuthWithID(ctx context.Context, id int64) (string, error)

func (*AuthService) Callback

func (s *AuthService) Callback(ctx context.Context, req *pb.CallbackRequest) (*pb.CallbackReply, error)

func (*AuthService) Login

func (s *AuthService) Login(_ context.Context, req *pb.LoginRequest) (*pb.LoginReply, error)

type ChatService

type ChatService struct {
	pb.UnimplementedChatServer
	// contains filtered or unexported fields
}

func NewChatService

func NewChatService(uc *biz.ChatUseCase, guc *biz.GoogleUseCase, uuc *biz.UserUseCase, logger log.Logger) *ChatService

func (*ChatService) TGChat

func (s *ChatService) TGChat(ctx context.Context, tguserID string, message string) (string, error)

func (*ChatService) UserChat

func (s *ChatService) UserChat(ctx context.Context, req *pb.UserChatRequest) (*pb.UserChatResponse, error)

type CronService

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

func NewCronService

func NewCronService(
	c *conf.Cron,
	logger log.Logger,
	uuc *biz.UserUseCase,
	cuc *biz.CalendarUseCase,
	euc *biz.EventUseCase,
	ehuc *biz.EventHistoryUseCase,
	guc *biz.GoogleUseCase,
	aiuc *biz.OpenAIUseCase,
) *CronService

func (*CronService) Init

func (s *CronService) Init()

Init initializes the cron service.

type TGService

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

func NewTGService

func NewTGService(logger log.Logger) *TGService

type UserService

type UserService struct {
	pb.UnimplementedUserServiceServer
	// contains filtered or unexported fields
}

func NewUserService

func NewUserService(
	logger log.Logger,
	uc *biz.UserUseCase,
	gg *biz.GoogleUseCase,
) *UserService

func (*UserService) CreateUser

func (s *UserService) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserReply, error)