landscape mcp server (poc)

.github/workflows/publish-landscape-mcp-server.yml

@@ -0,0 +1,79 @@
+---
+name: Build and Publish Landscape MCP Server
+
+on:
+  push:
+    branches: ['**']
+    paths:
+      - 'utilities/landscape-mcp-server/**'
+      - '.github/workflows/publish-landscape-mcp-server.yml'
+  pull_request:
+    branches: [main]
+    paths:
+      - 'utilities/landscape-mcp-server/**'
+      - '.github/workflows/publish-landscape-mcp-server.yml'
+
+env:
+  REGISTRY: ghcr.io
+  IMAGE_NAME: cncf/landscape-mcp-server
+
+jobs:
+  build-and-push:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      packages: write
+      id-token: write
+
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v3
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v3
+
+      - name: Log into registry ${{ env.REGISTRY }}
+        if: github.event_name != 'pull_request'
+        uses: docker/login-action@v3
+        with:
+          registry: ${{ env.REGISTRY }}
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Extract metadata (tags, labels) for Docker
+        id: meta
+        uses: docker/metadata-action@v5
+        with:
+          images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
+          tags: |
+            type=sha
+            type=ref,event=branch
+            type=ref,event=pr
+
+      - name: Build and push Docker image
+        id: build-and-push
+        uses: docker/build-push-action@v6
+        with:
+          context: ./utilities/landscape-mcp-server/
+          platforms: |
+            linux/amd64
+            linux/arm64
+          push: ${{ github.event_name != 'pull_request' }}
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+          cache-from: type=gha
+          cache-to: type=gha,mode=max
+
+      - name: Install cosign
+        if: github.event_name != 'pull_request'
+        uses: sigstore/cosign-installer@main
+
+      - name: Sign the published Docker image
+        if: github.event_name != 'pull_request'
+        env:
+          COSIGN_EXPERIMENTAL: "true"
+        run: |
+          echo "${{ steps.meta.outputs.tags }}" | xargs -I {} cosign sign -y {}@${{ steps.build-and-push.outputs.digest }}

utilities/landscape-mcp-server/Dockerfile

@@ -0,0 +1,20 @@
+# syntax=docker/dockerfile:1.7
+
+FROM golang:1.21-alpine AS builder
+
+WORKDIR /app
+
+COPY go.mod ./
+COPY *.go ./
+
+RUN go build -o landscape2-mcp-server
+
+FROM alpine:3.19
+
+RUN apk add --no-cache ca-certificates
+
+WORKDIR /app
+
+COPY --from=builder /app/landscape2-mcp-server /usr/local/bin/landscape2-mcp-server
+
+ENTRYPOINT ["landscape2-mcp-server"]

utilities/landscape-mcp-server/README.md

@@ -0,0 +1,27 @@
+# Landscape MCP Server
+
+Easily ask questions of the CNCF (Or other!) Landscape. 
+
+## Installation
+
+Add this server to your mcp.json (or equivalent):
+
+```
+"cncf-landscape": {
+      "command": "docker",
+      "args": [
+        "run",
+        "-i",
+        "--rm",
+        "ghcr.io/cncf/landscape-mcp-server:main",
+        "--data-url",
+        "https://landscape.cncf.io/data/full.json"
+      ]
+    }
+```
+
+## Examples
+
+- How many CNCF projects graduated in 2024?
+- When did OpenTelemetry reach incubating?
+- What CNCF projects moved levels in 2025?

utilities/landscape-mcp-server/dataset_loader.go

