|
@@ -19,6 +19,7 @@ from tracim.lib.base import logger
|
19
|
19
|
from tracim.lib.exceptions import AlreadyRunningDaemon
|
20
|
20
|
|
21
|
21
|
from tracim.lib.utils import get_rq_queue
|
|
22
|
+from tracim.lib.email_fetcher import MailFetcher
|
22
|
23
|
|
23
|
24
|
|
24
|
25
|
class DaemonsManager(object):
|
|
@@ -158,11 +159,22 @@ class MailFetcherDaemon(Daemon):
|
158
|
159
|
self.ok = True
|
159
|
160
|
|
160
|
161
|
def run(self):
|
161
|
|
- while self.ok:
|
162
|
|
- pass
|
|
162
|
+ from tracim.config.app_cfg import CFG
|
|
163
|
+ cfg = CFG.get_instance()
|
|
164
|
+ self._fetcher = MailFetcher(
|
|
165
|
+ host=cfg.EMAIL_REPLY_IMAP_SERVER,
|
|
166
|
+ port=cfg.EMAIL_REPLY_IMAP_PORT,
|
|
167
|
+ user=cfg.EMAIL_REPLY_IMAP_USER,
|
|
168
|
+ password=cfg.EMAIL_REPLY_IMAP_PASSWORD,
|
|
169
|
+ folder=cfg.EMAIL_REPLY_IMAP_FOLDER,
|
|
170
|
+ delay=cfg.EMAIL_REPLY_DELAY
|
|
171
|
+ )
|
|
172
|
+ self._fetcher.run()
|
163
|
173
|
|
164
|
174
|
def stop(self):
|
165
|
|
- self.ok = False
|
|
175
|
+ if self._fetcher:
|
|
176
|
+ self._fetcher.stop()
|
|
177
|
+
|
166
|
178
|
|
167
|
179
|
|
168
|
180
|
|