Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Revert "Dev/add cache" #30

Merged
merged 1 commit into from
Mar 9, 2021
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 0 additions & 3 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,11 +24,8 @@

REQUIREMENTS = [
"fs>2.0",
"webdavclient2",
"cachetools"
"webdavclient3",
"python-dateutil"

]

setup(
Expand Down
63 changes: 13 additions & 50 deletions webdavfs/webdavfs.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@
from fs.iotools import line_iterator
from fs.mode import Mode
from fs.path import dirname
from cachetools import TTLCache


log = logging.getLogger(__name__)
Expand Down Expand Up @@ -157,8 +156,7 @@ class WebDAVFS(FS):
'virtual': False,
}

def __init__(self, url, login=None, password=None, root=None,
cache_maxsize=10000, cache_ttl=60):
def __init__(self, url, login=None, password=None, root=None):
self.url = url
self.root = root
super(WebDAVFS, self).__init__()
Expand All @@ -169,8 +167,6 @@ def __init__(self, url, login=None, password=None, root=None,
'webdav_password': password,
'root': self.root
}
self.info_cache = TTLCache(maxsize=cache_maxsize,
ttl=cache_ttl)
self.client = wc.Client(options)

def _create_resource(self, path):
Expand All @@ -186,8 +182,7 @@ def _create_info_dict(info):
info_dict = {
'basic': {"is_dir": False},
'details': {'type': int(ResourceType.file)},
'access': {},
'other': {}
'access': {}
}

if six.PY2:
Expand Down Expand Up @@ -235,8 +230,9 @@ def exists(self, path):

def getinfo(self, path, namespaces=None):
_path = self.validatepath(path)
namespaces = namespaces or ()

if _path in '/':
<<<<<<< Updated upstream
info_dict = {
"basic": {
"name": "",
Expand All @@ -261,51 +257,18 @@ def getinfo(self, path, namespaces=None):
raise errors.ResourceNotFound(path, exc=exc)

return Info(info_dict)
=======
self.info_cache.clear()
try:
_path = self.validatepath(path)
namespaces = namespaces or ()
urn =wu.Urn(_path.encode('utf-8'))
path = self.client.get_full_path(urn);
if path in self.info_cache:
info = self.info_cache[path]
response = None
else:
response = self.client.execute_request(action='info',
path=urn.quote())
info = wc.WebDavXmlUtils.parse_info_response(content=response.content, path=path, hostname=self.client.webdav.hostname)
if info['name'] is None:
info['name'] = _path.split("/")[-1]
if wc.WebDavXmlUtils.parse_is_dir_response(content=response.content, path=path, hostname=self.client.webdav.hostname):
info['isdir'] = True
info['files'] = []
for i in wc.WebDavXmlUtils.parse_get_list_info_response(response.content):
if i['path'].rstrip('/') != path.rstrip('/'):
self.info_cache[i['path']] = i
filename = wu.Urn(i['path'], i['isdir']).filename()
if six.PY2:
filename = filename.decode('utf-8')
filename = filename.rstrip('/')
info['files'].append(filename)
self.info_cache[path] = info
info_dict = self._create_info_dict(info)
if info.get('isdir', False):
info_dict['basic']['is_dir'] = True
info_dict['details']['type'] = ResourceType.directory
except we.RemoteResourceNotFound as exc:
raise errors.ResourceNotFound(path, exc=exc)
retval = Info(info_dict)
return retval
>>>>>>> Stashed changes

def listdir(self, path):
info = self.getinfo(path)
if not info.is_dir:
_path = self.validatepath(path)

if not self.getinfo(_path).is_dir:
raise errors.DirectoryExpected(path)
for i in info.raw['other']['files']:
yield i
return

dir_list = self.client.list(_path.encode('utf-8'))
if six.PY2:
dir_list = map(operator.methodcaller('decode', 'utf-8'), dir_list)

return list(map(operator.methodcaller('rstrip', '/'), dir_list))

def makedir(self, path, permissions=None, recreate=False):
_path = self.validatepath(path)
Expand Down