~mpontillo/maas/beaconing--replies-from-maas--wip

« back to all changes in this revision

Viewing changes to src/maasserver/triggers/tests/test_system_listener.py

Committer: Mike Pontillo
Date: 2017-06-19 22:29:18 UTC
mfrom: (6085.2.8 maas)
Revision ID: mike.pontillo@canonical.com-20170619222918-4pzgkvgr9b7cbob2

Merge trunk.

files added:
src/maasserver/static/js/angular/3rdparty/vs-repeat.js

src/provisioningserver/drivers/osystem/rhel.py

src/provisioningserver/drivers/osystem/tests/test_rhel.py

files modified:
docs/development/notifications.rst

src/apiclient/testing/django.py

src/maasserver/api/doc_handler.py

src/maasserver/api/tests/test_doc.py

src/maasserver/api/tests/test_interfaces.py

src/maasserver/api/tests/test_maas.py

src/maasserver/compose_preseed.py

src/maasserver/djangosettings/settings.py

src/maasserver/forms/__init__.py

src/maasserver/forms/interface.py

src/maasserver/forms/settings.py

src/maasserver/forms/tests/test_interface.py

src/maasserver/models/config.py

src/maasserver/models/largefile.py

src/maasserver/models/tests/test_blockdevice.py

src/maasserver/models/tests/test_physicalblockdevice.py

src/maasserver/preseed.py

src/maasserver/proxyconfig.py

src/maasserver/service_monitor.py

src/maasserver/static/js/angular/controllers/fabric_details.js

src/maasserver/static/js/angular/controllers/tests/test_fabric_details.js

src/maasserver/static/js/angular/maas.js

src/maasserver/static/partials/dashboard.html

src/maasserver/static/partials/fabric-details.html

src/maasserver/static/partials/machines-table.html

src/maasserver/static/partials/networks-list.html

src/maasserver/static/partials/node-details.html *

src/maasserver/static/partials/node-events.html

src/maasserver/static/partials/nodes-list.html

src/maasserver/static/partials/pods-list.html

src/maasserver/templates/maasserver/js-conf.html

src/maasserver/tests/test_compose_preseed.py

src/maasserver/tests/test_preseed.py

src/maasserver/tests/test_proxyconfig.py

src/maasserver/tests/test_service_monitor.py

src/maasserver/triggers/system.py

src/maasserver/triggers/testing.py

src/maasserver/triggers/tests/test_init.py

src/maasserver/triggers/tests/test_system_listener.py

src/maasserver/urls.py

src/maasserver/utils/__init__.py

src/maasserver/utils/osystems.py

src/maasserver/utils/tests/test_osystems.py

src/maasserver/utils/tests/test_views.py

src/maasserver/utils/views.py

src/maasserver/views/account.py

src/maasserver/views/combo.py

src/maasserver/views/prefs.py

src/maasserver/views/settings.py

src/maasserver/views/tests/test_general.py

src/maasserver/websockets/handlers/tests/test_machine.py

src/provisioningserver/drivers/osystem/__init__.py

src/provisioningserver/drivers/osystem/centos.py

src/provisioningserver/drivers/osystem/tests/test_centos.py

src/provisioningserver/templates/proxy/maas-proxy.conf.template

src/provisioningserver/utils/service_monitor.py

src/provisioningserver/utils/tests/test_service_monitor.py

Show diffs side-by-side

added added

removed removed

src/maasserver/triggers/tests/test_system_listener.py

3713

% (json.dumps(kms_host_old), json.dumps(kms_host_new))))

3714

3715

3716

class TestProxySubnetListener(

3716

class TestProxyListener(

3717

MAASTransactionServerTestCase, TransactionalHelpersMixin):

3718

"""End-to-end test for the proxy triggers code."""

3719

3787

yield dv.get(timeout=2)

3788

finally:

3789

yield listener.stopService()

3790

3791

@wait_for_reactor

3792

@inlineCallbacks

3793

def test_sends_message_for_config_insert_enable_proxy(self):

3794

yield deferToDatabase(register_system_triggers)

3795

dv = DeferredValue()

3796

listener = self.make_listener_without_delay()

3797

listener.register(

3798

"sys_proxy", lambda *args: dv.set(args))

3799

yield listener.startService()

3800

try:

3801

yield deferToDatabase(self.create_config, "enable_proxy", True)

3802

yield dv.get(timeout=2)

3803

finally:

3804

yield listener.stopService()

3805

3806

@wait_for_reactor

3807

@inlineCallbacks

3808

def test_sends_message_for_config_insert_use_peer_proxy(self):

3809

yield deferToDatabase(register_system_triggers)

3810

dv = DeferredValue()

3811

listener = self.make_listener_without_delay()

3812

listener.register(

3813

"sys_proxy", lambda *args: dv.set(args))

3814

yield listener.startService()

3815

try:

3816

yield deferToDatabase(self.create_config, "use_peer_proxy", True)

3817

yield dv.get(timeout=2)

3818

finally:

3819

yield listener.stopService()

3820

3821

@wait_for_reactor

3822

@inlineCallbacks

3823

def test_sends_message_for_config_insert_http_proxy(self):

3824

yield deferToDatabase(register_system_triggers)

3825

dv = DeferredValue()

3826

listener = self.make_listener_without_delay()

3827

listener.register(

3828

"sys_proxy", lambda *args: dv.set(args))

3829

yield listener.startService()

3830

try:

3831

yield deferToDatabase(

3832

self.create_config, "http_proxy", "http://proxy.example.com")

3833

yield dv.get(timeout=2)

3834

finally:

3835

yield listener.stopService()

3836

3837

@wait_for_reactor

3838

@inlineCallbacks

3839

def test_sends_message_for_config_update_enable_proxy(self):

3840

yield deferToDatabase(register_system_triggers)

3841

yield deferToDatabase(self.create_config, "enable_proxy", True)

3842

dv = DeferredValue()

3843

listener = self.make_listener_without_delay()

3844

listener.register(

3845

"sys_proxy", lambda *args: dv.set(args))

3846

yield listener.startService()

3847

try:

3848

yield deferToDatabase(self.set_config, "enable_proxy", False)

3849

yield dv.get(timeout=2)

3850

finally:

3851

yield listener.stopService()

3852

3853

@wait_for_reactor

3854

@inlineCallbacks

3855

def test_sends_message_for_config_update_use_peer_proxy(self):

3856

yield deferToDatabase(register_system_triggers)

3857

yield deferToDatabase(self.create_config, "use_peer_proxy", True)

3858

dv = DeferredValue()

3859

listener = self.make_listener_without_delay()

3860

listener.register(

3861

"sys_proxy", lambda *args: dv.set(args))

3862

yield listener.startService()

3863

try:

3864

yield deferToDatabase(self.set_config, "use_peer_proxy", False)

3865

yield dv.get(timeout=2)

3866

finally:

3867

yield listener.stopService()

3868

3869

@wait_for_reactor

3870

@inlineCallbacks

3871

def test_sends_message_for_config_update_http_proxy(self):

3872

yield deferToDatabase(register_system_triggers)

3873

yield deferToDatabase(

3874

self.create_config, "http_proxy", "http://proxy1.example.com")

3875

dv = DeferredValue()

3876

listener = self.make_listener_without_delay()

3877

listener.register(

3878

"sys_proxy", lambda *args: dv.set(args))

3879

yield listener.startService()

3880

try:

3881

yield deferToDatabase(

3882

self.set_config, "http_proxy", "http://proxy2.example.com")

3883

yield dv.get(timeout=2)

3884

finally:

3885

yield listener.stopService()

Older »