service

package
v0.0.5-0...-8e55a6f Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2023 License: Apache-2.0 Imports: 70 Imported by: 3

README

Service

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ProviderSet = kitdi.NewSet(
	NewGrpcServerRegister,
	NewHttpServerRegister,
	NewUserRoleContrib,

	idp.NewWeChat,
	stripe.ProviderSet,

	kitdi.NewProvider(NewUserService, di.As(new(v12.UserServiceServer), new(v12.UserAdminServiceServer))),
	kitdi.NewProvider(NewUserInternalService, di.As(new(v12.UserInternalServiceServer))),

	kitdi.NewProvider(NewAccountService, di.As(new(v13.AccountServer))),

	kitdi.NewProvider(NewAuthService, di.As(new(v14.AuthServer))),

	kitdi.NewProvider(NewRoleServiceService, di.As(new(v1.RoleServiceServer))),
	kitdi.NewProvider(NewPermissionService, di.As(new(v15.PermissionServiceServer))),

	kitdi.NewProvider(NewWeChatAuthService, di.As(new(v14.WeChatAuthServiceServer))),
	api.NewUserTenantContrib,
	api.NewRefreshProvider,
	uhttp.NewAuth)

ProviderSet is service providers.

Functions

func FindUserByUsernameAndValidatePwd 

func FindUserByUsernameAndValidatePwd(ctx context.Context, um *biz.UserManager, username, password string) (*biz.User, error)

func MapBizRoleToApi 

func MapBizRoleToApi(u *biz.Role, b *pb.Role)

func MapBizUserToApi 

func MapBizUserToApi(ctx context.Context, u *biz.User, b vfs.Blob) *pb.User

func NewGrpcServerRegister 

func NewGrpcServerRegister(
	user *UserService,
	userInternal *UserInternalService,
	account *AccountService,
	auth *AuthService,
	weChatAuth *WeChatAuthService,
	role *RoleService,
	permission *PermissionService) kitgrpc.ServiceRegister

func NewHttpServerRegister 

func NewHttpServerRegister(
	user *UserService,
	userInternal *UserInternalService,
	resEncoder khttp.EncodeResponseFunc,
	errEncoder khttp.EncodeErrorFunc,
	account *AccountService,
	auth *AuthService,
	role *RoleService,
	permission *PermissionService,
	authHttp *uhttp.Auth,
	weChatAuth *WeChatAuthService,
	vfs vfs.Blob) kithttp.ServiceRegister

Types

type AccountService 

type AccountService struct {
	pb.UnimplementedAccountServer
	// contains filtered or unexported fields
}

func NewAccountService 

func NewAccountService(
	um *biz.UserManager,
	blob vfs.Blob,
	tenantService v13.TenantInternalServiceServer,
	userSetting biz.UserSettingRepo,
	userAddr biz.UserAddressRepo,
	normalizer biz.LookupNormalizer,
	appCfg *conf.AppConfig,
) *AccountService

func (*AccountService) CreateAddresses 

func (s *AccountService) CreateAddresses(ctx context.Context, req *pb.CreateAddressesRequest) (*pb.CreateAddressReply, error)

func (*AccountService) DeleteAddresses 

func (s *AccountService) DeleteAddresses(ctx context.Context, req *pb.DeleteAddressRequest) (*pb.DeleteAddressesReply, error)

func (*AccountService) GetAddresses 

func (s *AccountService) GetAddresses(ctx context.Context, req *pb.GetAddressesRequest) (*pb.GetAddressesReply, error)

func (*AccountService) GetProfile 

func (s *AccountService) GetProfile(ctx context.Context, req *pb.GetProfileRequest) (*pb.GetProfileResponse, error)

func (*AccountService) GetSettings 

func (s *AccountService) GetSettings(ctx context.Context, req *pb.GetSettingsRequest) (*pb.GetSettingsResponse, error)

func (*AccountService) UpdateAddresses 

func (s *AccountService) UpdateAddresses(ctx context.Context, req *pb.UpdateAddressesRequest) (*pb.UpdateAddressesReply, error)

func (*AccountService) UpdateAvatar 

