update scopes, init update records

src/hooks.server.ts

···
 
     // set the authed agent
     const authedAgent = new Agent(oauthSession);
-    event.locals.authedAgent = authedAgent;
+    if (!event.locals.authedAgent) {
+      event.locals.authedAgent = authedAgent;
+    }
 
     // set the authed user with decrypted session DID
     const user = await authedAgent.getProfile({ actor: decrypted });

src/lib/atproto.ts

···
 
 const publicUrl = "https://easytodo.link"
 // localhost resolves to either 127.0.0.1 or [::1] (if ipv6)
-const url = dev ? "http://[::1]:5173" : publicUrl;
+const url = dev ? "http://127.0.0.1:5173" : publicUrl;
 
 export const atclient = new NodeOAuthClient({
   stateStore: new AuthStateStore(db),
···
       : `http://localhost?redirect_uri=${
           encodeURIComponent(`${url}/oauth/callback`)
         }&scope=${
-          encodeURIComponent(`atproto repo:link.easytodo.tasks.list repo:link.easytodo.tasks.task`)
+          encodeURIComponent(`atproto repo:link.easytodo.tasks.list repo:link.easytodo.tasks.task rpc:app.bsky.actor.getProfile?aud=did:web:api.bsky.app%23bsky_appview`)
         }`,
     client_uri: url,
     redirect_uris: [`${url}/oauth/callback`],
-    scope: "atproto repo:link.easytodo.tasks.list repo:link.easytodo.tasks.task",
+    scope: "atproto repo:link.easytodo.tasks.list repo:link.easytodo.tasks.task rpc:app.bsky.actor.getProfile?aud=did:web:api.bsky.app%23bsky_appview",
     grant_types: ["authorization_code", "refresh_token"],
     application_type: "web",
     token_endpoint_auth_method: "none",

src/lib/stores.svelte.ts

···
   // optional
   duration?: number;
   stopwatchInterval?: number;
+  rkey?: string;
 }
 
 export type List = {
   id: string;
   title: string;
   tasks: Task[];
+  rkey?: string;
 }
 
 export const local_lists = persisted<List[]>("local_lists", [

src/lib/utils.ts

···
   return generateRandomString(10, alphabet("a-z", "0-9"));
 }
 
+export function parseAtUri(uri: string) {
+  const regex = /at:\/\/(?<did>did.*)\/(?<lexi>.*)\/(?<rkey>.*)/;
+  const groups = regex.exec(uri)?.groups;
+  return {
+    did: groups?.did,
+    lexi: groups?.lexi,
+    rkey: groups?.rkey
+  }
+}
+
 export function formatSecondsToDuration(seconds: number = 0) {
   let hours   = Math.floor(seconds / 3600);
   let minutes = Math.floor((seconds - (hours * 3600)) / 60);

src/routes/+page.server.ts

···
 import { atclient } from "$lib/atproto";
 import type { Task } from "$lib/stores.svelte";
+import { parseAtUri } from "$lib/utils";
 import type { $Typed } from "@atproto/api";
 import type { Create, CreateResult } from "@atproto/api/dist/client/types/com/atproto/repo/applyWrites";
 import { isValidHandle } from "@atproto/syntax";
···
 
     // get oauth authorizing url to redirect to
     const redirectUrl = await atclient.authorize(handle, {
-      scope: "atproto repo:link.easytodo.tasks.list repo:link.easytodo.tasks.task"
+      scope: "atproto repo:link.easytodo.tasks.list repo:link.easytodo.tasks.task rpc:app.bsky.actor.getProfile?aud=did:web:api.bsky.app%23bsky_appview"
     });
 
     if (!redirectUrl) { 
···
 
     const formData = await request.formData();
     const id = formData.get("id") as string;
+    const list_rkey = formData.get("rkey") as string;
     const title = formData.get("title") as string;
     const tasks = JSON.parse(formData.get("tasks") as string) as Task[];
-    
-    const task_records = tasks.map((t) => {
-      const { stopwatchInterval, ...rest } = t;
-      return {
-        $type: "link.easytodo.tasks.task",
-        ...rest
-      }
-    });
 
     const response = await agent.com.atproto.repo.applyWrites({
       repo: user.did,
-      writes: task_records.map((r) => {
-        return { 
-          $type: 'com.atproto.repo.applyWrites#create',
-          collection: "link.easytodo.tasks.task", 
-          value: r 
-        } 
+      writes: tasks.map((t) => {
+        const { rkey: task_rkey, stopwatchInterval, ...rest } = t;
+        if (task_rkey) {
+          console.log("UPDATE TASK");
+          return { 
+            $type: 'com.atproto.repo.applyWrites#update',
+            collection: "link.easytodo.tasks.task", 
+            rkey: task_rkey,
+            value: {
+              $type: "link.easytodo.tasks.task",
+              ...rest
+            }
+          } 
+        }
+        else {
+          console.log("CREATE TASK");
+          return { 
+            $type: 'com.atproto.repo.applyWrites#create',
+            collection: "link.easytodo.tasks.task", 
+            value: {
+              $type: "link.easytodo.tasks.task",
+              ...rest
+            },
+          } 
+        }
       })
     });
-
+    
     if (response.success) {
       console.log(response.data.results);
       const list_record = {
···
           return { cid: t.cid, uri: t.uri }
         })
       };
-      const { success, data } = await agent.com.atproto.repo.createRecord({
-        repo: user.did,
-        collection: "link.easytodo.tasks.list",
-        record: list_record
-      });
 
-      return { saveListRecordResult: { success, uri: data.uri }};
+      if (list_rkey) {
+        const { success, data } = await agent.com.atproto.repo.putRecord({
+          rkey: list_rkey,
+          repo: user.did,
+          collection: "link.easytodo.tasks.list",
+          record: list_record
+        });
+        console.log("UPDATE LIST", { success, uri: data.uri });
+        return { saveListRecordResult: { success, rkey: list_rkey, uri: data.uri }};
+      }
+      else {
+        const { success, data } = await agent.com.atproto.repo.createRecord({
+          repo: user.did,
+          collection: "link.easytodo.tasks.list",
+          record: list_record
+        });
+        const { rkey } = parseAtUri(data.uri);
+        console.log("CREATE LIST", { success, rkey, uri: data.uri });
+        return { saveListRecordResult: { success, rkey, uri: data.uri }};
+      }
+
     }
   }
 };