add support for multiple requests

Author: jackkav

packages/insomnia/src/main/api-process.mjs

@@ -5,13 +5,22 @@ import fs from 'node:fs';
 import express from 'express';
 
 const app = express();
-app.use(express.text()); // if you want raw text body
-// app.use(express.json());     // use this instead if sending JSON
+app.use(express.json()); // use this instead if sending JSON
+app.use(express.text({ type: 'text/plain' }));
 
 app.post('/upload', (req, res) => {
-  const content = req.body; // the raw POST body
-  process.parentPort.postMessage({ body: content });
+  const content = req.body;
+  if (!content) {
+    res.status(400).send('No content received');
+    return;
+  }
+  process.parentPort.postMessage({ curlRequests: [content] });
   res.send('Received: ' + content);
 });
 
+app.post('/upload-array', (req, res) => {
+  const content = req.body;
+  res.send('Received: ' + JSON.stringify(content));
+  process.parentPort.postMessage({ curlRequests: content.list });
+});
 app.listen(8080, () => console.log('Server running on http://localhost:8080'));

packages/insomnia/src/main/ipc/main.ts

@@ -231,22 +231,29 @@ export function registerMainHandlers() {
   });
   apiProcess.on('message', async msg => {
     console.log('[api-process] received message:', msg);
-    const resources = await convert(msg.body);
-    console.log('[api-process] converted to resources:', resources);
-    if (resources && !('convertErrorMessage' in resources) && resources.length > 0) {
-      const req = resources[0] as unknown as Partial<Request>;
-      let url = '';
-      for (const window of BrowserWindow.getAllWindows()) {
-        url = window.webContents.getURL();
+    if (!msg.curlRequests || !Array.isArray(msg.curlRequests)) {
+      console.warn('[api-process] invalid message format, missing curlRequests array');
+      return;
+    }
+    for (const request of msg.curlRequests) {
+      const resources = await convert(request);
+      console.log('[api-process] converted to resources:', resources);
+      if (resources && !('convertErrorMessage' in resources) && resources.length > 0) {
+        const req = resources[0] as unknown as Partial<Request>;
+        let url = '';
+        for (const window of BrowserWindow.getAllWindows()) {
+          url = window.webContents.getURL();
+        }
+
+        const workspaceId = url.match(/wrk_[a-zA-Z0-9]+/)?.[0];
+        console.log('[api-process] got workspace:', workspaceId);
+        await models.request.create({
+          ...req,
+          _id: undefined,
+          name: req.url,
+          parentId: workspaceId || 'wrk_scratchpad',
+        });
       }
-      const workspaceId = url.match(/wrk_[a-zA-Z0-9]+/)?.[0];
-      console.log('[api-process] got workspace:', workspaceId);
-      await models.request.create({
-        ...req,
-        _id: undefined,
-        name: req.url,
-        parentId: workspaceId || 'wrk_scratchpad',
-      });
       for (const window of BrowserWindow.getAllWindows()) {
         window.webContents.send('reload-from-mcp');
       }