Mirror/markqvist___Reticulum
1
0
Fork 0
mirror of https://github.com/markqvist/Reticulum.git synced 2026-04-27 22:25:37 +00:00
Code Issues Projects Releases Packages Wiki Activity

Added outbound transfer progress to git helper

Browse source
This commit is contained in:
Mark Qvist 2026-04-25 19:31:11 +02:00
commit de1000bfda
1 changed files with 12 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

17
RNS/Utilities/rngit/client.py
View file

@ -216,10 +216,16 @@ class ReticulumGitClient():
RNS.log(f"Link was closed", RNS.LOG_DEBUG) RNS.log(f"Link was closed", RNS.LOG_DEBUG)
if not self.link_ready: self.link_failed = True if not self.link_ready: self.link_failed = True
def _on_progress(self, request_receipt): def _on_progress(self, transfer_instance):
self.response_progress = request_receipt.progress if hasattr(transfer_instance, "progress"):
self.response_size = request_receipt.response_size self.response_progress = transfer_instance.progress
self.response_transfer_size = request_receipt.response_transfer_size self.response_size = transfer_instance.response_size
self.response_transfer_size = transfer_instance.response_transfer_size
elif hasattr(transfer_instance, "get_progress") and callable(transfer_instance.get_progress):
self.response_progress = transfer_instance.get_progress()
self.response_size = transfer_instance.total_size
self.response_transfer_size = transfer_instance.size
now = time.time() now = time.time()
if self.progress_updated_at == None: self.progress_updated_at = now if self.progress_updated_at == None: self.progress_updated_at = now
@ -270,7 +276,8 @@ class ReticulumGitClient():
self.response_metadata = None self.response_metadata = None
RNS.log(f"Sending request: {path}", RNS.LOG_DEBUG) RNS.log(f"Sending request: {path}", RNS.LOG_DEBUG)
self.link.request(path, data, progress_callback=self._on_progress, response_callback=self._response_ready, failed_callback=self._response_failed, timeout=timeout) request_receipt = self.link.request(path, data, progress_callback=self._on_progress, response_callback=self._response_ready, failed_callback=self._response_failed, timeout=timeout)
if request_receipt.resource: request_receipt.resource.progress_callback(self._on_progress)
self.request_event.wait(timeout=timeout) self.request_event.wait(timeout=timeout)
if self.request_response is None: self.abort("Request failed or timed out") if self.request_response is None: self.abort("Request failed or timed out")