RemSound/server/__pycache__/remsound-relay.cpython-311.pyc

§
FgjÁuã
ó*—dZd
dl
mZ
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dl	Z	d
dl
Z
d
dlZd
dlZd
dl
Z
d
dlmZmZ
d
dlmZ
dZdZdZd	Zd	Zd
Zd
ZdZdZd
ZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/e$e%e&e'e(hZ0dZ1de#zZ2eGd„d¦«¦«Z3eGd„d ¦«¦«Z4eGd!„d"¦«¦«Z5d:d'„Z6d;d+„Z7d<d-„Z8d=d0„Z9d>d2„Z:d?d4„Z;Gd5„d6¦«Z<d@d8„Z=e>d9krej?e=¦«¦
«

dSdS)Auè
RemSound UDP relay, dual-protocol.

Listens on a single UDP port and handles two protocol versions concurrently:

- v1 ("pairwise"): 12-byte header, two-slot reflector. First two distinct
  UDP endpoints to send a valid RemSound v1 packet claim the slots; subsequent
  v1 packets from one slot's endpoint are reflected to the other. Slots idle
  for IDLE_TIMEOUT_SECONDS are eligible for replacement. This is the original
  remsound-relay.py behaviour, preserved here unchanged so legacy clients keep
  working against the new server.

- v2 ("lobby"): 28-byte header with embedded CLIENT_ID (UUID). Up to
  REMSOUND_MAX_CLIENTS instances (default 10) form a single lobby. Each
  incoming packet is forwarded unmodified to every OTHER registered client.
  Identity is the CLIENT_ID, not the network endpoint — NAT rebinds and
  same-NAT-multiple-clients are no longer special cases. Periodic LobbyRoster
  packets keep clients informed of the current membership.

The two protocols share state only via the listening socket and the stats
counters. They never interact otherwise: a v1 client and a v2 client cannot
hear each other in this release (deliberate — see the design doc).

Owner: Pi thread. Spec: D:\Dropbox\proj\pi\remsound server update.md.
é)
ÚannotationsN)Ú	dataclassÚfield)
ÚOptionalz0.0.0.0iÖºié<gð?z/var/log/remsound-relay.logé
é sRMNDé
ééééééééééé	g@ó
c
ó|—eZ
dZUd
Zded<ded<dZded<dZded	<d
Zded<d
Zded<dZ	ded<d
Z
ded<dS)ÚPeerSlotu<v1 protocol — one of (up to) two peer endpoints in a pair.útuple[str, int]ÚaddrÚfloatÚ	last_seenrÚintÚ
rx_packetsÚ
tx_packetsFÚboolÚverifiedóÚbytesÚcookieçÚcookie_sentÚwould_block_loggedN©Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__annotations__rrr!r$r&r'©r"ú)D:\proj\RemSound\server\remsound-relay.pyrras—€€€€€€àFÐFØÐÐÑØÐÐÑØ€JÐÐÐÑØ€JÐÐÐÑà€HÐÐÐÑØ€FÐÐÐÑØ€KÐÐÐÑØ$ÐÐ$Ð$Ð$Ñ$Ð$Ð$r"rc
ó†—eZ
dZUd
Zded<ded<ded<dZd	ed
<dZd	ed<dZd
ed<dZded<dZ	ded<dZ
d
ed<dS)ÚClientEntryu<v2 protocol — one client in the lobby, keyed by CLIENT_ID.rrÚstrÚdisplay_namerrrrrrFr r!r"r#r$r%r&r'Nr(r.r"r/r1r1os£€€€€€€àFÐFØÐÐÑØÐÐÑØÐÐÑØ€JÐÐÐÑØ€JÐÐÐÑà€HÐÐÐÑØ€FÐÐÐÑØ€KÐÐÐÑØ$ÐÐ$Ð$Ð$Ñ$Ð$Ð$r"r1c
óœ—eZ
dZUd
Zded<d
Zded<d
Zded<d
Zded<d
Zded<d
Z	ded<d
Z
ded	<d
Zded
<d
Zded<d
Z
ded<d
S)Ú
RelayStatsrrÚ	forwardedÚdropped_unpairedÚdropped_lobby_fullÚrejected_bad_headerÚpair_changesÚ
lobby_changesÚaddr_checks_verifiedÚblocked_unverifiedÚwould_block_unverifiedÚrejected_ip_capN)r)r*r+r6r-r7r8r9r:r;r<r=r>r?r.r"r/r5r5~s€€€€€€à€IÐÐÐÑØÐÐÐÐÑØÐÐÐÐÑØ ÐÐ Ð Ð Ñ Ø€LÐÐÐÑØ€MÐÐÐÑØ !ÐÐ!Ð!Ð!Ñ!ØÐÐÐÐÑØ"#ÐÐ#Ð#Ð#Ñ#Ø€OÐÐÐÑÐÐr"r5Úlog_pathr2Úreturnúlogging.Loggerc

