index.js

import { Cluster } from "@nftstorage/ipfs-cluster";
import fs from "fs";
import path from "path";
import { dirname } from 'path';
import { fileURLToPath } from 'url';

const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);

// import { Blob } from "buffer";

import fetch from '@web-std/fetch'
import { FormData } from '@web-std/form-data'
import { File, Blob } from '@web-std/file'

Object.assign(global, { fetch, File, Blob, FormData })

import express from 'express';
var app = express();

let cluster = new Cluster("http://localhost:9094", {});

async function pinFolderToCluster(folderPath) {
    try {
        console.log(`Reading folder ${folderPath}`);
        const files = await fs.promises.readdir(folderPath)
        console.log(`DONE: -  Reading folder ${folderPath}`);
        console.log(`Reading files in ${folderPath}`);
        const input = files.filter(e => e != 'video.zip').map(file => {
            let buffer = fs.readFileSync(path.join(folderPath, file));
            let blob = new Blob([buffer]);
            blob.name = file;
            return blob;
        });
        console.log(`DONE: -  Reading files in ${folderPath}`);
        console.log(`Adding Directory using cluster`);
        const result = await cluster.addDirectory(input, {
            'replication-min': 1,
            replicationFactorMin: 1,
            'replication-max': 3,
            replicationFactorMax: 3,
            wrapWithDirectory: true
        })
        console.log(`DONE: - Adding Directory using cluster`);
        console.log(`Cluster response is - ${JSON.stringify(result)}`);
        var folderCid = result.filter(e => e.name === '')[0].cid;
        var thumbnailCid = result.filter(e => e.name.includes('thumbnail'))[0].cid;

        return {
            folderCid,
            thumbnailCid
        }
    } catch (e) {
        console.log(`ERROR: - ${e.toString()}`);
        console.error(e);
    }
}

var router = express.Router();

router.get('/', async (req, res) => {
    try {
        let extractPath = req.query.extractPath;
        if (extractPath === null || extractPath === undefined) {
            return res.json({ message: 'error - send extractPath query parameter' });
        }
        console.log(`extractPath is - ${extractPath}`);
        extractPath = extractPath.replaceAll('__', '/');
        console.log(`updated extractPath is - ${extractPath}`);
        let { folderCid, thumbnailCid } = await pinFolderToCluster(extractPath);
        console.log(`Folder CID is - ${folderCid}`);
        return res.json({ message: 'success', folderCid, thumbnailCid });
    } catch (e) {
        console.log(`ERROR: - ${e.toString()}`);
        console.error(e);
        return res.status(500).send({ error: `Error is ${e.toString()}` });
    }
});

app.use('/', router);

// Start the server
app.listen(13052, () => {
    console.log('Server is running on http://localhost:13052');
});