fazzatti
diff --git a/‎core/asset/sac/index.integration.test.ts‎
Lines changed: 22 additions & 5 deletions b/‎core/asset/sac/index.integration.test.ts‎
Lines changed: 22 additions & 5 deletions
diff --git a/‎core/contract/index.ts‎
Lines changed: 1 addition & 1 deletion b/‎core/contract/index.ts‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎core/deno.json‎
Lines changed: 1 addition & 1 deletion b/‎core/deno.json‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎core/event/event-filter/index.ts‎
Lines changed: 6 additions & 10 deletions b/‎core/event/event-filter/index.ts‎
Lines changed: 6 additions & 10 deletions
diff --git a/‎core/event/parsing/ledger-close-meta.ts‎
Lines changed: 9 additions & 9 deletions b/‎core/event/parsing/ledger-close-meta.ts‎
Lines changed: 9 additions & 9 deletions
diff --git a/‎core/ledger-parser/ledger/index.ts‎
Lines changed: 8 additions & 8 deletions b/‎core/ledger-parser/ledger/index.ts‎
Lines changed: 8 additions & 8 deletions
@@ -25,10 +25,14 @@ import * as SACError from "@/asset/sac/error.ts";
 describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
   const networkConfig = NetworkConfig.TestNet();
 
+  // The RPC may sometimes take a while to reflect changes, so we use a longer timeout for the integration tests
+  // This seems to be specific to testnet.
+  const wait = (ms = 500) => new Promise((resolve) => setTimeout(resolve, ms));
+
   const setupIssuerFlags = async (
     publicKey: Ed25519PublicKey,
     networkConfig: NetworkConfig,
-    config: TransactionConfig
+    config: TransactionConfig,
   ) => {
     const pipe = PIPE_ClassicTransaction.create({ networkConfig });
     const op = Operation.setOptions({
@@ -43,7 +47,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
     users: Signer[],
     asset: Asset,
     networkConfig: NetworkConfig,
-    config: TransactionConfig
+    config: TransactionConfig,
   ) => {
     const pipe = PIPE_ClassicTransaction.create({ networkConfig });
     const operations: xdr.Operation[] = [];
@@ -53,7 +57,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
         Operation.changeTrust({
           asset: asset,
           source: user.publicKey(),
-        })
+        }),
       );
     }
 
@@ -113,7 +117,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
 
       // Verify the contract ID matches the native asset contract ID
       const expectedContractId = Asset.native().contractId(
-        networkConfig.networkPassphrase
+        networkConfig.networkPassphrase,
       );
       assertEquals(nativeSAC.contractId, expectedContractId);
     });
@@ -155,7 +159,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
 
       await initializeWithFriendbot(
         networkConfig.friendbotUrl,
-        newAdminAccount.publicKey()
+        newAdminAccount.publicKey(),
       );
     });
 
@@ -167,6 +171,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
         newAdmin: newAdminAccount.publicKey(),
         config: txConfig,
       });
+      await wait();
       currentAdmin = await colibriSAC.admin();
       assertEquals(currentAdmin, newAdminAccount.publicKey());
 
@@ -177,6 +182,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
           signers: [newAdminAccount, issuer.signer()],
         },
       });
+      await wait();
       currentAdmin = await colibriSAC.admin();
       assertEquals(currentAdmin, issuer.address());
     });
@@ -192,6 +198,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
         amount: 1_000_000_0000000n, // 1M COLIBRI
         config: txConfig,
       });
+      await wait();
 
       userACurrentBalance = await colibriSAC.balance({
         id: userA.address(),
@@ -206,6 +213,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
           signers: [userA.signer(), issuer.signer()],
         },
       });
+      await wait();
 
       userACurrentBalance = await colibriSAC.balance({
         id: userA.address(),
@@ -224,6 +232,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
         authorize: false,
         config: txConfig,
       });
+      await wait();
 
       isAuthorized = await colibriSAC.authorized({
         id: userB.address(),
@@ -235,6 +244,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
         authorize: true,
         config: txConfig,
       });
+      await wait();
 
       isAuthorized = await colibriSAC.authorized({
         id: userB.address(),
@@ -249,6 +259,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
         amount: 100_0000000n, // 100 COLIBRI
         config: txConfig,
       });
+      await wait();
 
       let userBBalance = await colibriSAC.balance({
         id: userB.address(),
@@ -261,6 +272,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
         amount: 50_0000000n,
         config: txConfig,
       });
+      await wait();
 
       userBBalance = await colibriSAC.balance({
         id: userB.address(),
@@ -289,6 +301,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
           signers: [userA.signer(), issuer.signer()],
         },
       });
+      await wait();
 
       const userABalanceAfter = await colibriSAC.balance({
         id: userA.address(),
@@ -327,6 +340,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
           signers: [userA.signer(), issuer.signer()],
         },
       });
