chore: unstoppable domain proxy (#404) (#405)

Author: cgilbe27

src/gql/heart-monitor/heart-monitor.test.ts

@@ -42,7 +42,6 @@ import {
   defaultInflationDistribution,
   GQLFeatureFlags,
   defaultFeatureFlags,
-  defaultProxy,
   GQLProxies,
   defaultInflationReward,
   featureFlagsQueryString,
@@ -54,6 +53,8 @@ import {
   GQLQueryGqlUserArgs,
   GQLEvm,
   defaultEvm,
+  defaultBybit,
+  defaultProxy,
 } from ".."
 
 const nibiruUrl = "testnet-2"
@@ -360,19 +361,23 @@ test.skip("oraclePricesSubscription", async () => {
   )
 })
 
-const testProxies = async (fields: GQLProxies) => {
-  const resp = await heartMonitor.proxies(fields)
+const testProxies = async (fields: GQLProxies, domainName?: string) => {
+  const resp = await heartMonitor.proxies(fields, domainName)
   expect(resp).toHaveProperty("proxies")
 
   if (resp.proxies) {
     const { proxies } = resp
 
-    checkFields([proxies], ["bybit"])
+    checkFields(
+      [proxies],
+      ["bybit", ...(domainName ? ["unstoppableDomains"] : [])]
+    )
   }
 }
 
 test("proxies", async () => {
-  await testProxies(defaultProxy)
+  await testProxies(defaultProxy, "cameron.nibi")
+  await testProxies({ bybit: defaultBybit })
 })
 
 const testEvm = async (fields: GQLEvm) => {

src/gql/heart-monitor/heart-monitor.ts

@@ -106,7 +106,10 @@ export interface IHeartMonitor {
     AsyncIterableIterator<ExecutionResult<GqlOutOraclePrices>> | undefined
   >
 
-  readonly proxies: (fields: DeepPartial<GQLProxies>) => Promise<GqlOutProxies>
+  readonly proxies: (
+    fields: DeepPartial<GQLProxies>,
+    domainName?: string
+  ) => Promise<GqlOutProxies>
 
   readonly evm: (fields: DeepPartial<GQLEvm>) => Promise<GqlOutEvm>
 
@@ -198,8 +201,8 @@ export class HeartMonitor implements IHeartMonitor {
     fields: DeepPartial<GQLOraclePrice>
   ) => oraclePricesSubscription(args, fields, this.subscriptionClient)
 
-  proxies = async (fields: DeepPartial<GQLProxies>) =>
-    proxies(this.gqlEndpt, fields)
+  proxies = async (fields: DeepPartial<GQLProxies>, domainName?: string) =>
+    proxies(this.gqlEndpt, fields, domainName)
 
   evm = async (fields: DeepPartial<GQLEvm>) => evm(this.gqlEndpt, fields)
 

src/gql/query/proxies.ts

@@ -12,18 +12,38 @@ export interface GqlOutProxies {
 }
 
 export const proxiesQueryString = (
-  excludeParentObject: boolean,
-  fields: DeepPartial<GQLProxies>
-) =>
-  gqlQuery(
-    "proxies",
-    {},
-    convertObjectToPropertiesString(fields),
-    excludeParentObject
-  )
+  fields: DeepPartial<GQLProxies>,
+  domainName?: string
+) => {
+  const proxiesQuery: string[] = []
+
+  if (fields.bybit) {
+    proxiesQuery.push(
+      gqlQuery("bybit", {}, convertObjectToPropertiesString(fields.bybit), true)
+    )
+  }
+
+  if (fields.unstoppableDomains) {
+    proxiesQuery.push(
+      gqlQuery(
+        "unstoppableDomains",
+        { domainName },
+        convertObjectToPropertiesString(fields.unstoppableDomains),
+        true
+      )
+    )
+  }
+
+  return `{
+    proxies {
+      ${proxiesQuery.join("\n")}
+    }
+  }`
+}
 
 export const proxies = async (
   endpt: string,
-  fields: DeepPartial<GQLProxies>
+  fields: DeepPartial<GQLProxies>,
+  domainName?: string
 ): Promise<GqlOutProxies> =>
-  doGqlQuery(proxiesQueryString(false, fields), endpt)
+  doGqlQuery(proxiesQueryString(fields, domainName), endpt)

src/gql/query/user.ts

@@ -16,14 +16,13 @@ export const userQueryString = (
   args: GQLQueryGqlUserArgs,
   excludeParentObject: boolean,
   fields: DeepPartial<GQLUser>
-) => {
-  return gqlQuery(
+) =>
+  gqlQuery(
     "user",
     args,
     convertObjectToPropertiesString(fields),
     excludeParentObject
   )
-}
 
 export const user = async (
   args: GQLQueryGqlUserArgs,

src/gql/utils/consts.ts

@@ -1,5 +1,4 @@
 import { fetch } from "cross-fetch"
-import { Client } from "graphql-ws"
 
 type OptionalArrayOr<T, Otherwise> = T extends T[] ? T[] | undefined : Otherwise
 type OptionalUndefinedOr<T, Otherwise> = T extends undefined
@@ -163,7 +162,9 @@ export const gqlQuery = <T>(
   delete typedQueryArgs.where
 
   Object.keys(typedQueryArgs).forEach((key) =>
-    queryArgList.push(arg<T>(key, typedQueryArgs[key], true))
+    // key !== "domainName" normally `true`, however domainName is a special case
+    // Will need to future proof this if more special cases arise
+    queryArgList.push(arg<T>(key, typedQueryArgs[key], key !== "domainName"))
   )
 
   const hasQueryList = (char: string) => (queryArgList.length > 0 ? char : "")

src/gql/utils/defaultObjects.ts

@@ -1,5 +1,6 @@
 import {
   GQLBlock,
+  GQLBybitResponse,
   GQLDelegation,
   GQLDistributionCommission,
   GQLEvm,
@@ -235,20 +236,45 @@ export const defaultFeatureFlags: GQLFeatureFlags = {
   wasm: true,
 }
 
+export const defaultBybit: GQLBybitResponse = {
+  ask1Price: "",
+  ask1Size: "",
+  bid1Price: "",
+  bid1Size: "",
+  highPrice24h: "",
+  lastPrice: "",
+  lowPrice24h: "",
+  prevPrice24h: "",
+  price24hPcnt: "",
+  symbol: "",
+  turnover24h: "",
+  volume24h: "",
+}
+
 export const defaultProxy: GQLProxies = {
-  bybit: {
-    ask1Price: "",
-    ask1Size: "",
-    bid1Price: "",
-    bid1Size: "",
-    highPrice24h: "",
-    lastPrice: "",
-    lowPrice24h: "",
-    prevPrice24h: "",
-    price24hPcnt: "",
-    symbol: "",
-    turnover24h: "",
-    volume24h: "",
+  bybit: defaultBybit,
+  unstoppableDomains: {
+    records: {
+      cryptoEthAddress: "",
+      cryptoNibiAddress: "",
+      ipfsHtmlValue: "",
+      tokenEvmEthEthAddress: "",
+      tokenEvmMaticMaticAddress: "",
+      tokenEvmMaticPolAddress: "",
+      tokenNibiNibiNibiAddress: "",
+    },
+    meta: {
+      blockchain: "",
+      domain: "",
+      namehash: "",
+      owner: "",
+      networkId: 0,
+      registry: "",
+      resolver: "",
+      tokenId: "",
+      reverse: false,
+      type: "",
+    },
   },
 }
 

src/gql/utils/generated.ts

@@ -512,7 +512,13 @@ export enum GQLOraclesOrder {
 
 export type GQLProxies = {
   readonly __typename?: 'Proxies';
-  readonly bybit: GQLBybitResponse;
+  readonly bybit?: Maybe<GQLBybitResponse>;
+  readonly unstoppableDomains?: Maybe<GQLUnstoppableDomainsResponse>;
+};
+
+
+export type GQLProxiesGqlUnstoppableDomainsArgs = {
+  domainName: Scalars['String']['input'];
 };
 
 export type GQLQuery = {
@@ -614,6 +620,17 @@ export type GQLQueryGqlValidatorsArgs = {
   where?: InputMaybe<GQLValidatorFilter>;
 };
 
+export type GQLRecords = {
+  readonly __typename?: 'Records';
+  readonly cryptoEthAddress?: Maybe<Scalars['String']['output']>;
+  readonly cryptoNibiAddress?: Maybe<Scalars['String']['output']>;
+  readonly ipfsHtmlValue?: Maybe<Scalars['String']['output']>;
+  readonly tokenEvmEthEthAddress?: Maybe<Scalars['String']['output']>;
+  readonly tokenEvmMaticMaticAddress?: Maybe<Scalars['String']['output']>;
+  readonly tokenEvmMaticPolAddress?: Maybe<Scalars['String']['output']>;
+  readonly tokenNibiNibiNibiAddress?: Maybe<Scalars['String']['output']>;
+};
+
 export type GQLRedelegation = {
   readonly __typename?: 'Redelegation';
   readonly amount: Scalars['Int']['output'];
@@ -824,6 +841,26 @@ export enum GQLUnbondingOrder {
   GQLValidatorAddress = 'validator_address'
 }
 
+export type GQLUnstoppableDomainsMeta = {
+  readonly __typename?: 'UnstoppableDomainsMeta';
+  readonly blockchain: Scalars['String']['output'];
+  readonly domain: Scalars['String']['output'];
+  readonly namehash: Scalars['String']['output'];
+  readonly networkId: Scalars['Int']['output'];
+  readonly owner: Scalars['String']['output'];
+  readonly registry: Scalars['String']['output'];
+  readonly resolver: Scalars['String']['output'];
+  readonly reverse: Scalars['Boolean']['output'];
+  readonly tokenId: Scalars['String']['output'];
+  readonly type: Scalars['String']['output'];
+};
+
+export type GQLUnstoppableDomainsResponse = {
+  readonly __typename?: 'UnstoppableDomainsResponse';
+  readonly meta: GQLUnstoppableDomainsMeta;
+  readonly records: GQLRecords;
+};
+
 export type GQLUser = {
   readonly __typename?: 'User';
   readonly address: Scalars['String']['output'];

src/gql/utils/schema.graphql

@@ -393,7 +393,8 @@ enum OraclesOrder {
 }
 
 type Proxies {
-  bybit: BybitResponse!
+  bybit: BybitResponse
+  unstoppableDomains(domainName: String!): UnstoppableDomainsResponse
 }
 
 type Query {
@@ -419,6 +420,16 @@ type Query {
   wasm: Wasm!
 }
 
+type Records {
+  cryptoEthAddress: String
+  cryptoNibiAddress: String
+  ipfsHtmlValue: String
+  tokenEvmEthEthAddress: String
+  tokenEvmMaticMaticAddress: String
+  tokenEvmMaticPolAddress: String
+  tokenNibiNibiNibiAddress: String
+}
+
 type Redelegation {
   amount: Int!
   completion_time: String!
@@ -565,6 +576,24 @@ enum UnbondingOrder {
   validator_address
 }
 
+type UnstoppableDomainsMeta {
+  blockchain: String!
+  domain: String!
+  namehash: String!
+  networkId: Int!
+  owner: String!
+  registry: String!
+  resolver: String!
+  reverse: Boolean!
+  tokenId: String!
+  type: String!
+}
+
+type UnstoppableDomainsResponse {
+  meta: UnstoppableDomainsMeta!
+  records: Records!
+}
+
 type User {
   address: String!
   all_balances: [Balance!]!