@agoric/internal - npm Package Compare versions

Comparing version 0.3.3-dev-7f4df76.0 to 0.3.3-dev-7f8ede3.0

package.json

 {
   "name": "@agoric/internal",
-  "version": "0.3.3-dev-7f4df76.0+7f4df76",
+  "version": "0.3.3-dev-7f8ede3.0+7f8ede3",
   "description": "Externally unsupported utilities internal to agoric-sdk",
@@ -23,3 +23,3 @@ "type": "module",
   "dependencies": {
-    "@agoric/base-zone": "0.1.1-dev-7f4df76.0+7f4df76",
+    "@agoric/base-zone": "0.1.1-dev-7f8ede3.0+7f8ede3",
     "@endo/common": "^1.2.9",
@@ -38,3 +38,3 @@ "@endo/errors": "^1.2.9",
   "devDependencies": {
-    "@agoric/cosmic-proto": "0.4.1-dev-7f4df76.0+7f4df76",
+    "@agoric/cosmic-proto": "0.4.1-dev-7f8ede3.0+7f8ede3",
     "@endo/exo": "^1.5.8",
@@ -65,3 +65,3 @@ "@endo/init": "^1.1.8",
   },
-  "gitHead": "7f4df7622f3e70d2b80b83139e16c4f28616203a"
+  "gitHead": "7f8ede32036cebe85e381a1ff0cf98957ddfc96f"
 }

src/queue.d.ts

@@ -1,2 +0,2 @@
-export function makeWithQueue(): <T extends (...args: any[]) => any>(inner: T) => (...args: Parameters<T>) => Promise<Awaited<ReturnType<T>>>;
+export function makeWithQueue(): (inner: T) => (...args: Parameters<T>) => Promise<Awaited<ReturnType<T>>>;
 //# sourceMappingURL=queue.d.ts.map

src/storage-test-utils.d.ts

@@ -27,11 +27,12 @@ export function slotToRemotable(_slotId: string, iface?: string): import("@endo/pass-style").RemotableObject<string> & import("@endo/eventual-send").RemotableBrand<{}, {}>;
     data: Map<string, string>;
+    updateNewCellBlockHeight: (blockHeight?: number) => void;
     getValues: (path: string) => string[];
     messages: StorageMessage[];
-    toStorage: ((message: StorageMessage) => string | number | any[] | {
+    toStorage: ((message: StorageMessage) => string | number | true | any[] | {
         storeName: string;
         storeSubkey: string;
-    } | null | undefined) & import("@endo/pass-style").RemotableObject<`Alleged: ${string}`> & import("@endo/eventual-send").RemotableBrand<{}, (message: StorageMessage) => string | number | any[] | {
+    } | null) & import("@endo/pass-style").RemotableObject<`Alleged: ${string}`> & import("@endo/eventual-send").RemotableBrand<{}, (message: StorageMessage) => string | number | true | any[] | {
         storeName: string;
         storeSubkey: string;
-    } | null | undefined>;
+    } | null>;
 };
@@ -38,0 +39,0 @@ export function makeMockChainStorageRoot(): MockChainStorageRoot;

src/storage-test-utils.js

@@ -14,3 +14,3 @@ // @ts-check
  * @import {TotalMap} from './types.js';
- * @import {Marshaller, StorageEntry, StorageMessage, StorageNode} from './lib-chainStorage.js';
+ * @import {Marshaller, StorageEntry, StorageMessage, StorageNode, StreamCell} from './lib-chainStorage.js';
  */
@@ -104,2 +104,10 @@
   const data = new Map();
+  let currentBlockHeight = 0;
+
+  const updateNewCellBlockHeight = (blockHeight = currentBlockHeight + 1) => {
+    blockHeight > currentBlockHeight ||
+      Fail`blockHeight ${blockHeight} must be greater than ${currentBlockHeight}`;
+    currentBlockHeight = blockHeight;
+  };
+
   /** @param {string} prefix */
@@ -163,3 +171,3 @@ const getChildEntries = prefix => {
           }
-          break;
+          return true;
         }
@@ -172,4 +180,6 @@ case 'append': {
             value != null || Fail`attempt to append with no value`;
-            // In the absence of block boundaries, everything goes in a single StreamCell.
-            const oldVal = data.get(key);
+
+            /** @type {string | undefined} */
+            let oldVal = data.get(key);
+            /** @type {StreamCell | undefined} */
             let streamCell;
@@ -183,6 +193,15 @@ if (oldVal != null) {
               }
+              // StreamCells reset at block boundaries.
+              if (
+                streamCell &&
+                Number(streamCell.blockHeight) !== currentBlockHeight
+              ) {
+                streamCell = undefined;
+                oldVal = undefined;
+              }
             }
+
             if (streamCell === undefined) {
               streamCell = {
-                blockHeight: '0',
+                blockHeight: String(currentBlockHeight),
                 values: oldVal != null ? [oldVal] : [],
@@ -194,3 +213,3 @@ };
           }
-          break;
+          return true;
         }
@@ -228,2 +247,3 @@ case 'size':
     data: /** @type {Map<string, string>} */ (data),
+    updateNewCellBlockHeight,
     getValues,
@@ -230,0 +250,0 @@ messages,

src/typeGuards.d.ts

 export const StorageNodeShape: import("@endo/patterns").Matcher;
 /** To be used only for 'helper' facets where the calls are from trusted code. */
 export const UnguardedHelperI: import("@endo/patterns").InterfaceGuard<any>;
+/**
+ * @typedef {number | `${bigint}`} BridgeBigInt Ensure that callees passed a
+ *   bridge message that was serialised from a Golang int64 or uint64 accept
+ *   either a JS number or a stringified JS bigint.
+ */
+/**
+ * @type {import('./types.js').TypedPattern<BridgeBigInt>}
+ */
+export const BridgeBigIntShape: import("./types.js").TypedPattern<BridgeBigInt>;
+/**
+ * Ensure that callees passed a
+ *   bridge message that was serialised from a Golang int64 or uint64 accept
+ *   either a JS number or a stringified JS bigint.
+ */
+export type BridgeBigInt = number | `${bigint}`;
 //# sourceMappingURL=typeGuards.d.ts.map

src/typeGuards.js

 // @jessie-check
+// @ts-check
 
@@ -14,1 +15,12 @@ import { M } from '@endo/patterns';
 );
+
+/**
+ * @typedef {number | `${bigint}`} BridgeBigInt Ensure that callees passed a
+ *   bridge message that was serialised from a Golang int64 or uint64 accept
+ *   either a JS number or a stringified JS bigint.
+ */
+
+/**
+ * @type {import('./types.js').TypedPattern<BridgeBigInt>}
+ */
+export const BridgeBigIntShape = M.or(M.number(), M.string());

New alerts

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Fixed alerts

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

177189

2.09%

Number of package files

118

2.61%

Lines of code

4057

2.19%

Dependency changes

• Updated

  @agoric/base-zone@0.1.1-dev-7f8ede3.0+7f8ede3