ó<—t
j
d
¦
«
}
|
 tj¦
«

t
jdd¬¦«}	tj |d¬¦«}| |¦
«

|
 |¦
«

n=#t$r0}tj d|›d|›d	�¦
«

Yd}~nd}~w
wxYw
t
j
tj¦
«
}| |¦
«

|
 |¦
«

|
S)
Nzremsound-relayz+%(asctime)s level=%(levelname)s %(message)sz%Y-%m-%d %H:%M:%S)ÚfmtÚdatefmtúutf-8)
Úencodingzremsound-relay: could not open z: ú

)ÚloggingÚ	getLoggerÚsetLevelÚINFOÚ	FormatterÚhandlersÚWatchedFileHandlerÚsetFormatterÚ
addHandlerÚOSErrorÚsysÚstderrÚwriteÚ
StreamHandler)r@ÚloggerrDÚfhÚ
eÚshs      r/Úsetup_loggerr[Œs'
€Ý
Ô
Ð/Ñ
0Ô
0€FØ
‡O‚O•G”LÑ!Ô!Ð!Ý
Ô
Ø9Ø#ðñô€CðN
Ý
Ô
×
0Ò
0°ÀGÐ
0Ñ
LÔ
LˆØ
�Š˜ÑÔÐØ×Ò˜"ÑÔÐÐøÝð
N
ð
N
ð
N
݌
×ÒÐL¸8ÐLÐLÀqÐLÐLÐLÑMÔMÐMÐMÐMÐMÐMÐMøøøøð
N
øøøå	Ô	�sœzÑ	*Ô	*€B؇O‚O�CÑÔÐØ
×Ò�bÑÔÐØ€MsÁABÂ
CÂ!&CÃCÚdatar#úOptional[tuple[int, int, int]]c

óÀ—t
|¦
«
tkrd
S|d}
tjd|d¦«d}tjd|d¦«d}|
||fS)zBValidate a v1 header. Returns (type, stream_id, sequence) or None.Nrú<Hrrú<Ir)ÚlenÚ
V1_HEADER_LENÚstructÚunpack_from)r\Úpkt_typeÚ	stream_idÚsequences    r/Úparse_header_v1rhŸs`€å
ˆ4�y„y•=Ò Ð ØˆtØ�AŒw€HÝÔ" 4¨¨qÑ1Ô1°!Ô4€IÝÔ! $¨¨aÑ0Ô0°Ô3€HØ�Y Ð(Ð(r"ú%Optional[tuple[int, int, int, bytes]]c

ó
—t
|¦
«
tkrd
S|d}
tjd|d¦«d}tjd|d¦«d}t	|t
t
tz…¦
«
}|
|||fS)zSValidate a v2 header. Returns (type, stream_id, sequence, client_id_bytes) or None.Nrr_rrr`r)raÚ
V2_HEADER_LENrcrdr#ÚV2_CLIENT_ID_OFFSETÚV2_CLIENT_ID_LEN)r\rerfrgÚclient_id_bytess     r/Úparse_header_v2ro©s�€å
ˆ4�y„y•=Ò Ð ØˆtØ�AŒw€HÝÔ" 4¨¨qÑ1Ô1°!Ô4€IÝÔ! $¨¨aÑ0Ô0°Ô3€HݘDÕ!4Õ5HÕK[Ñ5[Ð![Ô\Ñ]Ô]€OØ�Y ¨/Ð9Ð9r"rrc

