Select an item from the sidebar
- +Parameters:
- +Form
JSON
Formatted
Raw JSON
No parameters required for this tool.
'; return; } - + const properties = schema.properties; const required = schema.required || []; - + for (const propName in properties) { const prop = properties[propName]; const formGroup = document.createElement('div'); formGroup.className = 'mb-6'; formGroup.dataset.propName = propName; - + // Create label const label = document.createElement('label'); label.htmlFor = 'param-' + propName; label.textContent = propName; label.className = 'block text-sm font-medium text-gray-700 mb-1'; - + if (required.includes(propName)) { const requiredSpan = document.createElement('span'); requiredSpan.className = 'text-red-600 font-bold'; @@ -500,7 +496,7 @@ func handleIndex() http.HandlerFunc { label.appendChild(requiredSpan); } formGroup.appendChild(label); - + // Add description if available if (prop.description) { const description = document.createElement('div'); @@ -508,7 +504,7 @@ func handleIndex() http.HandlerFunc { description.textContent = prop.description; formGroup.appendChild(description); } - + // Handle different types of inputs if (prop.type === 'array') { // Create array container @@ -516,14 +512,14 @@ func handleIndex() http.HandlerFunc { arrayContainer.className = 'mb-4'; arrayContainer.id = 'array-container-' + propName; formGroup.appendChild(arrayContainer); - + // Check if this is an array of objects with schema defined const isObjectArray = prop.items && prop.items.type === 'object' && prop.items.properties; - + if (isObjectArray) { // Store the item schema for later use when adding new items arrayContainer.dataset.itemSchema = JSON.stringify(prop.items); - + // Add button for adding new items const addButton = document.createElement('button'); addButton.type = 'button'; @@ -533,15 +529,15 @@ func handleIndex() http.HandlerFunc { addArrayItem(propName, prop.items); updateJSONFromForm(); // Update JSON when adding items }; - + const arrayActions = document.createElement('div'); arrayActions.className = 'mt-2'; arrayActions.appendChild(addButton); formGroup.appendChild(arrayActions); - + // Make sure to append the formGroup to the DOM before adding items formContainer.appendChild(formGroup); - + // Add initial empty item addArrayItem(propName, prop.items); } else { @@ -552,12 +548,12 @@ func handleIndex() http.HandlerFunc { textarea.className = 'w-full px-3 py-2 border border-gray-300 rounded-md shadow-sm focus:outline-none focus:ring-blue-500 focus:border-blue-500 font-mono'; textarea.placeholder = 'Enter one item per line'; textarea.rows = 4; - + // Add event listener to update JSON when textarea changes textarea.addEventListener('input', () => updateJSONFromForm()); - + formGroup.appendChild(textarea); - + formContainer.appendChild(formGroup); } } else { @@ -567,19 +563,19 @@ func handleIndex() http.HandlerFunc { case 'boolean': input = document.createElement('select'); input.className = 'w-full px-3 py-2 border border-gray-300 rounded-md shadow-sm focus:outline-none focus:ring-blue-500 focus:border-blue-500'; - + const trueOption = document.createElement('option'); trueOption.value = 'true'; trueOption.textContent = 'true'; - + const falseOption = document.createElement('option'); falseOption.value = 'false'; falseOption.textContent = 'false'; - + input.appendChild(trueOption); input.appendChild(falseOption); break; - + case 'number': case 'integer': input = document.createElement('input'); @@ -588,19 +584,19 @@ func handleIndex() http.HandlerFunc { if (prop.minimum !== undefined) input.min = prop.minimum; if (prop.maximum !== undefined) input.max = prop.maximum; break; - + case 'object': input = document.createElement('textarea'); input.placeholder = 'Enter JSON object'; input.className = 'w-full px-3 py-2 border border-gray-300 rounded-md shadow-sm focus:outline-none focus:ring-blue-500 focus:border-blue-500 font-mono'; input.rows = 4; break; - + default: // string or any other type if (prop.enum) { input = document.createElement('select'); input.className = 'w-full px-3 py-2 border border-gray-300 rounded-md shadow-sm focus:outline-none focus:ring-blue-500 focus:border-blue-500'; - + prop.enum.forEach(option => { const optionEl = document.createElement('option'); optionEl.value = option; @@ -614,32 +610,32 @@ func handleIndex() http.HandlerFunc { if (prop.format === 'password') input.type = 'password'; } } - + input.id = 'param-' + propName; input.name = propName; - + // Add event listener to update JSON when input changes input.addEventListener('input', () => updateJSONFromForm()); if (input.tagName === 'SELECT') { input.addEventListener('change', () => updateJSONFromForm()); } - + formGroup.appendChild(input); formContainer.appendChild(formGroup); } } } - + // Add a new item to an array function addArrayItem(propName, itemSchema) { const container = document.getElementById('array-container-' + propName); const itemIndex = container.children.length; - + // Create item container const itemDiv = document.createElement('div'); itemDiv.className = 'relative p-4 mb-4 bg-gray-50 border border-gray-200 rounded-lg'; itemDiv.dataset.index = itemIndex; - + // Add remove button const removeButton = document.createElement('button'); removeButton.type = 'button'; @@ -653,20 +649,20 @@ func handleIndex() http.HandlerFunc { updateJSONFromForm(); }; itemDiv.appendChild(removeButton); - + // Create form fields based on the item schema if (itemSchema && itemSchema.properties) { for (const fieldName in itemSchema.properties) { const fieldProp = itemSchema.properties[fieldName]; const fieldGroup = document.createElement('div'); fieldGroup.className = 'mb-4'; - + // Label const label = document.createElement('label'); label.htmlFor = 'param-' + propName + '-' + itemIndex + '-' + fieldName; label.textContent = fieldName; label.className = 'block text-sm font-medium text-gray-700 mb-1'; - + if (itemSchema.required && itemSchema.required.includes(fieldName)) { const requiredSpan = document.createElement('span'); requiredSpan.className = 'text-red-600 font-bold'; @@ -674,7 +670,7 @@ func handleIndex() http.HandlerFunc { label.appendChild(requiredSpan); } fieldGroup.appendChild(label); - + // Description if (fieldProp.description) { const description = document.createElement('div'); @@ -682,26 +678,26 @@ func handleIndex() http.HandlerFunc { description.textContent = fieldProp.description; fieldGroup.appendChild(description); } - + // Input let input; switch (fieldProp.type) { case 'boolean': input = document.createElement('select'); input.className = 'w-full px-3 py-2 border border-gray-300 rounded-md shadow-sm focus:outline-none focus:ring-blue-500 focus:border-blue-500'; - + const trueOption = document.createElement('option'); trueOption.value = 'true'; trueOption.textContent = 'true'; - + const falseOption = document.createElement('option'); falseOption.value = 'false'; falseOption.textContent = 'false'; - + input.appendChild(trueOption); input.appendChild(falseOption); break; - + case 'number': case 'integer': input = document.createElement('input'); @@ -710,12 +706,12 @@ func handleIndex() http.HandlerFunc { if (fieldProp.minimum !== undefined) input.min = fieldProp.minimum; if (fieldProp.maximum !== undefined) input.max = fieldProp.maximum; break; - + default: // string, object, or any other type if (fieldProp.enum) { input = document.createElement('select'); input.className = 'w-full px-3 py-2 border border-gray-300 rounded-md shadow-sm focus:outline-none focus:ring-blue-500 focus:border-blue-500'; - + fieldProp.enum.forEach(option => { const optionEl = document.createElement('option'); optionEl.value = option; @@ -729,33 +725,33 @@ func handleIndex() http.HandlerFunc { if (fieldProp.format === 'password') input.type = 'password'; } } - + input.id = 'param-' + propName + '-' + itemIndex + '-' + fieldName; input.name = propName + '-' + itemIndex + '-' + fieldName; input.dataset.field = fieldName; - + // Add event listener to update JSON when item field changes input.addEventListener('input', () => updateJSONFromForm()); if (input.tagName === 'SELECT') { input.addEventListener('change', () => updateJSONFromForm()); } - + fieldGroup.appendChild(input); itemDiv.appendChild(fieldGroup); } } - + container.appendChild(itemDiv); } - + // Update indices for array items after removal function updateArrayItemIndices(propName) { const container = document.getElementById('array-container-' + propName); const items = container.querySelectorAll('.array-item'); - + items.forEach((item, index) => { item.dataset.index = index; - + // Update all input IDs and names within this item const inputs = item.querySelectorAll('input, select, textarea'); inputs.forEach(input => { @@ -765,11 +761,11 @@ func handleIndex() http.HandlerFunc { }); }); } - + // Collect values from form function collectFormValues(tool) { const params = {}; - + // Check for schema in either parameters or inputSchema let schema = null; if (tool.parameters && tool.parameters.properties) { @@ -777,42 +773,42 @@ func handleIndex() http.HandlerFunc { } else if (tool.inputSchema && tool.inputSchema.properties) { schema = tool.inputSchema; } - + if (!schema) { return params; } - + const properties = schema.properties; - + for (const propName in properties) { const prop = properties[propName]; - + if (prop.type === 'array' && prop.items && prop.items.type === 'object' && prop.items.properties) { // Handle array of objects using the specialized UI const container = document.getElementById('array-container-' + propName); if (!container) continue; - + const items = container.querySelectorAll('.array-item'); const arrayValues = []; - + items.forEach(item => { const itemIndex = item.dataset.index; const itemValue = {}; - + // Collect all field values for this item for (const fieldName in prop.items.properties) { const input = document.getElementById('param-' + propName + '-' + itemIndex + '-' + fieldName); if (!input) continue; - + let value = input.value; - + // Convert types appropriately const fieldProp = prop.items.properties[fieldName]; switch (fieldProp.type) { case 'boolean': value = value === 'true'; break; - + case 'number': case 'integer': if (value !== '') { @@ -821,39 +817,39 @@ func handleIndex() http.HandlerFunc { continue; // Skip empty values } break; - + default: // For strings, just use as-is break; } - + // Only add non-empty values if (value !== '' && value !== undefined) { itemValue[fieldName] = value; } } - + // Only add non-empty objects if (Object.keys(itemValue).length > 0) { arrayValues.push(itemValue); } }); - + params[propName] = arrayValues; } else { // Handle regular inputs or simple arrays const input = document.getElementById('param-' + propName); - + if (!input) continue; - + let value = input.value; - + // Convert types appropriately switch (prop.type) { case 'boolean': value = value === 'true'; break; - + case 'number': case 'integer': if (value !== '') { @@ -862,7 +858,7 @@ func handleIndex() http.HandlerFunc { continue; // Skip empty values } break; - + case 'array': if (value) { // Split by new lines and filter empty lines @@ -873,7 +869,7 @@ func handleIndex() http.HandlerFunc { value = []; } break; - + case 'object': if (value) { try { @@ -886,22 +882,22 @@ func handleIndex() http.HandlerFunc { value = {}; } break; - + default: // For strings, just use as-is break; } - + // Only add non-empty values if (value !== '' && value !== undefined) { params[propName] = value; } } } - + return params; } - + // Call a tool with parameters function callTool(name, params) { fetch('/api/call', { @@ -924,18 +920,18 @@ func handleIndex() http.HandlerFunc { }) .catch(err => { document.getElementById('raw-output-container').textContent = 'Error calling tool: ' + err.message; - document.getElementById('formatted-output-container').innerHTML = - 'Error
' +
+ document.getElementById('formatted-output-container').innerHTML =
+ '';
});
}
-
+
// Call a resource
function callResource(uri) {
document.getElementById('main-title').textContent = 'Resource: ' + uri;
document.getElementById('tool-description').classList.add('hidden');
document.getElementById('tool-panel').classList.add('hidden');
-
+
fetch('/api/call', {
method: 'POST',
headers: {
@@ -955,18 +951,18 @@ func handleIndex() http.HandlerFunc {
})
.catch(err => {
document.getElementById('raw-output-container').textContent = 'Error reading resource: ' + err.message;
- document.getElementById('formatted-output-container').innerHTML =
- '
Error
' +
err.message + '
Error
' +
+ document.getElementById('formatted-output-container').innerHTML =
+ '';
});
}
-
+
// Call a prompt
function callPrompt(name) {
document.getElementById('main-title').textContent = 'Prompt: ' + name;
document.getElementById('tool-description').classList.add('hidden');
document.getElementById('tool-panel').classList.add('hidden');
-
+
fetch('/api/call', {
method: 'POST',
headers: {
@@ -986,59 +982,59 @@ func handleIndex() http.HandlerFunc {
})
.catch(err => {
document.getElementById('raw-output-container').textContent = 'Error getting prompt: ' + err.message;
- document.getElementById('formatted-output-container').innerHTML =
- '
Error
' +
err.message + '
Error
' +
+ document.getElementById('formatted-output-container').innerHTML =
+ '';
});
}
-
+
// Display formatted output
function displayFormattedOutput(data) {
const container = document.getElementById('formatted-output-container');
container.innerHTML = '';
-
+
if (data.error) {
const errorDiv = document.createElement('div');
errorDiv.className = 'result-object';
-
+
const errorTitle = document.createElement('h3');
errorTitle.textContent = 'Error';
errorDiv.appendChild(errorTitle);
-
+
const errorText = document.createElement('div');
errorText.className = 'result-property';
errorText.textContent = data.error;
errorDiv.appendChild(errorText);
-
+
container.appendChild(errorDiv);
return;
}
-
+
renderObject(data, container);
}
-
+
// Recursively render object
function renderObject(obj, container, level = 0) {
if (!obj || typeof obj !== 'object') return;
-
+
for (const key in obj) {
if (!obj.hasOwnProperty(key)) continue;
-
+
const value = obj[key];
-
+
if (value && typeof value === 'object' && !Array.isArray(value)) {
// This is an object
const objectDiv = document.createElement('div');
objectDiv.className = 'pl-4 border-l-2 border-blue-400 mb-4';
objectDiv.style.marginLeft = (level * 16) + 'px';
-
+
const objectTitle = document.createElement('h3');
objectTitle.className = 'text-lg font-semibold text-blue-600 mb-2';
objectTitle.textContent = key;
objectDiv.appendChild(objectTitle);
-
+
container.appendChild(objectDiv);
-
+
// Recursively render properties
renderObject(value, objectDiv, level + 1);
} else if (key === "content" && Array.isArray(value)) {
@@ -1046,14 +1042,14 @@ func handleIndex() http.HandlerFunc {
const contentDiv = document.createElement('div');
contentDiv.className = 'pl-4 border-l-2 border-blue-400 mb-4';
contentDiv.style.marginLeft = (level * 16) + 'px';
-
+
const contentTitle = document.createElement('h3');
contentTitle.className = 'text-lg font-semibold text-blue-600 mb-2';
contentTitle.textContent = key;
contentDiv.appendChild(contentTitle);
-
+
container.appendChild(contentDiv);
-
+
// Process each content item
value.forEach((item, index) => {
if (typeof item === 'object') {
@@ -1061,12 +1057,12 @@ func handleIndex() http.HandlerFunc {
const itemDiv = document.createElement('div');
itemDiv.className = 'pl-4 border-l-2 border-gray-300 mb-2 pb-2';
itemDiv.style.marginLeft = '16px';
-
+
const itemTitle = document.createElement('h3');
itemTitle.className = 'text-md font-semibold text-gray-700 mb-1';
itemTitle.textContent = 'Item ' + (index + 1);
itemDiv.appendChild(itemTitle);
-
+
contentDiv.appendChild(itemDiv);
renderObject(item, itemDiv, level + 2);
} else if (typeof item === 'string') {
@@ -1077,12 +1073,12 @@ func handleIndex() http.HandlerFunc {
const itemDiv = document.createElement('div');
itemDiv.className = 'pl-4 border-l-2 border-gray-300 mb-2 pb-2';
itemDiv.style.marginLeft = '16px';
-
+
const itemTitle = document.createElement('h3');
itemTitle.className = 'text-md font-semibold text-gray-700 mb-1';
itemTitle.textContent = 'Item ' + (index + 1);
itemDiv.appendChild(itemTitle);
-
+
contentDiv.appendChild(itemDiv);
renderObject(parsedItem, itemDiv, level + 2);
} else {
@@ -1104,21 +1100,21 @@ func handleIndex() http.HandlerFunc {
}
}
}
-
+
// Helper function to render primitive values
function renderPrimitiveValue(container, key, value, level) {
const propertyDiv = document.createElement('div');
propertyDiv.className = 'py-1 flex flex-wrap';
propertyDiv.style.marginLeft = (level * 16) + 'px';
-
+
const nameSpan = document.createElement('span');
nameSpan.className = 'text-gray-600 mr-2 font-medium';
nameSpan.textContent = key + ': ';
propertyDiv.appendChild(nameSpan);
-
+
const valueSpan = document.createElement('span');
valueSpan.className = 'font-mono';
-
+
if (value === null) {
valueSpan.classList.add('text-gray-500');
valueSpan.classList.add('italic');
@@ -1127,7 +1123,7 @@ func handleIndex() http.HandlerFunc {
valueSpan.textContent = JSON.stringify(value);
} else {
const type = typeof value;
-
+
if (type === 'string') {
valueSpan.classList.add('text-green-600');
} else if (type === 'number') {
@@ -1135,14 +1131,14 @@ func handleIndex() http.HandlerFunc {
} else if (type === 'boolean') {
valueSpan.classList.add('text-red-600');
}
-
+
// Check if string might be parseable JSON
if (type === 'string' && value.trim().startsWith('{') && value.trim().endsWith('}')) {
try {
// Try to parse and pretty print
const parsed = JSON.parse(value);
valueSpan.textContent = JSON.stringify(parsed, null, 2);
-
+
// Add a special class for JSON strings
valueSpan.className = 'font-mono p-3 mt-2 mb-2 block bg-gray-50 border border-gray-200 rounded-md overflow-x-auto whitespace-pre';
} catch (e) {
@@ -1153,7 +1149,7 @@ func handleIndex() http.HandlerFunc {
valueSpan.textContent = type === 'string' ? '"' + value + '"' : String(value);
}
}
-
+
propertyDiv.appendChild(valueSpan);
container.appendChild(propertyDiv);
}
@@ -1172,7 +1168,7 @@ func handleTools(cache *MCPClientCache) http.HandlerFunc {
//nolint:revive // Parameter r is required by http.HandlerFunc signature
return func(w http.ResponseWriter, r *http.Request) {
cache.mutex.Lock()
- resp, err := cache.client.ListTools()
+ resp, err := cache.client.ListTools(context.Background(), mcp.ListToolsRequest{})
cache.mutex.Unlock()
w.Header().Set("Content-Type", "application/json")
@@ -1197,7 +1193,7 @@ func handleResources(cache *MCPClientCache) http.HandlerFunc {
//nolint:revive // Parameter r is required by http.HandlerFunc signature
return func(w http.ResponseWriter, r *http.Request) {
cache.mutex.Lock()
- resp, err := cache.client.ListResources()
+ resp, err := cache.client.ListResources(context.Background(), mcp.ListResourcesRequest{})
cache.mutex.Unlock()
w.Header().Set("Content-Type", "application/json")
@@ -1222,7 +1218,7 @@ func handlePrompts(cache *MCPClientCache) http.HandlerFunc {
//nolint:revive // Parameter r is required by http.HandlerFunc signature
return func(w http.ResponseWriter, r *http.Request) {
cache.mutex.Lock()
- resp, err := cache.client.ListPrompts()
+ resp, err := cache.client.ListPrompts(context.Background(), mcp.ListPromptsRequest{})
cache.mutex.Unlock()
w.Header().Set("Content-Type", "application/json")
@@ -1274,11 +1270,24 @@ func handleCall(cache *MCPClientCache) http.HandlerFunc {
switch requestData.Type {
case "tool":
- resp, callErr = cache.client.CallTool(requestData.Name, requestData.Params)
+ var toolResponse *mcp.CallToolResult
+ request := mcp.CallToolRequest{}
+ request.Params.Name = requestData.Name
+ request.Params.Arguments = requestData.Params
+ toolResponse, callErr = cache.client.CallTool(context.Background(), request)
+ resp = ConvertJSONToMap(toolResponse)
case "resource":
- resp, callErr = cache.client.ReadResource(requestData.Name)
+ var resourceResponse *mcp.ReadResourceResult
+ request := mcp.ReadResourceRequest{}
+ request.Params.URI = requestData.Name
+ resourceResponse, callErr = cache.client.ReadResource(context.Background(), request)
+ resp = ConvertJSONToMap(resourceResponse)
case "prompt":
- resp, callErr = cache.client.GetPrompt(requestData.Name)
+ var promptResponse *mcp.GetPromptResult
+ request := mcp.GetPromptRequest{}
+ request.Params.Name = requestData.Name
+ promptResponse, callErr = cache.client.GetPrompt(context.Background(), request)
+ resp = ConvertJSONToMap(promptResponse)
default:
w.WriteHeader(http.StatusBadRequest)
//nolint:errcheck,gosec // No need to handle error from Encode in this context
diff --git a/cmd/mcptools/main_test.go b/cmd/mcptools/main_test.go
index 75b2180..1be87c8 100644
--- a/cmd/mcptools/main_test.go
+++ b/cmd/mcptools/main_test.go
@@ -12,7 +12,6 @@ import (
"testing"
"github.com/f/mcptools/cmd/mcptools/commands"
- "github.com/f/mcptools/pkg/transport"
)
const entityTypeValue = "tool"
@@ -97,7 +96,7 @@ func (t *MockTransport) Execute(method string, params interface{}) (map[string]i
}
type Shell struct {
- Transport transport.Transport
+ Transport *MockTransport
Reader io.Reader
Writer io.Writer
Format string
diff --git a/go.mod b/go.mod
index 41e3f75..96905dc 100644
--- a/go.mod
+++ b/go.mod
@@ -3,6 +3,7 @@ module github.com/f/mcptools
go 1.24.1
require (
+ github.com/mark3labs/mcp-go v0.24.1
github.com/peterh/liner v1.2.2
github.com/spf13/cobra v1.9.1
github.com/spf13/viper v1.20.1
@@ -15,6 +16,7 @@ require (
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/fsnotify/fsnotify v1.8.0 // indirect
github.com/go-viper/mapstructure/v2 v2.2.1 // indirect
+ github.com/google/uuid v1.6.0 // indirect
github.com/inconshreveable/mousetrap v1.1.0 // indirect
github.com/mattn/go-runewidth v0.0.16 // indirect
github.com/pelletier/go-toml/v2 v2.2.3 // indirect
@@ -27,6 +29,7 @@ require (
github.com/spf13/cast v1.7.1 // indirect
github.com/spf13/pflag v1.0.6 // indirect
github.com/subosito/gotenv v1.6.0 // indirect
+ github.com/yosida95/uritemplate/v3 v3.0.2 // indirect
go.uber.org/atomic v1.9.0 // indirect
go.uber.org/multierr v1.9.0 // indirect
golang.org/x/sys v0.31.0 // indirect
diff --git a/go.sum b/go.sum
index 675d4dd..0426ba3 100644
--- a/go.sum
+++ b/go.sum
@@ -10,12 +10,18 @@ github.com/go-viper/mapstructure/v2 v2.2.1 h1:ZAaOCxANMuZx5RCeg0mBdEZk7DZasvvZIx
github.com/go-viper/mapstructure/v2 v2.2.1/go.mod h1:oJDH3BJKyqBA2TXFhDsKDGDTlndYOZ6rGS0BRZIxGhM=
github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
github.com/google/go-cmp v0.6.0/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/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
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.23.1 h1:RzTzZ5kJ+HxwnutKA4rll8N/pKV6Wh5dhCmiJUu5S9I=
+github.com/mark3labs/mcp-go v0.23.1/go.mod h1:rXqOudj/djTORU/ThxYx8fqEVj/5pvTuuebQ2RC7uk4=
+github.com/mark3labs/mcp-go v0.24.1 h1:YV+5X/+W4oBdERLWgiA1uR7AIvenlKJaa5V4hqufI7E=
+github.com/mark3labs/mcp-go v0.24.1/go.mod h1:rXqOudj/djTORU/ThxYx8fqEVj/5pvTuuebQ2RC7uk4=
github.com/mattn/go-runewidth v0.0.3/go.mod h1:LwmH8dsx7+W8Uxz3IHJYH5QSwggIsqBzpuz5H//U1FU=
github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc=
github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w=
@@ -51,6 +57,8 @@ github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOf
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
github.com/subosito/gotenv v1.6.0 h1:9NlTDc1FTs4qu0DDq7AEtTPNw6SVm7uBMsUCUjABIf8=
github.com/subosito/gotenv v1.6.0/go.mod h1:Dk4QP5c2W3ibzajGcXpNraDfq2IrhjMIvMSWPKKo0FU=
+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=
go.uber.org/atomic v1.9.0 h1:ECmE8Bn/WFTYwEW/bpKD3M8VtR/zQVbavAoalC1PYyE=
go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
go.uber.org/multierr v1.9.0 h1:7fIwc/ZtS0q++VgcfqFDxSBZVv/Xo49/SYnDFupUwlI=
diff --git a/pkg/client/client.go b/pkg/client/client.go
deleted file mode 100644
index 48efae3..0000000
--- a/pkg/client/client.go
+++ /dev/null
@@ -1,128 +0,0 @@
-/*
-Package client implements mcp client functionality.
-*/
-package client
-
-import (
- "fmt"
- "os"
- "strings"
-
- "github.com/f/mcptools/pkg/transport"
-)
-
-// Client provides an interface to interact with MCP servers.
-// It abstracts away the transport mechanism so callers don't need
-// to worry about the details of HTTP, stdio, etc.
-type Client struct {
- transport transport.Transport
-}
-
-// Option provides a way for passing options to the Client to change its
-// configuration.
-type Option func(*Client)
-
-// CloseTransportAfterExecute allows keeping a transport alive if supported by
-// the transport.
-func CloseTransportAfterExecute(closeTransport bool) Option {
- return func(c *Client) {
- t, ok := c.transport.(interface{ SetCloseAfterExecute(bool) })
- if ok {
- t.SetCloseAfterExecute(closeTransport)
- }
- }
-}
-
-// SetShowServerLogs sets whether to show server logs.
-func SetShowServerLogs(showLogs bool) Option {
- return func(c *Client) {
- t, ok := c.transport.(interface{ SetShowServerLogs(bool) })
- if ok {
- t.SetShowServerLogs(showLogs)
- }
- }
-}
-
-// NewWithTransport creates a new MCP client using the provided transport.
-// This allows callers to provide a custom transport implementation.
-func NewWithTransport(t transport.Transport) *Client {
- return &Client{
- transport: t,
- }
-}
-
-// NewStdio creates a new MCP client that communicates with a command
-// via stdin/stdout using JSON-RPC.
-func NewStdio(command []string, opts ...Option) *Client {
- c := &Client{
- transport: transport.NewStdio(command),
- }
- for _, opt := range opts {
- opt(c)
- }
- return c
-}
-
-// NewHTTP creates a MCP client that communicates with a server via HTTP using JSON-RPC.
-func NewHTTP(address string) *Client {
- transport, err := transport.NewHTTP(address)
- if err != nil {
- fmt.Fprintf(os.Stderr, "Error creating HTTP transport: %s\n", err)
- os.Exit(1)
- }
-
- return &Client{
- transport: transport,
- }
-}
-
-// ListTools retrieves the list of available tools from the MCP server.
-func (c *Client) ListTools() (map[string]any, error) {
- return c.transport.Execute("tools/list", nil)
-}
-
-// ListResources retrieves the list of available resources from the MCP server.
-func (c *Client) ListResources() (map[string]any, error) {
- return c.transport.Execute("resources/list", nil)
-}
-
-// ListPrompts retrieves the list of available prompts from the MCP server.
-func (c *Client) ListPrompts() (map[string]any, error) {
- return c.transport.Execute("prompts/list", nil)
-}
-
-// CallTool calls a specific tool on the MCP server with the given arguments.
-func (c *Client) CallTool(toolName string, args map[string]any) (map[string]any, error) {
- params := map[string]any{
- "name": toolName,
- "arguments": args,
- }
- return c.transport.Execute("tools/call", params)
-}
-
-// GetPrompt retrieves a specific prompt from the MCP server.
-func (c *Client) GetPrompt(promptName string) (map[string]any, error) {
- params := map[string]any{
- "name": promptName,
- }
- return c.transport.Execute("prompts/get", params)
-}
-
-// ReadResource reads the content of a specific resource from the MCP server.
-func (c *Client) ReadResource(uri string) (map[string]any, error) {
- params := map[string]any{
- "uri": uri,
- }
- return c.transport.Execute("resources/read", params)
-}
-
-// ParseCommandString splits a command string into separate arguments,
-// respecting spaces as argument separators.
-// Note: This is a simple implementation that doesn't handle quotes or escapes.
-func ParseCommandString(cmdStr string) []string {
- if cmdStr == "" {
- return nil
- }
-
- return strings.Fields(cmdStr)
-}
diff --git a/pkg/transport/http.go b/pkg/transport/http.go
deleted file mode 100644
index f55f9a5..0000000
--- a/pkg/transport/http.go
+++ /dev/null
@@ -1,187 +0,0 @@
-package transport
-
-import (
- "bufio"
- "bytes"
- "encoding/json"
- "fmt"
- "io"
- "net/http"
- "net/url"
- "os"
- "strings"
- "time"
-)
-
-// HTTP implements the Transport interface by communicating with a MCP server over HTTP using JSON-RPC.
-type HTTP struct {
- eventCh chan string
- address string
- debug bool
- nextID int
-}
-
-// NewHTTP creates a new Http transport that will execute the given command.
-// It communicates with the command using JSON-RPC over HTTP.
-// Currently Http transport is implements MCP's Final draft version 2024-11-05,
-// https://spec.modelcontextprotocol.io/specification/2024-11-05/basic/transports/#http-with-sse
-func NewHTTP(address string) (*HTTP, error) {
- debug := os.Getenv("MCP_DEBUG") == "1"
-
- _, uriErr := url.ParseRequestURI(address)
- if uriErr != nil {
- return nil, fmt.Errorf("invalid address: %w", uriErr)
- }
-
- resp, err := http.Get(address + "/sse")
- if err != nil {
- return nil, fmt.Errorf("error sending request: %w", err)
- }
-
- eventCh := make(chan string, 1)
-
- go func() {
- defer func() {
- if closeErr := resp.Body.Close(); closeErr != nil {
- fmt.Fprintf(os.Stderr, "Failed to close response body: %v\n", closeErr)
- }
- }()
-
- reader := bufio.NewReader(resp.Body)
- for {
- line, lineErr := reader.ReadString('\n')
- if lineErr != nil {
- fmt.Fprintf(os.Stderr, "SSE read error: %v\n", lineErr)
- return
- }
- line = strings.TrimSpace(line)
- if debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Received SSE: %s\n", line)
- }
- if strings.HasPrefix(line, "data:") {
- data := strings.TrimSpace(line[5:])
- select {
- case eventCh <- data:
- default:
- }
- }
- }
- }()
-
- // First event we receive from SSE is the message address. We will use this endpoint to keep
- // a session alive.
- var messageAddress string
- select {
- case msg := <-eventCh:
- messageAddress = msg
- case <-time.After(10 * time.Second):
- return nil, fmt.Errorf("timeout waiting for SSE response")
- }
-
- client := &HTTP{
- // Use the SSE message address as the base address for the HTTP transport
- address: address + "/sse" + messageAddress,
- nextID: 1,
- debug: debug,
- eventCh: eventCh,
- }
-
- // Send initialize request
- _, err = client.Execute("initialize", map[string]any{
- "clientInfo": map[string]any{
- "name": "mcp-client",
- "version": "0.1.0",
- },
- "capabilities": map[string]any{},
- "protocolVersion": "2024-11-05",
- })
- if err != nil {
- return nil, fmt.Errorf("error sending initialize request: %w", err)
- }
-
- // Send intialized notification
- if err := client.send("notifications/initialized", nil); err != nil {
- return nil, fmt.Errorf("error sending initialized notification: %w", err)
- }
-
- return client, nil
-}
-
-// Execute implements the Transport via JSON-RPC over HTTP.
-func (t *HTTP) Execute(method string, params any) (map[string]any, error) {
- if err := t.send(method, params); err != nil {
- return nil, err
- }
-
- // After sending the request, we listen the SSE channel for the response
- var response Response
- select {
- case msg := <-t.eventCh:
- if unmarshalErr := json.Unmarshal([]byte(msg), &response); unmarshalErr != nil {
- return nil, fmt.Errorf("error unmarshaling response: %w, response: %s", unmarshalErr, msg)
- }
- case <-time.After(10 * time.Second):
- return nil, fmt.Errorf("timeout waiting for SSE response")
- }
-
- if response.Error != nil {
- return nil, fmt.Errorf("RPC error %d: %s", response.Error.Code, response.Error.Message)
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Successfully parsed response\n")
- }
-
- return response.Result, nil
-}
-
-func (t *HTTP) send(method string, params any) error {
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Connecting to server: %s\n", t.address)
- }
-
- request := Request{
- JSONRPC: "2.0",
- Method: method,
- ID: t.nextID,
- Params: params,
- }
- t.nextID++
-
- requestJSON, err := json.Marshal(request)
- if err != nil {
- return fmt.Errorf("error marshaling request: %w", err)
- }
-
- requestJSON = append(requestJSON, '\n')
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Sending request: %s\n", string(requestJSON))
- }
-
- resp, err := http.Post(t.address, "application/json", bytes.NewBuffer(requestJSON))
- if err != nil {
- return fmt.Errorf("error sending request: %w", err)
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Sent request to server\n")
- }
-
- defer func() {
- if closeErr := resp.Body.Close(); closeErr != nil {
- fmt.Fprintf(os.Stderr, "Failed to close response body: %v\n", closeErr)
- }
- }()
-
- body, err := io.ReadAll(resp.Body)
- if err != nil {
- return fmt.Errorf("error reading response: %w", err)
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Read from server: %s\n", string(body))
- }
-
- return nil
-}
diff --git a/pkg/transport/stdio.go b/pkg/transport/stdio.go
deleted file mode 100644
index fa451ac..0000000
--- a/pkg/transport/stdio.go
+++ /dev/null
@@ -1,360 +0,0 @@
-package transport
-
-import (
- "bufio"
- "bytes"
- "encoding/json"
- "fmt"
- "io"
- "os"
- "os/exec"
- "strings"
- "time"
-)
-
-// Stdio implements the Transport interface by executing a command
-// and communicating with it via stdin/stdout using JSON-RPC.
-type Stdio struct {
- process *stdioProcess
- command []string
- nextID int
- debug bool
- showServerLogs bool
-}
-
-// stdioProcess reflects the state of a running command.
-type stdioProcess struct {
- stdin io.WriteCloser
- stdout io.ReadCloser
- cmd *exec.Cmd
- stderrBuf *bytes.Buffer
- isInitializeSent bool
-}
-
-// NewStdio creates a new Stdio transport that will execute the given command.
-// It communicates with the command using JSON-RPC over stdin/stdout.
-func NewStdio(command []string) *Stdio {
- debug := os.Getenv("MCP_DEBUG") == "1"
- return &Stdio{
- command: command,
- nextID: 1,
- debug: debug,
- }
-}
-
-// SetCloseAfterExecute toggles whether the underlying process should be closed
-// or kept alive after each call to Execute.
-func (t *Stdio) SetCloseAfterExecute(v bool) {
- if v {
- t.process = nil
- } else {
- t.process = &stdioProcess{}
- }
-}
-
-// SetShowServerLogs toggles whether to print server logs.
-func (t *Stdio) SetShowServerLogs(v bool) {
- t.showServerLogs = v
-}
-
-// Execute implements the Transport interface by spawning a subprocess
-// and communicating with it via JSON-RPC over stdin/stdout.
-func (t *Stdio) Execute(method string, params any) (map[string]any, error) {
- process := t.process
- if process == nil {
- process = &stdioProcess{}
- }
-
- if process.cmd == nil {
- var err error
- process.stdin, process.stdout, process.cmd, process.stderrBuf, err = t.setupCommand()
- if err != nil {
- return nil, err
- }
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Starting initialization\n")
- }
-
- if !process.isInitializeSent {
- if initErr := t.initialize(process.stdin, process.stdout); initErr != nil {
- t.printStderr(process)
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Initialization failed: %v\n", initErr)
- }
- return nil, initErr
- }
- t.printStderr(process)
- process.isInitializeSent = true
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Initialization successful, sending method request\n")
- }
-
- request := Request{
- JSONRPC: "2.0",
- Method: method,
- ID: t.nextID,
- Params: params,
- }
- t.nextID++
-
- if sendErr := t.sendRequest(process.stdin, request); sendErr != nil {
- return nil, sendErr
- }
-
- response, err := t.readResponse(process.stdout)
- t.printStderr(process)
- if err != nil {
- return nil, err
- }
- err = t.closeProcess(process)
- if err != nil {
- return nil, err
- }
-
- return response.Result, nil
-}
-
-// printStderr prints and clears any accumulated stderr output.
-func (t *Stdio) printStderr(process *stdioProcess) {
- if !t.showServerLogs {
- return
- }
- if process.stderrBuf.Len() > 0 {
- for _, line := range strings.SplitAfter(process.stderrBuf.String(), "\n") {
- line = strings.TrimSuffix(line, "\n")
- if line != "" {
- fmt.Fprintf(os.Stderr, "[>] %s\n", line)
- }
- }
- process.stderrBuf.Reset() // Clear the buffer after reading
- }
-}
-
-// closeProcess waits for the command to finish, returning any error.
-func (t *Stdio) closeProcess(process *stdioProcess) error {
- if t.process != nil {
- return nil
- }
-
- _ = process.stdin.Close()
-
- // Wait for the command to finish with a timeout to prevent zombie processes
- done := make(chan error, 1)
- go func() {
- done <- process.cmd.Wait()
- }()
-
- select {
- case waitErr := <-done:
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Command completed with err: %v\n", waitErr)
- }
-
- if waitErr != nil && process.stderrBuf.Len() > 0 {
- return fmt.Errorf("command error: %w", waitErr)
- }
- case <-time.After(1 * time.Second):
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Command timed out after 1 seconds\n")
- }
- // Kill the process if it times out
- _ = process.cmd.Process.Kill()
- }
-
- return nil
-}
-
-// setupCommand prepares and starts the command, returning the stdin/stdout pipes and any error.
-func (t *Stdio) setupCommand() (stdin io.WriteCloser, stdout io.ReadCloser, cmd *exec.Cmd, stderrBuf *bytes.Buffer, err error) {
- if len(t.command) == 0 {
- return nil, nil, nil, nil, fmt.Errorf("no command specified for stdio transport")
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Executing command: %v\n", t.command)
- }
-
- cmd = exec.Command(t.command[0], t.command[1:]...) // #nosec G204
-
- stdin, err = cmd.StdinPipe()
- if err != nil {
- return nil, nil, nil, nil, fmt.Errorf("error getting stdin pipe: %w", err)
- }
-
- stdout, err = cmd.StdoutPipe()
- if err != nil {
- return nil, nil, nil, nil, fmt.Errorf("error getting stdout pipe: %w", err)
- }
-
- stderrBuf = &bytes.Buffer{}
- cmd.Stderr = stderrBuf
-
- if err = cmd.Start(); err != nil {
- return nil, nil, nil, nil, fmt.Errorf("error starting command: %w", err)
- }
-
- return stdin, stdout, cmd, stderrBuf, nil
-}
-
-// initialize sends the initialization request and waits for response and then sends the initialized
-// notification.
-func (t *Stdio) initialize(stdin io.WriteCloser, stdout io.ReadCloser) error {
- // Create initialization request with current ID
- initRequestID := t.nextID
- initRequest := Request{
- JSONRPC: "2.0",
- Method: "initialize",
- ID: initRequestID,
- Params: map[string]any{
- "clientInfo": map[string]any{
- "name": "f/mcptools",
- "version": "beta",
- },
- "protocolVersion": protocolVersion,
- "capabilities": map[string]any{},
- },
- }
- t.nextID++
-
- if err := t.sendRequest(stdin, initRequest); err != nil {
- return fmt.Errorf("init request failed: %w", err)
- }
-
- // readResponse now properly checks for matching response ID
- _, err := t.readResponse(stdout)
- if err != nil {
- return fmt.Errorf("init response failed: %w", err)
- }
-
- // Send initialized notification (notifications don't have IDs)
- initNotification := Request{
- JSONRPC: "2.0",
- Method: "notifications/initialized",
- }
-
- if sendErr := t.sendRequest(stdin, initNotification); sendErr != nil {
- return fmt.Errorf("init notification failed: %w", sendErr)
- }
-
- return nil
-}
-
-// sendRequest sends a JSON-RPC request and returns the marshaled request.
-func (t *Stdio) sendRequest(stdin io.WriteCloser, request Request) error {
- requestJSON, err := json.Marshal(request)
- if err != nil {
- return fmt.Errorf("error marshaling request: %w", err)
- }
- requestJSON = append(requestJSON, '\n')
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Preparing to send request: %s\n", string(requestJSON))
- }
-
- writer := bufio.NewWriter(stdin)
- n, err := writer.Write(requestJSON)
- if err != nil {
- return fmt.Errorf("error writing bytes to stdin: %w", err)
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Wrote %d bytes\n", n)
- }
-
- if flushErr := writer.Flush(); flushErr != nil {
- return fmt.Errorf("error flushing bytes to stdin: %w", flushErr)
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Successfully flushed bytes\n")
- }
-
- return nil
-}
-
-// readResponse reads and parses a JSON-RPC response matching the given request ID.
-func (t *Stdio) readResponse(stdout io.ReadCloser) (*Response, error) {
- reader := bufio.NewReader(stdout)
-
- // Keep track of the expected response ID (the last request ID we sent)
- expectedID := t.nextID - 1
-
- for {
- line, err := reader.ReadBytes('\n')
- if err != nil {
- return nil, fmt.Errorf("error reading from stdout: %w", err)
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Read from stdout: %s", string(line))
- }
-
- if len(line) == 0 {
- return nil, fmt.Errorf("no response from command")
- }
-
- // First check if this is a notification (no ID field)
- var msg map[string]interface{}
- if err := json.Unmarshal(line, &msg); err != nil {
- return nil, fmt.Errorf("error unmarshaling message: %w, response: %s", err, string(line))
- }
-
- // If it's a notification, display it and continue reading
- if methodVal, hasMethod := msg["method"]; hasMethod && msg["id"] == nil {
- method, ok := methodVal.(string)
- if ok && method == "notifications/message" {
- if paramsVal, hasParams := msg["params"].(map[string]interface{}); hasParams {
- level, _ := paramsVal["level"].(string)
- data, _ := paramsVal["data"].(string)
-
- // Format and print the notification based on level
- switch level {
- case "error":
- fmt.Fprintf(os.Stderr, "\033[31m[ERROR] %s\033[0m\n", data) // Red
- case "warning":
- fmt.Fprintf(os.Stderr, "\033[33m[WARNING] %s\033[0m\n", data) // Yellow
- case "alert":
- fmt.Fprintf(os.Stderr, "\033[35m[ALERT] %s\033[0m\n", data) // Magenta
- case "info":
- fmt.Fprintf(os.Stderr, "\033[36m[INFO] %s\033[0m\n", data) // Cyan
- default:
- fmt.Fprintf(os.Stderr, "\033[37m[%s] %s\033[0m\n", level, data) // White for unknown levels
- }
- }
- } else {
- // For other notification types
- fmt.Fprintf(os.Stderr, "[Notification] %s\n", string(line))
- }
- continue
- }
-
- // Parse as a proper response
- var response Response
- if unmarshalErr := json.Unmarshal(line, &response); unmarshalErr != nil {
- return nil, fmt.Errorf("error unmarshaling response: %w, response: %s", unmarshalErr, string(line))
- }
-
- // If this response has an ID field and it matches our expected ID, or if it has an error, return it
- if response.ID == expectedID || response.Error != nil {
- if response.Error != nil {
- return nil, fmt.Errorf("RPC error %d: %s", response.Error.Code, response.Error.Message)
- }
-
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Successfully parsed response with matching ID: %d\n", response.ID)
- }
-
- return &response, nil
- }
-
- // Otherwise, this is a response for a different request
- if t.debug {
- fmt.Fprintf(os.Stderr, "DEBUG: Received response for request ID %d, expecting %d. Continuing to read.\n",
- response.ID, expectedID)
- }
- }
-}
diff --git a/pkg/transport/transport.go b/pkg/transport/transport.go
deleted file mode 100644
index b27b7a8..0000000
--- a/pkg/transport/transport.go
+++ /dev/null
@@ -1,48 +0,0 @@
-// Package transport contains implementatations for different transport options for MCP.
-package transport
-
-import (
- "encoding/json"
- "io"
-)
-
-const (
- protocolVersion = "2024-11-05"
-)
-
-// Transport defines the interface for communicating with MCP servers.
-// Implementations should handle the specifics of communication protocols.
-type Transport interface {
- Execute(method string, params any) (map[string]any, error)
-}
-
-// Request represents a JSON-RPC 2.0 request.
-type Request struct {
- Params any `json:"params,omitempty"`
- JSONRPC string `json:"jsonrpc"`
- Method string `json:"method"`
- ID int `json:"id,omitempty"`
-}
-
-// Response represents a JSON-RPC 2.0 response.
-type Response struct {
- Result map[string]any `json:"result,omitempty"`
- Error *Error `json:"error,omitempty"`
- JSONRPC string `json:"jsonrpc"`
- ID int `json:"id"`
-}
-
-// Error represents a JSON-RPC 2.0 error.
-type Error struct {
- Message string `json:"message"`
- Code int `json:"code"`
-}
-
-// ParseResponse reads and parses a JSON-RPC response from a reader.
-func ParseResponse(r io.Reader) (*Response, error) {
- var response Response
- if err := json.NewDecoder(r).Decode(&response); err != nil {
- return nil, err
- }
- return &response, nil
-}
Error
' +
err.message + '