feat: pod subscriptions

package.json

@@ -56,6 +56,7 @@
     "@ethersphere/bee-js": "^6.2.0",
     "@fairdatasociety/fdp-contracts-js": "^3.10.0",
     "crypto-js": "^4.2.0",
+    "elliptic": "^6.5.4",
     "ethers": "^5.5.2",
     "js-sha3": "^0.9.2"
   },

src/fdp-storage.ts

@@ -5,7 +5,7 @@ import { Connection } from './connection/connection'
 import { Options } from './types'
 import { Directory } from './directory/directory'
 import { File } from './file/file'
-import { ENS } from '@fairdatasociety/fdp-contracts-js'
+import { ENS, DataHub } from '@fairdatasociety/fdp-contracts-js'
 import { CacheInfo, DEFAULT_CACHE_OPTIONS } from './cache/types'
 
 export class FdpStorage {
@@ -15,6 +15,7 @@ export class FdpStorage {
   public readonly directory: Directory
   public readonly file: File
   public readonly ens: ENS
+  public readonly dataHub: DataHub
   public readonly cache: CacheInfo
 
   constructor(beeUrl: string, postageBatchId: BatchId, options?: Options) {
@@ -24,8 +25,9 @@ export class FdpStorage {
     }
     this.connection = new Connection(new Bee(beeUrl), postageBatchId, this.cache, options)
     this.ens = new ENS(options?.ensOptions, null, options?.ensDomain)
+    this.dataHub = new DataHub(options?.dataHubOptions, null, options?.ensDomain)
     this.account = new AccountData(this.connection, this.ens)
-    this.personalStorage = new PersonalStorage(this.account)
+    this.personalStorage = new PersonalStorage(this.account, this.ens, this.dataHub)
     this.directory = new Directory(this.account)
     this.file = new File(this.account)
   }

src/pod/personal-storage.ts

@@ -1,3 +1,4 @@
+import { ec as EC } from 'elliptic'
 import { SharedPod, PodReceiveOptions, PodShareInfo, PodsList, Pod, PodsListPrepared } from './types'
 import { assertAccount } from '../account/utils'
 import { writeFeedData } from '../feed/api'
@@ -15,21 +16,29 @@ import {
   podPreparedToPod,
   sharedPodPreparedToSharedPod,
   podListToJSON,
+  assertPodShareInfo,
 } from './utils'
 import { getExtendedPodsList } from './api'
 import { uploadBytes } from '../file/utils'
-import { stringToBytes } from '../utils/bytes'
+import { bytesToString, stringToBytes } from '../utils/bytes'
 import { Reference, Utils } from '@ethersphere/bee-js'
-import { assertEncryptedReference, EncryptedReference } from '../utils/hex'
+import { assertEncryptedReference, EncryptedReference, HexString } from '../utils/hex'
 import { prepareEthAddress, preparePrivateKey } from '../utils/wallet'
 import { getCacheKey, setEpochCache } from '../cache/utils'
 import { getPodsList } from './cache/api'
 import { getNextEpoch } from '../feed/lookup/utils'
+import { DataHub, ENS, ENS_DOMAIN, Subscription } from '@fairdatasociety/fdp-contracts-js'
+import { decryptBytes } from '../utils/encryption'
+import { namehash } from 'ethers/lib/utils'
 
 export const POD_TOPIC = 'Pods'
 
 export class PersonalStorage {
-  constructor(private accountData: AccountData) {}
+  constructor(
+    private accountData: AccountData,
+    private ens: ENS,
+    private dataHub: DataHub,
+  ) {}
 
   /**
    * Gets the list of pods for the active account
@@ -198,4 +207,41 @@ export class PersonalStorage {
 
     return sharedPodPreparedToSharedPod(pod)
   }
+
+  async getSubscriptions(ens: string): Promise<Subscription[]> {
+    const subItems = await this.dataHub.getAllSubItemsForNameHash(namehash(`${ens}.${ENS_DOMAIN}`))
+
+    const subscriptions: Subscription[] = []
+
+    for (let i = 0; i < subItems.length; i++) {
+      const sub = await this.dataHub.getSubBy(subItems[i].subHash)
+
+      subscriptions.push(sub)
+    }
+
+    return subscriptions
+  }
+
+  async openSubscribedPod(subHash: HexString, swarmLocation: HexString): Promise<unknown> {
+    const sub = await this.dataHub.getSubBy(subHash)
+
+    const publicKeyHex = await this.ens.getPublicKeyByUsernameHash(sub.fdpSellerNameHash)
+
+    const wallet = this.accountData.wallet!
+
+    const ec = new EC('secp256k1')
+
+    const privateKey = ec.keyFromPrivate(wallet.privateKey)
+    const publicKey = ec.keyFromPublic(publicKeyHex.substring(2), 'hex')
+
+    const secret = privateKey.derive(publicKey.getPublic()).toString(16)
+
+    const encryptedData = await this.accountData.connection.bee.downloadData(swarmLocation)
+
+    const data = JSON.parse(bytesToString(decryptBytes(secret, encryptedData)))
+
+    assertPodShareInfo(data)
+
+    return data
+  }
 }

src/types.ts

@@ -1,5 +1,5 @@
 import { BeeRequestOptions } from '@ethersphere/bee-js'
-import { EnsEnvironment } from '@fairdatasociety/fdp-contracts-js'
+import { DataHubEnvironment, EnsEnvironment } from '@fairdatasociety/fdp-contracts-js'
 import { CacheOptions } from './cache/types'
 
 export { DirectoryItem, FileItem } from './content-items/types'
@@ -42,6 +42,10 @@ export interface Options {
    * FDP-contracts options
    */
   ensOptions?: EnsEnvironment
+  /**
+   * FDP-contracts options
+   */
+  dataHubOptions?: DataHubEnvironment
   /**
    * ENS domain for usernames
    */