Update index.js

index.js

@@ -38,8 +38,7 @@ const isipok = async (ip) => {
     return { ip, status: true, region: rg };
 }
 
-const testAll = async (startIP, endIP) => {
-    const results = [];
+const testAll = async (startIP, endIP, res) => {
     const [startI, startI0, startI1, startI2] = startIP.split('.').map(Number);
     const [endI, endI0, endI1, endI2] = endIP.split('.').map(Number);
 
@@ -66,7 +65,7 @@ const testAll = async (startIP, endIP) => {
         try {
             const result = await isipok(XForwardedForIP);
             if (result.status) {
-                results.push([result.ip, result.region]);
+                res.write(JSON.stringify([result.ip, result.region]) + ",\n");
             }
         } catch (error) {
             console.error(error);
@@ -76,6 +75,7 @@ const testAll = async (startIP, endIP) => {
 
     let count = 0;
     let stop = false;
+    res.write("[\n"); // Start of the array
     while (true) {
         while (count >= 16) {
             await new Promise((t) => { setTimeout(t, 100) });
@@ -91,13 +91,14 @@ const testAll = async (startIP, endIP) => {
             break;
         }
     }
-    return results;
+    res.write("];\n"); // End of the array
+    res.end();
 }
 
 app.post("/test", async (req, res) => {
     const { startIP, endIP } = req.body;
-    const results = await testAll(startIP, endIP);
-    res.json(results);
+    res.setHeader('Content-Type', 'text/plain');
+    await testAll(startIP, endIP, res);
 });
 
 app.get("/", (req, res) => {
@@ -123,7 +124,6 @@ app.get("/", (req, res) => {
             <textarea id="results" rows="10" cols="50"></textarea>
             <br>
             <button id="copyButton">复制</button>
-
             <script>
                 document.getElementById('ipForm').addEventListener('submit', async (event) => {
                     event.preventDefault();
@@ -136,10 +136,16 @@ app.get("/", (req, res) => {
                         },
                         body: JSON.stringify({ startIP, endIP })
                     });
-                    const results = await response.json();
-                    document.getElementById('results').value = JSON.stringify(results, null, 0);
+                    const reader = response.body.getReader();
+                    const decoder = new TextDecoder();
+                    let results = '';
+                    while (true) {
+                        const { done, value } = await reader.read();
+                        if (done) break;
+                        results += decoder.decode(value);
+                        document.getElementById('results').value = results;
+                    }
                 });
-
                 document.getElementById('copyButton').addEventListener('click', () => {
                     const results = document.getElementById('results');
                     results.select();
@@ -153,4 +159,4 @@ app.get("/", (req, res) => {
 
 app.listen(port, () => {
     console.log(`Server is running at http://localhost:${port}`);
-});
+});