feat: wip linking all classes

Author: MathurAditya724

packages/client/src/actor/actor.ts

@@ -1,29 +1,23 @@
 import type {
   AppBskyActorDefs,
   AppBskyFeedGetAuthorFeed,
+  AppBskyGraphDefs,
+  At,
+  ComAtprotoLabelDefs,
+  ComAtprotoRepoStrongRef,
 } from '@tsky/lexicons';
 import type { Client } from '~/agent/client';
+import { List } from '~/list';
 import type { RPCOptions } from '~/types';
 import { Paginator } from '~/utils';
 
 export class Actor {
   client: Client;
-  identifier: string;
+  did: At.DID;
 
-  constructor(client: Client, identifier: string) {
+  constructor(client: Client, did: At.DID) {
     this.client = client;
-    this.identifier = identifier;
-  }
-
-  /**
-   * Get detailed profile view of an actor. Does not require auth, but contains relevant metadata with auth.
-   */
-  async profile(): Promise<AppBskyActorDefs.ProfileViewDetailed> {
-    const res = await this.client.get('app.bsky.actor.getProfile', {
-      params: { actor: this.identifier },
-    });
-
-    return res.data;
+    this.did = did;
   }
 
   /**
@@ -32,7 +26,7 @@ export class Actor {
   starterPacks(limit?: number, options: RPCOptions = {}) {
     return Paginator.init(async (cursor) => {
       const res = await this.client.get('app.bsky.graph.getActorStarterPacks', {
-        params: { cursor, actor: this.identifier, limit },
+        params: { cursor, actor: this.did, limit },
         ...options,
       });
 
@@ -48,13 +42,19 @@ export class Actor {
       const res = await this.client.get('app.bsky.graph.getFollowers', {
         params: {
           cursor,
-          actor: this.identifier,
+          actor: this.did,
           limit,
         },
         ...options,
       });
 
-      return res.data;
+      return {
+        ...res.data,
+        subject: new ActorProfile(this.client, res.data.subject),
+        followers: res.data.followers.map(
+          (follower) => new ActorProfile(this.client, follower),
+        ),
+      };
     });
   }
 
@@ -66,13 +66,19 @@ export class Actor {
       const res = await this.client.get('app.bsky.graph.getFollows', {
         params: {
           cursor,
-          actor: this.identifier,
+          actor: this.did,
           limit,
         },
         ...options,
       });
 
-      return res.data;
+      return {
+        ...res.data,
+        subject: new ActorProfile(this.client, res.data.subject),
+        follows: res.data.follows.map(
+          (follow) => new ActorProfile(this.client, follow),
+        ),
+      };
     });
   }
 
@@ -84,13 +90,17 @@ export class Actor {
       const res = await this.client.get('app.bsky.graph.getLists', {
         params: {
           cursor,
-          actor: this.identifier,
+          actor: this.did,
           limit,
         },
         ...options,
       });
 
-      return res.data;
+      return {
+        ...res.data,
+        // TODO: Solve this
+        // lists: res.data.lists.map((list) => new List(this.client, list)),
+      };
     });
   }
 
@@ -100,13 +110,18 @@ export class Actor {
   async relationships(others?: string[], options?: RPCOptions) {
     const res = await this.client.get('app.bsky.graph.getRelationships', {
       params: {
-        actor: this.identifier,
+        actor: this.did,
         others,
       },
       ...options,
     });
 
-    return res.data;
+    return {
+      ...res.data,
+      actor: res.data.actor
+        ? new Actor(this.client, res.data.actor)
+        : undefined,
+    };
   }
 
   /**
@@ -115,7 +130,7 @@ export class Actor {
   feeds(limit?: number, options?: RPCOptions) {
     return Paginator.init(async (cursor) => {
       const res = await this.client.get('app.bsky.feed.getActorFeeds', {
-        params: { cursor, actor: this.identifier, limit },
+        params: { cursor, actor: this.did, limit },
         ...options,
       });
 
@@ -132,11 +147,61 @@ export class Actor {
   ) {
     return Paginator.init(async (cursor) => {
       const res = await this.client.get('app.bsky.feed.getAuthorFeed', {
-        params: { cursor, ...params, actor: this.identifier },
+        params: { cursor, ...params, actor: this.did },
         ...options,
       });
 
       return res.data;
     });
   }
 }
+
+export class BasicActorProfile
+  extends Actor
+  implements AppBskyActorDefs.ProfileViewBasic
+{
+  // @ts-expect-error - We added this property with Object.assign
+  handle: string;
+  associated?: AppBskyActorDefs.ProfileAssociated;
+  avatar?: string;
+  createdAt?: string;
+  displayName?: string;
+  labels?: ComAtprotoLabelDefs.Label[];
+  viewer?: AppBskyActorDefs.ViewerState;
+  $type?: string;
+
+  constructor(client: Client, actor: AppBskyActorDefs.ProfileViewBasic) {
+    super(client, actor.did);
+    Object.assign(this, actor);
+  }
+}
+
+export class ActorProfile
+  extends BasicActorProfile
+  implements AppBskyActorDefs.ProfileView
+{
+  description?: string;
+  indexedAt?: string;
+
+  constructor(client: Client, actor: AppBskyActorDefs.ProfileViewDetailed) {
+    super(client, actor);
+    Object.assign(this, actor);
+  }
+}
+
+export class DetailedActorProfile
+  extends ActorProfile
+  implements AppBskyActorDefs.ProfileViewDetailed
+{
+  banner?: string;
+  followersCount?: number;
+  followsCount?: number;
+  joinedViaStarterPack?: AppBskyGraphDefs.StarterPackViewBasic;
+  pinnedPost?: ComAtprotoRepoStrongRef.Main;
+  postsCount?: number;
+
+  constructor(client: Client, actor: AppBskyActorDefs.ProfileViewDetailed) {
+    super(client, actor);
+    Object.assign(this, actor);
+  }
+}

packages/client/src/agent/agent.ts

@@ -2,9 +2,10 @@ import { type CredentialManager, XRPC } from '@atcute/client';
 import type {
   AppBskyGraphGetStarterPack,
   AppBskyGraphGetStarterPacks,
+  At,
   Queries,
 } from '@tsky/lexicons';
-import { Actor } from '~/actor';
+import { DetailedActorProfile } from '~/actor';
 import { Feed } from '~/feed';
 import { List } from '~/list';
 import { Search } from '~/search';
@@ -19,15 +20,22 @@ export class Agent {
   constructor(private handler: CredentialManager) {
     // Initialize the client
     const xrpc = new XRPC({ handler: this.handler });
-    this.client = new Client(xrpc);
+    this.client = new Client(xrpc, this.handler);
   }
 
   get session() {
     return this.handler.session;
   }
 
-  actor(identifier: string) {
-    return new Actor(this.client, identifier);
+  /**
+   * Get detailed profile view of an actor. Does not require auth, but contains relevant metadata with auth.
+   */
+  async actor(identifier: At.DID | At.Handle): Promise<DetailedActorProfile> {
+    const res = await this.client.get('app.bsky.actor.getProfile', {
+      params: { actor: identifier },
+    });
+
+    return new DetailedActorProfile(this.client, res.data);
   }
 
   list(uri: string) {
@@ -47,7 +55,7 @@ export class Agent {
       throw new Error('There is no active session');
     }
 
-    return new User(this.client, this.session.handle);
+    return new User(this.client, this.session.did);
   }
 
   get video() {

packages/client/src/agent/client.ts

@@ -1,24 +1,31 @@
 import type {
+  CredentialManager,
   RPCOptions,
   XRPC,
   XRPCRequestOptions,
   XRPCResponse,
 } from '@atcute/client';
-import type { Procedures, Queries } from '@tsky/lexicons';
+import type { At, Procedures, Queries } from '@tsky/lexicons';
+import { parseAtUri } from '~/utils';
+import type { RPCOptions as GenericReqOptions, StrongRef } from '../types';
 
 // From @atcute/client
 type OutputOf<T> = T extends {
-  // biome-ignore lint/suspicious/noExplicitAny: <explanation>
-  output: any;
+  output: unknown;
 }
   ? T['output']
   : never;
 
+const NO_SESSION_ERROR =
+  'No session found. Please login to perform this action.';
+
 export class Client<Q = Queries, P = Procedures> {
   xrpc: XRPC;
+  crenditials: CredentialManager;
 
-  constructor(xrpc: XRPC) {
+  constructor(xrpc: XRPC, crenditials: CredentialManager) {
     this.xrpc = xrpc;
+    this.crenditials = crenditials;
   }
 
   /**
@@ -53,4 +60,86 @@ export class Client<Q = Queries, P = Procedures> {
   async request(options: XRPCRequestOptions): Promise<XRPCResponse> {
     return this.xrpc.request(options);
   }
+
+  /**
+   * Create a record.
+   * @param nsid The collection's NSID.
+   * @param record The record to create.
+   * @param rkey The rkey to use.
+   * @returns The record's AT URI and CID.
+   */
+  async createRecord<K extends keyof P>(
+    nsid: K,
+    record: Omit<RPCOptions<P[K]>, '$type' | 'createdAt'>,
+    rkey?: string,
+  ): Promise<StrongRef> {
+    if (!this.crenditials.session) throw new Error(NO_SESSION_ERROR);
+    const response = await this.call(
+      'com.atproto.repo.createRecord' as keyof P,
+      {
+        data: {
+          collection: nsid,
+          record: {
+            $type: nsid,
+            createdAt: new Date().toISOString(),
+            ...record,
+          },
+          repo: this.crenditials.session.did,
+          ...(rkey ? { rkey } : {}),
+        },
+      } as unknown as RPCOptions<P[keyof P]>,
+    );
+    return response.data;
+  }
+
+  /**
+   * Put a record in place of an existing record.
+   * @param nsid The collection's NSID.
+   * @param record The record to put.
+   * @param rkey The rkey to use.
+   * @returns The record's AT URI and CID.
+   */
+  async putRecord(
+    nsid: string,
+    record: object,
+    rkey: string,
+  ): Promise<StrongRef> {
+    if (!this.crenditials.session) throw new Error(NO_SESSION_ERROR);
+    const response = await this.call(
+      'com.atproto.repo.putRecord' as keyof P,
+      {
+        data: {
+          collection: nsid,
+          record: {
+            $type: nsid,
+            createdAt: new Date().toISOString(),
+            ...record,
+          },
+          repo: this.crenditials.session.did,
+          rkey,
+        },
+      } as unknown as RPCOptions<P[keyof P]>,
+    );
+    return response.data;
+  }
+
+  /**
+   * Delete a record.
+   * @param uri The record's AT URI.
+   */
+  async deleteRecord(
+    uri: At.Uri,
+    options: GenericReqOptions = {},
+  ): Promise<void> {
+    const { host: repo, collection, rkey } = parseAtUri(uri);
+    if (repo !== this.crenditials.session?.did)
+      throw new Error('Can only delete own record.');
+    await this.call(
+      'com.atproto.repo.deleteRecord' as keyof P,
+      {
+        data: { collection, repo, rkey },
+        ...options,
+      } as unknown as RPCOptions<P[keyof P]>,
+    );
+  }
 }

packages/client/src/list/list.ts

@@ -1,3 +1,4 @@
+import { ActorProfile } from '~/actor';
 import type { Client } from '~/agent/client';
 import type { RPCOptions } from '~/types';
 import { Paginator } from '~/utils';
@@ -22,7 +23,13 @@ export class List {
         ...options,
       });
 
-      return res.data;
+      return {
+        ...res.data,
+        items: res.data.items.map((item) => ({
+          ...item,
+          subject: new ActorProfile(this.client, item.subject),
+        })),
+      };
     });
   }