mirror of
https://github.com/paralus/paralus.git
synced 2026-03-04 18:10:21 +00:00
Add structure for OIdC provider service
This commit is contained in:
34
components/usermgmt/pkg/server/oidc_provider.go
Normal file
34
components/usermgmt/pkg/server/oidc_provider.go
Normal file
@@ -0,0 +1,34 @@
|
||||
package server
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/RafaySystems/rcloud-base/components/usermgmt/pkg/service"
|
||||
rpcv3 "github.com/RafaySystems/rcloud-base/components/usermgmt/proto/rpc/v3"
|
||||
userv3 "github.com/RafaySystems/rcloud-base/components/usermgmt/proto/types/userpb/v3"
|
||||
"google.golang.org/protobuf/types/known/emptypb"
|
||||
)
|
||||
|
||||
type oidcProvider struct {
|
||||
service.OIDCProviderService
|
||||
}
|
||||
|
||||
func NewOIDCServer(providerSvc service.OIDCProviderService) rpcv3.OIDCProviderServer {
|
||||
return &oidcProvider{providerSvc}
|
||||
}
|
||||
|
||||
func (s *oidcProvider) CreateOIDCProvider(ctx context.Context, p *userv3.OIDCProvider) (*userv3.OIDCProvider, error) {
|
||||
return s.Create(ctx, p)
|
||||
}
|
||||
func (s *oidcProvider) GetOIDCProvider(ctx context.Context, p *userv3.OIDCProvider) (*userv3.OIDCProvider, error) {
|
||||
return s.GetByID(ctx, p)
|
||||
}
|
||||
func (s *oidcProvider) ListOIDCProvider(ctx context.Context, p *emptypb.Empty) (*userv3.OIDCProviderList, error) {
|
||||
return s.List(ctx)
|
||||
}
|
||||
func (s *oidcProvider) UpdateOIDCProvider(ctx context.Context, p *userv3.OIDCProvider) (*userv3.OIDCProvider, error) {
|
||||
return s.Update(ctx, p)
|
||||
}
|
||||
func (s *oidcProvider) DeleteOIDCProvider(ctx context.Context, p *userv3.OIDCProvider) (*emptypb.Empty, error) {
|
||||
return &emptypb.Empty{}, s.Delete(ctx, p)
|
||||
}
|
||||
47
components/usermgmt/pkg/service/oidc_provider.go
Normal file
47
components/usermgmt/pkg/service/oidc_provider.go
Normal file
@@ -0,0 +1,47 @@
|
||||
package service
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/RafaySystems/rcloud-base/components/common/pkg/persistence/provider/pg"
|
||||
userv3 "github.com/RafaySystems/rcloud-base/components/usermgmt/proto/types/userpb/v3"
|
||||
bun "github.com/uptrace/bun"
|
||||
)
|
||||
|
||||
type OIDCProviderService interface {
|
||||
Create(context.Context, *userv3.OIDCProvider) (*userv3.OIDCProvider, error)
|
||||
GetByID(context.Context, *userv3.OIDCProvider) (*userv3.OIDCProvider, error)
|
||||
List(context.Context) (*userv3.OIDCProviderList, error)
|
||||
Update(context.Context, *userv3.OIDCProvider) (*userv3.OIDCProvider, error)
|
||||
Delete(context.Context, *userv3.OIDCProvider) error
|
||||
}
|
||||
|
||||
type oidcProvider struct {
|
||||
dao pg.EntityDAO
|
||||
}
|
||||
|
||||
func NewOIDCProviderService(db *bun.DB) OIDCProviderService {
|
||||
return &oidcProvider{
|
||||
dao: pg.NewEntityDAO(db),
|
||||
}
|
||||
}
|
||||
|
||||
func (s *oidcProvider) Create(ctx context.Context, provider *userv3.OIDCProvider) (*userv3.OIDCProvider, error) {
|
||||
return &userv3.OIDCProvider{}, nil
|
||||
}
|
||||
|
||||
func (s *oidcProvider) GetByID(ctx context.Context, provider *userv3.OIDCProvider) (*userv3.OIDCProvider, error) {
|
||||
return &userv3.OIDCProvider{}, nil
|
||||
}
|
||||
|
||||
func (s *oidcProvider) List(ctx context.Context) (*userv3.OIDCProviderList, error) {
|
||||
return &userv3.OIDCProviderList{}, nil
|
||||
}
|
||||
|
||||
func (s *oidcProvider) Update(ctx context.Context, provider *userv3.OIDCProvider) (*userv3.OIDCProvider, error) {
|
||||
return &userv3.OIDCProvider{}, nil
|
||||
}
|
||||
|
||||
func (s *oidcProvider) Delete(ctx context.Context, provider *userv3.OIDCProvider) error {
|
||||
return nil
|
||||
}
|
||||
Reference in New Issue
Block a user