]>
code.delx.au - offlineimap/blob - offlineimap/folder/LocalStatus.py
c07c2b52b59f1ed8d5bdfdd4d9ef154f67259baf
1 # Local status cache virtual folder
2 # Copyright (C) 2002 - 2008 John Goerzen
3 # <jgoerzen@complete.org>
5 # This program is free software; you can redistribute it and/or modify
6 # it under the terms of the GNU General Public License as published by
7 # the Free Software Foundation; either version 2 of the License, or
8 # (at your option) any later version.
10 # This program is distributed in the hope that it will be useful,
11 # but WITHOUT ANY WARRANTY; without even the implied warranty of
12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 # GNU General Public License for more details.
15 # You should have received a copy of the GNU General Public License
16 # along with this program; if not, write to the Free Software
17 # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19 from Base
import BaseFolder
22 magicline
= "OFFLINEIMAP LocalStatus CACHE DATA - DO NOT MODIFY - FORMAT 1"
24 class LocalStatusFolder(BaseFolder
):
25 def __init__(self
, root
, name
, repository
, accountname
, config
):
30 self
.dofsync
= config
.getdefaultboolean("general", "fsync")
31 self
.filename
= os
.path
.join(root
, name
)
32 self
.filename
= repository
.getfolderfilename(name
)
33 self
.messagelist
= None
34 self
.repository
= repository
35 self
.savelock
= threading
.Lock()
37 self
.accountname
= accountname
38 BaseFolder
.__init
__(self
)
40 def getaccountname(self
):
41 return self
.accountname
43 def storesmessages(self
):
46 def isnewfolder(self
):
47 return not os
.path
.exists(self
.filename
)
58 def getfullname(self
):
61 def deletemessagelist(self
):
62 if not self
.isnewfolder():
63 os
.unlink(self
.filename
)
65 def cachemessagelist(self
):
66 if self
.isnewfolder():
69 file = open(self
.filename
, "rt")
71 line
= file.readline().strip()
72 if not line
and not line
.read():
73 # The status file is empty - should not have happened,
77 assert(line
== magicline
)
78 for line
in file.xreadlines():
80 uid
, flags
= line
.split(':')
82 flags
= [x
for x
in flags
]
83 self
.messagelist
[uid
] = {'uid': uid
, 'flags': flags
}
91 self
.savelock
.acquire()
93 file = open(self
.filename
+ ".tmp", "wt")
94 file.write(magicline
+ "\n")
95 for msg
in self
.messagelist
.values():
98 flags
= ''.join(flags
)
99 file.write("%s:%s\n" % (msg
['uid'], flags
))
102 os
.fsync(file.fileno())
104 os
.rename(self
.filename
+ ".tmp", self
.filename
)
108 fd
= os
.open(os
.path
.dirname(self
.filename
), os
.O_RDONLY
)
115 self
.savelock
.release()
117 def getmessagelist(self
):
118 return self
.messagelist
120 def savemessage(self
, uid
, content
, flags
, rtime
):
122 # We cannot assign a uid.
125 if uid
in self
.messagelist
: # already have it
126 self
.savemessageflags(uid
, flags
)
129 self
.messagelist
[uid
] = {'uid': uid
, 'flags': flags
, 'time': rtime
}
133 def getmessageflags(self
, uid
):
134 return self
.messagelist
[uid
]['flags']
136 def getmessagetime(self
, uid
):
137 return self
.messagelist
[uid
]['time']
139 def savemessageflags(self
, uid
, flags
):
140 self
.messagelist
[uid
]['flags'] = flags
143 def deletemessage(self
, uid
):
144 if not uid
in self
.messagelist
:
146 del(self
.messagelist
[uid
])