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
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
|
#!/usr/bin/env python
'''Alpine/Chorus Client API Module'''
import logging
import requests
LOG = logging.Logger(name=__name__)
CONTENT_TYPE = 'application/x-www-form-urlencoded'
JSON_CONTENT_TYPE = 'application/json'
def login(username, password, session):
'''POST login request to chorus server'''
return _perform_http_method_(
session.config.get('alpine', 'host'), _login_(username, password))
def logout(session):
'''DELETE login request to chorus server'''
return _perform_http_method_(
session.config.get('alpine', 'host'),
_logout_(session.sid, session.cookies))
def check_login_status(session):
'''GET login request to chorus server'''
return _perform_http_method_(
session.config.get('alpine', 'host'),
_check_login_(session.sid, session.cookies))
def create_workfile(workspace_id, workfile_name, session):
'''POST new workfile to workspace'''
return _perform_http_method_(
session.config.get('alpine', 'host'),
_create_workfile_(workspace_id,
workfile_name,
session.sid,
session.cookies))
def update_workfile_version(userid, workfile_id, workfile, session):
'''POST new workfile version'''
return _perform_http_method_(
session.config.get('alpine', 'host'),
_update_workfile_version_(userid,
workfile_id,
workfile,
session.sid,
session.cookies))
def delete_workfile(workfile_id, session):
'''DELETE workfile'''
return _perform_http_method_(
session.config.get('alpine', 'host'),
_delete_workfile_(workfile_id, session.sid, session.cookies))
def _get_url_(host, endpoint=""):
'''Return the host and path for the chorus instance'''
return "http://%s/%s" % (host, endpoint)
def _perform_http_method_(host, request_data):
'''Perform IO operation to Chorus Server using request_data object'''
methods = {'GET': requests.get,
'POST': requests.post,
'DELETE': requests.delete,}
method = methods[request_data['method']]
response = method(_get_url_(host, request_data['url']),
params=request_data['params'],
headers=request_data['headers'],
cookies=request_data['cookies'],
data=request_data['data'])
LOG.info("Request: %s status code: %d",
request_data['url'],
response.status_code)
return response
def _login_(username, password):
'''Create Request Data for ChorusSession'''
return {
'data': {
'username': username,
'password': password,
},
'headers': {
'content-type': CONTENT_TYPE,
},
'params': {
'session_id': '',
},
'cookies': None,
'url': '/sessions?session_id=',
'method': 'POST',
}
def _check_login_(_, cookies):
'''Create request data for check login check'''
return {
'data': None,
'params': None,
'headers': {
'content-type': CONTENT_TYPE,
},
'cookies': cookies,
'url': '/sessions',
'method': 'GET',
}
def _logout_(sid, cookies):
'''Create request data for ChorusSession'''
return {
'data': None,
'headers': {
'content-type': CONTENT_TYPE,
},
'params': {
'session_id': sid,
},
'cookies': cookies,
'url': '/sessions',
'method': 'DELETE',
}
def _create_workfile_(workspace_id, workfile_name, sid, cookies):
'''Create request data for workfile creation'''
return {
'data': {
'workspace_id': workspace_id,
'file_name': workfile_name,
},
'headers': {
'content-type': CONTENT_TYPE,
},
'params': {
'session_id': sid,
},
'cookies': cookies,
'url': '/workspaces/%s/workfiles' % workspace_id,
'method': 'POST',
}
def _update_workfile_version_(userid, workfile_id, workfile, sid, cookies):
'''Create request data to update a workfile'''
return {
'data': {
'owner_id': userid,
'modifier_id': userid,
'commit_message': 'git commit',
'content': workfile,
},
'params': {
'session_id': sid,
},
'headers': {
'content-type': CONTENT_TYPE,
},
'cookies': cookies,
'url': '/workfiles/%s/versions' % workfile_id,
'method': 'POST',
}
def _delete_workfile_(workfile_id, sid, cookies):
'''Create request data to delete a workfile'''
return {
'data': None,
'params': {
'session_id': sid,
},
'headers': {
'content-type': CONTENT_TYPE,
},
'cookies': cookies,
'url': '/workfiles/%s' % workfile_id,
'method': 'DELETE',
}
|