ó(—|d
›d|d›�S)Nrú
:r
r.©
rs
 r/Ú	_fmt_addrrs´s€Ø�1ŒgÐ!Ð!˜˜QœÐ!Ð!Ð!r"Úrawc

ó—| d
¦
«
}
|
dkr
|d|
…}	| 
dd¬¦« ¦«S#t$r
YdSwxYw
)zMDecode the 32-byte null-padded UTF-8 display-name field. Tolerant of garbage.rrNrFÚreplace©
ÚerrorsÚ)ÚfindÚdecodeÚstripÚ	Exception)rtÚends  r/Ú_decode_lobby_namer¸sr€à

�(Š(�7Ñ
Ô
€CØ
ˆa‚x€xØ�$�3�$ŒiˆðØ�zŠz˜'¨)ˆzÑ4Ô4×:Ò:Ñ<Ô<Ð<øÝð
ð
ð
؈rˆrð
øøøs§(AÁ
AÁ
AÚnamec

óˆ—|p
d
 dd¬¦«dt…}
|
dtt|
¦
«
z
zzS)z9Encode a display name into LOBBY_NAME_BYTES, null-padded.ryrFrvrwNr)ÚencodeÚLOBBY_NAME_BYTESra)r€Úencodeds  r/Ú_encode_lobby_namer…ÃsF€àˆz�r×!Ò! '°)Ð!Ñ<Ô<Ð=NÕ>NÐ=NÔO€GØ�WÕ 0µ3°w±<´<Ñ ?Ñ@Ñ@Ð@r"c
ó¦—eZ
dZd
Z	d.d/d„Zd0d„Zd1d„Zd2d„Zd3d„Zd4d„Z	d5d„Z
d6d „Zd7d!„Zd8d"„Z
d9d#„Zd:d$„Zd;d'„Zd6d(„Zd8d)„Zd8d*„Zd6d+„Zd6d,„Zd-S)<ÚRelayzCDispatcher that owns both the v1 pair state and the v2 lobby state.FÚsockú
socket.socketÚlogrBÚmax_clientsrÚrequire_addr_checkr c
óÌ—|
|_||_
||_||_g|_i|_d
|_d|_t¦«|_	tj¦«|_dS)NFr%)
rˆrŠr‹rŒÚv1_peersÚ
v2_clientsÚv2_roster_dirtyÚv2_last_roster_broadcastr5ÚstatsÚtimeÚ	monotonicÚlast_stats_log)ÚselfrˆrŠr‹rŒs     r/Ú__init__zRelay.__init__Ìsa€àˆŒ	؈ŒØ&ˆÔð
#5ˆÔà(*ˆŒ
à8:ˆŒØ$ˆÔØ(+ˆÔ%å‘\”\ˆŒ
Ý"œnÑ.Ô.ˆÔÐÐr"r$r#rAc
óŽ—t
t¦
«
}t|d
d…<t|d<t|d<t|¦
«
|
zS)u²A v1-framed AddrCheck: 12-byte RemSound header + the cookie. v1 framing on purpose —
        every client (v1 pair or v2 lobby) parses it, and the echo comes back the same way.rrr)Ú	bytearrayrbÚMAGICÚ
