Skip to content

Commit e104b4c

Browse files
author
Lasim
committed
feat(gateway): add 'deploystack refresh' command to refresh MCP server configurations
1 parent 206a356 commit e104b4c

6 files changed

Lines changed: 141 additions & 30 deletions

File tree

‎services/gateway/README.md‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,24 @@ deploystack teams
196196
deploystack teams --switch 2
197197
```
198198

199+
### `deploystack refresh`
200+
201+
Refresh MCP server configurations from cloud control plane.
202+
203+
**Options:**
204+
205+
- `--url <url>` - DeployStack backend URL (override stored URL)
206+
207+
**Examples:**
208+
209+
```bash
210+
# Refresh MCP configuration for current team
211+
deploystack refresh
212+
213+
# Refresh with custom backend URL
214+
deploystack refresh --url http://localhost:3000
215+
```
216+
199217
### `deploystack mcp`
200218

201219
Manage MCP server configurations and discover tools.
@@ -223,6 +241,8 @@ deploystack mcp --tools 1
223241
deploystack mcp --clear
224242
```
225243

244+
**Note:** Both `deploystack refresh` and `deploystack mcp --refresh` perform identical operations using shared logic.
245+
226246
### `deploystack start`
227247

228248
Start the gateway server as a daemon (background process).

‎services/gateway/src/commands/index.ts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ export { registerLogoutCommand } from './logout';
33
export { registerWhoamiCommand } from './whoami';
44
export { registerTeamsCommand } from './teams';
55
export { registerMCPCommand } from './mcp';
6+
export { registerRefreshCommand } from './refresh';
67
export { registerStartCommand } from './start';
78
export { registerStopCommand } from './stop';
89
export { registerStatusCommand } from './status';

‎services/gateway/src/commands/mcp.ts‎

Lines changed: 6 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,10 @@ import fs from 'fs';
55
import path from 'path';
66
import os from 'os';
77
import { CredentialStorage } from '../core/auth/storage';
8-
import { DeployStackAPI } from '../core/auth/api-client';
98
import { MCPConfigService } from '../core/mcp';
109
import { TableFormatter } from '../utils/table';
1110
import { AuthenticationError } from '../types/auth';
11+
import { RefreshService } from '../services/refresh-service';
1212

1313
// PID file location
1414
const PID_FILE = path.join(os.tmpdir(), 'deploystack-gateway.pid');
@@ -209,43 +209,19 @@ export function registerMCPCommand(program: Command) {
209209
process.exit(1);
210210
}
211211

212-
const backendUrl = options.url || credentials.baseUrl || 'https://cloud.deploystack.io';
213-
const api = new DeployStackAPI(credentials, backendUrl);
214-
215212
// Handle refresh mode
216213
if (options.refresh) {
217-
console.log(chalk.blue(`🔄 Refreshing MCP configuration for team: ${chalk.cyan(credentials.selectedTeam.name)}`));
218-
spinner = ora('Downloading latest MCP configuration...').start();
219-
220-
try {
221-
const config = await mcpService.downloadAndStoreMCPConfig(
222-
credentials.selectedTeam.id,
223-
credentials.selectedTeam.name,
224-
api,
225-
false
226-
);
227-
228-
spinner.succeed(`MCP configuration refreshed (${config.servers.length} server${config.servers.length === 1 ? '' : 's'})`);
229-
console.log(chalk.green('✅ MCP configuration has been refreshed'));
230-
231-
// Show summary
232-
console.log(chalk.gray(`\n📊 Configuration Summary:`));
233-
console.log(chalk.gray(` Team: ${config.team_name}`));
234-
console.log(chalk.gray(` Installations: ${config.installations.length}`));
235-
console.log(chalk.gray(` Servers: ${config.servers.length}`));
236-
console.log(chalk.gray(` Last Updated: ${new Date(config.last_updated).toLocaleString()}`));
237-
238-
} catch (error) {
239-
spinner.fail('Failed to refresh MCP configuration');
240-
throw error;
241-
}
214+
const refreshService = new RefreshService();
215+
await refreshService.refreshMCPConfiguration({ url: options.url });
242216
return;
243217
}
244218

245219
// Handle status mode (default)
220+
const backendUrl = options.url || credentials.baseUrl || 'https://cloud.deploystack.io';
221+
246222
console.log(chalk.blue(`🤖 MCP Configuration Status`));
247223
console.log(chalk.gray(`🎯 Current team: ${chalk.cyan(credentials.selectedTeam.name)}`));
248-
console.log(chalk.gray(`🌐 Backend: ${backendUrl}\n`));
224+
console.log(chalk.gray(` Backend: ${backendUrl}\n`));
249225

250226
spinner = ora('Checking MCP configuration...').start();
251227

‎services/gateway/src/commands/refresh.ts‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
import { Command } from 'commander';
2+
import { RefreshService } from '../services/refresh-service';
3+
4+
export function registerRefreshCommand(program: Command) {
5+
program
6+
.command('refresh')
7+
.description('Refresh MCP server configurations from cloud')
8+
.option('--url <url>', 'DeployStack backend URL (override stored URL)')
9+
.action(async (options) => {
10+
const refreshService = new RefreshService();
11+
await refreshService.refreshMCPConfiguration({ url: options.url });
12+
});
13+
}

