equal
deleted
inserted
replaced
1 from collections import MutableMapping |
1 from collections import MutableMapping |
2 |
2 |
3 import schema |
3 import schema |
4 from .dbdefer import dbdefer |
4 from .dbdefer import dbdefer |
|
5 from .offer import extendProvider |
5 |
6 |
6 class Status: |
7 class Status: |
7 '''status for one recipient''' |
8 '''status for one recipient''' |
8 todo = 1 |
9 todo = 1 |
9 good = 2 |
10 good = 2 |
38 def create(self, session, user, recipients, message, offers, info=None): |
39 def create(self, session, user, recipients, message, offers, info=None): |
39 user = session.merge(user) |
40 user = session.merge(user) |
40 job = schema.Job(info=info, status="started") |
41 job = schema.Job(info=info, status="started") |
41 user.jobs.append(job) |
42 user.jobs.append(job) |
42 session.commit() |
43 session.commit() |
43 |
44 |
44 self[job.id] = ExJob(job.id, recipients, message, offers) |
45 o = extendProvider(user, message.typ, offers, session=session) |
|
46 self[job.id] = ExJob(job.id, recipients, message, o) |
45 return self[job.id] |
47 return self[job.id] |
46 |
48 |
47 exJobs = ExJobs() |
49 exJobs = ExJobs() |