from collections import MutableMapping

import schema

from .dbdefer import dbdefer

class Status:

    '''status for one recipient'''

    todo = 1

    good = 2

    error = 3

    def __init__(self, offer, status, errtext=None):

        self.status = status

        self.offer = offer             #the offer over that this job was done

        self.errtext = errtext         #the error text

class ExJob:

    '''One Job is a class that handles one job has multiple tasks'''

    def __init__(self, dbjob, recipients, message, offers):

        self.dbjob = dbjob       #Connection to mysql job element (id)

        self.message = message

        self.recipients = recipients

        self.offers = offers

        self.tasks={}

    def addTask(self,task):

        self.tasks[task.recipient] = task

    def setStatus(task,status):

        pass

    def setError(task,err):

        pass

class ExJobs(dict, MutableMapping):

    @dbdefer

    def create(self, session, user, recipients, message, offers, info=None):

        user = session.merge(user)

        job = schema.Job(info=info, status="started")

        user.jobs.append(job)

        session.commit()

        return self[job.id]

exJobs = ExJobs()