Rev2192, Fix incorrect site detection when using async commands with Cors or MergerSite plugin
This commit is contained in:
parent
94cd5d32e5
commit
d3d7489232
3 changed files with 16 additions and 15 deletions
|
@ -1,5 +1,6 @@
|
||||||
import re
|
import re
|
||||||
import cgi
|
import cgi
|
||||||
|
import copy
|
||||||
|
|
||||||
from Plugin import PluginManager
|
from Plugin import PluginManager
|
||||||
from Translate import Translate
|
from Translate import Translate
|
||||||
|
@ -25,18 +26,17 @@ def getCorsPath(site, inner_path):
|
||||||
class UiWebsocketPlugin(object):
|
class UiWebsocketPlugin(object):
|
||||||
# Add cors support for file commands
|
# Add cors support for file commands
|
||||||
def corsFuncWrapper(self, func_name, to, inner_path, *args, **kwargs):
|
def corsFuncWrapper(self, func_name, to, inner_path, *args, **kwargs):
|
||||||
func = getattr(super(UiWebsocketPlugin, self), func_name)
|
|
||||||
if inner_path.startswith("cors-"):
|
if inner_path.startswith("cors-"):
|
||||||
cors_address, cors_inner_path = getCorsPath(self.site, inner_path)
|
cors_address, cors_inner_path = getCorsPath(self.site, inner_path)
|
||||||
|
|
||||||
site_before = self.site # Save to be able to change it back after we ran the command
|
req_self = copy.copy(self)
|
||||||
self.site = self.server.sites.get(cors_address) # Change the site to the merged one
|
req_self.site = self.server.sites.get(cors_address) # Change the site to the merged one
|
||||||
try:
|
|
||||||
back = func(to, cors_inner_path, *args, **kwargs)
|
func = getattr(super(UiWebsocketPlugin, req_self), func_name)
|
||||||
finally:
|
back = func(to, cors_inner_path, *args, **kwargs)
|
||||||
self.site = site_before # Change back to original site
|
|
||||||
return back
|
return back
|
||||||
else:
|
else:
|
||||||
|
func = getattr(super(UiWebsocketPlugin, self), func_name)
|
||||||
return func(to, inner_path, *args, **kwargs)
|
return func(to, inner_path, *args, **kwargs)
|
||||||
|
|
||||||
def actionFileGet(self, to, inner_path, *args, **kwargs):
|
def actionFileGet(self, to, inner_path, *args, **kwargs):
|
||||||
|
|
|
@ -1,5 +1,6 @@
|
||||||
import re
|
import re
|
||||||
import time
|
import time
|
||||||
|
import copy
|
||||||
|
|
||||||
from Plugin import PluginManager
|
from Plugin import PluginManager
|
||||||
from Translate import Translate
|
from Translate import Translate
|
||||||
|
@ -122,7 +123,6 @@ class UiWebsocketPlugin(object):
|
||||||
|
|
||||||
# Add support merger sites for file commands
|
# Add support merger sites for file commands
|
||||||
def mergerFuncWrapper(self, func_name, to, inner_path, *args, **kwargs):
|
def mergerFuncWrapper(self, func_name, to, inner_path, *args, **kwargs):
|
||||||
func = getattr(super(UiWebsocketPlugin, self), func_name)
|
|
||||||
if inner_path.startswith("merged-"):
|
if inner_path.startswith("merged-"):
|
||||||
merged_address, merged_inner_path = checkMergerPath(self.site.address, inner_path)
|
merged_address, merged_inner_path = checkMergerPath(self.site.address, inner_path)
|
||||||
|
|
||||||
|
@ -131,14 +131,15 @@ class UiWebsocketPlugin(object):
|
||||||
if merger_cert and self.user.getSiteData(merged_address).get("cert") != merger_cert:
|
if merger_cert and self.user.getSiteData(merged_address).get("cert") != merger_cert:
|
||||||
self.user.setCert(merged_address, merger_cert)
|
self.user.setCert(merged_address, merger_cert)
|
||||||
|
|
||||||
site_before = self.site # Save to be able to change it back after we ran the command
|
req_self = copy.copy(self)
|
||||||
self.site = self.server.sites.get(merged_address) # Change the site to the merged one
|
req_self.site = self.server.sites.get(merged_address) # Change the site to the merged one
|
||||||
try:
|
|
||||||
back = func(to, merged_inner_path, *args, **kwargs)
|
func = getattr(super(UiWebsocketPlugin, req_self), func_name)
|
||||||
finally:
|
back = func(to, merged_inner_path, *args, **kwargs)
|
||||||
self.site = site_before # Change back to original site
|
|
||||||
return back
|
return back
|
||||||
else:
|
else:
|
||||||
|
func = getattr(super(UiWebsocketPlugin, self), func_name)
|
||||||
return func(to, inner_path, *args, **kwargs)
|
return func(to, inner_path, *args, **kwargs)
|
||||||
|
|
||||||
def actionFileList(self, to, inner_path, *args, **kwargs):
|
def actionFileList(self, to, inner_path, *args, **kwargs):
|
||||||
|
|
|
@ -10,7 +10,7 @@ class Config(object):
|
||||||
|
|
||||||
def __init__(self, argv):
|
def __init__(self, argv):
|
||||||
self.version = "0.5.7"
|
self.version = "0.5.7"
|
||||||
self.rev = 2190
|
self.rev = 2192
|
||||||
self.argv = argv
|
self.argv = argv
|
||||||
self.action = None
|
self.action = None
|
||||||
self.config_file = "zeronet.conf"
|
self.config_file = "zeronet.conf"
|
||||||
|
|
Loading…
Reference in a new issue