带回退并发机制的ipfs重定向
This commit is contained in:
BlueSkyXN 2024-09-17 12:04:13 +08:00
parent c771186ece
commit 8d88a6c144

View File

@ -1,28 +1,87 @@
// ==UserScript== // ==UserScript==
// @name Custom IPFS Link Redirector // @name IPFS Gateway Redirector with Fallback and Retry
// @namespace http://tampermonkey.net/ // @namespace http://tampermonkey.net/
// @version 0.2 // @version 0.3
// @description Redirects IPFS links to a custom IPFS gateway // @description Redirects IPFS links to multiple fallback IPFS gateways with concurrent requests and retry mechanism
// @author BlueSkyXN // @author BlueSkyXN
// @match *://*/* // @match *://*/*
// @grant none // @grant none
// @run-at document-end // @run-at document-end
// @updateURL https://raw.githubusercontent.com/BlueSkyXN/WorkerJS_CloudFlare_ImageBed/main/UserScript/ipfs-fix.js
// @downloadURL https://raw.githubusercontent.com/BlueSkyXN/WorkerJS_CloudFlare_ImageBed/main/UserScript/ipfs-fix.js
// ==/UserScript== // ==/UserScript==
(function() { (function() {
'use strict'; 'use strict';
// 自定义 IPFS 网关地址 // 定义多个 IPFS 网关,按优先级排列
var customIpfsGateway = "https://gateway.pinata.cloud/ipfs/"; var 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/"
];
// 匹配 IPFS 链接的正则表达式 // 匹配 IPFS 链接的正则表达式
var ipfsRegex = /\/ipfs\/(Qm\w+)/; var ipfsRegex = /\/ipfs\/(Qm\w+|baf\w+)/;
// 处理所有的图片链接 // 处理所有的图片链接
var imgs = document.querySelectorAll('img'); var imgs = document.querySelectorAll('img');
// 自定义并发请求的网关数量
var concurrentRequests = 2;
// 创建一个请求函数,返回一个 Promise
function fetchFromGateway(gateway, hash) {
return new Promise((resolve, reject) => {
let img = new Image();
img.src = gateway + hash;
// 成功加载图片时解析 Promise
img.onload = () => {
resolve(gateway + hash);
};
// 图片加载失败时拒绝 Promise
img.onerror = () => {
reject("Failed to load from: " + gateway);
};
});
}
// 逐步按组并发请求网关
async function tryIpfsGatewaysSequentially(img, hash, gateways) {
let remainingGateways = gateways.slice(); // 复制网关列表
let originalSrc = img.src; // 保存原始 URL
while (remainingGateways.length > 0) {
// 取出一组并发网关
let gatewaysToTry = remainingGateways.splice(0, concurrentRequests);
try {
// 并发请求多个网关,并返回第一个成功的
let successfulUrl = await Promise.race(gatewaysToTry.map(gateway => fetchFromGateway(gateway, hash)));
img.src = successfulUrl; // 设置为第一个成功的 URL
console.log("Successfully loaded from:", successfulUrl);
return; // 请求成功则停止
} catch (error) {
console.error(error); // 记录错误
}
}
// 如果所有网关都失败了,再次尝试一次所有网关
try {
let successfulUrl = await Promise.race(gateways.map(gateway => fetchFromGateway(gateway, hash)));
img.src = successfulUrl; // 设置为成功的 URL
console.log("Second attempt successfully loaded from:", successfulUrl);
} catch (error) {
console.error("All gateways failed in second attempt. Returning to original URL.");
img.src = originalSrc; // 所有都失败后恢复原始 URL
}
}
// 遍历每个图片链接
for (var i = 0; i < imgs.length; i++) { for (var i = 0; i < imgs.length; i++) {
var imgSrc = imgs[i].src; var imgSrc = imgs[i].src;
@ -30,8 +89,7 @@
var match = imgSrc.match(ipfsRegex); var match = imgSrc.match(ipfsRegex);
if (match) { if (match) {
var ipfsHash = match[1]; // 提取IPFS哈希值 var ipfsHash = match[1]; // 提取IPFS哈希值
imgs[i].src = customIpfsGateway + ipfsHash; // 替换为自定义网关链接 tryIpfsGatewaysSequentially(imgs[i], ipfsHash, ipfsGateways); // 尝试按组并发请求网关
console.log("Redirecting IPFS link to custom gateway:", imgs[i].src);
} }
} }