V1_VERSIONÚTYPE_ADDR_CHECKr#)r–r$Úheaders   r/Ú_addr_check_packetzRelay._addr_check_packetâsA€õ�=Ñ)Ô)ˆÝˆˆq�ˆs‰Ýˆˆq‰	Ý#ˆˆq‰	Ý�V‰}Œ}˜vÑ%Ð%r"rrÚnowrÚNonec
ó€
—|
js||
j
z
tkrd
S|
jst	jt¦
«
|
_||
_
	|j | 	|
j¦
«
|¦«
d
S#t$r4}|j dt|¦
«
|¦«
Yd
}~d
Sd
}~w
wxYw
)zŒIssue (or re-issue) the cookie challenge for an entry. Throttled; keeps the same cookie
        until verified so a slow echo still matches.Nz)event=addr_check_send_failed to=%s err=%s)r!r&ÚADDR_CHECK_RESEND_SECONDSr$ÚosÚurandomÚADDR_CHECK_COOKIE_LENrˆÚsendtoržrRrŠÚwarningrs)r–ÚentryrrŸrYs     r/Ú_send_addr_checkzRelay._send_addr_checkësÖ€ðŒ>ð
	˜c EÔ$5Ñ5Õ9RÒRÐRØˆFØŒ|ð
	=Ýœ:Õ&;Ñ<Ô<ˆEŒL؈Ôð	^
ØŒI×Ò˜T×4Ò4°U´\ÑBÔBÀDÑIÔIÐIÐIÐIøÝð
	^
ð
	^
ð
	^
ØŒH×ÒÐHÍ)ÐTXÉ/Ì/Ð[\Ñ]Ô]Ð]Ð]Ð]Ð]Ð]Ð]Ð]øøøøð
	^
øøøsÁ
3A?Á?
B=Â	)B8Â8B=r\Ú
header_lenc
óð—|||tz…}|
j
rX||
j
krO|
jsJd
|
_|jx
jdz
c_|j dt|¦
«
¦«
dSdSdSdS)u´An AddrCheck came back from a registered endpoint — verify its cookie. The echo may
        arrive v1-framed (as sent) even from a v2 client, so callers pass their header length.Tr
zevent=addr_verified addr=%sN)r¥r$r!r’r<rŠÚinfors)r–r¨r\rrªr$s      r/Ú_try_verifyzRelay._try_verifyøs�€ð�j Õ.CÑ!CÐCÔDˆØŒ<ð	J
˜F e¤lÒ2Ð2¸5¼>Ð2Ø!ˆEŒNØŒJÐ+Ô+¨qÑ0Ð+Ô+ØŒH�MŠMÐ7½À4¹¼ÑIÔIÐIÐIÐIð	J
ð	J
Ð2Ð2Ð2Ð2r"Úipr2c
óć
—t
ˆ
f
d
„|j
D¦«¦
«
}|t
ˆ
f
d„|j ¦«D¦«¦
«
z
}|tkS)zMTrue when this source IP already holds MAX_ENTRIES_PER_IP lobby/pair entries.c
3
ó>•
K
—|]}
|
jd‰k¯d
V—

ŒdS©rr
Nrr)Ú.0Ú
pr®s  €r/ú	<genexpr>z#Relay._ip_at_cap.<locals>.<genexpr>
s-øèè€Ð@Ð@˜!°
´°q´	¸R²°�A°°°°Ð@Ð@r"c
3
ó>•
K
—|]}
|
jd‰k¯d
V—

ŒdSr±rr)r²rYr®s  €r/r´z#Relay._ip_at_cap.<locals>.<genexpr>
s-øèè€ÐLÐL˜1¸A¼FÀ1¼IȺO¸O�Q¸O¸O¸O¸OÐLÐLr")ÚsumrŽr�ÚvaluesÚMAX_ENTRIES_PER_IP)r–r®Úcounts ` r/Ú
_ip_at_capzRelay._ip_at_cap