+      await wait();
 
       // Check allowance is now set
       allowance = await colibriSAC.allowance({
@@ -364,6 +378,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
           signers: [userB.signer(), issuer.signer()],
         },
       });
+      await wait();
 
       const userABalanceAfter = await colibriSAC.balance({
         id: userA.address(),
@@ -401,6 +416,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
           signers: [userA.signer(), issuer.signer()],
         },
       });
+      await wait();
 
       const userABalanceBefore = await colibriSAC.balance({
         id: userA.address(),
@@ -418,6 +434,7 @@ describe("[Testnet] Stellar Asset Contract", disableSanitizeConfig, () => {
           signers: [userB.signer(), issuer.signer()],
         },
       });
+      await wait();
 
       const userABalanceAfter = await colibriSAC.balance({
         id: userA.address(),
 
@@ -57,7 +57,7 @@ export class Contract {
     this.networkConfig = networkConfig;
     if (!rpc) {
       assert(networkConfig && networkConfig.rpcUrl, new E.MISSING_RPC_URL());
-      rpc = new Server(networkConfig.rpcUrl);
+      rpc = new Server(networkConfig.rpcUrl, { allowHttp: networkConfig.allowHttp });
     }
 
     this.rpc = rpc;
 
@@ -1,6 +1,6 @@
 {
   "name": "@colibri/core",
-  "version": "0.16.0",
+  "version": "0.16.1",
   "license": "MIT",
   "exports": {
     ".": "./mod.ts"
 
@@ -9,6 +9,7 @@ import type { BoundedArray } from "@/common/helpers/bounded-array.ts";
 import type { ContractId } from "@/strkeys/types.ts";
 import { assert } from "@/common/assert/assert.ts";
 import * as E from "@/event/event-filter/error.ts";
+import { isDefined } from "@/common/type-guards/is-defined.ts";
 export class EventFilter {
   private _type?: EventType;
   private _contractIds?: BoundedArray<ContractId, 0, 5>;
@@ -36,14 +37,9 @@ export class EventFilter {
     return {
       type: this._type,
       contractIds: this._contractIds,
-      topics:
-        this._topics === undefined
-          ? undefined
-          : [
-              ...this._topics.map((topicFilter) =>
-                this.encodeTopics(topicFilter)
-              ),
-            ],
+      topics: isDefined(this._topics)
+        ? [...this._topics.map((topicFilter) => this.encodeTopics(topicFilter))]
+        : undefined,
     };
   }
 
@@ -77,7 +73,7 @@ export class EventFilter {
 }
 const eventTopicsMatchFilterTopic = (
   topicFilter: TopicFilter,
-  eventTopics: xdr.ScVal[]
+  eventTopics: xdr.ScVal[],
 ): boolean => {
   assert(eventTopics.length > 0, new E.EVENT_HAS_NO_TOPICS());
 
@@ -101,7 +97,7 @@ const eventTopicsMatchFilterTopic = (
       throw new E.FAILED_TO_CHECK_FILTER_SEGMENT(
         filterSegment,
         eventSegment,
-        e as Error
+        e as Error,
       );
     }
     return false; // No match for this segment
 
@@ -10,25 +10,25 @@ import { assert } from "@/common/assert/assert.ts";
 import { isDefined } from "@/common/type-guards/is-defined.ts";
 
 export const isLedgerCloseMetaV1 = (
-  metadataXdr: xdr.LedgerCloseMeta
+  metadataXdr: xdr.LedgerCloseMeta,
 ): boolean => {
   return metadataXdr.switch() === 1;
 };
 
 export const isLedgerCloseMetaV2 = (
-  metadataXdr: xdr.LedgerCloseMeta
+  metadataXdr: xdr.LedgerCloseMeta,
 ): boolean => {
   return metadataXdr.switch() === 2;
 };
 
 export const parseEventsFromLedgerCloseMeta = async (
   metadataXdr: xdr.LedgerCloseMeta,
   onEvent: EventHandler,
-  filters?: EventFilter[]
+  filters?: EventFilter[],
 ): Promise<void> => {
   assert(
     xdr.LedgerCloseMeta.isValid(metadataXdr),
-    new E.INVALID_LEDGER_CLOSE_META_XDR()
+    new E.INVALID_LEDGER_CLOSE_META_XDR(),
   );
 
   let ledgerCloseMeta:
@@ -46,7 +46,7 @@ export const parseEventsFromLedgerCloseMeta = async (
 
   assert(
     isDefined(ledgerCloseMeta),
-    new E.UNSUPPORTED_LEDGER_CLOSE_META_VERSION(metadataXdr.switch())
+    new E.UNSUPPORTED_LEDGER_CLOSE_META_VERSION(metadataXdr.switch()),
   );
 
   const ledgerSequence = ledgerCloseMeta.ledgerHeader().header().ledgerSeq();
@@ -84,7 +84,7 @@ export const parseEventsFromLedgerCloseMeta = async (
         const contractId =
           contractIdXdr !== null
             ? (Address.fromScAddress(
-                xdr.ScAddress.scAddressTypeContract(contractIdXdr)
+                xdr.ScAddress.scAddressTypeContract(contractIdXdr),
               ).toString() as ContractId)
             : undefined;
 
@@ -100,7 +100,7 @@ export const parseEventsFromLedgerCloseMeta = async (
             ledgerSequence,
             transactionIndex,
             operationIndex,
-            eventIndex
+            eventIndex,
           );
 
           await onEvent(
@@ -116,7 +116,7 @@ export const parseEventsFromLedgerCloseMeta = async (
               topic: topic,
               value: value,
               inSuccessfulContractCall: inSuccessfulContractCall,
-            })
+            }),
           );
         }
       }
@@ -135,7 +135,7 @@ export const isIncludedInFilters = ({
   type?: EventType;
   topics?: xdr.ScVal[];
 }): boolean => {
-  if (filters === undefined || filters.length === 0) return true;
+  if (!isDefined(filters) || filters.length === 0) return true;
 
   for (const filter of filters) {
     if (type !== undefined && !filter.matchesType(type)) continue;
 
@@ -25,8 +25,8 @@ import {
  * - TransactionMeta: v4 only (archive normalizes all to v4)
  *
  * Envelope availability:
- * - v2: ✅ Available from txSet.phases
- * - v0/v1: ❌ Not available (v4 meta doesn't include envelope)
+ * - v2: Available from txSet.phases
+ * - v0/v1: Not available (v4 meta doesn't include envelope)
  *
  * Uses @memoize() to cache expensive parsing operations.
  *
@@ -60,7 +60,7 @@ export class Ledger {
     // Validate required fields
     if (!entry.sequence || !entry.hash || !entry.ledgerCloseTime) {
       throw new INVALID_LEDGER_ENTRY(
-        JSON.stringify({ sequence: entry.sequence, hash: entry.hash })
+        JSON.stringify({ sequence: entry.sequence, hash: entry.hash }),
       );
     }
 
@@ -91,7 +91,7 @@ export class Ledger {
       // RPC returns base64-encoded LedgerHeaderHistoryEntry
       const historyEntry = ensureXdrType(
         this.headerXdr,
-        xdr.LedgerHeaderHistoryEntry
+        xdr.LedgerHeaderHistoryEntry,
       );
       return historyEntry.header();
     } catch (error) {
@@ -198,7 +198,7 @@ export class Ledger {
               this,
               resultMeta,
               envelope,
-              index
+              index,
             );
           } else {
             return Transaction.fromMeta(this, resultMeta, index);
@@ -219,7 +219,7 @@ export class Ledger {
               this,
               resultMeta,
               envelope,
-              index
+              index,
             );
           } else {
             return Transaction.fromMeta(this, resultMeta, index);
@@ -241,7 +241,7 @@ export class Ledger {
               this,
               resultMeta,
               envelope,
-              index
+              index,
             );
           } else {
             // Fallback to fromMeta if envelope not found (shouldn't happen normally)
@@ -264,7 +264,7 @@ export class Ledger {
    * - parallelTxsComponent: Soroban transactions (ParallelTxExecutionStage[][])
    */
   private extractEnvelopesFromGeneralizedTxSet(
-    txSet: xdr.GeneralizedTransactionSet
+    txSet: xdr.GeneralizedTransactionSet,
   ): xdr.TransactionEnvelope[] {
     const txSetV1 = txSet.v1TxSet();
     const phases = txSetV1.phases();
Original file line number	Diff line number	Diff line change
`@@ -57,7 +57,7 @@ export class Contract {`
`57`	`57`	`this.networkConfig = networkConfig;`
`58`	`58`	`if (!rpc) {`
`59`	`59`	`assert(networkConfig && networkConfig.rpcUrl, new E.MISSING_RPC_URL());`
`60`		`- rpc = new Server(networkConfig.rpcUrl);`
	`60`	`+ rpc = new Server(networkConfig.rpcUrl, { allowHttp: networkConfig.allowHttp });`
`61`	`61`	`}`
`62`	`62`
`63`	`63`	`this.rpc = rpc;`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@colibri/core",`
`3`		`- "version": "0.16.0",`
	`3`	`+ "version": "0.16.1",`
`4`	`4`	`"license": "MIT",`
`5`	`5`	`"exports": {`
`6`	`6`	`".": "./mod.ts"`