add ownerAssets

oceanprotocol · Jul 3, 2020 · d8dadf5 · d8dadf5
1 parent 28d1775
commit d8dadf5
Show file tree

Hide file tree

Showing 5 changed files with 13,968 additions and 5 deletions.
diff --git a/src/metadatastore/MetadataStore.ts b/src/metadatastore/MetadataStore.ts
@@ -315,6 +315,20 @@ export class MetadataStore {
         return result
     }
 
+    public async getOwnerAssets(owner: string): Promise<DDO[]> {
+        const query = {
+            offset: 100,
+            page: 1,
+            query: {
+                'publickey.id.owner': owner
+            },
+            sort: {
+                value: 1
+            }
+        }
+        return (await this.queryMetadata(query)).results
+    }
+
     /**
      * Edit Metadata for a DDO.
      * @param  {did} string DID.

diff --git a/src/ocean/Assets.ts b/src/ocean/Assets.ts
@@ -172,10 +172,8 @@ export class Assets extends Instantiable {
      * @param  {string} owner Owner address.
      * @return {Promise<string[]>} List of DIDs.
      */
-    public async ownerAssets(owner: string): Promise<string[]> {
-        // TODO:
-        // return this.ocean.keeper.didRegistry.getAttributesByOwner(owner)
-        return ['']
+    public async ownerAssets(owner: string): Promise<DDO[]> {
+        return this.ocean.metadatastore.getOwnerAssets(owner)
     }
 
     /**

diff --git a/test/integration/Marketplaceflow.test.ts b/test/integration/Marketplaceflow.test.ts
@@ -41,7 +41,6 @@ describe('Marketplace flow', () => {
 
             ocean = await Ocean.getInstance(config)
             owner = (await ocean.accounts.list())[0]
-            console.log(owner.getId())
             alice = (await ocean.accounts.list())[1]
             bob = (await ocean.accounts.list())[2]
             marketplace = (await ocean.accounts.list())[3]