feat: reupload

src/bee.ts

@@ -272,6 +272,29 @@ export class Bee {
     return pinning.getPin(this.url, reference)
   }
 
+  /**
+   * Instructs the Bee node to reupload a locally pinned data into the network.
+   *
+   * @param reference
+   * @param axiosOptions
+   * @throws BeeArgumentError if the reference is not locally pinned
+   */
+  async reuploadPinnedData(reference: Reference | string, axiosOptions?: AxiosRequestConfig): Promise<void> {
+    assertReference(reference)
+
+    try {
+      // TODO: This should be detected by Bee, but until https://github.com/ethersphere/bee/issues/1803 is resolved
+      //  it is good idea to do some input validation on our side.
+      await this.getPin(reference)
+    } catch (e) {
+      if (e.status === 404) {
+        throw new BeeArgumentError('The passed reference is not locally pinned!', reference)
+      }
+    }
+
+    await bzz.reupload(this.url, reference, axiosOptions)
+  }
+
   /**
    * Send to recipient or target with Postal Service for Swarm
    *

src/modules/bzz.ts

@@ -182,3 +182,19 @@ export async function uploadCollection(
 
   return response.data.reference
 }
+
+/**
+ * Reupload locally pinned data
+ * @param url
+ * @param reference
+ * @param options
+ * @throws BeeResponseError if not locally pinned or invalid data
+ */
+export async function reupload(url: string, reference: Reference, options?: AxiosRequestConfig): Promise<void> {
+  await safeAxios({
+    ...options,
+    method: 'patch',
+    url: `${url}${bzzEndpoint}/${reference}/`,
+    responseType: 'json',
+  })
+}

test/integration/bee-class.spec.ts

@@ -191,6 +191,23 @@ describe('Bee class', () => {
     })
   })
 
+  describe('reupload', () => {
+    it('should reupload pinned data', async () => {
+      const content = randomByteArray(16, Date.now())
+
+      const hash = await bee.uploadData(await getPostageBatch(), content)
+      await bee.pin(hash)
+      await bee.reuploadPinnedData(hash) // Does not return anything, but will throw exception if something is going wrong
+    })
+
+    it('should throw error if data is not pinned', async () => {
+      const content = randomByteArray(16, Date.now())
+
+      const hash = await bee.uploadData(await getPostageBatch(), content)
+      await expect(bee.reuploadPinnedData(hash)).rejects.toThrowError(BeeArgumentError)
+    })
+  })
+
   describe('pss', () => {
     it(
       'should send and receive data',

test/integration/modules/bzz.spec.ts

@@ -210,6 +210,18 @@ describe('modules/bzz', () => {
       expect(file1.name).toEqual(fileName)
       expect(file1.data).toEqual(data)
     })
+
+    it('should reupload directory', async () => {
+      const directoryStructure: Collection<Uint8Array> = [
+        {
+          path: '0',
+          data: Uint8Array.from([0]),
+        },
+      ]
+
+      const hash = await bzz.uploadCollection(BEE_URL, directoryStructure, await getPostageBatch(), { pin: true })
+      await bzz.reupload(BEE_URL, hash) // Does not return anything, but will throw error if something is wrong
+    })
   })
 
   describe('file', () => {
@@ -279,5 +291,13 @@ describe('modules/bzz', () => {
       },
       BIG_FILE_TIMEOUT,
     )
+
+    it('should reupload file', async () => {
+      const data = 'hello world'
+      const filename = 'hello.txt'
+
+      const hash = await bzz.uploadFile(BEE_URL, data, await getPostageBatch(), filename, { pin: true })
+      await bzz.reupload(BEE_URL, hash) // Does not return anything, but will throw error if something is wrong
+    })
   })
 })