feat: use json rpc apis for IOTA-Names reads

crates/iota-indexer/src/apis/indexer_api.rs

@@ -13,8 +13,8 @@ use iota_json_rpc_types::{
     IotaTransactionBlockResponseQuery, ObjectsPage, Page, TransactionBlocksPage, TransactionFilter,
 };
 use iota_names::{
-    IotaNamesNft, IotaNamesRegistration, config::IotaNamesConfig, domain::Domain,
-    error::IotaNamesError, registry::NameRecord,
+    IotaNamesNft, IotaNamesRegistration, SubdomainRegistration, config::IotaNamesConfig,
+    domain::Domain, error::IotaNamesError, registry::NameRecord,
 };
 use iota_open_rpc::Module;
 use iota_types::{
@@ -463,6 +463,27 @@ impl IndexerApiServer for IndexerApi {
 
         Ok(owned_objects)
     }
+
+    async fn iota_names_find_all_subdomain_nfts(
+        &self,
+        address: IotaAddress,
+        cursor: Option<ObjectID>,
+        limit: Option<usize>,
+        options: Option<IotaObjectDataOptions>,
+    ) -> RpcResult<ObjectsPage> {
+        let query = IotaObjectResponseQuery {
+            filter: Some(IotaObjectDataFilter::StructType(
+                SubdomainRegistration::type_(self.iota_names_config.package_address.into()),
+            )),
+            options,
+        };
+
+        let owned_objects = self
+            .get_owned_objects(address, Some(query), cursor, limit)
+            .await?;
+
+        Ok(owned_objects)
+    }
 }
 
 impl IotaRpcModule for IndexerApi {

crates/iota-json-rpc-api/src/indexer.rs

@@ -149,4 +149,14 @@ pub trait IndexerApi {
         limit: Option<usize>,
         options: Option<IotaObjectDataOptions>,
     ) -> RpcResult<ObjectsPage>;
+
+    /// Find all subdomain NFTs for the given address.
+    #[method(name = "iotaNamesFindAllSubdomainNFTs")]
+    async fn iota_names_find_all_subdomain_nfts(
+        &self,
+        address: IotaAddress,
+        cursor: Option<ObjectID>,
+        limit: Option<usize>,
+        options: Option<IotaObjectDataOptions>,
+    ) -> RpcResult<ObjectsPage>;
 }

crates/iota-json-rpc/src/indexer_api.rs

@@ -21,8 +21,8 @@ use iota_json_rpc_types::{
 };
 use iota_metrics::spawn_monitored_task;
 use iota_names::{
-    IotaNamesNft, IotaNamesRegistration, config::IotaNamesConfig, domain::Domain,
-    error::IotaNamesError, registry::NameRecord,
+    IotaNamesNft, IotaNamesRegistration, SubdomainRegistration, config::IotaNamesConfig,
+    domain::Domain, error::IotaNamesError, registry::NameRecord,
 };
 use iota_open_rpc::Module;
 use iota_storage::key_value_store::TransactionKeyValueStore;
@@ -582,6 +582,28 @@ impl<R: ReadApiServer> IndexerApiServer for IndexerApi<R> {
 
         Ok(owned_objects)
     }
+
+    #[instrument(skip(self))]
+    async fn iota_names_find_all_subdomain_nfts(
+        &self,
+        address: IotaAddress,
+        cursor: Option<ObjectID>,
+        limit: Option<usize>,
+        options: Option<IotaObjectDataOptions>,
+    ) -> RpcResult<ObjectsPage> {
+        let query = IotaObjectResponseQuery {
+            filter: Some(IotaObjectDataFilter::StructType(
+                SubdomainRegistration::type_(self.iota_names_config.package_address.into()),
+            )),
+            options,
+        };
+
+        let owned_objects = self
+            .get_owned_objects(address, Some(query), cursor, limit)
+            .await?;
+
+        Ok(owned_objects)
+    }
 }
 
 impl<R: ReadApiServer> IotaRpcModule for IndexerApi<R> {

crates/iota-open-rpc/spec/openrpc.json

@@ -4636,6 +4636,51 @@
         }
       }
     },
+    {
+      "name": "iotax_iotaNamesFindAllSubdomainNFTs",
+      "tags": [
+        {
+          "name": "Extended API"
+        }
+      ],
+      "description": "Find all subdomain NFTs for the given address.",
+      "params": [
+        {
+          "name": "address",
+          "required": true,
+          "schema": {
+            "$ref": "#/components/schemas/IotaAddress"
+          }
+        },
+        {
+          "name": "cursor",
+          "schema": {
+            "$ref": "#/components/schemas/ObjectID"
+          }
+        },
+        {
+          "name": "limit",
+          "schema": {
+            "type": "integer",
+            "format": "uint",
+            "minimum": 0.0
+          }
+        },
+        {
+          "name": "options",
+          "schema": {
+            "$ref": "#/components/schemas/ObjectDataOptions"
+          }
+        }
+      ],
+      "result": {
+        "name": "ObjectsPage",
+        "required": true,
+        "schema": {
+          "$ref": "#/components/schemas/Page_for_IotaObjectResponse_and_ObjectID"
+        }
+      }
+    },
     {
       "name": "iotax_iotaNamesLookup",
       "tags": [

crates/iota/Cargo.toml

@@ -69,6 +69,7 @@ iota-graphql-rpc = { workspace = true, optional = true }
 iota-graphql-rpc-client = { workspace = true, optional = true }
 iota-indexer = { workspace = true, optional = true }
 iota-json.workspace = true
+iota-json-rpc-api.workspace = true
 iota-json-rpc-types.workspace = true
 iota-keys.workspace = true
 iota-move.workspace = true