1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
#!/usr/bin/python3
# -*- coding: utf-8 -*-
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
#
# Authors:
# @author: David Blaisonneau <david.blaisonneau@orange.com>
# @author: Arnaud Morin <arnaud1.morin@orange.com>
from opensteak.foreman_objects.objects import ForemanObjects
from opensteak.foreman_objects.itemHost import ItemHost
import time
class Hosts(ForemanObjects):
"""
Host sclass
"""
objName = 'hosts'
payloadObj = 'host'
def list(self):
""" Function list
list the hosts
@return RETURN: List of ItemHost objects
"""
return list(map(lambda x: ItemHost(self.api, x['id'], x),
self.api.list(self.objName)))
def __getitem__(self, key):
""" Function __getitem__
Get an host
@param key: The host name or ID
@return RETURN: The ItemHost object of an host
"""
return ItemHost(self.api, key, self.api.get(self.objName, key))
def __printProgression__(self, status, msg, eol):
""" Function __printProgression__
Print the creation progression or not
It uses the foreman.printer lib
@param status: Status of the message
@param msg: Message
@param eol: End Of Line (to get a new line or not)
@return RETURN: None
"""
if self.printHostProgress:
self.__printProgression__(status, msg, eol=eol)
def createVM(self, key, attributes, printHostProgress=False):
""" Function createVM
Create a Virtual Machine
The creation of a VM with libVirt is a bit complexe.
We first create the element in foreman, the ask to start before
the result of the creation.
To do so, we make async calls to the API and check the results
@param key: The host name or ID
@param attributes:The payload of the host creation
@param printHostProgress: The link to opensteak.printerlib
to print or not the
progression of the host creation
@return RETURN: The API result
"""
self.printHostProgress = printHostProgress
self.async = True
# Create the VM in foreman
self.__printProgression__('In progress',
key + ' creation: push in Foreman', eol='\r')
future1 = self.api.create('hosts', attributes, async=True)
# Wait before asking to power on the VM
sleep = 5
for i in range(0, sleep):
time.sleep(1)
self.__printProgression__('In progress',
key + ' creation: start in {0}s'
.format(sleep - i),
eol='\r')
# Power on the VM
self.__printProgression__('In progress',
key + ' creation: starting', eol='\r')
future2 = self[key].powerOn()
# Show Power on result
if future2.result().status_code is 200:
self.__printProgression__('In progress',
key + ' creation: wait for end of boot',
eol='\r')
else:
self.__printProgression__(False,
key + ' creation: Error',
failed=str(future2.result().status_code))
return False
# Show creation result
if future1.result().status_code is 200:
self.__printProgression__('In progress',
key + ' creation: created',
eol='\r')
else:
self.__printProgression__(False,
key + ' creation: Error',
failed=str(future1.result().status_code))
return False
# Wait for puppet catalog to be applied
loop_stop = False
while not loop_stop:
status = self[key].getStatus()
if status == 'No Changes' or status == 'Active':
self.__printProgression__(True,
key + ' creation: provisioning OK')
loop_stop = True
elif status == 'Error':
self.__printProgression__(False,
key + ' creation: Error',
failed="Error during provisioning")
loop_stop = True
return False
else:
self.__printProgression__('In progress',
key + ' creation: provisioning ({})'
.format(status),
eol='\r')
time.sleep(5)
return True
|
