[graphql]suins lookup (#14197)

## Description 

implement resolveNameServiceAddress on top-level Query resolver +
nameServiceConnection for objectOwner.

Not keen on importing all of sui-json-rpc just to get access to the
NameService type. Made a copy in sui-graphql-rpc, but thoughts on doing
something like lifting the type to sui-json-rpc-types?
<img width="965" alt="Screenshot 2023-10-10 at 3 47 22 PM"
src="https://github.com/MystenLabs/sui/assets/127570466/01ffaf21-dba5-493f-a5dd-8f637af24c15">

Not clear on what defaultNameServiceName should be ... is this intended
to be the first/ primary name returned by
https://docs.sui.io/sui-jsonrpc#suix_resolveNameServiceNames



## Test Plan 

How did you test the new or updated feature?

---
If your changes are not user-facing and not a breaking change, you can
skip the following section. Otherwise, please indicate what changed, and
then add to the Release Notes section as highlighted during the release
process.

### Type of Change (Check all that apply)

- [ ] protocol change
- [ ] user-visible impact
- [ ] breaking change for a client SDKs
- [ ] breaking change for FNs (FN binary must upgrade)
- [ ] breaking change for validators or node operators (must upgrade
binaries)
- [ ] breaking change for on-chain data layout
- [ ] necessitate either a data wipe or data migration

### Release notes

Author: wlmyng

Cargo.lock

@@ -39,6 +39,7 @@ uuid.workspace = true
 # Used for dummy data
 bcs.workspace = true
 sui-sdk.workspace = true
+sui-json-rpc.workspace = true
 sui-json-rpc-types.workspace = true
 sui-indexer.workspace = true
 sui-types.workspace = true

crates/sui-graphql-rpc/Cargo.toml

@@ -0,0 +1,14 @@
+{
+  resolveNameServiceAddress(name:"example.sui") {
+    location
+  }
+  address(address:"0x0b86be5d779fac217b41d484b8040ad5145dc9ba0cba099d083c6cbda50d983e"){
+    location
+    balance(type:"0x2::sui::SUI") {
+      coinType
+      coinObjectCount
+      totalBalance
+    }
+    defaultNameServiceName
+  }
+}

crates/sui-graphql-rpc/examples/name_service/name_service.graphql

@@ -498,6 +498,7 @@ type Query {
 	transactionBlockConnection(first: Int, after: String, last: Int, before: String, filter: TransactionBlockFilter): TransactionBlockConnection
 	objectConnection(first: Int, after: String, last: Int, before: String, filter: ObjectFilter): ObjectConnection
 	protocolConfig(protocolVersion: Int): ProtocolConfigs!
+	resolveNameServiceAddress(name: String!): Address
 }
 
 type SafeMode {

crates/sui-graphql-rpc/schema/current_progress_schema.graphql

@@ -45,8 +45,10 @@ use sui_indexer::{
     schema_v2::{checkpoints, epochs, objects, packages, transactions, tx_indices},
     PgConnectionPoolConfig,
 };
+use sui_json_rpc::name_service::{Domain, NameRecord, NameServiceConfig};
 use sui_json_rpc_types::SuiTransactionBlockEffects;
 use sui_sdk::types::{
+    base_types::SuiAddress as NativeSuiAddress,
     digests::ChainIdentifier,
     effects::TransactionEffects,
     messages_checkpoint::{
@@ -58,6 +60,7 @@ use sui_sdk::types::{
         GenesisObject, SenderSignedData, TransactionDataAPI, TransactionExpiration, TransactionKind,
     },
 };
+use sui_types::dynamic_field::Field;
 
 use super::DEFAULT_PAGE_SIZE;
 
@@ -958,6 +961,55 @@ impl PgManager {
             Ok(None)
         }
     }
+
+    pub(crate) async fn resolve_name_service_address(
+        &self,
+        name_service_config: &NameServiceConfig,
+        name: String,
+    ) -> Result<Option<Address>, Error> {
+        let domain = name.parse::<Domain>()?;
+
+        let record_id = name_service_config.record_field_id(&domain);
+
+        let field_record_object = match self.inner.get_object_in_blocking_task(record_id).await? {
+            Some(o) => o,
+            None => return Ok(None),
+        };
+
+        let record = field_record_object
+            .to_rust::<Field<Domain, NameRecord>>()
+            .ok_or_else(|| Error::Internal(format!("Malformed Object {record_id}")))?
+            .value;
+
+        Ok(record.target_address.map(|address| Address {
+            address: SuiAddress::from_array(address.to_inner()),
+        }))
+    }
+
+    pub(crate) async fn default_name_service_name(
+        &self,
+        name_service_config: &NameServiceConfig,
+        address: SuiAddress,
+    ) -> Result<Option<String>, Error> {
+        let reverse_record_id =
+            name_service_config.reverse_record_field_id(NativeSuiAddress::from(address));
+
+        let field_reverse_record_object = match self
+            .inner
+            .get_object_in_blocking_task(reverse_record_id)
+            .await?
+        {
+            Some(o) => o,
+            None => return Ok(None),
+        };
+
+        let domain = field_reverse_record_object
+            .to_rust::<Field<SuiAddress, Domain>>()
+            .ok_or_else(|| Error::Internal(format!("Malformed Object {reverse_record_id}")))?
+            .value;
+
+        Ok(Some(domain.to_string()))
+    }
 }
 
 impl TryFrom<StoredCheckpoint> for Checkpoint {

crates/sui-graphql-rpc/src/context_data/db_data_provider.rs

@@ -4,6 +4,7 @@
 use async_graphql::{ErrorExtensionValues, ErrorExtensions, Response, ServerError};
 use async_graphql_axum::GraphQLResponse;
 use sui_indexer::errors::IndexerError;
+use sui_json_rpc::name_service::DomainParseError;
 
 use crate::context_data::db_data_provider::DbValidationError;
 
@@ -45,6 +46,8 @@ pub(crate) fn graphql_error(code: &str, message: impl Into<String>) -> ServerErr
 
 #[derive(Debug, thiserror::Error)]
 pub enum Error {
+    #[error(transparent)]
+    DomainParse(#[from] DomainParseError),
     #[error(transparent)]
     DbValidation(#[from] DbValidationError),
     #[error("Provide one of digest or sequence_number, not both")]
@@ -72,7 +75,8 @@ pub enum Error {
 impl ErrorExtensions for Error {
     fn extend(&self) -> async_graphql::Error {
         async_graphql::Error::new(format!("{}", self)).extend_with(|_err, e| match self {
-            Error::DbValidation(_)
+            Error::DomainParse(_)
+            | Error::DbValidation(_)
             | Error::InvalidCheckpointQuery
             | Error::CursorNoBeforeAfter
             | Error::CursorNoFirstLast

crates/sui-graphql-rpc/src/error.rs

@@ -137,7 +137,6 @@ mod tests {
             ("Query", "coinMetadata"),
             ("Query", "moveCallMetrics"),
             ("Query", "networkMetrics"),
-            ("Query", "resolveNameServiceAddress"),
             ("Subscription", "events"),
             ("Subscription", "transactions"),
         ]);

crates/sui-graphql-rpc/src/functional_group.rs

@@ -17,6 +17,7 @@ use std::default::Default;
 use std::env;
 use std::net::SocketAddr;
 use std::sync::Arc;
+use sui_json_rpc::name_service::NameServiceConfig;
 
 static PROM_ADDR: &str = "0.0.0.0:9184";
 
@@ -37,6 +38,7 @@ pub async fn start_example_server(conn: ConnectionConfig, service_config: Servic
             e
         })
         .unwrap();
+    let name_service_config = NameServiceConfig::default();
 
     let prom_addr: SocketAddr = PROM_ADDR.parse().unwrap();
     let registry = start_prom(prom_addr);
@@ -52,6 +54,7 @@ pub async fn start_example_server(conn: ConnectionConfig, service_config: Servic
         .context_data(data_loader)
         .context_data(service_config)
         .context_data(pg_conn_pool)
+        .context_data(name_service_config)
         .context_data(Arc::new(metrics))
         .extension(QueryLimitsChecker::default())
         .extension(FeatureGate)

crates/sui-graphql-rpc/src/server/simple_server.rs

@@ -2,13 +2,14 @@
 // SPDX-License-Identifier: Apache-2.0
 
 use async_graphql::{connection::Connection, *};
+use sui_json_rpc::name_service::NameServiceConfig;
 
 use crate::context_data::db_data_provider::PgManager;
 
-use super::name_service::NameService;
 use super::{
     balance::Balance,
     coin::Coin,
+    name_service::NameService,
     object::{Object, ObjectFilter},
     stake::Stake,
     sui_address::SuiAddress,
@@ -128,17 +129,21 @@ impl Address {
         unimplemented!()
     }
 
-    pub async fn default_name_service_name(&self) -> Option<String> {
-        unimplemented!()
+    pub async fn default_name_service_name(&self, ctx: &Context<'_>) -> Result<Option<String>> {
+        ctx.data_unchecked::<PgManager>()
+            .default_name_service_name(ctx.data_unchecked::<NameServiceConfig>(), self.address)
+            .await
+            .extend()
     }
 
     pub async fn name_service_connection(
         &self,
+        ctx: &Context<'_>,
         first: Option<u64>,
         after: Option<String>,
         last: Option<u64>,
         before: Option<String>,
-    ) -> Option<Connection<String, NameService>> {
+    ) -> Result<Option<Connection<String, NameService>>> {
         unimplemented!()
     }
 }

crates/sui-graphql-rpc/src/types/address.rs

@@ -5,5 +5,5 @@ use async_graphql::*;
 use serde::{Deserialize, Serialize};
 
 #[derive(Clone, Eq, PartialEq, Debug, Serialize, Deserialize)]
-pub(crate) struct NameService(String);
+pub(crate) struct NameService(pub String);
 scalar!(NameService, "NameService");