From 2a6525fd8631e5d816108d3ff7e3c97f08e79995 Mon Sep 17 00:00:00 2001
From: BlueSkyXN <63384277+BlueSkyXN@users.noreply.github.com>
Date: Tue, 17 Sep 2024 12:21:31 +0800
Subject: [PATCH] 0.9.3
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

IPFS保活-CFJS版本
---
 .../ipfs-multi-gateway-fetcher.js             | 80 +++++++++++++++++++
 1 file changed, 80 insertions(+)
 create mode 100644 cloudflare-worker-js/ipfs-multi-gateway-fetcher.js

diff --git a/cloudflare-worker-js/ipfs-multi-gateway-fetcher.js b/cloudflare-worker-js/ipfs-multi-gateway-fetcher.js
new file mode 100644
index 0000000..22c7f48
--- /dev/null
+++ b/cloudflare-worker-js/ipfs-multi-gateway-fetcher.js
@@ -0,0 +1,80 @@
+addEventListener("fetch", event => {
+    event.respondWith(handleRequest(event.request));
+});
+
+const ipfsGateways = [
+    "https://gateway.pinata.cloud/ipfs/",
+    "https://eth.sucks/ipfs/",
+    "https://hardbin.com/ipfs/",
+    "https://ipfs.raribleuserdata.com/ipfs/",
+    "https://ipfs.crossbell.io/ipfs/",
+    "https://ipfs.basedfellas.io/ipfs/",
+    "https://ipfs.io/ipfs/"
+];
+
+/**
+ * 处理传入请求
+ * @param {Request} request
+ */
+async function handleRequest(request) {
+    // 从 URL 提取 IPFS hash
+    const url = new URL(request.url);
+    const ipfsHash = url.pathname.replace("/", ""); // 提取 URL 路径中的 IPFS hash
+    if (!ipfsHash) {
+        return new Response("IPFS hash is missing.", { status: 400 });
+    }
+
+    // 生成并发请求
+    const gatewayPromises = ipfsGateways.map(gateway => fetchGateway(gateway, ipfsHash));
+
+    // 并发所有请求，返回最早的结果
+    const results = await Promise.all(gatewayPromises);
+
+    // 构造响应，返回请求结果
+    const responseBody = JSON.stringify(results, null, 2);
+    return new Response(responseBody, {
+        headers: { "Content-Type": "application/json" },
+    });
+}
+
+/**
+ * 向指定 IPFS 网关发起请求，并返回状态信息
+ * @param {string} gateway
+ * @param {string} hash
+ */
+async function fetchGateway(gateway, hash) {
+    const url = gateway + hash;
+    const startTime = Date.now();
+
+    try {
+        // 首先尝试使用 HEAD 请求
+        let response = await fetch(url, { method: "HEAD" });
+        const elapsedTime = Date.now() - startTime;
+        return {
+            gateway: url,
+            status: response.status,
+            time: `${elapsedTime}ms`,
+            method: "HEAD"
+        };
+    } catch (error) {
+        // 如果 HEAD 请求失败，使用 GET 请求进行回退
+        try {
+            let response = await fetch(url, { method: "GET", headers: { "Range": "bytes=0-0" } }); // 仅请求文件的前1个字节
+            const elapsedTime = Date.now() - startTime;
+            return {
+                gateway: url,
+                status: response.status,
+                time: `${elapsedTime}ms`,
+                method: "GET with Range"
+            };
+        } catch (getError) {
+            const elapsedTime = Date.now() - startTime;
+            return {
+                gateway: url,
+                status: "Failed",
+                time: `${elapsedTime}ms`,
+                error: getError.toString()
+            };
+        }
+    }
+}