mirror of
https://github.com/zitadel/zitadel.git
synced 2025-12-30 05:24:45 +00:00
39a29f534a
# Which Problems Are Solved This PR implements the endpoints listed in https://github.com/zitadel/zitadel/issues/10443 . # How the Problems Are Solved The implementation follows the same pattern as the Organization one. There are no peculiarities to this PR. The `Update`, `Delete` are implementing the `Commander` interface, while `Get` and `List` instance(s) endpoints are implementing the `Querier` interace. # Additional Context - Closes #10443 - Depends on #10445
83 lines
2.6 KiB
Go
83 lines
2.6 KiB
Go
package instance
|
|
|
|
import (
|
|
"context"
|
|
|
|
"connectrpc.com/connect"
|
|
|
|
instancev2 "github.com/zitadel/zitadel/backend/v3/api/instance/v2"
|
|
"github.com/zitadel/zitadel/internal/api/authz"
|
|
filter "github.com/zitadel/zitadel/internal/api/grpc/filter/v2beta"
|
|
instance "github.com/zitadel/zitadel/pkg/grpc/instance/v2beta"
|
|
)
|
|
|
|
func (s *Server) GetInstance(ctx context.Context, request *connect.Request[instance.GetInstanceRequest]) (*connect.Response[instance.GetInstanceResponse], error) {
|
|
if authz.GetFeatures(ctx).EnableRelationalTables {
|
|
return instancev2.GetInstance(ctx, request)
|
|
}
|
|
|
|
inst, err := s.query.Instance(ctx, true)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return connect.NewResponse(&instance.GetInstanceResponse{
|
|
Instance: ToProtoObject(inst),
|
|
}), nil
|
|
}
|
|
|
|
func (s *Server) ListInstances(ctx context.Context, req *connect.Request[instance.ListInstancesRequest]) (*connect.Response[instance.ListInstancesResponse], error) {
|
|
if authz.GetFeatures(ctx).EnableRelationalTables {
|
|
return instancev2.ListInstances(ctx, req)
|
|
}
|
|
|
|
queries, err := ListInstancesRequestToModel(req.Msg, s.systemDefaults)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
instances, err := s.query.SearchInstances(ctx, queries)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return connect.NewResponse(&instance.ListInstancesResponse{
|
|
Instances: InstancesToPb(instances.Instances),
|
|
Pagination: filter.QueryToPaginationPb(queries.SearchRequest, instances.SearchResponse),
|
|
}), nil
|
|
}
|
|
|
|
func (s *Server) ListCustomDomains(ctx context.Context, req *connect.Request[instance.ListCustomDomainsRequest]) (*connect.Response[instance.ListCustomDomainsResponse], error) {
|
|
queries, err := ListCustomDomainsRequestToModel(req.Msg, s.systemDefaults)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
domains, err := s.query.SearchInstanceDomains(ctx, queries)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return connect.NewResponse(&instance.ListCustomDomainsResponse{
|
|
Domains: DomainsToPb(domains.Domains),
|
|
Pagination: filter.QueryToPaginationPb(queries.SearchRequest, domains.SearchResponse),
|
|
}), nil
|
|
}
|
|
|
|
func (s *Server) ListTrustedDomains(ctx context.Context, req *connect.Request[instance.ListTrustedDomainsRequest]) (*connect.Response[instance.ListTrustedDomainsResponse], error) {
|
|
queries, err := ListTrustedDomainsRequestToModel(req.Msg, s.systemDefaults)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
domains, err := s.query.SearchInstanceTrustedDomains(ctx, queries)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return connect.NewResponse(&instance.ListTrustedDomainsResponse{
|
|
TrustedDomain: trustedDomainsToPb(domains.Domains),
|
|
Pagination: filter.QueryToPaginationPb(queries.SearchRequest, domains.SearchResponse),
|
|
}), nil
|
|
}
|