midas/playbooks
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

library/calendar_sync.py aktualisiert

Browse Source
This commit is contained in:
midas
2025-07-12 08:29:59 +00:00
parent b5434c7441
commit 951a08d651
1 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
library/calendar_sync.py
View File

@ -1,5 +1,6 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
import sys
from ansible.module_utils.basic import AnsibleModule from ansible.module_utils.basic import AnsibleModule
from caldav import DAVClient from caldav import DAVClient
import vobject import vobject
@ -10,8 +11,12 @@ def fetch_ics_events(url, user=None, password=None):
try: try:
response = requests.get(url, auth=(user, password) if user else None) response = requests.get(url, auth=(user, password) if user else None)
response.raise_for_status() response.raise_for_status()
cal = vobject.readOne(response.text) # Alle VEVENTs aus ICS-Datei extrahieren
return [comp for comp in cal.components() if comp.name == 'VEVENT'] events = []
for component in vobject.readComponents(response.text):
if hasattr(component, "vevent"):
events.append(component.vevent)
return events
except Exception as e: except Exception as e:
raise Exception(f"ICS-Fehler: {str(e)}") raise Exception(f"ICS-Fehler: {str(e)}")
@ -47,20 +52,21 @@ def sync_ics_to_caldav(module):
module.params['verify_ssl'] module.params['verify_ssl']
) )
# Bestehende Events aus dem Zielkalender einlesen und UIDs extrahieren # Bestehende Events analysieren
existing_events = {} existing_events = {}
for event in target_cal.events(): for event in target_cal.events():
try: try:
vobj = vobject.readOne(event.data) for vobj in vobject.readComponents(event.data):
uid = str(vobj.vevent.uid) if hasattr(vobj, "vevent"):
existing_events[uid] = event uid = str(vobj.vevent.uid)
existing_events[uid] = event
except Exception as e: except Exception as e:
raise Exception(f"Fehler beim Parsen eines bestehenden Events: {str(e)}") raise Exception(f"Fehler beim Parsen eines bestehenden Events: {str(e)}")
changed = False changed = False
results = {'added': [], 'updated': [], 'removed': []} results = {'added': [], 'updated': [], 'removed': []}
# Neue ICS-Events einfügen oder updaten # Neue Events hinzufügen oder aktualisieren
for vevent in ics_events: for vevent in ics_events:
uid = str(vevent.uid) uid = str(vevent.uid)
ical_data = vevent.serialize() ical_data = vevent.serialize()
@ -75,7 +81,7 @@ def sync_ics_to_caldav(module):
results['updated'].append(uid) results['updated'].append(uid)
changed = True changed = True
# Nicht mehr vorhandene Events löschen, wenn gewünscht # Entfernen von Events, wenn aktiviert
if module.params['purge']: if module.params['purge']:
current_uids = {str(e.uid) for e in ics_events} current_uids = {str(e.uid) for e in ics_events}
for uid in set(existing_events.keys()) - current_uids: for uid in set(existing_events.keys()) - current_uids: