wsadmin/wsadmin.py at master · lordtor/wsadmin · GitHub

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
143
144
145
146
#!/usr/bin/python
# -*- coding: utf-8 -*-
# Copyright (c) 2015 Amir Mofasser <amir.mofasser@gmail.com> (@amimof)

# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
DOCUMENTATION = """
module: wsadmin
version_added: "1.0.3"
author: "Yuriy Rumyantsev (SBT-Rumyantsev-YUN@mail.ca.sbrf.ru)"
"""

EXAMPLES = """
# Run:
"""
import os
import subprocess
import platform
import datetime
import random
import string

def random_generator(size, chars=string.ascii_letters + string.digits):
    return ''.join(random.choice(chars) for _ in range(size))

def main():

    # Read arguments
    module = AnsibleModule(
        argument_spec = dict(
            wasdir = dict(default='', required=False),
            washost = dict(default='', required=False),
            wasport = dict(default='', required=False),
            conntype = dict(default='', required=False),
            lang = dict(default='', required=False),
            was_params = dict(default='', required=False),
            tracefile = dict(default='', required=False),
            username = dict(default='', required=False),
            password = dict(default='', required=False, no_log=True),
            script = dict(default='', required=False),
            script_params = dict(default='', required=False),
            was_command = dict(default='', required=False),
            accept_cert = dict(default=False, required=False)
        )
    )

    wasdir = module.params['wasdir']
    washost = module.params['washost']
    wasport = module.params['wasport']
    conntype = module.params['conntype']
    lang = module.params['lang']
    was_params = module.params['was_params']
    tracefile = module.params['tracefile']
    username = module.params['username']
    d = str(random_generator(5))
    os.environ[d] = module.params['password']
    script = module.params['script']
    script_params = module.params['script_params']
    was_command = module.params['was_command']
    accept_cert = module.params['accept_cert']
    if os.environ[d]:
        new_password = " -password $" + d + " "
    else:
        new_password = ""
    argument = ""
    if script != "" and was_command != "":
        module.fail_json(msg="Use only  one parameter script or command")
    else:
        argument = ""
        if script != "":
            argument = " -f " + script + script_params
        if was_command != "":
            argument = " -c " + was_command
    username = " -username " + username + " " if username != "" else username
    conntype = " -conntype " + conntype + " " if conntype != "" else conntype
    lang = " -lang " + lang + " " if lang != "" else " -lang jython "
    washost = " -host  " + washost + " " if washost != "" else washost
    wasport = " -port " + wasport + " " if wasport != "" else wasport
    tracefile = " -tracefile " + tracefile + " " if tracefile != "" else tracefile
    if accept_cert.upper() is not True:
        if new_password != "":
            raw_command_line = os.path.join(wasdir,'wsadmin.sh')+" " + lang + conntype + washost + wasport + was_params + username + new_password + tracefile + argument
        else:
            raw_command_line = os.path.join(wasdir,'wsadmin.sh')+" " + lang + conntype + washost + wasport + was_params + username + tracefile + argument
    else:
        raw_command_line = "echo y| " + os.path.join(wasdir,'wsadmin.sh')+" "  + lang + conntype + washost + wasport + was_params + argument

    if wasdir:
        wasdir = os.path.abspath(wasdir)
        os.chdir(wasdir)

    child = subprocess.Popen(
        [raw_command_line],
        shell=True,
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE
    )
    stdout_value, stderr_value = child.communicate()

    if child.returncode != 0:
        if script != "" and accept_cert is not True:
            module.fail_json(
                changed=False,
                msg="Failed executing wsadmin script:  {0} ".format(script),
                stdout=stdout_value,
                stderr=stderr_value
            )
        elif was_command != "" and accept_cert is not True:
            module.fail_json(
                changed=False,
                msg="Failed executing wsadmin command:  {0} ".format(was_command),
                stdout=stdout_value,
                stderr=stderr_value
            )
        elif accept_cert is True:
            module.fail_json(
                changed=True,
                msg="Failed  accept certificate wsadmin ".format(),
                stdout=stdout_value,
                stderr=stderr_value)
    else:
        if script != "" and accept_cert is not True:
            module.exit_json(
                changed=True,
                msg="Script executed successfully: {0}".format(script),
                stdout=stdout_value,
                stderr=stderr_value,
            )
        elif was_command != "" and accept_cert is not True:
            module.fail_json(
                changed=True,
                msg="Wsadmin command executed successfully:  {0} ".format(was_command),
                stdout=stdout_value,
                stderr=stderr_value
            )
        elif accept_cert is True:
            module.fail_json(
                changed=True,
                msg="Wsadmin accept certificate successfully ".format(),
                stdout=stdout_value,
                stderr=stderr_value)


# import module snippets
from ansible.module_utils.basic import *
if __name__ == '__main__':
    main()