feat: initial implementation of pure-Go GraphRAG MCP server

- 5-phase GraphRAG pipeline: load, chunk, embed, extract graph, community detection
- Three LLM providers: Azure OpenAI, Ollama, HuggingFace (TGI)
- Pure Go SQLite store (modernc.org/sqlite, CGO_ENABLED=0)
- Louvain community detection with hierarchical levels
- 12 MCP tools via SSE transport (mark3labs/mcp-go)
- REST API + embedded vanilla-JS SPA with vis-network graph
- Concurrent batched embeddings, parallel graph extraction, parallel community summarization
- CLI: index, stats, serve (cobra + viper)
- GitHub Actions: CI, auto-beta, release + GoReleaser cross-platform builds

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: aksOps

.github/workflows/beta.yml

@@ -0,0 +1,13 @@
+name: Auto Beta
+
+on:
+  push:
+    branches: [main]
+
+permissions:
+  contents: write
+
+jobs:
+  auto-beta:
+    uses: RandomCodeSpace/central-ops/.github/workflows/reusable-auto-beta.yml@main
+    secrets: inherit

.github/workflows/ci.yml

@@ -0,0 +1,32 @@
+name: CI
+
+on:
+  push:
+    branches: [main]
+  pull_request:
+    branches: [main]
+
+permissions:
+  contents: read
+
+jobs:
+  build-and-test:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+
+      - name: Set up Go
+        uses: actions/setup-go@v5
+        with:
+          go-version-file: go.mod
+          cache: true
+
+      - name: Build
+        run: CGO_ENABLED=0 go build ./...
+
+      - name: Vet
+        run: go vet ./...
+
+      - name: Test
+        run: CGO_ENABLED=0 go test -race -timeout 120s ./...

.github/workflows/release.yml

@@ -0,0 +1,18 @@
+name: Release
+
+on:
+  workflow_dispatch:
+    inputs:
+      version:
+        description: 'Base beta version to release (e.g., v0.0.5-beta)'
+        required: true
+
+permissions:
+  contents: write
+
+jobs:
+  release:
+    uses: RandomCodeSpace/central-ops/.github/workflows/reusable-release.yml@main
+    secrets: inherit
+    with:
+      version: ${{ inputs.version }}

.gitignore

@@ -0,0 +1,17 @@
+# Binaries
+docsgraph
+docsgraph.exe
+docsgraph-linux
+docsgraph-*
+
+# Data
+*.db
+*.db-shm
+*.db-wal
+
+# Build artifacts
+dist/
+
+# OS
+.DS_Store
+Thumbs.db

.goreleaser.yaml

@@ -0,0 +1,61 @@
+version: 2
+
+project_name: docsgraph
+
+before:
+  hooks:
+    - go mod tidy
+
+builds:
+  - id: docsgraph
+    main: .
+    binary: docsgraph
+    env:
+      - CGO_ENABLED=0
+    goos:
+      - linux
+      - windows
+      - darwin
+    goarch:
+      - amd64
+      - arm64
+    ldflags:
+      - -s -w
+      - -X main.version={{.Version}}
+      - -X main.commit={{.Commit}}
+      - -X main.date={{.Date}}
+
+archives:
+  - id: docsgraph
+    builds: [docsgraph]
+    name_template: "{{ .ProjectName }}_{{ .Version }}_{{ .Os }}_{{ .Arch }}"
+    format_overrides:
+      - goos: windows
+        format: zip
+    files:
+      - config.example.yaml
+      - LICENSE*
+      - README*
+
+checksum:
+  name_template: "checksums.txt"
+  algorithm: sha256
+
+release:
+  github:
+    owner: RandomCodeSpace
+    name: docsgraphcontext
+  draft: false
+  prerelease: auto
+  name_template: "{{.ProjectName}} {{.Tag}}"
+
+changelog:
+  sort: asc
+  use: github
+  filters:
+    exclude:
+      - "^docs:"
+      - "^test:"
+      - "^chore:"
+      - Merge pull request
+      - Merge branch

cmd/index.go