shø€åÐ@Ð@Ð@Ð@˜tœ}Ð@Ñ@Ô@Ñ@Ô@ˆØ
•ÐLÐLÐLÐL ¤× 6Ò 6Ñ 8Ô 8ÐLÑLÔLÑLÔLÑLˆØÕ*Ò*Ð*r"Úprotoc
óö—|
jrd
S|j
r|jx
jdz
c_dS|jx
jdz
c_|
js5d
|
_|j d|t|
j	¦
«
¦«
d
S)z±The enforcement point: may forwarded traffic be delivered to this entry's address?
        Watch-only mode always says yes but logs (once per entry) who WOULD have been blocked.Tr
Fz^event=would_block_unverified proto=%s addr=%s (watch-only; enforcement would withhold traffic))
r!rŒr’r=r>r'rŠr¬rsr)r–r¨r»s   r/Ú_may_forward_tozRelay._may_forward_to
s“€ðŒ>ð
	Ø�4ØÔ"ð	ØŒJÐ)Ô)¨QÑ.Ð)Ô)Ø�5ØŒ
Ð)Ô)¨QÑ.Ð)Ô)ØÔ'ð	Ø'+ˆEÔ$ØŒH�MŠMØpØ•y ¤Ñ,Ô,ñ
ô
ð
ðˆtr"ú
Optional[int]c
óX—t
|j
¦
«
D]\}}|j|
kr|c
SŒdS)
N)Ú	enumeraterŽr)r–rÚ
ir³s    r/Ú
_v1_find_slotzRelay._v1_find_slot
s=€Ý˜dœmÑ,Ô,ð	ð	‰DˆAˆqØŒv˜Š~ˆ~Ø���ðàˆtr"c
óz
—|jsdSg}g}|jD]E}|
|j
z
tk
r| |¦
«

Œ+| |j¦
«

ŒF|r\||_|D]T}|j d
t|¦
«
t|j¦
«
¦«
|j	x
j
dz
c_
ŒSdSdS)Nz3event=peer_dropped reason=idle addr=%s remaining=%dr
)rŽrÚIDLE_TIMEOUT_SECONDSÚappendrrŠr¬rsrar’r:)r–rŸÚkeptÚdroppedr³rs      r/Ú_v1_expire_idlezRelay._v1_expire_idle 
sä€ØŒ}ð
	ØˆFØ!ˆØ)+ˆØ”ð	'ð	'ˆAØ�a”kÑ!Õ&:Ò:Ð:Ø—’˜A‘”��à—’˜qœvÑ&Ô&Ð&Ð&Øð	-Ø ˆDŒMØð
-ð
-�Ø”—
’
ØIݘd‘O”O¥S¨¬Ñ%7Ô%7ñôðð”
Ð'Ô'¨1Ñ,Ð'Ô'Ð'ð	-ð	-ð
-ð
-r"c
ó²—t
|j
¦
«
d
krþ|j
 t|
|¬¦«¦
«

