diff --git a/pkg/scimbridge/scim/client.go b/pkg/scimbridge/scim/client.go new file mode 100644 index 000000000..a320fb27c --- /dev/null +++ b/pkg/scimbridge/scim/client.go @@ -0,0 +1,235 @@ +// Copyright (c) 2025 Probo Inc . +// +// Permission to use, copy, modify, and/or distribute this software for any +// purpose with or without fee is hereby granted, provided that the above +// copyright notice and this permission notice appear in all copies. +// +// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH +// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY +// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, +// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM +// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR +// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR +// PERFORMANCE OF THIS SOFTWARE. + +package scim + +import ( + "bytes" + "context" + "encoding/json" + "fmt" + "io" + "net/http" + "net/url" + "strings" + + "go.gearno.de/kit/httpclient" +) + +type Client struct { + endpoint string + token string + httpClient *http.Client +} + +func NewClient(endpoint, token string) *Client { + return &Client{ + endpoint: strings.TrimSuffix(endpoint, "/"), + token: token, + httpClient: httpclient.DefaultPooledClient(), + } +} + +func (c *Client) ListUsers(ctx context.Context) ([]User, error) { + var allUsers []User + startIndex := 1 + count := 100 + + for { + users, total, err := c.listUsersPage(ctx, startIndex, count) + if err != nil { + return nil, err + } + + allUsers = append(allUsers, users...) + + if len(allUsers) >= total { + break + } + + startIndex += count + } + + return allUsers, nil +} + +func (c *Client) listUsersPage(ctx context.Context, startIndex, count int) ([]User, int, error) { + reqURL := fmt.Sprintf("%s/Users?startIndex=%d&count=%d", c.endpoint, startIndex, count) + + req, err := http.NewRequestWithContext(ctx, http.MethodGet, reqURL, nil) + if err != nil { + return nil, 0, fmt.Errorf("cannot create request: %w", err) + } + + c.setHeaders(req) + + resp, err := c.httpClient.Do(req) + if err != nil { + return nil, 0, fmt.Errorf("cannot fetch users: %w", err) + } + defer resp.Body.Close() + + if resp.StatusCode != http.StatusOK { + body, _ := io.ReadAll(resp.Body) + return nil, 0, fmt.Errorf("SCIM API error: status %d, body: %s", resp.StatusCode, string(body)) + } + + var listResp ListResponse + if err := json.NewDecoder(resp.Body).Decode(&listResp); err != nil { + return nil, 0, fmt.Errorf("cannot decode response: %w", err) + } + + return listResp.Resources, listResp.TotalResults, nil +} + +func (c *Client) CreateUser(ctx context.Context, user *User) error { + payload := map[string]any{ + "schemas": []string{"urn:ietf:params:scim:schemas:core:2.0:User"}, + "userName": user.UserName, + "name": map[string]string{ + "givenName": user.GivenName, + "familyName": user.FamilyName, + "formatted": user.DisplayName, + }, + "displayName": user.DisplayName, + "active": user.Active, + "emails": []map[string]any{ + { + "value": user.UserName, + "type": "work", + "primary": true, + }, + }, + } + + body, err := json.Marshal(payload) + if err != nil { + return fmt.Errorf("cannot marshal user: %w", err) + } + + reqURL := fmt.Sprintf("%s/Users", c.endpoint) + req, err := http.NewRequestWithContext(ctx, http.MethodPost, reqURL, bytes.NewReader(body)) + if err != nil { + return fmt.Errorf("cannot create request: %w", err) + } + + c.setHeaders(req) + req.Header.Set("Content-Type", "application/scim+json") + + resp, err := c.httpClient.Do(req) + if err != nil { + return fmt.Errorf("cannot create user: %w", err) + } + defer resp.Body.Close() + + if resp.StatusCode != http.StatusCreated && resp.StatusCode != http.StatusOK { + respBody, _ := io.ReadAll(resp.Body) + return fmt.Errorf("SCIM API error: status %d, body: %s", resp.StatusCode, string(respBody)) + } + + return nil +} + +func (c *Client) UpdateUser(ctx context.Context, userID string, user *User) error { + payload := map[string]any{ + "schemas": []string{"urn:ietf:params:scim:schemas:core:2.0:User"}, + "userName": user.UserName, + "name": map[string]string{ + "givenName": user.GivenName, + "familyName": user.FamilyName, + "formatted": user.DisplayName, + }, + "displayName": user.DisplayName, + "active": user.Active, + "emails": []map[string]any{ + { + "value": user.UserName, + "type": "work", + "primary": true, + }, + }, + } + + body, err := json.Marshal(payload) + if err != nil { + return fmt.Errorf("cannot marshal user: %w", err) + } + + reqURL := fmt.Sprintf("%s/Users/%s", c.endpoint, url.PathEscape(userID)) + req, err := http.NewRequestWithContext(ctx, http.MethodPut, reqURL, bytes.NewReader(body)) + if err != nil { + return fmt.Errorf("cannot create request: %w", err) + } + + c.setHeaders(req) + req.Header.Set("Content-Type", "application/scim+json") + + resp, err := c.httpClient.Do(req) + if err != nil { + return fmt.Errorf("cannot update user: %w", err) + } + defer resp.Body.Close() + + if resp.StatusCode != http.StatusOK { + respBody, _ := io.ReadAll(resp.Body) + return fmt.Errorf("SCIM API error: status %d, body: %s", resp.StatusCode, string(respBody)) + } + + return nil +} + +func (c *Client) DeactivateUser(ctx context.Context, userID string) error { + payload := map[string]any{ + "schemas": []string{"urn:ietf:params:scim:api:messages:2.0:PatchOp"}, + "Operations": []map[string]any{ + { + "op": "replace", + "path": "active", + "value": false, + }, + }, + } + + body, err := json.Marshal(payload) + if err != nil { + return fmt.Errorf("cannot marshal patch: %w", err) + } + + reqURL := fmt.Sprintf("%s/Users/%s", c.endpoint, url.PathEscape(userID)) + req, err := http.NewRequestWithContext(ctx, http.MethodPatch, reqURL, bytes.NewReader(body)) + if err != nil { + return fmt.Errorf("cannot create request: %w", err) + } + + c.setHeaders(req) + req.Header.Set("Content-Type", "application/scim+json") + + resp, err := c.httpClient.Do(req) + if err != nil { + return fmt.Errorf("cannot deactivate user: %w", err) + } + defer resp.Body.Close() + + if resp.StatusCode != http.StatusOK { + respBody, _ := io.ReadAll(resp.Body) + return fmt.Errorf("SCIM API error: status %d, body: %s", resp.StatusCode, string(respBody)) + } + + return nil +} + +func (c *Client) setHeaders(req *http.Request) { + req.Header.Set("Authorization", "Bearer "+c.token) + req.Header.Set("Accept", "application/scim+json") +} diff --git a/pkg/scimbridge/scim/user.go b/pkg/scimbridge/scim/user.go new file mode 100644 index 000000000..aac2b7e8d --- /dev/null +++ b/pkg/scimbridge/scim/user.go @@ -0,0 +1,32 @@ +// Copyright (c) 2025 Probo Inc . +// +// Permission to use, copy, modify, and/or distribute this software for any +// purpose with or without fee is hereby granted, provided that the above +// copyright notice and this permission notice appear in all copies. +// +// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH +// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY +// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, +// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM +// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR +// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR +// PERFORMANCE OF THIS SOFTWARE. + +package scim + +type User struct { + ID string `json:"id,omitempty"` + UserName string `json:"userName"` + DisplayName string `json:"displayName"` + GivenName string `json:"-"` + FamilyName string `json:"-"` + Active bool `json:"active"` +} + +type ListResponse struct { + Schemas []string `json:"schemas"` + TotalResults int `json:"totalResults"` + StartIndex int `json:"startIndex"` + ItemsPerPage int `json:"itemsPerPage"` + Resources []User `json:"Resources"` +}