nextcloud_ics_sync/nextcloud_ics_sync.py at master · MrBE4R/nextcloud_ics_sync · GitHub

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
#!/usr/bin/env python3
import configparser, logging, requests, traceback
from icalendar.cal import Calendar
from icalendar.prop import vText


log_option = {
    'format': '[%(asctime)s] [%(levelname)s] %(message)s',
    'level': getattr(logging, 'INFO')
}

logging.basicConfig(**log_option)
logging.getLogger("requests").setLevel(logging.WARNING)


CALDAVURL = '%sremote.php/dav/calendars/%s/%s'

def events_are_different(event1, event2):
  # ---  Compares two VEVENTs for relevant differences.
    fields = ['DTSTART', 'DTEND', 'SUMMARY', 'LOCATION', 'DESCRIPTION']
    for f in fields:
        v1 = event1.get(f)
        v2 = event2.get(f)
        if (v1 and not v2) or (v2 and not v1):
            return True
        if v1 and v2 and v1.to_ical() != v2.to_ical():
            return True
    return False

def do_import(username, password, calendar, server, ics_url, ics_username, ics_password):
    logging.info('  Working with calendar %s...' % calendar)
    base_url = CALDAVURL % (server, username, calendar)

    target_fetch_url = '%s?export' % base_url
    r = requests.get(target_fetch_url, auth=(username, password))
    r.raise_for_status()
    try:
        target_cal = Calendar.from_ical(r.text)
    except ValueError as e:
        logging.error('    Warning: Could not parse iCal (%s)' % target_fetch_url)
        logging.error(e)
        return

    target_events = {bytes.decode(e['UID'].to_ical()).replace('\'', '').replace('/', 'slash'): e
                     for e in target_cal.walk('VEVENT')}
    existing_uids = set(target_events.keys())

    sourceRequest = requests.get(ics_url, auth=(ics_username, ics_password))
    sourceRequest.encoding = 'utf-8'
    sourceContent = sourceRequest.text
    c = Calendar.from_ical(sourceContent)

    distant_events = {bytes.decode(e['UID'].to_ical()).replace('\'', '').replace('/', 'slash'): e
                      for e in c.walk('VEVENT')}
    distant_uids = set(distant_events.keys())


    imported_uids = []
    for uid, e in distant_events.items():
        name = bytes.decode(e['SUMMARY'].to_ical()) if isinstance(e['SUMMARY'], vText) else str(e['SUMMARY'])
        cal = Calendar()
        cal.add_component(e)
        url = '%s/%s.ics' % (base_url, uid)

    # --- NEW: If event exists and has changed, update ---
        if uid in existing_uids:
            existing = target_events[uid]
            if events_are_different(e, existing):
                r = requests.put(url, data=cal.to_ical(), auth=(username, password),
                                 headers={'content-type': 'text/calendar; charset=UTF-8'})
                if r.status_code in (201, 204):
                    logging.info('   Updated: %s (%s)' % (uid, name))
                else:
                    r.raise_for_status()
            else:
                logging.debug('   No changes: %s (%s)' % (uid, name))
        else:
            # --- NEU: Nur neue Events werden wie bisher importiert ---
            r = requests.put(url, data=cal.to_ical(), auth=(username, password),
                             headers={'content-type': 'text/calendar; charset=UTF-8'})
            if r.status_code == 500 and r'Sabre\VObject\Recur\NoInstancesException' in r.text:
                logging.warning('   No valid instances: %s (%s)' % (uid, name))
            elif r.status_code in (201, 204):
                logging.info('   Imported: %s (%s)' % (uid, name))
                imported_uids.append(uid)
            else:
                r.raise_for_status()

    # --- Delete removed events ---

    for euid in existing_uids - distant_uids:
        r = requests.delete('%s/%s.ics' % (base_url, euid), auth=(username, password))
        if r.status_code == 204:
            logging.info('Deleted %s' % euid)
        elif r.status_code == 404:
            pass
        else:
            r.raise_for_status()

    logging.info('  Done.')


if __name__ == '__main__':
    logging.info('Initializing script...')
    Config = configparser.RawConfigParser()
    Config.read('nextcloud_ics_sync.ini')
    logging.info('Done.')
    logging.info('Importing calendars...')

    for key in Config.sections():
        logging.info(' Working on section %s' % key)
        try:
            do_import(
                Config.get(key, 'username'), Config.get(key, 'password'), Config.get(key, 'calendar'), Config.get(key, 'server'),
                Config.get(key, 'ics_url'), Config.get(key, 'ics_username'), Config.get(key, 'ics_password')
            )
        except Exception as e:
            logging.error(traceback.print_exc())
        logging.info(' Done.')
    logging.info('Done.')