# -*- coding: utf-8 -*-
from globaleaks.jobs.job import LoopingJob

from globaleaks.tests import helpers


class LoopingJobX(LoopingJob):
    interval = 2
    operation_called = 0

    def run(self):
        self.operation_called += 1


class TestLoopingJob(helpers.TestGL):
    def test_base_scheduler(self):
        """
        This function asseses the functionalities of a scheduler in calling
        the run() function periodically.
        """
        job = LoopingJobX()

        self.assertEqual(job.operation_called, 0)

        self.test_reactor.advance(1)

        self.assertEqual(job.operation_called, 1)

        self.test_reactor.advance(1)

        self.assertEqual(job.operation_called, 1)

        for i in range(2, 10):
            self.test_reactor.advance(2)
            self.assertEqual(job.operation_called, i)

        return job.stop()