SPIKE: prototype participants in Fast USDC sequence diagram

a3p-integration/proposals/d:quick-send/.yarnrc.yml

@@ -0,0 +1 @@
+nodeLinker: node-modules

a3p-integration/proposals/d:quick-send/package.json

@@ -0,0 +1,27 @@
+{
+  "agoricProposal": {
+    "source": "subdir",
+    "sdk-generate": [
+      "vats/init-orchestration.js",
+      "fast-usdc/init-quickSend.js"
+    ],
+    "type": "/agoric.swingset.CoreEvalProposal"
+  },
+  "type": "module",
+  "license": "Apache-2.0",
+  "dependencies": {
+    "@agoric/synthetic-chain": "^0.3.0",
+    "ava": "^5.3.1"
+  },
+  "ava": {
+    "concurrency": 1,
+    "timeout": "2m",
+    "files": [
+      "!submission"
+    ]
+  },
+  "scripts": {
+    "agops": "yarn --cwd /usr/src/agoric-sdk/ --silent agops"
+  },
+  "packageManager": "[email protected]"
+}

a3p-integration/proposals/d:quick-send/quick-load.test.js

@@ -0,0 +1,20 @@
+// @ts-check
+/* global globalThis */
+import test from 'ava';
+import { extractStreamCellValue } from '@agoric/synthetic-chain';
+import { localAPI, makeLCD } from './test-lib/cosmos-api.js';
+import { makeVStorage } from './test-lib/vstorage-client.js';
+
+const io = { api: makeLCD(localAPI, { fetch: globalThis.fetch }) };
+
+test('quickSend is in agoricNames.instance', async t => {
+  const vs = makeVStorage(io.api);
+  const data = await vs.readStorage('published.agoricNames.instance');
+  const value = extractStreamCellValue(data);
+  assert.typeof(value, 'string');
+  const capData = JSON.parse(value);
+  const encoding = JSON.parse(capData?.body.replace(/^#/, ''));
+  const byName = Object.fromEntries(encoding);
+  t.log('agoricNames.instance keys', Object.keys(byName));
+  t.truthy(byName.quickSend);
+});

a3p-integration/proposals/d:quick-send/test-lib/cosmos-api.js

@@ -0,0 +1,42 @@
+// @ts-check
+const { freeze } = Object;
+
+/**
+ * @see {@link https://docs.cosmos.network/v0.46/core/grpc_rest.html#rest-server}
+ */
+export const defaultAPIPort = 1317;
+export const localAPI = `http://localhost:${defaultAPIPort}`;
+
+/**
+ * @param {string} apiURL
+ * @param {object} io
+ * @param {typeof fetch} io.fetch
+ */
+export const makeLCD = (apiURL, { fetch }) => {
+  if (typeof apiURL !== 'string') throw TypeError(typeof apiURL);
+
+  /**
+   * @param {string} href
+   * @param {object} [options]
+   * @param {Record<string, string>} [options.headers]
+   */
+  const getJSON = async (href, options = {}) => {
+    const opts = {
+      keepalive: true,
+      headers: {
+        'Content-Type': 'application/json',
+        ...options.headers,
+      },
+    };
+    const url = `${apiURL}${href}`;
+    const r = await fetch(url, opts);
+    if (!r.ok) throw Error(r.statusText);
+    return r.json();
+  };
+
+  return freeze({
+    getJSON,
+    latestBlock: () => getJSON(`/cosmos/base/tendermint/v1beta1/blocks/latest`),
+  });
+};
+/** @typedef {ReturnType<makeLCD>} LCD */

a3p-integration/proposals/d:quick-send/test-lib/vstorage-client.js

@@ -0,0 +1,34 @@
+// @ts-check
+
+/**
+ * @param {import("./cosmos-api").LCD} lcd
+ */
+export const makeVStorage = lcd => {
+  const getJSON = (href, options) => lcd.getJSON(href, options);
+
+  // height=0 is the same as omitting height and implies the highest block
+  const href = (path = 'published', { kind = 'data' } = {}) =>
+    `/agoric/vstorage/${kind}/${path}`;
+  const headers = height =>
+    height ? { 'x-cosmos-block-height': `${height}` } : undefined;
+
+  const readStorage = (
+    path = 'published',
+    { kind = 'data', height = 0 } = {},
+  ) =>
+    getJSON(href(path, { kind }), { headers: headers(height) }).catch(err => {
+      throw Error(
+        `cannot read ${kind} of ${path}: ${err.message} ${err?.cause.message}`,
+      );
+    });
+  const readCell = (path, opts) =>
+    readStorage(path, opts)
+      .then(data => data.value)
+      .then(s => (s === '' ? {} : JSON.parse(s)));
+
+  return {
+    lcd,
+    readStorage,
+    readCell,
+  };
+};

a3p-integration/proposals/d:quick-send/test.sh

@@ -0,0 +1,2 @@
+#!/bin/bash
+yarn ava