···

       
1
       
 
       
import type { AtUri } from "@/lib/types/atproto";

     

       
2
       
-
       
import type { SessionInfo } from "@/lib/types/handshake";

     

       
3
       
 
       
import type WebSocket from "ws";

     

       
4
       
 
       


     

       
5
       
 
       
export const registrationState = {

     
···

       
15
       
 
       
    return registrationState;

     

       
16
       
 
       
};

     

       
17
       
 
       


     

       
18
       
-
       
export const handshakeTokens = new Map<AtUri, SessionInfo>();

     

       
19
       
-
       
export const shardSessions = new Map<SessionInfo, WebSocket>();

     

···

       
1
       
 
       
import type { AtUri } from "@/lib/types/atproto";

     

       
2
       
+
       
import type { ShardSessionInfo } from "@/lib/types/handshake";

     

       
3
       
 
       
import type WebSocket from "ws";

     

       
4
       
 
       


     

       
5
       
 
       
export const registrationState = {

     
···

       
15
       
 
       
    return registrationState;

     

       
16
       
 
       
};

     

       
17
       
 
       


     

       
18
       
+
       
export const handshakeTokens = new Map<AtUri, ShardSessionInfo>();

     

       
19
       
+
       
export const shardSessions = new Map<ShardSessionInfo, WebSocket>();

     

···

       
1
       
 
       
import { atUriSchema } from "@/lib/types/atproto";

     

       
2
       
 
       
import { z } from "zod";

     

       
3
       
 
       


     

       
4
       
-
       
export const sessionInfoSchema = z.object({

     

       
5
       
 
       
    id: z.string(),

     

       
6
       
 
       
    token: z.string(),

     

       
7
       
 
       
    fingerprint: z.string(),

     

       
8
       
 
       
    allowedChannels: z.array(atUriSchema),

     

       
9
       
 
       
});

     

       
10
       
-
       
export type SessionInfo = z.infer<typeof sessionInfoSchema>;

     

···

       
1
       
 
       
import { atUriSchema } from "@/lib/types/atproto";

     

       
2
       
 
       
import { z } from "zod";

     

       
3
       
 
       


     

       
4
       
+
       
export const shardSessionInfoSchema = z.object({

     

       
5
       
 
       
    id: z.string(),

     

       
6
       
 
       
    token: z.string(),

     

       
7
       
 
       
    fingerprint: z.string(),

     

       
8
       
 
       
    allowedChannels: z.array(atUriSchema),

     

       
9
       
 
       
});

     

       
10
       
+
       
export type ShardSessionInfo = z.infer<typeof shardSessionInfoSchema>;

     

···

       
1
       
-
       
import { sessionInfoSchema } from "@/lib/types/handshake";

     

       
2
       
 
       
import { httpResponseErrorInfoSchema } from "@/lib/types/http/errors";

     

       
3
       
 
       
import { z } from "zod";

     

       
4
       
 
       


     
···

       
12
       
 
       
>;

     

       
13
       
 
       


     

       
14
       
 
       
export const handshakeResponseSchema = z.object({

     

       
15
       
-
       
    sessionInfo: sessionInfoSchema,

     

       
16
       
 
       
});

     

       
17
       
 
       
export type HandshakeResponse = z.infer<typeof handshakeResponseSchema>;

     

       
18
       
 
       


     

···

       
1
       
+
       
import { shardSessionInfoSchema } from "@/lib/types/handshake";

     

       
2
       
 
       
import { httpResponseErrorInfoSchema } from "@/lib/types/http/errors";

     

       
3
       
 
       
import { z } from "zod";

     

       
4
       
 
       


     
···

       
12
       
 
       
>;

     

       
13
       
 
       


     

       
14
       
 
       
export const handshakeResponseSchema = z.object({

     

       
15
       
+
       
    sessionInfo: shardSessionInfoSchema,

     

       
16
       
 
       
});

     

       
17
       
 
       
export type HandshakeResponse = z.infer<typeof handshakeResponseSchema>;

     

       
18
       
 
       


     

···

       
1
       
 
       
import type { AtUri, Did } from "@/lib/types/atproto";

     

       
2
       
-
       
import type { SessionInfo } from "@/lib/types/handshake";

     

       
3
       
 
       
import {

     

       
4
       
 
       
    handshakeResponseSchema,

     

       
5
       
 
       
    httpSuccessResponseSchema,

     
···

       
16
       
 
       
}: {

     

       
17
       
 
       
    did: Did;

     

       
18
       
 
       
    channels: Array<AtUri>;

     

       
19
       
-
       
}): Promise<Result<SessionInfo, unknown>> => {

     

       
20
       
 
       
    const shardUrlResult = await getShardEndpointFromDid(did);

     

       
21
       
 
       
    if (!shardUrlResult.ok) return { ok: false, error: shardUrlResult.error };

     

       
22
       
 
       


     

···

       
1
       
 
       
import type { AtUri, Did } from "@/lib/types/atproto";

     

       
2
       
+
       
import type { ShardSessionInfo } from "@/lib/types/handshake";

     

       
3
       
 
       
import {

     

       
4
       
 
       
    handshakeResponseSchema,

     

       
5
       
 
       
    httpSuccessResponseSchema,

     
···

       
16
       
 
       
}: {

     

       
17
       
 
       
    did: Did;

     

       
18
       
 
       
    channels: Array<AtUri>;

     

       
19
       
+
       
}): Promise<Result<ShardSessionInfo, unknown>> => {

     

       
20
       
 
       
    const shardUrlResult = await getShardEndpointFromDid(did);

     

       
21
       
 
       
    if (!shardUrlResult.ok) return { ok: false, error: shardUrlResult.error };

     

       
22