add search options to get published and purchased subscriptions

Author: spielcrypto

catalog/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nevermined-io/catalog",
-  "version": "1.3.3",
+  "version": "1.3.4",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "dependencies": {

catalog/src/catalog.tsx

@@ -23,7 +23,8 @@ import {
   BigNumber,
   SubscriptionsAndServicesDDOs,
   OrderProgressStep,
-  SubscriptionsAndDatasetsDDOs
+  SubscriptionsAndDatasetsDDOs,
+  SearchOptions
 } from './types'
 import {
   conductOrder,
@@ -210,85 +211,87 @@ export const NeverminedProvider = ({ children, config, verbose }: NeverminedProv
       }
     },
 
-    getPublishedSubscriptions: async (): Promise<DDO[]> => {
+    getPublishedSubscriptions: async (searchOptions?: SearchOptions): Promise<DDO[]> => {
       try {
         const account = await getCurrentAccount(sdk)
-        const query = await sdk.search.subscriptionsCreated(account)
+        const query = await sdk.search.subscriptionsCreated(account, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
         return query.results
       } catch {
         verbose && Logger.error(error)
         return []
       }
     },
 
-    getPublishedSubscriptionsAndServices: async (): Promise<SubscriptionsAndServicesDDOs[]> => {
+    getPublishedSubscriptionsAndServices: async (searchOptions?: SearchOptions
+      ): Promise<SubscriptionsAndServicesDDOs[]> => {
       try {
         const account = await getCurrentAccount(sdk)
-        const query = await sdk.search.subscriptionsCreated(account)
-        return getSubscriptionsAndServices(query.results, sdk)
+        const query = await sdk.search.subscriptionsCreated(account, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
+        return getSubscriptionsAndServices(query.results, sdk, searchOptions)
       } catch (error) {
         verbose && Logger.error(error)
         return []
       }
     },
 
-    getPublishedSubscriptionsAndDatasets: async (): Promise<SubscriptionsAndDatasetsDDOs[]> => {
+    getPublishedSubscriptionsAndDatasets: async (searchOptions?: SearchOptions): Promise<SubscriptionsAndDatasetsDDOs[]> => {
       try {
         const account = await getCurrentAccount(sdk)
-        const query = await sdk.search.subscriptionsCreated(account)
-        return getSubscriptionsAndDatasets(query.results, sdk)
+        const query = await sdk.search.subscriptionsCreated(account, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
+        return getSubscriptionsAndDatasets(query.results, sdk, searchOptions)
       } catch (error) {
         verbose && Logger.error(error)
         return []
       }
     },
 
-    getPurchasedSubscriptions: async (): Promise<DDO[]> => {
+    getPurchasedSubscriptions: async (searchOptions?: SearchOptions): Promise<DDO[]> => {
       try {
         const account = await getCurrentAccount(sdk)
-        const query = await sdk.search.subscriptionsPurchased(account)
+        const query = await sdk.search.subscriptionsPurchased(account, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
         return query.results
       } catch (error) {
         verbose && Logger.error(error)
         return []
       }
     },
 
-    getPurchasedSubscriptionsAndServices: async (): Promise<SubscriptionsAndServicesDDOs[]> => {
+    getPurchasedSubscriptionsAndServices: async (searchOptions?: SearchOptions
+      ): Promise<SubscriptionsAndServicesDDOs[]> => {
       try {
         const account = await getCurrentAccount(sdk)
-        const query = await sdk.search.subscriptionsPurchased(account)
-        return getSubscriptionsAndServices(query.results, sdk)
+        const query = await sdk.search.subscriptionsPurchased(account, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
+        return getSubscriptionsAndServices(query.results, sdk, searchOptions)
       } catch (error) {
         verbose && Logger.error(error)
         return []
       }
     },
 
-    getPurchasedSubscriptionsAndDatasets: async (): Promise<SubscriptionsAndDatasetsDDOs[]> => {
+    getPurchasedSubscriptionsAndDatasets: async (searchOptions?: SearchOptions): Promise<SubscriptionsAndDatasetsDDOs[]> => {
       try {
         const account = await getCurrentAccount(sdk)
-        const query = await sdk.search.subscriptionsPurchased(account)
-        return getSubscriptionsAndDatasets(query.results, sdk)
+        const query = await sdk.search.subscriptionsPurchased(account, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
+        return getSubscriptionsAndDatasets(query.results, sdk, searchOptions)
       } catch (error) {
         verbose && Logger.error(error)
         return []
       }
     },
 
-    getAssociatedServices: async (did: string): Promise<DDO[]> => {
+    getAssociatedServices: async (did: string, searchOptions?: SearchOptions): Promise<DDO[]> => {
       try {
-        const query = await sdk.search.servicesBySubscription(did)
+        const query = await sdk.search.servicesBySubscription(did, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
         return query.results
       } catch (error) {
         verbose && Logger.error(error)
         return []
       }
     },
 
-    getAssociatedDatasets: async (did: string): Promise<DDO[]> => {
+    getAssociatedDatasets: async (did: string, searchOptions?: SearchOptions): Promise<DDO[]> => {
       try {
-        const query = await sdk.search.datasetsBySubscription(did)
+        const query = await sdk.search.datasetsBySubscription(did, searchOptions?.offset, searchOptions?.page, searchOptions?.sort, searchOptions?.appId)
         return query.results
       } catch (error) {
         verbose && Logger.error(error)

catalog/src/types/index.ts

@@ -299,6 +299,20 @@ export interface GenericOutput<T, E> {
   success: boolean
 }
 
+/**
+ * Query search options
+ */
+export interface SearchOptions {
+  /** Number of results per page */
+  offset?: number
+  /** Number of page */
+  page?: number
+  /** result order */
+  sort?: 'asc' | 'desc'
+  /** If app to search have an id */
+  appId?: string
+}
+
 /** Id of the asset */
 export type DID = string
 
@@ -405,51 +419,62 @@ export interface AccountModule {
   /**
    * Get only published Subscriptions
    * @param address the address which published the subscription returned
+   * @param searchOptions options for customize result
    * @returns published subscriptions
    */
-  getPublishedSubscriptions: (address: string) => Promise<DDO[]>
+  getPublishedSubscriptions: (searchOptions?: SearchOptions) => Promise<DDO[]>
   /**
    * Get all the services associated a subscription
    * @param address the subscription address
+   * @param searchOptions options for customize result
    * @returns associated services to subscriptions
    */
-  getAssociatedServices: (did: string) => Promise<DDO[]>
+  getAssociatedServices: (did: string, searchOptions?: SearchOptions) => Promise<DDO[]>
   /**
    * Get all the datasets associated to a subscription
    * @param address the subscription address
+   * @param searchOptions options for customize result
    * @returns associated datasets to subscriptions
    */
-  getAssociatedDatasets: (did: string) => Promise<DDO[]>
+  getAssociatedDatasets: (did: string, searchOptions?: SearchOptions) => Promise<DDO[]>
   /**
    * Get all the published subscriptions and services associated from the wallet address passed
-   * @param did the did of the subscription
+   * @param searchOptions options for customize result
    * @returns published subscriptions and service
    */
-  getPublishedSubscriptionsAndServices: (address: string) => Promise<SubscriptionsAndServicesDDOs[]>
+  getPublishedSubscriptionsAndServices: (
+    searchOptions?: SearchOptions,
+  ) => Promise<SubscriptionsAndServicesDDOs[]>
   /**
    * Get all the published subscriptions and datasets associated from the wallet address passed
-   * @param did the did of the subscription
+   * @param searchOptions options for customize result
    * @returns published subscriptions and its datasets
    */
-  getPublishedSubscriptionsAndDatasets: (address: string) => Promise<SubscriptionsAndDatasetsDDOs[]>
+  getPublishedSubscriptionsAndDatasets: (
+    searchOptions?: SearchOptions,
+  ) => Promise<SubscriptionsAndDatasetsDDOs[]>
   /**
    * Get only purchased Subscriptions
-   * @param address the address which purchased the subscription returned
+   * @param searchOptions options for customize result
    * @returns purchased subscriptions
    */
-  getPurchasedSubscriptions: (address: string) => Promise<DDO[]>
+  getPurchasedSubscriptions: (searchOptions?: SearchOptions) => Promise<DDO[]>
   /**
    * Get all the purchased subscriptions and services associated from the wallet address passed
-   * @param address the address which published the subscription returned
+   * @param searchOptions options for customize result
    * @returns purchased subscriptions and services
    */
-  getPurchasedSubscriptionsAndServices: (address: string) => Promise<SubscriptionsAndServicesDDOs[]>
+  getPurchasedSubscriptionsAndServices: (
+    searchOptions?: SearchOptions,
+  ) => Promise<SubscriptionsAndServicesDDOs[]>
   /**
    * Get all the purchased subscriptions and datasets associated from the wallet address passed
-   * @param did the did of the subscription
+   * @param searchOptions options for customize result
    * @returns purchased subscriptions and its datasets
    */
-  getPurchasedSubscriptionsAndDatasets: (address: string) => Promise<SubscriptionsAndDatasetsDDOs[]>
+  getPurchasedSubscriptionsAndDatasets: (
+    searchOptions?: SearchOptions,
+  ) => Promise<SubscriptionsAndDatasetsDDOs[]>
   /**
    * Generate a token for authentication in the Marketplace API
    * @returns The new generated token

catalog/src/utils/index.ts

@@ -4,6 +4,7 @@ import {
   ERCType,
   MarketplaceAPIToken,
   NeverminedOptions,
+  SearchOptions,
   SubscribablePromise,
 } from '../types'
 import axios from 'axios'
@@ -173,10 +174,20 @@ export const handlePostRequest = async (url: string, formData: FormData, retries
   }
 }
 
-export const getSubscriptionsAndServices = async (subscriptionsDDOs: DDO[], sdk: Nevermined) => {
+export const getSubscriptionsAndServices = async (
+  subscriptionsDDOs: DDO[],
+  sdk: Nevermined,
+  searchOptions?: SearchOptions,
+) => {
   return Promise.all(
     subscriptionsDDOs.map(async (ddo) => {
-      const query = await sdk.search.servicesBySubscription(ddo.id)
+      const query = await sdk.search.servicesBySubscription(
+        ddo.id,
+        searchOptions?.offset,
+        searchOptions?.page,
+        searchOptions?.sort,
+        searchOptions?.appId,
+      )
 
       return {
         subscription: ddo,
@@ -186,10 +197,20 @@ export const getSubscriptionsAndServices = async (subscriptionsDDOs: DDO[], sdk:
   )
 }
 
-export const getSubscriptionsAndDatasets = async (subscriptionsDDOs: DDO[], sdk: Nevermined) => {
+export const getSubscriptionsAndDatasets = async (
+  subscriptionsDDOs: DDO[],
+  sdk: Nevermined,
+  searchOptions?: SearchOptions,
+) => {
   return Promise.all(
     subscriptionsDDOs.map(async (ddo) => {
-      const query = await sdk.search.datasetsBySubscription(ddo.id)
+      const query = await sdk.search.datasetsBySubscription(
+        ddo.id,
+        searchOptions?.offset,
+        searchOptions?.page,
+        searchOptions?.sort,
+        searchOptions?.appId,
+      )
 
       return {
         subscription: ddo,

catalog/unit-tests/catalog/catalog.account.spec.tsx

@@ -546,7 +546,7 @@ describe('Nevermined account', () => {
 
           (async () => {
             try {
-              const result = await account.getPublishedSubscriptions(walletAddress)
+              const result = await account.getPublishedSubscriptions()
 
               setSubscriptions([...result])
             } catch (error: any) {
@@ -582,7 +582,7 @@ describe('Nevermined account', () => {
 
           (async () => {
             try {
-              const result = await account.getPublishedSubscriptionsAndServices(walletAddress)
+              const result = await account.getPublishedSubscriptionsAndServices()
 
               setSubscriptions([...result])
             } catch (error: any) {
@@ -621,7 +621,7 @@ describe('Nevermined account', () => {
 
           (async () => {
             try {
-              const result = await account.getPurchasedSubscriptions(walletAddress)
+              const result = await account.getPurchasedSubscriptions()
 
               setSubscriptions([...result])
             } catch (error: any) {
@@ -657,7 +657,7 @@ describe('Nevermined account', () => {
 
           (async () => {
             try {
-              const result = await account.getPurchasedSubscriptionsAndServices(walletAddress)
+              const result = await account.getPurchasedSubscriptionsAndServices()
 
               setSubscriptions([...result])
             } catch (error: any) {
@@ -732,7 +732,7 @@ describe('Nevermined account', () => {
 
           (async () => {
             try {
-              const result = await account.getPublishedSubscriptionsAndDatasets(walletAddress)
+              const result = await account.getPublishedSubscriptionsAndDatasets()
 
               setSubscriptions([...result])
             } catch (error: any) {
@@ -771,7 +771,7 @@ describe('Nevermined account', () => {
 
           (async () => {
             try {
-              const result = await account.getPublishedSubscriptionsAndDatasets(walletAddress)
+              const result = await account.getPublishedSubscriptionsAndDatasets()
 
               setSubscriptions([...result])
             } catch (error: any) {

providers/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@nevermined-io/providers",
   "private": false,
-  "version": "1.3.3",
+  "version": "1.3.4",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "dependencies": {