feat(lightspeed): First draft implementation of MCP Service Selection

Assisted-by: Claude Opus 4.6

Generated-by: Cursor
Signed-off-by: Maysun J Faisal <maysunaneek@gmail.com>

Author: maysunfaisal

workspaces/lightspeed/.gitignore

@@ -52,3 +52,7 @@ site
 
 # E2E test reports
 e2e-test-report/
+
+# Local SQLite database files
+sqlite-data/
+*.sqlite

workspaces/lightspeed/app-config.yaml

@@ -30,6 +30,18 @@ backend:
   database:
     client: better-sqlite3
     connection: ':memory:'
+      # Use the directory property to store the database in a file for local development
+      # The database is used for the user preferences and MCP servers settings
+      # directory: './sqlite-data'
+    # OpenShift / RHDH production — uses the PostgreSQL instance managed by the
+    # RHDH Helm chart or Operator.  These env vars are injected from the
+    # PostgreSQL Secret into the Backstage container by the deployment config.
+    # client: pg
+    # connection:
+    #   host: ${POSTGRES_HOST}
+    #   port: ${POSTGRES_PORT}
+    #   user: ${POSTGRES_USER}
+    #   password: ${POSTGRES_PASSWORD}
   # workingDirectory: /tmp # Use this to configure a working directory for the scaffolder, defaults to the OS temp-dir
 
 integrations:

workspaces/lightspeed/plugins/lightspeed-backend/__fixtures__/lcsHandlers.ts

@@ -237,6 +237,33 @@ export const lcsHandlers: HttpHandler[] = [
     return HttpResponse.json(mockModelRes);
   }),
 
+  // LCS MCP server list — returns registered servers so the backend can
+  // resolve URLs for validation without requiring url in app-config.
+  http.get(`${LOCAL_LCS_ADDR}/v1/mcp-servers`, () => {
+    return HttpResponse.json({
+      servers: [
+        {
+          name: 'static-mcp',
+          url: 'http://mock-mcp-server:9999',
+          provider_id: 'model-context-protocol',
+          source: 'config',
+        },
+        {
+          name: 'no-token-server',
+          url: 'http://mock-mcp-server:9999',
+          provider_id: 'model-context-protocol',
+          source: 'config',
+        },
+        {
+          name: 'lcs-only-server',
+          url: 'http://mock-mcp-server:9999',
+          provider_id: 'model-context-protocol',
+          source: 'api',
+        },
+      ],
+    });
+  }),
+
   // Catch-all handler for unknown paths
   http.all(`${LOCAL_LCS_ADDR}/*`, ({ request }) => {
     console.log(`Caught request to unknown path: ${request.url}`);

workspaces/lightspeed/plugins/lightspeed-backend/__fixtures__/mcpHandlers.ts

@@ -0,0 +1,73 @@
+/*
+ * Copyright Red Hat, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { http, HttpResponse, type HttpHandler } from 'msw';
+
+export const MOCK_MCP_ADDR = 'http://mock-mcp-server:9999';
+export const MOCK_MCP_VALID_TOKEN = 'valid-mcp-token';
+
+const MOCK_TOOLS = [
+  { name: 'create_issue', description: 'Create a GitHub issue' },
+  { name: 'list_repos', description: 'List repositories' },
+  { name: 'get_user', description: 'Get user profile' },
+];
+
+export const mcpHandlers: HttpHandler[] = [
+  http.post(MOCK_MCP_ADDR, async ({ request }) => {
+    const auth = request.headers.get('Authorization');
+    if (auth !== `Bearer ${MOCK_MCP_VALID_TOKEN}`) {
+      return HttpResponse.json({ error: 'Unauthorized' }, { status: 401 });
+    }
+
+    const body = (await request.json()) as { method: string; id?: number };
+
+    if (body.method === 'initialize') {
+      return HttpResponse.json(
+        {
+          jsonrpc: '2.0',
+          result: {
+            protocolVersion: '2024-11-05',
+            capabilities: { tools: {} },
+            serverInfo: { name: 'mock-mcp-server', version: '1.0.0' },
+          },
+          id: body.id,
+        },
+        { headers: { 'Mcp-Session-Id': 'mock-session-123' } },
+      );
+    }
+
+    if (body.method === 'notifications/initialized') {
+      return new HttpResponse(null, { status: 204 });
+    }
+
+    if (body.method === 'tools/list') {
+      return HttpResponse.json({
+        jsonrpc: '2.0',
+        result: { tools: MOCK_TOOLS },
+        id: body.id,
+      });
+    }
+
+    return HttpResponse.json(
+      {
+        jsonrpc: '2.0',
+        error: { code: -32601, message: 'Method not found' },
+        id: body.id,
+      },
+      { status: 200 },
+    );
+  }),
+];

workspaces/lightspeed/plugins/lightspeed-backend/config.d.ts

@@ -36,15 +36,18 @@ export interface Config {
      */
     mcpServers?: Array<{
       /**
-       * The name of the mcp server.
+       * The name of the MCP server. Must match the name registered in LCS config.
+       * The URL is fetched from LCS (GET /v1/mcp-servers) at startup.
        * @visibility backend
        */
       name: string;
       /**
-       * The access token for authenticating MCP server.
+       * The default access token for authenticating with this MCP server.
+       * Optional — if omitted, users must provide their own token via the UI.
+       * Users can also override this with a personal token via PATCH /mcp-servers/:name.
        * @visibility secret
        */
-      token: string;
+      token?: string;
     }>;
   };
 }

