1919from typing import Awaitable , Callable , List , NamedTuple
2020from urllib .parse import ParseResult
2121
22- from murfey .client .tui .status_bar import StatusBar
2322from murfey .util .client import Observer
2423
2524logger = logging .getLogger ("murfey.client.rsync" )
@@ -59,7 +58,6 @@ def __init__(
5958 server_url : ParseResult ,
6059 stop_callback : Callable = lambda * args , ** kwargs : None ,
6160 local : bool = False ,
62- status_bar : StatusBar | None = None ,
6361 do_transfer : bool = True ,
6462 remove_files : bool = False ,
6563 required_substrings_for_removal : List [str ] = [],
@@ -107,7 +105,6 @@ def __init__(
107105 )
108106 self ._stopping = False
109107 self ._halt_thread = False
110- self ._statusbar = status_bar
111108
112109 def __repr__ (self ) -> str :
113110 return f"<RSyncer ({ self ._basepath } → { self ._remote } ) [{ self .status } ]"
@@ -116,15 +113,12 @@ def __repr__(self) -> str:
116113 def from_rsyncer (cls , rsyncer : RSyncer , ** kwargs ):
117114 kwarguments_from_rsyncer = {
118115 "local" : rsyncer ._local ,
119- "status_bar" : rsyncer ._statusbar ,
120116 "do_transfer" : rsyncer ._do_transfer ,
121117 "remove_files" : rsyncer ._remove_files ,
122118 "notify" : rsyncer ._notify ,
123119 }
124120 kwarguments_from_rsyncer .update (kwargs )
125121 assert isinstance (kwarguments_from_rsyncer ["local" ], bool )
126- if kwarguments_from_rsyncer ["status_bar" ] is not None :
127- assert isinstance (kwarguments_from_rsyncer ["status_bar" ], StatusBar )
128122 assert isinstance (kwarguments_from_rsyncer ["do_transfer" ], bool )
129123 assert isinstance (kwarguments_from_rsyncer ["remove_files" ], bool )
130124 assert isinstance (kwarguments_from_rsyncer ["notify" ], bool )
@@ -134,7 +128,6 @@ def from_rsyncer(cls, rsyncer: RSyncer, **kwargs):
134128 rsyncer ._rsync_module ,
135129 rsyncer ._server_url ,
136130 local = kwarguments_from_rsyncer ["local" ],
137- status_bar = kwarguments_from_rsyncer ["status_bar" ],
138131 do_transfer = kwarguments_from_rsyncer ["do_transfer" ],
139132 remove_files = kwarguments_from_rsyncer ["remove_files" ],
140133 notify = kwarguments_from_rsyncer ["notify" ],
@@ -398,12 +391,6 @@ def parse_stdout(line: str):
398391 return
399392
400393 self ._files_transferred += 1
401- if self ._statusbar :
402- with self ._statusbar .lock :
403- self ._statusbar .transferred = [
404- self ._statusbar .transferred [0 ] + 1 ,
405- self ._statusbar .transferred [1 ],
406- ]
407394 current_outstanding = self .queue .unfinished_tasks - (
408395 self ._files_transferred - previously_transferred
409396 )
0 commit comments