import os
import unittest
import time
from subprocess import Popen, PIPE


def touch(fname):
    with open(fname, 'a'):
        os.utime(fname, None)
    return


def pgrep_spoolers():
    cmd = ["pgrep", "-f", "uWSGI spooler"]
    proc = Popen(cmd, stdout=PIPE)
    rv = set(map(int, proc.stdout.readlines()))
    proc.terminate()
    return rv


class MuleReloadingTest(unittest.TestCase):

    def test_reloading(self):
        try:
            uwsgi = Popen(["./uwsgi", "--master", "--spooler=directory", "--touch-spoolers-reload=/tmp/reload", "--socket=:0", "--auto-procname"])
            subprocesses = pgrep_spoolers()
            touch("/tmp/reload")
            time.sleep(1)
            new_subprocesses = pgrep_spoolers()
            proc_intersect = subprocesses.intersection(new_subprocesses)
            self.assertFalse(proc_intersect)
        finally:
            uwsgi.terminate()


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