helium · ChewingGlass · Sep 15, 2023 · Sep 12, 2023 · Sep 13, 2023 · Sep 13, 2023
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -3,6 +3,24 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.2.22](https://github.com/helium/helium-program-library/compare/v0.2.21...v0.2.22) (2023-09-13)
+
+
+### Features
+
+* **#373:** replace clockwork ([#388](https://github.com/helium/helium-program-library/issues/388)) ([55033c7](https://github.com/helium/helium-program-library/commit/55033c718df08f41eb2f77d726d59d916ebbd677)), closes [#373](https://github.com/helium/helium-program-library/issues/373)
+* **#376:** Replace lazy transactions markers with a bitmap to reclaim rent ([#380](https://github.com/helium/helium-program-library/issues/380)) ([a691257](https://github.com/helium/helium-program-library/commit/a6912570d4e3d89869cd13c5cfc8ce8c4355148e)), closes [#376](https://github.com/helium/helium-program-library/issues/376) [#376](https://github.com/helium/helium-program-library/issues/376)
+* **#379:** Automate npm publish and fix devnet conflicting sqds txns ([#386](https://github.com/helium/helium-program-library/issues/386)) ([a4a3780](https://github.com/helium/helium-program-library/commit/a4a37806fefe82ca9a38f04c311f600ad1f7c36c))
+
+
+### Reverts
+
+* Revert "Add back mobile genesis fix for devnet" ([93e9a2c](https://github.com/helium/helium-program-library/commit/93e9a2c370ba77a49b02efc2590ddf3039465ed6))
+
+
+
+
+
 ## [0.2.15](https://github.com/helium/helium-program-library/compare/v0.2.14...v0.2.15) (2023-07-31)
 
 **Note:** Version bump only for package helium-program-library

diff --git a/lerna.json b/lerna.json
@@ -1,6 +1,8 @@
 {
   "npmClient": "yarn",
-  "packages": ["packages/*"],
+  "packages": [
+    "packages/*"
+  ],
   "useWorkspaces": true,
-  "version": "0.2.21"
+  "version": "0.2.22"
 }
diff --git a/packages/account-fetch-cache-hooks/CHANGELOG.md b/packages/account-fetch-cache-hooks/CHANGELOG.md
@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.2.22](https://github.com/helium/helium-program-libary/compare/v0.2.21...v0.2.22) (2023-09-13)
+
+**Note:** Version bump only for package @helium/account-fetch-cache-hooks
+
+
+
+
+
 ## [0.2.15](https://github.com/helium/helium-program-libary/compare/v0.2.14...v0.2.15) (2023-07-31)
 
 **Note:** Version bump only for package @helium/account-fetch-cache-hooks

diff --git a/packages/account-fetch-cache-hooks/package.json b/packages/account-fetch-cache-hooks/package.json
@@ -6,7 +6,7 @@
     "registry": "https://registry.npmjs.org/"
   },
   "license": "Apache-2.0",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "React hooks and context for account-fetch-cache",
   "repository": {
     "type": "git",
@@ -32,7 +32,7 @@
     "prebuild": "npm run clean && npm run package"
   },
   "dependencies": {
-    "@helium/account-fetch-cache": "^0.2.21",
+    "@helium/account-fetch-cache": "^0.2.22",
     "@solana/web3.js": "^1.78.4",
     "react-async-hook": "^4.0.0"
   },

diff --git a/packages/account-fetch-cache/CHANGELOG.md b/packages/account-fetch-cache/CHANGELOG.md
@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.2.22](https://github.com/helium/helium-program-library/compare/v0.2.21...v0.2.22) (2023-09-13)
+
+**Note:** Version bump only for package @helium/account-fetch-cache
+
+
+
+
+
 ## [0.2.15](https://github.com/helium/helium-program-library/compare/v0.2.14...v0.2.15) (2023-07-31)
 
 **Note:** Version bump only for package @helium/account-fetch-cache

diff --git a/packages/account-fetch-cache/package.json b/packages/account-fetch-cache/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@helium/account-fetch-cache",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "Solana account fetch cache to eliminate reduntant fetching, and batch fetches",
   "publishConfig": {
     "access": "public",

diff --git a/packages/account-fetch-cache/src/accountFetchCache.ts b/packages/account-fetch-cache/src/accountFetchCache.ts
@@ -39,6 +39,26 @@ function getWriteableAccounts(
 
 let id = 0;
 
+let singletons: Record<string, AccountFetchCache | undefined> = {};
+export function getSingleton(conn: Connection): AccountFetchCache {
+  const commitment = conn.commitment || "confirmed"
+  const endp = conn.rpcEndpoint
+  if (!singletons[endp + commitment]) {
+    singletons[endp + commitment] = new AccountFetchCache({
+      connection: conn,
+      commitment,
+    })
+
+  }
+  return singletons[endp + commitment]!
+}
+
+function setSingleton(conn: Connection, cache: AccountFetchCache) {
+  const commitment = conn.commitment || "confirmed";
+  const endp = conn.rpcEndpoint;
+  singletons[endp + commitment] = cache;
+}
+
 export class AccountFetchCache {
   connection: Connection;
   chunkSize: number;
@@ -64,9 +84,7 @@ export class AccountFetchCache {
     publicKey: PublicKey,
     com?: Commitment
   ) => Promise<AccountInfo<Buffer> | null>;
-  oldSendTransaction: (
-    ...args: any[]
-  ) => Promise<string>;
+  oldSendTransaction: (...args: any[]) => Promise<string>;
   oldSendRawTransaction: (
     rawTransaction: Buffer | Uint8Array | Array<number>,
     options?: SendOptions
@@ -101,8 +119,7 @@ export class AccountFetchCache {
     );
 
     this.oldSendTransaction = connection.sendTransaction.bind(connection);
-    this.oldSendRawTransaction =
-      connection.sendRawTransaction.bind(connection);
+    this.oldSendRawTransaction = connection.sendRawTransaction.bind(connection);
 
     const self = this;
 
@@ -152,12 +169,14 @@ export class AccountFetchCache {
             return self.requeryMissing(instructions);
           })
           .catch(console.error);
-      } catch(e: any) {
+      } catch (e: any) {
         // TODO: handle transaction v2
       }
 
       return result;
     };
+
+    setSingleton(connection, this)
   }
 
   async requeryMissing(instructions: TransactionInstruction[]) {
@@ -214,7 +233,10 @@ export class AccountFetchCache {
     this.currentBatch = new Set(); // Erase current batch from state, so we can fetch multiple at a time
     try {
       const keys = Array.from(currentBatch);
-      const array = await this.connection.getMultipleAccountsInfo(keys.map(b => new PublicKey(b)), this.commitment)
+      const array = await this.connection.getMultipleAccountsInfo(
+        keys.map((b) => new PublicKey(b)),
+        this.commitment
+      );
       keys.forEach((key, index) => {
         const callback = this.pendingCallbacks.get(key);
         callback && callback(array[index], null);
@@ -363,6 +385,48 @@ export class AccountFetchCache {
     return query;
   }
 
+  async searchMultiple<T>(
+    pubKeys: PublicKey[],
+    parser?: AccountParser<T> | undefined,
+    isStatic: Boolean = false, // optimization, set if the data will never change
+    forceRequery = false
+  ): Promise<(ParsedAccountBase<T> | undefined)[]> {
+    pubKeys.forEach(key => {
+      this.registerParser(key, parser);
+      const address = key.toBase58();
+      if (isStatic) {
+        this.statics.add(address);
+      } else if (this.statics.has(address)) {
+        this.statics.delete(address); // If trying to use this as not static, need to rm it from the statics list.
+      }
+
+      if (forceRequery || !this.genericCache.has(address)) {
+        this.currentBatch.add(address);
+      }
+    })
+
+    const searched = new Set(pubKeys.map((p) => p.toBase58()));
+    // Force a batch fetch to resolve all accounts
+    const { keys, array } = await this.fetchBatch();
+    // Cache these results if they aren't going to change
+    if (isStatic) {
+      keys.forEach((key, index) => {
+        if (searched.has(key)) {
+          const item = array[index];
+          if (item) {
+            this.genericCache.set(
+              key,
+              this.getParsed(key, item, parser) || null
+            );
+          }
+        }
+      });
+    }
+
+
+    return pubKeys.map(key => this.genericCache.get(key.toBase58()) as ParsedAccountBase<T> | undefined);
+  }
+
   onAccountChange<T>(
     key: PublicKey,
     parser: AccountParser<T> | undefined,
@@ -373,7 +437,7 @@ export class AccountFetchCache {
       const address = key.toBase58();
       this.updateCache(address, parsed || null);
     } catch (e: any) {
-      console.error("accountFetchCache", "Failed to update account", e)
+      console.error("accountFetchCache", "Failed to update account", e);
     }
   }
 
@@ -391,43 +455,43 @@ export class AccountFetchCache {
       // Only websocket watch accounts that exist
       // Don't recreate listeners
       // xNFT doesn't support onAccountChange, so we have to make a new usable connection.
-        if (!this.accountChangeListeners.has(address)) {
-          try {
+      if (!this.accountChangeListeners.has(address)) {
+        try {
+          this.accountChangeListeners.set(
+            address,
+            this.connection.onAccountChange(
+              id,
+              (account) => this.onAccountChange(id, undefined, account),
+              this.commitment
+            )
+          );
+        } catch (e: any) {
+          if (e.toString().includes("not implemented")) {
+            // @ts-ignore
+            this.usableConnection =
+              // @ts-ignore
+              this.usableConnection ||
+              new Connection(
+                // @ts-ignore
+                this.connection._rpcEndpoint,
+                this.commitment
+              );
             this.accountChangeListeners.set(
               address,
-              this.connection.onAccountChange(
+              // @ts-ignore
+              this.usableConnection.onAccountChange(
                 id,
+                // @ts-ignore
                 (account) => this.onAccountChange(id, undefined, account),
                 this.commitment
               )
             );
-          } catch (e: any) {
-            if (e.toString().includes("not implemented")) {
-              // @ts-ignore
-              this.usableConnection =
-                // @ts-ignore
-                this.usableConnection ||
-                new Connection(
-                  // @ts-ignore
-                  this.connection._rpcEndpoint,
-                  this.commitment
-                );
-              this.accountChangeListeners.set(
-                address,
-                // @ts-ignore
-                this.usableConnection.onAccountChange(
-                  id,
-                  // @ts-ignore
-                  (account) => this.onAccountChange(id, undefined, account),
-                  this.commitment
-                )
-              );
-            } else {
-              console.error(e)
-              throw e
-            }
+          } else {
+            console.error(e);
+            throw e;
           }
         }
+      }
     } else if (!exists) {
       // Poll accounts that don't exist
       this.missingAccounts.set(

diff --git a/packages/account-postgres-sink-service/CHANGELOG.md b/packages/account-postgres-sink-service/CHANGELOG.md
@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.2.22](https://github.com/helium/helium-program-libary/compare/v0.2.21...v0.2.22) (2023-09-13)
+
+**Note:** Version bump only for package @helium/account-postgres-sink-service
+
+
+
+
+
 ## [0.2.15](https://github.com/helium/helium-program-libary/compare/v0.2.14...v0.2.15) (2023-07-31)
 
 **Note:** Version bump only for package @helium/account-postgres-sink-service

diff --git a/packages/account-postgres-sink-service/package.json b/packages/account-postgres-sink-service/package.json
@@ -6,7 +6,7 @@
     "registry": "https://registry.npmjs.org/"
   },
   "license": "Apache-2.0",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "Sync account data to postgres",
   "repository": {
     "type": "git",
@@ -34,7 +34,7 @@
   "dependencies": {
     "@coral-xyz/anchor": "^0.26.0",
     "@fastify/cors": "^8.1.1",
-    "@helium/account-fetch-cache": "^0.2.21",
+    "@helium/account-fetch-cache": "^0.2.22",
     "@metaplex-foundation/mpl-token-metadata": "^2.10.0",
     "@solana/web3.js": "^1.78.4",
     "aws-sdk": "^2.1344.0",

diff --git a/packages/active-device-oracle/CHANGELOG.md b/packages/active-device-oracle/CHANGELOG.md
@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.2.22](https://github.com/helium/helium-program-libary/compare/v0.2.21...v0.2.22) (2023-09-13)
+
+**Note:** Version bump only for package @helium/active-device-oracle
+
+
+
+
+
 ## [0.2.15](https://github.com/helium/helium-program-libary/compare/v0.2.14...v0.2.15) (2023-07-31)
 
 **Note:** Version bump only for package @helium/active-device-oracle

diff --git a/packages/active-device-oracle/package.json b/packages/active-device-oracle/package.json
@@ -6,7 +6,7 @@
     "registry": "https://registry.npmjs.org/"
   },
   "license": "Apache-2.0",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "Oracle of helium active devices",
   "repository": {
     "type": "git",

diff --git a/packages/anchor-resolvers/CHANGELOG.md b/packages/anchor-resolvers/CHANGELOG.md
@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.2.22](https://github.com/helium/helium-program-library/compare/v0.2.21...v0.2.22) (2023-09-13)
+
+**Note:** Version bump only for package @helium/anchor-resolvers
+
+
+
+
+
 ## [0.2.15](https://github.com/helium/helium-program-library/compare/v0.2.14...v0.2.15) (2023-07-31)
 
 **Note:** Version bump only for package @helium/anchor-resolvers

diff --git a/packages/anchor-resolvers/package.json b/packages/anchor-resolvers/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@helium/anchor-resolvers",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "Wrappers around anchor custom resolvers to make composition easier",
   "publishConfig": {
     "access": "public",

diff --git a/packages/circuit-breaker-sdk/CHANGELOG.md b/packages/circuit-breaker-sdk/CHANGELOG.md
@@ -3,6 +3,14 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [0.2.22](https://github.com/helium/helium-program-libary/compare/v0.2.21...v0.2.22) (2023-09-13)
+
+**Note:** Version bump only for package @helium/circuit-breaker-sdk
+
+
+
+
+
 ## [0.2.15](https://github.com/helium/helium-program-libary/compare/v0.2.14...v0.2.15) (2023-07-31)
 
 **Note:** Version bump only for package @helium/circuit-breaker-sdk