IPFS fail notify (#7)

* return 404 if ipfs share failed
clear autoipfs opts if share/unshare fails

* bump to 0.3.2

Author: ikreymer

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@webrecorder/awp-sw",
   "browser": "dist/sw.js",
-  "version": "0.3.1",
+  "version": "0.3.2",
   "main": "index.js",
   "type": "module",
   "repository": {

src/api.js

@@ -134,6 +134,12 @@ class ExtAPI extends API
       event.waitUntil(p);
     }
 
+    try {
+      await p;
+    } catch (e) {
+      return {error: "ipfs_not_available"};
+    }
+
     return {collId};
   }
 

src/ipfsutils.js

@@ -89,9 +89,13 @@ export async function ipfsAdd(coll, downloaderOpts = {}, replayOpts = {}, progre
 
   let url, cid;
 
+  let reject = null;
+
+  const p2 = new Promise((res, rej) => reject = rej);
+
   const p = readable
     .pipeThrough(new ShardingStream(shardSize))
-    .pipeThrough(new ShardStoringStream(autoipfs, concur))
+    .pipeThrough(new ShardStoringStream(autoipfs, concur, reject))
     .pipeTo(
       new WritableStream({
         write: (res) => {
@@ -113,7 +117,7 @@ export async function ipfsAdd(coll, downloaderOpts = {}, replayOpts = {}, progre
     downloaderOpts.markers, favicon,
   );
 
-  await p;
+  await Promise.race([p, p2]);
 
   const res = {cid: cid.toString(), url};
 
@@ -135,7 +139,9 @@ export async function ipfsRemove(coll) {
       try {
         await autoipfs.clear(url);
       } catch (e) {
-        console.log("Removal from this IPFS backend not yet implemented");
+        console.log("Failed to unpin");
+        autoipfsOpts.daemonURL = null;
+        return false;
       }
     }
 
@@ -493,7 +499,7 @@ export class ShardingStream extends TransformStream {
  * @extends {TransformStream<import('./types').CARFile, import('./types').CARMetadata>}
  */
 export class ShardStoringStream extends TransformStream {
-  constructor(autoipfs, concurrency) {
+  constructor(autoipfs, concurrency, reject) {
     const queue = new Queue({ concurrency });
     const abortController = new AbortController();
     super({
@@ -513,6 +519,8 @@ export class ShardStoringStream extends TransformStream {
             } catch (err) {
               controller.error(err);
               abortController.abort(err);
+              autoipfsOpts.daemonURL = null;
+              reject(err);
             }
           },
           { signal: abortController.signal }