From 61415577c03169c8eab09ad7ebbd815c071d0bb0 Mon Sep 17 00:00:00 2001
From: Nischal D <nxdeo010@gmail.com>
Date: Sun, 5 Oct 2025 18:49:07 +0530
Subject: [PATCH] FIX/Fix the BroadCast File Transfer

---
 .classpath                                    |  10 -
 .project                                      |  28 --
 .settings/org.eclipse.core.resources.prefs    |   2 -
 .settings/org.eclipse.jdt.core.prefs          |  11 -
 bin/Main/Main.class                           | Bin 3339 -> 0 bytes
 bin/discovery/CentralRegistry.class           | Bin 4626 -> 0 bytes
 bin/discovery/FileData.class                  | Bin 4266 -> 0 bytes
 bin/discovery/Handshake.class                 | Bin 4630 -> 0 bytes
 bin/discovery/Node.class                      | Bin 2019 -> 0 bytes
 .../messages/CentralRegistryRequest.class     | Bin 1157 -> 0 bytes
 .../messages/CentralRegistryResponse.class    | Bin 1234 -> 0 bytes
 bin/discovery/messages/FileRequest.class      | Bin 522 -> 0 bytes
 bin/discovery/messages/FileResponse.class     | Bin 683 -> 0 bytes
 bin/discovery/messages/TransferRequest.class  | Bin 590 -> 0 bytes
 bin/discovery/messages/TransferResponse.class | Bin 680 -> 0 bytes
 bin/module-info.class                         | Bin 153 -> 0 bytes
 bin/p2p/ConnectionHandlerParallel.class       | Bin 4678 -> 0 bytes
 bin/p2p/ConnectionHandlerSequential.class     | Bin 4235 -> 0 bytes
 bin/p2p/FileTransfer.class                    | Bin 3998 -> 0 bytes
 bin/p2p/ObjectTransfer.class                  | Bin 1208 -> 0 bytes
 bin/utils/FileTransfer.class                  | Bin 4643 -> 0 bytes
 config.properties                             |  10 +
 src/Main/Main.java                            |  15 +-
 src/p2p/BroadCastTransfer.java                | 304 ++++++++++++++----
 src/p2p/ObjectTransfer.java                   |  38 ++-
 src/utils/Config.java                         |  35 ++
 26 files changed, 320 insertions(+), 133 deletions(-)
 delete mode 100644 .classpath
 delete mode 100644 .project
 delete mode 100644 .settings/org.eclipse.core.resources.prefs
 delete mode 100644 .settings/org.eclipse.jdt.core.prefs
 delete mode 100644 bin/Main/Main.class
 delete mode 100644 bin/discovery/CentralRegistry.class
 delete mode 100644 bin/discovery/FileData.class
 delete mode 100644 bin/discovery/Handshake.class
 delete mode 100644 bin/discovery/Node.class
 delete mode 100644 bin/discovery/messages/CentralRegistryRequest.class
 delete mode 100644 bin/discovery/messages/CentralRegistryResponse.class
 delete mode 100644 bin/discovery/messages/FileRequest.class
 delete mode 100644 bin/discovery/messages/FileResponse.class
 delete mode 100644 bin/discovery/messages/TransferRequest.class
 delete mode 100644 bin/discovery/messages/TransferResponse.class
 delete mode 100644 bin/module-info.class
 delete mode 100644 bin/p2p/ConnectionHandlerParallel.class
 delete mode 100644 bin/p2p/ConnectionHandlerSequential.class
 delete mode 100644 bin/p2p/FileTransfer.class
 delete mode 100644 bin/p2p/ObjectTransfer.class
 delete mode 100644 bin/utils/FileTransfer.class