@@ -0,0 +1,78 @@
+package cmd
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/amit/docsgraphcontext/internal/llm"
+	"github.com/amit/docsgraphcontext/internal/pipeline"
+	"github.com/amit/docsgraphcontext/internal/store"
+	"github.com/spf13/cobra"
+)
+
+var (
+	indexForce    bool
+	indexWorkers  int
+	indexBatch    int
+	indexFinalize bool
+	indexVerbose  bool
+)
+
+var indexCmd = &cobra.Command{
+	Use:   "index [path]",
+	Short: "Index documents (Phases 1-2: load, chunk, embed, extract graph)",
+	Args:  cobra.MaximumNArgs(1),
+	RunE: func(cmd *cobra.Command, args []string) error {
+		st, err := store.Open(cfg.DBPath())
+		if err != nil {
+			return fmt.Errorf("open store: %w", err)
+		}
+		defer st.Close()
+
+		if indexFinalize {
+			prov, err := llm.NewProvider(&cfg.LLM)
+			if err != nil {
+				return fmt.Errorf("llm provider: %w", err)
+			}
+			pl := pipeline.New(st, prov, cfg)
+			fmt.Fprintln(os.Stderr, "Running Phase 3-4: community detection + summaries...")
+			if err := pl.Finalize(cmd.Context(), indexVerbose); err != nil {
+				return err
+			}
+			fmt.Fprintln(os.Stderr, "Finalization complete.")
+			return nil
+		}
+
+		if len(args) == 0 {
+			return fmt.Errorf("path required (or use --finalize)")
+		}
+
+		prov, err := llm.NewProvider(&cfg.LLM)
+		if err != nil {
+			return fmt.Errorf("llm provider: %w", err)
+		}
+
+		pl := pipeline.New(st, prov, cfg)
+		opts := pipeline.IndexOptions{
+			Force:   indexForce,
+			Workers: indexWorkers,
+			Verbose: indexVerbose,
+		}
+
+		fmt.Fprintf(os.Stderr, "Indexing %s (workers=%d)...\n", args[0], indexWorkers)
+		if err := pl.IndexPath(cmd.Context(), args[0], opts); err != nil {
+			return err
+		}
+		fmt.Fprintln(os.Stderr, "Indexing complete.")
+		return nil
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(indexCmd)
+	indexCmd.Flags().BoolVar(&indexForce, "force", false, "Re-index even if file hash already exists")
+	indexCmd.Flags().IntVar(&indexWorkers, "workers", 4, "Parallel workers for indexing")
+	indexCmd.Flags().IntVar(&indexBatch, "batch-size", 20, "Embedding batch size")
+	indexCmd.Flags().BoolVar(&indexFinalize, "finalize", false, "Run community detection + summaries (Phases 3-4)")
+	indexCmd.Flags().BoolVar(&indexVerbose, "verbose", false, "Show per-file errors")
+}

cmd/root.go

@@ -0,0 +1,48 @@
+package cmd
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/amit/docsgraphcontext/internal/config"
+	"github.com/spf13/cobra"
+)
+
+var (
+	cfgFile string
+	cfg     *config.Config
+)
+
+var rootCmd = &cobra.Command{
+	Use:   "docsgraph",
+	Short: "DocsGraphContext — Pure Go GraphRAG MCP server",
+	Long: `DocsGraphContext ingests unstructured documents, builds a knowledge graph
+with community detection, and exposes an MCP server + embedded Web UI.`,
+	SilenceUsage:  true,
+	SilenceErrors: true,
+}
+
+func Execute() {
+	if err := rootCmd.Execute(); err != nil {
+		fmt.Fprintln(os.Stderr, "error:", err)
+		os.Exit(1)
+	}
+}
+
+func init() {
+	cobra.OnInitialize(initConfig)
+	rootCmd.PersistentFlags().StringVar(&cfgFile, "config", "", "config file (default ~/.docsgraph/config.yaml)")
+}
+
+func initConfig() {
+	var err error
+	cfg, err = config.Load(cfgFile)
+	if err != nil {
+		fmt.Fprintln(os.Stderr, "config error:", err)
+		os.Exit(1)
+	}
+	if err := os.MkdirAll(cfg.DataDir, 0755); err != nil {
+		fmt.Fprintln(os.Stderr, "mkdir error:", err)
+		os.Exit(1)
+	}
+}

cmd/serve.go

@@ -0,0 +1,87 @@
+package cmd
+
+import (
+	"context"
+	"fmt"
+	"net"
+	"net/http"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+
+	"github.com/amit/docsgraphcontext/internal/api"
+	"github.com/amit/docsgraphcontext/internal/embedder"
+	"github.com/amit/docsgraphcontext/internal/llm"
+	"github.com/amit/docsgraphcontext/internal/store"
+	"github.com/spf13/cobra"
+)
+
+var (
+	serveHost string
+	servePort int
+)
+
+var serveCmd = &cobra.Command{
+	Use:   "serve",
+	Short: "Start MCP + Web UI server",
+	RunE: func(cmd *cobra.Command, args []string) error {
+		// Override config with CLI flags
+		if serveHost != "" {
+			cfg.Server.Host = serveHost
+		}
+		if servePort != 0 {
+			cfg.Server.Port = servePort
+		}
+
+		st, err := store.Open(cfg.DBPath())
+		if err != nil {
+			return fmt.Errorf("open store: %w", err)
+		}
+		defer st.Close()
+
+		prov, err := llm.NewProvider(&cfg.LLM)
+		if err != nil {
+			return fmt.Errorf("llm provider: %w", err)
+		}
+
+		emb := embedder.New(prov, cfg.Indexing.BatchSize)
+		router := api.NewRouter(st, prov, emb, cfg)
+
+		addr := fmt.Sprintf("%s:%d", cfg.Server.Host, cfg.Server.Port)
+		ln, err := net.Listen("tcp", addr)
+		if err != nil {
+			return fmt.Errorf("listen: %w", err)
+		}
+
+		srv := &http.Server{Handler: router, ReadTimeout: 60 * time.Second, WriteTimeout: 120 * time.Second}
+
+		fmt.Fprintf(os.Stderr, "DocsGraphContext server running on http://%s\n", addr)
+		fmt.Fprintf(os.Stderr, "  Web UI:  http://%s/\n", addr)
+		fmt.Fprintf(os.Stderr, "  MCP:     http://%s/mcp\n", addr)
+		fmt.Fprintf(os.Stderr, "  API:     http://%s/api/\n", addr)
+		fmt.Fprintf(os.Stderr, "  LLM:     %s (%s)\n", prov.Name(), prov.ModelID())
+
+		// Graceful shutdown
+		ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
+		defer stop()
+
+		go func() {
+			if err := srv.Serve(ln); err != nil && err != http.ErrServerClosed {
+				fmt.Fprintln(os.Stderr, "server error:", err)
+			}
+		}()
+
+		<-ctx.Done()
+		fmt.Fprintln(os.Stderr, "\nShutting down...")
+		shutCtx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		defer cancel()
+		return srv.Shutdown(shutCtx)
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(serveCmd)
+	serveCmd.Flags().StringVar(&serveHost, "host", "", "Server host (overrides config)")
+	serveCmd.Flags().IntVar(&servePort, "port", 0, "Server port (overrides config)")
+}