33
33
helpers = [AptFacadeHelper, SimpleRepositoryHelper, BrokerServiceHelper]
39
self.store = PackageStore(self.makeFile())
40
self.config = PackageChangerConfiguration()
41
self.config.data_path = self.makeDir()
42
self.process_factory = StubProcessFactory()
43
self.twisted_reactor = FakeReactor()
44
reboot_required_filename = self.makeFile("reboot required")
45
os.mkdir(self.config.package_directory)
46
os.mkdir(self.config.binaries_path)
47
touch_file(self.config.update_stamp_filename)
48
self.changer = PackageChanger(
49
self.store, self.facade, self.remote, self.config,
50
process_factory=self.process_factory,
51
twisted_reactor=self.twisted_reactor,
52
reboot_required_filename=reboot_required_filename)
53
self.changer.update_notifier_stamp = "/Not/Existing"
54
service = self.broker_service
55
service.message_store.set_accepted_types(["change-packages-result",
58
result = super(AptPackageChangerTest, self).setUp()
59
return result.addCallback(set_up)
36
super(AptPackageChangerTest, self).setUp()
37
self.store = PackageStore(self.makeFile())
38
self.config = PackageChangerConfiguration()
39
self.config.data_path = self.makeDir()
40
self.process_factory = StubProcessFactory()
41
self.twisted_reactor = FakeReactor()
42
reboot_required_filename = self.makeFile("reboot required")
43
os.mkdir(self.config.package_directory)
44
os.mkdir(self.config.binaries_path)
45
touch_file(self.config.update_stamp_filename)
46
self.changer = PackageChanger(
47
self.store, self.facade, self.remote, self.config,
48
process_factory=self.process_factory,
49
twisted_reactor=self.twisted_reactor,
50
reboot_required_filename=reboot_required_filename)
51
self.changer.update_notifier_stamp = "/Not/Existing"
52
service = self.broker_service
53
service.message_store.set_accepted_types(["change-packages-result",
61
56
def set_pkg1_installed(self):
62
57
"""Return the hash of a package that is installed."""
1479
1474
self.broker_service.reactor.advance(100)
1480
1475
self.twisted_reactor.advance(10)
1481
1476
payloads = self.broker_service.exchanger._transport.payloads
1482
self.assertEqual(1, len(payloads))
1477
self.assertEqual(0, len(payloads))
1484
1479
[arguments] = self.process_factory.spawns
1485
1480
protocol = arguments[0]