TMP: creating alice avatar blob and profile record

Author: shuuji3

packages/client/globalSetup.ts

@@ -1,3 +1,5 @@
+import fs from 'node:fs/promises';
+
 import type { TestProject } from 'vitest/node';
 
 import { CredentialManager, XRPC } from '@atcute/client';
@@ -16,8 +18,8 @@ export async function setup(project: TestProject) {
     handler: manager,
   });
 
-  await createAccount(rpc, 'alice.test');
-  await createAccount(rpc, 'bob.test');
+  await createAccount(rpc, 'alice.test', manager);
+  await createAccount(rpc, 'bob.test', manager);
 
   project.provide('testPdsUrl', network.pds.url);
   project.provide('testPlcUrl', network.plc.url);
@@ -27,7 +29,16 @@ export async function teardown() {
   await network.close();
 }
 
-const createAccount = async (rpc: XRPC, handle: string) => {
+// sleep function with promise
+function sleep(sec: number) {
+  return new Promise((res) => setTimeout(res, sec * 1000));
+}
+
+const createAccount = async (
+  rpc: XRPC,
+  handle: string,
+  manager: CredentialManager,
+) => {
   await rpc.call('com.atproto.server.createAccount', {
     data: {
       handle: handle,
@@ -36,6 +47,87 @@ const createAccount = async (rpc: XRPC, handle: string) => {
     },
   });
   console.log(`🙋 Created new account: @${handle}`);
+
+  // authenticate
+  // create post
+  await manager.login({ identifier: 'alice.test', password: 'password' });
+
+  const { data: post } = await rpc.call('com.atproto.repo.createRecord', {
+    data: {
+      repo: 'alice.test',
+      collection: 'app.bsky.feed.post',
+      record: {
+        $type: 'app.bsky.feed.post',
+        createdAt: new Date().toISOString(),
+        text: "Hi, I'm Alice!",
+        langs: ['en'],
+      },
+    },
+  });
+  // console.log(`* post=${JSON.stringify(post, null, 2)}`);
+  /*
+  * post={
+    "uri": "at://did:plc:gcd4sqigo6mdn4njqwejknux/app.bsky.feed.post/3lik4gtsx5s2c",
+    "cid": "bafyreieqmqwthbpxhep2v3pu4zske2gekvwomzlzjlnt5ambn2vftcbyj4",
+    "commit": {
+      "cid": "bafyreidxz4gbxqk4bku7g3mk46hfk3ggz7i2eb547hlicboc2xg2y6nn7y",
+      "rev": "3lik4gtt32s2c"
+    },
+    "validationStatus": "valid"
+  }
+   */
+
+  const { buffer } = await fs.readFile(
+    'bafkreifl3xu4hsmmlov54dcblrswri3xrjm6aivrj5zvrqdmgkuyuontpm.jpeg',
+  );
+  const { data: blob } = await rpc.call('com.atproto.repo.uploadBlob', {
+    headers: { 'content-type': 'image/jpeg' },
+    data: buffer,
+  });
+  // console.log(`* blob=${JSON.stringify(blob, null, 2)}`);
+  /*
+  {
+    "blob": {
+      "$type": "blob",
+      "ref": {
+        "$link": "bafkreifl3xu4hsmmlov54dcblrswri3xrjm6aivrj5zvrqdmgkuyuontpm"
+      },
+      "mimeType": "image/jpeg",
+      "size": 315488
+    }
+  }
+  */
+
+  const { data: profile } = await rpc.call('com.atproto.repo.createRecord', {
+    data: {
+      repo: 'alice.test',
+      collection: 'app.bsky.actor.profile',
+      record: {
+        $type: 'app.bsky.actor.profile',
+        avatar: blob.blob,
+        // avatar: {
+        // cid: blob.blob.ref.$link,
+        // mimeType: blob.blob.mimeType,
+        // size: blob.blob.size,
+        // },
+        createdAt: new Date().toISOString(),
+        description: "I'm Alice!",
+        displayName: 'alice',
+      },
+    },
+  });
+  console.log(`profile=${JSON.stringify(profile, null, 2)}`);
+
+  const { data: records } = await rpc.get('com.atproto.repo.listRecords', {
+    params: {
+      repo: 'alice.test',
+      collection: 'app.bsky.actor.profile',
+      // collection: 'app.bsky.feed.post',
+    },
+  });
+  console.log(`* records=${JSON.stringify(records, null, 2)}`);
+
+  await sleep(60 * 10);
 };
 
 declare module 'vitest' {