|j dt
|
¦
«
t
|j
¦
«
¦«
|jx
jdz
c_t
|j
¦
«
d
krV|j dt
|j
dj	¦
«
t
|j
dj	¦
«
¦«
t
|j
¦
«
dz
S|j
dj
|j
dj
k
rdn
d}||j
|j
z
tkrx|j
|j	}t|
|¬¦«|j
|<|j dt
|¦
«
t
|
¦
«
¦«
|jx
jdz
c_|SdS)	Nr)rrz)event=peer_joined addr=%s slots_filled=%dr
zevent=peer_paired a=%s b=%srz!event=peer_replaced old=%s new=%séÿÿÿÿ)rarŽrÅrrŠr¬rsr’r:rrrÄ)r–rrŸÚoldestÚold_addrs     r/Ú_v1_admit_or_replacezRelay._v1_admit_or_replace3
s®
€ÝˆtŒ}ÑÔ 
Ò!Ð!ØŒM× Ò ¥¨t¸sÐ!CÑ!CÔ!CÑDÔDÐDØŒH�MŠMØ;ݘ$‘”¥ T¤]Ñ!3Ô!3ñ
ô
ð
ð
ŒJÐ#Ô# qÑ(Ð#Ô#Ý�4”=Ñ!Ô! QÒ&Ð&Ø”—
’
Ø1ݘdœm¨AÔ.Ô3Ñ4Ô4ݘdœm¨AÔ.Ô3Ñ4Ô4ñôðõ
�t”}Ñ%Ô%¨
Ñ)Ð)Ø”m AÔ&Ô0°D´MÀ!Ô4DÔ4NÒNÐN��ÐTUˆØ�$”- Ô'Ô1Ñ1Õ5IÒIÐIØ”} VÔ,Ô1ˆHÝ$,°$À#Ð$FÑ$FÔ$FˆDŒM˜&Ñ!ØŒH�MŠMØ3ݘ(Ñ#Ô#¥Y¨t¡_¤_ñ
ô
ð
ð
ŒJÐ#Ô# qÑ(Ð#Ô#؈M؈rr"c
ó—t
|
¦
«
}|€|j
x
jd
z
c_dS|d}tj¦«}|t
krˆ|j ¦«D]-}|j|kr | 	||
|t¦«

dSŒ.| |¦
«
}|�(| 	|j||
|t¦«
dS| |¦
«
}|€z| 
|d¦
«
r|j
x
jd
z
c_dS| |¦
«

| ||¦«}|dkr|j
x
jd
z
c_dS|j|}	||	_|	x
jd
z
c_| |	||¦«
t+|j¦
«
dkr¶|jd
|z
}
| |
d¦«sdS	|j |
|
j¦«
|
x
jd
z
c_|j
x
jd
z
c_dS#t6$r9}|j dt=|
j¦
«
|¦«
Yd}~dSd}~w
wxYw
|j
x
jd
z
c_dS)Nr
rrÚv1z'event=send_failed proto=v1 to=%s err=%s)rhr’r9r“r”rœr�r·rr­rbrÂrŽrºr?rÈrÍr7rrr©rar½rˆr¦rr6rRrŠr§rs)r–r\rÚparsedrerŸrYÚfoundÚidxÚpeerÚothers           r/Ú
_handle_v1zRelay._handle_v1N
sÌ€Ý  Ñ&Ô&ˆØˆ>ØŒJÐ*Ô*¨aÑ/Ð*Ô*ØˆFؘ!”9ˆÝŒnÑԈؕÒ&Ð&ð”_×+Ò+Ñ-Ô-ð
ð
�
Ø”6˜T’>�>Ø×$Ò$ Q¨¨dµMÑBÔBÐBØ�F�Fð"ð×&Ò& tÑ,Ô,ˆEØÐ Ø× Ò  ¤¨uÔ!5°t¸TÅ=ÑQÔQÐQØˆFØ× Ò  Ñ&Ô&ˆØˆ;Ø�Š˜t AœwÑ'Ô'ð
Ø”
Ð*Ô*¨aÑ/Ð*Ô*Ø�Ø× Ò  Ñ%Ô%Ð%Ø×+Ò+¨D°#Ñ6Ô6ˆCØ�QŠwˆwØ”
Ð+Ô+¨qÑ0Ð+Ô+Ø�ØŒ}˜SÔ!ˆØˆŒØˆŒ˜1шŒØ×Ò˜d D¨#Ñ.Ô.Ð.݈tŒ}ÑÔ Ò"Ð"Ø”M ! c¡'Ô*ˆEØ×'Ò'¨¨tÑ4Ô4ð

