chore(read): add read endpoint

sadoprotocol · Jun 13, 2023 · 286a84b · 286a84b
1 parent 63c077d
commit 286a84b
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/modules/ipfs.js b/modules/ipfs.js
@@ -9,6 +9,7 @@ const ipfsConfig = {
 };
 
 exports.create = create;
+exports.get = get;
 exports.resolve = resolve;
 exports.publish = publish;
 exports.pin = pin;
@@ -33,6 +34,10 @@ async function create(content) {
   return data;
 }
 
+async function get(addr) {
+  return getContent(ipfsConfig.gateway + '/ipfs/' + addr)
+}
+
 async function pin(addr) {
   if (!addr.includes('ipfs')) {
     addr = '/ipfs/' + addr;

diff --git a/routes/index.js b/routes/index.js
@@ -84,6 +84,19 @@ router.post("/upload", upload.single("file"), async function (req, res, next) {
   }
 });
 
+router.get("/:cid", async function (req, res, next) {
+  const file = await ipfsModel.findOne({ path: req.params.cid });
+  if (file === undefined) {
+    return next(createError(404, 'File not found.'));
+  }
+  const content = await ipfs.get(file.path);
+  if (content === undefined) {
+    return next(createError(500, 'Unable to fetch file from IPFS.'));
+  }
+  res.set('Content-Type', file.type);
+  res.status(200).send(Buffer.from(content, 'base64'));
+});
+
 async function handleIpfs(bitmap, options) {
   let uploaded = await ipfs.create(bitmap);