Exécuter une commande à distance (SSH)

Instructions

Implementation Reference

• server.js:437-450 (handler)

  Handler function that queues an SSH execution job using queue.addJob, logs it, executes via ssh.executeCommand, polls for completion with waitForJobCompletion, and returns synchronous result or background initiation message.

      async (params) => {
          const job = queue.addJob({ type: 'ssh', ...params, status: 'pending' });
          history.logTask(job);
          ssh.executeCommand(job.id);
  
          const finalJob = await waitForJobCompletion(job.id, config.syncTimeout);
          if (finalJob) {
              return { content: [{ type: "text", text: `Résultat direct (tâche ${finalJob.id}):
  ${finalJob.output || JSON.stringify(finalJob, null, 2)}` }] };
          } else {
              return { content: [{ type: "text", text: `Tâche d'exécution ${job.id} initiée en arrière-plan.` }] };
          }
      }
  );

• server.js:428-436 (schema)

  Tool metadata including title, description, and Zod inputSchema defining parameters: alias (server alias), cmd (command to execute), optional rappel (reminder in seconds).

  {
      title: "Exécuter une commande à distance (SSH)",
                  description: `Exécute une commande SSH. Si la tâche prend moins de ${config.syncTimeout / 1000}s, le résultat est direct. Sinon, elle passe en arrière-plan.`, 
                  inputSchema: z.object({
                      alias: z.string().describe("Alias du serveur cible."),
                  cmd: z.string().describe("La commande complète à exécuter."),
                  rappel: z.number().optional().describe("Définit un rappel en secondes.")
                  })
  },

• server.js:427-450 (registration)

  MCP server registration of the 'task_exec' tool, including schema and inline handler implementation.

      "task_exec",
      {
          title: "Exécuter une commande à distance (SSH)",
                      description: `Exécute une commande SSH. Si la tâche prend moins de ${config.syncTimeout / 1000}s, le résultat est direct. Sinon, elle passe en arrière-plan.`, 
                      inputSchema: z.object({
                          alias: z.string().describe("Alias du serveur cible."),
                      cmd: z.string().describe("La commande complète à exécuter."),
                      rappel: z.number().optional().describe("Définit un rappel en secondes.")
                      })
      },
      async (params) => {
          const job = queue.addJob({ type: 'ssh', ...params, status: 'pending' });
          history.logTask(job);
          ssh.executeCommand(job.id);
  
          const finalJob = await waitForJobCompletion(job.id, config.syncTimeout);
          if (finalJob) {
              return { content: [{ type: "text", text: `Résultat direct (tâche ${finalJob.id}):
  ${finalJob.output || JSON.stringify(finalJob, null, 2)}` }] };
          } else {
              return { content: [{ type: "text", text: `Tâche d'exécution ${job.id} initiée en arrière-plan.` }] };
          }
      }
  );

• server.js:381-395 (helper)

  Helper function used by task_exec (and other tools) to asynchronously wait for job completion with polling and timeout.

  async function waitForJobCompletion(jobId, timeout) {
      return new Promise((resolve) => {
          const startTime = Date.now();
          const interval = setInterval(() => {
              const job = queue.getJob(jobId);
              if (job.status === 'completed' || job.status === 'failed') {
                  clearInterval(interval);
                  resolve(job);
              } else if (Date.now() - startTime > timeout) {
                  clearInterval(interval);
                  resolve(null);
              }
          }, 200);
      });
  }