LeenkxTeam/LNXSDK
3
3
Fork 5
Code Issues 16 Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: LeenkxTeam:main
Branches Tags
LeenkxTeam:main LeenkxTeam:Ref Onek8:main
..
compare: Onek8:main
Branches Tags
Onek8:main LeenkxTeam:main LeenkxTeam:Ref

3 Commits
main ... main

Author SHA1 Message Date
Onek8
6454d741d4 P2P fix raw dedup 2026-10-27 23:06:31 -07:00
Onek8
7d63d60d99 Merge branch 'main' of https://dev.leenkx.com/Onek8/LNXSDK 2026-10-27 22:42:45 -07:00
Onek8
9f37c2bd8b P2P wire peer event order 2026-10-27 22:42:26 -07:00
2 changed files with 7 additions and 6 deletions
Expand all files Collapse all files

7
leenkx/Sources/leenkx/network/torrent/LeenkxClient.hx
View File

@ -408,9 +408,10 @@ class LeenkxClient {
}
function onMessageData(identifier:String, message:Bytes, ?senderPk:String):Void {
var hash = Crypto.hash(message).sub(0, 16).toHex();
var hash = (message.length > 0 && message.get(0) == 0x00)
? null : Crypto.hash(message).sub(0, 16).toHex();
var t = now();
if (!seen.exists(hash)) {
if (hash == null || !seen.exists(hash)) {
if (message.length > 0 && (message.get(0) == 0x00 || message.get(0) == 0x01)) {
var isRelayed = message.get(0) == 0x01;
var offset = 1;
@ -434,7 +435,7 @@ class LeenkxClient {
var rawPayload = message.sub(offset, message.length - offset);
var payload = new leenkx.network.Buffer();
payload.writeBytes(rawPayload);
seen.set(hash, t);
if (isRelayed) seen.set(hash, t);
var senderAddr = msgSenderPk != null ? pkToAddress.get(msgSenderPk) : null;
if (senderAddr == null && msgSenderPk != null && msgSenderPk != "") {
senderAddr = addressFromPk(msgSenderPk);

6
leenkx/Sources/leenkx/network/torrent/transport/WireTransport.hx
View File

@ -116,9 +116,6 @@ class WireTransport implements ITransport {
if (onPeerHandshake != null && remotePk != "") {
onPeerHandshake(remotePk, remoteEk);
}
if (onPeerConnected != null) {
onPeerConnected(peerId, getPeerCount());
}
};
wire.onExtended = function(name:String, data:Bytes) {
if (name != EXT) return;
@ -132,6 +129,9 @@ class WireTransport implements ITransport {
if (onError != null) onError(msg);
};
wire.start([EXT]);
if (onPeerConnected != null) {
onPeerConnected(peerId, getPeerCount());
}
}
function onPeerLeft(peerId:String):Void {