feat(runner): call sync directly when not in shim; allow URIs in .sync calls (#1463)

* feat(runner): call sync directly when not in shim; allow URIs in .sync calls

- Update storage.ts to call sync directly when not running in a shim environment.
- Allow either EntityId or URIs on sync call (eventually we'll deprecate the former)

* cleaner return value

* Changes to use URI instead of EntityId in internal APIs (#1464)

* Minor tweaks
- Use await instead of a promise chain in Storage.syncCell.
- Use URI isntead of Entity, since we also define this in memory/interface.ts.

* Change IStorageProvider API to be URI based instead of EntityId as well as the BaseStorageProvider implementation and the Storage class.
Moved BaseStorageProvider.toEntity into Storage.toURI, since this is the only place it's needed.
Changed IStorageProvider to use URI instead of EntityId, as well as the ProviderConnection and Provider classes.
Updated tests to use cell.getAsNormalizedFullLink to get the URI instead of EntityId.

---------

Co-authored-by: ubik2 <ubik2@users.noreply.github.com>

Author: seefeldb

packages/runner/integration/reconnection.test.ts

@@ -7,7 +7,7 @@
 
 import { Identity } from "@commontools/identity";
 import { StorageManager } from "../src/storage/cache.ts";
-import type { SchemaContext } from "@commontools/memory/interface";
+import type { SchemaContext, URI } from "@commontools/memory/interface";
 
 const TOOLSHED_URL = Deno.env.get("TOOLSHED_API_URL") ||
   "http://localhost:8000";
@@ -72,30 +72,30 @@ const storageManager3 = StorageManager.open({
 });
 const provider3 = storageManager3.open(signer.did());
 console.log(`Provider3 (control) connected to memory server`);
-
+const uri: URI = `of:${TEST_DOC_ID}`;
 // Listen for updates on the test-reconnection-counter document
 // Note: this is not the schema subscription, its just a client-side listener
-provider1.sink({ "/": TEST_DOC_ID }, (value) => {
+provider1.sink(uri, (value) => {
   updateCount1++;
   updates1.push(value.value);
   console.log(`Provider1 Update #${updateCount1}:`, value.value);
 });
 
-provider3.sink({ "/": TEST_DOC_ID }, (value) => {
+provider3.sink(uri, (value) => {
   updateCount3++;
   updates3.push(value.value);
   console.log(`Provider3 Update #${updateCount3}:`, value.value);
 });
 
 // Establish server-side subscription with schema
 console.log("Establishing subscriptions...");
-await provider1.sync({ "/": TEST_DOC_ID }, true, testSchema);
-await provider3.sync({ "/": TEST_DOC_ID }, true, testSchema);
+await provider1.sync(uri, true, testSchema);
+await provider3.sync(uri, true, testSchema);
 
 // Send initial value to server
 console.log("Sending initial value...");
 await provider1.send([{
-  entityId: { "/": TEST_DOC_ID },
+  uri,
   value: {
     value: {
       value: 1,
@@ -155,7 +155,7 @@ console.log(`Connected to memory server as second client`);
 
 // Establish server-side subscription with schema
 console.log("Establishing subscription as second client...");
-await provider2.sync({ "/": TEST_DOC_ID }, true, testSchema);
+await provider2.sync(uri, true, testSchema);
 
 // Send test updates and check if subscription still works
 console.log("Sending test updates after disconnection...");
@@ -164,7 +164,7 @@ const intervalId = setInterval(async () => {
   try {
     // Send an update as the second
     const result = await provider2.send([{
-      entityId: { "/": TEST_DOC_ID },
+      uri,
       value: {
         value: {
           value: testValue++,

packages/runner/src/doc-map.ts

@@ -1,5 +1,6 @@
 import { refer } from "merkle-reference/json";
 import { isRecord } from "@commontools/utils/types";
+import { URI } from "@commontools/memory/interface";
 import { isOpaqueRef } from "./builder/types.ts";
 import { createDoc, type DocImpl, isDoc } from "./doc.ts";
 import {
@@ -118,19 +119,19 @@ export class DocumentMap implements IDocumentMap {
 
   getDocByEntityId<T = any>(
     space: MemorySpace,
-    entityId: EntityId | string,
+    entityId: EntityId | URI,
     createIfNotFound?: true,
     sourceIfCreated?: DocImpl<any>,
   ): DocImpl<T>;
   getDocByEntityId<T = any>(
     space: MemorySpace,
-    entityId: EntityId | string,
+    entityId: EntityId | URI,
     createIfNotFound: false,
     sourceIfCreated?: DocImpl<any>,
   ): DocImpl<T> | undefined;
   getDocByEntityId<T = any>(
     space: MemorySpace,
-    entityId: EntityId | string,
+    entityId: EntityId | URI,
     createIfNotFound = true,
     sourceIfCreated?: DocImpl<any>,
   ): DocImpl<T> | undefined {