‎services/gateway/src/index.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ import {
88
registerWhoamiCommand,
99
registerTeamsCommand,
1010
registerMCPCommand,
11+
registerRefreshCommand,
1112
registerStartCommand,
1213
registerStopCommand,
1314
registerStatusCommand,
@@ -28,6 +29,7 @@ registerLogoutCommand(program);
2829
registerWhoamiCommand(program);
2930
registerTeamsCommand(program);
3031
registerMCPCommand(program);
32+
registerRefreshCommand(program);
3133
registerStartCommand(program);
3234
registerStopCommand(program);
3335
registerStatusCommand(program);

‎services/gateway/src/services/refresh-service.ts‎

Lines changed: 99 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,99 @@
1+
import chalk from 'chalk';
2+
import ora from 'ora';
3+
import { CredentialStorage } from '../core/auth/storage';
4+
import { DeployStackAPI } from '../core/auth/api-client';
5+
import { MCPConfigService } from '../core/mcp';
6+
import { AuthenticationError } from '../types/auth';
7+
8+
export interface RefreshOptions {
9+
url?: string;
10+
}
11+
12+
export class RefreshService {
13+
private storage: CredentialStorage;
14+
private mcpService: MCPConfigService;
15+
16+
constructor() {
17+
this.storage = new CredentialStorage();
18+
this.mcpService = new MCPConfigService();
19+
}
20+
21+
/**
22+
* Refresh MCP server configurations from the cloud control plane
23+
* @param options Refresh options including optional backend URL override
24+
*/
25+
async refreshMCPConfiguration(options: RefreshOptions = {}): Promise<void> {
26+
let spinner: ReturnType<typeof ora> | null = null;
27+
28+
try {
29+
// Check authentication
30+
if (!await this.storage.isAuthenticated()) {
31+
console.log(chalk.red('❌ Not authenticated'));
32+
console.log(chalk.gray(`💡 Run 'deploystack login' to authenticate`));
33+
process.exit(1);
34+
}
35+
36+
const credentials = await this.storage.getCredentials();
37+
if (!credentials) {
38+
console.log(chalk.red('❌ No stored credentials found'));
39+
console.log(chalk.gray(`💡 Run 'deploystack login' to authenticate`));
40+
process.exit(1);
41+
}
42+
43+
// Check if team is selected
44+
if (!credentials.selectedTeam) {
45+
console.log(chalk.red('❌ No team selected'));
46+
console.log(chalk.gray(`💡 Run 'deploystack teams --switch <team-number>' to select a team`));
47+
process.exit(1);
48+
}
49+
50+
const backendUrl = options.url || credentials.baseUrl || 'https://cloud.deploystack.io';
51+
const api = new DeployStackAPI(credentials, backendUrl);
52+
53+
console.log(chalk.blue(`🔄 Refreshing MCP configuration for team: ${chalk.cyan(credentials.selectedTeam.name)}`));
54+
spinner = ora('Downloading latest MCP configuration...').start();
55+
56+
try {
57+
const config = await this.mcpService.downloadAndStoreMCPConfig(
58+
credentials.selectedTeam.id,
59+
credentials.selectedTeam.name,
60+
api,
61+
false
62+
);
63+
64+
spinner.succeed(`MCP configuration refreshed (${config.servers.length} server${config.servers.length === 1 ? '' : 's'})`);
65+
console.log(chalk.green('✅ MCP configuration has been refreshed'));
66+
67+
// Show summary
68+
console.log(chalk.gray(`\n📊 Configuration Summary:`));
69+
console.log(chalk.gray(` Team: ${config.team_name}`));
70+
console.log(chalk.gray(` Installations: ${config.installations.length}`));
71+
console.log(chalk.gray(` Servers: ${config.servers.length}`));
72+
console.log(chalk.gray(` Last Updated: ${new Date(config.last_updated).toLocaleString()}`));
73+
74+
} catch (error) {
75+
spinner.fail('Failed to refresh MCP configuration');
76+
throw error;
77+
}
78+
79+
} catch (error) {
80+
if (spinner) {
81+
spinner.fail('MCP refresh operation failed');
82+
}
83+
84+
if (error instanceof AuthenticationError) {
85+
console.log(chalk.red(`❌ Failed to refresh MCP configuration: ${error.message}`));
86+
87+
if (error.code === 'TOKEN_EXPIRED') {
88+
console.log(chalk.gray(`💡 Run 'deploystack login' to refresh your authentication`));
89+
} else if (error.code === 'NETWORK_ERROR') {
90+
console.log(chalk.gray('💡 Check your internet connection and try again'));
91+
}
92+
} else {
93+
console.log(chalk.red(`❌ Unexpected error: ${error instanceof Error ? error.message : String(error)}`));
94+
}
95+
96+
process.exit(1);
97+
}
98+
}
99+
}

0 commit comments

Comments
 (0)