Skip to content

match filesize and test valid rsync connection on _init_ #4

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.

Sign up for GitHub

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

Open
fewerthon wants to merge 1 commit into
base: master
Choose a base branch
from
Open

match filesize and test valid rsync connection on _init_ #4

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
45 changes: 39 additions & 6 deletions fuse_rsync.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ class RsyncModule():
"""
This class implements access to an Rsync module.
"""
def __init__(self, host, module, user = None, password = None):
def __init__(self, host, module, user = None, password = None, path = '/'):
self._environment = os.environ.copy()
self._remote_url = "rsync://"
if not user is None:
Expand All @@ -35,6 +35,16 @@ def __init__(self, host, module, user = None, password = None):
if not password is None:
self._environment['RSYNC_PASSWORD'] = password
self._attr_cache = {}
#testa rsync no inicio do modulo
remote_url = self._remote_url + path
try:
output = subprocess.check_output(["rsync", "--list-only", remote_url], env = self._environment)
except subprocess.CalledProcessError as err:
if err.returncode == 23:
return []
raise err



def _parse_attrs(self, attrs):
"""
Expand Down Expand Up @@ -70,13 +80,23 @@ def list(self, path = '/'):
in a datetime object) and *filename* (The file's name).
"""
# See http://stackoverflow.com/questions/10323060/printing-file-permissions-like-ls-l-using-stat2-in-c for modes
RE_LINE = re.compile("^([ldcbps-]([r-][w-][x-]){3})\s+([0-9]+)\s+([0-9]{4}/[0-9]{2}/[0-9]{2} [0-9]{2}:[0-9]{2}:[0-9]{2}) (.*)$")
#antigo nao considera arquivos e diretorios que tem virgula no tamanho
#ex:
#drwxr-xr-x 4,096 2024/01/29 10:35:15 .
#-rw-r--r-- 648 2023/12/15 15:10:19 xfer-2023-12-15.log
#-rw-r--r-- 162 2024/01/29 10:39:33 xfer-2024-01-29.log
#drwxr-xr-x 4,096 2024/06/04 00:10:06 ears
#drwx------ 4,096 2022/01/14 11:36:49 lost+found
#drwxr-xr-x 4,096 2024/06/04 09:49:01 rex
#drwxr-xr-x 4,096 2023/12/22 09:35:19 tts

#RE_LINE = re.compile("^([ldcbps-]([r-][w-][x-]){3})\s+([0-9,]+)\s+([0-9]{4}/[0-9]{2}/[0-9]{2} [0-9]{2}:[0-9]{2}:[0-9]{2}) (.*)$")
RE_LINE = re.compile(r"^([ldcbps-]([r-][w-][x-]){3})\s+([\d,.]+)\s+(\d{4}/\d{2}/\d{2} \d{2}:\d{2}:\d{2})\s+(.*)$")
remote_url = self._remote_url + path
try:
cmdline = ["rsync", "--list-only", remote_url]
log.debug("executing %s", " ".join(cmdline))
output = subprocess.check_output(["rsync", "--list-only", remote_url], env = self._environment)

listing = []
for line in output.decode(encoding = 'iso-8859-1').split("\n"):
match = RE_LINE.match(line)
Expand All @@ -86,7 +106,8 @@ def list(self, path = '/'):

listing.append({
"attrs": self._parse_attrs(match.group(1)),
"size": int(match.group(3)),
#"size": int(match.group(3)),
"size": int(match.group(3).replace(',','').replace('.','')),
"timestamp": datetime.datetime.strptime(match.group(4), "%Y/%m/%d %H:%M:%S"),
"filename": match.group(5)
})
Expand All @@ -113,6 +134,17 @@ def copy(self, remotepath = '/', localpath = None):

return localpath

"""
#funcao de teste do list
def test_list_function():
rsync_module = RsyncModule('tesbe2a1', 'rex2', user='root', password='your_password')
listing = rsync_module.list('/')
for entry in listing:
print(entry)

test_list_function()
"""

class FuseRsyncFileInfo(fuse.FuseFileInfo):
"""
Encapsulates the file handle for an opened file.
Expand Down Expand Up @@ -158,6 +190,7 @@ def init(self):
options = self.cmdline[0]
log.debug("Invoked fsinit() with host=%s, module=%s, user=%s, password=%s", options.host, options.module, options.user, options.password)
self._rsync = RsyncModule(options.host, options.module, options.user, options.password)


# Filesystem methods
# ==================
Expand All @@ -180,7 +213,7 @@ def getattr(self, path, fh=None):
log.debug("Invoked getattr('%s')", path)

path = self._full_path(path)

st = fuse.Stat()

if path == "/":
Expand Down Expand Up @@ -228,7 +261,7 @@ def readdir(self, path, offset):
log.debug("Invoked readdir('%s')", path)

full_path = self._full_path(path)

yield fuse.Direntry('.')
yield fuse.Direntry('..')

Expand Down