feat: additional datahub functions

README.md

@@ -335,6 +335,24 @@ const fdpCache = new FdpStorage('https://localhost:1633', batchId, {
 fdpCache.cache.object = JSON.parse(cache)
 ```
 
+There are available function for interacting with DataHub contract. For example to list all available subscriptions:
+
+```js
+const subs = await fdp.personalStorage.getAllSubscriptions()
+```
+
+To get user's subscriptions:
+
+```js
+const subItems = await fdp.personalStorage.getAllSubItems()
+```
+
+And to get pod information of a subItem:
+
+```js
+const podShareInfo = await fdp.personalStorage.openSubscribedPod(subItems[0].subHash, subItems[0].unlockKeyLocation)
+```
+
 ## Documentation
 
 You can generate API docs locally with:

src/pod/personal-storage.ts

@@ -26,9 +26,18 @@ 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, SubItem, Subscription } from '@fairdatasociety/fdp-contracts-js'
+import {
+  ActiveBid,
+  DataHub,
+  ENS,
+  ENS_DOMAIN,
+  SubItem,
+  Subscription,
+  SubscriptionRequest,
+} from '@fairdatasociety/fdp-contracts-js'
 import { decryptWithBytes, deriveSecretFromKeys } from '../utils/encryption'
 import { namehash } from 'ethers/lib/utils'
+import { BigNumber } from 'ethers'
 
 export const POD_TOPIC = 'Pods'
 
@@ -234,4 +243,52 @@ export class PersonalStorage {
 
     return data
   }
+
+  async getActiveBids(): Promise<ActiveBid[]> {
+    return this.dataHub.getActiveBids(this.accountData.wallet!.address)
+  }
+
+  async getListedSubs(address: string): Promise<string[]> {
+    return this.dataHub.getListedSubs(address)
+  }
+
+  async getSubRequests(address: string): Promise<SubscriptionRequest[]> {
+    return this.dataHub.getSubRequests(address)
+  }
+
+  async bidSub(subHash: string, buyerUsername: string, value: BigNumber): Promise<void> {
+    return this.dataHub.requestSubscription(subHash, buyerUsername, value)
+  }
+
+  async createSubscription(
+    sellerUsername: string,
+    swarmLocation: string,
+    price: BigNumber,
+    categoryHash: string,
+    podAddress: string,
+    daysValid: number,
+    value?: BigNumber,
+  ): Promise<void> {
+    return this.dataHub.createSubscription(
+      sellerUsername,
+      swarmLocation,
+      price,
+      categoryHash,
+      podAddress,
+      daysValid,
+      value,
+    )
+  }
+
+  async getAllSubscriptions(): Promise<Subscription[]> {
+    return this.dataHub.getSubs()
+  }
+
+  async getSubscriptionsByCategory(categoryHash: string) {
+    const subs = await this.getAllSubscriptions()
+
+    // TODO temporary until the category gets added to fdp-contracts
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
+    return subs.filter(sub => (sub as any).category === categoryHash)
+  }
 }