func (s *AccountService) UpdateAvatar(ctx http.Context) error

func (*AccountService) UpdateProfile 

func (s *AccountService) UpdateProfile(ctx context.Context, req *pb.UpdateProfileRequest) (*pb.UpdateProfileResponse, error)

func (*AccountService) UpdateSettings 

func (s *AccountService) UpdateSettings(ctx context.Context, req *pb.UpdateSettingsRequest) (*pb.UpdateSettingsResponse, error)

type AuthService 

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

func NewAuthService 

func NewAuthService(um *biz.UserManager,
	rm *biz.RoleManager,
	token jwt.Tokenizer,
	config *jwt.TokenizerConfig,
	pwdValidator biz.PasswordValidator,
	refreshTokenRepo biz.RefreshTokenRepo,
	emailer biz.EmailSender,
	security *conf.Security,
	signIn *biz.SignInManager,
	authz authz.Service,
	trust api2.TrustedContextValidator,
	logger klog.Logger) *AuthService

func (*AuthService) ChangePasswordByForget 

func (s *AuthService) ChangePasswordByForget(ctx context.Context, req *pb.ChangePasswordByForgetRequest) (*pb.ChangePasswordByForgetReply, error)

func (*AuthService) ChangePasswordByPre 

func (s *AuthService) ChangePasswordByPre(ctx context.Context, req *pb.ChangePasswordByPreRequest) (*pb.ChangePasswordByPreReply, error)

func (*AuthService) ForgetPassword 

func (s *AuthService) ForgetPassword(ctx context.Context, req *pb.ForgetPasswordRequest) (*pb.ForgetPasswordReply, error)

func (*AuthService) GetCsrfToken 

func (s *AuthService) GetCsrfToken(ctx context.Context, req *pb.GetCsrfTokenRequest) (*pb.GetCsrfTokenResponse, error)

func (*AuthService) Login 

func (s *AuthService) Login(ctx context.Context, req *pb.LoginAuthRequest) (*pb.LoginAuthReply, error)

func (*AuthService) LoginPasswordless 

func (s *AuthService) LoginPasswordless(ctx context.Context, req *pb.LoginPasswordlessRequest) (*pb.LoginPasswordlessReply, error)

func (*AuthService) Refresh 

func (s *AuthService) Refresh(ctx context.Context, req *pb.RefreshTokenAuthRequest) (*pb.RefreshTokenAuthReply, error)

func (*AuthService) RefreshRememberToken 

func (s *AuthService) RefreshRememberToken(ctx context.Context, req *pb.RefreshRememberTokenRequest) (*pb.RefreshRememberTokenReply, error)

func (*AuthService) Register 

func (s *AuthService) Register(ctx context.Context, req *pb.RegisterAuthRequest) (*pb.RegisterAuthReply, error)

func (*AuthService) SendForgetPasswordToken 

func (s *AuthService) SendForgetPasswordToken(ctx context.Context, req *pb.ForgetPasswordTokenRequest) (*pb.ForgetPasswordTokenReply, error)

func (*AuthService) SendPasswordlessToken 

func (s *AuthService) SendPasswordlessToken(ctx context.Context, req *pb.PasswordlessTokenAuthRequest) (*pb.PasswordlessTokenAuthReply, error)

func (*AuthService) Token 

func (s *AuthService) Token(ctx context.Context, req *pb.TokenRequest) (*pb.TokenReply, error)

func (*AuthService) ValidatePassword 

func (s *AuthService) ValidatePassword(ctx context.Context, req *pb.ValidatePasswordRequest) (*pb.ValidatePasswordReply, error)

type PermissionService 

type PermissionService struct {
	pb.UnimplementedPermissionServiceServer
	// contains filtered or unexported fields
}

func NewPermissionService 

func NewPermissionService(auth authz.Service, permissionMgr authz.PermissionManagementService, sr authz.SubjectResolver, trust api2.TrustedContextValidator) *PermissionService

func (*PermissionService) AddSubjectPermission 

func (s *PermissionService) AddSubjectPermission(ctx context.Context, req *pb.AddSubjectPermissionRequest) (*pb.AddSubjectPermissionResponse, error)

