bobbydigitales/dandelion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add peer disconnect event dispatch

Browse Source
This commit is contained in:
bobbydigitales
2025-04-29 01:10:03 -07:00
parent 0005f06b2b
commit 45b707f39d
3 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
deno/ddln_server.ts
View File

@@ -200,9 +200,10 @@ interface PeerMessage {
} }
function peerMessageHandler(m: PeerMessage, _socket: WebSocket) { function peerMessageHandler(m: PeerMessage, _socket: WebSocket) {
const time = Temporal.Now.zonedDateTimeISO();
console.log(`pm:${m.message.type} f:${colorID(m.from)}:${m.from_peername}:${m.from_username} t:${colorID(m.to)}`) console.log(`[${time}]pm:${m.message.type} f:${colorID(m.from)}:${m.from_peername}:${m.from_username} t:${colorID(m.to)}`)
const toPeer = peerSockets.get(m.to); const toPeer = peerSockets.get(m.to);
if (!toPeer) { if (!toPeer) {
console.log(`Couln't find peer ${m.to}`) console.log(`Couln't find peer ${m.to}`)

2
src/PeerManager.ts
View File

@@ -314,6 +314,8 @@ export class PeerManager {
this.bootstrapPeerConnection = null; this.bootstrapPeerConnection = null;
} }
this.dispatchEvent(PeerEventTypes.PEER_DISCONNECTED, {peerID:remotePeerID});
} }
async disconnectFromPeer(remotePeerID: string) { async disconnectFromPeer(remotePeerID: string) {

6
src/bootstrap_main.ts
View File

@@ -38,10 +38,10 @@ Restruucture the app around the data. App/WS split is messy. Clean it up.
// import * as ForceGraph3D from "3d-force-graph"; // import * as ForceGraph3D from "3d-force-graph";
// import { openDatabase, getData, addData, addDataArray, clearData, deleteData, mergeDataArray, getAllData, checkPostIds, getAllIds, getPostsByIds } from "db"; // import { openDatabase, getData, addData, addDataArray, clearData, deleteData, mergeDataArray, getAllData, checkPostIds, getAllIds, getPostsByIds } from "db";
import { generateID } from "IDUtils"; import { generateID } from "./IDUtils.js";
import { PeerManager } from "PeerManager"; import { PeerManager } from "./PeerManager.js";
import {log, logID, renderLog, setLogVisibility} from "log" import {log, logID, renderLog, setLogVisibility} from "./log.js"
// import {PeerConnection} from "webRTC"; // import {PeerConnection} from "webRTC";