Fix direct read adapter review findings

Author: snissn

src/demo/tokenhost-wrapper.mjs

@@ -285,13 +285,14 @@ export function createTokenHostRegistryDirectReadAdapter({
 
   async function readDatasetPage({ offset = 0n, limit = maxLimit } = {}) {
     const normalizedLimit = normalizePageLimit(limit, maxLimit);
-    const keys = Array.from(
+    const rawKeys = Array.from(
       await readContract(
         registryDatasetKeysPageRead(registryAddress, { offset, limit: normalizedLimit }),
       ),
     );
+    const keys = rawKeys.map(registryDatasetKeyId);
     const datasets = await mapWithConcurrency(
-      keys,
+      rawKeys,
       maxDetailConcurrency,
       async (key) => {
         const dataset = normalizeRegistryDatasetRecord(
@@ -306,7 +307,7 @@ export function createTokenHostRegistryDirectReadAdapter({
 
     return {
       sourceOfTruth: DIRECT_READ_SOURCE,
-      pagination: offsetPagination({ offset, limit: normalizedLimit, rows: keys }),
+      pagination: offsetPagination({ offset, limit: normalizedLimit, rows: rawKeys }),
       keys,
       datasets,
     };
@@ -478,7 +479,7 @@ export function createTokenHostRegistryDirectReadAdapter({
       { model },
       {
         ...options,
-        now: options.now ?? now,
+        now: options.now ?? now ?? currentUnixSeconds(),
       },
     );
   }
@@ -758,6 +759,10 @@ function normalizeConcurrency(concurrency) {
   return value;
 }
 
+function currentUnixSeconds() {
+  return Math.floor(Date.now() / 1000);
+}
+
 function decimalString(value) {
   return BigInt(value).toString();
 }

test/tokenhost-direct-reads.test.mjs

@@ -52,6 +52,10 @@ test("Token Host direct read adapter builds admin surfaces from registry list vi
   assert.equal(accountPage.accounts[0].objectPagination.mode, "objectIdCursor");
   assert.deepEqual((await adapter.readAccountObjectPage(ACCOUNT_A, { limit: 2n })).ids, ["1"]);
 
+  const datasetPage = await adapter.readDatasetPage({ limit: 2n });
+  assert.deepEqual(datasetPage.keys, [`${ACCOUNT_A}:111:222`]);
+  assert.doesNotThrow(() => JSON.stringify(datasetPage));
+
   const surfaces = await adapter.readAdminSurfaces({ limit: 2n });
   assert.equal(
     surfaces.sourceOfTruth.platformState,
@@ -158,6 +162,17 @@ test("Token Host direct read adapter honors admin route hints", async () => {
   ]);
 });
 
+test("Token Host direct read adapter defaults admin time for coordinator expiry checks", async () => {
+  const adapter = createTokenHostRegistryDirectReadAdapter({
+    publicClient: createRegistryFixtureClient(),
+    registryAddress: REGISTRY_ADDRESS,
+    maxPageSize: 2,
+  });
+  const surfaces = await adapter.readAdminSurfaces({ route: { name: "coordinators" } });
+
+  assert.equal(surfaces.coordinators[0].sessionStatus, "expired");
+});
+
 test("Token Host direct read adapter restarts active cursor pages from the registry head", async () => {
   const adapter = createTokenHostRegistryDirectReadAdapter({
     publicClient: createRegistryFixtureClient({ staleActiveCursor: 99n }),