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
|
/*-
* ============LICENSE_START==========================================
* OPENECOMP - DCAE
* ===================================================================
* Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
* ===================================================================
* 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.
* ============LICENSE_END============================================
*/
import org.yaml.snakeyaml.Yaml;
import groovy.text.SimpleTemplateEngine
import groovy.io.FileType
import static org.openecomp.ncomp.sirius.manager.console.Utils.*;
import org.openecomp.dcae.controller.platform.servers.controller.DcaeDcaePlatformControllerConsole
server = new DcaeDcaePlatformControllerConsole("console.properties","localhost")
def cli = new CliBuilder(usage:'dcae-controller.sh wait-for OPTIONS')
cli.p(longOpt:'path', args:1, 'Resource Path')
cli.e(longOpt:'exists', args:0, 'Object Exists')
cli.a(longOpt:'attribute', args:1, 'Attribute')
cli.m(longOpt:'match', args:1, 'Match')
cli.n(longOpt:'isNull', args:0, 'Is Null')
cli.N(longOpt:'isNotNull', args:0, 'Is not Null')
cli.f(longOpt:'frequency', args:1, 'Polling Frequency (seconds)')
cli.t(longOpt:'timeout', args:1, 'Timeout (seconds)')
cli._(longOpt:'debug', args:0, 'Debug')
cli.v(longOpt:'verbose', args:0, 'Verbose')
def options = cli.parse(args)
if (args.length == 0 ) {
cli.usage()
System.exit(1)
}
def timeout = options.timeout ? Long.parseLong(options.timeout) * 1000 : 300000 // default 5 min
def frequency = options.frequency ? Long.parseLong(options.frequency) * 1000 : 30000 // default 30 seconds
def path = options.path ? options.path : "/" // default 30 seconds
Date start = new Date()
def status = "UNKNOWN"
while (new Date().time < start.time + timeout) {
def o = null
try { o = server.list(path,0) } catch (e) {
if (options.debug) println "LISTING error: $e"
}
if (options.debug) {
if (o)
println "object is ${object2json(o).toString(2)}"
else
println "object is NULL"
}
if ( ! options.exists && o == null) {
println "Error: caller expect the object to exists but it does not: $path"
System.exit(2)
}
if (options.exists && o == null) {
// need to keep waiting
status = "Object does not exists: $path"
}
else {
if ( ! options.attribute ) System.exit(0)
def a = options.attribute
def v = o[a]
if (options.isNull) {
if (v == null) System.exit(0) else status = "Attribute not null: $path@$a"
}
if (options.isNotNull) {
if (v != null) System.exit(0) else status = "Attribute null: $path@$a"
}
if (options.match) {
if ("$v" == options.match) System.exit(0) else status = "Attribute match: $path@$a '$v' != '$options.match'"
}
}
if (options.verbose)
println "Waiting: $status : waited ${new Date().time-start.time} milliseconds"
Thread.sleep(frequency)
}
println "Error: Timeout: $status : waited ${new Date().time-start.time} milliseconds"
System.exit(2)
|
