<reponame>scbabacus/eventsourcing
import datetime
import os
import unittest
from time import sleep

from eventsourcing.application.multiprocess import Multiprocess
from eventsourcing.contrib.paxos.application import PaxosProcess, PaxosSystem
from eventsourcing.domain.model.events import assert_event_handlers_empty
from eventsourcing.tests.test_system_fixtures import set_db_uri


class TestPaxosSystem(unittest.TestCase):

    def test_single_threaded(self):
        system = PaxosSystem(setup_tables=True, processes=3)

        with system:
            paxos1 = system.paxosprocess0.propose_value(11111, quorum_size=system.quorum_size, assume_leader=False)
            paxos2 = system.paxosprocess1.propose_value(22222, quorum_size=system.quorum_size, assume_leader=False)
            paxos3 = system.paxosprocess2.propose_value(33333, quorum_size=system.quorum_size, assume_leader=False)

            # Check each process has a resolution.
            self.assertEqual(system.paxosprocess0.repository[paxos1.id].resolution.value, 11111)
            self.assertEqual(system.paxosprocess1.repository[paxos1.id].resolution.value, 11111)
            self.assertEqual(system.paxosprocess2.repository[paxos1.id].resolution.value, 11111)
            self.assertEqual(system.paxosprocess0.repository[paxos2.id].resolution.value, 22222)
            self.assertEqual(system.paxosprocess1.repository[paxos2.id].resolution.value, 22222)
            self.assertEqual(system.paxosprocess2.repository[paxos2.id].resolution.value, 22222)
            self.assertEqual(system.paxosprocess0.repository[paxos3.id].resolution.value, 33333)
            self.assertEqual(system.paxosprocess1.repository[paxos3.id].resolution.value, 33333)
            self.assertEqual(system.paxosprocess2.repository[paxos3.id].resolution.value, 33333)

    def test_multiprocessing(self):
        set_db_uri()
        system = PaxosSystem(setup_tables=True, processes=3)

        with Multiprocess(system, pipeline_ids=[1, 2, 3]), PaxosProcess(name='paxosprocess0', pipeline_id=1) as \
            paxosprocess0:
            sleep(3)
            print("Running {}".format(datetime.datetime.now()))
            paxos1 = paxosprocess0.propose_value(11111, quorum_size=system.quorum_size, assume_leader=True)

            paxosprocess0.change_pipeline(2)
            paxos2 = paxosprocess0.propose_value(22222, quorum_size=system.quorum_size, assume_leader=True)

            paxosprocess0.change_pipeline(3)
            paxos3 = paxosprocess0.propose_value(33333, quorum_size=system.quorum_size, assume_leader=True)

            # Check each process has a resolution.
            while True:
                if paxosprocess0.repository[paxos1.id].resolution:
                    break
            self.assertEqual(paxosprocess0.repository[paxos1.id].resolution.value, 11111)
            print("")
            print("")
            print("")
            print("")
            print("Finished {}".format(datetime.datetime.now()))

            while True:
                if paxosprocess0.repository[paxos2.id].resolution:
                    break
            self.assertEqual(paxosprocess0.repository[paxos2.id].resolution.value, 22222)

            while True:
                if paxosprocess0.repository[paxos3.id].resolution:
                    break
            self.assertEqual(paxosprocess0.repository[paxos3.id].resolution.value, 33333)

    def tearDown(self):
        assert_event_handlers_empty()

        try:
            del (os.environ['DB_URI'])
        except KeyError:
            pass

import datetime
import os
import unittest
from time import sleep

from eventsourcing.application.multiprocess import Multiprocess
from eventsourcing.contrib.paxos.application import PaxosProcess, PaxosSystem
from eventsourcing.domain.model.events import assert_event_handlers_empty
from eventsourcing.tests.test_system_fixtures import set_db_uri


class TestPaxosSystem(unittest.TestCase):

    def test_single_threaded(self):
        system = PaxosSystem(setup_tables=True, processes=3)

        with system:
            paxos1 = system.paxosprocess0.propose_value(11111, quorum_size=system.quorum_size, assume_leader=False)
            paxos2 = system.paxosprocess1.propose_value(22222, quorum_size=system.quorum_size, assume_leader=False)
            paxos3 = system.paxosprocess2.propose_value(33333, quorum_size=system.quorum_size, assume_leader=False)

            # Check each process has a resolution.
            self.assertEqual(system.paxosprocess0.repository[paxos1.id].resolution.value, 11111)
            self.assertEqual(system.paxosprocess1.repository[paxos1.id].resolution.value, 11111)
            self.assertEqual(system.paxosprocess2.repository[paxos1.id].resolution.value, 11111)
            self.assertEqual(system.paxosprocess0.repository[paxos2.id].resolution.value, 22222)
            self.assertEqual(system.paxosprocess1.repository[paxos2.id].resolution.value, 22222)
            self.assertEqual(system.paxosprocess2.repository[paxos2.id].resolution.value, 22222)
            self.assertEqual(system.paxosprocess0.repository[paxos3.id].resolution.value, 33333)
            self.assertEqual(system.paxosprocess1.repository[paxos3.id].resolution.value, 33333)
            self.assertEqual(system.paxosprocess2.repository[paxos3.id].resolution.value, 33333)

    def test_multiprocessing(self):
        set_db_uri()
        system = PaxosSystem(setup_tables=True, processes=3)

        with Multiprocess(system, pipeline_ids=[1, 2, 3]), PaxosProcess(name='paxosprocess0', pipeline_id=1) as \
            paxosprocess0:
            sleep(3)
            print("Running {}".format(datetime.datetime.now()))
            paxos1 = paxosprocess0.propose_value(11111, quorum_size=system.quorum_size, assume_leader=True)

            paxosprocess0.change_pipeline(2)
            paxos2 = paxosprocess0.propose_value(22222, quorum_size=system.quorum_size, assume_leader=True)

            paxosprocess0.change_pipeline(3)
            paxos3 = paxosprocess0.propose_value(33333, quorum_size=system.quorum_size, assume_leader=True)

            # Check each process has a resolution.
            while True:
                if paxosprocess0.repository[paxos1.id].resolution:
                    break
            self.assertEqual(paxosprocess0.repository[paxos1.id].resolution.value, 11111)
            print("")
            print("")
            print("")
            print("")
            print("Finished {}".format(datetime.datetime.now()))

            while True:
                if paxosprocess0.repository[paxos2.id].resolution:
                    break
            self.assertEqual(paxosprocess0.repository[paxos2.id].resolution.value, 22222)

            while True:
                if paxosprocess0.repository[paxos3.id].resolution:
                    break
            self.assertEqual(paxosprocess0.repository[paxos3.id].resolution.value, 33333)

    def tearDown(self):
        assert_event_handlers_empty()

        try:
            del (os.environ['DB_URI'])
        except KeyError:
            pass
# Check each process has a resolution. # Check each process has a resolution.