Ø�ð
Ø”	× Ò   u¤zÑ2Ô2Ð2ØÐ Ô  AÑ%Ð Ô Ø”
Ð$Ô$¨
Ñ)Ð$Ô$Ð$Ð$øÝð
ð
ð
Ø”× Ò Ø=ݘeœjÑ)Ô)¨1ñôðððððððøøøøð
øøøð
ŒJÐ'Ô'¨1Ñ,Ð'Ô'Ð'Ð'sÇ$AH+È+
I.È5.I)É)I.c

óŽ—t
t¦
«
}
t|
d
d…<t|
d<t|
d<tjd|
dd
¦«
tjd|
dd
¦«
t|
tttz…<t
¦«}t|j ¦«¦
«
dd	…}| 
t|¦
«
¦
«

|D]F\}}| |j¦
«

| t#|j¦
«
¦
«

ŒGt!|
¦
«
t!|¦
«
zS)
z7Build a LobbyRoster packet with the current membership.rrrr_rr`rNéÿ)r™rkršÚ
V2_VERSIONÚTYPE_LOBBY_ROSTERrcÚ	pack_intoÚSERVER_CLIENT_ID_BYTESrlrmÚlistr�ÚitemsrÅraÚextendr#r…r3)r–r�ÚpayloadÚmembersÚcidr¨s      r/Ú_v2_build_roster_packetzRelay._v2_build_roster_packet�
s
€õ�=Ñ)Ô)ˆÝˆˆq�ˆs‰Ýˆˆq‰	Ý%ˆˆq‰	ÝÔ˜˜v q¨!Ñ,Ô,Ð,ÝÔ˜˜v q¨!Ñ,Ô,Ð,ÝMcˆÕ"Õ#6Õ9IÑ#IÐIÑJÝ‘+”+ˆÝ�t”×,Ò,Ñ.Ô.Ñ/Ô/°°°Ô5ˆØ�Š•s˜7‘|”|Ñ$Ô$Ð$Ø!ð	C
ð	C
‰JˆC�Ø�NŠN˜3œ9Ñ%Ô%Ð%Ø�NŠNÕ-¨eÔ.@ÑAÔAÑBÔBÐBÐBÝ�V‰}Œ}�u W™~œ~Ñ-Ð-r"c

óÞ
—|js!d
|_
tj¦«|_dS| ¦«}
|j ¦«D]w}|jr|js
Œ	|j	 
|
|j¦«
Œ3#t$r8}|j
 dt|j¦
«
|¦«
Yd}~Œpd}~w
wxYw
d
|_
tj¦«|_dS)NFz5event=send_failed proto=v2 reason=roster to=%s err=%s)r�r�r“r”r‘râr·rŒr!rˆr¦rrRrŠr§rs)r–Úpacketr¨rYs    r/Ú_v2_broadcast_rosterzRelay._v2_broadcast_roster“
s
€ØŒð	Ø#(ˆDÔ Ý,0¬NÑ,<Ô,<ˆDÔ)ØˆFØ×-Ò-Ñ/Ô/ˆØ”_×+Ò+Ñ-Ô-ð	ð	ˆEðÔ&ð

¨u¬~ð

Øð
Ø”	× Ò  ¨¬Ñ4Ô4Ð4Ð4øÝð
ð
ð
Ø”× Ò ØKݘeœjÑ)Ô)¨1ñôððððððøøøøð
øøøð
 %ˆÔÝ(,¬Ñ(8Ô(8ˆÔ%Ð%Ð%sÁ( B	Â	
CÂ.CÃCÚattempted_client_idú	uuid.UUIDc
óê—t
t¦
«
}t|d
d…<t|d<t|d<tjd|dd
¦«
tjd|dd
¦«
t|tttz…<tt|j¦
«
dz
|j
dz
g¦
«
}	|j t|¦
«
|z|¦«
n@#t $r3}|j d	t'|¦
«
|¦«
Yd
}~nd
}~w
wxYw
|j d|
t'|¦
«
t|j¦
«
|j
¦«
|jx
jdz
c_d
S)
z>Send a LobbyFull packet back to an over-cap client and log it.rrrr_rr`rr×z9event=send_failed proto=v2 reason=lobby_full to=%s err=%sNz?event=lobby_full attempted_client_id=%s addr=%s count=%d max=%dr
)r™rkršrØÚTYPE_LOBBY_FULLrcrÚrÛrlrmr#rar�r‹rˆr¦rRrŠr§rsr¬r’r8)r–rærr�rßrYs      r/Ú_v2_send_lobby_fullzRelay._v2_send_lobby_full¨
s
€å�=Ñ)Ô)ˆÝˆˆq�ˆs‰Ýˆˆq‰	Ý#ˆˆq‰	ÝÔ˜˜v q¨!Ñ,Ô,Ð,ÝÔ˜˜v q¨!Ñ,Ô,Ð,ÝMcˆÕ"Õ#6Õ9IÑ#IÐIÑJå�˜Tœ_Ñ-Ô-°Ñ4°dÔ6FÈÑ6MÐNÑOÔOˆð	ØŒI×Ò�U 6™]œ]¨WÑ4°dÑ;Ô;Ð;Ð;øÝð	ð	ð	ØŒH×ÒØKݘ$‘” ñ
ô
ð
ð
ð
ð
ð
ð
øøøøð	øøøð
	