func (*PermissionService) CheckCurrent 

func (s *PermissionService) CheckCurrent(ctx context.Context, req *pb.CheckPermissionRequest) (*pb.CheckPermissionReply, error)

func (*PermissionService) CheckForSubjects 

func (s *PermissionService) CheckForSubjects(ctx context.Context, req *pb.CheckSubjectsPermissionRequest) (*pb.CheckSubjectsPermissionReply, error)

CheckForSubjects internal api for remote permission checker

func (*PermissionService) GetCurrent 

func (s *PermissionService) GetCurrent(ctx context.Context, req *pb.GetCurrentPermissionRequest) (*pb.GetCurrentPermissionReply, error)

func (*PermissionService) ListSubjectPermission 

func (s *PermissionService) ListSubjectPermission(ctx context.Context, req *pb.ListSubjectPermissionRequest) (*pb.ListSubjectPermissionResponse, error)

func (*PermissionService) RemoveSubjectPermission 

func (s *PermissionService) RemoveSubjectPermission(ctx context.Context, req *pb.RemoveSubjectPermissionRequest) (*pb.RemoveSubjectPermissionReply, error)

func (*PermissionService) UpdateSubjectPermission 

func (s *PermissionService) UpdateSubjectPermission(ctx context.Context, req *pb.UpdateSubjectPermissionRequest) (*pb.UpdateSubjectPermissionResponse, error)

type RoleService 

type RoleService struct {
	pb.UnimplementedRoleServiceServer
	// contains filtered or unexported fields
}

func NewRoleServiceService 

func NewRoleServiceService(repo *biz.RoleManager, auth authz.Service, permissionMgr authz.PermissionManagementService) *RoleService

func (*RoleService) CreateRole 

func (s *RoleService) CreateRole(ctx context.Context, req *pb.CreateRoleRequest) (*pb.Role, error)

func (*RoleService) DeleteRole 

func (s *RoleService) DeleteRole(ctx context.Context, req *pb.DeleteRoleRequest) (*pb.DeleteRoleResponse, error)

func (*RoleService) GetRole 

func (s *RoleService) GetRole(ctx context.Context, req *pb.GetRoleRequest) (*pb.Role, error)

func (*RoleService) GetRolePermission 

func (s *RoleService) GetRolePermission(ctx context.Context, req *pb.GetRolePermissionRequest) (*pb.GetRolePermissionResponse, error)

func (*RoleService) ListRoles 

func (s *RoleService) ListRoles(ctx context.Context, req *pb.ListRolesRequest) (*pb.ListRolesResponse, error)

func (*RoleService) UpdateRole 

func (s *RoleService) UpdateRole(ctx context.Context, req *pb.UpdateRoleRequest) (*pb.Role, error)

func (*RoleService) UpdateRolePermission 

func (s *RoleService) UpdateRolePermission(ctx context.Context, req *pb.UpdateRolePermissionRequest) (*pb.UpdateRolePermissionResponse, error)

type UserInternalService 

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

func NewUserInternalService 

func NewUserInternalService(
	seeder seed.Seeder,
	producer event.Producer,
	auth authz.Service,
	trust kapi.TrustedContextValidator,
	dtmHelper *dtmsrv.Helper,
	blob vfs.Blob,
	um *biz.UserManager,
	l klog.Logger,
	stripeClient *stripeclient.API,
) *UserInternalService

func (*UserInternalService) CheckUserTenant 

func (s *UserInternalService) CheckUserTenant(ctx context.Context, req *pb.CheckUserTenantRequest) (*pb.CheckUserTenantReply, error)

CheckUserTenant internal api for check user tenant

func (*UserInternalService) CreateTenant 

func (s *UserInternalService) CreateTenant(ctx context.Context, req *pb.UserInternalCreateTenantRequest) (res *emptypb.Empty, err error)

func (*UserInternalService) FindOrCreateStripeCustomer 

func (s *UserInternalService) FindOrCreateStripeCustomer(ctx context.Context, req *pb.FindOrCreateStripeCustomerRequest) (*pb.FindOrCreateStripeCustomerReply, error)

