[client] Replace iOS DNS IsPrivate heuristic with route manager check (#5694)

client/internal/dns/mock_server.go

@@ -85,6 +85,11 @@ func (m *MockServer) PopulateManagementDomain(mgmtURL *url.URL) error {
 	return nil
 }
 
+// SetRouteChecker mock implementation of SetRouteChecker from Server interface
+func (m *MockServer) SetRouteChecker(func(netip.Addr) bool) {
+	// Mock implementation - no-op
+}
+
 // BeginBatch mock implementation of BeginBatch from Server interface
 func (m *MockServer) BeginBatch() {
 	// Mock implementation - no-op

client/internal/dns/server.go

@@ -57,6 +57,7 @@ type Server interface {
 	ProbeAvailability()
 	UpdateServerConfig(domains dnsconfig.ServerDomains) error
 	PopulateManagementDomain(mgmtURL *url.URL) error
+	SetRouteChecker(func(netip.Addr) bool)
 }
 
 type nsGroupsByDomain struct {
@@ -104,6 +105,7 @@ type DefaultServer struct {
 
 	statusRecorder *peer.Status
 	stateManager   *statemanager.Manager
+	routeMatch     func(netip.Addr) bool
 
 	probeMu     sync.Mutex
 	probeCancel context.CancelFunc
@@ -229,6 +231,14 @@ func newDefaultServer(
 	return defaultServer
 }
 
+// SetRouteChecker sets the function used by upstream resolvers to determine
+// whether an IP is routed through the tunnel.
+func (s *DefaultServer) SetRouteChecker(f func(netip.Addr) bool) {
+	s.mux.Lock()
+	defer s.mux.Unlock()
+	s.routeMatch = f
+}
+
 // RegisterHandler registers a handler for the given domains with the given priority.
 // Any previously registered handler for the same domain and priority will be replaced.
 func (s *DefaultServer) RegisterHandler(domains domain.List, handler dns.Handler, priority int) {
@@ -743,6 +753,7 @@ func (s *DefaultServer) registerFallback(config HostDNSConfig) {
 		log.Errorf("failed to create upstream resolver for original nameservers: %v", err)
 		return
 	}
+	handler.routeMatch = s.routeMatch
 
 	for _, ns := range originalNameservers {
 		if ns == config.ServerIP {
@@ -852,6 +863,7 @@ func (s *DefaultServer) createHandlersForDomainGroup(domainGroup nsGroupsByDomai
 		if err != nil {
 			return nil, fmt.Errorf("create upstream resolver: %v", err)
 		}
+		handler.routeMatch = s.routeMatch
 
 		for _, ns := range nsGroup.NameServers {
 			if ns.NSType != nbdns.UDPNameServerType {
@@ -1036,6 +1048,7 @@ func (s *DefaultServer) addHostRootZone() {
 		log.Errorf("unable to create a new upstream resolver, error: %v", err)
 		return
 	}
+	handler.routeMatch = s.routeMatch
 
 	handler.upstreamServers = maps.Keys(hostDNSServers)
 	handler.deactivate = func(error) {}

client/internal/dns/upstream.go

@@ -70,6 +70,7 @@ type upstreamResolverBase struct {
 	deactivate     func(error)
 	reactivate     func()
 	statusRecorder *peer.Status
+	routeMatch     func(netip.Addr) bool
 }
 
 type upstreamFailure struct {

client/internal/dns/upstream_ios.go

@@ -65,11 +65,13 @@ func (u *upstreamResolverIOS) exchange(ctx context.Context, upstream string, r *
 	} else {
 		upstreamIP = upstreamIP.Unmap()
 	}
-	if u.lNet.Contains(upstreamIP) || upstreamIP.IsPrivate() {
-		log.Debugf("using private client to query upstream: %s", upstream)
+	needsPrivate := u.lNet.Contains(upstreamIP) ||
+		(u.routeMatch != nil && u.routeMatch(upstreamIP))
+	if needsPrivate {
+		log.Debugf("using private client to query %s via upstream %s", r.Question[0].Name, upstream)
 		client, err = GetClientPrivate(u.lIP, u.interfaceName, timeout)
 		if err != nil {
-			return nil, 0, fmt.Errorf("error while creating private client: %s", err)
+			return nil, 0, fmt.Errorf("create private client: %s", err)
 		}
 	}
 

client/internal/engine.go

@@ -499,6 +499,17 @@ func (e *Engine) Start(netbirdConfig *mgmProto.NetbirdConfig, mgmtURL *url.URL)
 
 	e.routeManager.SetRouteChangeListener(e.mobileDep.NetworkChangeListener)
 
+	e.dnsServer.SetRouteChecker(func(ip netip.Addr) bool {
+		for _, routes := range e.routeManager.GetClientRoutes() {
+			for _, r := range routes {
+				if r.Network.Contains(ip) {
+					return true
+				}
+			}
+		}
+		return false
+	})
+
 	if err = e.wgInterfaceCreate(); err != nil {
 		log.Errorf("failed creating tunnel interface %s: [%s]", e.config.WgIfaceName, err.Error())
 		e.close()

go.mod

@@ -254,7 +254,7 @@ require (
 	github.com/russellhaering/goxmldsig v1.5.0 // indirect
 	github.com/rymdport/portal v0.4.2 // indirect
 	github.com/shirou/gopsutil/v4 v4.25.1 // indirect
-	github.com/shoenig/go-m1cpu v0.2.0 // indirect
+	github.com/shoenig/go-m1cpu v0.2.1 // indirect
 	github.com/shopspring/decimal v1.4.0 // indirect
 	github.com/spf13/cast v1.7.0 // indirect
 	github.com/srwiley/oksvg v0.0.0-20221011165216-be6e8873101c // indirect

go.sum

@@ -511,8 +511,8 @@ github.com/shirou/gopsutil/v3 v3.24.4/go.mod h1:lTd2mdiOspcqLgAnr9/nGi71NkeMpWKd
 github.com/shirou/gopsutil/v4 v4.25.1 h1:QSWkTc+fu9LTAWfkZwZ6j8MSUk4A2LV7rbH0ZqmLjXs=
 github.com/shirou/gopsutil/v4 v4.25.1/go.mod h1:RoUCUpndaJFtT+2zsZzzmhvbfGoDCJ7nFXKJf8GqJbI=
 github.com/shoenig/go-m1cpu v0.1.6/go.mod h1:1JJMcUBvfNwpq05QDQVAnx3gUHr9IYF7GNg9SUEw2VQ=
-github.com/shoenig/go-m1cpu v0.2.0 h1:t4GNqvPZ84Vjtpboo/kT3pIkbaK3vc+JIlD/Wz1zSFY=
-github.com/shoenig/go-m1cpu v0.2.0/go.mod h1:KkDOw6m3ZJQAPHbrzkZki4hnx+pDRR1Lo+ldA56wD5w=
+github.com/shoenig/go-m1cpu v0.2.1 h1:yqRB4fvOge2+FyRXFkXqsyMoqPazv14Yyy+iyccT2E4=
+github.com/shoenig/go-m1cpu v0.2.1/go.mod h1:KkDOw6m3ZJQAPHbrzkZki4hnx+pDRR1Lo+ldA56wD5w=
 github.com/shoenig/test v0.6.4/go.mod h1:byHiCGXqrVaflBLAMq/srcZIHynQPQgeyvkvXnjqq0k=
 github.com/shoenig/test v1.7.0 h1:eWcHtTXa6QLnBvm0jgEabMRN/uJ4DMV3M8xUGgRkZmk=
 github.com/shoenig/test v1.7.0/go.mod h1:UxJ6u/x2v/TNs/LoLxBNJRV9DiwBBKYxXSyczsBHFoI=

release_files/install.sh

@@ -128,7 +128,7 @@ cat <<-EOF | ${SUDO} tee /etc/yum.repos.d/netbird.repo
 name=NetBird
 baseurl=https://pkgs.netbird.io/yum/
 enabled=1
-gpgcheck=0
+gpgcheck=1
 gpgkey=https://pkgs.netbird.io/yum/repodata/repomd.xml.key
 repo_gpgcheck=1
 EOF

shared/management/client/rest/azure_idp.go

@@ -1,112 +0,0 @@
-package rest
-
-import (
-	"bytes"
-	"context"
-	"encoding/json"
-
-	"github.com/netbirdio/netbird/shared/management/http/api"
-)
-
-// AzureIDPAPI APIs for Azure AD IDP integrations
-type AzureIDPAPI struct {
-	c *Client
-}
-
-// List retrieves all Azure AD IDP integrations
-func (a *AzureIDPAPI) List(ctx context.Context) ([]api.AzureIntegration, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/azure-idp", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[[]api.AzureIntegration](resp)
-	return ret, err
-}
-
-// Get retrieves a specific Azure AD IDP integration by ID
-func (a *AzureIDPAPI) Get(ctx context.Context, integrationID string) (*api.AzureIntegration, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/azure-idp/"+integrationID, nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.AzureIntegration](resp)
-	return &ret, err
-}
-
-// Create creates a new Azure AD IDP integration
-func (a *AzureIDPAPI) Create(ctx context.Context, request api.CreateAzureIntegrationRequest) (*api.AzureIntegration, error) {
-	requestBytes, err := json.Marshal(request)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := a.c.NewRequest(ctx, "POST", "/api/integrations/azure-idp", bytes.NewReader(requestBytes), nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.AzureIntegration](resp)
-	return &ret, err
-}
-
-// Update updates an existing Azure AD IDP integration
-func (a *AzureIDPAPI) Update(ctx context.Context, integrationID string, request api.UpdateAzureIntegrationRequest) (*api.AzureIntegration, error) {
-	requestBytes, err := json.Marshal(request)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := a.c.NewRequest(ctx, "PUT", "/api/integrations/azure-idp/"+integrationID, bytes.NewReader(requestBytes), nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.AzureIntegration](resp)
-	return &ret, err
-}
-
-// Delete deletes an Azure AD IDP integration
-func (a *AzureIDPAPI) Delete(ctx context.Context, integrationID string) error {
-	resp, err := a.c.NewRequest(ctx, "DELETE", "/api/integrations/azure-idp/"+integrationID, nil, nil)
-	if err != nil {
-		return err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	return nil
-}
-
-// Sync triggers a manual sync for an Azure AD IDP integration
-func (a *AzureIDPAPI) Sync(ctx context.Context, integrationID string) (*api.SyncResult, error) {
-	resp, err := a.c.NewRequest(ctx, "POST", "/api/integrations/azure-idp/"+integrationID+"/sync", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.SyncResult](resp)
-	return &ret, err
-}
-
-// GetLogs retrieves synchronization logs for an Azure AD IDP integration
-func (a *AzureIDPAPI) GetLogs(ctx context.Context, integrationID string) ([]api.IdpIntegrationSyncLog, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/azure-idp/"+integrationID+"/logs", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[[]api.IdpIntegrationSyncLog](resp)
-	return ret, err
-}

shared/management/client/rest/azure_idp_test.go

@@ -1,252 +0,0 @@
-//go:build integration
-
-package rest_test
-
-import (
-	"context"
-	"encoding/json"
-	"io"
-	"net/http"
-	"testing"
-	"time"
-
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
-
-	"github.com/netbirdio/netbird/shared/management/client/rest"
-	"github.com/netbirdio/netbird/shared/management/http/api"
-	"github.com/netbirdio/netbird/shared/management/http/util"
-)
-
-var testAzureIntegration = api.AzureIntegration{
-	Id:                1,
-	Enabled:           true,
-	ClientId:          "12345678-1234-1234-1234-123456789012",
-	TenantId:          "87654321-4321-4321-4321-210987654321",
-	SyncInterval:      300,
-	GroupPrefixes:     []string{"eng-"},
-	UserGroupPrefixes: []string{"dev-"},
-	Host:              "microsoft.com",
-	LastSyncedAt:      time.Date(2024, 1, 1, 0, 0, 0, 0, time.UTC),
-}
-
-func TestAzureIDP_List_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal([]api.AzureIntegration{testAzureIntegration})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.List(context.Background())
-		require.NoError(t, err)
-		assert.Len(t, ret, 1)
-		assert.Equal(t, testAzureIntegration, ret[0])
-	})
-}
-
-func TestAzureIDP_List_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.List(context.Background())
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Empty(t, ret)
-	})
-}
-
-func TestAzureIDP_Get_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal(testAzureIntegration)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Get(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Equal(t, testAzureIntegration, *ret)
-	})
-}
-
-func TestAzureIDP_Get_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Get(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestAzureIDP_Create_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "POST", r.Method)
-			reqBytes, err := io.ReadAll(r.Body)
-			require.NoError(t, err)
-			var req api.CreateAzureIntegrationRequest
-			err = json.Unmarshal(reqBytes, &req)
-			require.NoError(t, err)
-			assert.Equal(t, "12345678-1234-1234-1234-123456789012", req.ClientId)
-			retBytes, _ := json.Marshal(testAzureIntegration)
-			_, err = w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Create(context.Background(), api.CreateAzureIntegrationRequest{
-			ClientId:      "12345678-1234-1234-1234-123456789012",
-			ClientSecret:  "secret",
-			TenantId:      "87654321-4321-4321-4321-210987654321",
-			Host:          api.CreateAzureIntegrationRequestHostMicrosoftCom,
-			GroupPrefixes: &[]string{"eng-"},
-		})
-		require.NoError(t, err)
-		assert.Equal(t, testAzureIntegration, *ret)
-	})
-}
-
-func TestAzureIDP_Create_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Create(context.Background(), api.CreateAzureIntegrationRequest{})
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestAzureIDP_Update_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "PUT", r.Method)
-			reqBytes, err := io.ReadAll(r.Body)
-			require.NoError(t, err)
-			var req api.UpdateAzureIntegrationRequest
-			err = json.Unmarshal(reqBytes, &req)
-			require.NoError(t, err)
-			assert.Equal(t, true, *req.Enabled)
-			retBytes, _ := json.Marshal(testAzureIntegration)
-			_, err = w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Update(context.Background(), "int-1", api.UpdateAzureIntegrationRequest{
-			Enabled: ptr(true),
-		})
-		require.NoError(t, err)
-		assert.Equal(t, testAzureIntegration, *ret)
-	})
-}
-
-func TestAzureIDP_Update_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Update(context.Background(), "int-1", api.UpdateAzureIntegrationRequest{})
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestAzureIDP_Delete_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "DELETE", r.Method)
-			w.WriteHeader(200)
-		})
-		err := c.AzureIDP.Delete(context.Background(), "int-1")
-		require.NoError(t, err)
-	})
-}
-
-func TestAzureIDP_Delete_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		err := c.AzureIDP.Delete(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-	})
-}
-
-func TestAzureIDP_Sync_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1/sync", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "POST", r.Method)
-			retBytes, _ := json.Marshal(api.SyncResult{Result: ptr("ok")})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Sync(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Equal(t, "ok", *ret.Result)
-	})
-}
-
-func TestAzureIDP_Sync_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1/sync", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.Sync(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestAzureIDP_GetLogs_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1/logs", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal([]api.IdpIntegrationSyncLog{testSyncLog})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.GetLogs(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Len(t, ret, 1)
-		assert.Equal(t, testSyncLog, ret[0])
-	})
-}
-
-func TestAzureIDP_GetLogs_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/azure-idp/int-1/logs", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.AzureIDP.GetLogs(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Empty(t, ret)
-	})
-}

