Merge pull request #769 from input-output-hk/feat/plutus-data-serialization

feat: nft metadata service

Author: AngelCastilloB

.github/workflows/continuous-integration-e2e.yaml

@@ -29,7 +29,6 @@ env:
 
 on:
   pull_request:
-    branches: ['master']
   push:
     branches: ['master']
     tags: ['*.*.*']

.github/workflows/continuous-integration-unit-tests.yaml

@@ -6,7 +6,6 @@ env:
 
 on:
   pull_request:
-    branches: ['master']
   push:
     branches: ['master']
     tags: ['*.*.*']

packages/cardano-services-client/src/HttpProvider.ts

@@ -2,7 +2,6 @@
 import { HttpProviderConfigPaths, Provider, ProviderError, ProviderFailure } from '@cardano-sdk/core';
 import { Logger } from 'ts-log';
 import { fromSerializableObject, toSerializableObject } from '@cardano-sdk/util';
-import { apiVersion as staticApiVersion } from './version';
 import axios, { AxiosAdapter, AxiosRequestConfig, AxiosResponseTransformer } from 'axios';
 import packageJson from '../package.json';
 
@@ -104,7 +103,7 @@ export const createHttpProvider = <T extends Provider>({
           const req: AxiosRequestConfig = {
             ...axiosOptions,
             adapter,
-            baseURL: `${baseUrl.replace(/\/$/, '')}/v${staticApiVersion.root}/${serviceSlug}`,
+            baseURL: `${baseUrl.replace(/\/$/, '')}/v${apiVersion}/${serviceSlug}`,
             data: { ...args[0] },
             headers: {
               ...axiosOptions?.headers,

packages/cardano-services-client/src/version.ts

@@ -1,12 +1,12 @@
 // auto-generated using ../scripts/createVersionSource.js
 export const apiVersion = {
   assetInfo: '1.0.0',
-  chainHistory: '1.0.0',
+  chainHistory: '2.0.0',
   handle: '1.0.0',
   networkInfo: '1.0.0',
   rewards: '1.0.0',
   root: '1.0.0',
   stakePool: '1.0.0',
-  txSubmit: '1.0.0',
-  utxo: '1.0.0'
+  txSubmit: '2.0.0',
+  utxo: '2.0.0'
 };

packages/cardano-services-client/test/HttpProvider.test.ts

@@ -11,8 +11,8 @@ import path from 'path';
 
 const packageJson = require(path.join(__dirname, '..', 'package.json'));
 
-type ComplexArg2 = { map: Map<string, Buffer> };
-type ComplexResponse = Map<bigint, Buffer>[];
+type ComplexArg2 = { map: Map<string, Uint8Array> };
+type ComplexResponse = Map<bigint, Uint8Array>[];
 interface TestProvider extends Provider {
   noArgsEmptyReturn(): Promise<void>;
   complexArgsAndReturn({ arg1, arg2 }: { arg1: bigint; arg2: ComplexArg2 }): Promise<ComplexResponse>;
@@ -95,8 +95,8 @@ describe('createHttpProvider', () => {
   describe('method with complex args and return', () => {
     it('serializes args and deserializes response using core serializableObject', async () => {
       const arg1 = 123n;
-      const arg2: ComplexArg2 = { map: new Map([['key', Buffer.from('abc')]]) };
-      const expectedResponse: ComplexResponse = [new Map([[1234n, Buffer.from('response data')]])];
+      const arg2: ComplexArg2 = { map: new Map([['key', new Uint8Array(Buffer.from('abc'))]]) };
+      const expectedResponse: ComplexResponse = [new Map([[1234n, new Uint8Array(Buffer.from('response data'))]])];
       const provider = createTxSubmitProviderClient();
       closeServer = await createStubHttpProviderServer(port, stubProviderPaths.complexArgsAndReturn, (req, res) => {
         expect(fromSerializableObject(req.body)).toEqual({ arg1, arg2 });

packages/cardano-services-client/version.json

@@ -1,11 +1,11 @@
 {
   "assetInfo": "1.0.0",
-  "chainHistory": "1.0.0",
+  "chainHistory": "2.0.0",
   "handle": "1.0.0",
   "networkInfo": "1.0.0",
   "rewards": "1.0.0",
   "root": "1.0.0",
   "stakePool": "1.0.0",
-  "txSubmit": "1.0.0",
-  "utxo": "1.0.0"
+  "txSubmit": "2.0.0",
+  "utxo": "2.0.0"
 }

packages/cardano-services/src/Asset/DbSyncAssetProvider/AssetBuilder.ts

@@ -1,5 +1,5 @@
 import { Cardano } from '@cardano-sdk/core';
-import { LastMintTxModel, MultiAssetHistoryModel, MultiAssetModel } from './types';
+import { LastMintTxModel, MultiAssetModel } from './types';
 import { Logger } from 'ts-log';
 import { Pool } from 'pg';
 import Queries from './queries';
@@ -32,14 +32,4 @@ export class AssetBuilder {
     });
     return result.rows[0];
   }
-
-  public async queryMultiAssetHistory(policyId: Cardano.PolicyId, name: Cardano.AssetName) {
-    this.#logger.debug('About to query multi asset history', { name, policyId });
-    const result = await this.#db.query<MultiAssetHistoryModel>({
-      name: 'find_multi_asset_history',
-      text: Queries.findMultiAssetHistory,
-      values: [Buffer.from(policyId, 'hex'), Buffer.from(name, 'hex')]
-    });
-    return result.rows;
-  }
 }

packages/cardano-services/src/Asset/DbSyncAssetProvider/DbSyncAssetProvider.ts

@@ -11,7 +11,7 @@ import {
 import { AssetBuilder } from './AssetBuilder';
 import { AssetPolicyIdAndName, NftMetadataService, TokenMetadataService } from '../types';
 import { DB_CACHE_TTL_DEFAULT, InMemoryCache, NoCache } from '../../InMemoryCache';
-import { DbSyncProvider, DbSyncProviderDependencies } from '../../util/DbSyncProvider';
+import { DbSyncProvider, DbSyncProviderDependencies } from '../../util';
 
 /**
  * Properties that are need to create DbSyncAssetProvider
@@ -74,7 +74,6 @@ export class DbSyncAssetProvider extends DbSyncProvider() implements AssetProvid
   async getAsset({ assetId, extraData }: GetAssetArgs) {
     const assetInfo = await this.#getAssetInfo(assetId);
 
-    if (extraData?.history) await this.loadHistory(assetInfo);
     if (extraData?.nftMetadata) assetInfo.nftMetadata = await this.#getNftMetadata(assetInfo);
     if (extraData?.tokenMetadata) {
       try {
@@ -133,15 +132,6 @@ export class DbSyncAssetProvider extends DbSyncProvider() implements AssetProvid
     return Promise.all(assetIds.map((_) => getAssetInfo(_)));
   }
 
-  private async loadHistory(assetInfo: Asset.AssetInfo) {
-    assetInfo.history = (
-      await this.#builder.queryMultiAssetHistory(assetInfo.policyId, assetInfo.name)
-    ).map<Asset.AssetMintOrBurn>(({ hash, quantity }) => ({
-      quantity: BigInt(quantity),
-      transactionId: hash.toString('hex') as unknown as Cardano.TransactionId
-    }));
-  }
-
   async #getNftMetadata(asset: AssetPolicyIdAndName): Promise<Asset.NftMetadata | null> {
     return this.#cache.get(
       nftMetadataCacheKey(Cardano.AssetId.fromParts(asset.policyId, asset.name)),
@@ -166,9 +156,8 @@ export class DbSyncAssetProvider extends DbSyncProvider() implements AssetProvid
       const supply = BigInt(multiAsset.sum);
       // Backwards compatibility
       const quantity = supply;
-      const mintOrBurnCount = Number(multiAsset.count);
 
-      return { assetId, fingerprint, mintOrBurnCount, name, policyId, quantity, supply };
+      return { assetId, fingerprint, name, policyId, quantity, supply };
     });
   }
 }

packages/cardano-services/src/Asset/DbSyncNftMetadataService.ts

@@ -39,6 +39,6 @@ export class DbSyncNftMetadataService implements NftMetadataService {
     this.#logger.debug('Querying tx metadata', lastMintedTxId);
     const metadatas = await this.#metadataService.queryTxMetadataByHashes([lastMintedTxId]);
     const metadata = metadatas.get(lastMintedTxId);
-    return Asset.util.metadatumToCip25(assetInfo, metadata, this.#logger);
+    return Asset.NftMetadata.fromMetadatum(assetInfo, metadata, this.#logger);
   }
 }

packages/cardano-services/src/Asset/TypeOrmNftMetadataService.ts

@@ -0,0 +1,37 @@
+import { Asset, Cardano } from '@cardano-sdk/core';
+import { AssetPolicyIdAndName, NftMetadataService } from './types';
+import { NftMetadataEntity } from '@cardano-sdk/projection-typeorm';
+import { TypeormProviderDependencies, TypeormService } from '../util';
+
+export class TypeOrmNftMetadataService extends TypeormService implements NftMetadataService {
+  constructor({ connectionConfig$, logger, entities }: TypeormProviderDependencies) {
+    super('TypeOrmNftMetadataService', { connectionConfig$, entities, logger });
+  }
+
+  async getNftMetadata(assetInfo: AssetPolicyIdAndName): Promise<Asset.NftMetadata | null> {
+    const assetId = Cardano.AssetId.fromParts(assetInfo.policyId, assetInfo.name);
+    const stringAssetName = Buffer.from(assetInfo.name, 'hex').toString('utf8');
+    return this.withDataSource(async (dataSource) => {
+      const queryRunner = dataSource.createQueryRunner();
+      const nftMetadataRepository = queryRunner.manager.getRepository(NftMetadataEntity);
+
+      const asset = await nftMetadataRepository.findOneBy({
+        name: stringAssetName,
+        userTokenAsset: { id: assetId }
+      });
+
+      if (!asset) {
+        return null;
+      }
+
+      return {
+        image: asset.image,
+        name: asset.name,
+        ...(asset.description && { description: asset.description }),
+        ...(asset.files && { files: asset.files }),
+        ...(asset.mediaType && { mediaType: asset.mediaType }),
+        ...(asset.otherProperties && { otherProperties: asset.otherProperties })
+      } as unknown as Asset.NftMetadata;
+    });
+  }
+}