neptune/ghost-portal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Play nicer with pinata rate limits (#8995)

Browse Source 
* Play nicer with pinata rate limits

* Update

* Additional logging
This commit is contained in:
Jaco 2023-02-09 21:17:35 +02:00 committed by GitHub
parent 9d29a78fe2
commit 9d191f54a8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 41 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
scripts/ipfsUpload.mjs
View File

@ -22,6 +22,12 @@ const PINMETA = { name: DOMAIN };
const repo = `https://${process.env.GH_PAT}@github.com/${process.env.GITHUB_REPOSITORY}.git`;
async function wait (delay = 2500) {
return new Promise((resolve) => {
setTimeout(() => resolve(), delay);
});
}
function createPinata () {
try {
return pinataSDK(process.env.PINATA_API_KEY, process.env.PINATA_SECRET_KEY);
@ -98,6 +104,8 @@ async function pin () {
console.log(`Pinned ${result.IpfsHash}`);
await wait();
return result.IpfsHash;
}
@ -110,20 +118,27 @@ async function unpin (exclude) {
const result = await pinata.pinList({ metadata: PINMETA, status: 'pinned' });
await wait();
console.log('Available Pinata pins', result.rows);
if (result.count > 1) {
const filtered = result.rows
const hashes = result.rows
.map((r) => r.ipfs_pin_hash)
.filter((hash) => hash !== exclude);
if (filtered.length) {
await Promise.all(
filtered.map((hash) =>
pinata
.unpin(hash)
.then(() => console.log(`Unpinned ${hash}`))
.catch(console.error)
)
);
for (let i = 0; i < hashes.length; i++) {
const hash = hashes[i];
try {
await pinata.unpin(hash);
console.log(`Unpinned ${hash}`);
} catch (error) {
console.error(`Failed unpinning ${hash}`, error);
}
await wait();
}
}
}
@ -144,12 +159,22 @@ async function dnslink (hash) {
.join('.')
);
await Promise.all(records.map((record) =>
cloudflare(
{ token: process.env.CF_API_TOKEN },
{ link: `/ipfs/${hash}`, record, zone: DOMAIN }
)
));
for (let i = 0; i < records.length; i++) {
const record = records[i];
try {
await cloudflare(
{ token: process.env.CF_API_TOKEN },
{ link: `/ipfs/${hash}`, record, zone: DOMAIN }
);
console.log(`Updated dnslink ${record}`);
} catch (error) {
console.error(`Failed updating dnslink ${record}`, error);
}
await wait();
}
console.log(`Dnslink ${hash} for ${records.join(', ')}`);
}