2002-06-21 04:20:42 +02:00
|
|
|
# Local status cache repository support
|
|
|
|
# Copyright (C) 2002 John Goerzen
|
|
|
|
# <jgoerzen@complete.org>
|
|
|
|
#
|
|
|
|
# This program is free software; you can redistribute it and/or modify
|
|
|
|
# it under the terms of the GNU General Public License as published by
|
2003-04-16 21:23:45 +02:00
|
|
|
# the Free Software Foundation; either version 2 of the License, or
|
|
|
|
# (at your option) any later version.
|
2002-06-21 04:20:42 +02:00
|
|
|
#
|
|
|
|
# This program is distributed in the hope that it will be useful,
|
|
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
# GNU General Public License for more details.
|
|
|
|
#
|
|
|
|
# You should have received a copy of the GNU General Public License
|
|
|
|
# along with this program; if not, write to the Free Software
|
2006-08-12 06:15:55 +02:00
|
|
|
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
|
2002-06-21 04:20:42 +02:00
|
|
|
|
2015-01-01 22:20:43 +01:00
|
|
|
import os
|
|
|
|
|
2013-07-27 23:25:13 +02:00
|
|
|
from offlineimap.folder.LocalStatus import LocalStatusFolder
|
2011-05-07 11:00:57 +02:00
|
|
|
from offlineimap.folder.LocalStatusSQLite import LocalStatusSQLiteFolder
|
2012-02-05 11:57:19 +01:00
|
|
|
from offlineimap.repository.Base import BaseRepository
|
2002-06-21 04:20:42 +02:00
|
|
|
|
|
|
|
class LocalStatusRepository(BaseRepository):
|
2003-04-18 04:18:34 +02:00
|
|
|
def __init__(self, reposname, account):
|
|
|
|
BaseRepository.__init__(self, reposname, account)
|
2013-07-28 14:03:46 +02:00
|
|
|
|
|
|
|
# class and root for all backends
|
|
|
|
self.backends = {}
|
|
|
|
self.backends['sqlite'] = {
|
|
|
|
'class': LocalStatusSQLiteFolder,
|
|
|
|
'root': os.path.join(account.getaccountmeta(), 'LocalStatus-sqlite')
|
|
|
|
}
|
|
|
|
|
|
|
|
self.backends['plain'] = {
|
|
|
|
'class': LocalStatusFolder,
|
|
|
|
'root': os.path.join(account.getaccountmeta(), 'LocalStatus')
|
|
|
|
}
|
|
|
|
|
|
|
|
# Set class and root for the configured backend
|
|
|
|
self.setup_backend(self.account.getconf('status_backend', 'plain'))
|
2011-05-07 11:00:57 +02:00
|
|
|
|
2011-09-16 10:54:25 +02:00
|
|
|
if not os.path.exists(self.root):
|
2012-02-05 11:31:54 +01:00
|
|
|
os.mkdir(self.root, 0o700)
|
2011-05-07 11:00:57 +02:00
|
|
|
|
Reuse LocalStatus() folders rather than recreate instances
If we ask twice for a LocalStatusFolder via getfolder(), we would
get a newly created instance each time. This can lead to problems,
as e.g. write locks protecting files only work within the same Folder
instance. Make it so, that we cache all Folder instances that we have
asked for and hand back the existing one if we ask again for it,
rather than recreate a new instance.
Also, make getfolders() a noop for LocalStatus. We attempted to
derive the foldername from the name of the LocalStatusfile. However,
this is not really possible, as we do file name mangling
(".$" -> "dot", "/" -> ".") and there is no way to get the original folder
name from the LocalStatus file name anyway.
This commit could potentially solve the "file not found" errors, that people
have been seeing with their LocalStatusCache files. If we have 2
instances of a LocalStatusFolder pointing to the same file, our locking
system would not work.
Signed-off-by: Sebastian Spaeth <Sebastian@SSpaeth.de>
2012-09-01 01:02:20 +02:00
|
|
|
# self._folders is a dict of name:LocalStatusFolders()
|
|
|
|
self._folders = {}
|
2002-06-21 04:20:42 +02:00
|
|
|
|
2013-07-28 14:03:46 +02:00
|
|
|
def setup_backend(self, backend):
|
|
|
|
if backend in self.backends.keys():
|
|
|
|
self._backend = backend
|
|
|
|
self.root = self.backends[backend]['root']
|
|
|
|
self.LocalStatusFolderClass = self.backends[backend]['class']
|
|
|
|
|
|
|
|
else:
|
|
|
|
raise SyntaxWarning("Unknown status_backend '%s' for account '%s'" \
|
2014-05-06 23:27:30 +02:00
|
|
|
% (backend, self.account.name))
|
2013-07-28 14:03:46 +02:00
|
|
|
|
|
|
|
def import_other_backend(self, folder):
|
|
|
|
for bk, dic in self.backends.items():
|
|
|
|
# skip folder's own type
|
|
|
|
if dic['class'] == type(folder):
|
|
|
|
continue
|
|
|
|
|
|
|
|
repobk = LocalStatusRepository(self.name, self.account)
|
|
|
|
repobk.setup_backend(bk) # fake the backend
|
|
|
|
folderbk = dic['class'](folder.name, repobk)
|
|
|
|
|
|
|
|
# if backend contains data, import it to folder.
|
|
|
|
if not folderbk.isnewfolder():
|
|
|
|
self.ui._msg('Migrating LocalStatus cache from %s to %s ' % (bk, self._backend) + \
|
|
|
|
'status folder for %s:%s' % (self.name, folder.name))
|
|
|
|
|
|
|
|
folderbk.cachemessagelist()
|
|
|
|
folder.messagelist = folderbk.messagelist
|
|
|
|
folder.saveall()
|
|
|
|
break
|
|
|
|
|
2002-06-21 04:20:42 +02:00
|
|
|
def getsep(self):
|
|
|
|
return '.'
|
|
|
|
|
|
|
|
def makefolder(self, foldername):
|
2013-07-28 14:03:46 +02:00
|
|
|
"""Create a LocalStatus Folder"""
|
2011-09-15 15:37:52 +02:00
|
|
|
|
|
|
|
if self.account.dryrun:
|
|
|
|
return # bail out in dry-run mode
|
2011-05-07 11:00:57 +02:00
|
|
|
|
2013-07-27 23:25:13 +02:00
|
|
|
# Create an empty StatusFolder
|
|
|
|
folder = self.LocalStatusFolderClass(foldername, self)
|
|
|
|
folder.save()
|
|
|
|
|
2002-06-21 04:20:42 +02:00
|
|
|
# Invalidate the cache.
|
2013-07-28 14:03:46 +02:00
|
|
|
self.forgetfolders()
|
2002-06-21 04:20:42 +02:00
|
|
|
|
2011-05-05 15:59:28 +02:00
|
|
|
def getfolder(self, foldername):
|
|
|
|
"""Return the Folder() object for a foldername"""
|
Reuse LocalStatus() folders rather than recreate instances
If we ask twice for a LocalStatusFolder via getfolder(), we would
get a newly created instance each time. This can lead to problems,
as e.g. write locks protecting files only work within the same Folder
instance. Make it so, that we cache all Folder instances that we have
asked for and hand back the existing one if we ask again for it,
rather than recreate a new instance.
Also, make getfolders() a noop for LocalStatus. We attempted to
derive the foldername from the name of the LocalStatusfile. However,
this is not really possible, as we do file name mangling
(".$" -> "dot", "/" -> ".") and there is no way to get the original folder
name from the LocalStatus file name anyway.
This commit could potentially solve the "file not found" errors, that people
have been seeing with their LocalStatusCache files. If we have 2
instances of a LocalStatusFolder pointing to the same file, our locking
system would not work.
Signed-off-by: Sebastian Spaeth <Sebastian@SSpaeth.de>
2012-09-01 01:02:20 +02:00
|
|
|
if foldername in self._folders:
|
|
|
|
return self._folders[foldername]
|
|
|
|
|
|
|
|
folder = self.LocalStatusFolderClass(foldername, self)
|
2013-07-28 14:03:46 +02:00
|
|
|
|
|
|
|
# if folder is empty, try to import data from an other backend
|
|
|
|
if folder.isnewfolder():
|
|
|
|
self.import_other_backend(folder)
|
|
|
|
|
Reuse LocalStatus() folders rather than recreate instances
If we ask twice for a LocalStatusFolder via getfolder(), we would
get a newly created instance each time. This can lead to problems,
as e.g. write locks protecting files only work within the same Folder
instance. Make it so, that we cache all Folder instances that we have
asked for and hand back the existing one if we ask again for it,
rather than recreate a new instance.
Also, make getfolders() a noop for LocalStatus. We attempted to
derive the foldername from the name of the LocalStatusfile. However,
this is not really possible, as we do file name mangling
(".$" -> "dot", "/" -> ".") and there is no way to get the original folder
name from the LocalStatus file name anyway.
This commit could potentially solve the "file not found" errors, that people
have been seeing with their LocalStatusCache files. If we have 2
instances of a LocalStatusFolder pointing to the same file, our locking
system would not work.
Signed-off-by: Sebastian Spaeth <Sebastian@SSpaeth.de>
2012-09-01 01:02:20 +02:00
|
|
|
self._folders[foldername] = folder
|
|
|
|
return folder
|
2011-05-05 15:59:28 +02:00
|
|
|
|
2002-06-21 04:20:42 +02:00
|
|
|
def getfolders(self):
|
2013-07-21 21:00:23 +02:00
|
|
|
"""Returns a list of all cached folders.
|
2002-06-21 05:40:58 +02:00
|
|
|
|
Reuse LocalStatus() folders rather than recreate instances
If we ask twice for a LocalStatusFolder via getfolder(), we would
get a newly created instance each time. This can lead to problems,
as e.g. write locks protecting files only work within the same Folder
instance. Make it so, that we cache all Folder instances that we have
asked for and hand back the existing one if we ask again for it,
rather than recreate a new instance.
Also, make getfolders() a noop for LocalStatus. We attempted to
derive the foldername from the name of the LocalStatusfile. However,
this is not really possible, as we do file name mangling
(".$" -> "dot", "/" -> ".") and there is no way to get the original folder
name from the LocalStatus file name anyway.
This commit could potentially solve the "file not found" errors, that people
have been seeing with their LocalStatusCache files. If we have 2
instances of a LocalStatusFolder pointing to the same file, our locking
system would not work.
Signed-off-by: Sebastian Spaeth <Sebastian@SSpaeth.de>
2012-09-01 01:02:20 +02:00
|
|
|
Does nothing for this backend. We mangle the folder file names
|
|
|
|
(see getfolderfilename) so we can not derive folder names from
|
|
|
|
the file names that we have available. TODO: need to store a
|
|
|
|
list of folder names somehow?"""
|
|
|
|
pass
|
2002-06-21 04:20:42 +02:00
|
|
|
|
2011-05-05 15:59:28 +02:00
|
|
|
def forgetfolders(self):
|
|
|
|
"""Forgets the cached list of folders, if any. Useful to run
|
|
|
|
after a sync run."""
|
Reuse LocalStatus() folders rather than recreate instances
If we ask twice for a LocalStatusFolder via getfolder(), we would
get a newly created instance each time. This can lead to problems,
as e.g. write locks protecting files only work within the same Folder
instance. Make it so, that we cache all Folder instances that we have
asked for and hand back the existing one if we ask again for it,
rather than recreate a new instance.
Also, make getfolders() a noop for LocalStatus. We attempted to
derive the foldername from the name of the LocalStatusfile. However,
this is not really possible, as we do file name mangling
(".$" -> "dot", "/" -> ".") and there is no way to get the original folder
name from the LocalStatus file name anyway.
This commit could potentially solve the "file not found" errors, that people
have been seeing with their LocalStatusCache files. If we have 2
instances of a LocalStatusFolder pointing to the same file, our locking
system would not work.
Signed-off-by: Sebastian Spaeth <Sebastian@SSpaeth.de>
2012-09-01 01:02:20 +02:00
|
|
|
self._folders = {}
|