forked from Sysdeploy/WaitForSyncthing
Compare commits
No commits in common. "sync" and "main" have entirely different histories.
|
@ -1,69 +0,0 @@
|
|||
import os
|
||||
import xml.etree.ElementTree as ET
|
||||
import requests
|
||||
|
||||
# Global variables for API access - These variables do not change and are set once when the app starts.
|
||||
API_URL = os.getenv('SYNCTHING_API_URL', 'http://127.0.0.1:8384')
|
||||
API_KEY = None
|
||||
|
||||
def get_api_key(config_file):
|
||||
""" Retrieve the API key from the local Syncthing configuration XML file. """
|
||||
try:
|
||||
tree = ET.parse(config_file)
|
||||
root = tree.getroot()
|
||||
return root.find('.//apikey').text
|
||||
except FileNotFoundError:
|
||||
raise Exception("Configuration file not found.")
|
||||
except AttributeError:
|
||||
raise Exception("API key not found in the configuration file.")
|
||||
|
||||
|
||||
def syncthing_request(url):
|
||||
""" Generic function for Syncthing API GET requests. """
|
||||
headers = {'X-Api-Key': API_KEY}
|
||||
response = requests.get(url, headers=headers)
|
||||
response.raise_for_status()
|
||||
return response.json()
|
||||
|
||||
|
||||
def check_folder_idle(folder_id):
|
||||
""" Check if the specified folder is idle. """
|
||||
status_url = f"{API_URL}/rest/db/status?folder={folder_id}"
|
||||
status = syncthing_request(status_url)
|
||||
return status['state'] == 'idle'
|
||||
|
||||
def long_poll_events(last_event_id, folder_id):
|
||||
""" Long poll the events endpoint filtering by the last known event ID and specific events. """
|
||||
events_url = f"{API_URL}/rest/events?since={last_event_id}&events=StateChanged&timeout=60"
|
||||
events = syncthing_request(events_url)
|
||||
return [event for event in events if event['data']['folder'] == folder_id]
|
||||
|
||||
def main():
|
||||
global API_KEY
|
||||
folder_id = os.getenv('SYNCTHING_FOLDER_ID')
|
||||
config_file = os.getenv('SYNCTHING_CONFIG_FILE')
|
||||
|
||||
if not folder_id:
|
||||
raise ValueError("Folder ID must be provided as an environment variable.")
|
||||
|
||||
API_KEY = get_api_key(config_file)
|
||||
|
||||
# Start by getting the latest event ID
|
||||
current_events = syncthing_request(f"{API_URL}/rest/events?limit=1")
|
||||
last_event_id = current_events[0]['id'] if current_events else 0
|
||||
|
||||
# Check initial state
|
||||
is_idle = check_folder_idle(folder_id)
|
||||
|
||||
while not is_idle:
|
||||
events = long_poll_events(last_event_id, folder_id)
|
||||
for event in events:
|
||||
last_event_id = event['id']
|
||||
is_idle = event['data']['to'] == 'idle'
|
||||
if is_idle:
|
||||
print("Folder transitioned to idle.")
|
||||
break
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
main()
|
Loading…
Reference in New Issue
Block a user