Remove vault valuation service code.

Author: jpe7s

gradle/wrapper/gradle-wrapper.jar

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-9.3.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-9.4.0-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME

gradle/wrapper/gradle-wrapper.properties

@@ -38,7 +38,7 @@ class GlamAccountClientImpl implements GlamAccountClient {
     this.wrappedSolPDA = splAccountClient.wrappedSolPDA().publicKey();
     this.glamAccounts = glamVaultAccounts.glamAccounts();
     this.invokedProtocolProgram = glamAccounts.invokedProtocolProgram();
-    this.globalConfigKey = glamVaultAccounts.glamAccounts().globalConfigPDA().publicKey();
+    this.globalConfigKey = glamAccounts.globalConfigPDA().publicKey();
   }
 
   static ProtocolPermissions adaptPermissions(final GlamAccounts glamAccounts,

gradlew

@@ -47,7 +47,6 @@
   exports systems.glam.services.mints;
   exports systems.glam.services.oracles.scope.parsers;
   exports systems.glam.services.oracles.scope;
-  exports systems.glam.services.pricing.accounting;
   exports systems.glam.services.pricing;
   exports systems.glam.services.rpc;
   exports systems.glam.services.state;

sdk/src/main/java/systems/glam/sdk/GlamAccountClientImpl.java

@@ -16,10 +16,10 @@ public BaseDelegateService(final GlamAccountClient glamAccountClient) {
   }
 
   protected final StateAccount stateAccount(final Map<PublicKey, AccountInfo<byte[]>> accountsNeededMap) {
-    return StateAccount.read(accountsNeededMap.get(stateAccountKey()));
+    return StateAccount.read(accountsNeededMap.get(key()));
   }
 
-  public PublicKey stateAccountKey() {
+  public PublicKey key() {
     return glamAccountClient.vaultAccounts().glamStateKey();
   }
 }

services/src/main/java/module-info.java

@@ -13,6 +13,7 @@
 
 import java.nio.file.Path;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
 
 public interface ServiceContext {
 
@@ -51,6 +52,8 @@ default Path globalConfigCacheFile() {
 
   void executeTask(final Runnable task);
 
+  ExecutorService taskExecutor();
+
   void backoff(final long failureCount) throws InterruptedException;
 
   long minCheckStateDelayNanos();

services/src/main/java/systems/glam/services/BaseDelegateService.java

@@ -140,6 +140,11 @@ public void executeTask(final Runnable task) {
     taskExecutor.execute(task);
   }
 
+  @Override
+  public ExecutorService taskExecutor() {
+    return taskExecutor;
+  }
+
   @Override
   public void backoff(final long failureCount) throws InterruptedException {
     NANOSECONDS.sleep(Math.max(minCheckStateDelayNanos, backoff.delay(failureCount, NANOSECONDS)));

services/src/main/java/systems/glam/services/ServiceContext.java

@@ -8,6 +8,7 @@
 
 import java.nio.file.Path;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
 
 public class BaseServiceContext {
 
@@ -52,4 +53,8 @@ public final Path resolveGlamStateFilePath(final PublicKey glamStateKey) {
   public final void executeTask(final Runnable task) {
     serviceContext.executeTask(task);
   }
+
+  public final ExecutorService taskExecutor() {
+    return serviceContext.taskExecutor();
+  }
 }

services/src/main/java/systems/glam/services/ServiceContextImpl.java

@@ -8,23 +8,21 @@
 import software.sava.rpc.json.http.response.AccountInfo;
 import software.sava.services.solana.remote.call.RpcCaller;
 import systems.glam.services.ServiceContext;
-import systems.glam.services.db.sql.BatchSqlExecutor;
 import systems.glam.services.integrations.drift.DriftMarketCache;
 import systems.glam.services.integrations.kamino.KaminoCache;
 import systems.glam.services.mints.*;
 import systems.glam.services.oracles.scope.FeedIndexes;
-import systems.glam.services.pricing.accounting.VaultAumRecord;
 import systems.glam.services.rpc.AccountConsumer;
 import systems.glam.services.rpc.AccountFetcher;
 import systems.glam.services.state.GlobalConfigCache;
 
 import java.nio.file.Path;
 import java.util.Collection;
+import java.util.concurrent.ExecutorService;
 
 public interface IntegrationServiceContext {
 
   static IntegrationServiceContext createContext(final ServiceContext serviceContext,
-                                                 final BatchSqlExecutor<VaultAumRecord> aumRecordBatchExecutor,
                                                  final MintCache mintCache,
                                                  final StakePoolCache stakePoolCache,
                                                  final GlobalConfigCache globalConfigCache,
@@ -36,7 +34,6 @@ static IntegrationServiceContext createContext(final ServiceContext serviceConte
                                                  final KaminoCache kaminoCache) {
     return new IntegrationServiceContextImpl(
         serviceContext,
-        aumRecordBatchExecutor,
         mintCache,
         stakePoolCache,
         globalConfigCache,
@@ -65,6 +62,8 @@ default AccountMeta readClockSysVar() {
 
   void executeTask(final Runnable task);
 
+  ExecutorService taskExecutor();
+
   RpcCaller rpcCaller();
 
   MintContext mintContext(final PublicKey mint);
@@ -83,8 +82,6 @@ default AccountMeta readClockSysVar() {
 
   FeedIndexes scopeAggregateIndexes(final PublicKey mint, final PublicKey oracle, final OracleType oracleType);
 
-  void persistAumRecord(final VaultAumRecord aumRecord) throws InterruptedException;
-
   IntegLookupTableCache integTableCache();
 
   DriftMarketCache driftMarketCache();