@@ -0,0 +1,159 @@
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"log"
+	"math"
+	"net/http"
+	"os"
+	"strings"
+	"time"
+)
+
+type dataSource struct {
+	filePath string
+	url      string
+}
+
+func loadDataset(ctx context.Context, src dataSource) (*Dataset, error) {
+	raw, err := readSource(ctx, src.filePath, src.url)
+	if err != nil {
+		return nil, fmt.Errorf("load data source: %w", err)
+	}
+
+	var full fullDataset
+	if err := json.Unmarshal(raw, &full); err != nil {
+		return nil, fmt.Errorf("parse full dataset: %w", err)
+	}
+
+	items := make([]LandscapeItem, 0, len(full.Items))
+	for _, it := range full.Items {
+		accepted, err := parseDate(it.AcceptedAt)
+		if err != nil {
+			log.Printf("warning: invalid accepted_at for %s: %v", it.Name, err)
+		}
+		graduated, err := parseDate(it.GraduatedAt)
+		if err != nil {
+			log.Printf("warning: invalid graduated_at for %s: %v", it.Name, err)
+		}
+		incubating, err := parseDate(it.IncubatingAt)
+		if err != nil {
+			log.Printf("warning: invalid incubating_at for %s: %v", it.Name, err)
+		}
+		joined, err := parseDate(it.JoinedAt)
+		if err != nil {
+			log.Printf("warning: invalid joined_at for %s: %v", it.Name, err)
+		}
+
+		item := LandscapeItem{
+			Name:              it.Name,
+			Category:          it.Category,
+			Subcategory:       it.Subcategory,
+			MemberSubcategory: strings.TrimSpace(it.MemberSubcategory),
+			Maturity:          strings.TrimSpace(it.Maturity),
+			JoinedAt:          joined,
+			AcceptedAt:        accepted,
+			GraduatedAt:       graduated,
+			IncubatingAt:      incubating,
+			CrunchbaseURL:     strings.TrimSpace(it.CrunchbaseURL),
+		}
+		items = append(items, item)
+	}
+
+	orgs := make(map[string]CrunchbaseOrganization, len(full.CrunchbaseData))
+	for url, org := range full.CrunchbaseData {
+		rounds := make([]FundingRound, 0, len(org.FundingRounds))
+		for _, round := range org.FundingRounds {
+			date, err := parseDate(round.AnnouncedOn)
+			if err != nil {
+				log.Printf("warning: invalid announced_on for %s: %v", url, err)
+				continue
+			}
+
+			var amountPtr *int64
+			if round.Amount != nil {
+				amt := int64(math.Round(*round.Amount))
+				amountPtr = &amt
+			}
+
+			rounds = append(rounds, FundingRound{
+				Amount:      amountPtr,
+				AnnouncedOn: date,
+				Kind:        strings.TrimSpace(round.Kind),
+			})
+		}
+		orgs[url] = CrunchbaseOrganization{FundingRounds: rounds}
+	}
+
+	return &Dataset{
+		Items:          items,
+		CrunchbaseOrgs: orgs,
+	}, nil
+}
+
+func readSource(ctx context.Context, filePath, url string) ([]byte, error) {
+	switch {
+	case filePath != "":
+		return os.ReadFile(filePath)
+	case url != "":
+		req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil)
+		if err != nil {
+			return nil, err
+		}
+		resp, err := http.DefaultClient.Do(req)
+		if err != nil {
+			return nil, err
+		}
+		defer resp.Body.Close()
+		if resp.StatusCode != http.StatusOK {
+			return nil, fmt.Errorf("unexpected status %d", resp.StatusCode)
+		}
+		return io.ReadAll(resp.Body)
+	default:
+		return nil, errors.New("either file or url must be provided")
+	}
+}
+
+func parseDate(value string) (*time.Time, error) {
+	if strings.TrimSpace(value) == "" {
+		return nil, nil
+	}
+	t, err := time.Parse("2006-01-02", value)
+	if err != nil {
+		return nil, err
+	}
+	tt := t
+	return &tt, nil
+}
+
+type fullDataset struct {
+	Items          []fullItem                  `json:"items"`
+	CrunchbaseData map[string]fullOrganization `json:"crunchbase_data"`
+}
+
+type fullItem struct {
+	Name              string `json:"name"`
+	Category          string `json:"category"`
+	Subcategory       string `json:"subcategory"`
+	MemberSubcategory string `json:"member_subcategory"`
+	Maturity          string `json:"maturity"`
+	JoinedAt          string `json:"joined_at"`
+	AcceptedAt        string `json:"accepted_at"`
+	GraduatedAt       string `json:"graduated_at"`
+	IncubatingAt      string `json:"incubating_at"`
+	CrunchbaseURL     string `json:"crunchbase_url"`
+}
+
+type fullOrganization struct {
+	FundingRounds []fullFundingRound `json:"funding_rounds"`
+}
+
+type fullFundingRound struct {
+	Amount      *float64 `json:"amount"`
+	AnnouncedOn string   `json:"announced_on"`
+	Kind        string   `json:"kind"`
+}

utilities/landscape-mcp-server/go.mod

@@ -0,0 +1,3 @@
+module github.com/cncf/landscape2/go/mcp-server
+
+go 1.21