#!/usr/bin/env python
# +leo-ver=4
# +node:@file xmp.py
#@@first
#
#    Copyright (C) 2001  Jeff Epler  <jepler unpythonic dhs org>
#
#    This program can be distributed under the terms of the GNU LGPL.
#    See the file COPYING.
#

# +others
# +node:imports

from fuse import Fuse
from optparse import OptionParser
from errno import *
from stat import *
import os,statvfs,thread,logging,dbus

### 
# Set up logging
###
log = logging.getLogger("trackerfs")
log.setLevel(logging.ERROR)
fh = logging.StreamHandler()
fh.setLevel(logging.ERROR)
#create formatter
formatter = logging.Formatter("%(asctime)s - %(name)s - %(levelname)s - %(message)s")
fh.setFormatter(formatter)
log.addHandler(fh)

class TrackerFs (Fuse):

	def __init__(self,*args, **kw):
		Fuse.__init__(self,*args,**kw)
		
		#Initialize dbus session and tracker interfaces
		bus = dbus.SessionBus()
		obj = bus.get_object('org.freedesktop.Tracker','/org/freedesktop/tracker')
		self.tracker = dbus.Interface(obj, 'org.freedesktop.Tracker')
		self.keywords = dbus.Interface(obj, 'org.freedesktop.Tracker.Keywords')
		self.filesdb = dbus.Interface(obj, 'org.freedesktop.Tracker.Files')
		
		print "Trackerfs:mountpoint: %s" % repr(self.mountpoint)
		print "Trackerfs:unnamed mount options: %s" % self.optlist
		print "Trackerfs:named mount options: %s" % self.optdict
		
		self.filelist = []
		self.tmplist = []
		self._refresh_filelist()
		pass

	def mythread(self):
		print "start thread"
		#while 1:
		#	time.sleep(120)
		#	self.getdir()

	def _refresh_filelist(self):
		if self.optdict.has_key("tag"):
			print "Use Tag"
			self.filelist = self.keywords.Search(-1,'Files',self.optdict['tag'].split("+"),-1,-1)
			self.filelist = map(lambda x: str(x),self.filelist)
		#elif self.optdict.has_key("query"):
		#	print "Use Query"
		#	self.filelist = os.popen("/usr/bin/tracker-query "+self.optdict['query'],"r").readlines();
		#	self.filelist = map(lambda x:(x.split(' : ')),self.filelist)
		#	self.filelist = map(lambda x:(x[0].strip(' \t\r\n')),self.filelist)
		#elif self.optdict.has_key("key"):
		#	print "Use key"
		#	self.filelist = os.popen("/usr/bin/tracker-search "+self.optdict['tag'].replace("+",","),"r").readlines();
		#	self.filelist = map(lambda x:(x.strip(' \t\r\n')),self.filelist)
		#else:
		#	print 'You must specifi a tag or a query'
		#	return 0
		#self.filelist.extend(self.tmplist)
		print self.filelist
		#self.filelist.pop()

	def _get_file_path(self,filename):
		if os.path.dirname(filename) == "/":
			for file in self.filelist:
				if filename== "/"+os.path.basename(file):
					return file
		else:
			path = filename.split("/")
			relpath = filename.replace("/"+path[1],"")
			for file in self.filelist:
				if path[1] == os.path.basename(file):
					return file+relpath
		return filename

	def getattr(self,path):
		print 'File:'+path+'Attr:'+self._get_file_path(path)
		return os.lstat(self._get_file_path(path))

	def readlink(self, path):
		return os.readlink(path)

	def getdir(self, path):
		if path == "/":
			self._refresh_filelist()
			return map(lambda x: (os.path.basename(x),0),self.filelist)
		else:
			return map(lambda x: (os.path.basename(x),0),os.listdir(self._get_file_path(path)))

	def unlink(self, path):
		print 'unlink'
		return os.unlink(path)

	def rmdir(self, path):
		return os.rmdir(path)

	def symlink(self, path, path1):
		return os.symlink(path, path1)

	def rename(self, path, path1):
		return os.rename(path, path1)

	def link(self, path, path1):
		return os.link(path, path1)

	def chmod(self, path, mode):
		return os.chmod(self._get_file_path(path), mode)

	def chown(self, path, user, group):
		return os.chown(self._get_file_path(path), user, group)

	def truncate(self, path, size):
		f = open(self._get_file_path(path), "w+")
		return f.truncate(size)

	def mknod(self, path, mode, dev):
		if os.path.dirname(path) == "/":
			path = "~/.documents/"+os.path.basename(path)		
			print 'MkNod:'+path+'....'
			if S_ISREG(mode):
				self.tmplist.append(path)
				self._refresh_filelist()
				self.getdir("/")
				res = os.open(path, os.O_CREAT | os.O_WRONLY,mode);
				#restat = os.fstat(res);
				#self.filesdb.Create(path,False,'image/png',dbus.Int32(restat[ST_SIZE]),restat[ST_MTIME])
			else:
				return -EINVAL
		
	def mkdir(self, path, mode):
		path = "~/.documents/"+os.path.basename(path)
		res = os.mkdir(path,mode)
		self.tmplist.append(path)
		self._refresh_filelist()
		self.getdir("/")
		return res

	def utime(self, path, times):
		return os.utime(self._get_file_path(path), times)

	def open(self, path, flags):
		path = self._get_file_path(path)
		res = os.open(path,flags)
		print "Trackerfs:open: %s" % path
		os.close(res)
		return 0

	def read(self, path, length, offset):
		path = self._get_file_path(path)
		print "Trackerfs:read: %s" % path
		f = open(self._get_file_path(path), "r")
		f.seek(offset)
		return f.read(length)

	def write(self, path, buf, off):
		path = self._get_file_path(path)
		print "Trackerfs:write: %s" % path
		f = open(path, "w")
		f.seek(off)
		f.write(buf)
		return len(buf)
		return 0

	def release(self, path, flags):
		print "Trackerfs:release: %s %s" % (self._get_file_path(path), flags)
		return 0

	def statfs(self):
		self.sysconst = os.statvfs("/home/eugenio/.documents")
		print "Trackerfs:statfs: returning fictitious values"
		print self.sysconst[statvfs.F_BLOCKS]
		block_size = self.sysconst[statvfs.F_BSIZE]
		blocks = self.sysconst[statvfs.F_BLOCKS]
		blocks_free = self.sysconst[statvfs.F_BFREE]
		blocks_avail = self.sysconst[statvfs.F_BAVAIL]
		files = self.sysconst[statvfs.F_FILES]
		files_free = self.sysconst[statvfs.F_FFREE]
		namelen = self.sysconst[statvfs.F_NAMEMAX]
		return (block_size, blocks, blocks_free, blocks_avail, files, files_free, namelen)

	def fsync(self, path, isfsyncfile):
		print "Trackerfs:fsync: path=%s, isfsyncfile=%s" % (path, isfsyncfile)
		return 0

if __name__ == '__main__':
	server = TrackerFs()
	server.multithreaded = 0;
	server.main()