| [b2cfdb] | 1 | /* | 
|---|
|  | 2 | * manipulateAtomsTest.cpp | 
|---|
|  | 3 | * | 
|---|
|  | 4 | *  Created on: Feb 18, 2010 | 
|---|
|  | 5 | *      Author: crueger | 
|---|
|  | 6 | */ | 
|---|
|  | 7 |  | 
|---|
|  | 8 | #include "manipulateAtomsTest.hpp" | 
|---|
|  | 9 |  | 
|---|
|  | 10 | #include <cppunit/CompilerOutputter.h> | 
|---|
|  | 11 | #include <cppunit/extensions/TestFactoryRegistry.h> | 
|---|
|  | 12 | #include <cppunit/ui/text/TestRunner.h> | 
|---|
|  | 13 | #include <iostream> | 
|---|
|  | 14 | #include <boost/bind.hpp> | 
|---|
|  | 15 |  | 
|---|
|  | 16 | #include "Descriptors/AtomDescriptor.hpp" | 
|---|
|  | 17 | #include "Descriptors/AtomIdDescriptor.hpp" | 
|---|
|  | 18 | #include "Actions/ManipulateAtomsProcess.hpp" | 
|---|
|  | 19 | #include "Actions/ActionRegistry.hpp" | 
|---|
|  | 20 |  | 
|---|
|  | 21 | #include "World.hpp" | 
|---|
|  | 22 | #include "atom.hpp" | 
|---|
|  | 23 |  | 
|---|
|  | 24 | // Registers the fixture into the 'registry' | 
|---|
|  | 25 | CPPUNIT_TEST_SUITE_REGISTRATION( manipulateAtomsTest ); | 
|---|
|  | 26 |  | 
|---|
|  | 27 | // some stubs | 
|---|
|  | 28 | class AtomStub : public atom { | 
|---|
|  | 29 | public: | 
|---|
|  | 30 | AtomStub(int _id) : | 
|---|
|  | 31 | atom(), | 
|---|
|  | 32 | id(_id), | 
|---|
|  | 33 | manipulated(false) | 
|---|
|  | 34 | {} | 
|---|
|  | 35 |  | 
|---|
| [57adc7] | 36 | virtual atomId_t getId(){ | 
|---|
| [b2cfdb] | 37 | return id; | 
|---|
|  | 38 | } | 
|---|
|  | 39 |  | 
|---|
|  | 40 | virtual void doSomething(){ | 
|---|
|  | 41 | manipulated = true; | 
|---|
|  | 42 | } | 
|---|
|  | 43 |  | 
|---|
|  | 44 | bool manipulated; | 
|---|
|  | 45 | private: | 
|---|
| [57adc7] | 46 | atomId_t id; | 
|---|
| [b2cfdb] | 47 | }; | 
|---|
|  | 48 |  | 
|---|
| [afb47f] | 49 | class countObserver : public Observer{ | 
|---|
|  | 50 | public: | 
|---|
|  | 51 | countObserver() : | 
|---|
|  | 52 | count(0) | 
|---|
|  | 53 | {} | 
|---|
|  | 54 | virtual ~countObserver(){} | 
|---|
|  | 55 |  | 
|---|
|  | 56 | void update(Observable *){ | 
|---|
|  | 57 | count++; | 
|---|
|  | 58 | } | 
|---|
|  | 59 |  | 
|---|
|  | 60 | void subjectKilled(Observable *) | 
|---|
|  | 61 | {} | 
|---|
|  | 62 |  | 
|---|
|  | 63 | int count; | 
|---|
|  | 64 | }; | 
|---|
| [b2cfdb] | 65 |  | 
|---|
|  | 66 | // set up and tear down | 
|---|
|  | 67 | void manipulateAtomsTest::setUp(){ | 
|---|
|  | 68 | World::get(); | 
|---|
|  | 69 | for(int i=0;i<ATOM_COUNT;++i){ | 
|---|
|  | 70 | atoms[i]= new AtomStub(i); | 
|---|
| [46d958] | 71 | World::get()->registerAtom(atoms[i]); | 
|---|
| [b2cfdb] | 72 | } | 
|---|
|  | 73 | } | 
|---|
|  | 74 | void manipulateAtomsTest::tearDown(){ | 
|---|
|  | 75 | World::destroy(); | 
|---|
|  | 76 | ActionRegistry::purgeRegistry(); | 
|---|
|  | 77 | } | 
|---|
|  | 78 |  | 
|---|
|  | 79 | // some helper functions | 
|---|
| [a1510d] | 80 | static bool hasAll(std::vector<atom*> atoms,int min, int max, std::set<int> excluded = std::set<int>()){ | 
|---|
| [b2cfdb] | 81 | for(int i=min;i<max;++i){ | 
|---|
|  | 82 | if(!excluded.count(i)){ | 
|---|
|  | 83 | std::vector<atom*>::iterator iter; | 
|---|
|  | 84 | bool res=false; | 
|---|
|  | 85 | for(iter=atoms.begin();iter!=atoms.end();++iter){ | 
|---|
|  | 86 | res |= (*iter)->getId() == i; | 
|---|
|  | 87 | } | 
|---|
|  | 88 | if(!res) { | 
|---|
|  | 89 | cout << "Atom " << i << " missing in returned list" << endl; | 
|---|
|  | 90 | return false; | 
|---|
|  | 91 | } | 
|---|
|  | 92 | } | 
|---|
|  | 93 | } | 
|---|
|  | 94 | return true; | 
|---|
|  | 95 | } | 
|---|
|  | 96 |  | 
|---|
| [a1510d] | 97 | static bool hasNoDuplicates(std::vector<atom*> atoms){ | 
|---|
| [b2cfdb] | 98 | std::set<int> found; | 
|---|
|  | 99 | std::vector<atom*>::iterator iter; | 
|---|
|  | 100 | for(iter=atoms.begin();iter!=atoms.end();++iter){ | 
|---|
|  | 101 | int id = (*iter)->getId(); | 
|---|
|  | 102 | if(found.count(id)) | 
|---|
|  | 103 | return false; | 
|---|
|  | 104 | found.insert(id); | 
|---|
|  | 105 | } | 
|---|
|  | 106 | return true; | 
|---|
|  | 107 | } | 
|---|
|  | 108 |  | 
|---|
| [a1510d] | 109 | static void operation(atom* _atom){ | 
|---|
| [b2cfdb] | 110 | AtomStub *atom = dynamic_cast<AtomStub*>(_atom); | 
|---|
|  | 111 | assert(atom); | 
|---|
|  | 112 | atom->doSomething(); | 
|---|
|  | 113 | } | 
|---|
|  | 114 |  | 
|---|
|  | 115 |  | 
|---|
|  | 116 | void manipulateAtomsTest::testManipulateSimple(){ | 
|---|
|  | 117 | ManipulateAtomsProcess *proc = World::get()->manipulateAtoms(boost::bind(operation,_1),"FOO",AllAtoms()); | 
|---|
|  | 118 | proc->call(); | 
|---|
|  | 119 | std::vector<atom*> allAtoms = World::get()->getAllAtoms(AllAtoms()); | 
|---|
|  | 120 | std::vector<atom*>::iterator iter; | 
|---|
|  | 121 | for(iter=allAtoms.begin();iter!=allAtoms.end();++iter){ | 
|---|
|  | 122 | AtomStub *atom; | 
|---|
|  | 123 | atom = dynamic_cast<AtomStub*>(*iter); | 
|---|
|  | 124 | assert(atom); | 
|---|
|  | 125 | CPPUNIT_ASSERT(atom->manipulated); | 
|---|
|  | 126 | } | 
|---|
|  | 127 | } | 
|---|
|  | 128 |  | 
|---|
|  | 129 | void manipulateAtomsTest::testManipulateExcluded(){ | 
|---|
|  | 130 | ManipulateAtomsProcess *proc = World::get()->manipulateAtoms(boost::bind(operation,_1),"FOO",AllAtoms() && !AtomById(ATOM_COUNT/2)); | 
|---|
|  | 131 | proc->call(); | 
|---|
|  | 132 | std::vector<atom*> allAtoms = World::get()->getAllAtoms(AllAtoms()); | 
|---|
|  | 133 | std::vector<atom*>::iterator iter; | 
|---|
|  | 134 | for(iter=allAtoms.begin();iter!=allAtoms.end();++iter){ | 
|---|
|  | 135 | AtomStub *atom; | 
|---|
|  | 136 | atom = dynamic_cast<AtomStub*>(*iter); | 
|---|
|  | 137 | assert(atom); | 
|---|
|  | 138 | if(atom->getId()!=(int)ATOM_COUNT/2) | 
|---|
|  | 139 | CPPUNIT_ASSERT(atom->manipulated); | 
|---|
|  | 140 | else | 
|---|
|  | 141 | CPPUNIT_ASSERT(!atom->manipulated); | 
|---|
|  | 142 | } | 
|---|
|  | 143 | } | 
|---|
|  | 144 |  | 
|---|
| [afb47f] | 145 | void manipulateAtomsTest::testObserver(){ | 
|---|
|  | 146 | countObserver *obs = new countObserver(); | 
|---|
|  | 147 | World::get()->signOn(obs); | 
|---|
|  | 148 | ManipulateAtomsProcess *proc = World::get()->manipulateAtoms(boost::bind(operation,_1),"FOO",AllAtoms() && !AtomById(ATOM_COUNT/2)); | 
|---|
|  | 149 | proc->call(); | 
|---|
|  | 150 |  | 
|---|
|  | 151 | CPPUNIT_ASSERT_EQUAL(1,obs->count); | 
|---|
|  | 152 | World::get()->signOff(obs); | 
|---|
|  | 153 | delete obs; | 
|---|
|  | 154 | } | 
|---|