Add basic team resource (#2)

* introduce initial "Team" resource support

* Add resources tests

Author: geropl

go.mod

@@ -4,14 +4,15 @@ go 1.23.6
 
 require (
 	github.com/google/go-cmp v0.7.0
-	github.com/mark3labs/mcp-go v0.8.5
+	github.com/google/uuid v1.6.0
+	github.com/mark3labs/mcp-go v0.18.0
+	github.com/spf13/cobra v1.9.1
 	gopkg.in/dnaeon/go-vcr.v4 v4.0.2
+	gopkg.in/yaml.v3 v3.0.1
 )
 
 require (
-	github.com/google/uuid v1.6.0 // indirect
 	github.com/inconshreveable/mousetrap v1.1.0 // indirect
-	github.com/spf13/cobra v1.9.1 // indirect
 	github.com/spf13/pflag v1.0.6 // indirect
-	gopkg.in/yaml.v3 v3.0.1 // indirect
+	github.com/yosida95/uritemplate/v3 v3.0.2 // indirect
 )

go.sum

@@ -7,8 +7,8 @@ github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
-github.com/mark3labs/mcp-go v0.8.5 h1:s5oRwQfs83Jim3ZAcQMyUQNHzCEVIuGD12GV8vhJqqc=
-github.com/mark3labs/mcp-go v0.8.5/go.mod h1:cjMlBU0cv/cj9kjlgmRhoJ5JREdS7YX83xeIG9Ko/jE=
+github.com/mark3labs/mcp-go v0.18.0 h1:YuhgIVjNlTG2ZOwmrkORWyPTp0dz1opPEqvsPtySXao=
+github.com/mark3labs/mcp-go v0.18.0/go.mod h1:KmJndYv7GIgcPVwEKJjNcbhVQ+hJGJhrCCB/9xITzpE=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
@@ -18,6 +18,8 @@ github.com/spf13/pflag v1.0.6 h1:jFzHGLGAlb3ruxLB8MhbI6A8+AQX/2eW4qeyNZXNp2o=
 github.com/spf13/pflag v1.0.6/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
 github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/yosida95/uritemplate/v3 v3.0.2 h1:Ed3Oyj9yrmi9087+NczuL5BwkIc4wvTb5zIM+UJPGz4=
+github.com/yosida95/uritemplate/v3 v3.0.2/go.mod h1:ILOh0sOhIJR3+L/8afwt/kE++YT040gmv5BQTMR2HP4=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/dnaeon/go-vcr.v4 v4.0.2 h1:7T5VYf2ifyK01ETHbJPl5A6XTpUljD4Trw3GEDcdedk=

pkg/server/resources.go

@@ -0,0 +1,158 @@
+package server
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"strings"
+
+	"github.com/geropl/linear-mcp-go/pkg/linear"
+	"github.com/mark3labs/mcp-go/mcp"
+	mcpserver "github.com/mark3labs/mcp-go/server"
+)
+
+// TeamsResource is the resource definition for Linear teams
+var TeamsResource = mcp.NewResource(
+	"linear://teams",
+	"Linear Teams",
+	mcp.WithResourceDescription("List of teams in Linear"),
+	mcp.WithMIMEType("application/json"),
+)
+
+// TeamResource is the resource definition for a specific Linear team
+var TeamResource = mcp.NewResource(
+	"linear://team/{id}",
+	"Linear Team",
+	mcp.WithResourceDescription("Details of a specific team in Linear"),
+	mcp.WithMIMEType("application/json"),
+)
+
+// RegisterResources registers all Linear resources with the MCP server
+func RegisterResources(s *mcpserver.MCPServer, linearClient *linear.LinearClient) {
+	// Register Teams resource
+	s.AddResource(TeamsResource, TeamsResourceHandler(linearClient))
+
+	// Register Team resource
+	s.AddResource(TeamResource, TeamResourceHandler(linearClient))
+}
+
+// TeamsResourceHandler handles the linear://teams resource
+func TeamsResourceHandler(linearClient *linear.LinearClient) mcpserver.ResourceHandlerFunc {
+	return func(ctx context.Context, request mcp.ReadResourceRequest) ([]mcp.ResourceContents, error) {
+		// Get teams from Linear
+		teams, err := linearClient.GetTeams("")
+		if err != nil {
+			return nil, fmt.Errorf("failed to get teams: %v", err)
+		}
+
+		// Create resource content
+		results := []mcp.ResourceContents{}
+		for _, t := range teams {
+			teamJSON, err := json.Marshal(t)
+			if err != nil {
+				return nil, fmt.Errorf("failed to marshal team: %v", err)
+			}
+
+			results = append(results, mcp.TextResourceContents{
+				URI:      fmt.Sprintf("linear://team/%s", t.ID),
+				MIMEType: "application/json",
+				Text:     string(teamJSON),
+			})
+		}
+
+		return results, nil
+	}
+}
+
+// TeamResourceHandler handles the linear://team/{id} resource
+func TeamResourceHandler(linearClient *linear.LinearClient) mcpserver.ResourceHandlerFunc {
+	return func(ctx context.Context, request mcp.ReadResourceRequest) ([]mcp.ResourceContents, error) {
+		// Extract team ID from URI
+		uri := request.Params.URI
+		if !strings.HasPrefix(uri, "linear://team/") {
+			return nil, fmt.Errorf("invalid team URI: %s", uri)
+		}
+
+		teamID := uri[len("linear://team/"):]
+		if teamID == "" {
+			return nil, fmt.Errorf("team ID is required")
+		}
+
+		// Resolve team ID (could be UUID, name, or key)
+		resolvedTeamID, err := resolveTeamIdentifier(linearClient, teamID)
+		if err != nil {
+			return nil, fmt.Errorf("failed to resolve team identifier: %v", err)
+		}
+
+		// Get all teams and find the matching one
+		teams, err := linearClient.GetTeams("")
+		if err != nil {
+			return nil, fmt.Errorf("failed to get teams: %v", err)
+		}
+
+		var team *linear.Team
+		for i, t := range teams {
+			if t.ID == resolvedTeamID {
+				team = &teams[i]
+				break
+			}
+		}
+
+		if team == nil {
+			return nil, fmt.Errorf("team not found: %s", teamID)
+		}
+
+		// Format team as JSON
+		teamJSON, err := json.Marshal(team)
+		if err != nil {
+			return nil, fmt.Errorf("failed to marshal team: %v", err)
+		}
+
+		// Create resource content
+		return []mcp.ResourceContents{
+			mcp.TextResourceContents{
+				URI:      fmt.Sprintf("linear://team/%s", team.ID),
+				MIMEType: "application/json",
+				Text:     string(teamJSON),
+			},
+		}, nil
+	}
+}
+
+// resolveTeamIdentifier resolves a team identifier (UUID, name, or key) to a team ID
+func resolveTeamIdentifier(linearClient *linear.LinearClient, identifier string) (string, error) {
+	// If it's a valid UUID, use it directly
+	if isValidUUID(identifier) {
+		return identifier, nil
+	}
+
+	// Otherwise, try to find a team by name or key
+	teams, err := linearClient.GetTeams("")
+	if err != nil {
+		return "", fmt.Errorf("failed to get teams: %v", err)
+	}
+
+	// First try exact match on name or key
+	for _, team := range teams {
+		if team.Name == identifier || team.Key == identifier {
+			return team.ID, nil
+		}
+	}
+
+	// If no exact match, try case-insensitive match
+	identifierLower := strings.ToLower(identifier)
+	for _, team := range teams {
+		if strings.ToLower(team.Name) == identifierLower || strings.ToLower(team.Key) == identifierLower {
+			return team.ID, nil
+		}
+	}
+
+	return "", fmt.Errorf("no team found with identifier '%s'", identifier)
+}
+
+// isValidUUID checks if a string is a valid UUID
+func isValidUUID(uuidStr string) bool {
+	// Simple UUID validation - check if it has the correct format
+	// This is a simplified version and doesn't validate the UUID fully
+	return len(uuidStr) == 36 && strings.Count(uuidStr, "-") == 4
+}