Œ�
Š
ØMØ¥¨4¡¤Ý�”Ñ Ô  $Ô"2ñ	
ô	
ð	
ð
	
Œ
Ð%Ô%¨Ñ*Ð%Ô%Ð%Ð%sÂ0+CÃ
DÃ&)DÄDc
ó|
—|jsdSg}|j 
¦«D]-\}}|
|jz
tkr| |¦
«

Œ.|D]f}|j |¦
«
}|j d
|t|j	¦
«
¦«
|j
x
jdz
c_d|_ŒgdS)Nz.event=client_idle_expired client_id=%s addr=%sr
T)
r�rÝrrÄrÅÚpoprŠr¬rsrr’r;r�)r–rŸÚexpiredrár¨s     r/Ú_v2_expire_idlezRelay._v2_expire_idleÁ
s؀،ð
	ØˆFØ#%ˆØœ/×/Ò/Ñ1Ô1ð	$ð	$‰JˆC�Ø�e”oÑ%Õ)=Ò=Ð=Ø—’˜sÑ#Ô#Ð#øØð	(ð	(ˆCØ”O×'Ò'¨Ñ,Ô,ˆEØŒH�MŠMØ@Ø•Y˜uœzÑ*Ô*ñ
ô
ð
ð
ŒJÐ$Ô$¨
Ñ)Ð$Ô$Ø#'ˆDÔ Ð ð	(ð	(r"c
óð—t
|
¦
«
}|€|j
x
jd
z
c_dS|\}}}}	tj|¬¦
«
}n&#t
$r
|j
x
jd
z
c_YdSwxYw
t
j¦«}	|j 	|¦
«
}
|
du
o
|
j
|k}|
�
€| |d¦
«
r@|j
x
jd
z
c_|j
 d|t|¦
«
¦«
dSt!|j¦
«
|jkr| ||¦«
dSt'|d|	¬¦«}
|
|j|<|j
 d|t|¦
«
t!|j¦
«
¦«
|j
x
jd
z
c_d|_nq|
j
|kr_|j
 d	|t|
j
¦
«
t|¦
«
¦«
||
_
d
|
_d|
_d|
_d
|
_|	|
_|
x
jd
z
c_|t:krHt!|
¦
«
t<t>zkrt<nt@}| !|
|
||¦«
dS| "|
||	¦«
|tFkrb|
t<t<tHz…}
tK|
¦
«
}||
j&kr*||
_&|j
 d
||¦«
d|_dS|tNkr�|s+|j
 d|t|¦
«
¦«
dS|j (|d¦«
|j
 d|t|¦
«
¦«
|j
x
jd
z