Refactor GlobalConfigCache to integrate listener-based change notifications and enhance validation logic. Remove unused ScopeMonitorServiceEntrypoint.

Author: jpe7s

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

@@ -29,6 +29,7 @@
   requires java.sql;
   requires com.zaxxer.hikari;
   requires org.postgresql.jdbc;
+  requires java.desktop;
 
   uses SqlDataSource.Factory;
   provides SqlDataSource.Factory with PostgresDataSourceFactory;

services/src/main/java/systems/glam/services/mints/AssetMetaContext.java

@@ -7,14 +7,13 @@
 import systems.glam.sdk.idl.programs.glam.config.gen.types.GlobalConfig;
 import systems.glam.sdk.idl.programs.glam.config.gen.types.OracleSource;
 
-import java.util.Arrays;
-
 public interface AssetMetaContext extends Comparable<AssetMetaContext>, DecimalInteger {
 
-  static AssetMetaContext create(final AssetMeta assetMeta) {
+  static AssetMetaContext create(final int index, final AssetMeta assetMeta) {
     final var asset = assetMeta.asset();
     final var oracle = assetMeta.oracle();
     return new AssetMetaContextRecord(
+        index,
         assetMeta.asset(),
         AccountMeta.createRead(asset),
         assetMeta.decimals(),
@@ -27,9 +26,16 @@ static AssetMetaContext create(final AssetMeta assetMeta) {
   }
 
   static AssetMetaContext[] mapAssetMetas(final GlobalConfig globalConfig) {
-    return Arrays.stream(globalConfig.assetMetas()).map(AssetMetaContext::create).toArray(AssetMetaContext[]::new);
+    final var assetMetas = globalConfig.assetMetas();
+    final var assetMetaContext = new AssetMetaContext[assetMetas.length];
+    for (int i = 0; i < assetMetas.length; i++) {
+      assetMetaContext[i] = AssetMetaContext.create(i, assetMetas[i]);
+    }
+    return assetMetaContext;
   }
 
+  int index();
+
   PublicKey asset();
 
   AccountMeta readAssetMint();

services/src/main/java/systems/glam/services/mints/AssetMetaContextRecord.java

@@ -4,7 +4,8 @@
 import software.sava.core.accounts.meta.AccountMeta;
 import systems.glam.sdk.idl.programs.glam.config.gen.types.OracleSource;
 
-public record AssetMetaContextRecord(PublicKey asset,
+public record AssetMetaContextRecord(int index,
+                                     PublicKey asset,
                                      AccountMeta readAssetMint,
                                      int decimals,
                                      PublicKey oracle,
@@ -33,13 +34,15 @@ public int compareTo(final AssetMetaContext o) {
   public String toJson() {
     return String.format("""
             {
+             "index": %d,
              "asset": "%s",
              "decimals": %d,
              "oracle": "%s",
              "oracleSource": "%s",
              "priority": %d,
              "maxAgeSeconds": %d
             }""",
+        index,
         asset.toBase58(),
         decimals,
         oracle.toBase58(),

services/src/main/java/systems/glam/services/oracles/scope/ScopeMonitorServiceEntrypoint.java

@@ -39,7 +39,7 @@ static CompletableFuture<GlobalConfigCache> initCache(final Path globalConfigFil
         final var globalConfig = GlobalConfig.read(globalConfigKey, data);
         final var assetMetaContexts = AssetMetaContext.mapAssetMetas(globalConfig);
         final var assetMetaMap = createMap(assetMetaContexts);
-        final var globalConfigUpdate = new GlobalConfigCacheImpl.GlobalConfigUpdate(0, assetMetaContexts, data);
+        final var globalConfigUpdate = new GlobalConfigUpdate(0, assetMetaContexts, data);
         final var cache = new GlobalConfigCacheImpl(
             globalConfigFilePath,
             configProgram, globalConfigKey,
@@ -69,7 +69,7 @@ static CompletableFuture<GlobalConfigCache> initCache(final Path globalConfigFil
           final var globalConfig = GlobalConfig.read(accountInfo.pubKey(), data);
           final var assetMetaContexts = AssetMetaContext.mapAssetMetas(globalConfig);
           final var assetMetaMap = createMapChecked(slot, assetMetaContexts, mintCache);
-          final var globalConfigUpdate = new GlobalConfigCacheImpl.GlobalConfigUpdate(
+          final var globalConfigUpdate = new GlobalConfigUpdate(
               slot, assetMetaContexts, data
           );
           persistGlobalConfig(globalConfigFilePath, data);
@@ -122,6 +122,8 @@ private static Map<PublicKey, AssetMetaContext[]> createMap(final AssetMetaConte
     return assetMetaMap;
   }
 
+  GlobalConfigUpdate globalConfig();
+
   AssetMetaContext watchForMint(final PublicKey mint, final PublicKey stateAccount);
 
   /**
@@ -147,4 +149,8 @@ private static Map<PublicKey, AssetMetaContext[]> createMap(final AssetMetaConte
   CompletableFuture<Void> initCache();
 
   void subscribe(final SolanaRpcWebsocket websocket);
+
+  void subscribe(final GlobalConfigListener listener);
+
+  void unsubscribe(final GlobalConfigListener listener);
 }