type UserRoleContrib 

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

func NewUserRoleContrib 

func NewUserRoleContrib(um *biz.UserManager) *UserRoleContrib

func (*UserRoleContrib) Process 

func (u *UserRoleContrib) Process(ctx context.Context, subject authz.Subject) ([]authz.Subject, error)

type UserService 

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

func NewUserService 

func NewUserService(
	um *biz.UserManager,
	rm *biz.RoleManager,
	auth authz.Service,
	blob vfs.Blob,
	trust api2.TrustedContextValidator,
	permissionMgr authz.PermissionManagementService,
	l klog.Logger,
) *UserService

func (*UserService) CreateUser 

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

func (*UserService) CreateUserAdmin 

func (s *UserService) CreateUserAdmin(ctx context.Context, req *pb.AdminCreateUserRequest) (*pb.User, error)

func (*UserService) DeleteUser 

func (s *UserService) DeleteUser(ctx context.Context, req *pb.DeleteUserRequest) (*pb.DeleteUserResponse, error)

func (*UserService) DeleteUserAdmin 

func (s *UserService) DeleteUserAdmin(ctx context.Context, req *pb.AdminDeleteUserRequest) (*pb.AdminDeleteUserResponse, error)

func (*UserService) GetUser 

func (s *UserService) GetUser(ctx context.Context, req *pb.GetUserRequest) (*pb.User, error)

func (*UserService) GetUserAdmin 

func (s *UserService) GetUserAdmin(ctx context.Context, req *pb.AdminGetUserRequest) (*pb.User, error)

func (*UserService) GetUserPermission 

func (s *UserService) GetUserPermission(ctx context.Context, req *pb.GetUserPermissionRequest) (*pb.GetUserPermissionReply, error)

func (*UserService) GetUserRoles 

func (s *UserService) GetUserRoles(ctx context.Context, req *pb.GetUserRoleRequest) (*pb.GetUserRoleReply, error)

func (*UserService) InviteUser 

func (s *UserService) InviteUser(ctx context.Context, req *pb.InviteUserRequest) (*pb.InviteUserReply, error)

func (*UserService) ListUsers 

func (s *UserService) ListUsers(ctx context.Context, req *pb.ListUsersRequest) (*pb.ListUsersResponse, error)

func (*UserService) ListUsersAdmin 

func (s *UserService) ListUsersAdmin(ctx context.Context, req *pb.AdminListUsersRequest) (*pb.AdminListUsersResponse, error)

func (*UserService) PublicSearchUser 

func (s *UserService) PublicSearchUser(ctx context.Context, req *pb.SearchUserRequest) (*pb.SearchUserResponse, error)

PublicSearchUser is for inviting user or creating user

func (*UserService) UpdateAvatar 

func (s *UserService) UpdateAvatar(ctx http.Context) error

func (*UserService) UpdateUser 

func (s *UserService) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.User, error)

func (*UserService) UpdateUserAdmin 

func (s *UserService) UpdateUserAdmin(ctx context.Context, req *pb.AdminUpdateUserRequest) (*pb.User, error)

func (*UserService) UpdateUserPermission 

func (s *UserService) UpdateUserPermission(ctx context.Context, req *pb.UpdateUserPermissionRequest) (*pb.UpdateUserPermissionReply, error)

type WeChatAuthService 

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

func NewWeChatAuthService 

func NewWeChatAuthService(wechat *idp.WechatFactory, strCache cache.CacheInterface[string], um *biz.UserManager, authSrv *AuthService) *WeChatAuthService

func (*WeChatAuthService) MiniProgramCode 

func (s *WeChatAuthService) MiniProgramCode(ctx context.Context, req *pb.WechatMiniProgramCodeReq) (*pb.WeChatLoginReply, error)

func (*WeChatAuthService) MiniProgramPhoneCode 

func (s *WeChatAuthService) MiniProgramPhoneCode(ctx context.Context, req *pb.WechatMiniProgramPhoneCodeReq) (*pb.WeChatLoginReply, error)

Source Files

View all Source files

Directories

Path Synopsis

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.