Add owner method on assets module.

integration/ocean/AssetOwners.test.ts

@@ -0,0 +1,31 @@
+import { assert } from "chai"
+
+import { config } from "../config"
+
+import { getMetadata } from "../utils"
+
+import { Ocean, Account } from "../../src" // @oceanprotocol/squid
+
+describe("Asset Owners", () => {
+    let ocean: Ocean
+
+    let publisher: Account
+
+    const metadata = getMetadata()
+
+    before(async () => {
+        ocean = await Ocean.getInstance(config)
+
+        // Accounts
+        publisher = (await ocean.accounts.list())[0]
+        publisher.setPassword(process.env.ACCOUNT_PASSWORD)
+    })
+
+    it("should be set correctly the owner of a asset", async () => {
+        const ddo = await ocean.assets.create(metadata as any, publisher)
+
+        const owner = await ocean.assets.owner(ddo.id)
+
+        assert.equal(owner, publisher.getId())
+    })
+})

src/ocean/OceanAssets.ts

@@ -259,6 +259,24 @@ export class OceanAssets extends Instantiable {
         return agreementId
     }
 
+    /**
+     * Returns the owner of a asset.
+     * @param  {string} did Decentralized ID.
+     * @return {Promise<string>} Returns Agreement ID
+     */
+    public async owner(did: string): Promise<string> {
+        const ddo = await this.resolve(did)
+        const checksum = ddo.getChecksum()
+        const {creator, signatureValue} = ddo.proof
+        const signer = await this.ocean.utils.signature.verifyText(checksum, signatureValue)
+
+        if (signer.toLowerCase() !== creator.toLowerCase()) {
+            this.logger.warn(`Owner of ${ddo.id} doesn't match. Expected ${creator} instead of ${signer}.`)
+        }
+
+        return creator
+    }
+
     /**
      * Search over the assets using a query.
      * @param  {SearchQuery} query Query to filter the assets.