shared/management/client/rest/client.go

@@ -110,15 +110,6 @@ type Client struct {
 	// see more: https://docs.netbird.io/api/resources/scim
 	SCIM *SCIMAPI
 
-	// GoogleIDP NetBird Google Workspace IDP integration APIs
-	GoogleIDP *GoogleIDPAPI
-
-	// AzureIDP NetBird Azure AD IDP integration APIs
-	AzureIDP *AzureIDPAPI
-
-	// OktaScimIDP NetBird Okta SCIM IDP integration APIs
-	OktaScimIDP *OktaScimIDPAPI
-
 	// EventStreaming NetBird Event Streaming integration APIs
 	// see more: https://docs.netbird.io/api/resources/event-streaming
 	EventStreaming *EventStreamingAPI
@@ -194,9 +185,6 @@ func (c *Client) initialize() {
 	c.MSP = &MSPAPI{c}
 	c.EDR = &EDRAPI{c}
 	c.SCIM = &SCIMAPI{c}
-	c.GoogleIDP = &GoogleIDPAPI{c}
-	c.AzureIDP = &AzureIDPAPI{c}
-	c.OktaScimIDP = &OktaScimIDPAPI{c}
 	c.EventStreaming = &EventStreamingAPI{c}
 	c.IdentityProviders = &IdentityProvidersAPI{c}
 	c.Ingress = &IngressAPI{c}

shared/management/client/rest/google_idp.go

@@ -1,112 +0,0 @@
-package rest
-
-import (
-	"bytes"
-	"context"
-	"encoding/json"
-
-	"github.com/netbirdio/netbird/shared/management/http/api"
-)
-
-// GoogleIDPAPI APIs for Google Workspace IDP integrations
-type GoogleIDPAPI struct {
-	c *Client
-}
-
-// List retrieves all Google Workspace IDP integrations
-func (a *GoogleIDPAPI) List(ctx context.Context) ([]api.GoogleIntegration, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/google-idp", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[[]api.GoogleIntegration](resp)
-	return ret, err
-}
-
-// Get retrieves a specific Google Workspace IDP integration by ID
-func (a *GoogleIDPAPI) Get(ctx context.Context, integrationID string) (*api.GoogleIntegration, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/google-idp/"+integrationID, nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.GoogleIntegration](resp)
-	return &ret, err
-}
-
-// Create creates a new Google Workspace IDP integration
-func (a *GoogleIDPAPI) Create(ctx context.Context, request api.CreateGoogleIntegrationRequest) (*api.GoogleIntegration, error) {
-	requestBytes, err := json.Marshal(request)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := a.c.NewRequest(ctx, "POST", "/api/integrations/google-idp", bytes.NewReader(requestBytes), nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.GoogleIntegration](resp)
-	return &ret, err
-}
-
-// Update updates an existing Google Workspace IDP integration
-func (a *GoogleIDPAPI) Update(ctx context.Context, integrationID string, request api.UpdateGoogleIntegrationRequest) (*api.GoogleIntegration, error) {
-	requestBytes, err := json.Marshal(request)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := a.c.NewRequest(ctx, "PUT", "/api/integrations/google-idp/"+integrationID, bytes.NewReader(requestBytes), nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.GoogleIntegration](resp)
-	return &ret, err
-}
-
-// Delete deletes a Google Workspace IDP integration
-func (a *GoogleIDPAPI) Delete(ctx context.Context, integrationID string) error {
-	resp, err := a.c.NewRequest(ctx, "DELETE", "/api/integrations/google-idp/"+integrationID, nil, nil)
-	if err != nil {
-		return err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	return nil
-}
-
-// Sync triggers a manual sync for a Google Workspace IDP integration
-func (a *GoogleIDPAPI) Sync(ctx context.Context, integrationID string) (*api.SyncResult, error) {
-	resp, err := a.c.NewRequest(ctx, "POST", "/api/integrations/google-idp/"+integrationID+"/sync", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.SyncResult](resp)
-	return &ret, err
-}
-
-// GetLogs retrieves synchronization logs for a Google Workspace IDP integration
-func (a *GoogleIDPAPI) GetLogs(ctx context.Context, integrationID string) ([]api.IdpIntegrationSyncLog, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/google-idp/"+integrationID+"/logs", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[[]api.IdpIntegrationSyncLog](resp)
-	return ret, err
-}

shared/management/client/rest/google_idp_test.go

@@ -1,248 +0,0 @@
-//go:build integration
-
-package rest_test
-
-import (
-	"context"
-	"encoding/json"
-	"io"
-	"net/http"
-	"testing"
-	"time"
-
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
-
-	"github.com/netbirdio/netbird/shared/management/client/rest"
-	"github.com/netbirdio/netbird/shared/management/http/api"
-	"github.com/netbirdio/netbird/shared/management/http/util"
-)
-
-var testGoogleIntegration = api.GoogleIntegration{
-	Id:                1,
-	Enabled:           true,
-	CustomerId:        "C01234567",
-	SyncInterval:      300,
-	GroupPrefixes:     []string{"eng-"},
-	UserGroupPrefixes: []string{"dev-"},
-	LastSyncedAt:      time.Date(2024, 1, 1, 0, 0, 0, 0, time.UTC),
-}
-
-func TestGoogleIDP_List_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal([]api.GoogleIntegration{testGoogleIntegration})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.List(context.Background())
-		require.NoError(t, err)
-		assert.Len(t, ret, 1)
-		assert.Equal(t, testGoogleIntegration, ret[0])
-	})
-}
-
-func TestGoogleIDP_List_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.List(context.Background())
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Empty(t, ret)
-	})
-}
-
-func TestGoogleIDP_Get_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal(testGoogleIntegration)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Get(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Equal(t, testGoogleIntegration, *ret)
-	})
-}
-
-func TestGoogleIDP_Get_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Get(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestGoogleIDP_Create_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "POST", r.Method)
-			reqBytes, err := io.ReadAll(r.Body)
-			require.NoError(t, err)
-			var req api.CreateGoogleIntegrationRequest
-			err = json.Unmarshal(reqBytes, &req)
-			require.NoError(t, err)
-			assert.Equal(t, "C01234567", req.CustomerId)
-			retBytes, _ := json.Marshal(testGoogleIntegration)
-			_, err = w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Create(context.Background(), api.CreateGoogleIntegrationRequest{
-			CustomerId:        "C01234567",
-			ServiceAccountKey: "key-data",
-			GroupPrefixes:     &[]string{"eng-"},
-		})
-		require.NoError(t, err)
-		assert.Equal(t, testGoogleIntegration, *ret)
-	})
-}
-
-func TestGoogleIDP_Create_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Create(context.Background(), api.CreateGoogleIntegrationRequest{})
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestGoogleIDP_Update_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "PUT", r.Method)
-			reqBytes, err := io.ReadAll(r.Body)
-			require.NoError(t, err)
-			var req api.UpdateGoogleIntegrationRequest
-			err = json.Unmarshal(reqBytes, &req)
-			require.NoError(t, err)
-			assert.Equal(t, true, *req.Enabled)
-			retBytes, _ := json.Marshal(testGoogleIntegration)
-			_, err = w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Update(context.Background(), "int-1", api.UpdateGoogleIntegrationRequest{
-			Enabled: ptr(true),
-		})
-		require.NoError(t, err)
-		assert.Equal(t, testGoogleIntegration, *ret)
-	})
-}
-
-func TestGoogleIDP_Update_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Update(context.Background(), "int-1", api.UpdateGoogleIntegrationRequest{})
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestGoogleIDP_Delete_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "DELETE", r.Method)
-			w.WriteHeader(200)
-		})
-		err := c.GoogleIDP.Delete(context.Background(), "int-1")
-		require.NoError(t, err)
-	})
-}
-
-func TestGoogleIDP_Delete_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		err := c.GoogleIDP.Delete(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-	})
-}
-
-func TestGoogleIDP_Sync_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1/sync", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "POST", r.Method)
-			retBytes, _ := json.Marshal(api.SyncResult{Result: ptr("ok")})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Sync(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Equal(t, "ok", *ret.Result)
-	})
-}
-
-func TestGoogleIDP_Sync_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1/sync", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.Sync(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestGoogleIDP_GetLogs_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1/logs", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal([]api.IdpIntegrationSyncLog{testSyncLog})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.GetLogs(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Len(t, ret, 1)
-		assert.Equal(t, testSyncLog, ret[0])
-	})
-}
-
-func TestGoogleIDP_GetLogs_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/google-idp/int-1/logs", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.GoogleIDP.GetLogs(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Empty(t, ret)
-	})
-}

