fetch_workspace.go

package main

import (
	"context"
	"log"
	"net/http"
	"os"

	_ "github.com/joho/godotenv/autoload"
	"github.com/project-kessel/kessel-sdk-go/kessel/auth"

	v2 "github.com/project-kessel/kessel-sdk-go/kessel/rbac/v2"
)

func fetchWorkspace() {
	ctx := context.Background()

	discovered, err := auth.FetchOIDCDiscovery(ctx, os.Getenv("AUTH_DISCOVERY_ISSUER_URL"), auth.FetchOIDCDiscoveryOptions{
		HttpClient: nil, // Optionally specify an http client - defaults to http.DefaultClient
	})

	if err != nil {
		panic(err)
	}

	oauthCredentials := auth.NewOAuth2ClientCredentials(os.Getenv("AUTH_CLIENT_ID"), os.Getenv("AUTH_CLIENT_SECRET"), discovered.TokenEndpoint)

	// GET /api/rbac/v2/workspaces/?type=default&with_ancestry=true
	// with_ancestry=true is sent by default so fallback workspaces are
	// included even without explicit inventory permission.
	defaultWorkspace, err := v2.FetchDefaultWorkspace(ctx, "http://localhost:8000", "12345", v2.FetchWorkspaceOptions{
		HttpClient: http.DefaultClient,
		Auth: auth.OAuth2AuthRequest(&oauthCredentials, auth.OAuth2AuthRequestOptions{
			HttpClient: http.DefaultClient,
		}),
	})

	if err != nil {
		panic(err)
	}

	log.Printf("Found default Workspace: %+v", defaultWorkspace)

	// GET /api/rbac/v2/workspaces/?type=root&with_ancestry=true
	rootWorkspace, err := v2.FetchRootWorkspace(ctx, "http://localhost:8000", "12345", v2.FetchWorkspaceOptions{
		HttpClient: http.DefaultClient,
		Auth: auth.OAuth2AuthRequest(&oauthCredentials, auth.OAuth2AuthRequestOptions{
			HttpClient: http.DefaultClient,
		}),
	})

	if err != nil {
		panic(err)
	}

	log.Printf("Found root Workspace: %+v", rootWorkspace)
}

func main() { fetchWorkspace() }