blob: e97fbdab609ff5adea85091fa56cb7dec56a1292 [file] [log] [blame]
Gabe Black4c040b72016-11-17 22:35:04 +00001import os
2import sys
3from django.db.models import Q, F
4from services.activetest.models import ActiveTestService, ActiveTestTenant
5from synchronizers.base.SyncInstanceUsingAnsible import SyncInstanceUsingAnsible
6
7parentdir = os.path.join(os.path.dirname(__file__), "..")
8sys.path.insert(0, parentdir)
9
10class SyncActiveTestTenant(SyncInstanceUsingAnsible):
11
12 provides = [ActiveTestTenant]
13
14 observes = ActiveTestTenant
15
16 requested_interval = 0
17
18 template_name = "activetesttenant_playbook.yaml"
19
20 service_key_name = "/opt/xos/synchronizers/activetest/activetest_private_key"
21
22 def __init__(self, *args, **kwargs):
23 super(SyncActiveTestTenant, self).__init__(*args, **kwargs)
24
25 def fetch_pending(self, deleted):
26
27 if (not deleted):
28 objs = ActiveTestTenant.get_tenant_objects().filter(
29 Q(enacted__lt=F('updated')) | Q(enacted=None), Q(lazy_blocked=False))
30 else:
31 # If this is a deletion we get all of the deleted tenants..
32 objs = ActiveTestTenant.get_deleted_tenant_objects()
33
34 return objs
35
36 def get_activetestservice(self, o):
37 if not o.provider_service:
38 return None
39
40 activetestservice = ActiveTestService.get_service_objects().filter(id=o.provider_service.id)
41
42 if not activetestservice:
43 return None
44
45 return activetestservice[0]
46
47 # Gets the attributes that are used by the Ansible template but are not
48 # part of the set of default attributes.
49 def get_extra_attributes(self, o):
50 return { "public_ip": o.public_ip }
51
52