pkg/server/resources_test.go

@@ -0,0 +1,141 @@
+package server
+
+import (
+	"context"
+	"encoding/json"
+	"path/filepath"
+	"testing"
+
+	"github.com/geropl/linear-mcp-go/pkg/linear"
+	"github.com/google/go-cmp/cmp"
+	"github.com/mark3labs/mcp-go/mcp"
+	mcpserver "github.com/mark3labs/mcp-go/server"
+)
+
+func TestResourceHandlers(t *testing.T) {
+	// Define test cases
+	tests := []struct {
+		handlerName string
+		name        string
+		uri         string
+		handlerFunc func(*linear.LinearClient) mcpserver.ResourceHandlerFunc
+	}{
+		// TeamsResourceHandler test cases
+		{
+			handlerName: "TeamsResourceHandler",
+			name:        "List All",
+			uri:         "linear://teams",
+			handlerFunc: TeamsResourceHandler,
+		},
+		// TeamResourceHandler test cases
+		{
+			handlerName: "TeamResourceHandler",
+			name:        "Fetch By ID",
+			uri:         "linear://team/" + TEAM_ID,
+			handlerFunc: TeamResourceHandler,
+		},
+		{
+			handlerName: "TeamResourceHandler",
+			name:        "Fetch By Name",
+			uri:         "linear://team/" + TEAM_NAME,
+			handlerFunc: TeamResourceHandler,
+		},
+		{
+			handlerName: "TeamResourceHandler",
+			name:        "Fetch By Key",
+			uri:         "linear://team/" + TEAM_KEY,
+			handlerFunc: TeamResourceHandler,
+		},
+		{
+			handlerName: "TeamResourceHandler",
+			name:        "Invalid ID",
+			uri:         "linear://team/invalid-identifier-does-not-exist", // Use a clearly invalid identifier
+			handlerFunc: TeamResourceHandler,
+		},
+		{
+			handlerName: "TeamResourceHandler",
+			name:        "Missing ID",
+			uri:         "linear://team/", // Test case where ID is missing from URI path
+			handlerFunc: TeamResourceHandler,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.handlerName+"_"+tt.name, func(t *testing.T) {
+			// Generate fixture and golden file paths
+			fixtureName := "resource_" + tt.handlerName + "_" + tt.name
+			goldenPath := filepath.Join("../../testdata/golden", fixtureName+".golden")
+
+			// Create test client with VCR
+			// Use distinct flags for resource tests to avoid conflicts
+			client, cleanup := linear.NewTestClient(t, fixtureName, *record || *recordWrites)
+			defer cleanup()
+
+			// Get the handler function
+			handler := tt.handlerFunc(client)
+
+			// Create the request
+			request := mcp.ReadResourceRequest{}
+			request.Params.URI = tt.uri
+
+			// Call the handler
+			contents, err := handler(context.Background(), request)
+
+			// Extract the actual output and error
+			var actualOutput, actualErr string
+			if err != nil {
+				actualErr = err.Error()
+			} else {
+				// Marshal the contents to JSON for comparison
+				jsonBytes, jsonErr := json.MarshalIndent(contents, "", "  ") // Use indent for readability
+				if jsonErr != nil {
+					t.Fatalf("Failed to marshal resource contents to JSON: %v", jsonErr)
+				}
+				actualOutput = string(jsonBytes)
+			}
+
+			// If goldenResource flag is set, update the golden file
+			if *golden {
+				writeGoldenFile(t, goldenPath, expectation{
+					Err:    actualErr,
+					Output: actualOutput,
+				})
+				// Also update the VCR recording implicitly by running the test
+				t.Logf("Updated golden file: %s", goldenPath)
+				// We might need to re-run the test without the golden flag
+				// after recording to ensure the comparison passes.
+				// However, for now, just writing the golden file is the goal.
+				return // Skip comparison when updating golden files
+			}
+
+			// Otherwise, read the golden file and compare
+			expected := readGoldenFile(t, goldenPath)
+
+			// Compare error
+			if diff := cmp.Diff(expected.Err, actualErr); diff != "" {
+				t.Errorf("Error mismatch (-want +got):\n%s", diff)
+			}
+
+			// Compare output (only if no error is expected)
+			if expected.Err == "" && actualErr == "" {
+				// Compare JSON strings directly
+				if diff := cmp.Diff(expected.Output, actualOutput); diff != "" {
+					// To make diffs easier to read, unmarshal and compare structures
+					var expectedContents []mcp.ResourceContents
+					var actualContents []mcp.ResourceContents
+					json.Unmarshal([]byte(expected.Output), &expectedContents) // Ignore error for diffing
+					json.Unmarshal([]byte(actualOutput), &actualContents)      // Ignore error for diffing
+					t.Errorf("Output mismatch (-want +got):\n%s", cmp.Diff(expectedContents, actualContents))
+					t.Logf("Expected JSON:\n%s", expected.Output)
+					t.Logf("Actual JSON:\n%s", actualOutput)
+				}
+			} else if expected.Err == "" && actualErr != "" {
+				t.Errorf("Expected no error, but got: %s", actualErr)
+			} else if expected.Err != "" && actualErr == "" {
+				t.Errorf("Expected error '%s', but got none", expected.Err)
+			}
+		})
+	}
+}
+
+// readGoldenFile and writeGoldenFile are defined in test_helpers.go

pkg/server/server.go

@@ -44,6 +44,9 @@ func NewLinearMCPServer(writeAccess bool) (*LinearMCPServer, error) {
 
 	// Register tools
 	RegisterTools(mcpServer, linearClient, writeAccess)
+	
+	// Register resources
+	RegisterResources(mcpServer, linearClient)
 
 	return server, nil
 }