External/5chan
1
0
Fork 0
mirror of https://github.com/bitsocialnet/5chan.git synced 2026-08-03 07:41:04 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(electron): catch stream errors (e.g. ECONNRESET) in IPFS downloader and add retry logic

Browse Source
This commit is contained in:
Tom (plebeius.eth)
2025-05-13 15:42:40 +02:00
parent a5c60bccc7
commit 694b01b8e3
1 changed files with 25 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
electron/before-pack.js
+25 -3
View File
@@ -24,12 +24,20 @@ const ipfsClientMacUrl = `https://dist.ipfs.io/kubo/v${ipfsClientVersion}/kubo_v
const ipfsClientLinuxUrl = `https://dist.ipfs.io/kubo/v${ipfsClientVersion}/kubo_v${ipfsClientVersion}_linux-amd64.tar.gz`; const ipfsClientLinuxUrl = `https://dist.ipfs.io/kubo/v${ipfsClientVersion}/kubo_v${ipfsClientVersion}_linux-amd64.tar.gz`;
const downloadWithProgress = (url) => const downloadWithProgress = (url) =>
new Promise((resolve) => { new Promise((resolve, reject) => {
const split = url.split('/'); const split = url.split('/');
const fileName = split[split.length - 1]; const fileName = split[split.length - 1];
const chunks = []; const chunks = [];
const req = https.request(url); const req = https.request(url);
req.on('error', (err) => {
console.error(`Error making request for ${url}:`, err);
reject(err);
});
req.on('response', (res) => { req.on('response', (res) => {
res.on('error', (err) => {
console.error(`Error in response for ${url}:`, err);
reject(err);
});
// handle redirects // handle redirects
if (res.statusCode == 301 || res.statusCode === 302) { if (res.statusCode == 301 || res.statusCode === 302) {
resolve(downloadWithProgress(res.headers.location)); resolve(downloadWithProgress(res.headers.location));
@@ -57,6 +65,20 @@ const downloadWithProgress = (url) =>
req.end(); req.end();
}); });
// add retry wrapper around downloadWithProgress to handle transient network errors
const downloadWithRetry = async (url, retries = 3) => {
for (let attempt = 1; attempt <= retries; attempt++) {
try {
return await downloadWithProgress(url);
} catch (err) {
console.warn(`Download attempt ${attempt} for ${url} failed:`, err);
if (attempt === retries) throw err;
// wait before retrying
await new Promise((res) => setTimeout(res, attempt * 1000));
}
}
};
// plebbit kubo downloads dont need to be extracted // plebbit kubo downloads dont need to be extracted
const download = async (url, destinationPath) => { const download = async (url, destinationPath) => {
let binName = 'ipfs'; let binName = 'ipfs';
@@ -71,7 +93,7 @@ const download = async (url, destinationPath) => {
const split = url.split('/'); const split = url.split('/');
const fileName = split[split.length - 1]; const fileName = split[split.length - 1];
const dowloadPath = path.join(destinationPath, fileName); const dowloadPath = path.join(destinationPath, fileName);
const file = await downloadWithProgress(url); const file = await downloadWithRetry(url);
fs.ensureDirSync(destinationPath); fs.ensureDirSync(destinationPath);
await fs.writeFile(binPath, file); await fs.writeFile(binPath, file);
}; };
@@ -90,7 +112,7 @@ const downloadAndExtract = async (url, destinationPath) => {
const split = url.split('/'); const split = url.split('/');
const fileName = split[split.length - 1]; const fileName = split[split.length - 1];
const dowloadPath = path.join(destinationPath, fileName); const dowloadPath = path.join(destinationPath, fileName);
const file = await downloadWithProgress(url); const file = await downloadWithRetry(url);
fs.ensureDirSync(destinationPath); fs.ensureDirSync(destinationPath);
await fs.writeFile(dowloadPath, file); await fs.writeFile(dowloadPath, file);
console.log(`Downloaded archive to ${dowloadPath}`); console.log(`Downloaded archive to ${dowloadPath}`);