From 93427ffa01854856bb1e23f3fc7bc9fbbb5f9a87 Mon Sep 17 00:00:00 2001
From: niks3089 <niks3089@gmail.com>
Date: Mon, 19 Feb 2024 14:28:19 +0530
Subject: [PATCH] das-api: Include mint-extensions in the response

---
 digital_asset_types/src/dapi/common/asset.rs | 28 ++++++++++++++++++++
 digital_asset_types/src/rpc/asset.rs         |  3 +++
 2 files changed, 31 insertions(+)

diff --git a/digital_asset_types/src/dapi/common/asset.rs b/digital_asset_types/src/dapi/common/asset.rs
index 655eefdc4..9fd9a3881 100644
--- a/digital_asset_types/src/dapi/common/asset.rs
+++ b/digital_asset_types/src/dapi/common/asset.rs
@@ -16,6 +16,7 @@ use log::warn;
 use mime_guess::Mime;
 
 use sea_orm::DbErr;
+use serde_json::Map;
 use serde_json::Value;
 use std::cmp::Ordering;
 use std::collections::HashMap;
@@ -47,6 +48,30 @@ pub fn file_from_str(str: String) -> File {
     }
 }
 
+fn filter_non_null_fields(value: Option<&Value>) -> Option<Value> {
+    match value {
+        Some(Value::Null) => None,
+        Some(Value::Object(map)) => {
+            if map.values().all(|v| matches!(v, Value::Null)) {
+                None
+            } else {
+                let filtered_map: Map<String, Value> = map
+                    .into_iter()
+                    .filter(|(_k, v)| !matches!(v, Value::Null))
+                    .map(|(k, v)| (k.clone(), v.clone()))
+                    .collect();
+
+                if filtered_map.is_empty() {
+                    None
+                } else {
+                    Some(Value::Object(filtered_map))
+                }
+            }
+        }
+        _ => value.cloned(),
+    }
+}
+
 pub fn build_asset_response(
     assets: Vec<FullAsset>,
     limit: u64,
@@ -368,6 +393,8 @@ pub fn asset_to_rpc(asset: FullAsset, options: &Options) -> Result<RpcAsset, DbE
         .unwrap_or(false);
     let edition_nonce =
         safe_select(chain_data_selector, "$.edition_nonce").and_then(|v| v.as_u64());
+
+    let mint_ext = filter_non_null_fields(asset.mint_extensions.as_ref());
     Ok(RpcAsset {
         interface: interface.clone(),
         id: bs58::encode(asset.id).into_string(),
@@ -435,6 +462,7 @@ pub fn asset_to_rpc(asset: FullAsset, options: &Options) -> Result<RpcAsset, DbE
             remaining: u.get("remaining").and_then(|t| t.as_u64()).unwrap_or(0),
         }),
         burnt: asset.burnt,
+        mint_extensions: mint_ext,
     })
 }
 
diff --git a/digital_asset_types/src/rpc/asset.rs b/digital_asset_types/src/rpc/asset.rs
index 415b63672..bd468a194 100644
--- a/digital_asset_types/src/rpc/asset.rs
+++ b/digital_asset_types/src/rpc/asset.rs
@@ -6,6 +6,7 @@ use std::collections::BTreeMap;
 
 use crate::dao::sea_orm_active_enums::ChainMutability;
 use schemars::JsonSchema;
+use serde_json::Value;
 use {
     serde::{Deserialize, Serialize},
     std::collections::HashMap,
@@ -364,4 +365,6 @@ pub struct Asset {
     pub supply: Option<Supply>,
     pub mutable: bool,
     pub burnt: bool,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub mint_extensions: Option<Value>,
 }