Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
@xiaohaodu
xiaohaodu committed Jun 1, 2024
1 parent 320cabe commit 089cc5f
Show file tree
Hide file tree
Showing 2 changed files with 62 additions and 53 deletions.
113 changes: 61 additions & 52 deletions packages/local-chat-x-core/libp2p.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -109,61 +109,70 @@ export default class Libp2pManager {
});
}
private handleListenEvent() {
this.libp2p.addEventListener("connection:open", (connection) => {
console.log("connection:open", connection.detail);
});
this.libp2p.addEventListener("connection:close", (connection) => {
console.log("connection:open", connection.detail);
});
this.libp2p.addEventListener("connection:prune", (connection) => {
console.log("connection:prune", connection.detail);
});
this.libp2p.addEventListener("peer:connect", (peerId) => {
console.log("peer:connect ", peerId.detail);
});
this.libp2p.addEventListener("peer:disconnect", (peerId) => {
console.log("peer:disconnect ", peerId.detail);
});
// this.libp2p.addEventListener("connection:open", (connection) => {
// console.log("connection:open", connection.detail);
// });
// this.libp2p.addEventListener("connection:close", (connection) => {
// console.log("connection:open", connection.detail);
// });
// this.libp2p.addEventListener("connection:prune", (connection) => {
// console.log("connection:prune", connection.detail);
// });
// this.libp2p.addEventListener("peer:connect", (peerId) => {
// console.log("peer:connect ", peerId.detail);
// });
// this.libp2p.addEventListener("peer:disconnect", (peerId) => {
// console.log("peer:disconnect ", peerId.detail);
// });
this.libp2p.addEventListener("peer:discovery", (peerIdInfo) => {
console.log("peer:discovery ", peerIdInfo.detail);
// console.log("peer:discovery ", peerIdInfo.detail);
console.log(
"peer:discovery",
peerIdInfo.detail.multiaddrs.filter((multiaddr) => {
return (
multiaddr.toString().includes("webrtc") ||
multiaddr.toString().includes("ws")
);
})
);
});

this.libp2p.addEventListener("peer:identify", (identifyResult) => {
console.log("peer:identify ", identifyResult.detail);
});
this.libp2p.addEventListener("peer:update", (peerUpdate) => {
console.log("peer:update ", peerUpdate.detail);
});
this.libp2p.addEventListener("self:peer:update", (peerUpdate) => {
console.log("self:peer:update ", peerUpdate.detail);
console.log("self:peer:update protocols", this.libp2p.getProtocols());
console.log("self:peer:update multiaddrs", this.libp2p.getMultiaddrs());
this.libp2p.getMultiaddrs().forEach((multiaddr, index) => {
console.log(
`self:peer:update multiaddr ${index} ${multiaddr.toString()}`
);
});
console.log("self:peer:update dialQueue", this.libp2p.getDialQueue());
console.log("self:peer:update connections", this.libp2p.getConnections());
console.log("self:peer:update peers", this.libp2p.getPeers());
});
this.libp2p.addEventListener("start", () => {
console.log("start");
console.log("protocols", this.libp2p.getProtocols());
console.log("multiaddrs", this.libp2p.getMultiaddrs());
console.log("dialQueue", this.libp2p.getDialQueue());
console.log("connections", this.libp2p.getConnections());
console.log("peers", this.libp2p.getPeers());
});
this.libp2p.addEventListener("stop", () => {
console.log("stop");
});
this.libp2p.addEventListener("transport:close", (listener) => {
console.log("transport:close", listener.detail);
});
this.libp2p.addEventListener("transport:listening", (listener) => {
console.log("transport:listening", listener.detail);
});
// this.libp2p.addEventListener("peer:identify", (identifyResult) => {
// console.log("peer:identify ", identifyResult.detail);
// });
// this.libp2p.addEventListener("peer:update", (peerUpdate) => {
// console.log("peer:update ", peerUpdate.detail);
// });
// this.libp2p.addEventListener("self:peer:update", (peerUpdate) => {
// console.log("self:peer:update ", peerUpdate.detail);
// console.log("self:peer:update protocols", this.libp2p.getProtocols());
// console.log("self:peer:update multiaddrs", this.libp2p.getMultiaddrs());
// this.libp2p.getMultiaddrs().forEach((multiaddr, index) => {
// console.log(
// `self:peer:update multiaddr ${index} ${multiaddr.toString()}`
// );
// });
// console.log("self:peer:update dialQueue", this.libp2p.getDialQueue());
// console.log("self:peer:update connections", this.libp2p.getConnections());
// console.log("self:peer:update peers", this.libp2p.getPeers());
// });
// this.libp2p.addEventListener("start", () => {
// console.log("start");
// console.log("protocols", this.libp2p.getProtocols());
// console.log("multiaddrs", this.libp2p.getMultiaddrs());
// console.log("dialQueue", this.libp2p.getDialQueue());
// console.log("connections", this.libp2p.getConnections());
// console.log("peers", this.libp2p.getPeers());
// });
// this.libp2p.addEventListener("stop", () => {
// console.log("stop");
// });
// this.libp2p.addEventListener("transport:close", (listener) => {
// console.log("transport:close", listener.detail);
// });
// this.libp2p.addEventListener("transport:listening", (listener) => {
// console.log("transport:listening", listener.detail);
// });
}

private handleProtocol() {}
Expand Down
2 changes: 1 addition & 1 deletion packages/web-chat-x-vue/src/views/PrivateChat.vue
View file
Original file line number Diff line number Diff line change
Expand Up @@ -183,7 +183,7 @@ async function isOnlineProxy(handle:Function|(()=>{})){
const {peerManager}=usePeer()
peerManager.remotePeerId=friendId
peerManager.remoteUser=ref(friend)
peerManager.remoteUser=friend
async function audioCall(){
await peerManager.speakCall(false,true)
}
Expand Down

0 comments on commit 089cc5f

Please sign in to comment.