Merge pull request #119 from IBM/add-mcp-server-time-go

Added fast MCP server in go

Author: crivetimihai

.github/tools/cleanup.sh

@@ -0,0 +1,162 @@
+#!/usr/bin/env bash
+#───────────────────────────────────────────────────────────────────────────────
+#  Script : cleanup.sh
+#  Author : Mihai Criveti
+#  Purpose: Prune old or unused GHCR container versions for IBM's MCP Context Forge
+#  Copyright 2025
+#  SPDX-License-Identifier: Apache-2.0
+#
+#  Description:
+#    This script safely manages container versions in GitHub Container Registry
+#    (ghcr.io) under the IBM organization, specifically targeting the
+#    `mcp-context-forge` package. It supports interactive and non-interactive
+#    deletion modes to help you keep the container registry clean.
+#
+#    Features:
+#    • Dry-run by default to avoid accidental deletion
+#    • Tag whitelisting with regular expression matching
+#    • GitHub CLI integration with scope validation
+#    • CI/CD-compatible via environment overrides
+#
+#  Requirements:
+#    • GitHub CLI (gh) v2.x with appropriate scopes
+#    • jq (command-line JSON processor)
+#
+#  Required Token Scopes:
+#    delete:packages
+#
+#  Authentication Notes:
+#    Authenticate with:
+#      gh auth refresh -h github.com -s read:packages,delete:packages
+#    Or:
+#      gh auth logout
+#      gh auth login --scopes "read:packages,delete:packages,write:packages,repo,read:org,gist"
+#
+#    Verify authentication with:
+#      gh auth status -t
+#
+#  Environment Variables:
+#    GITHUB_TOKEN / GH_TOKEN : GitHub token with required scopes
+#    DRY_RUN                 : Set to "false" to enable actual deletions (default: true)
+#
+#  Usage:
+#    ./cleanup.sh                 # Dry-run with confirmation prompt
+#    DRY_RUN=false ./cleanup.sh --yes  # Actual deletion without prompt (for CI)
+#
+#───────────────────────────────────────────────────────────────────────────────
+
+set -euo pipefail
+
+##############################################################################
+# 1. PICK A TOKEN
+##############################################################################
+NEEDED_SCOPES="delete:packages"
+
+if [[ -n "${GITHUB_TOKEN:-}" ]]; then
+  TOKEN="$GITHUB_TOKEN"
+elif [[ -n "${GH_TOKEN:-}" ]]; then
+  TOKEN="$GH_TOKEN"
+else
+  # fall back to whatever gh already has
+  if ! TOKEN=$(gh auth token 2>/dev/null); then
+    echo "❌  No token exported and gh not logged in. Fix with:"
+    echo "    gh auth login  (or export GITHUB_TOKEN)"
+    exit 1
+  fi
+fi
+export GH_TOKEN="$TOKEN"   # gh api uses this
+
+# Fixed scope checking - check for both required scopes individually
+if scopes=$(gh auth status --show-token 2>/dev/null | grep -oP 'Token scopes: \K.*' || echo ""); then
+  missing_scopes=()
+
+  # if ! echo "$scopes" | grep -q "read:packages"; then
+  #   missing_scopes+=("read:packages")
+  # fi
+
+  if ! echo "$scopes" | grep -q "delete:packages"; then
+    missing_scopes+=("delete:packages")
+  fi
+
+  if [[ ${#missing_scopes[@]} -gt 0 ]]; then
+    echo "⚠️  Your token scopes are [$scopes] – but you're missing: [$(IFS=','; echo "${missing_scopes[*]}")]"
+    echo "    Run: gh auth refresh -h github.com -s $NEEDED_SCOPES"
+    exit 1
+  fi
+else
+  echo "⚠️  Could not verify token scopes. Proceeding anyway..."
+fi
+
+##############################################################################
+# 2. CONFIG
+##############################################################################
+ORG="ibm"
+PKG="mcp-context-forge"
+KEEP_TAGS=( "0.1.0" "v0.1.0" "0.1.1" "v0.1.1" "latest" )
+PER_PAGE=100
+
+DRY_RUN=${DRY_RUN:-true}          # default safe
+ASK_CONFIRM=true
+[[ ${1:-} == "--yes" ]] && ASK_CONFIRM=false
+KEEP_REGEX="^($(IFS='|'; echo "${KEEP_TAGS[*]}"))$"
+
+##############################################################################
+# 3. MAIN
+##############################################################################
+delete_ids=()
+
+echo "📦  Scanning ghcr.io/${ORG}/${PKG} …"
+
+# Process versions and collect IDs to delete
+while IFS= read -r row; do
+  id=$(jq -r '.id' <<<"$row")
+  digest=$(jq -r '.digest' <<<"$row")
+  tags_csv=$(jq -r '.tags | join(",")' <<<"$row")
+  keep=$(jq -e --arg re "$KEEP_REGEX" 'any(.tags[]?; test($re))' <<<"$row" 2>/dev/null) || keep=false
+
+  if [[ $keep == true ]]; then
+    printf "✅  KEEP    %s  [%s]\n" "$digest" "$tags_csv"
+  else
+    printf "🗑️   DELETE  %s  [%s]\n" "$digest" "$tags_csv"
+    delete_ids+=("$id")
+  fi
+done < <(gh api -H "Accept: application/vnd.github+json" \
+            "/orgs/${ORG}/packages/container/${PKG}/versions?per_page=${PER_PAGE}" \
+            --paginate | \
+         jq -cr --arg re "$KEEP_REGEX" '
+           .[] |
+           {
+             id,
+             digest: .metadata.container.digest,
+             tags: (.metadata.container.tags // [])
+           }
+         ')
+
+##############################################################################
+# 4. CONFIRMATION & DELETION
+##############################################################################
+if [[ ${#delete_ids[@]} -eq 0 ]]; then
+  echo "✨  Nothing to delete!"
+  exit 0
+fi
+
+if [[ $DRY_RUN == true ]]; then
+  if [[ $ASK_CONFIRM == true ]]; then
+    echo
+    read -rp "Proceed to delete the ${#delete_ids[@]} versions listed above? (y/N) " reply
+    [[ $reply =~ ^[Yy]$ ]] || { echo "Aborted – nothing deleted."; exit 0; }
+  fi
+  echo "🚀  Re-running in destructive mode …"
+  DRY_RUN=false exec "$0" --yes
+else
+  echo "🗑️  Deleting ${#delete_ids[@]} versions..."
+  for id in "${delete_ids[@]}"; do
+    if gh api -X DELETE -H "Accept: application/vnd.github+json" \
+              "/orgs/${ORG}/packages/container/${PKG}/versions/${id}" >/dev/null 2>&1; then
+      echo "✅  Deleted version ID: $id"
+    else
+      echo "❌  Failed to delete version ID: $id"
+    fi
+  done
+  echo "Done."
+fi

README.md

@@ -31,7 +31,7 @@ ContextForge MCP Gateway is a feature-rich gateway, proxy and MCP Registry that
     - [1 · Minimum viable run](#1--minimum-viable-run)
     - [2 · Persist the SQLite database](#2--persist-the-sqlite-database)
     - [3 · Local tool discovery (host network)](#3--local-tool-discovery-host-network)
-  - [Podman (rootless-friendly)](#-podman-rootless-friendly)  
+  - [Podman (rootless-friendly)](#-podman-rootless-friendly)
     - [1 · Basic run](#1--basic-run)
     - [2 · Persist SQLite](#2--persist-sqlite)
     - [3 · Host networking (rootless)](#3--host-networking-rootless)

docs/docs/development/index.md

@@ -154,5 +154,3 @@ GitHub Actions enforce:
 CI configs live in `.github/workflows/`.
 
 ---
-
-

mcp-servers/go/fast-time-server/.gitignore

@@ -0,0 +1 @@
+fast-time-server

mcp-servers/go/fast-time-server/README.md

@@ -0,0 +1,62 @@
+# fast-time-server
+
+Ultra‑light MCP server in Go that exposes a single tool, `get_system_time(timezone)`, returning the current time in RFC 3339.
+
+---
+
+## Prerequisites
+
+* **Go ≥ 1.22** ([https://go.dev/dl/](https://go.dev/dl/))
+
+---
+
+## Build
+
+Use the provided `build.sh` helper:
+
+```bash
+./build.sh
+```
+
+<details>
+<summary>What <code>build.sh</code> does</summary>
+
+```bash
+#!/usr/bin/env bash
+set -euo pipefail
+
+go mod tidy                       # ensure deps are synced
+GOFLAGS="-trimpath -ldflags=-s -w" \
+  go build -o fast-time-server .
+```
+
+</details>
+
+---
+
+## Run
+
+```bash
+npx -y supergateway \
+  --stdio "./fast-time-server" \
+  --port 8003
+```
+
+---
+
+
+##  Benchmark
+
+```
+while :; do curl -X POST -H "Authorization: Bearer $MCPGATEWAY_BEARER_TOKEN" \
+     -H "Content-Type: application/json" \
+     -d '{"jsonrpc":"2.0","id":1,"method":"get_system_time"}' \
+     http://localhost:4444/rpc; done
+
+# or
+hey -n 100 -c 10 -m POST \
+  -H "Authorization: Bearer $MCPGATEWAY_BEARER_TOKEN" \
+  -H "Content-Type: application/json" \
+  -d '{"jsonrpc":"2.0","id":1,"method":"get_system_time"}' \
+  http://localhost:4444/rpc
+```

mcp-servers/go/fast-time-server/build.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+go mod tidy
+go build -trimpath -ldflags "-s -w" -o fast-time-server

mcp-servers/go/fast-time-server/go.mod

@@ -0,0 +1,13 @@
+module fast-time-server
+
+go 1.23
+
+toolchain go1.23.10
+
+require github.com/mark3labs/mcp-go v0.32.0 // MCP server/runtime
+
+require (
+    github.com/google/uuid v1.6.0 // indirect
+    github.com/spf13/cast v1.7.1 // indirect
+    github.com/yosida95/uritemplate/v3 v3.0.2 // indirect
+)

mcp-servers/go/fast-time-server/go.sum

@@ -0,0 +1,26 @@
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
+github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+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/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
+github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/mark3labs/mcp-go v0.32.0 h1:fgwmbfL2gbd67obg57OfV2Dnrhs1HtSdlY/i5fn7MU8=
+github.com/mark3labs/mcp-go v0.32.0/go.mod h1:rXqOudj/djTORU/ThxYx8fqEVj/5pvTuuebQ2RC7uk4=
+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/rogpeppe/go-internal v1.9.0 h1:73kH8U+JUqXU8lRuOHeVHaa/SZPifC7BkcraZVejAe8=
+github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
+github.com/spf13/cast v1.7.1 h1:cuNEagBQEHWN1FnbGEjCXL2szYEXqfJPbP2HNUaca9Y=
+github.com/spf13/cast v1.7.1/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
+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/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

mcp-servers/go/fast-time-server/main.go

@@ -0,0 +1,75 @@
+// -*- coding: utf-8 -*-
+// fast-time-server – ultra‑fast MCP server exposing get_system_time
+//
+// Copyright 2025
+// SPDX-License-Identifier: Apache-2.0
+// Authors: Mihai Criveti
+//
+// This file implements an MCP server written in Go that provides a single
+// tool `get_system_time(timezone)` returning the current wall‑clock time
+// for a given IANA timezone in RFC3339 format.
+//
+// It uses the `mcp-go` library for MCP protocol handling and provides
+// a simple, efficient implementation that avoids unnecessary parsing of
+// timezone data by caching loaded locations.
+package main
+
+import (
+    "context"
+    "fmt"
+    "log"
+    "sync"
+    "time"
+
+    "github.com/mark3labs/mcp-go/mcp"
+    "github.com/mark3labs/mcp-go/server"
+)
+
+// --- ultra-light tz cache (avoids parsing zoneinfo repeatedly)
+var tzCache sync.Map
+
+func loadLocation(name string) (*time.Location, error) {
+    if loc, ok := tzCache.Load(name); ok {
+        return loc.(*time.Location), nil
+    }
+    loc, err := time.LoadLocation(name)
+    if err != nil {
+        return nil, err
+    }
+    tzCache.Store(name, loc)
+    return loc, nil
+}
+
+func main() {
+    // Create the core MCP server – no custom logger needed
+    s := server.NewMCPServer(
+        "fast-time-server",
+        "1.0.0",
+        server.WithToolCapabilities(false), // expose only tools
+        server.WithLogging(),               // use built-in logging
+        server.WithRecovery(),              // panic-safe handlers
+    )
+
+    // Declare the tool schema
+    timeTool := mcp.NewTool("get_system_time",
+        mcp.WithDescription("Return current time in RFC3339 for an IANA timezone"),
+        mcp.WithString("timezone", mcp.Description("IANA zone, default UTC")),
+    )
+
+    // Attach the handler
+    s.AddTool(timeTool, func(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
+        tz := req.GetString("timezone", "UTC") // modern accessor
+
+        loc, err := loadLocation(tz)
+        if err != nil {
+            return mcp.NewToolResultError(fmt.Sprintf("unknown timezone %q", tz)), nil
+        }
+        now := time.Now().In(loc).Format(time.RFC3339)
+        return mcp.NewToolResultText(now), nil
+    })
+
+    // Serve over stdio (fastest transport)
+    if err := server.ServeStdio(s); err != nil {
+        log.Fatalf("server error: %v", err)
+    }
+}

mcpgateway/main.py

@@ -269,7 +269,7 @@ class MCPPathRewriteMiddleware:
     - Only rewrites paths ending with '/mcp' but not exactly '/mcp'.
     - Performs authentication before rewriting.
     - Passes rewritten requests to `streamable_http_session`.
-    - All other requests are passed through unchanged.
+    - All other requests are passed through without change.
     """
 
     def __init__(self, app):