feat: support creating roles based on Realms governance power

Author: beeman

.env.example

@@ -66,6 +66,8 @@ FEATURE_PRIVATE_PROFILES=false
 #FEATURE_RESOLVER_SOLANA_FUNGIBLE=true
 # Enable resolver for Solana Non-Fungible Tokens
 #FEATURE_RESOLVER_SOLANA_NON_FUNGIBLE=true
+# Enable resolver for Solana Realms Voters
+#FEATURE_RESOLVER_SOLANA_REALMS=true
 # Enable resolver for Solana Validators
 #FEATURE_RESOLVER_SOLANA_VALIDATOR=false
 # Enable Network Asset Verification

api-schema.graphql

@@ -629,6 +629,7 @@ enum NetworkResolver {
   Anybodies
   SolanaFungible
   SolanaNonFungible
+  SolanaRealms
   SolanaValidator
 }
 
@@ -658,6 +659,7 @@ type NetworkTokenPaging {
 enum NetworkTokenType {
   Fungible
   NonFungible
+  RealmsVoter
   Validator
 }
 

libs/api/core/data-access/src/lib/config/api-core-config.service.ts

@@ -39,6 +39,9 @@ export class ApiCoreConfigService {
     if (this.featureResolverSolanaNonFungible) {
       resolvers.push(NetworkResolver.SolanaNonFungible)
     }
+    if (this.featureResolverSolanaRealms) {
+      resolvers.push(NetworkResolver.SolanaRealms)
+    }
     if (this.featureResolverSolanaValidator) {
       resolvers.push(NetworkResolver.SolanaValidator)
     }
@@ -252,6 +255,10 @@ export class ApiCoreConfigService {
     return this.service.get<boolean>('featureResolverSolanaNonFungible')
   }
 
+  get featureResolverSolanaRealms() {
+    return this.service.get<boolean>('featureResolverSolanaRealms')
+  }
+
   get featureResolverSolanaValidator() {
     return this.service.get<boolean>('featureResolverSolanaValidator')
   }

libs/api/core/data-access/src/lib/config/configuration.ts

@@ -70,6 +70,7 @@ export interface ApiCoreConfig {
   featurePubkeyProtocol: boolean
   featureResolverSolanaFungible: boolean
   featureResolverSolanaNonFungible: boolean
+  featureResolverSolanaRealms: boolean
   featureResolverSolanaValidator: boolean
   // Host
   host: string
@@ -140,6 +141,7 @@ export function configuration(): ApiCoreConfig {
     featurePubkeyProtocol: process.env['FEATURE_PUBKEY_PROTOCOL'] === 'true',
     featureResolverSolanaFungible: process.env['FEATURE_RESOLVER_SOLANA_FUNGIBLE'] === 'true',
     featureResolverSolanaNonFungible: process.env['FEATURE_RESOLVER_SOLANA_NON_FUNGIBLE'] === 'true',
+    featureResolverSolanaRealms: process.env['FEATURE_RESOLVER_SOLANA_REALMS'] === 'true',
     featureResolverSolanaValidator: process.env['FEATURE_RESOLVER_SOLANA_VALIDATOR'] === 'true',
     host: process.env['HOST'] as string,
     logColor: process.env['LOG_COLOR'] === 'true',

libs/api/core/data-access/src/lib/config/validation-schema.ts

@@ -46,6 +46,7 @@ export const validationSchema = Joi.object({
   FEATURE_PUBKEY_PROTOCOL: Joi.boolean().default(false),
   FEATURE_RESOLVER_SOLANA_FUNGIBLE: Joi.boolean().default(true),
   FEATURE_RESOLVER_SOLANA_NON_FUNGIBLE: Joi.boolean().default(true),
+  FEATURE_RESOLVER_SOLANA_REALMS: Joi.boolean().default(true),
   FEATURE_RESOLVER_SOLANA_VALIDATOR: Joi.boolean().default(false),
   FEATURE_VERIFY_NETWORK_ASSETS: Joi.boolean().default(false),
   GRAPHQL_PLAYGROUND: Joi.boolean().default(false),

libs/api/network-asset/data-access/src/lib/api-network-asset-sync.service.ts

@@ -190,9 +190,10 @@ export class ApiNetworkAssetSyncService {
     // Get the fungible and non-fungible tokens for the cluster
     const solanaFungibleTokens: NetworkToken[] = tokens.filter((t) => t.type === NetworkTokenType.Fungible)
     const solanaNonFungibleTokens: NetworkToken[] = tokens.filter((t) => t.type === NetworkTokenType.NonFungible)
+    const solanaRealmsVoterTokens: NetworkToken[] = tokens.filter((t) => t.type === NetworkTokenType.RealmsVoter)
 
     this.logger.verbose(
-      `[${cluster}] syncIdentity: Syncing assets for ${owner} on ${cluster}, solanaFungibleTokens: ${solanaFungibleTokens.length}, solanaNonFungibleTokens: ${solanaNonFungibleTokens.length},`,
+      `[${cluster}] syncIdentity: Syncing assets for ${owner} on ${cluster}, solanaFungibleTokens: ${solanaFungibleTokens.length}, solanaNonFungibleTokens: ${solanaNonFungibleTokens.length}, solanaRealmsVoterTokens: ${solanaRealmsVoterTokens.length},`,
     )
     // TODO: Move the resolveNetworkAssets function into a separate method
     let assets: NetworkAssetInput[] = []
@@ -202,6 +203,7 @@ export class ApiNetworkAssetSyncService {
         owner,
         solanaFungibleTokens,
         solanaNonFungibleTokens,
+        solanaRealmsVoterTokens,
       })
     } catch (error) {
       this.logger.error(`[${cluster}] syncIdentity: Error syncing assets for ${owner} on ${cluster}: ${error}`)

libs/api/network-asset/data-access/src/lib/api-network-asset.service.ts

@@ -53,4 +53,23 @@ export class ApiNetworkAssetService {
       },
     })
   }
+
+  async getRealmsVoterAssetsForOwners({
+    accounts,
+    cluster,
+    owners,
+  }: {
+    accounts: string[]
+    cluster: NetworkCluster
+    owners: string[]
+  }) {
+    return this.core.data.networkAsset.findMany({
+      where: {
+        cluster,
+        group: { in: accounts },
+        owner: { in: owners },
+        type: NetworkTokenType.RealmsVoter,
+      },
+    })
+  }
 }

libs/api/network-token/data-access/src/lib/api-network-token-data.service.ts

@@ -3,7 +3,7 @@ import { OnEvent } from '@nestjs/event-emitter'
 import { NetworkCluster, NetworkToken, NetworkTokenType, Prisma } from '@prisma/client'
 import { ApiCoreService, EVENT_APP_STARTED, PagingInputFields } from '@pubkey-link/api-core-data-access'
 import { ApiNetworkService, EVENT_NETWORKS_PROVISIONED } from '@pubkey-link/api-network-data-access'
-import { getNetworkTokenType } from '@pubkey-link/api-network-util'
+import { getNetworkTokenType, REALMS_PROGRAM_ID } from '@pubkey-link/api-network-util'
 import { SystemProgram } from '@solana/web3.js'
 import { AdminUpdateNetworkTokenInput } from './dto/admin-update-network-token.input'
 import { NetworkTokenPaging } from './entity/network-token.entity'
@@ -89,6 +89,8 @@ export class ApiNetworkTokenDataService {
     const type =
       info.owner.toString() === 'CoREENxT6tW1HoK8ypY1SxRMZTcVPm7R94rH4PZNhX7d'
         ? NetworkTokenType.NonFungible
+        : info.owner.toString() === REALMS_PROGRAM_ID
+        ? NetworkTokenType.RealmsVoter
         : getNetworkTokenType(info?.data?.program)
 
     const data: Prisma.NetworkTokenCreateInput = {

libs/api/network/data-access/src/lib/api-network.data-access.module.ts

@@ -8,6 +8,7 @@ import { ApiNetworkProvisionService } from './provision/api-network-provision.se
 import { ApiNetworkResolverSolanaFungibleService } from './resolver/api-network-resolver-solana-fungible.service'
 import { ApiNetworkResolverSolanaNonFungibleService } from './resolver/api-network-resolver-solana-non-fungible.service'
 import { ApiNetworkResolverService } from './resolver/api-network-resolver.service'
+import { ApiNetworkResolverRealmsVoterService } from './resolver/api-network-resolver-realms-voter.service'
 
 @Module({
   imports: [ApiCoreDataAccessModule],
@@ -16,6 +17,7 @@ import { ApiNetworkResolverService } from './resolver/api-network-resolver.servi
     ApiNetworkDataAdminService,
     ApiNetworkDataService,
     ApiNetworkProvisionService,
+    ApiNetworkResolverRealmsVoterService,
     ApiNetworkResolverService,
     ApiNetworkResolverSolanaFungibleService,
     ApiNetworkResolverSolanaNonFungibleService,

libs/api/network/data-access/src/lib/api-network.service.ts

@@ -1,9 +1,15 @@
 import { DasApiAsset } from '@metaplex-foundation/digital-asset-standard-api'
 import { publicKey } from '@metaplex-foundation/umi'
 import { Injectable, Logger } from '@nestjs/common'
-import { NetworkCluster, Prisma } from '@prisma/client'
+import { NetworkCluster, NetworkTokenType, Prisma } from '@prisma/client'
 import { ApiCoreService } from '@pubkey-link/api-core-data-access'
-import { getMetadataProgram, getNetworkTokenType, WNS_PROGRAM_ID } from '@pubkey-link/api-network-util'
+import {
+  getMetadataProgram,
+  getNetworkTokenType,
+  getRealm,
+  REALMS_PROGRAM_ID,
+  WNS_PROGRAM_ID,
+} from '@pubkey-link/api-network-util'
 import { getTokenMetadata, TOKEN_2022_PROGRAM_ID, TOKEN_PROGRAM_ID } from '@solana/spl-token'
 import { TokenMetadata } from '@solana/spl-token-metadata'
 import { AccountInfo, BlockhashWithExpiryBlockHeight, ParsedAccountData, PublicKey } from '@solana/web3.js'
@@ -47,6 +53,26 @@ export class ApiNetworkService {
     return res.blockhash
   }
 
+  async getRealmsMetadata({
+    cluster,
+    account,
+  }: {
+    cluster: NetworkCluster
+    account: PublicKey | string
+  }): Promise<Prisma.NetworkTokenCreateInput> {
+    const found = await getRealm({ realm: account.toString() })
+    if (!found) {
+      throw new Error(`Realm not found`)
+    }
+    return {
+      account: account.toString(),
+      type: NetworkTokenType.RealmsVoter,
+      name: found.name,
+      program: found.program,
+      network: { connect: { cluster } },
+      raw: found,
+    }
+  }
   async getAccountInfo({ cluster, account }: { cluster: NetworkCluster; account: PublicKey | string }) {
     return this.cluster
       .getConnection(cluster)
@@ -70,6 +96,11 @@ export class ApiNetworkService {
   }
 
   async getAllTokenMetadata({ cluster, account }: { cluster: NetworkCluster; account: string }) {
+    const info = await this.getAccountInfo({ account, cluster })
+    if (info.owner.toString() === REALMS_PROGRAM_ID) {
+      return this.getRealmsMetadata({ account, cluster })
+    }
+
     const asset = await this.getAsset({ cluster: cluster, account: account })
 
     // If we have the group pointer, we can fetch the members of the group to create a list of mints