···

       
1
       
1
       
 
       
// TODO:

     

       
2
       
2
       
 
       
// - dark mode

     

       
3
       
3
       
 
       
// - display loading notice when fetching existing session

     

       
4
       
4
       
-
       
// - rework oauth as implementation fleshes out

     

       
5
       
5
       
-
       
// - split in multiple files?

     

       
6
       
4
       
 
       


     

       
7
       
5
       
 
       
import {

     

       
8
       
6
       
 
       
  createSignal,

     
···

       
15
       
13
       
 
       
import { createStore } from "solid-js/store";

     

       
16
       
14
       
 
       


     

       
17
       
15
       
 
       
import { Agent } from "@atproto/api";

     

       
18
       
18
       
-
       
import {

     

       
19
       
19
       
-
       
  BrowserOAuthClient,

     

       
20
       
20
       
-
       
  OAuthSession,

     

       
21
       
21
       
-
       
} from "@atproto/oauth-client-browser";

     

       
16
       
16
       
+
       
import { BrowserOAuthClient } from "@atproto/oauth-client-browser";

     

       
22
       
17
       
 
       


     

       
23
       
18
       
 
       
enum RepoStatus {

     

       
24
       
19
       
 
       
  BLOCKEDBY = 1 << 0,

     
···

       
50
       
45
       
 
       
  setLoginState(false);

     

       
51
       
46
       
 
       
});

     

       
52
       
47
       
 
       


     

       
53
       
53
       
-
       
let appAgent: Agent;

     

       
48
       
48
       
+
       
let agent: Agent;

     

       
54
       
49
       
 
       
let userHandle: string;

     

       
55
       
50
       
 
       


     

       
56
       
56
       
-
       
const result: undefined | OAuthSession = await client.init().catch(() => {});

     

       
51
       
51
       
+
       
const result = await client.init().catch(() => {});

     

       
57
       
52
       
 
       


     

       
58
       
53
       
 
       
if (result) {

     

       
59
       
59
       
-
       
  const init = await client.init();

     

       
60
       
60
       
-
       
  appAgent = new Agent(init!.session);

     

       
54
       
54
       
+
       
  agent = new Agent(result.session);

     

       
61
       
55
       
 
       
  setLoginState(true);

     

       
62
       
62
       
-
       
  const res = await appAgent.getProfile({ actor: appAgent.did! });

     

       
56
       
56
       
+
       
  const res = await agent.getProfile({ actor: agent.did! });

     

       
63
       
57
       
 
       
  userHandle = res.data.handle;

     

       
64
       
58
       
 
       
}

     

       
65
       
59
       
 
       


     
···

       
76
       
70
       
 
       
};

     

       
77
       
71
       
 
       


     

       
78
       
72
       
 
       
const logoutBsky = async () => {

     

       
79
       
79
       
-
       
  if (result) await client.revoke(result.sub);

     

       
73
       
73
       
+
       
  if (result) await client.revoke(result.session.sub);

     

       
80
       
74
       
 
       
};

     

       
81
       
75
       
 
       


     

       
82
       
76
       
 
       
const Follows: Component = () => {

     
···

       
205
       
199
       
 
       
    const fetchFollows = async () => {

     

       
206
       
200
       
 
       
      const PAGE_LIMIT = 100;

     

       
207
       
201
       
 
       
      const fetchPage = async (cursor?: any) => {

     

       
208
       
208
       
-
       
        return await appAgent.com.atproto.repo.listRecords({

     

       
209
       
209
       
-
       
          repo: appAgent.did!,

     

       
202
       
202
       
+
       
        return await agent.com.atproto.repo.listRecords({

     

       
203
       
203
       
+
       
          repo: agent.did!,

     

       
210
       
204
       
 
       
          collection: "app.bsky.graph.follow",

     

       
211
       
205
       
 
       
          limit: PAGE_LIMIT,

     

       
212
       
206
       
 
       
          cursor: cursor,

     
···

       
232
       
226
       
 
       
        setFollowCount(follows.length);

     

       
233
       
227
       
 
       


     

       
234
       
228
       
 
       
        try {

     

       
235
       
235
       
-
       
          const res = await appAgent.getProfile({

     

       
229
       
229
       
+
       
          const res = await agent.getProfile({

     

       
236
       
230
       
 
       
            actor: record.value.subject,

     

       
237
       
231
       
 
       
          });

     

       
238
       
232
       
 
       


     
···

       
244
       
238
       
 
       
              viewer.blocking || viewer.blockingByList

     

       
245
       
239
       
 
       
                ? RepoStatus.BLOCKEDBY | RepoStatus.BLOCKING

     

       
246
       
240
       
 
       
                : RepoStatus.BLOCKEDBY;

     

       
247
       
247
       
-
       
          } else if (res.data.did.includes(appAgent.did!)) {

     

       
241
       
241
       
+
       
          } else if (res.data.did.includes(agent.did!)) {

     

       
248
       
242
       
 
       
            status = RepoStatus.YOURSELF;

     

       
249
       
243
       
 
       
          } else if (viewer.blocking || viewer.blockingByList) {

     

       
250
       
244
       
 
       
            status = RepoStatus.BLOCKING;

     
···

       
312
       
306
       
 
       


     

       
313
       
307
       
 
       
    const BATCHSIZE = 200;

     

       
314
       
308
       
 
       
    for (let i = 0; i < writes.length; i += BATCHSIZE) {

     

       
315
       
315
       
-
       
      await appAgent.com.atproto.repo.applyWrites({

     

       
316
       
316
       
-
       
        repo: appAgent.did!,

     

       
309
       
309
       
+
       
      await agent.com.atproto.repo.applyWrites({

     

       
310
       
310
       
+
       
        repo: agent.did!,

     

       
317
       
311
       
 
       
        writes: writes.slice(i, i + BATCHSIZE),

     

       
318
       
312
       
 
       
      });

     

       
319
       
313
       
 
       
    }