ai-node-canvas 0.84.0: a stopped call says where the limit is, and the MCP server gets a minute

A call the Host stops is stopped by the Host, not by us. The connector API
takes a signal and nothing else, and a picture is asked for in one
synchronous call - there is no task to poll, the way a video has one. The
message on the card now says where that limit is (about thirty seconds, and
it is the Host's), and what the user can still change: a smaller request.
A video is submitted and polled, which is why the same limit reads as a
mystery for a picture and not for a video.

The MCP server is given a minute to answer instead of half of one. A call
that starts a run hands the work to the page and waits for the page's
answer, and a page that is busy must not turn the call into a failure.

248 tests, 248 mutations, 0 errors.

Author: antianqi

plugins/antianqi/ai-node-canvas/.minimax-plugin/plugin.json

@@ -2,7 +2,7 @@
   "schemaVersion": 1,
   "name": "ai-node-canvas",
   "displayName": "节点画布",
-  "version": "0.83.0",
+  "version": "0.84.0",
   "description": "无限画布节点编排：把 MiniMax 模型生成的文本、图片、视频串成工作流，连线即数据流，上游产物可直接被下游引用。",
   "author": "antianqi",
   "icon": "icon.png",

plugins/antianqi/ai-node-canvas/miniapp/node/connector-runner.mjs

@@ -32,6 +32,41 @@ const TOOL = {
   assetUrl: 'get_asset_url',
 };
 
+/**
+ * What a connector call that the Host stopped says.
+ *
+ * The Host gives every connector call a window of its own — about thirty
+ * seconds — and a call that runs longer is stopped. That window is the Host's
+ * and not ours to widen, so the message has to say that it is there, and what
+ * the user can do about it.
+ *
+ * A picture is asked for in one synchronous call: there is no task number to
+ * poll, so a picture that takes too long is simply lost. The way out is a
+ * smaller request. A video is submitted and polled, which is why it can run
+ * for a quarter of an hour — and that difference is worth saying out loud,
+ * because the same limit reads as a mystery otherwise.
+ *
+ * @param {string} suffix the tool that was called
+ * @param {string} code the Host's error code
+ * @returns {string|null} the note, or null when the failure is not a stop
+ */
+export function connectorStopNote(suffix, code) {
+  const isImage = suffix === TOOL.image;
+  if (code === 'CONNECTOR_OUTCOME_UNKNOWN') {
+    return '调用已经发出但没收到回执，结果未知（可能已经扣费）；宿主对单次连接器调用有约 30 秒的超时上限，这个上限在宿主那边，画布改不了。'
+      + (isImage
+        ? '出图是一次调用直接出结果，没有可轮询的任务号，所以只能把请求变小：把清晰度降到 1K、少给几张参考图，再点一次生成。'
+        : '');
+  }
+  if (code === 'CONNECTOR_TIMEOUT') {
+    return '这次调用超过了宿主的超时上限（约 30 秒）被中止；结果未知（可能已经扣费），先核对业务状态再决定要不要重试。'
+      + (isImage
+        ? '出图是一次调用直接出结果，没有可轮询的任务号，所以只能把请求变小：把清晰度降到 1K、少给几张参考图，再点一次生成。'
+        : '');
+  }
+  return null;
+}
+
 // The provider takes media URLs, never local paths or data URIs.
 //
 // The link comes under a few names, and the video task answers with its own:
@@ -215,11 +250,7 @@ export function createConnectorRunner(context, options = {}) {
         // The time shown is the call's own time. The time it spent waiting for
         // the machine is said separately, because that is the difference
         // between "the provider was slow" and "it stood behind another call".
-        const note = error?.code === 'CONNECTOR_OUTCOME_UNKNOWN'
-          ? '调用已经发出但没收到回执，结果未知（可能已经扣费）；宿主对连接器调用有超时上限，太慢的调用会被中止。'
-          : error?.code === 'CONNECTOR_TIMEOUT'
-            ? '这次调用超过了宿主的时限（默认 30 秒）被中止；结果未知，先核对业务状态再决定要不要重试。'
-            : String(error?.message ?? error);
+        const note = connectorStopNote(suffix, error?.code) ?? String(error?.message ?? error);
         throw Object.assign(
           new Error(`调用 ${suffix} 失败（耗时 ${(callMs / 1000).toFixed(1)}s${queueNote(waitedMs)}）：${note}`),
           { code: error?.code ?? 'CONNECTOR_ERROR' },

plugins/antianqi/ai-node-canvas/package.json

@@ -1,6 +1,6 @@
 {
   "name": "ai-node-canvas",
-  "version": "0.83.0",
+  "version": "0.84.0",
   "private": true,
   "description": "Node-graph canvas MiniApp for MiniMax Code: wire MiniMax model runs into a visual workflow.",
   "mcode": {

plugins/antianqi/ai-node-canvas/servers.mcp.json

@@ -6,7 +6,7 @@
       "url": "http://127.0.0.1:9/mcp/canvas",
       "headers": {},
       "description": "节点画布的托管 MCP：读画布（canvas_list / canvas_read），也在画布上加节点、连线、改节点、删节点、发起运行（canvas_add_node / canvas_connect / canvas_update_node / canvas_remove_node / canvas_run），还有现成的工作流模板（canvas_list_templates / canvas_apply_template）。写操作改的是用户画布上看得见的东西；canvas_remove_node 删掉的节点没法恢复；canvas_run 会真的发起一次生成、花掉用户自己的额度（视频可能跑十几分钟，但这次调用很快就会返回「已经开始」，结果用 canvas_read 看）；canvas_apply_template 只把模板的骨架铺到画布上（节点、连线、提示词、参数），它自己不跑、不花钱，要跑得再调 canvas_run。",
-      "timeout": 30000
+      "timeout": 60000
     }
   }
 }

plugins/antianqi/ai-node-canvas/tests/smoke.test.mjs

@@ -8767,3 +8767,30 @@ test('the README says that a deleted template is gone for good', async () => {
   assert.match(en, /cannot be undone/, '英文 README 要写明删掉找不回来');
   assert.match(zh, /找不回来/, '中文 README 要写明删掉找不回来');
 });
+
+test('a call the Host stopped says where the limit is, and what to do', async () => {
+  // The Host gives every connector call a window of its own, and a picture is
+  // asked for in one call — there is no task to poll, so a picture that takes
+  // too long is lost. The message has to say where that limit is, and what the
+  // user can still change.
+  const { connectorStopNote } = await import('../miniapp/node/connector-runner.mjs');
+  const image = connectorStopNote('generate_image', 'CONNECTOR_OUTCOME_UNKNOWN');
+  assert.match(image, /30 秒/, '要说出这个窗口有多长');
+  assert.match(image, /宿主/, '要说出这个上限在宿主那边');
+  assert.match(image, /1K/, '出图要给出马上能用的办法');
+  // A call that was not stopped is not one of these.
+  assert.equal(connectorStopNote('generate_image', 'CONNECTOR_PROVIDER_ERROR'), null);
+  // A video is submitted and polled, so it does not need a smaller request.
+  const video = connectorStopNote('submit_video_generation', 'CONNECTOR_TIMEOUT');
+  assert.match(video, /30 秒/);
+  assert.equal(/1K/.test(video), false, '视频不是一次调用出结果，不用教人降清晰度');
+});
+
+test('the MCP server is given a minute', async () => {
+  // The Host waits this long for the MCP server to answer. A call that starts
+  // a run has to hand the work to the page and wait for the page's answer, so
+  // the window is a minute: a page that is busy must not turn the call into a
+  // failure.
+  const raw = await readFile(fileURLToPath(new URL('../servers.mcp.json', import.meta.url)), 'utf8');
+  assert.equal(JSON.parse(raw).mcpServers.canvas.timeout, 60000);
+});