import unittest

from iro.controller.task import createJob

from iro.model.job import jobs, Job

from iro.model.pool import data

from iro.model.message import SMS, Fax, Mail
from iro.model.schema import Job as DBJob, User
from iro.telnumber import Telnumber

from iro.error import JobNotFound
from iro.validate import vHash


from .dbtestcase import DBTestCase, setUpModule, tearDownModule

#activates all logging we can get.

from twisted.python import log
import logging
logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(name)s(%(processName)s)-%(levelname)s: %(message)s')
observer = log.PythonLoggingObserver()
observer.start()

class DumpPool():
    def run(self, f,*a,**k):
        return f(*a,**k)


data.pool=DumpPool()


class JobsTest(DBTestCase):
    '''tests for jobs'''

    def tearDown(self):
        jobs.clear()
        DBTestCase.tearDown(self)

    def testCreate(self):
        with self.session() as session:
            u = User(name='test',apikey='abcdef123456789')
            session.add(u)

        job = jobs.create(u, [Telnumber('123456789')], SMS('test'), ['test'])
        self.assertIsInstance(job, Job)
        self.assertTrue(vHash(job.id, None, 40, 40))

        with self.session() as session:
            j = session.query(DBJob.hash).all()
            self.assertEqual(j,[(job.id,)])

        self.assertEqual(jobs[job.id],job)

    def testGet(self):
        with self.session() as session:
            u = User(name='test',apikey='abcdef123456789')
            session.add(u)

        job = Job(u, [Telnumber('123456789')], SMS('test'), ['test'])
        jobs['a1'] = job

        self.assertEqual(len(jobs), 1)
        self.assertEqual(job, jobs['a1'])

    def testGetFromDB(self):
        with self.session() as session:
            u = User(name='test',apikey='abcdef123456789')
            job = DBJob(hash='a1', info="info", status="started")
            u.jobs.append(job)
            session.add(u)

        with self.session() as session:
            job = session.merge(job)
            u = session.merge(u)
            self.assertEqual(repr(jobs['a1'].dbjob),repr(job))
            self.assertEqual(repr(jobs['a1'].user),repr(u))
            self.assertEqual(jobs['a1'].info, 'info')

    def testUnknownJob(self):
        with self.assertRaises(JobNotFound):
            Job.fromDB('a1234567890')

        with self.assertRaises(KeyError):
            jobs['a1234567890']

    @unittest.skip('test not implemented')
    def testSyncroniced(self):
        pass

class JobTest(DBTestCase):
    def testCreateSMS(self):
        job = createJob([],SMS('sms'),[])
        pass

    def testCreateFax(self):
        job = createJob([],Fax('header','fax',[]),[])
        pass

    def testCreateMail(self):
        job = createJob([],Mail('sub','body','t@t.de'),[])
    

if __name__ == '__main__':
        unittest.main()