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
|
#
# Author:: Adam Edwards (<adamed@getchef.com>)
#
# Copyright:: 2014, Chef Software, Inc.
#
# 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.
#
require 'chef/util/powershell/cmdlet'
class Chef::Util::DSC
class LocalConfigurationManager
def initialize(node, configuration_path)
@node = node
@configuration_path = configuration_path
clear_execution_time
end
def test_configuration(configuration_document)
status = run_configuration_cmdlet(configuration_document)
configuration_update_required?(status.return_value)
end
def set_configuration(configuration_document)
run_configuration_cmdlet(configuration_document, true)
end
def last_operation_execution_time_seconds
if @operation_start_time && @operation_end_time
@operation_end_time - @operation_start_time
end
end
private
def run_configuration_cmdlet(configuration_document, apply_configuration = false)
Chef::Log.debug("DSC: Calling DSC Local Config Manager to #{apply_configuration ? "set" : "test"} configuration document.")
test_only_parameters = ! apply_configuration ? '-whatif; if (! $?) { exit 1 }' : ''
start_operation_timing
command_code = "$ProgressPreference = 'SilentlyContinue';start-dscconfiguration -path #{@configuration_path} -wait -force #{test_only_parameters}"
status = nil
begin
save_configuration_document(configuration_document)
cmdlet = ::Chef::Util::Powershell::Cmdlet.new(@node, "#{command_code}")
status = cmdlet.run
ensure
end_operation_timing
remove_configuration_document
if last_operation_execution_time_seconds
Chef::Log.debug("DSC: DSC operation completed in #{last_operation_execution_time_seconds} seconds.")
end
end
Chef::Log.debug("DSC: Completed call to DSC Local Config Manager")
status
end
def configuration_update_required?(what_if_output)
Chef::Log.debug("DSC: DSC returned the following '-whatif' output from test operation:\n#{what_if_output}")
parse_what_if_output(what_if_output)
end
def save_configuration_document(configuration_document)
::FileUtils.mkdir_p(@configuration_path)
::File.open(configuration_document_path, 'wb') do | file |
file.write(configuration_document)
end
end
def remove_configuration_document
::FileUtils.rm(configuration_document_path)
end
def configuration_document_path
File.join(@configuration_path,'..mof')
end
def parse_what_if_output(what_if_output)
# What-if output for start-dscconfiguration contains lines that look like one of the following:
#
# What if: [SEA-ADAMED1]: LCM: [ Start Set ] [[Group]chef_dsc]
# What if: [SEA-ADAMED1]: [[Group]chef_dsc] Performing the operation "Add" on target "Group: demo1"
#
# The second line lacking the 'LCM:' is what happens if there is a change required to make the system consistent with the resource.
# Such a line without LCM is only present if an update to the system is required. Therefore, we test each line below
# to see if it is missing the LCM, and declare that an update is needed if so.
has_change_line = false
what_if_output.lines.each do |line|
if (line =~ /.+\:\s+\[\S*\]\:\s+LCM\:/).nil?
has_change_line = true
break
end
end
has_change_line
end
def clear_execution_time
@operation_start_time = nil
@operation_end_time = nil
end
def start_operation_timing
clear_execution_time
@operation_start_time = Time.now
end
def end_operation_timing
@operation_end_time = Time.now
end
end
end
|
