feat: package/asset: implement status_change call (#169)

Signed-off-by: Adi Bhagavath <[email protected]>
dhiway · Feb 27, 2024 · cdfe577 · cdfe577
1 parent 43b9462
commit cdfe577
Show file tree

Hide file tree

Showing 2 changed files with 79 additions and 15 deletions.
diff --git a/packages/asset/src/Asset.chain.ts b/packages/asset/src/Asset.chain.ts
@@ -1,4 +1,3 @@
-
 import {
   AssetUri,
   IAssetEntry,
@@ -9,21 +8,19 @@ import {
   SignExtrinsicCallback,
   AuthorizationId,
   ASSET_PREFIX,
+  DidUri,
 } from '@cord.network/types'
+
 import type { Option } from '@cord.network/types'
-import type {
-  PalletAssetAssetEntry,
-} from '@cord.network/augment-api'
+import type { PalletAssetAssetEntry, PalletAssetAssetStatusOf } from '@cord.network/augment-api'
 
 import * as Did from '@cord.network/did'
 import { uriToIdentifier } from '@cord.network/identifier'
 import { Chain } from '@cord.network/network'
 import { ConfigService } from '@cord.network/config'
 import { SDKErrors } from '@cord.network/utils'
 
-export async function isAssetStored(
-  assetUri: AssetUri
-): Promise<boolean> {
+export async function isAssetStored(assetUri: AssetUri): Promise<boolean> {
   try {
     const api = ConfigService.get('api')
     const identifier = uriToIdentifier(assetUri)
@@ -91,9 +88,7 @@ export async function dispatchIssueToChain(
 
     const authorizationId: AuthorizationId = uriToIdentifier(authorizationUri)
 
-    const exists = await isAssetStored(
-      assetEntry.entry.assetId as AssetUri
-    )
+    const exists = await isAssetStored(assetEntry.entry.assetId as AssetUri)
 
     if (!exists) {
       throw new SDKErrors.CordDispatchError(`Asset Entry not found on chain.`)
@@ -124,7 +119,6 @@ export async function dispatchIssueToChain(
   }
 }
 
-
 export async function dispatchTransferToChain(
   assetEntry: IAssetTransfer,
   authorAccount: CordKeyringPair,
@@ -133,10 +127,7 @@ export async function dispatchTransferToChain(
   try {
     const api = ConfigService.get('api')
 
-    const tx = api.tx.asset.transfer(
-    	  assetEntry.entry,
-	  assetEntry.digest,
-    )
+    const tx = api.tx.asset.transfer(assetEntry.entry, assetEntry.digest)
 
     const extrinsic = await Did.authorizeTx(
       assetEntry.owner,
@@ -157,3 +148,68 @@ export async function dispatchTransferToChain(
   }
 }
 
+export async function dispatchAssetStatusChangeToChain(
+  assetId: AssetUri,
+  assetIssuerDidUri: DidUri,
+  authorAccount: CordKeyringPair,
+  newStatus: PalletAssetAssetStatusOf,
+  signCallback: SignExtrinsicCallback,
+  assetInstanceId?: string
+): Promise<void> {
+  try {
+    const api = ConfigService.get('api')
+    let tx
+
+    if (assetInstanceId) {
+      let encodedAssetInstanceDetail = await api.query.asset.issuance(
+        assetId,
+        assetInstanceId
+      )
+      if (encodedAssetInstanceDetail.isNone) {
+        throw new SDKErrors.AssetInstanceNotFound(
+          `Error: Assset Instance Not Found`
+        )
+      }
+      let assetInstanceDetail = JSON.parse(
+        encodedAssetInstanceDetail.toString()
+      )
+      if (assetIssuerDidUri !== assetInstanceDetail.assetInstanceIssuer) {
+        throw new SDKErrors.AssetIssuerMismatch(`Error: Assset issuer mismatch`)
+      }
+      if (assetInstanceDetail.assetInstanceStatus === newStatus) {
+        throw new SDKErrors.AssetStatusError(
+          `Error: Asset Instance is already in the ${newStatus} state`
+        )
+      }
+      tx = api.tx.asset.statusChange(assetId, assetInstanceId, newStatus)
+    } else {
+      let encodedAssetDetail = await api.query.asset.assets(assetId)
+      if (encodedAssetDetail.isNone) {
+        throw new SDKErrors.AssetNotFound(`Error: Assset Not Found`)
+      }
+      let assetDetail = JSON.parse(encodedAssetDetail.toString())
+      if (assetIssuerDidUri !== assetDetail.assetIssuer) {
+        throw new SDKErrors.AssetIssuerMismatch(`Error: Assset issuer mismatch`)
+      }
+      if (assetDetail.assetInstanceStatus === newStatus) {
+        throw new SDKErrors.AssetStatusError(
+          `Error: Asset is already in the ${newStatus} state`
+        )
+      }
+      tx = api.tx.asset.statusChange(assetId, null, newStatus)
+    }
+
+    const extrinsic = await Did.authorizeTx(
+      assetIssuerDidUri,
+      tx,
+      signCallback,
+      authorAccount.address
+    )
+
+    await Chain.signAndSubmitTx(extrinsic, authorAccount)
+  } catch (error) {
+    throw new SDKErrors.CordDispatchError(
+      `Error dispatching to chain: "${error}".`
+    )
+  }
+}
diff --git a/packages/utils/src/SDKErrors.ts b/packages/utils/src/SDKErrors.ts
@@ -238,3 +238,11 @@ export class DecodingMessageError extends SDKError {}
 export class TimeoutError extends SDKError {}
 
 export class CodecMismatchError extends SDKError {}
+
+export class AssetIssuerMismatch extends SDKError {}
+
+export class AssetInstanceNotFound extends SDKError {}
+
+export class AssetNotFound extends SDKError {}
+
+export class AssetStatusError extends SDKError {}