Various fixes from the deployed fork

api/Dockerfile

@@ -1,4 +1,4 @@
-FROM rust:1.80.1 as transformerBuilder
+FROM rust:1-bookworm as transformerBuilder
 WORKDIR /usr/src/myapp
 COPY ./transformer .
 RUN cargo install --path .

api/src/config/config.ts

@@ -14,7 +14,7 @@ export default (): Config => {
     },
 
     ol: {
-      provider: 'https://rpc.0l.fyi',
+      provider: ENV.RPC_PROVIDER_URL!,
       dataApiHost: ENV.DATA_API_HOST!,
       validatorHandlesUrl: ENV.VALIDATOR_HANDLES_URL || undefined,
       communityWalletsUrl: ENV.COMMUNITY_WALLETS_URL || undefined,

api/src/node-watcher/node-watcher.service.ts

@@ -12,13 +12,12 @@ import { S3Service } from '../s3/s3.service.js';
 import axios from 'axios';
 
 const LEDGER_VERSION_LIMIT = 30n;
+// Updated from https://github.com/petticur/seed-peers/blob/main/fullnode_seed_playlist.json
 const DEFAULT_UPSTREAMS = [
   '172.104.211.8',
-  '160.202.129.29',
-  '209.38.172.53',
-  '38.242.137.192',
-  '136.243.93.42',
-  '65.109.80.179',
+  '70.15.242.6',
+  '91.99.73.45',
+  '66.165.238.146',
 ];
 
 @Injectable()

api/src/ol/account.resolver.ts

@@ -36,6 +36,11 @@ export class AccountResolver {
     return this.olService.getSlowWallet(account.address);
   }
 
+  @ResolveField(() => Boolean, { nullable: true })
+  public async initialized(@Parent() account: Account): Promise<Boolean | null> {
+    return this.olService.getInitialized(account.address);
+  }
+
   @ResolveField(() => PaginatedMovements)
   public async movements(
     @Parent() account: Account,

api/src/ol/ol.service.ts

@@ -250,6 +250,15 @@ export class OlService {
     }
   }
 
+  public async getInitialized(address: Uint8Array): Promise<boolean> {
+    const res = await this.aptosClient.view({
+      function: '0x1::activity::is_initialized',
+      type_arguments: [],
+      arguments: [`0x${Buffer.from(address).toString('hex')}`],
+    });
+    return res[0] as boolean;
+  }
+
   public async getLatestStableVersion(): Promise<null | BN> {
     const js = this.natsService.jetstream;
     const kv = await js.views.kv('ol');

api/src/ol/validators/validators.processor.ts

@@ -35,7 +35,7 @@ export class ValidatorsProcessor extends WorkerHost {
 
     await this.validatorsQueue.add('updateValidatorsHandlersCache', undefined, {
       repeat: {
-        every: 12 * 60 * 60 * 1000, // 12 hours
+        every: 1 * 60 * 60 * 1000, // 1 hour -- beware if this triggers github rate limits
       },
     });
 

api/src/ol/validators/validators.service.ts

@@ -193,7 +193,9 @@ export class ValidatorsService {
         const balance = await this.olService.getAccountBalance(validator.address);
         const currentBid = await this.olService.getCurrentBid(validator.address);
         const slowWallet = await this.olService.getSlowWallet(validator.address);
-        const unlocked = Number(slowWallet?.unlocked);
+        // If we hit an uninitialized V7 slow wallet we need to override the unlocked balance as zero
+        const initialized = await this.olService.getInitialized(validator.address);
+        const unlocked = initialized ? Number(slowWallet?.unlocked) : Number(0);
         const addr = validator.address.toString('hex').toLocaleUpperCase();
         if (!handles.get(addr)) {
           this.logger.debug(`handles miss for address ${addr}`)

api/src/schema.gql

@@ -113,6 +113,7 @@ type Account {
   address: Bytes!
   balance: Decimal
   slowWallet: SlowWallet
+  reauthorized: Boolean!
   movements(first: Int! = 10, after: String, order: OrderDirection! = ASC): PaginatedMovements!
 }