workspaces/lightspeed/plugins/lightspeed-backend/migrations/20260302120000_add_mcp_servers.js

@@ -0,0 +1,41 @@
+/*
+ * Copyright Red Hat, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * @param {import('knex').Knex} knex
+ */
+exports.up = async function up(knex) {
+  await knex.schema.createTable('lightspeed_mcp_user_settings', table => {
+    table.string('id').primary().notNullable();
+    table.string('server_name').notNullable();
+    table.string('user_entity_ref').notNullable();
+    table.boolean('enabled').notNullable().defaultTo(true);
+    table.text('token'); // nullable — user override for admin default
+    table.string('status').notNullable().defaultTo('unknown');
+    table.integer('tool_count').notNullable().defaultTo(0);
+    table.timestamp('created_at').notNullable().defaultTo(knex.fn.now());
+    table.timestamp('updated_at').notNullable().defaultTo(knex.fn.now());
+
+    table.unique(['server_name', 'user_entity_ref']);
+  });
+};
+
+/**
+ * @param {import('knex').Knex} knex
+ */
+exports.down = async function down(knex) {
+  await knex.schema.dropTableIfExists('lightspeed_mcp_user_settings');
+};

workspaces/lightspeed/plugins/lightspeed-backend/package.json

@@ -51,7 +51,8 @@
     "@langchain/openai": "^0.6.0",
     "@red-hat-developer-hub/backstage-plugin-lightspeed-common": "workspace:^",
     "express": "^4.21.1",
-    "http-proxy-middleware": "^3.0.2"
+    "http-proxy-middleware": "^3.0.2",
+    "knex": "^3.1.0"
   },
   "devDependencies": {
     "@backstage/backend-test-utils": "^1.10.4",
@@ -68,7 +69,8 @@
   "files": [
     "dist",
     "config.d.ts",
-    "app-config.yaml"
+    "app-config.yaml",
+    "migrations"
   ],
   "configSchema": "config.d.ts",
   "repository": {

workspaces/lightspeed/plugins/lightspeed-backend/src/database/migration.ts

@@ -0,0 +1,35 @@
+/*
+ * Copyright Red Hat, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import {
+  DatabaseService,
+  resolvePackagePath,
+} from '@backstage/backend-plugin-api';
+
+const migrationsDir = resolvePackagePath(
+  '@red-hat-developer-hub/backstage-plugin-lightspeed-backend',
+  'migrations',
+);
+
+export async function migrate(databaseManager: DatabaseService) {
+  const knex = await databaseManager.getClient();
+
+  if (!databaseManager.migrations?.skip) {
+    await knex.migrate.latest({
+      directory: migrationsDir,
+    });
+  }
+}

workspaces/lightspeed/plugins/lightspeed-backend/src/index.ts

@@ -18,3 +18,9 @@ export { lightspeedPlugin as default } from './plugin';
 export * from './service/router';
 
 export type { RouterOptions } from './service/types';
+export type {
+  McpServerResponse,
+  McpServerStatus,
+  McpToolInfo,
+  McpValidationResult,
+} from './service/mcp-server-types';

workspaces/lightspeed/plugins/lightspeed-backend/src/plugin.ts

@@ -19,6 +19,7 @@ import {
   createBackendPlugin,
 } from '@backstage/backend-plugin-api';
 
+import { migrate } from './database/migration';
 import { createRouter } from './service/router';
 
 /**
@@ -36,14 +37,26 @@ export const lightspeedPlugin = createBackendPlugin({
         httpAuth: coreServices.httpAuth,
         userInfo: coreServices.userInfo,
         permissions: coreServices.permissions,
+        database: coreServices.database,
       },
-      async init({ logger, config, http, httpAuth, userInfo, permissions }) {
+      async init({
+        logger,
+        config,
+        http,
+        httpAuth,
+        userInfo,
+        permissions,
+        database,
+      }) {
+        await migrate(database);
+
         http.use(
           await createRouter({
-            config: config,
-            logger: logger,
-            httpAuth: httpAuth,
-            userInfo: userInfo,
+            config,
+            logger,
+            database,
+            httpAuth,
+            userInfo,
             permissions,
           }),
         );