feat: add asset edit functionality

src/Nautilus/Asset/NautilusDDO.ts

@@ -17,6 +17,7 @@ import {
   NautilusService,
   ServiceTypes
 } from './Service/NautilusService'
+import { transformAquariusAssetToDDO } from '../../utils/aquarius'
 
 export class NautilusDDO {
   id: string
@@ -35,7 +36,7 @@ export class NautilusDDO {
   }
 
   static createFromAquariusAsset(aquariusAsset: Asset): NautilusDDO {
-    const ddo = this.transformAquariusAssetToDDO(aquariusAsset)
+    const ddo = transformAquariusAssetToDDO(aquariusAsset)
 
     return this.createFromDDO(ddo)
   }
@@ -239,20 +240,4 @@ export class NautilusDDO {
     // Otherwise we return the replacement
     return replacementService
   }
-
-  static transformAquariusAssetToDDO(aquariusAsset: Asset): DDO {
-    const ddo = structuredClone(aquariusAsset)
-
-    const unwantedAssetAttributes = [
-      'nft',
-      'datatokens',
-      'event',
-      'stats',
-      'purgatory'
-    ]
-    for (const attribute of unwantedAssetAttributes) {
-      delete ddo[attribute]
-    }
-    return ddo as DDO
-  }
 }

src/Nautilus/Nautilus.ts

@@ -269,7 +269,7 @@ export class Nautilus {
     )
   }
 
-  async getAquariusAssets(dids: string[]): Promise<{ [key: string]: Asset }> {
+  async getAquariusAssets(dids: string[]): Promise<{ [did: string]: Asset }> {
     try {
       return await getAssets(this.config.metadataCacheUri, dids)
     } catch (error) {

src/utils/aquarius.ts

@@ -1,5 +1,6 @@
-import { Asset, LoggerInstance } from '@oceanprotocol/lib'
+import { Asset, DDO, LoggerInstance } from '@oceanprotocol/lib'
 import axios, { AxiosResponse } from 'axios'
+import { AQUARIUS_ASSET_EXTENDED_DDO_PROPS } from './constants'
 
 export async function getAsset(
   metadataCacheUri: string,
@@ -35,7 +36,7 @@ export async function getAsset(
 export async function getAssets(
   metadataCacheUri: string,
   dids: string[]
-): Promise<{ [key: string]: Asset }> {
+): Promise<{ [did: string]: Asset }> {
   const apiPath = '/api/aquarius/assets/query'
 
   if (!metadataCacheUri) {
@@ -62,7 +63,7 @@ export async function getAssets(
     }
   }
 
-  const assets: { [key: string]: Asset } = {}
+  const assets: { [did: string]: Asset } = {}
 
   try {
     const fullAquariusUrl = new URL(apiPath, metadataCacheUri).href
@@ -88,3 +89,12 @@ export async function getAssets(
     throw error
   }
 }
+
+export function transformAquariusAssetToDDO(aquariusAsset: Asset): DDO {
+  const ddo = structuredClone(aquariusAsset)
+
+  for (const attribute of AQUARIUS_ASSET_EXTENDED_DDO_PROPS) {
+    delete ddo[attribute]
+  }
+  return ddo as DDO
+}

src/utils/constants.ts

@@ -0,0 +1,12 @@
+import { Asset, DDO } from '@oceanprotocol/lib'
+
+export type AssetSpecificProps = Exclude<keyof Asset, keyof DDO>
+
+// these are the props which extend the DDO interface to be an aquarius Asset
+// this const is needed to strip these away from an Asset to convert it into an DDO
+export const AQUARIUS_ASSET_EXTENDED_DDO_PROPS: AssetSpecificProps[] = [
+  'nft',
+  'datatokens',
+  'stats',
+  'purgatory'
+]

src/utils/helpers/trusted-algorithms.ts

@@ -76,41 +76,40 @@ export async function resolvePublisherTrustedAlgorithms(
   metadataCacheUri: string
 ) {
   for (const service of nautilusDDOServices) {
-    if (service.addedPublisherTrustedAlgorithms.length > 0) {
-      const dids = service.addedPublisherTrustedAlgorithms.map(
-        (asset) => asset.did
-      )
-      const newPublisherTrustedAlgorithms = await getPublisherTrustedAlgorithms(
-        dids,
-        metadataCacheUri
-      )
+    if (service.addedPublisherTrustedAlgorithms?.length) continue
 
-      if (service.compute?.publisherTrustedAlgorithms?.length === 0) {
-        service.compute.publisherTrustedAlgorithms =
-          newPublisherTrustedAlgorithms
-        return
-      }
+    const dids = service.addedPublisherTrustedAlgorithms.map(
+      (asset) => asset.did
+    )
+    const newPublisherTrustedAlgorithms = await getPublisherTrustedAlgorithms(
+      dids,
+      metadataCacheUri
+    )
 
-      newPublisherTrustedAlgorithms.forEach((algorithm) => {
-        const index = service.compute.publisherTrustedAlgorithms.findIndex(
-          (existingAlgorithm) => existingAlgorithm.did === algorithm.did
-        )
+    if (service.compute?.publisherTrustedAlgorithms?.length === 0) {
+      service.compute.publisherTrustedAlgorithms = newPublisherTrustedAlgorithms
+      return
+    }
+
+    newPublisherTrustedAlgorithms.forEach((algorithm) => {
+      const index = service.compute.publisherTrustedAlgorithms.findIndex(
+        (existingAlgorithm) => existingAlgorithm.did === algorithm.did
+      )
 
-        if (index === -1) {
-          // Algorithm with the same DID doesn't exist, add it
-          service.compute.publisherTrustedAlgorithms.push(algorithm)
-        } else {
-          // If either checksum is different, replace the existing algorithm
-          const existing = service.compute.publisherTrustedAlgorithms[index]
-          if (
-            existing.containerSectionChecksum !==
-              algorithm.containerSectionChecksum ||
-            existing.filesChecksum !== algorithm.filesChecksum
-          ) {
-            service.compute.publisherTrustedAlgorithms[index] = algorithm
-          }
+      if (index === -1) {
+        // Algorithm with the same DID doesn't exist, add it
+        service.compute.publisherTrustedAlgorithms.push(algorithm)
+      } else {
+        // If either checksum is different, replace the existing algorithm
+        const existing = service.compute.publisherTrustedAlgorithms[index]
+        if (
+          existing.containerSectionChecksum !==
+            algorithm.containerSectionChecksum ||
+          existing.filesChecksum !== algorithm.filesChecksum
+        ) {
+          service.compute.publisherTrustedAlgorithms[index] = algorithm
         }
-      })
-    }
+      }
+    })
   }
 }