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

Notify merger site on changes as the original site

Browse source
This commit is contained in:
shortcutme 2016-08-16 19:58:16 +02:00
parent d39b8570cc
commit 67da76427b
1 changed files with 5 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
plugins/MergerSite/MergerSitePlugin.py
View file

@ -241,24 +241,21 @@ class SitePlugin(object):
def fileDone(self, inner_path): def fileDone(self, inner_path):
super(SitePlugin, self).fileDone(inner_path) super(SitePlugin, self).fileDone(inner_path)
merged_type = merged_db.get(self.address)
virtual_path = "merged-%s/%s/%s" % (merged_type, self.address, inner_path)
for merger_site in merged_to_merger.get(self.address, []): for merger_site in merged_to_merger.get(self.address, []):
if merger_site.address == self.address: if merger_site.address == self.address:
continue continue
merger_site.fileDone(virtual_path) for ws in merger_site.websockets:
ws.event("siteChanged", self, {"event": ["file_done", inner_path]})
def fileFailed(self, inner_path): def fileFailed(self, inner_path):
super(SitePlugin, self).fileFailed(inner_path) super(SitePlugin, self).fileFailed(inner_path)
merged_type = merged_db.get(self.address)
virtual_path = "merged-%s/%s/%s" % (merged_type, self.address, inner_path)
for merger_site in merged_to_merger.get(self.address, []): for merger_site in merged_to_merger.get(self.address, []):
if merger_site.address == self.address: if merger_site.address == self.address:
continue continue
merger_site.fileFailed(virtual_path) for ws in merger_site.websockets:
ws.event("siteChanged", self, {"event": ["file_failed", inner_path]})
@PluginManager.registerTo("SiteManager") @PluginManager.registerTo("SiteManager")