swapnil/ansible-modules-syncthing
1
0
Fork 0
forked from Sysdeploy/ansible-modules-syncthing
Code Pull Requests Activity

Extract fetching data from the REST API

Browse Source
This commit is contained in:
Borjan Tchakaloff 2021-02-18 17:33:11 +01:00
parent c7aa08f97a
commit c3cd1e450d
1 changed files with 23 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
library/storage/syncthing/syncthing_folder.py
View File

@ -106,7 +106,7 @@ from xml.etree.ElementTree import parse
from ansible.module_utils.basic import AnsibleModule from ansible.module_utils.basic import AnsibleModule
from ansible.module_utils.urls import fetch_url, url_argument_spec from ansible.module_utils.urls import fetch_url, url_argument_spec
SYNCTHING_API_URI = "/rest/system/config" SYNCTHING_API_BASE_URI = "/rest"
if platform.system() == 'Windows': if platform.system() == 'Windows':
DEFAULT_ST_CONFIG_LOCATION = '%localappdata%/Syncthing/config.xml' DEFAULT_ST_CONFIG_LOCATION = '%localappdata%/Syncthing/config.xml'
elif platform.system() == 'Darwin': elif platform.system() == 'Darwin':
@ -115,8 +115,8 @@ else:
DEFAULT_ST_CONFIG_LOCATION = '$HOME/.config/syncthing/config.xml' DEFAULT_ST_CONFIG_LOCATION = '$HOME/.config/syncthing/config.xml'
def make_headers(host, api_key): def make_headers(host, api_key, resource):
url = '{}{}'.format(host, SYNCTHING_API_URI) url = '{}{}/{}'.format(host, SYNCTHING_API_BASE_URI, resource)
headers = {'X-Api-Key': api_key } headers = {'X-Api-Key': api_key }
return url, headers return url, headers
@ -135,12 +135,18 @@ def get_key_from_filesystem(module):
module.fail_json(msg="Auto-configuration failed. Please specify" module.fail_json(msg="Auto-configuration failed. Please specify"
"the API key manually.") "the API key manually.")
# Fetch Syncthing configuration def get_data_from_rest_api(module, resource):
def get_config(module): url, headers = make_headers(
url, headers = make_headers(module.params['host'], module.params['api_key']) module.params['host'], module.params['api_key'], resource
)
resp, info = fetch_url( resp, info = fetch_url(
module, url, data=None, headers=headers, module,
method='GET', timeout=module.params['timeout']) url,
data=None,
headers=headers,
method='GET',
timeout=module.params['timeout']
)
if not info or info['status'] != 200: if not info or info['status'] != 200:
result['response'] = info result['response'] = info
@ -155,6 +161,10 @@ def get_config(module):
return json.loads(content) return json.loads(content)
# Fetch Syncthing configuration
def get_config(module):
return get_data_from_rest_api(module, 'system/config')
# Get the device name -> device ID mapping. # Get the device name -> device ID mapping.
def get_devices_mapping(config): def get_devices_mapping(config):
return { return {
@ -170,7 +180,11 @@ def get_folder_config(folder_id, config):
# Post the new configuration to Syncthing API # Post the new configuration to Syncthing API
def post_config(module, config, result): def post_config(module, config, result):
url, headers = make_headers(module.params['host'], module.params['api_key']) url, headers = make_headers(
module.params['host'],
module.params['api_key'],
'system/config',
)
headers['Content-Type'] = 'application/json' headers['Content-Type'] = 'application/json'
result['msg'] = config result['msg'] = config