/**
* Environment-based MCP Client
* Uses environment variables for secure credential management
*/
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
import { createSmitheryUrl } from "@smithery/sdk";
import { Client } from "@modelcontextprotocol/sdk/client/index.js";
import dotenv from "dotenv";
// Load environment variables
dotenv.config();
// Validate required environment variables
const requiredEnvVars = [
'HOME_ASSISTANT_TOKEN',
'HOME_ASSISTANT_URL',
'SMITHERY_API_KEY'
];
const missingVars = requiredEnvVars.filter(varName => !process.env[varName]);
if (missingVars.length > 0) {
console.error("❌ Missing required environment variables:");
missingVars.forEach(varName => console.error(` - ${varName}`));
console.error("\n💡 Create a .env file with:");
console.error("HOME_ASSISTANT_TOKEN=your_token_here");
console.error("HOME_ASSISTANT_URL=http://your-hass-ip:8123");
console.error("SMITHERY_API_KEY=your_smithery_key_here");
process.exit(1);
}
// Configuration from environment variables
const config = {
homeAssistantToken: process.env.HOME_ASSISTANT_TOKEN,
homeAssistantUrl: process.env.HOME_ASSISTANT_URL,
debug: process.env.DEBUG === 'true' || false,
requestTimeout: parseInt(process.env.REQUEST_TIMEOUT) || 10000
};
console.log("🔧 Configuration loaded:");
console.log(` - Home Assistant URL: ${config.homeAssistantUrl}`);
console.log(` - Debug mode: ${config.debug}`);
console.log(` - Request timeout: ${config.requestTimeout}ms`);
console.log(` - Token: ${config.homeAssistantToken.substring(0, 10)}...`);
// Create Smithery URL
const serverUrl = createSmitheryUrl(
"https://server.smithery.ai/@gilberth/enhanced-homeassistant-mcp",
{
config,
apiKey: process.env.SMITHERY_API_KEY
}
);
const transport = new StreamableHTTPClientTransport(serverUrl);
// Create MCP client
const client = new Client({
name: "Enhanced Home Assistant Client (Secure)",
version: "1.0.0"
});
async function demonstrateCapabilities() {
try {
console.log("\n🔗 Connecting to Enhanced Home Assistant MCP Server...");
await client.connect(transport);
console.log("✅ Connected successfully!");
// Get available tools
const tools = await client.listTools();
console.log(`\n📋 Found ${tools.tools.length} available tools:`);
// Group tools by category
const categories = {
basic: [],
automation: [],
history: [],
devices: [],
system: [],
resources: []
};
tools.tools.forEach(tool => {
if (tool.name.includes('automation')) {
categories.automation.push(tool.name);
} else if (tool.name.includes('history') || tool.name.includes('time') || tool.name.includes('trend')) {
categories.history.push(tool.name);
} else if (tool.name.includes('device') || tool.name.includes('area')) {
categories.devices.push(tool.name);
} else if (tool.name.includes('system') || tool.name.includes('config') || tool.name.includes('log')) {
categories.system.push(tool.name);
} else if (tool.name.includes('resource')) {
categories.resources.push(tool.name);
} else {
categories.basic.push(tool.name);
}
});
Object.entries(categories).forEach(([category, toolNames]) => {
if (toolNames.length > 0) {
console.log(`\n ${category.toUpperCase()}:`);
toolNames.forEach(name => console.log(` - ${name}`));
}
});
// Interactive demonstration
console.log("\n🎮 Running capability demonstration...");
// Test connection
console.log("\n1️⃣ Testing Home Assistant API connection...");
const apiResult = await client.callTool({
name: "homeassistant_api",
arguments: {}
});
console.log(` ✅ ${apiResult.content[0].text}`);
// Get entities overview
console.log("\n2️⃣ Getting entities overview...");
const entitiesResult = await client.callTool({
name: "homeassistant_list_entities",
arguments: { limit: 10 }
});
console.log(` 📱 Retrieved entity list`);
// Search for lights
console.log("\n3️⃣ Searching for light entities...");
try {
const lightsResult = await client.callTool({
name: "homeassistant_search_entities",
arguments: {
query: "light",
limit: 5
}
});
console.log(` 💡 Found light entities`);
} catch (error) {
console.log(` ⚠️ No light entities found or search failed`);
}
// Get system info
console.log("\n4️⃣ Getting system information...");
try {
const systemResult = await client.callTool({
name: "homeassistant_get_system_info",
arguments: {}
});
console.log(` ⚙️ System information retrieved`);
} catch (error) {
console.log(` ⚠️ System info unavailable: ${error.message}`);
}
// Try automations
console.log("\n5️⃣ Checking automations...");
try {
const automationsResult = await client.callTool({
name: "homeassistant_list_automations",
arguments: {}
});
console.log(` 🤖 Automations list retrieved`);
} catch (error) {
console.log(` ⚠️ Automations unavailable (normal if none exist)`);
}
console.log("\n🎉 Capability demonstration completed!");
console.log("\n💡 Your Enhanced Home Assistant MCP Server is working correctly!");
console.log(" You can now integrate this with your AI applications.");
} catch (error) {
console.error("\n❌ Error during demonstration:", error.message);
if (error.message.includes('unauthorized') || error.message.includes('401')) {
console.error("\n🔑 Authentication issue:");
console.error(" - Check your HOME_ASSISTANT_TOKEN");
console.error(" - Ensure the token has proper permissions");
} else if (error.message.includes('connect') || error.message.includes('network')) {
console.error("\n🌐 Connection issue:");
console.error(" - Check your HOME_ASSISTANT_URL");
console.error(" - Ensure Home Assistant is accessible from Smithery");
console.error(" - For local HA, you might need to expose it publicly");
} else if (error.message.includes('smithery') || error.message.includes('api key')) {
console.error("\n🔐 Smithery issue:");
console.error(" - Check your SMITHERY_API_KEY");
console.error(" - Ensure the server is deployed on Smithery");
}
} finally {
try {
await client.close();
console.log("\n👋 Connection closed gracefully.");
} catch (error) {
console.error("Warning: Error closing connection:", error.message);
}
}
}
// Run the demonstration
demonstrateCapabilities().catch(error => {
console.error("Fatal error:", error);
process.exit(1);
});
