services/fuse/arvados_fuse/fusefile.py

   1 import logging
   2 import re
   3 import json
   4
   5 from fresh import FreshBase, convertTime
   6
   7 _logger = logging.getLogger('arvados.arvados_fuse')
   8
   9 class File(FreshBase):
  10     """Base for file objects."""
  11
  12     def __init__(self, parent_inode, _mtime=0):
  13         super(File, self).__init__()
  14         self.inode = None
  15         self.parent_inode = parent_inode
  16         self._mtime = _mtime
  17
  18     def size(self):
  19         return 0
  20
  21     def readfrom(self, off, size):
  22         return ''
  23
  24     def mtime(self):
  25         return self._mtime
  26
  27     def clear(self, force=False):
  28         return True
  29
  30
  31 class StreamReaderFile(File):
  32     """Wraps a StreamFileReader as a file."""
  33
  34     def __init__(self, parent_inode, reader, _mtime):
  35         super(StreamReaderFile, self).__init__(parent_inode, _mtime)
  36         self.reader = reader
  37
  38     def size(self):
  39         return self.reader.size()
  40
  41     def readfrom(self, off, size):
  42         return self.reader.readfrom(off, size)
  43
  44     def stale(self):
  45         return False
  46
  47
  48 class StringFile(File):
  49     """Wrap a simple string as a file"""
  50     def __init__(self, parent_inode, contents, _mtime):
  51         super(StringFile, self).__init__(parent_inode, _mtime)
  52         self.contents = contents
  53
  54     def size(self):
  55         return len(self.contents)
  56
  57     def readfrom(self, off, size):
  58         return self.contents[off:(off+size)]
  59
  60
  61 class ObjectFile(StringFile):
  62     """Wrap a dict as a serialized json object."""
  63
  64     def __init__(self, parent_inode, obj):
  65         super(ObjectFile, self).__init__(parent_inode, "", 0)
  66         self.uuid = obj['uuid']
  67         self.update(obj)
  68
  69     def update(self, obj):
  70         self._mtime = convertTime(obj['modified_at']) if 'modified_at' in obj else 0
  71         self.contents = json.dumps(obj, indent=4, sort_keys=True) + "\n"