migrate to dids, dht resolve #1146

Author: joepio

.claude/settings.local.json

@@ -0,0 +1,10 @@
+{
+  "permissions": {
+    "allow": [
+      "mcp__chrome-devtools__new_page",
+      "mcp__chrome-devtools__take_screenshot",
+      "Bash(cargo test --package atomic-server --test dht_resolve --no-run)",
+      "Bash(cargo test --package atomic-server --test dht_resolve -- --nocapture)"
+    ]
+  }
+}

Cargo.lock

@@ -1,4 +1,10 @@
-import { core, useStore, server, dataBrowser } from '@tomic/react';
+import {
+  core,
+  useStore,
+  server,
+  dataBrowser,
+  generateKeyPair,
+} from '@tomic/react';
 import { useState, useCallback, FormEvent, FC, useEffect, useId } from 'react';
 import { styled } from 'styled-components';
 import { stringToSlug } from '../../../../../helpers/stringToSlug';
@@ -16,6 +22,27 @@ import { CustomResourceDialogProps } from '../../useNewResourceUI';
 import { useCreateAndNavigate } from '../../../../../hooks/useCreateAndNavigate';
 import { useSettings } from '../../../../../helpers/AppSettings';
 
+const DRIVE_PUBLIC_KEY = 'https://atomicdata.dev/properties/drive/publicKey';
+const DRIVE_PRIVATE_KEY = 'https://atomicdata.dev/properties/drive/privateKey';
+const DRIVE_HASH = 'https://atomicdata.dev/properties/drive/hash';
+
+function decodeBase64(base64: string): Uint8Array {
+  const binary = atob(base64);
+  const bytes = new Uint8Array(binary.length);
+
+  for (let i = 0; i < binary.length; i++) {
+    bytes[i] = binary.charCodeAt(i);
+  }
+
+  return bytes;
+}
+
+function toHex(bytes: Uint8Array): string {
+  return Array.from(bytes)
+    .map(b => b.toString(16).padStart(2, '0'))
+    .join('');
+}
+
 export const NewDriveDialog: FC<CustomResourceDialogProps> = ({
   onClose,
   onCreated,
@@ -38,27 +65,44 @@ export const NewDriveDialog: FC<CustomResourceDialogProps> = ({
         'No agent set in the Store, required when creating a Drive',
       );
     }
+    const driveKeys = await generateKeyPair();
+    const drivePublicKeyBytes = decodeBase64(driveKeys.publicKey);
+    const prefix = new TextEncoder().encode('atomicdata.drive');
+    const hashInput = new Uint8Array(
+      prefix.length + drivePublicKeyBytes.length,
+    );
+    hashInput.set(prefix, 0);
+    hashInput.set(drivePublicKeyBytes, prefix.length);
+    const digest = await crypto.subtle.digest('SHA-256', hashInput);
+    const driveHash = toHex(new Uint8Array(digest).slice(0, 16));
 
     await createAndNavigate(
       server.classes.drive,
       {
         [core.properties.name]: name,
         [core.properties.write]: [agent.subject],
         [core.properties.read]: [agent.subject],
+        [DRIVE_PUBLIC_KEY]: driveKeys.publicKey,
+        [DRIVE_PRIVATE_KEY]: driveKeys.privateKey,
+        [DRIVE_HASH]: driveHash,
       },
       {
         noParent: true,
         skipNavigation,
         onCreated: async resource => {
           // Add drive to the agents drive list.
-          const agentResource = await store.getResource(agent.subject!);
-          agentResource.push(server.properties.drives, [resource.subject]);
-          await agentResource.save();
+          // DID agents may not have a local resource, so we ignore errors here.
+          try {
+            const agentResource = await store.getResource(agent.subject!);
+            agentResource.push(server.properties.drives, [resource.subject]);
+            await agentResource.save();
+          } catch (_e) {
+            // Agent resource update failed (e.g., DID agents don't have a local resource)
+          }
 
           // Create a default ontology.
           const ontologyName = stringToSlug(name.trim());
           const ontology = await store.newResource({
-            subject: `${resource.subject}/defaultOntology`,
             isA: core.classes.ontology,
             parent: resource.subject,
             propVals: {

browser/data-browser/src/components/forms/NewForm/CustomCreateActions/CustomForms/NewDriveDialog.tsx

@@ -54,10 +54,13 @@ export const AppSettingsContextProvider = (
 
   const setDrive = useCallback(
     (newDrive: string) => {
-      const url = new URL(newDrive);
       innerSetDrive(newDrive);
-      setBaseURL(url.origin);
-      serverURLStorage.set(url.origin);
+
+      if (newDrive.startsWith('http://') || newDrive.startsWith('https://')) {
+        const url = new URL(newDrive);
+        setBaseURL(url.origin);
+        serverURLStorage.set(url.origin);
+      }
     },
     [innerSetDrive, setBaseURL],
   );

browser/data-browser/src/helpers/AppSettings.tsx

@@ -50,7 +50,7 @@ export function useCreateAndNavigate(): CreateAndNavigate {
         await resource.save();
 
         if (onCreated) {
-          onCreated(resource);
+          await onCreated(resource);
         }
 
         if (!skipNavigation) {

browser/data-browser/src/hooks/useCreateAndNavigate.ts

@@ -3438,3 +3438,11 @@ msgstr ""
 #: src/views/InvitePage.tsx
 msgid "Failed to persist agent after accepting invite"
 msgstr ""
+
+#: src/views/InvitePage.tsx
+msgid "Invite accepted, but no destination was returned."
+msgstr ""
+
+#: src/components/forms/NewForm/SubjectField.tsx
+msgid "The identifier of the resource. DID subjects are determined by the genesis commit signature."
+msgstr ""

browser/data-browser/src/locales/de.po

@@ -3457,3 +3457,11 @@ msgstr "Failed to persist agent after accepting invite"
 #: src/routes/Search/SearchRoute.tsx
 msgid "Searching for <0/>..."
 msgstr "Searching for <0/>..."
+
+#: src/views/InvitePage.tsx
+msgid "Invite accepted, but no destination was returned."
+msgstr "Invite accepted, but no destination was returned."
+
+#: src/components/forms/NewForm/SubjectField.tsx
+msgid "The identifier of the resource. DID subjects are determined by the genesis commit signature."
+msgstr "The identifier of the resource. DID subjects are determined by the genesis commit signature."

browser/data-browser/src/locales/en.po

@@ -3424,3 +3424,11 @@ msgstr ""
 #: src/views/InvitePage.tsx
 msgid "Failed to persist agent after accepting invite"
 msgstr ""
+
+#: src/views/InvitePage.tsx
+msgid "Invite accepted, but no destination was returned."
+msgstr ""
+
+#: src/components/forms/NewForm/SubjectField.tsx
+msgid "The identifier of the resource. DID subjects are determined by the genesis commit signature."
+msgstr ""

browser/data-browser/src/locales/es.po

@@ -3437,3 +3437,11 @@ msgstr ""
 #: src/views/InvitePage.tsx
 msgid "Failed to persist agent after accepting invite"
 msgstr ""
+
+#: src/views/InvitePage.tsx
+msgid "Invite accepted, but no destination was returned."
+msgstr ""
+
+#: src/components/forms/NewForm/SubjectField.tsx
+msgid "The identifier of the resource. DID subjects are determined by the genesis commit signature."
+msgstr ""

browser/data-browser/src/locales/fr.po

@@ -57,10 +57,7 @@ export function ChatRoomPage({ resource }: ResourcePageProps) {
       e?.preventDefault();
 
       if (!disableSend) {
-        const subject = store.createSubject(resource.subject);
-
         const msgResource = await store.newResource({
-          subject,
           parent: resource.subject,
           isA: dataBrowser.classes.message,
           propVals: {