shared/management/client/rest/okta_scim_idp.go

@@ -1,112 +0,0 @@
-package rest
-
-import (
-	"bytes"
-	"context"
-	"encoding/json"
-
-	"github.com/netbirdio/netbird/shared/management/http/api"
-)
-
-// OktaScimIDPAPI APIs for Okta SCIM IDP integrations
-type OktaScimIDPAPI struct {
-	c *Client
-}
-
-// List retrieves all Okta SCIM IDP integrations
-func (a *OktaScimIDPAPI) List(ctx context.Context) ([]api.OktaScimIntegration, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/okta-scim-idp", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[[]api.OktaScimIntegration](resp)
-	return ret, err
-}
-
-// Get retrieves a specific Okta SCIM IDP integration by ID
-func (a *OktaScimIDPAPI) Get(ctx context.Context, integrationID string) (*api.OktaScimIntegration, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/okta-scim-idp/"+integrationID, nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.OktaScimIntegration](resp)
-	return &ret, err
-}
-
-// Create creates a new Okta SCIM IDP integration
-func (a *OktaScimIDPAPI) Create(ctx context.Context, request api.CreateOktaScimIntegrationRequest) (*api.OktaScimIntegration, error) {
-	requestBytes, err := json.Marshal(request)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := a.c.NewRequest(ctx, "POST", "/api/integrations/okta-scim-idp", bytes.NewReader(requestBytes), nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.OktaScimIntegration](resp)
-	return &ret, err
-}
-
-// Update updates an existing Okta SCIM IDP integration
-func (a *OktaScimIDPAPI) Update(ctx context.Context, integrationID string, request api.UpdateOktaScimIntegrationRequest) (*api.OktaScimIntegration, error) {
-	requestBytes, err := json.Marshal(request)
-	if err != nil {
-		return nil, err
-	}
-	resp, err := a.c.NewRequest(ctx, "PUT", "/api/integrations/okta-scim-idp/"+integrationID, bytes.NewReader(requestBytes), nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.OktaScimIntegration](resp)
-	return &ret, err
-}
-
-// Delete deletes an Okta SCIM IDP integration
-func (a *OktaScimIDPAPI) Delete(ctx context.Context, integrationID string) error {
-	resp, err := a.c.NewRequest(ctx, "DELETE", "/api/integrations/okta-scim-idp/"+integrationID, nil, nil)
-	if err != nil {
-		return err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	return nil
-}
-
-// RegenerateToken regenerates the SCIM API token for an Okta SCIM integration
-func (a *OktaScimIDPAPI) RegenerateToken(ctx context.Context, integrationID string) (*api.ScimTokenResponse, error) {
-	resp, err := a.c.NewRequest(ctx, "POST", "/api/integrations/okta-scim-idp/"+integrationID+"/token", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[api.ScimTokenResponse](resp)
-	return &ret, err
-}
-
-// GetLogs retrieves synchronization logs for an Okta SCIM IDP integration
-func (a *OktaScimIDPAPI) GetLogs(ctx context.Context, integrationID string) ([]api.IdpIntegrationSyncLog, error) {
-	resp, err := a.c.NewRequest(ctx, "GET", "/api/integrations/okta-scim-idp/"+integrationID+"/logs", nil, nil)
-	if err != nil {
-		return nil, err
-	}
-	if resp.Body != nil {
-		defer resp.Body.Close()
-	}
-	ret, err := parseResponse[[]api.IdpIntegrationSyncLog](resp)
-	return ret, err
-}

shared/management/client/rest/okta_scim_idp_test.go

@@ -1,246 +0,0 @@
-//go:build integration
-
-package rest_test
-
-import (
-	"context"
-	"encoding/json"
-	"io"
-	"net/http"
-	"testing"
-	"time"
-
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
-
-	"github.com/netbirdio/netbird/shared/management/client/rest"
-	"github.com/netbirdio/netbird/shared/management/http/api"
-	"github.com/netbirdio/netbird/shared/management/http/util"
-)
-
-var testOktaScimIntegration = api.OktaScimIntegration{
-	Id:                1,
-	AuthToken:         "****",
-	Enabled:           true,
-	GroupPrefixes:     []string{"eng-"},
-	UserGroupPrefixes: []string{"dev-"},
-	LastSyncedAt:      time.Date(2024, 1, 1, 0, 0, 0, 0, time.UTC),
-}
-
-func TestOktaScimIDP_List_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal([]api.OktaScimIntegration{testOktaScimIntegration})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.List(context.Background())
-		require.NoError(t, err)
-		assert.Len(t, ret, 1)
-		assert.Equal(t, testOktaScimIntegration, ret[0])
-	})
-}
-
-func TestOktaScimIDP_List_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.List(context.Background())
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Empty(t, ret)
-	})
-}
-
-func TestOktaScimIDP_Get_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal(testOktaScimIntegration)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.Get(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Equal(t, testOktaScimIntegration, *ret)
-	})
-}
-
-func TestOktaScimIDP_Get_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.Get(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestOktaScimIDP_Create_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "POST", r.Method)
-			reqBytes, err := io.ReadAll(r.Body)
-			require.NoError(t, err)
-			var req api.CreateOktaScimIntegrationRequest
-			err = json.Unmarshal(reqBytes, &req)
-			require.NoError(t, err)
-			assert.Equal(t, "my-okta-connection", req.ConnectionName)
-			retBytes, _ := json.Marshal(testOktaScimIntegration)
-			_, err = w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.Create(context.Background(), api.CreateOktaScimIntegrationRequest{
-			ConnectionName: "my-okta-connection",
-			GroupPrefixes:  &[]string{"eng-"},
-		})
-		require.NoError(t, err)
-		assert.Equal(t, testOktaScimIntegration, *ret)
-	})
-}
-
-func TestOktaScimIDP_Create_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.Create(context.Background(), api.CreateOktaScimIntegrationRequest{})
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestOktaScimIDP_Update_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "PUT", r.Method)
-			reqBytes, err := io.ReadAll(r.Body)
-			require.NoError(t, err)
-			var req api.UpdateOktaScimIntegrationRequest
-			err = json.Unmarshal(reqBytes, &req)
-			require.NoError(t, err)
-			assert.Equal(t, true, *req.Enabled)
-			retBytes, _ := json.Marshal(testOktaScimIntegration)
-			_, err = w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.Update(context.Background(), "int-1", api.UpdateOktaScimIntegrationRequest{
-			Enabled: ptr(true),
-		})
-		require.NoError(t, err)
-		assert.Equal(t, testOktaScimIntegration, *ret)
-	})
-}
-
-func TestOktaScimIDP_Update_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "No", Code: 400})
-			w.WriteHeader(400)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.Update(context.Background(), "int-1", api.UpdateOktaScimIntegrationRequest{})
-		assert.Error(t, err)
-		assert.Equal(t, "No", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestOktaScimIDP_Delete_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "DELETE", r.Method)
-			w.WriteHeader(200)
-		})
-		err := c.OktaScimIDP.Delete(context.Background(), "int-1")
-		require.NoError(t, err)
-	})
-}
-
-func TestOktaScimIDP_Delete_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		err := c.OktaScimIDP.Delete(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-	})
-}
-
-func TestOktaScimIDP_RegenerateToken_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1/token", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "POST", r.Method)
-			retBytes, _ := json.Marshal(testScimToken)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.RegenerateToken(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Equal(t, testScimToken, *ret)
-	})
-}
-
-func TestOktaScimIDP_RegenerateToken_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1/token", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.RegenerateToken(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Nil(t, ret)
-	})
-}
-
-func TestOktaScimIDP_GetLogs_200(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1/logs", func(w http.ResponseWriter, r *http.Request) {
-			assert.Equal(t, "GET", r.Method)
-			retBytes, _ := json.Marshal([]api.IdpIntegrationSyncLog{testSyncLog})
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.GetLogs(context.Background(), "int-1")
-		require.NoError(t, err)
-		assert.Len(t, ret, 1)
-		assert.Equal(t, testSyncLog, ret[0])
-	})
-}
-
-func TestOktaScimIDP_GetLogs_Err(t *testing.T) {
-	withMockClient(func(c *rest.Client, mux *http.ServeMux) {
-		mux.HandleFunc("/api/integrations/okta-scim-idp/int-1/logs", func(w http.ResponseWriter, r *http.Request) {
-			retBytes, _ := json.Marshal(util.ErrorResponse{Message: "Not found", Code: 404})
-			w.WriteHeader(404)
-			_, err := w.Write(retBytes)
-			require.NoError(t, err)
-		})
-		ret, err := c.OktaScimIDP.GetLogs(context.Background(), "int-1")
-		assert.Error(t, err)
-		assert.Equal(t, "Not found", err.Error())
-		assert.Empty(t, ret)
-	})
-}

