feat(sdk): token and group queries

Dockerfile

@@ -724,6 +724,7 @@ COPY --from=build-dapi /platform/packages/dapi /platform/packages/dapi
 COPY --from=build-dapi /platform/packages/dapi-grpc /platform/packages/dapi-grpc
 COPY --from=build-dapi /platform/packages/js-grpc-common /platform/packages/js-grpc-common
 COPY --from=build-dapi /platform/packages/wasm-dpp /platform/packages/wasm-dpp
+COPY --from=build-dapi /platform/packages/token-history-contract /platform/packages/token-history-contract
 
 RUN cp /platform/packages/dapi/.env.example /platform/packages/dapi/.env
 

packages/dapi-grpc/build.rs

@@ -47,7 +47,7 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
     // Derive features for versioned messages
     //
     // "GetConsensusParamsRequest" is excluded as this message does not support proofs
-    const VERSIONED_REQUESTS: [&str; 34] = [
+    const VERSIONED_REQUESTS: [&str; 40] = [
         "GetDataContractHistoryRequest",
         "GetDataContractRequest",
         "GetDataContractsRequest",
@@ -82,14 +82,20 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
         "GetIdentitiesTokenBalancesRequest",
         "GetIdentityTokenInfosRequest",
         "GetIdentitiesTokenInfosRequest",
+        "GetTokenStatusesRequest",
+        "GetTokenTotalSupplyRequest",
+        "GetGroupInfoRequest",
+        "GetGroupInfosRequest",
+        "GetGroupActionsRequest",
+        "GetGroupActionSignersRequest",
     ];
 
     // The following responses are excluded as they don't support proofs:
     // - "GetConsensusParamsResponse"
     // - "GetStatusResponse"
     //
     //  "GetEvonodesProposedEpochBlocksResponse" is used for 2 Requests
-    const VERSIONED_RESPONSES: [&str; 33] = [
+    const VERSIONED_RESPONSES: [&str; 39] = [
         "GetDataContractHistoryResponse",
         "GetDataContractResponse",
         "GetDataContractsResponse",
@@ -123,6 +129,12 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
         "GetIdentitiesTokenBalancesResponse",
         "GetIdentityTokenInfosResponse",
         "GetIdentitiesTokenInfosResponse",
+        "GetTokenStatusesResponse",
+        "GetTokenTotalSupplyResponse",
+        "GetGroupInfoResponse",
+        "GetGroupInfosResponse",
+        "GetGroupActionsResponse",
+        "GetGroupActionSignersResponse",
     ];
 
     check_unique(&VERSIONED_REQUESTS).expect("VERSIONED_REQUESTS");

packages/dapi/lib/externalApis/drive/fetchProofForStateTransitionFactory.js

@@ -11,13 +11,17 @@ const {
   TokenTransitionType,
 } = require('@dashevo/wasm-dpp');
 const { GetDataContractRequest } = require('@dashevo/dapi-grpc/clients/platform/v0/web/platform_pb');
+const { contractId: tokensHistoryContractIdString } = require('@dashevo/token-history-contract/lib/systemIds');
+const bs58 = require('bs58');
 
 /**
  * @param {PlatformPromiseClient} driveClient
  * @param {DashPlatformProtocol} dpp
  * @return {fetchProofForStateTransition}
  */
 function fetchProofForStateTransitionFactory(driveClient, dpp) {
+  const tokensHistoryContractIdBuffer = bs58.decode(tokensHistoryContractIdString);
+
   /**
    * @typedef {fetchProofForStateTransition}
    * @param {AbstractStateTransition} stateTransition
@@ -30,7 +34,7 @@ function fetchProofForStateTransitionFactory(driveClient, dpp) {
 
     const requestV0 = new GetProofsRequestV0();
 
-    let dataContractsCache = {};
+    const dataContractsCache = {};
 
     if (stateTransition.isDocumentStateTransition()) {
       const {
@@ -46,110 +50,117 @@ function fetchProofForStateTransitionFactory(driveClient, dpp) {
       const tokenStatusesList = [];
 
       for (const batchedTransition of stateTransition.getTransitions()) {
+        // Fetch data contract to determine correct recipient identity
+        const dataContractId = batchedTransition.getDataContractId();
+        const dataContractIdString = dataContractId.toString();
+
         if (batchedTransition instanceof TokenTransition) {
-          switch (batchedTransition.getTransitionType()) {
-            case TokenTransitionType.Burn: {
-              const request = new IdentityTokenBalanceRequest({
-                tokenId: batchedTransition.getTokenId()
-                  .toBuffer(),
-                identityId: stateTransition.getOwnerId()
-                  .toBuffer(),
-              });
-
-              identityTokenBalancesList.push(request);
-              break;
-            }
-            case TokenTransitionType.Mint: {
-              // Fetch data contract to determine correct recipient identity
-              const dataContractId = batchedTransition.getDataContractId();
-              const dataContractIdString = dataContractId.toString();
+          if (!dataContractsCache[dataContractIdString]) {
+            const dataContractRequestV0 = new GetDataContractRequest.GetDataContractRequestV0();
+            dataContractRequestV0.setId(dataContractId.toBuffer());
 
-              if (!dataContractsCache[dataContractIdString]) {
-                const dataContractRequestV0 = new GetDataContractRequest.GetDataContractRequestV0({
-                  id: dataContractId.toBuffer(),
-                });
+            const dataContractRequest = new GetDataContractRequest();
+            dataContractRequest.setV0(dataContractRequestV0);
 
-                const dataContractRequest = new GetDataContractRequest();
-                dataContractRequest.setV0(dataContractRequestV0);
+            const dataContractResponse = await driveClient.getDataContract(dataContractRequest);
 
-                const dataContractResponse = await driveClient.getDataContract(dataContractRequest);
+            const dataContractBuffer = Buffer.from(
+              dataContractResponse.getV0().getDataContract_asU8(),
+            );
+
+            dataContractsCache[dataContractIdString] = await dpp.dataContract
+              .createFromBuffer(dataContractBuffer, { skipValidation: true });
+          }
 
-                const dataContractBuffer = Buffer.from(
-                  dataContractResponse.getV0().getDataContract_asU8(),
+          const dataContract = dataContractsCache[dataContractIdString];
+
+          const tokenConfiguration = dataContract.getTokenConfiguration(
+            batchedTransition.getTokenContractPosition(),
+          );
+
+          // In case if we keep history for token events we can provide better proof
+          // for clients
+          if (tokenConfiguration.keepsHistory()) {
+            const documentRequest = new DocumentRequest();
+            documentRequest.setContractId(tokensHistoryContractIdBuffer);
+            documentRequest.setDocumentType(batchedTransition.getHistoricalDocumentTypeName());
+
+            const documentId = batchedTransition.getHistoricalDocumentId(
+              stateTransition.getOwnerId(),
+              batchedTransition.getIdentityContractNonce(),
+            );
+
+            documentRequest.setDocumentId(documentId.toBuffer());
+
+            documentsList.push(documentRequest);
+          } else {
+            // If not we can provide only balance / supply proofs
+            switch (batchedTransition.getTransitionType()) {
+              case TokenTransitionType.Burn: {
+                const request = new IdentityTokenBalanceRequest();
+                request.setTokenId(batchedTransition.getTokenId().toBuffer());
+                request.setIdentityId(stateTransition.getOwnerId().toBuffer());
+
+                identityTokenBalancesList.push(request);
+                break;
+              }
+              case TokenTransitionType.Mint: {
+                const request = new IdentityTokenBalanceRequest();
+                request.setTokenId(batchedTransition.getTokenId().toBuffer());
+                request.setIdentityId(
+                  batchedTransition.toTransition().getRecipientId(tokenConfiguration).toBuffer(),
                 );
 
-                dataContractsCache[dataContractIdString] = await dpp.dataContract
-                  .createFromBuffer(dataContractBuffer);
+                identityTokenBalancesList.push(request);
+                break;
               }
+              case TokenTransitionType.Transfer: {
+                const requestSender = new IdentityTokenBalanceRequest();
+                requestSender.setTokenId(batchedTransition.getTokenId().toBuffer());
+                requestSender.setIdentityId(stateTransition.getOwnerId().toBuffer());
+
+                const requestRecipient = new IdentityTokenBalanceRequest();
+                requestRecipient.setTokenId(batchedTransition.getTokenId().toBuffer());
+                requestRecipient.setIdentityId(
+                  batchedTransition.toTransition().getRecipientId().toBuffer(),
+                );
 
-              const dataContract = dataContractsCache[dataContractIdString];
+                identityTokenBalancesList.push(requestSender, requestRecipient);
+                break;
+              }
+              case TokenTransitionType.DestroyFrozenFunds: {
+                const request = new IdentityTokenBalanceRequest();
+                request.setTokenId(batchedTransition.getTokenId().toBuffer());
+                request.setIdentityId(
+                  batchedTransition.toTransition().getFrozenIdentityId().toBuffer(),
+                );
 
-              const tokenConfiguration = dataContract.getTokenConfiguration(
-                batchedTransition.getTokenContractPosition(),
-              );
+                identityTokenBalancesList.push(request);
+                break;
+              }
+              case TokenTransitionType.EmergencyAction:
+              {
+                const request = new TokenStatusRequest();
 
-              const request = new IdentityTokenBalanceRequest({
-                tokenId: batchedTransition.getTokenId()
-                  .toBuffer(),
-                identityId: batchedTransition.toTransition().getRecipientId(tokenConfiguration)
-                  .toBuffer(),
-              });
+                request.setTokenId(batchedTransition.getTokenId().toBuffer());
 
-              identityTokenBalancesList.push(request);
-              break;
-            }
-            case TokenTransitionType.Transfer: {
-              const requestSender = new IdentityTokenBalanceRequest({
-                tokenId: batchedTransition.getTokenId()
-                  .toBuffer(),
-                identityId: stateTransition.getOwnerId().toBuffer(),
-              });
-
-              const requestRecipient = new IdentityTokenBalanceRequest({
-                tokenId: batchedTransition.getTokenId()
-                  .toBuffer(),
-                identityId: batchedTransition.toTransition().getRecipientId()
-                  .toBuffer(),
-              });
-
-              identityTokenBalancesList.push(requestSender, requestRecipient);
-              break;
-            }
-            case TokenTransitionType.DestroyFrozenFunds: {
-              const request = new IdentityTokenBalanceRequest({
-                tokenId: batchedTransition.getTokenId()
-                  .toBuffer(),
-                identityId: batchedTransition.toTransition().getFrozenIdentityId()
-                  .toBuffer(),
-              });
-
-              identityTokenBalancesList.push(request);
-              break;
-            }
-            case TokenTransitionType.EmergencyAction:
-            {
-              const request = new TokenStatusRequest({
-                tokenId: batchedTransition.getTokenId()
-                  .toBuffer(),
-              });
-
-              tokenStatusesList.push(request);
-              break;
-            }
-            case TokenTransitionType.Freeze:
-            case TokenTransitionType.Unfreeze: {
-              const request = new IdentityTokenInfoRequest({
-                tokenId: batchedTransition.getTokenId()
-                  .toBuffer(),
-                identityId: batchedTransition.toTransition().getFrozenIdentityId()
-                  .toBuffer(),
-              });
-
-              identityTokenInfosList.push(request);
-              break;
+                tokenStatusesList.push(request);
+                break;
+              }
+              case TokenTransitionType.Freeze:
+              case TokenTransitionType.Unfreeze: {
+                const request = new IdentityTokenInfoRequest();
+                request.setTokenId(batchedTransition.getTokenId().toBuffer());
+                request.setIdentityId(
+                  batchedTransition.toTransition().getFrozenIdentityId().toBuffer(),
+                );
+
+                identityTokenInfosList.push(request);
+                break;
+              }
+              default:
+                throw new Error(`Unsupported token transition type ${batchedTransition.getTransitionType()}`);
             }
-            default:
-              throw new Error(`Unsupported token transition type ${batchedTransition.getTransitionType()}`);
           }
         } else if (batchedTransition instanceof DocumentTransition) {
           const documentRequest = new DocumentRequest();
@@ -254,6 +265,9 @@ function fetchProofForStateTransitionFactory(driveClient, dpp) {
     const request = new GetProofsRequest();
     request.setV0(requestV0);
 
+    // TODO: Remove logging
+    console.dir(request.toObject(), { depth: null });
+
     return driveClient.getProofs(request);
   }
 

packages/dapi/lib/grpcServer/handlers/platform/platformHandlersFactory.js

@@ -95,7 +95,7 @@ function platformHandlersFactory(
   );
 
   // waitForStateTransitionResult
-  const fetchProofForStateTransition = fetchProofForStateTransitionFactory(driveClient);
+  const fetchProofForStateTransition = fetchProofForStateTransitionFactory(driveClient, dpp);
 
   const getExistingTransactionResult = getExistingTransactionResultFactory(
     rpcClient,

packages/dapi/package.json

@@ -38,6 +38,7 @@
     "@dashevo/dashcore-lib": "~0.22.0",
     "@dashevo/dashd-rpc": "^19.0.0",
     "@dashevo/grpc-common": "workspace:*",
+    "@dashevo/token-history-contract": "workspace:*",
     "@dashevo/wasm-dpp": "workspace:*",
     "@grpc/grpc-js": "1.4.4",
     "@pshenmic/zeromq": "6.0.0-beta.22",

packages/dapi/scripts/api.js

@@ -131,7 +131,7 @@ async function main() {
   });
   logger.info(`JSON RPC server is listening on port ${config.rpcServer.port}`);
 
-  const dpp = new DashPlatformProtocol(null, 1);
+  const dpp = new DashPlatformProtocol(null, 9);
 
   // Start GRPC server
   logger.info('Starting GRPC server');