···

       
1
       
-
       
import { channelSessions } from "@/lib/state";

     

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

     

       
3
       
 
       
import { systemsGmstnDevelopmentChannelRecordSchema } from "@/lib/types/lexicon/systems.gmstn.development.channel";

     

       
4
       
 
       
import {

     
···

       
110
       
 
       
        if (!handshakeResult.ok) continue;

     

       
111
       
 
       
        const sessionInfo = handshakeResult.data;

     

       
112
       
 
       
        console.log("Handshake to", shardAtUri.rKey, "complete!");

     

       
113
       
-
       
        channelSessions.set(shardAtUri, sessionInfo);

     

       
114
       
 
       
    }

     

       
115
       
 
       
};

     

···

       
1
       
+
       
import { handshakeTokens, shardSessions } from "@/lib/state";

     

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

     

       
3
       
 
       
import { systemsGmstnDevelopmentChannelRecordSchema } from "@/lib/types/lexicon/systems.gmstn.development.channel";

     

       
4
       
 
       
import {

     
···

       
110
       
 
       
        if (!handshakeResult.ok) continue;

     

       
111
       
 
       
        const sessionInfo = handshakeResult.data;

     

       
112
       
 
       
        console.log("Handshake to", shardAtUri.rKey, "complete!");

     

       
113
       
+
       
        handshakeTokens.set(shardAtUri, sessionInfo);

     

       
114
       
 
       
    }

     

       
115
       
 
       
};

     

···

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

     

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

     

       
0
       
 
       

     

       
3
       
 
       


     

       
4
       
 
       
export const registrationState = {

     

       
5
       
 
       
    registered: false,

     
···

       
14
       
 
       
    return registrationState;

     

       
15
       
 
       
};

     

       
16
       
 
       


     

       
17
       
-
       
export const channelSessions = new Map<AtUri, SessionInfo>();

     

       
0
       
 
       

     

···

       
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 = {

     

       
6
       
 
       
    registered: false,

     
···

       
15
       
 
       
    return registrationState;

     

       
16
       
 
       
};

     

       
17
       
 
       


     

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

     

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