shared/management/http/api/types.gen.go

@@ -16,24 +16,6 @@ const (
 	TokenAuthScopes  = "TokenAuth.Scopes"
 )
 
-// Defines values for CreateAzureIntegrationRequestHost.
-const (
-	CreateAzureIntegrationRequestHostMicrosoftCom CreateAzureIntegrationRequestHost = "microsoft.com"
-	CreateAzureIntegrationRequestHostMicrosoftUs  CreateAzureIntegrationRequestHost = "microsoft.us"
-)
-
-// Valid indicates whether the value is a known member of the CreateAzureIntegrationRequestHost enum.
-func (e CreateAzureIntegrationRequestHost) Valid() bool {
-	switch e {
-	case CreateAzureIntegrationRequestHostMicrosoftCom:
-		return true
-	case CreateAzureIntegrationRequestHostMicrosoftUs:
-		return true
-	default:
-		return false
-	}
-}
-
 // Defines values for CreateIntegrationRequestPlatform.
 const (
 	CreateIntegrationRequestPlatformDatadog     CreateIntegrationRequestPlatform = "datadog"
@@ -1468,36 +1450,6 @@ type AvailablePorts struct {
 	Udp int `json:"udp"`
 }
 
-// AzureIntegration defines model for AzureIntegration.
-type AzureIntegration struct {
-	// ClientId Azure AD application (client) ID
-	ClientId string `json:"client_id"`
-
-	// Enabled Whether the integration is enabled
-	Enabled bool `json:"enabled"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes []string `json:"group_prefixes"`
-
-	// Host Azure host domain for the Graph API
-	Host string `json:"host"`
-
-	// Id The unique identifier for the integration
-	Id int64 `json:"id"`
-
-	// LastSyncedAt Timestamp of the last synchronization
-	LastSyncedAt time.Time `json:"last_synced_at"`
-
-	// SyncInterval Sync interval in seconds
-	SyncInterval int `json:"sync_interval"`
-
-	// TenantId Azure AD tenant ID
-	TenantId string `json:"tenant_id"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes []string `json:"user_group_prefixes"`
-}
-
 // BearerAuthConfig defines model for BearerAuthConfig.
 type BearerAuthConfig struct {
 	// DistributionGroups List of group IDs that can use bearer auth
@@ -1605,51 +1557,6 @@ type Country struct {
 // CountryCode 2-letter ISO 3166-1 alpha-2 code that represents the country
 type CountryCode = string
 
-// CreateAzureIntegrationRequest defines model for CreateAzureIntegrationRequest.
-type CreateAzureIntegrationRequest struct {
-	// ClientId Azure AD application (client) ID
-	ClientId string `json:"client_id"`
-
-	// ClientSecret Base64-encoded Azure AD client secret
-	ClientSecret string `json:"client_secret"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
-
-	// Host Azure host domain for the Graph API
-	Host CreateAzureIntegrationRequestHost `json:"host"`
-
-	// SyncInterval Sync interval in seconds (minimum 300). Defaults to 300 if not specified.
-	SyncInterval *int `json:"sync_interval,omitempty"`
-
-	// TenantId Azure AD tenant ID
-	TenantId string `json:"tenant_id"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
-}
-
-// CreateAzureIntegrationRequestHost Azure host domain for the Graph API
-type CreateAzureIntegrationRequestHost string
-
-// CreateGoogleIntegrationRequest defines model for CreateGoogleIntegrationRequest.
-type CreateGoogleIntegrationRequest struct {
-	// CustomerId Customer ID from Google Workspace Account Settings
-	CustomerId string `json:"customer_id"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
-
-	// ServiceAccountKey Base64-encoded Google service account key
-	ServiceAccountKey string `json:"service_account_key"`
-
-	// SyncInterval Sync interval in seconds (minimum 300). Defaults to 300 if not specified.
-	SyncInterval *int `json:"sync_interval,omitempty"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
-}
-
 // CreateIntegrationRequest Request payload for creating a new event streaming integration. Also used as the structure for the PUT request body, but not all fields are applicable for updates (see PUT operation description).
 type CreateIntegrationRequest struct {
 	// Config Platform-specific configuration as key-value pairs. For creation, all necessary credentials and settings must be provided. For updates, provide the fields to change or the entire new configuration.
@@ -1665,19 +1572,7 @@ type CreateIntegrationRequest struct {
 // CreateIntegrationRequestPlatform The event streaming platform to integrate with (e.g., "datadog", "s3", "firehose"). This field is used for creation. For updates (PUT), this field, if sent, is ignored by the backend.
 type CreateIntegrationRequestPlatform string
 
-// CreateOktaScimIntegrationRequest defines model for CreateOktaScimIntegrationRequest.
-type CreateOktaScimIntegrationRequest struct {
-	// ConnectionName The Okta enterprise connection name on Auth0
-	ConnectionName string `json:"connection_name"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
-}
-
-// CreateScimIntegrationRequest defines model for CreateScimIntegrationRequest.
+// CreateScimIntegrationRequest Request payload for creating an SCIM IDP integration
 type CreateScimIntegrationRequest struct {
 	// GroupPrefixes List of start_with string patterns for groups to sync
 	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
@@ -2052,30 +1947,6 @@ type GeoLocationCheckAction string
 // GetTenantsResponse defines model for GetTenantsResponse.
 type GetTenantsResponse = []TenantResponse
 
-// GoogleIntegration defines model for GoogleIntegration.
-type GoogleIntegration struct {
-	// CustomerId Customer ID from Google Workspace
-	CustomerId string `json:"customer_id"`
-
-	// Enabled Whether the integration is enabled
-	Enabled bool `json:"enabled"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes []string `json:"group_prefixes"`
-
-	// Id The unique identifier for the integration
-	Id int64 `json:"id"`
-
-	// LastSyncedAt Timestamp of the last synchronization
-	LastSyncedAt time.Time `json:"last_synced_at"`
-
-	// SyncInterval Sync interval in seconds
-	SyncInterval int `json:"sync_interval"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes []string `json:"user_group_prefixes"`
-}
-
 // Group defines model for Group.
 type Group struct {
 	// Id Group ID
@@ -2367,12 +2238,6 @@ type InstanceVersionInfo struct {
 	ManagementUpdateAvailable bool `json:"management_update_available"`
 }
 
-// IntegrationEnabled defines model for IntegrationEnabled.
-type IntegrationEnabled struct {
-	// Enabled Whether the integration is enabled
-	Enabled *bool `json:"enabled,omitempty"`
-}
-
 // IntegrationResponse Represents an event streaming integration.
 type IntegrationResponse struct {
 	// AccountId The identifier of the account this integration belongs to.
@@ -2400,15 +2265,6 @@ type IntegrationResponse struct {
 // IntegrationResponsePlatform The event streaming platform.
 type IntegrationResponsePlatform string
 
-// IntegrationSyncFilters defines model for IntegrationSyncFilters.
-type IntegrationSyncFilters struct {
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
-}
-
 // InvoicePDFResponse defines model for InvoicePDFResponse.
 type InvoicePDFResponse struct {
 	// Url URL to redirect the user to invoice.
@@ -2828,27 +2684,6 @@ type OSVersionCheck struct {
 	Windows *MinKernelVersionCheck `json:"windows,omitempty"`
 }
 
-// OktaScimIntegration defines model for OktaScimIntegration.
-type OktaScimIntegration struct {
-	// AuthToken SCIM API token (full on creation/regeneration, masked on retrieval)
-	AuthToken string `json:"auth_token"`
-
-	// Enabled Whether the integration is enabled
-	Enabled bool `json:"enabled"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes []string `json:"group_prefixes"`
-
-	// Id The unique identifier for the integration
-	Id int64 `json:"id"`
-
-	// LastSyncedAt Timestamp of the last synchronization
-	LastSyncedAt time.Time `json:"last_synced_at"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes []string `json:"user_group_prefixes"`
-}
-
 // PINAuthConfig defines model for PINAuthConfig.
 type PINAuthConfig struct {
 	// Enabled Whether PIN auth is enabled
@@ -3698,12 +3533,12 @@ type RulePortRange struct {
 	Start int `json:"start"`
 }
 
-// ScimIntegration defines model for ScimIntegration.
+// ScimIntegration Represents a SCIM IDP integration
 type ScimIntegration struct {
 	// AuthToken SCIM API token (full on creation, masked otherwise)
 	AuthToken string `json:"auth_token"`
 
-	// Enabled Whether the integration is enabled
+	// Enabled Indicates whether the integration is enabled
 	Enabled bool `json:"enabled"`
 
 	// GroupPrefixes List of start_with string patterns for groups to sync
@@ -3715,9 +3550,6 @@ type ScimIntegration struct {
 	// LastSyncedAt Timestamp of when the integration was last synced
 	LastSyncedAt time.Time `json:"last_synced_at"`
 
-	// Prefix The connection prefix used for the SCIM provider
-	Prefix string `json:"prefix"`
-
 	// Provider Name of the SCIM identity provider
 	Provider string `json:"provider"`
 
@@ -4119,11 +3951,6 @@ type Subscription struct {
 	UpdatedAt time.Time `json:"updated_at"`
 }
 
-// SyncResult Response for a manual sync trigger
-type SyncResult struct {
-	Result *string `json:"result,omitempty"`
-}
-
 // TenantGroupResponse defines model for TenantGroupResponse.
 type TenantGroupResponse struct {
 	// Id The Group ID
@@ -4169,74 +3996,14 @@ type TenantResponse struct {
 // TenantResponseStatus The status of the tenant
 type TenantResponseStatus string
 
-// UpdateAzureIntegrationRequest defines model for UpdateAzureIntegrationRequest.
-type UpdateAzureIntegrationRequest struct {
-	// ClientId Azure AD application (client) ID
-	ClientId *string `json:"client_id,omitempty"`
-
-	// ClientSecret Base64-encoded Azure AD client secret
-	ClientSecret *string `json:"client_secret,omitempty"`
-
-	// Enabled Whether the integration is enabled
-	Enabled *bool `json:"enabled,omitempty"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
-
-	// SyncInterval Sync interval in seconds (minimum 300)
-	SyncInterval *int `json:"sync_interval,omitempty"`
-
-	// TenantId Azure AD tenant ID
-	TenantId *string `json:"tenant_id,omitempty"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
-}
-
-// UpdateGoogleIntegrationRequest defines model for UpdateGoogleIntegrationRequest.
-type UpdateGoogleIntegrationRequest struct {
-	// CustomerId Customer ID from Google Workspace Account Settings
-	CustomerId *string `json:"customer_id,omitempty"`
-
-	// Enabled Whether the integration is enabled
-	Enabled *bool `json:"enabled,omitempty"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
-
-	// ServiceAccountKey Base64-encoded Google service account key
-	ServiceAccountKey *string `json:"service_account_key,omitempty"`
-
-	// SyncInterval Sync interval in seconds (minimum 300)
-	SyncInterval *int `json:"sync_interval,omitempty"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
-}
-
-// UpdateOktaScimIntegrationRequest defines model for UpdateOktaScimIntegrationRequest.
-type UpdateOktaScimIntegrationRequest struct {
-	// Enabled Whether the integration is enabled
-	Enabled *bool `json:"enabled,omitempty"`
-
-	// GroupPrefixes List of start_with string patterns for groups to sync
-	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
-
-	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
-	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
-}
-
-// UpdateScimIntegrationRequest defines model for UpdateScimIntegrationRequest.
+// UpdateScimIntegrationRequest Request payload for updating an SCIM IDP integration
 type UpdateScimIntegrationRequest struct {
-	// Enabled Whether the integration is enabled
+	// Enabled Indicates whether the integration is enabled
 	Enabled *bool `json:"enabled,omitempty"`
 
 	// GroupPrefixes List of start_with string patterns for groups to sync
 	GroupPrefixes *[]string `json:"group_prefixes,omitempty"`
 
-	// Prefix The connection prefix used for the SCIM provider
-	Prefix *string `json:"prefix,omitempty"`
-
 	// UserGroupPrefixes List of start_with string patterns for groups which users to sync
 	UserGroupPrefixes *[]string `json:"user_group_prefixes,omitempty"`
 }
@@ -4746,12 +4513,6 @@ type PostApiIngressPeersJSONRequestBody = IngressPeerCreateRequest
 // PutApiIngressPeersIngressPeerIdJSONRequestBody defines body for PutApiIngressPeersIngressPeerId for application/json ContentType.
 type PutApiIngressPeersIngressPeerIdJSONRequestBody = IngressPeerUpdateRequest
 
-// CreateAzureIntegrationJSONRequestBody defines body for CreateAzureIntegration for application/json ContentType.
-type CreateAzureIntegrationJSONRequestBody = CreateAzureIntegrationRequest
-
-// UpdateAzureIntegrationJSONRequestBody defines body for UpdateAzureIntegration for application/json ContentType.
-type UpdateAzureIntegrationJSONRequestBody = UpdateAzureIntegrationRequest
-
 // PostApiIntegrationsBillingAwsMarketplaceActivateJSONRequestBody defines body for PostApiIntegrationsBillingAwsMarketplaceActivate for application/json ContentType.
 type PostApiIntegrationsBillingAwsMarketplaceActivateJSONRequestBody PostApiIntegrationsBillingAwsMarketplaceActivateJSONBody
 
@@ -4788,12 +4549,6 @@ type CreateSentinelOneEDRIntegrationJSONRequestBody = EDRSentinelOneRequest
 // UpdateSentinelOneEDRIntegrationJSONRequestBody defines body for UpdateSentinelOneEDRIntegration for application/json ContentType.
 type UpdateSentinelOneEDRIntegrationJSONRequestBody = EDRSentinelOneRequest
 
-// CreateGoogleIntegrationJSONRequestBody defines body for CreateGoogleIntegration for application/json ContentType.
-type CreateGoogleIntegrationJSONRequestBody = CreateGoogleIntegrationRequest
-
-// UpdateGoogleIntegrationJSONRequestBody defines body for UpdateGoogleIntegration for application/json ContentType.
-type UpdateGoogleIntegrationJSONRequestBody = UpdateGoogleIntegrationRequest
-
 // PostApiIntegrationsMspTenantsJSONRequestBody defines body for PostApiIntegrationsMspTenants for application/json ContentType.
 type PostApiIntegrationsMspTenantsJSONRequestBody = CreateTenantRequest
 
@@ -4809,12 +4564,6 @@ type PostApiIntegrationsMspTenantsIdSubscriptionJSONRequestBody PostApiIntegrati
 // PostApiIntegrationsMspTenantsIdUnlinkJSONRequestBody defines body for PostApiIntegrationsMspTenantsIdUnlink for application/json ContentType.
 type PostApiIntegrationsMspTenantsIdUnlinkJSONRequestBody PostApiIntegrationsMspTenantsIdUnlinkJSONBody
 
-// CreateOktaScimIntegrationJSONRequestBody defines body for CreateOktaScimIntegration for application/json ContentType.
-type CreateOktaScimIntegrationJSONRequestBody = CreateOktaScimIntegrationRequest
-
-// UpdateOktaScimIntegrationJSONRequestBody defines body for UpdateOktaScimIntegration for application/json ContentType.
-type UpdateOktaScimIntegrationJSONRequestBody = UpdateOktaScimIntegrationRequest
-
 // CreateSCIMIntegrationJSONRequestBody defines body for CreateSCIMIntegration for application/json ContentType.
 type CreateSCIMIntegrationJSONRequestBody = CreateScimIntegrationRequest