ipfsSaveState.js

const { ipfs } = require("./index");

exports.ipfsSaveState = (blocknum, buffer, ipfsc, tries) => {
    return new Promise((resolve, reject) => {
        if(tries)console.log('Retry IPFS Save:', tries)
        ipfs.add(buffer, (err, ipfs_return) => {
            if (!err) {
                var hash = '';
                try {
                    hash = ipfs_return[0].hash;
                } catch (e) { console.log(e); }
                console.log(blocknum + `:Saved: ${hash}`);
                resolve({
                    hashLastIBlock: hash,
                    hashBlock: blocknum
                })
            } else {
                reject(err)
                    /*
                    cycleipfs(cycle++)
                    if (cycle >= 25) {
                        cycle = 0;
                        return;
                    }
                    */
            }
        })
    })
}

exports.ipfsPeerConnect = (peerid) => {
    return new Promise((resolve, reject) => {
        //ipfs.swarm.addrs().then((addrs) => {console.log(addrs)})
        ipfs.swarm.connect(`/p2p/${peerid}`, (err, res) => {
            if(res)resolve(res.Strings[0])
            if(err){
                resolve(`Failed to connect to${peerid}`)
            }
        })
    })
}