diff --git a/.classpath b/.classpath
deleted file mode 100644
index 52f234a..0000000
--- a/.classpath
+++ /dev/null
@@ -1,10 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<classpath>
-	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-23">
-		<attributes>
-			<attribute name="module" value="true"/>
-		</attributes>
-	</classpathentry>
-	<classpathentry kind="src" path="src"/>
-	<classpathentry kind="output" path="bin"/>
-</classpath>
diff --git a/.project b/.project
deleted file mode 100644
index 858ec5e..0000000
--- a/.project
+++ /dev/null
@@ -1,28 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<projectDescription>
-	<name>p2pfilesharing</name>
-	<comment></comment>
-	<projects>
-	</projects>
-	<buildSpec>
-		<buildCommand>
-			<name>org.eclipse.jdt.core.javabuilder</name>
-			<arguments>
-			</arguments>
-		</buildCommand>
-	</buildSpec>
-	<natures>
-		<nature>org.eclipse.jdt.core.javanature</nature>
-	</natures>
-	<filteredResources>
-		<filter>
-			<id>1759349142872</id>
-			<name></name>
-			<type>30</type>
-			<matcher>
-				<id>org.eclipse.core.resources.regexFilterMatcher</id>
-				<arguments>node_modules|\.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
-			</matcher>
-		</filter>
-	</filteredResources>
-</projectDescription>
diff --git a/.settings/org.eclipse.core.resources.prefs b/.settings/org.eclipse.core.resources.prefs
deleted file mode 100644
index 99f26c0..0000000
--- a/.settings/org.eclipse.core.resources.prefs
+++ /dev/null
@@ -1,2 +0,0 @@
-eclipse.preferences.version=1
-encoding/<project>=UTF-8
diff --git a/.settings/org.eclipse.jdt.core.prefs b/.settings/org.eclipse.jdt.core.prefs
deleted file mode 100644
index 6f94d6a..0000000
--- a/.settings/org.eclipse.jdt.core.prefs
+++ /dev/null
@@ -1,11 +0,0 @@
-eclipse.preferences.version=1
-org.eclipse.jdt.core.compiler.codegen.targetPlatform=23
-org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
-org.eclipse.jdt.core.compiler.compliance=23
-org.eclipse.jdt.core.compiler.debug.lineNumber=generate
-org.eclipse.jdt.core.compiler.debug.localVariable=generate
-org.eclipse.jdt.core.compiler.debug.sourceFile=generate
-org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
-org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=warning
-org.eclipse.jdt.core.compiler.release=enabled
-org.eclipse.jdt.core.compiler.source=23
diff --git a/bin/Main/Main.class b/bin/Main/Main.class
deleted file mode 100644
index 92ad32b187335d8de4610e153ac500a1f61abc9b..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 3339
zcma)8Yj+!072VgCG_o?y!;am`E~y-nR+3$-byH|1H>6RMT2xNl*fDhig|Re|CmzkH
zGb1N%fkL5B2rcvhCFLC+1`3n}kWCEXy%uy)zVM0v!57x*s@Yc~TXO7n)sK0cd+s^=
z?DM$u`de480m$NS3fcrZ#x%o9$%}%3z|OPUyp}RGtCTuEb5<{S0-+JZGQ5KV?eWBv
zKp<-u^$6P0p(2Qoz>d6O>Bp+&8Qq!GW=vh6GjA6(b4qgz`Q8u)yjjB)*p^>+n4z&U
z9SiitPv@JCCp^cnN*U=aa^!qLuXu)Sxe7W3y6Renoyr|wUkPKkfKt#c&(X{XdT^71
z8#hGa8&nZRFT>Fvt7;~ZbjMqK`oU%rrxe^Qu)S!w1$$n17E;IR(e|Muf<D}$B8GmF
z=IY+Kt~<H$>&&b}kKn!7uVA0Ru4Z64%hOA`qvBTFCJ?S@j;mAlHa2q7V?sp|1Ej6t
zaol#OABg7?QxV*bl!76FXcKPMr{RQNGF;DDP;m$D6bQPWCiiv4^G#J58A%S~E*h*b
znh5U3`xU&8dQGiS%__RH+MKT99%)L3o;3}+k?Ls`87b|Q(v7Ya+_xbKle3Pl6+2ma
zA5d`!_p_dyDszA9W=t)4IZ?GNSwxu#Mv#>i_kh5St(jZbkc^Drs0=xzV04Z7s%My~
ziGpTXy3>IVBCp_~4ZtQATu(2n7{f7vHd&6{J^)!}R;B7Osk&Asf(J1!5j-q#Qv<<u
zDv2rSVM4_uPBK2bDs#JTY@B7iW-N>k38as(Ae>miE|<x2EMBdcwpNUd95qaRT=QlR
z#%w26w9i>h@u=p`9!#WT5lrK>f>SLm(PCc3hh>=tE7GIH{iuqM;$y5iOF!?)eihgq
zPqgsdC|ub-Gb##FH^4S5he6eVe%_#&9+Xtf!XSHo59Lah?dVy}rOt+KT5E$-Va%~O
zj&M6WI#zM)lB1P}hK3}3Qf^6<N*$$Xg;5a@jI0N25f|hx=vGXF_uE<%zGi%jkrBqc
zz@eNqubD=1jn|>rNmncB>DaraS0XsCVnLFy&9n3NIo**#O8FBiK8{b2$XO;rPQv<F
z%!TnJCyVbOj8AiYEo}-uLk61tBy;<K=4lZ;g{NgT^~*l`yozV=1p(EmH?HnTHGxEH
zZ>;UiY)+dj{R?<j!Izku%5WtmbtfIoa?i+d^BlfR(`$%))BCrebn|eKwe!4+7v!7|
z7ED``unRA#_-cLf*E2WaX@xmDE67UGoDxTC*A}@Uvg_@WvO;~7Fz?KAXG>uIwBQM$
zxPI%>sK4CW&s^`Qx}3wZO*a~7REcZ?jy_^i8g0hh5M;H?X+^hZ*a$7K);Z>qENb87
z#`A_wZ>YySrd8@^n}U~V)YQr|MQz_5a%#V-;%Bl-ww3&ILQZX&=3mI+^qTCwT#M7j
zAm(W|VOO1k?kA{zFb~PYgUlVaZO`TTRvFX1S-a>)@N3i*{6=7J^LR0=d3#Pz<?BGG
zsGZRYo-Gf7B`gz6xhWF(XKVf&JALDF;+wj=FK^p()yfvt){>?T8z&bkdaL@oU-VtR
z^WN5J)v%n^Omo8U^vsSBezg;!2n2qo;wQM1f)xr_^*K5Bv!>>{IzJ))B(Q%IVOxc*
z;4cDu-dUC9>vM#DI&SC523}cl2=S`$EycUwJ(yfV_%a{b5aCrW16|n0tLiK8egoe+
zupK+7wUf^QuI!R#+Wt$k)D;gW+lM>5YUsX**b4flm++qaKr%2~!=8a;aCjMeYlsgl
zV^Hc*+I>;Hy<Wq>*kCdw4Gbogrhx;4%eZ$1Bhv#{aS$w@!^du~;m8UeoW6qG5{{<>
zS8$?ps)k3Rff_zigO(0PgPp}1&RoQHxpuY&a}h65XxH#qIus3E3tsY<s&Z-dAJI_z
za9W9m0>kNWRH@<Ibh@L4$6saW{F&r`+rI+aB~v$_?EU*QyeFa^ou6b_ub^uYLwxyE
z{iSaa{VRBCIvQTWXVZ~rBpP1E=N4B>(J<rq;^OL~5|Hn8LgM|(BEmAD7cY}yU5tu{
zNOXHWHJ1>lqgzOKj0x&TFZN;|zvbfmy^Eh>84Tbs29d`QA*OJe4XtAs23N~CfG61H
zPx4FY0`A3&xDVgrr_Lho$7|em1xG;&@n?+Ub>#2{t^Avx9sj|&=*5KCk4Z7e4~G;U
z5qD!++=J8N5HcdmgJ={*ktf!1o|&?29%sR@An-N3%(pIdV>iCeXfmQ37wb=xc(X2R
zBc?a-3ckSzFW~q1CNTy0|9yNL-(jt;;Awo9Rzk#5#`h>wh^T~1d<qj&gqlA<gx&-A
zA$~+Fi}a{Ljj!S?f(m}Dps)TnqA)mm-J_uAP4sf*Ee!M7|5Mf7;Z<7OyknIf+t=+t
zDA@Hs1a?MbBQqq~ND20Ytb~qa4L?mT<LB2m(}6lGZB%K;FL`alW%BK}*KaAi%E+(b
P50uCu@ki$1uZaF12C7<F

diff --git a/bin/discovery/CentralRegistry.class b/bin/discovery/CentralRegistry.class
deleted file mode 100644
index 3ab951fe3ee46127f2347607a28989f1dcd591d0..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 4626
zcmb7HX>=3U75>JOHL@5sIVOmZR3t23F$Llf8BB|TVDJ`1O$<qsvGi;U%QMQ%*x)uz
zN=lcsX`5~Y(j^Tkahq;osm+o=x{)T`_ch&UPk-i|p8iO4PV0VeMzY3Bn^W+anfKnk
z_uYHH@80+H(!VcU0?>@VswhzqOK0qqIV`M^`etD`mY&@$`ZBg-ji?AJSa3ie*6Xvn
z(O2Kmb3mjV1!_(Rt4+@-nBVHI4mp`@JtrC!lqEBLhVBemLc#i}s~f$cYbxnj8KbXp
ze`|5`b~7y+n`ok>c{jJ6zM>$!F_q028K+4>pt7n<L9m%BD&{L#Saf5DZuirb2<Bm-
zhA1=zp^dIu85CTjp%fwMc*YRzLxVlS+N1Ym>1?#sOzGJ!-O9+ZI~hR$3%QNcpRpBO
z=ksV<qUdy~?dTSBQ(oy4b3>}?D#P`7gNhrbBr`c;J7Q2n9LpGwIYiwGFF_fzzLVK;
zm?NPNHimH%&89qP;#MA;xM@VN0;^Q4<f<F~R6PxqsFGMoQ(1%7D`)1vsw;vT)TyXd
zFmEap8djrT!JIzfbQ11PQ%1+Ux5#bZs9`PEF>2R3Q&ia^!&GpyhB8D{+`|1_rwrlL
zCxu0NCC$`;a3W~HtrC}Y@~ct9Mr<NNdMYJyZu+V`FI_!XqcMWbc(aN(5u@DNT%Lt{
zEZwksg{5H&nib5oL`r0aMS-F#^1=Gd<PH0n+^Axkf~sQNgTl7;K4DKUgx%uaAz?dZ
z*oxaU>_Ceo#YoO&jT@z((_!pVpm{h6t2dJs5wxL0Mf+6z-3rjqiQ5@JH_)>r*%Xkx
zU>d9TMVQ&7hCO%-Eqm1|tnIX{VDrpCeFS`+fEug1!r065A;>w?A;mI!Ru;D{ckI@%
zPwp5^3M1WFSWXI&w!^s77o*gW3UAeL_Y@Z;aU{&Th8|gnrKzlGGaYI4s-W{8Z{6hW
z>9@>-vhp<ap`U>2>2z`^m$L|oNGn+EXYZsi1Bl=NvML6qSlf0;(kWva8V2RY^Ie`M
z9X&Nb;-uI#%z`|trln(2Ud6o%;zdlGv$}1!o6dG~$Vg90v8?j-$Sl}Cb}P8nM_=Cp
zJ4DEK>C9~VL_CJe2GDar_Mqa<dGNVp3Hns?f1s*BVRG}`#Le!c=k#N)n+CQ>x5ue?
zfaxigs_T#>`e6+Z;$0-VWH1}2Z-2?Wt-7PLGT)8&s(24QFBVZ@Rm1!6kk>%ul<dni
zQ|T|m{3#%}`+$ar5g|p)gNCr?;6r#s#fRyw>ssM}(eM#jE^|_*;piE|-X%t)=*KjC
z9G_sS$YTX7{ZuK`(9F!Lc$8SoIDur-?})HtKc?Z6_!Lhx-LmwNl$je*P(6$3mYJqo
z*bSv$pV9C*K1;uHvb}GZMR}&KKR<crqdcuoXm}EzBfkdq0nuz4Dc#wdar*higU4{#
zI;Mo3&#d2Aek#gBJrP9-PN?`iBPs&--<yS<<2J0@r|~5fUo0HAF0;0nW>)B|voGT-
zEQ?`1J0v=K6)dXU=ifXpM#hZd8QK0%DM<M9Q4sLa%soAQ;{vhVqTh@&8qVTt3L-Y!
zlb5Mt5`2AsmK3vT+z&mBb3FCDV=3--ru1rgRA10=(LI!f#qMR`ISrR2lOtqTn|DG)
zNs<%1k@QXyJ81AOLi)-V!HCHBwnMx|aiHvDn-FrqJCBTtnua(izqrc!=Cjrp=<5N&
zA}(GPe9g<v?ssK&zo%f;Y}uW`cG*7-Wa)6y9I{eE=9pDF?S8Xb79meBg5=n|A?DhI
z({HAEO8f*rQ}I&;%ZrUGV+@-EqTZvM$JFh5$}z1GN#UO>IOg{(FYOuJp&RL}u$Q-*
z=D<*{(T7}~yuO(!ihFn%&mz9xCqGLg$eU=^v)N?E5smXh_;DD&QgD-mCe9N`q~nem
zFF+TUaL4=E$P#fSjNdS9PcX}iT6)Bjv*W#{HBIt&ygjyygT>kWHBML}?V9>M3wxVo
zQBm@cEQx!E1s6%37K1I(J&A;^;!g@z%*gg^`BQOK!43agl*f{nY%F762(ZzV@B+sx
zGDoUA3UkaW9lt{eV-7T~%;l(_lJei2i<s9vjs<5>eu~2qRPY&b7t8s+28-NTP>q-I
zNo7_A=S!={acxme?h1-Y6)8#qEJlp)GAzM$p0aY1eoEh-K8>Z(8^^Gm@9Ht|Z%y?X
ztXEo<wu@-!mQ&-{&|Wu&L?Rdqo<mcjG*<dNwkATc&{=Gc?i@qwaYSOlSm+#fdvjg>
zxjVeM{r<VT>aI*YPMi0PP8@5ky8=~y*IaI^c>&?t)=|u@sXd8sP3;&`HJ4j!#*i7E
zFcHK`4C64pUcz(kVZImP1pgcPcaAa1#BIR>K4Z-E66RqkS8t%^GSuQmtiy67IJyn1
z(2i>C=heN3w{(+O3}Zcu>t=S>>)q@%5iMp2mW$j<-neWy+@lsdF+}Mgtu^By4l%<C
z-oZ!kHflV{`M2Xf=J_4e-h{}a3ETozMU9HI``4i2eiZ?gCpOAoMfpz7zJ@Tb=jpPt
z2`VZSmX8C3jF&+VGCC%iK@LpEdW-ArB5%?4j8asR{_yCPS6<IVNs^wDg-U77S-f)$
zN80#)fBR{a*Ph1*OK=>Ic;6o_!Sgtp2nHHTW5Mo3*`<bXpg|qQ(pXuAx>iC@z>Xb9
zS+Jp$XdO|N3bi8q#KhH#(#NnV7Q7U^=Q-3+E*OY~0vw;i@ffu(1=Dp&xkW5=9-j_i
zFIiW60Z#yA;3(F6!;|^piXe@22kMfEpsN$~>pbNOUBqZNN%;jChm2_)Urhw7B~MS2
zx?{8#9d}JvNE_#4!7)600he9fQ%uTt@CyD;0(rz4Ch)*E5@$QhvxOAe1&<~j{Q1<$
zA1$|YW;cn`fjh7lccGgX?K??}y9sy??`kRDq0)F1f;8yEQ^?>MqWCNZxRZ^SNuR3(
z=x-#?D<sZ8a7YOfBw4CCwgm!HfRA4ud|~{HShNt_xp);{Cwu|=bRWLKU4kU=2)>DL
z5!TI^k8g7|#C_{<g{vX%z1aN<a_1;spbtUrxq$S1kzbOYTR_5XkUuub$gL{cT$&yw
z1xdf7Kt;&}?Sy75qv@ZRw=AQ=SV)5L7mi0TdRj`$KobGWb1cuS)di^hD<03r@lsoL
zEg>64SazE4OJvrN?;9qOSwb(s`$iNGaOE)99>lFU!t#2^&0e*)Yax4R%4cs4vnJy%
zp|mW^7nwa7_hK-x4YCHkxJPBV8Lv?$fFE$Z1V6-&_+G-9U(lOhy3b#`&)>Swm+=R#
O%U^7N#GmmO#Qp<zeYhe3

diff --git a/bin/discovery/FileData.class b/bin/discovery/FileData.class
deleted file mode 100644
index 61e25a1e9660f6bbfe3a6151ef37cc1021183654..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 4266
zcmai1`&U%g75)x0%pHacA_`^<DltA_7$j<?1|qG1#4!w7$6^puz06$T!Z3F-_YMJ5
zn>I~fX|<2^k=mEGNo~`n)iw@RjJChDYxQ5~pV0pxtE==o_uhd4hIB3Fp4UEme|zum
z>~r|%e;+&o(1*V%s1T@68CKGq)pPS514df!*KAFJU!ZPEo7FnfT4ti-^w^Z1v=syd
zwmP$h*^$t5hL$$2Xk%$zAUMvgL)r|x^@A%L6L!wXOmute3F8Xa#VK!iZa!Pwc~Y|`
z1p?0*8N==o@U^rK3;6rYlpcZ)n^n}HR$$Yhk<o|pGh=%0oNKmz&`fISVU17-!<+Qm
zlZHj4gX<k5l7^P`_@uSaiMgbnwGA_4DF_Q}DLNWEy}Y8}NddLEAfpw+cI=Sw8f9;n
zie@}TNAx+vvWbC?Tu|_|z>d;QL#91o<};~fz4c7TUKRVWUtrseHm&!WnWSc)H|$CF
zEL+P+W&6q@U++u^yRk!}iKu8pR6v=~Z8tSrTUyu4S3%%_3I##A=@}IVafmLY^~{9L
zq|k*^QsfgVst^jX*Qw%@5@{Xv${3uOv-OO{z)7)ZRa8q&0^KT}!!d!)%uq6))@)r0
zyP4kYxk4Vv$?gqceM*IjphuT8nuOyYr@TO|>ql|FKuyBdlGAZ5>ySXfiB$x4c_>ir
zL3YDYZMhD3BX7-RX>rXR`CCp&juf}M%q@y|BX7IwU~x^3Lg>dC6`#RbYDjCA9m}Nj
zxzpoxrX|)I3*wvrq|mU6^LSC9%F2&f&dHH<jg<)wStu3to31V%s+fX{Bu^>LVwr5-
zrsujg6T&DyCuw?#`B)qK;UF~TIo^LHgd}tYDS;;)MV6k-=L~zkBd%MPHlg<$6S`%q
z7{`PgjF>~tBolIQV{(?)(k+b{DyA?^w&k-a5`<iB8SRb5T8Aaz85J3rj1oN{q)INe
z#^kP-Rph_}5lA_BWE@*Zdllr10dR_zoAchhkxuEk5NvD?Vve$VpE)!a!WDd8!K);a
z<EXQtciz@jT*Vg%V^&M&b(x|qExo1jmoh}&k1wkD5?&{UaWglg*(83M0F0KLHn)bB
zW4grlhKjG?t5m0DvwDW!wwF;?3S^acL}cUZD!w6)d(bxBMH$0ys`!>Hot4S7X|Y;e
z$9EKbyI9>Ex6e)H%vWUjRPkMWk0(h>r4spUHpiUnMDj!_l4arU)?o$T7udcMzq9#_
zZOpJ7cy%<0A96Qo)vTo_O!8=Qra5EU&EvB69SGqqye%pDV}VGi2^V~KN$6G^{Ru1K
zYIY8piF|VMc+to*0FruK-UQ)Q#iHa`@H(iNp^H0Qfenbttc>Ny$MqbgM|*iZ$4CO}
ztV7DGNgi-X3Yw{~#+GfZXCQ3}t_vy<B)aGEvdN8n=vHv6p4IgC@_Kk*;Ds`wI#m*@
z_0jWY){}>bLJ2dUOFD&_iI=5VUjGMVcv(MtP1CmQoR*F2_N1AzLiiItQ1EAgJu6u^
zGPCBi-r-tt@2vqXX`8uuiTIwt+ogy-X;<M%Et5*?)}BGroX%%UGrr!7RU2i+EhGMa
zj+>{VPfMp029NQk0PY5HpA}I$zCz8eW)Z{#fi5}ys=ROH1#xV@*dJ|{BY7np6K-E3
zSy_?QUXHG^KF2Z{J=e!7ZRvbad?>JYUChcwLBV5zogXhsLb@TtQ)GsZze@N~A+K;g
zBr4=R?X<jzotAef+ZxL88O84=jt;ZswS&sY0_yHMV)7Ld;&xyw)iq)Zd#WqMnFfxe
zf<{VgW8crw6OO7!gy7@MNvUcP+eg|K&=ijru=55sFJkvd+XL(Y7SQrI!r9h)XqRor
zJsgfiA|If=fFt*CG$JRv?x9Db@j;^5M^}KIw6%+tcN4|a{O(5tEjWZ$^dO4o(e5B^
zb}@KJi3Xph+Y)g%j-!{T`>2aYX^AR)3WS1wg%2L-)d2OlVd-G&hK0E9aIwMx5^yFD
zmJP}C42iqBhte{9fk+#DTpQFQ%u=VLL57f0%TNPO=A_}1bgKxY!m(M&03CjR4UlKc
z0*T?&G7vW-fygcfc`cA*1k$qs5J?>g<b|>kIl49?$IAj4EFY1hYk`~~kbw<=NbX7?
z@v=aA)&hx@1u|3~h{G^9u`b`^1TwS%5P5i5+vSs&tvot29^bdM)g36{^s%Ojn+Vh=
z?zA=eFBkAx3C*Q%J&6mPWp)!hNawhD*fHW#b=z|Ow|V(jP=^s*pfO2Ra_&FaBu(=f
z&F`v1SMeg(Ybo_m#Kq7eM&+S<smot~`98+FDmORdVX!N38#Up|aKP7~6fha~hXVzq
zM>>^?n@j%=R~C@%3NFGPS-@;pRX8}(Rr9D*^>tR?#-4CZL-pa#P`Il875|6ujrbZu
z_c5QikJk$L^7%KaMMHIidTZ%l;i>|@7WV%g!LYx8H}Aw(`q9Tj(SIP=9w&%s`@0B6
zdCspzAIBH*)=2#iq6_%ZV}`vJuj3m1@bjH=gY7kbWebk)uy>7L*}4(!WrV<IO)W06
zAiabpTw-as%u;ZP2^u4<brytiu1>&Wdld%tPf?e_r_U7bV%o_-mj9$McFP%f=#&V)
z2Jt3-ik}fp1Lp8^{DKIZ@G@@V7UR8(hvS#bkHYGC!Rz(lG=9a^Angv|9lXnub&<LH
zHEvV-F75mVzx6Wu4yu=^B<K{M?Fz0tf1?VL3f^PY`3O}@{Fkk^{5oY6KJx?%*Ly(o
z5+Q~@UXm4ViEdV|k&>nF`bP*IXH!Lsq?juq7jAIKXQW5<GxT4U!$w)AWhLV8D1SW<
z@H;Rs#roJtIWXdW0t_Ngw$CzCxspTK=*8NHKRCPo=<Kd#WD2yf;C%mrMXt#L^bn8m
HSA_ou!YrjS

diff --git a/bin/discovery/Handshake.class b/bin/discovery/Handshake.class
deleted file mode 100644
index ec2271e4f6f009fe294352a6e98b00b5768bbf94..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 4630
zcma)9d3;<|75;8IlQ;AF(k<Nvp`_3yYXfc5(j-<&N^EG8hD=FKEzp;l*JRr1%yiyN
zO2ifsMMV@>6jxNBYF+4Jk`krG1+<DHiYVfOyW;kjfA~l1ciww5^Rg7|FP;0|z2|=S
zEZ;fjzH{dvdmKO;{-vQzp)#JZW9cC)JKVU%OvUX%bHAk_pfG2jIb=2_&D22S_WpfV
zET>Q&OD3!oALeW;?dnR$trmsZZCuHk$sTJUVdt{L3ZX5gJ(x?kZ|34Q2P~gUBpW-;
z48_CI#6Zf-<+GN;`iZNp?yGZhG?z`J23mZ_wI`C+W;18DY$S^A9?@;)1{IoK9j0WG
z2P`0=R+^Pc<TfhIsIKW%2(-~84f7P{meiJ$sJf21m~UVKX44(5&bBZV78wX3EKd;w
z2Et-;B4u^u5A<8v9cF)$X3pD|j+x0`Gn<fiXHv%u%;$l*!Gx`_z-MML7E~~3=gcg<
zKEJxdC*k<LrZ<c$uuQ|169N_;wsY121Iw|3My2!IyukHNBHh?cm*!}{Wgch=p<2Nh
zECjwPozhW@dJT1ChGYE14F(#pN<qsAMlwa%>Z#GH=@pQx3|x)X)ZUS$k<}fdt-@LZ
zL6mD)$KB2mDJ$0)wX)=3G#%S-<#b$wW(^w@W=*7-fflqX%p9<C-IkT@PK#F<vko0i
z*eFq1El<}P*o5mCA2SxSG8Cz-u5q<=PIAs@(Xkor8m?ztGOIHl#dl=Ql)cx=8hAan
zC{$#vn3Wi^3jAO08S8`bfPHB~pWeVDg{M8%!MvTT>ak)8YsiXg*ru?gWYPi4w#@;{
zZY;=Jb}o#q=rXV!-6Up#>kPdw@P%2L(1RTsqBNldT39u36Ub%pl}rhJg+YFOy&RZ{
zH(-~BKH6KNJE?Bqjo3|uSUQz66DfPE#iX7PZ`Us^HQarR!sR6;CRt`@(ka^#)AkrJ
zQO>}MYiKT$TX?J^24-Bmka3PXuS=(smYFiJ7Xzf+keSR|+xIFgtls6f!V_x|GZF^&
zVLv%Rs})xGxmnQFM^|r3$IW1_ECA_zL$%M*PKHf+cYNemaN6or(;GsD?h@bkSgr%A
zqAZbdnk?KS$81nZ-L_Kk0>KIz`v^8wUx6N?r=~!MaGS#70*5^h``Gs;g)63s(WDI_
zym<nOPj{-W;fTVOuZU8J_AvH@F^oG6ycKsb|J`&|OxDAAyZHNVmi|}ucZbgbg;0wJ
z-bv?{H1{c~;~w0r;oU63rRw73yn**f*$&2%X<_4G?2$_IJ_GNUObL5crK4Mx?iAHO
zWZ=V+h-K}}-H%MHuufyr@c=%q;bSDf6p^-cD#b>bNT;NHCt1&g<*8i4Od9wEKFO4p
zXiMM}s{QQrQqga$Hzmci3HR!F5TDiXnL=512)JV~n?5AX#K7n95cAiJ$D{d7Cd<NN
zF_{+ok0=Va2;?L9yoRF_(5}BtswI^-@CEVHY^QKXb7pKm9UWtS9xKSRDRgWv%4_(t
zLRBd*+LESiccpXf>3k|)lp+H%PQg|&wjA46@7X?m<=MBu-dAorp(EXWB5nnj&ep$A
z`fBNDFQvJZwGL7#U-nL_Nly9U0Tg8GU3zgrms*qzuw@c+*>s{MCKhl-n!w9nS-J?W
z$Ox}RJE1MQjR#jaF<?dZE)qu8xno&bmq<1K9Fi&LdgOD8k4XyOHt-!hNw1OaQ?6|D
z*dI!{?bJV=9s9cmz9)MmMcSMzpoZ@&)RaVv&YcA56(Jqx@U*1-4;5BUuWkv;yVyt`
zKO=j7EG2)cIlN71_=!SoY3IeYDAc59@tlF5;dvoeKE^a5qkYhY0wewC7Y1IyFG<yY
zw-5D7{~=$hYj#Pi`IUiR<2QWI$nEMHzk(hKeYoC?zioL_A-u%m5zX_aV%t^i`DAjq
z>ZVLGZN{y5Rc_F#a$~I6_W~K`n(L>#7g=`4n0xzHsPhHz;{GVGwEq8+F0wRi7YIPV
z`QzxtjI<JoiC+S8=li<>P5QnbP3N;Q%Qb3N@shhrG8juKID?-i0qAl=<dZJDoRPO{
zuIhX)!%U96V;A2mc=rxr7G`s14kb2FM*b}r$K1YARG!4b;?v^eTqwgO{M8+?MI0C7
zHO?#uz?;1X)5uYAK3F@7OH13zoypnG7Q+?5WmrPNFfK<GXQ)G2hMLbLUh4@gowsrX
zH5@M)L1W!XtWlk+YaC5|C$MG&>qqh0=0GGcg4Z<%Bf&AWHJ8ht4(^GRpT*W@?F1G^
zv{UFD!HuV}vy46G_&9Fvlet@o5g0@N1d+iqoJG$llFcDON()jj5*oundCfbo#d8jM
z=L|Q8W%YKxj^l7&Bzy{Y5M0K$$O)r(TeB__?{MLC!bO53cvnO}h4+r&J{do70*htG
z2OU)%J?<aFM<anJFI0$$pE`OW*vU79oVWTjUG+~P)X;ep74;1dBUIlof=}0<>8u~Y
z!$;4*KqjnE0X3JtU8I&M@o}YEtJdO+-uNZ*MMAk35&m9A7A#@-s!+*~q80r5Y2fc#
ztVAoS`N3O<Uex0VXYa-;-US-j-LGO_UW11yb&PHHB-Y_+tjBY_7re-ijhC=d1+ZB)
z@jGDy`6)EnD=bv4_zLdgn>>A$9OZ2j|G}d;PMsU@JWdcRNYrO=3SZ-T8=k-jM#+jJ
zJbetOsp~QH;W3PpH*)6J@eSxaDS*duhSWSu@LGf_&*R@39(4YiwsH6`^i3SX;R`&p
zOlee=KaUXQ34GIKpV~wejr-GM_*Ul_o+91O_0=|v;s?!vaop2K|K7*{<lc{jbP)!a
z!6YZn;@Rf%Nck!JbOb+t09TV&wTxx$X}mZCI~iSht1G-Mo%dUk;V5(gVaSeC?MlQk
zAOUj5LV(txg6iBzwR&iHl&d?jj8(J_yXf}axR!VDF5JSWTe;6fg1;&Lio<0GO~LQb
z%~76yk3Z1R0QTdLbZr^e2b>_xAntCu`A=M1Moc#dO$_uH{!GaPLn6)%I?lZmWf!<H
zsG&#0{q&>rch2!<Io-*Y=em<vQU_R=m=KS0bnAy(2vWt`5yoHeS8vA}j&AK>zL#o;
xTXM2g&z?{}gh5h2{x&VZ%aZ|y2ykdx0Je5d1E0<>PuBVNqRtBcaP0Z#{{S#b$P54g

diff --git a/bin/discovery/Node.class b/bin/discovery/Node.class
deleted file mode 100644
index 0900bd90616c00bbb5ead696a0d865fa09fa17ab..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 2019
zcma)+-A)rh6vzM5mbSFZ*Fsy1iiilMAXQXQ%ZJ*8&{(kv1TVZ=+6k<bU9!87pfT|=
zd<ZWzk!ZZ|0emRqnVF?6?P3hsowL((&iwvo&f)i;pT7W<P>LbM&|f#*ntj5Z)54}*
z=P^VW2HzSdMxkL?dxclKZ+Xp&A<8f!cTKyn#U0aVnD30;24{#Kaqg7s40@#%w&gjd
zwO3?_i(fa5!=_`^->ce=$H2;zVA-@xZ<XOmt~<m3?38DA7$PO2PaupT4SmoV!nv89
zUJ$m17~;Z8Yv@(h6%7exjcQ0jV;HEI7T-KR+~v-;(xq4In$g%XNGs{|HzVG@=~96z
z7pqo`W1OM)-on!SUHZF6_8#}Deqly(Gu<-C#cjEy0;CI7Nk5IMVA79JU(F+^q|IDp
zpU0>QQyHkn=aFhJl9MHid$zhKo%*4m;VuX~b7&m!l5N!t@3raeljVAb<&o$Y0gT<c
zx_8Qf>JwY`u~Xygrs$zw(R%ZueW<q2ZQFA_$2fY)y?wjxCa{P{F)T4mwi?W|PV56-
zQ2Yva-KcrCb1HN^X86=j>wBw&8-`VHaCfp|+Xu%-#ctrXoeP26r$;=%{Y{&{8kb_b
zVn0R6Xf(D=j~54`co@er!=f0C_iB1prrGq|`1!1~zRJ~>E$(iGePGbamc^Y?!*E^h
z#<0e4yQ?rkQe$|=F!pa(8b?(Z+@y&K)6;_pLSlrdNkU?P<VxcsR~jB#ljPTjetHkk
z*GKZ}p>;I>9fSGVGYseF&XCIAIYTC&iku<)RmNTwK8Vu0kIv|)+ynF;#4v`Cg^p|V
z%LA1O*D*$4!e5XuX$h8)v;<99T7oAcX>^}vgM5U)E@|`|0%9on;{t_FF`#oJNYOur
zG@YN3r)w(GKb=ucCj6`gT1D2L{5K4LAtMAKCn`5b+k$(V!M8B!2d|R10FTPzw2G0C
zyJIBzhRl#wUQO{)Up!rSAV{hcWFin`Di|cy2{J_>)0cpV+KUQI2ZCfeLGpnhxnPh?
zC&)a36fOY~S1&+jkf*n3zxJ!ie(t!Mg+P#5%=y8stGRliL)6tQ63EgeAfodG$em_I
zs<IP-wCE9fQuJi#$^OJV&?-@yvH~mQy-H%%D9=-xg5@^SwBG_@EJ!`~X)YjzKcN$g
O6btHGM)6Pa9NE7NHgKK*

diff --git a/bin/discovery/messages/CentralRegistryRequest.class b/bin/discovery/messages/CentralRegistryRequest.class
deleted file mode 100644
index c0f0c46131b588f0bce5113a9e00c9f976420c49..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 1157
zcmah{T~8B16g{&Pwk?a$777$a5QOa(DSm&{_<}J$G-#-4;)}^rhO(sHt-D)HeepMG
z_((MI2l%6mXSRhd(Zq+nGjs3WbIzPQzkYxJ31Ax)9hyLK-w7JtvGjZ8whRKhDTDI1
zbVJ{6?aHPTgnn;Ve(cI1)R7RFI<k-La?5s`<u`jrvcc?_z;u*#ymC$Yj@@!T+j}i3
zkT`JEGF=^Vykh319oiLvQSXy0eL}{{JKnxzDG~NMY|K`NY_-sL+$L*d&mGqZUkI$5
zvBpc>SS|u9)(N*w*fd6vF))Fwz=&C_r$A)}bR^X-Zy<$q5_1BEAKhE}O1-KT42;7_
z;W`#|+_>UFtrvu{ZQv%Bi0XAiftkK&n(>y3L+X}xyOPE&tm;@1$X$39D;v0tH37Y&
zI$AD4%-GfYMpx8LCaaDsce?F8>A&lHoUM8dyH&U8J3SvH6XBr~2$W)G{Aai{Ry)|I
zy11zW1C!W{xzdqpXjcRdW>c)|xXY>iJ?%8MkWt}*frlsyj0ZAQBYSNJhe<pZ$TVfx
z@j^a4z8^(F`AIbZ^@l*Z=5_ssR4oDv|9+pF%2+IOU?coSqsZy<tqV2VXyqKas`>=3
zF;4RI1sXFz(K^SJRXRn^+Bn6Gm7P7s{5LFECzv_Ia(|cO?kj)Ru+F&1=L13|2$aGU
zAv2gpmiZh^?o3vf`rs(S;)ygUQIv>wN|qLh*%*lVz_Z3$;X({`+_|D-$e!mVfjrsg
z$UaXE1;*<UYrc<i$y$gk5D`~-z}2BL#briZKd|-w9QV}qPmn8};r{T(R`wA!44DfU
iW8Wf~m&m$|S*$Rw(v!6qyLriO;t7pc>`&RJ;n^RT`S{lW

diff --git a/bin/discovery/messages/CentralRegistryResponse.class b/bin/discovery/messages/CentralRegistryResponse.class
deleted file mode 100644
index 3647f13a48b675ab22565ac720ebf1b0818a680a..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 1234
zcma))UsKaS6vfZBp^+N?7Azot3ewVsLKNOac@W2^4m#A~#ivjf43j2IlEUD-U&VJF
z(HUp-1NfmF&nBe}3ZtEA_U_)@dw+Y*{`~dr2Y?-H>c|L~hfdh?&t!06wPhIE$1=2b
zq!$IYyC;vGFbXdAWO(X(q12%XjGowMw&mL1vGwxcM7AOwIf03I)$y&S3>@2a-q{DP
z6v&007K;iL8vSF>eBYI}w<R!eDrLaz*qcV5V%I;E%xOoCsxXntyx_`nJF=P0J#joI
z+7@_Ry`ggIOk6EB@71X7v&Rm5<&njhfgy|wWUICPL9nZVyD)Uz6Bxcurm|B829a0M
zi~${Y1~H3y9dp;jX<mepY#UfWiFN%>BrutvQl(dc<3-IVkal}3k0mVYctDY^L`<a(
zlu;4TPt^(6W0CZQ69=}`T}B#?CwDvT0~x$d#2;_?E!*9<X$Z~eE^5(Rhl<xzlKjhd
z%AE})4-NR|o(y=))ZwmM;z*#9Cc85E&#ek|<))2)Jpr{d-}E~{ODfX@W^Z|x>q<5(
z(vB?u1M!!x@Qn-QQ#{g5jw(NdVSYzA`@p%zaohZgQFHAQ1ylQu$x9T?&nRZ=O>^}U
z)1Ppk)9Ei*Orm0TqZbz#ePo3UR`{*38(3MxIHLl_Fo7vdVh%;-r?81>JjD#E++`-6
zQDdZj+gK&Bh@(2zSW&I5lR9Cxy3Fr6&oXDl%>Rwshn(kw1>dWNc@|$FW{GHve1l7D
zw;aQjk`_HUs|RNxfm1R*>>{0ak;*YrUCDR5Zhep$<OotBNR?{U=!!{@RU*_=5ak|3
Rxd%~>UCprlBUZ>@<2MwF3G@H}

diff --git a/bin/discovery/messages/FileRequest.class b/bin/discovery/messages/FileRequest.class
deleted file mode 100644
index 8c9e1b48b4a74bd968357748b1ae908884a3356f..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 522
zcmZuu+fKqj5IxgYxs{8E_e=0eKx02Z;|s<of{7RsAD6P?lG4Vukmz6eKumn_1N<oC
zY(edV+3d{D**P<3c0a$~KLE6Gkbyxs9ID6-W-@$sCNhe|NJh@J^5m_2n#w57z#>$}
zVkR6<_#@|LFqST(tAtvDs=(>VPzg`Hh=C^wS<Su@vEYo(U-2LGoKRZUR{p3P44G0%
z<!OX-RxgyV;!DDDBX#*(B!wk}W}jfSnVN@*vW)^N1hdiX=Rm01$RMjvH5)nP3FVIR
zWp_Fm$nb8Vy4nd`;q?Vi!c#0kD}GcFp`PmY-y5-9df@F7^1Wahx>D=pv9w#xdZr%>
zN36l*y#j+Ri{g(UEh+KDvTcrw9Nlw<$-dlrL#cH#$6D)jj`dfD3~aEi!eU!st7j^r
e#A}n0`htcnY;(i~u)}RAIqh;I-FS~91N+~&x^!m%

diff --git a/bin/discovery/messages/FileResponse.class b/bin/discovery/messages/FileResponse.class
deleted file mode 100644
index 67275d8e10c35ddb255ad0cf3e41c30b8cebc16f..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 683
zcmZvZO;6iE5Qg8e-6W(Y-_QnVLkfq)E%k*PRS!+Y0Yy|ws@ylpk}h&=u$@Td#9!(m
zLh7MEpg#&RyP+WxJ$UD1-<^3p^Y{Mu9{?R3W?>N;W0j1exr~4MQ<)@UA`|~q1+piT
zt0+ul77n3wDdxftL^$!k4KL*=%_2jnnXHQZzKoR!)QuPhl2GW$>zPba6;95hF(*ph
zrye?UVl=w^c%^YJxF?rflWK~uA{8vp#g8<EYWIodOB4lCge=H>QlUye6V6&|6-={d
z@$>g<l2z08fZ%kPHV+#W7X?%acB?(u0Ab5T7CG&`a<Q@W>MmSt>fEl2JYEutT@}jn
z*>ou5@5|9ty3t4k1Ht3sQ9UM|^oL3a%{7YuZi0W)<~b1Pf{^b=vv?#mE}^W=zlD9&
z|A!`X*!;bK!zaV?%1NUd%Xr2zu(7-l6#2fy(Jd@~1?+ftD0}Z0sCge2*!GSVc<t4l
z1$KV%t%W_UL59yw?or^{MLtWYqKrB!c*8fx%Sw2Q21i=2NyvDb#WLPLSFnxOWG>D7
Ijw1^P4}KMv;s5{u

diff --git a/bin/discovery/messages/TransferRequest.class b/bin/discovery/messages/TransferRequest.class
deleted file mode 100644
index 222d55d0ca1851582fab9d64061444874caae3f5..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 590
zcmZ`$+fKqz5S&x02v$VE`xW8?RAWCt<BNvGgs2h1`vDGkOlh?(B>GoA5ECE#06)q&
ztwxE74?Vj(+1Z`hzJI*F0XRb?4MU*P(_z;itKiWYsxXuT6*{dzdSPD$H|k-e!YB<>
zAb%&v(s89XaIQLcs!McMpp>B6cbY2D($!D0<0^sNH&c6qOTR}T-}qe<BgX>fwI4(R
z;zGcv_c&^*rLJ9dE+fgd*%R&Q=v1IuooYyCOw~Vxi&~qb&$uFs6qYP3pdgT{*4i0x
zhlP1qakgS1jk!2mvyeenV6mY+bvYV#RM7fzQE2#G>9!@E(bYF-Mz=Z?*q>Vd-`!&M
zP384eK#P4^H18A3*`_}Vx+>O8Nq>%g6kil&3QO^uNnR@D9}}_8B+^3?1>NO{FS2rB
zz+^1hFUZ@66BO-(36|~c309wp8(8PN!igZ;Br`*9j@%;h*dS_u@v(_5R-A-w?iES4
RLynPTyVMXX+hb**{0TYYfFS??

diff --git a/bin/discovery/messages/TransferResponse.class b/bin/discovery/messages/TransferResponse.class
deleted file mode 100644
index 81667862c6324b83f52037ddfe02e98138e272b2..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 680
zcmZ`$%Sr<=6g`=at=6%v)>nPM3Uw4`Be+mpC<sDPQRzNyV~vaxolFH?`AaT};KC2^
zqr{uk7eyCI&b_%g_uP}W_m@`y`zUANFf2EvZm2sE-v`%1Yu*w%IFEUxFGPGQ^o@$N
z$iQVNT=6>|ggj~m$Mq}GNHRz>jM}VJ!I_9959I@|hk_w@DsJ0CCo*assU{@~)t^2l
zvu$e(ee=7<JyCJOzz!MuzgjaCt3QqRlnMop=y7^SMl#uD*sAn0_r`~R5Ukc1+<nrK
zMG7MxawsySDyy{tFpPP~V$h%o4;l0uRPr#;MbjQU3^C-ZG7?Aa>$-@~yF-suRfC5$
zPDYRkpGh~ll$xRZOVz(V(_Gp3+c+D1IYe@AtUK8=)s7qDKpLCJdVgxec!fn0oTAkS
zmv)+f{+k*7_N3YDNmJO9egb*AFHrOdhh70w{xgRC*$zhiwGPJp^$sTelH0-56WuzP
zF*Qij?op2+;?7x?BC(V(j9I$b>@r~v^Awr-1yaB)S|sFHv_xuB78yN8?=nRWRz3jT
C@|H6I

diff --git a/bin/module-info.class b/bin/module-info.class
deleted file mode 100644
index 79cac06890f91d786a2f9e44834271b31f383703..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 153
zcmX^0Z`VEs1_oyaE_MbcMh5QO{FKt1RNc(Hw0uSeuHgLAqU2P!%$!t41_2}~y{yEt
zL`DWSU$AOn26jdUz5=6yG@!!bjKreMymVm(PDTb!kTSib#NyNj1_nl;H4wnWzzk$C
WF|aVO0%<V@Hn1=w14jdx0U-b+f*&~m

diff --git a/bin/p2p/ConnectionHandlerParallel.class b/bin/p2p/ConnectionHandlerParallel.class
deleted file mode 100644
index 244fa0a4d0b4de90d2b4167b53afa9b9b52feb03..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 4678
zcmaJ^`&Sg#9sgX|Wp;-_5rsHtbQ4VkU8GG^%wl2{O@#tlQ7qM@4!Z-aE<4-VSrXDm
z`qJ8WZPPZjiA~d5`iiYK1q-S4iD~*wUrFDObJ~BQ=lDbE=iXUlc<4Etd+*%)z2E2O
z^WDo!{~NywpauWZP$F=9?w(v@i<8aTNiXeW_gUFg#&!=_u9eBy84V$U$`jU*)tIre
z{f+y3Pf$*vY)3kq_8t%@t*h@A2(>sVTSqCP2Er&4SlXV>+MR{LUfVrn^=52=s&*%7
zWx6dlEx(JKA#Wg^7g*bVODCEI%3V8Yr-$qZ(^6MWU2FTSPhFmy&h|IgcWYQCP^}KK
zw%6EYyF<3y<s?tqo{mZ^m%go_vvsZY-BHwFrH0$)MAtQ(_v}FfCTba(Q(&OgzM-_!
zcz{+s+On;|<|-y|wSn8QM&PzV>!i&DCN1ws+8f|1?^#)oVO7)6LO*rHaHobl1ePmT
z=c+ca4(kQ9oV1q7N+k<b)OX8x?l!Oib*zPzOxij6y1cGvPDQWcZq~4oF3uR*V|i9<
zHdiRdp(BpX8X8!y*{rF11{(1ifhGO67m%l>858t6aL}xy9{0%n-Yc-O=<z%eS)Z*u
zo$*DMa(}@KII{&!QpI}d)_n#NVBviaY;RX8<=S~Bb>)l)GRRgA#S^-4KXz&$CIfi&
zv0>nK*u|s{S($>pzfa)qU{ZZdH!o7EDhRa5GVhspWd?E!OCuBUpn=z8pFo6INwquK
zenpeEDwLp2YI}pMYTF|AbZkL~flllf2tVScJz`y}JG#4-fYtFvbZI!ql&B0UI(Asz
zfPq6eObdf)q9t6{)>hvpoj79PP3R%or4u*Qv{sR%Ez-_00}n~2hLag5Pwv*^n2zJ<
z)nLsaQ<*q4;5v^;${I+5iYlyBs;iL8$!ggAo~ia+VX{$H@tCApzkvZoDBE>)oB*53
z$r%$8Bm4J0D)GzaV_*;rLMQ4vsNU*l{3~Yatqc?sUxkp2;soAmz*YT5@ukbNk|z(j
zR+8~l;#d{IRFDZD64<b4%UD=HCM@T;B$H@m0sDy2PHRxLui2~@oe(hcffhq@`0D2O
z9-`PtX3{phhvJsNvVfpZQ!+3$mzx5nFU1tiqb(IyO3#Aq5vaW(KA%~XSCMq3A7dn<
zjV+_M(AQ_X0wqUx3q*T|Jv)C;;Y3hkw&w+ELnRd|za3Uib#D!)sW)$DQ_`M5U6517
z6t((31xx1x<71NOAD5kcp#;IM;S+&QA;S;GDv|YsfluMnOdGKhJPR}kCN6lw25}Zo
zO1qzBZfASc92sf)bAg5_Lksjd9p}(gg)+2g_&m!R>}5L6qe%|W8u+55e_6)P_Im?z
z>w<wVOJr;GR^q7&8onZt`BjO`g(+CPIh@7U4SWO7v0|z@_^l<xRzk9!MTZ=|W#E#c
zbzi2Cr|on2wrm8?%hqsocYSLFqYO`m6=UhVSiZm?k9@wbkjV^hmg4LJXC-waXko>D
zfZu4o3PuOmbQoQ}2<A!&++Y%eP@G>nqG)N~+?)o1J}=#r4oPYDJU>S)sTAS9-sKeB
zWbr+)=BDqL&9XwI%WlW<@}6tuI&5#iN#%81!%sE5D6oE(*Xit#bJA|~vFrb$KWHUA
z#~qfXdP(5PV5y4IzC!=mlwaTOI429a=7kjv?991%XgFstB7QU=zsT=XQAG>iXkGl3
zXkJ=|sR(`{u-bq0#M1c~Um>o?hf&PQ#$-#2i3onhzT2W&Q7q{{`Rr6e9=yy)*g^Hg
zk~d_|V@_Wz&xXO{nCcG^{Fbjpnf_SuF_wz)u^7u+LpE1=rRVn)+3UKF8%q`BtISu$
z#AoyDH%jCcfpslTA(M(_9pX=VNhr#v+N`Ha@Q-W{#lq5n=M<&X*`JA;F1DT-6Wol|
z6&<Z7F<bebbz3qPf1~mm{w8qOf-)~wI1T?0SaWMpLf@}4?%?yFlrKSWB)`}e$Z&o&
zau%G!8^;j2#6<~oj`A23DCcPS0-P)O6~z)P<qj{Gp5nL!5SK-V=$t@hPwg105~0he
zt{ulJU=(XbA}kVRW@r?5CA10D_n6u!HjUx6iO2-D^l-H;5#<HBz5NPyjAOUDXGTV`
zw@K$ojXsW6wYRJiFGLc?2&JQ@QCeLwiuM}4y5f}Gq}S-tC(dKF8R3CxTs>8zU%`Ph
zqv-D0R#EcI^vhJVX&i6%bw{UAYeq+LbcF7PO@2nyrx~6!BU9KSjXyksI2{jPgKm~3
z!XsE_hRw1I{Ngl<w@AT=5|p>JDV&fY*dyq@<t++Elpt^2Qjo{t%jh%1qezd#@g3(!
z&J0bVMJ6;qg60nS6;WUD$<FvSL>f9qP!VsqfJnT7ZpJ4&sHHZpw0KGj*SSmVnLBY2
z6RhY~yo6UcZy*w6g=1oy*v7e592ST9ZdoESVwm3{aax?_4DpnBiu<JsDcz{%mQEa$
zqn6_aqGKyxG&@m+gFNfutE!Lxr3|ty<!~1s!`*lf*U$15caabNBiJPR5f>S37Ehy5
zJjb{ECETNs_ZTrpbm0*^s_b6IFz>U&iXprWZ|B2mgD~(8ypuTGiWl)X-lgI?gLl(L
zl(rA!y?7tJ8^kW0!fEQu(XaPYUj={aLjH<ARO1XjfG|B+p;jgMAT3_Ns%c)R5E|~+
za9sUW&Me{@>NRW$Y4{MiavjUoPGcqXTgifl$FHNjq@8m`#dSnySG(2LH2D{vqe9*}
zQ6n#0hrWwbG&;=`lt>|Uwt|6v7$5N|Su(+(SVXa1bc#f10`Z=WtH$urM0f&cdnA}X
zIfl<9$|i8GCq9O!5*mrIaU4%8WK7_^+<hjYfc=FgMND$xOEuAPjQ9{Nt08f|=2Nkp
z{4vYS^3rN!6c;5ezG-S^`6w>;Y%|EZ|4@0=ci06aKUPZEkBy+RQ+_EDj5SP}Wm9OB
zH?NFfLn7304N)`HIfA7PX6OQ<93|H%6j4IF5T3$AG7wVj@J%mJD58WKCT}LwFxg3F
zkRznmcU5d$lNe#tF`MUD{xyvGdCrx1760ZO7Eux946#nEyFq|90!oso65DvAiMQ|L
zzbrfO0PC}t;}JsdVeEm8ef-~|lm7$kC!qHcjt6O{ORUEsaWDTXYNDiUw?62%W1K5#
zYrBF!A;#4N_eyB#zj%S557XWid=FRIuIosHNqnC~c!2tUfFF_wduc_&KT6wm3jXEv
zV5tJVL5djuiXJRipf6RRAI9=&iW$UL5QuRNXEmJDaQ+73mrUbML>8ATLR}XUx#i`A
z`s_-gxV&7VxU_g#0eLw)%8wXv34V;9aNbVGe@3C7tMQj={Iwc?qsHH<@egWzRgHft
R?*E0ib>93d{*Hgb{6EKzjI{s&

diff --git a/bin/p2p/ConnectionHandlerSequential.class b/bin/p2p/ConnectionHandlerSequential.class
deleted file mode 100644
index 0a302141543e8e5193f2fd7e056d57949b6f55a4..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 4235
zcmai0TU%UL8GaYc%%0h7AR!r&4Go#JX)}{Rs7XxBkfsUb1O<W}LQ7&BH!~ZUFw9J5
z_K*^*wQ8{S6pd}IRbxFMp0!bj8fx%Jp2s_%#~Uxb@kW0^F2r}O8DK+b<gnLTd%fRb
zec$_id;Rslx9<Sxz=DPff$iCS+18FsI&H_DWF~#aN+(iwE@odY*l8zer8Ia1He9kM
ztk#s39%(&0bcsj-z2nTe-ls0cI?taJ5S;@4Bk@!+opg>0RE8r10-lac!VW;7%77O>
zf!gk5+U_lk581hXYba$4)OBa#R%*b?CFQ#O(sx9u(NT#F25R7^DrYpA7ueDLf1GWj
zv78;ZlN0u-q%=?;?(AOiJ?7++>5;a`fQEX3pxQ{=PHW80P4LW__?YeJ2x6-=Ytn4E
zGcq7wG#Ypa+XQ@8JZ@)s`c2_TNv{%Df^8bM3v5wJlbO~NmSc6MvjvAnZEIY|4m_ga
zVMbxatdcXZ6ORhijM$C~PfbfEsLZv|rlSeFq=R9Bt>KavYasG~yScmMi;TtDg5z=~
zf@Z0rg;6N0P{~~mkTlY2;BkC_iKYLE?o4__CALdP1p5sfzy}4qS8_>*Vb;PI+B;RO
z4&ktd5Ait4wo=+-Iim)mU~($QlW9tYySgIO(}X7s9L19iv^24-rZa%!=+Mx<ig>Zf
zykn0WIDwN?lqoO^!R6EUF|p-Hx7Cr|rwyC|Nx5a*8nemnxaB;PbVfPLJ675ummXX1
z-1l=u$5ZIh(9M)DMbl-=K(CCUmX+pHX&IV610R-@^~O_~ye$ver=uUt$hjpQDk}Y>
zxy%*GdIQhkS%GRRk%$$t*_@rv+l<9hYFC5FUCE?A8KDaXKB8h_=W;rp$450>TrwdE
zarWd3lB_Ih0~Ur@vZPoK)mtM>+2$pBxf5T<YCSD=(W_y3iduEDm}AAq`g2yC=Lw>(
z4i!ks0ACW=wQhmkA4ldmo5?X}{$Y}_*BYk_b?d>5ysH?Qz!GL{m6A&a+YMV(scHo_
zx`3s6r1y!{MJQmFQ1{m-6>gB8xywYLVHv)*gosxsi6yV{B%+JGVW==XZ07_jE|9o^
zp-IQiKdopjh*+VjD=$=1tzz3_WmWUj@X~6|tA?dvlGgHeIw8Ff2(Lrkb=#bz%4cMq
zUz44%bQX8IS+N>E>uMCTX}KdH6})QTbND=iN%pw+Bt^?jkl}RiutiPbi_-3w81b^*
zwHRso%dUPYkLGG~I<BKx!&jN-rMi;{9XHS{A8#1=nru$Kl${=NMy18C8+Z%fVCYp-
zDm5%mxJy>d6!y!<O#|OnwK<$B<SBC<-;oXIyRs!+XpeOI@qKzE?SvR@CzLO+-RJYe
zg;Z*CuY|LdrzHO?ahj<sG4*&NA#1kGhdwqtdX-lcWG*EG-LY|VYHhShhuY!QVQ@2c
zO@xT{NHlxxDwguS9?KMR@$x4y^nj21UKv|@*`CQbc_(LOdu(SklgR7%4Q4eI1$M6V
z@nm`;GiJAzz7eIKddiABncSr81@8*H>84m2T~b)ORpfVeXEI}jY}@@zbiG+6*gu)I
z*MVPf;Y$~iwlWnJy~`>(tW+w-?^9c?55M+fPGFnLZTW_f2=T5H%3BjQXZdJI`0+bJ
zPUdo%TqseHSA~!aaEO6P=ULhcGB5B*N2ZWUgwh!@#IbUGs+JYXq(idDg#>}*Z71(k
zxsH^@exBFxM}bH0i{*OJ(eP)1rUygGuu>>lpZpl|gGc(wOBQDy&NTkB5V+dKQT}Kf
zJ@^&$cQ~zp!KY7c)S_CwkqUUzDhsu8lw#i9v#4DwQlmtS5&#<^KeqvF!se22We=^_
zP~Vj35xsK=4mQkUOVlHxUJ><~o+28e+8mk&O|6K~EFO#c=MWj(GmAaZfaxz{?;-sb
z^!NNxV+KJpU>cRd>LT{l>%r=4_94Aq54?6051D>$n8uxJ_4>Ow_(~B+1`k$OyuJ9h
zTR67oHckOWbeVw#G?;-R&d#7N>Xl2sTAJQ@)4zZN(%#cEXr^P{yU<Nv)H{QXrq}dM
zbH$;Em<0M2P)cbFxFkIvoWalor3myZAf+A%<hJ(~&YRvMp1X~B$#E_cre^^iGGHS!
zXzP(HzgjiV_cq^!zolme)y*x_@He;6&F1+YYH4UzT1J%?&J*u2sr&IM_Ac;pauYw{
z*oeR5pBy&}UFaNZL_|dR(XSE5L=V><abBF~2$2<8zOPh-=~9`lV{YrIVGFfwrRGLn
z?6%=Jd3b_vda)Y=oKK*IHus7>XccXETpYtbaT)u?%Qzse;h<vBRjE}>VN9`B&QcgB
zhiXI@(#Vj<jrb3;xJ*7p@I&N~S7#Z8g8~^BWz(6!73j2n94}y!`cBZttJGIbw5K$q
z4?%nkFTzU?Hmg|$KF-5Uqj8Y})k4E3H1w;#;L>D=h9;WzX!s-x;T|?_U*vK12Vud@
z{(GpZ=;l~meGh?^S-X0*$kOw!QXyrYua^S%pdaTD2rM!L6%wTOHuIn_GnA^BD_-ZJ
zSg)c%^opow4m$>SH_qbIQSTh41|@-BnZ*~PzBybUY@WqeWS!lRv)7`Ez^@+)n7(?J
z!<(f7t727{KC`MaXcX~HN%n7<npsuE+k*!U*3!RNOLgCqbwo06m1Lft!G>PBQq-Pq
znKyk4XqA#bn8B{7r{yjJrl)rXwJoM+8Ua3K1rg*|APRUF@SJp&1$6Fx1qkvhP|N)L
zVOr*U$#*iJMKh!5&N=DsMVRDykqK_Xt9XOs2HeJ7j$Ztmzx)wi;a#S6JNJRZd`2nJ
zM(Ly2hbQ@_9mjAIr_qTnoaGh14}+YKAV&TD!pHl35Cg)*vo1O}kf`IzMuQ?Y$s-!@
zBfhJkg@543q_dZH-eMvCltc~VB7TOSlj8gE1b%^ElH!M1Ad=Vt+72sXSJ8u7MQ4Kz
z!YIw?!6rrLN=4^MY+5ADAamRl+o54f!*vZembqNBh=<`{A6F)^E+i+bsz~CMndE0x
vmE>n-Sy)kY6Z=Ey8*z(Y7@&b9{VhSa)$={|yi=b4p8GoY{(wK>FEIZHAQ1KR

diff --git a/bin/p2p/FileTransfer.class b/bin/p2p/FileTransfer.class
deleted file mode 100644
index fe896c95cb5e039d309ab3a2cf93eec9544240ee..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 3998
zcma)9`&%4W8Ga8eJG;w}1Og-zH6<-1+&9LUwo4mZZVgI+1VT&GREOOYSXg#8GXs=*
zsm7XU)p)D6sh75iky>LlH39}r<E8pM{z?8IzGr4{kj1CZ1Ly2H=bP{LzTbCd{{7!O
zcLDU^Lk(pDyD~>I(f(vgj@f3~IWKJu0q)M23uZKBrl+FAlQS~z3IrcZrjzb*f%4{-
zae+XOm5>pXBdntWL4lov$+R4rpPQ8Sm^qn}0yTqH+)Ry|c2cdgn*nz^>8P`<cDn@h
zgteGXS!P1{Bhb`5Sa4(1wUg<ouE9joiCYWOUWyLUfv%Qu4b=iIh3z@%IOddeqCGP0
z+GgssoJu;by>wb$n3s+l!7l7pF4qdwl`x<b)-xK<a$364Q7b+x`Pg3U(_jefD40?n
z==c~uE)brQ?ueB3z=%L?bIbjXD+T*?Jb(s)%B=8+WizqN=RgE?cu;xukU)J2uLfGi
zBWS`Q4F{P!l{z1m9B4Y4(IOCWWIB-p>|j<;A&9Obw|pt)Pw8#b(T)y*DqF^7azW-)
z<Pa!QQ5;%UhlZ#?YauP$Bj9ALv?Dcql0g*Y723U~YesMwVKp4p@o9xmr6XN+c*1n1
z!|24rIv&BJq@pt)C&~i5ivsGltdum<T@iHQaSe|NR2SHjJ=Ad=pCQjCec5p{HBX)q
zfM=EZCv|kAN1!4@AgR6j>{hl#Ake3yA5XDF@?^EGIR(AIq2{d*6s>bnb}3^6_?(8%
zZmP4<CC8O>ItFo)E?M(rMx7sC(u$6d{4PsCnsW?r7^gIlXhl`(mxqqi7!}YKRA9sB
z1#%oHs^qR>1hZ9D!-jB1$2guA*fVF&${s5nH{GX`?lgZnu9<e3k4?(5PnJ*?!354~
zc$V;Z0Bm+&$8!o=Eu$hzrE8ecGa-DQ!u?MU4EFUlj14zD)i>5K(${x-Gy)TG4U;)l
zUKo8Z#AU`!T4@~#ukm=QMqM*L%W{a5UJN{MdSEy&uVGrCp+JhBl<7D_mfLU5rxST8
zfzbIZ=Tw_2h-V{aZ`jgV2t*OiURxr9w!9$FR&=m^S$K_!{V(Wvy@t&5%@&oNqQvCP
zW{0xn=h-4W?H|dOUxG9iP*Jj36+M-wC_6#Ma@jwVX3D3wplFtkn?azaDlhjZ&5YOL
zHS|RAWxS-}D}<p?<tNN^!kH$wbbJ+G^E+lwDoG=ZiXF2c>19yE*9G<$HuKq2PUd_0
zMSMeb%}ZNqFCWNOt*X0!Q{aJZ_4?@v<1${+F^>h+j=rPgyQ;^lwyiV|nR6uB_XHj+
zp(fXn^DbV&50r~P6lnfP?SZYn24y%C#ufZn$4~GYvGQ*U!F%E=eyZUOhM+D17H685
zGiyO*Hzn;+b;)_K>G&CbPM@<KUHPr9mVx^Tt*(GNys6_YRZSJ~l;!YZzlL9GxSlH{
z5A(5U+gemtxsDt76>&EciP8B?#%3>;34y)E7gt`GR}2GCEmc6UGRxgXi)C1ZOettd
zs{`AM<Voz6s=|XN*d1AMjisL20t%IT5002FJ3?gCnz!T9&rr3Ra^jt;_*vb&JzU4N
z&CE&ZPFo2lg4<Zp@JCuJw1;GR!J3s(zf1W2v)_!nmc67J>#D%(#p%gP`wD&VoW?=R
znw`%S-_qHhQv}+k2gjB&vV{2ABKd5SDDKl)6+LDuHJWr~*UljR5W*c6cyIRoOC}o5
z^Hyu{Pz&MD0!F{d#3UMW5_}i)MMMa9Nrld6?mBd$f;a2{iD`QcRyrE~%9pwOGF2*e
z4S#3V|9?^TNk36Iz{{hYR~I;vxd?L9xQcQXoGV&a5xT`6Wr%Q8$KbC@j=C?vxr(bW
zc3>xW_;A@i1U!j%*0F1X3TjTSqi&*Y1$+4aiB%jJ>S$j>W5*g=V*w*@51p}!bsU~p
z#gSOh2)3@^Q%1#Y99u!`D$b~%PfWxjcaMe3kA;>IGa_}NBQed;jNlr2ucH2aoG`RC
z4Bf#Pu!3inak#K`&f9u9B<ezS;kP$FT*hu5);#aYg@!s-@P%89E{r!>urfPOF&!%2
zA?)V3gS*u*P=ozkH=-78Ecc_RM+|$=$Jf$xJe|TmEb>+MMM}NGy;qss*YFVaHsLxB
zVHqu6R-U6a;2k6}!&&{BMT(hI9?T(4UkqG=g$#XY#20Y^HuKpA7Y_d`Xm?h%Rbp`t
z9kiHY&aYGA1uXH27pd_L1UFbPl^TXM?A5SKL!E|l4V@Z$u@D-yVuP-gmf$manVM~6
z3R=R@O533Ye%$2GK(l6mQS#L<%aa3)MyJ2;t>H_g$i<1a_Eo$*Bw_)f2vIjdChXzA
zqKqO23Dc-BZ&l#m!{u1W2;IiFR`BgucpX<J+S{u4o2&SKEMf$Wh!PIp!H<Agr4hM}
zSB=Uwylw>liI5Ro!7l<gNxuBb2z(H$FarNV#Hfe`mQig4jEWmvaazIK>X=j|S;}uR
z-%Z3|k)GEQiA$UpIjVUF*Eh(bMUHCr*HhVbj#b_KfC4`k0>p0z-<q3ng!mricnpu?
zVSZRXf>Y$yGkBbDZ^vn?n|hxhzTIR|4{oB@V^YQ&-{W42`j|&@X@R*7;9dNhdu7!A
z7CH4UdC`RDJx&E_rO)G(Mq9_psox+(okyv4hUlEaLHw4Q)O%w+e#gB^>eoDW1w3}m
zLffD_x<{?U-gr^NHSf=-*<}y(D;yQg*b_>MDneZQ4=TGkRaI@!+d#3L#}_*Odj?j9
fTX>&yE!S&Q_$O~%_r|~A1D>eQihKAQ{sH5ED=!Ae

diff --git a/bin/p2p/ObjectTransfer.class b/bin/p2p/ObjectTransfer.class
deleted file mode 100644
index 84ba96ae3d22c555e8d4feb11f231bbe32e4e446..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 1208
zcmZWoYflqF6g?N(t}M%=FWzbq!L}f)__hcpjU*%$K0rwP=28Y&EW6D<(4VDWXd;O}
zz#nD2v%77lkWFTG=H7G8y>n*%{`>t0Kph`73=wkejkdXed?A{_p=UY%sqi$U2$L7q
zm1VXp=PZd5GMlzz2U~>Ua^;ASs=Fsb$1p|=q>&*^G;Bxgg_p;|JG72lg2@|h(`p@A
zo-NnOW-2(heL|seSGh*eec_zM^$=Fdji?Mq1m=O;{3e20yrI-pleOrdel$fpuwBR3
zkR#+HnC+Uo`@M*U0%5Kjh$Z&JpdAJWfhVj>9aEUmFwKqJ5;ZW3Io>`KfeIkZlq+#P
ztfWS2I`UYM$8w)An>2Adr*b5-9vUcNkudt*vjfp>yqI7H`;_@h1|G}9PM@|y|C~+n
zqjMo-?;I5e-N;yJMAVW>M=)Had%{A$l?XM^5Mj&{O<`a4N?g9{O>!8jiiUMUsV`n{
zS-!vL20L!(oG8{j<8vCcX4e^TX2ZY>yd;dX2}+1Ct$3gW*a8!;r3G)KPrcsM6zPD8
zcLv@=-aNhpy_;9)vZ~FnOLo61!hDZ4_D$txz5_S(nqtS6FCiaibf4I|>=ldPx5RG|
zJhG$6@Tl?1<e7L*S39`(i+_fo^C-h|9Oco76L=ou)d<Eh!C901pW;Y1qWQ|Sl78w2
z`7hOL6g!yzytaCc2W!`O)aT7H28=b3V`KqE{-j1JMq?Q(ykZ_aL7CYNuBL)2>y2O)
zYl&`#=PaH^%DaplVnp@^rc{33!K(%fzx~OZaWi_9u*hUfk=RrWNW`RXoA|(Dgslj(
F{U0$q9vuJx

diff --git a/bin/utils/FileTransfer.class b/bin/utils/FileTransfer.class
deleted file mode 100644
index a1ce32e6dc72be026b35ec1d969016e5dbe779e8..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 4643
zcmaJ_`FB)T9sk^9CU55Dg)ET33lye>mINlmwm|5l1tA4VOadhkjL^!<%u6ybnK#b7
z2@UQGh)Y$pYDJ2*ig9ZdtO+KSxQ2>r-CFnM9Q_wOhaZfed*6h-Eakwt_r80-_q%>R
z-??z(f8*BxwBTPFiUg|iZZef?+>=b%2eVc>*Jo!n1OzIMTSHc3%1ZY)?(02n$6bMv
z2b1ZfyIr8TuD)9!(BdR)9mNP62%<!wygiw=JM)9RcJ`pvo3g3A-HBVNZY!IV--XS9
zJCMu?ENfqAxmlnzYsc;6kS!e&sHtmhpLL|m%_h_R&Gp?HDg~<5LE3g3yX@?co$Yes
zCu~<o1(r&OmeIqy*81)+YOq4X@;M=O4d+~Y(13|rhU4TJUA1Q@=``-A6_>VbYp}VB
zsaj>=4y+bfK4_h=Tby*<at|ln0j_ecm3A3RH4QEFQ%3}MX}D8hsd9C$Y6EMrPC&~@
zYpJwUvQR~Rw~Xf=1M5-80$B05ouRKw>k8&n^eXOV4IAj<jG>1u*J@2?@`X5bM6pRj
z1B*19HFeKGBVH%4q~CUZ^3*hAf?oR$nswCUKAGS91y&S1o+l#fvxTQKzQ|JU%ey{j
zHls<ZSSQ_jz(5Qvyyt=K?o1@Ic8*D1G2?*@vXw*Ogf2XU9U2HkA4olH7<fH)GO0sW
zDsS)W6S&8pR1e6_i<GJg0xh!456`<Y1G$Bzk%`!2;0@R-5F%C*?M}L1aigsYMQD@S
z-YBcuwun6)o6%vQ6Z-^$C$mYHSl8-~>}n-obv%MD4F{MKl|jY94$B=da1e)RVK7Ow
z1nb(`>f59fhYh?5Jw&^7;+C4$Dl)T0+Bs_AQAy8WJmus_*m@k*aSXj0tQlk~69)&f
z&PmBr194DMnUzR%<ue&s4V&LH)t)O%Hp(g<l{D)&FrWx!XR|tvBc<WQj0uU6eY+o*
z_)R)#1A|}?I#Jg_^;SRQUp7;3WuTDwDg<N{$MIGJS=D3|U%Ff?euDif&Uh+tw2ENL
z%Y+XJtY5TcEUX_BmT|HqlW1iD`-ss_Yf$y9*{m0w5HNDS7DIA)>gM+zqS%P1k~X`C
z;+8<APtc<&8JL*MO##!BVv6R`mI^DRXMXkw)ZP-G&n(KTNV<}z7>Q_O%jnJbv84+X
z9oZ!i?j3gR+yR9XL5bO(=c^5sl&So7SQ*u_HJqW|oSjZcdjfTSP8Cwr>iOg^od=AM
zNuqyTcJhT11iOY$_&S9Q-yf?)){_Q4g-<hW#ESpS*C3cU{|Ot!IXorpewMkN?NM`N
zr0LK38m0`**XMMcM^hC_(4yh<EUUkl>9~j{IXr9Ni<15&DLdWo4#=%b2EHtjt<hVF
zrz&XpibUpDB{CPLVDaW~4qrF$4Lrw+spjCdmH=A`$#xDMa`={k%Zk>0seF#M&*R&&
z5xgK<!;xL}ts#suJQ-GmrE?>>JbyfLxxRcVHM~iRvkRP))Cr-5754ystNAJz?Pt?r
zbh!eUD<p9JN%TW;e(8v!^1it_^#grgx+xuy((HL&j#yGD!hOBV$!Ft*_duoGoO!2g
zl0_jyb~%olbF)^a!*&OpL{7(b{8YnB0_$d}oJ<cnC+tQKuHKLM9xLuT*<o3o8v;-H
zt5cBn6z;XsiIkmN*X}qc@|os^MfB~=xp;6mV=p3p#3#SVPf|fei<L@s@rR+gyaZDr
z{6b)r_s)qVa}ho~vM%335hopyT`VF(_!V1ii|Rg+xRXxv$z~^F^5A8GH3!tIO5TuZ
zjyQdh9D4+hBdR5Y@LPd9WO5^g_g5mqs3SRR$mS}i^!%P8yR%s*8%gBlL(Egf#H&}M
z5_v^nZHtpnB_e5ukds~#ee!iS>!}j_BRc}C;CUHwor07)`!j*k#cnfWf}4@Lf}{21
zVk@s@TT&K(mU0^YCUEzHGA~v*4gU~WeS1-&-K#S0<cpw~k3VoErPv8bYJN3x7Mz0{
z#t^#9MG<t4@)%r|ax^>v&Sm@xV+qQ+!^_2|IW7Uj711F&Cs5H-JBF%Q;0mg1$FUL^
z#TpR{idcym7{%Q&Z36W@rZ$R=W4JdKn!x5BuC~U)ydbx?UB!dr*ro27p;7E^(s@#&
zkE2!XRaW4|P|O&ibl5bCtII~wUZYo+owl3w8a@2vMXWMIJTQ%Gr)%`9*nf5u-91~&
zik_K%nTj@!<ISG#@Dysz@F<Rq(A}WP&ye~wgOg@x3Y(?z$3_sP<H76D&5~Gf1eIpc
zEV;xlPNR5>6bvarc}ttZaT$U=g5KNSqF_h~^44tyc^tfgJ~KFq<TxD9aeidXz!X|!
zLUSW%?vP(0^%b4$j9y2mp<@JP(S}P1MH}d5bh3k5YNJYvtF&;Pxy&}X1J7fE72Sdx
zc!l$NB0*L-BDRXHoNL7)afnZqB_bt;`5h2v#2L;I7sLhb7b~Q6qncX=aZrX@K3>+N
zk{YY1eHjj5IeM@HeFVcG)*!>vQ>epxxqcQKX+J6s^A+EZO(Ml-`_s5rJcs+lWj^yH
z@=j4N(S?(ET-m*XVeYZ1iXprWZ|7TTy)f_&ypuTGf|u|vyj#U}7Vn{rFl`^g`|y7H
zIf$J&jWg7jp>H3czB2y01-un~sK!}*5J7sdOs$IWAzHkImD9XXCNw;x;h6ecF|&wj
zsMoMLpy9*h%1u<RnP#Z^?PS5jV>eM+)XurA>?Xpqt6geqn*0mSQ6cXfuaOsSLf^?L
z9G+$hilmS_TgE^?f+svm7ELfH7Ex>yogx;PK(uGW$}xO27M#Gj9toyTj^Q)0k_nve
ziH_kyOd~NijN@sAj0s$nyU)ZFu)olxh)FJdsU|#*5f6eTH6+g0JSvuwKW2$pT3l_6
z;(1AnZ<?A}I*KbjTMe@AKU7}z9d-f9j};R3V<V{OlwXPjV-1sL$rKvp&8s6=9}6^G
zN7xK>j-b533|vB(qvRTeLQ04if>U@@212SGdd&+I3Mrw6$=8x;nCv7o$Pv=(yDB!W
zNsJ%?`UKw-z-q?)0_O_6ihpwsim(WChFB}s-XcI70R=QsY8!7nz}wA)?{@y#f!+M~
z+hP9S#ADb48*TjO#C|^eA0eRI2*-o8b4aX1x40jNMHAsV3;JysC)A~_Z3_N`7*`YA
zE25?U;zfc!NPAcDJzQhEt|JX5@qH3uJNDrR_#ug~8+#S}!?aze;9p7)$`$AhQpE69
z^kAt1eX#=lFqTeJ%pkt}K#XcQr{TPYi?<NJWEyuNw76UW>bj7~EiEO~XIB!%rKJ+Z
z#f8fX$V=H#e#D52@MHXh^ELweXB7Im8h@$AU#syqYW$rV|DeWK)%d5v{$F@o=gq(3
J@AxOo{{yN|e}4b~

diff --git a/config.properties b/config.properties
index 2ee1808..e5a37f1 100644
--- a/config.properties
+++ b/config.properties
@@ -1,2 +1,12 @@
 test.dir=./src/test
 downloads.dir=./src/downloads
+
+#Defaults
+beacon.port=12344
+broadcast.group=255.255.255.255   
+broadcast.port=12345
+broadcast.chunk_bytes=1024
+broadcast.max_rounds=3
+broadcast.nack_port=50011
+broadcast.nack_delay_ms=200
+broadcast.wait_nacks_ms=250
diff --git a/src/Main/Main.java b/src/Main/Main.java
index 0c5e865..6b120f5 100644
--- a/src/Main/Main.java
+++ b/src/Main/Main.java
@@ -113,7 +113,7 @@ public static void main(String[] args) throws IOException {
 
                 
                 Scanner scanner = new Scanner(System.in);
-                System.out.print("Enter command (upload <FilePath> or download <FileHash>): ");
+                System.out.print("Enter command (upload <FilePath> | download <FileHash> | broadcastfile <FilePath> | broadcastrecieve <FileHash>): ");
                 
                 while (true) {
                     
@@ -149,14 +149,11 @@ public static void main(String[] args) throws IOException {
                             
                             break;
                         case "broadcastfile":
-                        	FileData f = new FileData(argument);
-                			
-                			System.out.println("The File Hash of the File to be broadcasted is " + f.getFileHash());
-                			System.out.println("Type broadcast to enter broadcasting period");
-                			
-                			userInput = scanner.nextLine().trim();
-                        	BroadCastTransfer.BroadcastFile(f , Handshake.getClient() , argument);
-                        	break;
+                    	
+                			FileData f = new FileData(argument);
+    						System.out.println("The File Hash of the File to be broadcasted is " + f.getFileHash());
+    						BroadCastTransfer.BroadcastFile(f , Handshake.getClient() , argument);
+    						break;
                         
                         case "broadcastrecieve":
                         	BroadCastTransfer.RecieveFile(argument);
diff --git a/src/p2p/BroadCastTransfer.java b/src/p2p/BroadCastTransfer.java
index 16a9ebe..a104860 100644
--- a/src/p2p/BroadCastTransfer.java
+++ b/src/p2p/BroadCastTransfer.java
@@ -11,6 +11,16 @@
 import java.net.DatagramPacket;
 import java.net.DatagramSocket;
 import java.net.InetAddress;
+import java.nio.ByteBuffer;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+import java.util.TreeSet;
+import java.util.Random;
+import java.nio.charset.StandardCharsets;
+
 
 import discovery.FileData;
 import discovery.Node;
@@ -20,11 +30,49 @@
 
 public class BroadCastTransfer {
 	
-	public static int broadcastListeningPort = 12345;
-	private static int BUFFER_SIZE = 1024;
-	public static int broadCastCountDefault = 1; //anybody that misses the beacon would miss the file transfer
+	public static int broadcastListeningPort = Config.getBroadcastPort();
+	private static int BUFFER_SIZE = 1024; 
+	public static int broadCastCountDefault = 3; //anybody that misses the beacon would miss the file transfer
 	public static int congestionControlSleepTime = 30;
 	public static int congestionControlSleepPacketCount = 400;
+
+	static final byte FLAG_DATA = 0x01;
+	static final byte FLAG_EOB  = 0x02; // End Of Broadcast (marker after first pass)
+	
+	// Make a packet with header and data
+	static ByteBuffer makePkt(int sessionId, int seq, int total, byte flag, byte[] data) 
+	{
+    	int body = (data == null ? 0 : data.length);
+    	ByteBuffer bb = ByteBuffer.allocate(1 + 4 + 4 + 4 + body);
+    	bb.put(flag);            // 1
+    	bb.putInt(sessionId);    // 4
+    	bb.putInt(seq);          // 4
+    	bb.putInt(total);        // 4
+    	if (body > 0) bb.put(data);
+    	bb.flip();
+    	return bb;
+	}
+
+	// Parse a received packet
+	static class Parsed 
+	{
+    	byte flag; int sid; int seq; int total; byte[] data;
+	}
+	static Parsed parsePkt(byte[] buf, int len) 
+	{
+    	ByteBuffer bb = ByteBuffer.wrap(buf, 0, len);
+    	Parsed p = new Parsed();
+    	p.flag  = bb.get();
+    	p.sid   = bb.getInt();
+    	p.seq   = bb.getInt();
+    	p.total = bb.getInt();
+    	int remain = bb.remaining();
+    	p.data = new byte[remain];
+    	bb.get(p.data);
+    	return p;
+	}
+
+
 	public static void BroadcastFile(FileData f, Node client , String filePath) {
 		try {
 			
@@ -42,62 +90,155 @@ public static void BroadcastFile(FileData f, Node client , String filePath) {
             socket.setBroadcast(true); // Enable broadcasting
             
             // Define the broadcast address
-            InetAddress broadcastAddress = InetAddress.getByName("255.255.255.255");
+            InetAddress broadcastAddress = InetAddress.getByName(Config.getBroadcastGroup());
+
+			//NACK Listener 
+			int nackPort = Config.getBroadcastNackPort();
+            int waitNacksMs = Config.getBroadcastWaitNacksMs();
+            int maxRounds = Config.getBroadcastMaxRounds();
+
+			DatagramSocket nackSocket = new DatagramSocket(nackPort);
+            nackSocket.setSoTimeout(waitNacksMs);
 
             // Open the file to read
             File file = new File(filePath);
             FileInputStream fileInputStream = new FileInputStream(file);
-            byte[] buffer = new byte[BUFFER_SIZE];
+
+            byte[] buf = new byte[BUFFER_SIZE];
+            List<byte[]> slices = new ArrayList<>();
             int bytesRead;
+            while ((bytesRead = fileInputStream.read(buf)) != -1) {
+                byte[] chunk = new byte[bytesRead];
+                System.arraycopy(buf, 0, chunk, 0, bytesRead);
+                slices.add(chunk);
+            }
+            fileInputStream.close();
+
+			int totalPackets = slices.size(); // Total number of packets to send
+            int sessionId = (int)(System.nanoTime() & 0x7fffffff); // Random session ID
 
             // Send the file in chunks
-            int sequenceNumber = 0;
+            //int sequenceNumber = 0;
             long totalSize = f.getFileSize();
             long sentSize = 0;
-            while ((bytesRead = fileInputStream.read(buffer)) != -1) {
+
+			for (int sequenceNumber =0; sequenceNumber < totalPackets; sequenceNumber++) 
+			{
+                byte[] chunk = slices.get(sequenceNumber);
                 // Create a packet with the chunk and sequence number
                 ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                 DataOutputStream dataOutputStream = new DataOutputStream(byteArrayOutputStream);
                 dataOutputStream.writeInt(sequenceNumber); // Add sequence number
-                dataOutputStream.write(buffer, 0, bytesRead); // Add the chunk
+                dataOutputStream.write(chunk); // Add the chunk
                 byte[] packetData = byteArrayOutputStream.toByteArray();
 
+				ByteBuffer pkt = makePkt(sessionId, sequenceNumber, totalPackets, FLAG_DATA, packetData); // Create packet with header
+
                 // Send the packet
-                DatagramPacket packet = new DatagramPacket(packetData, packetData.length, broadcastAddress, BroadCastTransfer.broadcastListeningPort);
+                DatagramPacket packet = new DatagramPacket(pkt.array(), pkt.remaining(), broadcastAddress, BroadCastTransfer.broadcastListeningPort);
                 socket.send(packet);
-                sentSize += bytesRead;
-                sequenceNumber++;
+                sentSize += chunk.length;
                 
                 UserExperience.printProgressBar(sentSize, totalSize);
                 
-                if(sequenceNumber%BroadCastTransfer.congestionControlSleepPacketCount == 0) {
+                if(sequenceNumber%BroadCastTransfer.congestionControlSleepPacketCount == 0 && sequenceNumber != 0) { // Congestion control
                 	Thread.sleep(BroadCastTransfer.congestionControlSleepTime);
                 }
             }
 
             // Send an end-of-file packet
-            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
-            DataOutputStream dataOutputStream = new DataOutputStream(byteArrayOutputStream);
-            dataOutputStream.writeInt(-1); // Special sequence number to indicate EOF
-            byte[] eofPacketData = byteArrayOutputStream.toByteArray();
-            DatagramPacket eofPacket = new DatagramPacket(eofPacketData, eofPacketData.length, broadcastAddress, BroadCastTransfer.broadcastListeningPort);
-            socket.send(eofPacket);
+           {
+                ByteBuffer eob = makePkt(sessionId, -1, totalPackets, FLAG_EOB, null); // EOB packet
+                DatagramPacket eofPacket = new DatagramPacket(eob.array(), eob.remaining(), broadcastAddress, BroadCastTransfer.broadcastListeningPort); 
+                socket.send(eofPacket);// Send EOB packet
+            }
+
+            System.out.println("File broadcast complete (pass 1). Listening for NACKs...");
+
+			// Listen for NACKs and resend missing packets
+
+			for (int round = 0; round < maxRounds; round++) 
+			{
+                long deadline = System.currentTimeMillis() + waitNacksMs;
+                Set<Integer> toRetransmit = new TreeSet<>();
+				while (System.currentTimeMillis() < deadline) 
+				{
+                    try 
+					{
+                        byte[] nbuf = new byte[2048];
+                        DatagramPacket ndp = new DatagramPacket(nbuf, nbuf.length);
+                        nackSocket.receive(ndp);
+
+                        String msg = new String(ndp.getData(), 0, ndp.getLength(), StandardCharsets.UTF_8);
+                        // Expected: "NACK;<sessionId>;<seq1,seq2,...>"
+                        if (!msg.startsWith("NACK;")) continue;
+                        String[] parts = msg.split(";", 3);
+                        if (parts.length < 2) continue;
+                        int sid = Integer.parseInt(parts[1].trim());
+                        if (sid != sessionId) continue;
+
+                        if (parts.length == 3 && !parts[2].isEmpty()) {
+                            String[] seqs = parts[2].split(",");
+                            for (String s : seqs) {
+                                s = s.trim();
+                                if (!s.isEmpty()) toRetransmit.add(Integer.parseInt(s));
+                            }
+                        }
+                    } catch (IOException e) {
+                        // timeout or transient; break the inner wait loop
+                        break;
+                    }
+                }
+
+                if (toRetransmit.isEmpty()) {
+                    System.out.println("No NACKs in round " + (round + 1) + ". Done.");
+                    break;
+                }
+				
+				System.out.println("Round " + (round + 1) + " retransmitting: " + toRetransmit);
+
+                // Re-broadcast missing chunks
+                for (int seq : toRetransmit) {
+                    if (seq < 0 || seq >= totalPackets) continue;
+                    byte[] chunk = slices.get(seq);
 
-            System.out.println("File broadcast complete.");
+                    ByteArrayOutputStream baos = new ByteArrayOutputStream();
+                    DataOutputStream dos = new DataOutputStream(baos);
+                    dos.writeInt(seq);
+                    dos.write(chunk);
+                    byte[] legacyPayload = baos.toByteArray();
+
+                    ByteBuffer pkt = makePkt(sessionId, seq, totalPackets, FLAG_DATA, legacyPayload);
+                    DatagramPacket dp = new DatagramPacket(pkt.array(), pkt.remaining(), broadcastAddress, BroadCastTransfer.broadcastListeningPort);
+                    socket.send(dp);
+                }
+
+                // Re-send EOB to trigger final hole checks at receivers
+                ByteBuffer eob = makePkt(sessionId, -1, totalPackets, FLAG_EOB, null);
+                socket.send(new DatagramPacket(eob.array(), eob.remaining(), broadcastAddress, BroadCastTransfer.broadcastListeningPort));
+            }
+
+            System.out.println("Broadcast (with repairs) complete.");
 
             // Clean up
-            fileInputStream.close();
             socket.close();
-		} catch (IOException | InterruptedException e) {
-			// TODO Auto-generated catch block
-			e.printStackTrace();
-		}
-		
-	}
+            nackSocket.close();
+
+        } catch (IOException | InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+
 	
 	public static void RecieveFile(String fileHash) {
 		BroadcastBeacon beacon = (BroadcastBeacon)ObjectTransfer.recieveObjectBroadcast();
-		
+		if (beacon == null) //
+        {
+            System.err.println("Failed to receive beacon (null). Is the sender running and on the same LAN?");
+            return;
+        }
+
 		long totalSize = beacon.file.getFileSize();
 		
 		if(beacon.file.getFileHash().equals(fileHash)) {
@@ -107,43 +248,86 @@ public static void RecieveFile(String fileHash) {
 
 	            // Open the file to write
 	            String outputFilePath = new java.io.File(Config.getDownloadsDir(), beacon.file.getFileName()).getPath();
-	            FileOutputStream fileOutputStream = new FileOutputStream(outputFilePath);
-	            byte[] buffer = new byte[BUFFER_SIZE];
+	            //FileOutputStream fileOutputStream = new FileOutputStream(outputFilePath);
+	            byte[] bigBuf = new byte[65535]; // Max UDP packet size
 	            long recvSize = 0;
+
+				 // Buffer chunks by sequence number (so out-of-order doesn’t corrupt the file)
+                Map<Integer, byte[]> bufferBySeq = new HashMap<>();
+                int expectedTotal = -1;
+                int sessionId = -1;
+
+				// For NACKs
+                int nackPort = Config.getBroadcastNackPort();
+                int nackDelayMs = Config.getBroadcastNackDelayMs();
+                Random jitter = new Random();
 	            // Receive packets and write to file
 	            while (true) {
-	                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
+	                DatagramPacket packet = new DatagramPacket(bigBuf, bigBuf.length);
 	                socket.receive(packet);
 
+					// Parse reliability header
+                    Parsed p = parsePkt(packet.getData(), packet.getLength());
+                    if (sessionId == -1) sessionId = p.sid;
+
 	                // Extract sequence number and data
-	                ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(packet.getData());
-	                DataInputStream dataInputStream = new DataInputStream(byteArrayInputStream);
-	                int sequenceNumber = dataInputStream.readInt();
-
-	                if (sequenceNumber == -1) {
-	                    // End-of-file packet received
-	                    System.out.println("End of file received.");
-	                    break;
-	                }
-
-	                // Write the chunk to the file
-	                int bytesRead = packet.getLength() - 4; // Subtract 4 bytes for the sequence number
-	                byte[] chunk = new byte[bytesRead];
-	                dataInputStream.readFully(chunk);
-	                fileOutputStream.write(chunk);
-	                recvSize += bytesRead;
-	                
-	                UserExperience.printProgressBar(recvSize, totalSize);
-	                
-	            }
-
-	            // Clean up
-	            fileOutputStream.close();
-	            socket.close();
-	        } catch (Exception e) {
-	            e.printStackTrace();
-	        }
-
-		}
-	}
+	                	if (p.flag == FLAG_DATA) { 
+                        ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(p.data); // FIXED: p.data
+                        DataInputStream dataInputStream = new DataInputStream(byteArrayInputStream);
+                        int sequenceNumber = dataInputStream.readInt();
+                        int payloadLen = p.data.length - 4;
+                        byte[] chunk = new byte[payloadLen];
+                        dataInputStream.readFully(chunk);
+
+                        if (!bufferBySeq.containsKey(sequenceNumber)) {
+                            bufferBySeq.put(sequenceNumber, chunk);
+                            recvSize += chunk.length;
+                            UserExperience.printProgressBar(recvSize, totalSize);
+                        }
+
+                        if (expectedTotal < 0) expectedTotal = p.total;
+
+                    } else if (p.flag == FLAG_EOB) {
+                        if (expectedTotal < 0) expectedTotal = p.total;
+
+                        List<Integer> missing = new ArrayList<>();
+                        for (int i = 0; i < expectedTotal; i++) {
+                            if (!bufferBySeq.containsKey(i)) missing.add(i);
+                        }
+
+                        if (missing.isEmpty()) {
+                            try (FileOutputStream fos = new FileOutputStream(outputFilePath)) {
+                                for (int i = 0; i < expectedTotal; i++) {
+                                    fos.write(bufferBySeq.get(i));
+                                }
+                            }
+                            System.out.println("End of file received (complete).");
+                            socket.close();
+                            return;
+                        } else {
+                            int delay = jitter.nextInt(Math.max(1, nackDelayMs));
+                            try { Thread.sleep(delay); } catch (InterruptedException ignored) {}
+
+                            missing.removeIf(bufferBySeq::containsKey);
+
+                            if (!missing.isEmpty()) {
+                                String body = String.join(",", missing.stream().map(String::valueOf).toArray(String[]::new));
+                                String msg = "NACK;" + sessionId + ";" + body;
+                                byte[] m = msg.getBytes(StandardCharsets.UTF_8);
+                                DatagramPacket ndp = new DatagramPacket(m, m.length, InetAddress.getByName(Config.getBroadcastGroup()), nackPort);
+                                DatagramSocket ns = new DatagramSocket();
+                                ns.setBroadcast(true);
+                                ns.send(ndp);
+                                ns.close();
+                            }
+                        }
+                    }
+                }
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
+    
 }
diff --git a/src/p2p/ObjectTransfer.java b/src/p2p/ObjectTransfer.java
index 7269ef4..c2f57ff 100644
--- a/src/p2p/ObjectTransfer.java
+++ b/src/p2p/ObjectTransfer.java
@@ -6,8 +6,16 @@
 import java.net.InetAddress;
 import java.net.Socket;
 
+import utils.Config;
+
 public class ObjectTransfer {
-	public static int broadCastListeningPort = 12345;
+
+	public static int broadCastListeningPort = Config.getBeaconPort();
+    private static final String BROADCAST_GROUP = Config.getBroadcastGroup();
+
+    private static final int MAX_UDP_PAYLOAD = 65507;
+    private static final int RECV_BUFFER = 65535;
+    
     public static void sendObject(Socket socket, Object object) throws IOException {
         // Create an ObjectOutputStream to send the object
         ObjectOutputStream outputStream = new ObjectOutputStream(socket.getOutputStream());
@@ -26,7 +34,7 @@ public static Object receiveObject(Socket socket) throws IOException, ClassNotFo
     }
     
     public static void sendObjectBroadcast(Object obj) {
-    	try {
+            try {
             // Serialize the object
             ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
             ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteArrayOutputStream);
@@ -36,27 +44,31 @@ public static void sendObjectBroadcast(Object obj) {
             objectOutputStream.close();
             byteArrayOutputStream.close();
 
+            // 
+            if (serializedObject.length > MAX_UDP_PAYLOAD) {
+                System.err.println("[ObjectTransfer] Serialized object too large for a single UDP packet (" +
+                                   serializedObject.length + " > " + MAX_UDP_PAYLOAD + ").");
+                return;
+            }
+
             // Create a UDP socket
-            DatagramSocket socket = new DatagramSocket();
+            try(DatagramSocket socket = new DatagramSocket()){
             socket.setBroadcast(true); // Enable broadcasting
 
             // Define the broadcast address and port
-            InetAddress broadcastAddress = InetAddress.getByName("255.255.255.255");
-            
+            InetAddress broadcastAddress = InetAddress.getByName(BROADCAST_GROUP.trim());
 
             // Create a DatagramPacket with the serialized object
             DatagramPacket packet = new DatagramPacket(serializedObject, serializedObject.length, broadcastAddress, ObjectTransfer.broadCastListeningPort);
 
             // Send the packet
             socket.send(packet);
+            }
             System.out.println("Object broadcasted successfully!");
-
-            // Close the socket
-            socket.close();
-        } catch (Exception e) {
-            e.printStackTrace();
+        }catch (Exception e){
+                e.printStackTrace();
+            }
         }
-    }
     
     public static Object recieveObjectBroadcast() {
     	try {
@@ -64,7 +76,7 @@ public static Object recieveObjectBroadcast() {
             DatagramSocket socket = new DatagramSocket(ObjectTransfer.broadCastListeningPort); // Listen on the same port
 
             // Buffer to store incoming data
-            byte[] buffer = new byte[1024];
+            byte[] buffer = new byte[RECV_BUFFER];
             DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
 
             // Receive the packet
@@ -73,7 +85,7 @@ public static Object recieveObjectBroadcast() {
             System.out.println("Object received!");
 
             // Deserialize the object
-            ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(packet.getData());
+            ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(packet.getData(), 0, packet.getLength());
             ObjectInputStream objectInputStream = new ObjectInputStream(byteArrayInputStream);
             Object receivedObject = objectInputStream.readObject();
             objectInputStream.close();
diff --git a/src/utils/Config.java b/src/utils/Config.java
index 6b1608d..fcad39c 100644
--- a/src/utils/Config.java
+++ b/src/utils/Config.java
@@ -24,6 +24,41 @@ public final class Config {
 
     private Config() {}
 
+     // Getters for broadcast properties
+    public static String getBroadcastGroup() 
+    { 
+        return PROPERTIES.getProperty("broadcast.group","255.255.255.255").trim();
+    }
+    public static int getBroadcastPort()
+     {
+        return Integer.parseInt(PROPERTIES.getProperty("broadcast.port","50010")); 
+    }
+    public static int getBroadcastChunkBytes() 
+    { 
+        return Integer.parseInt(PROPERTIES.getProperty("broadcast.chunk_bytes","4096"));
+    }
+    public static int getBroadcastMaxRounds() 
+    { 
+        return Integer.parseInt(PROPERTIES.getProperty("broadcast.max_rounds","3")); 
+    }
+    public static int getBroadcastNackPort() 
+    {
+        return Integer.parseInt(PROPERTIES.getProperty("broadcast.nack_port","50011")); 
+    }
+    public static int getBroadcastNackDelayMs() 
+    {
+        return Integer.parseInt(PROPERTIES.getProperty("broadcast.nack_delay_ms","200")); 
+    }
+    public static int getBroadcastWaitNacksMs() 
+    { 
+        return Integer.parseInt(PROPERTIES.getProperty("broadcast.wait_nacks_ms","250")); 
+    }
+    public static int getBeaconPort() 
+    {
+        return Integer.parseInt(PROPERTIES.getProperty("beacon.port", "12344"));
+    }
+
+    // Getters for directory paths
     public static String getTestDir() {
         String dir = PROPERTIES.getProperty("test.dir", DEFAULT_TEST_DIR);
         ensureDirectory(dir);