oci/zeronet
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

FileRequest -> Remove Unnecessary check

Browse source
This commit is contained in:
canewsin 2023-03-24 02:23:16 +05:30
parent f2ef6e5d9c
commit d8e52eaabd
1 changed files with 10 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/File/FileRequest.py
View file

@ -165,21 +165,19 @@ class FileRequest(object):
site.onFileDone(inner_path) # Trigger filedone site.onFileDone(inner_path) # Trigger filedone
if inner_path.endswith("content.json"): # Download every changed file from peer # Download every changed file from peer
peer = site.addPeer(self.connection.ip, self.connection.port, return_peer=True, source="update") # Add or get peer peer = site.addPeer(self.connection.ip, self.connection.port, return_peer=True, source="update") # Add or get peer
# On complete publish to other peers # On complete publish to other peers
diffs = params.get("diffs", {}) diffs = params.get("diffs", {})
site.onComplete.once(lambda: site.publish(inner_path=inner_path, diffs=diffs, limit=6), "publish_%s" % inner_path) site.onComplete.once(lambda: site.publish(inner_path=inner_path, diffs=diffs, limit=6), "publish_%s" % inner_path)
# Load new content file and download changed files in new thread # Load new content file and download changed files in new thread
def downloader(): def downloader():
site.downloadContent(inner_path, peer=peer, diffs=params.get("diffs", {})) site.downloadContent(inner_path, peer=peer, diffs=params.get("diffs", {}))
del self.server.files_parsing[file_uri]
gevent.spawn(downloader)
else:
del self.server.files_parsing[file_uri] del self.server.files_parsing[file_uri]
gevent.spawn(downloader)
self.response({"ok": "Thanks, file %s updated!" % inner_path}) self.response({"ok": "Thanks, file %s updated!" % inner_path})
self.connection.goodAction() self.connection.goodAction()