1
|
1 #!/usr/bin/python
|
2
|
2 ###
|
|
3 ### Google Calendar MultiMerge v0.000001
|
|
4 ### (C) 2016 Matti 'ccr' Hamalainen <ccr@tnsp.org>
|
|
5 ###
|
|
6 ### Python 2.7 <= x < 3 required! Please refer to
|
|
7 ### README.txt for information on other depencies.
|
|
8 ###
|
1
|
9 import os
|
|
10 import sys
|
|
11 import signal
|
|
12 import re
|
|
13 import time
|
|
14 import datetime
|
|
15 import httplib2
|
|
16 import ConfigParser
|
|
17 import oauth2client
|
|
18 from oauth2client import client
|
|
19 from oauth2client import tools
|
|
20 from googleapiclient import discovery
|
|
21
|
|
22
|
|
23 ###
|
|
24 ### Misc. helper functions
|
|
25 ###
|
|
26
|
|
27 ## Wrapper for print() that does not break when redirecting stdin/out
|
|
28 ## because of piped output not having a defined encoding. We default
|
|
29 ## to UTF-8 encoding in output here.
|
|
30 def gcm_print(smsg):
|
|
31 gcm_msgbuf.append(smsg.encode("UTF-8"))
|
|
32 if sys.stdout.encoding != None:
|
|
33 print(smsg.encode(sys.stdout.encoding))
|
|
34 else:
|
|
35 print(smsg.encode("UTF-8"))
|
|
36
|
|
37
|
|
38 ## Fatal errors
|
|
39 def gcm_fatal(smsg):
|
|
40 gcm_print(u"ERROR: "+ smsg)
|
|
41 sys.exit(1)
|
|
42
|
|
43
|
|
44 ## Debug messages
|
|
45 def gcm_debug(smsg):
|
|
46 if cfg.debug:
|
|
47 gcm_print(u"DBG: "+ smsg)
|
|
48 else:
|
|
49 gcm_msgbuf.append(u"DBG: "+ smsg.encode("UTF-8"))
|
|
50
|
|
51
|
|
52 ## Handle SIGINT signals here
|
|
53 def gcm_signal_handler(signal, frame):
|
|
54 gcm_print("\nQuitting due to SIGINT / Ctrl+C!")
|
|
55 sys.exit(0)
|
|
56
|
|
57
|
|
58 def gcm_get_credentials(mcfg):
|
|
59 store = oauth2client.file.Storage(mcfg.credential_file)
|
|
60 credentials = store.get()
|
|
61 if not credentials or credentials.invalid:
|
|
62 flow = client.flow_from_clientsecrets(mcfg.secret_file, mcfg.scope)
|
|
63 flow.user_agent = mcfg.app_name
|
|
64 credentials = tools.run_flow(flow, store, mcfg)
|
|
65 if not credentials or credentials.invalid:
|
|
66 gcm_fatal("Failed to authenticate / invalid credentials.")
|
|
67 return credentials
|
|
68
|
|
69
|
|
70 def gcm_dump_events(events):
|
|
71 for event in events:
|
|
72 ev_start = event["start"].get("dateTime", event["start"].get("date"))
|
|
73 ev_end = event["end"].get("dateTime", event["end"].get("date"))
|
|
74 gcm_print(u"{0:25} - {1:25} : {2}".format(ev_start, ev_end, event["summary"]))
|
|
75
|
|
76
|
|
77 class GCMSettings(dict):
|
|
78 def __init__(self):
|
|
79 self.m_data = {}
|
|
80 self.m_saveable = {}
|
|
81 self.m_translate = {}
|
|
82
|
|
83 def __getattr__(self, name):
|
|
84 if name in self.m_data:
|
|
85 return self.m_data[name]
|
|
86 else:
|
|
87 gcm_fatal("GCMSettings.__getattr__(): No such attribute '"+ name +"'.")
|
|
88
|
|
89 def mtranslate(self, name, value):
|
|
90 if name in self.m_translate and self.m_translate[name]:
|
|
91 return self.m_translate[name](value)
|
|
92 else:
|
|
93 return value
|
|
94
|
|
95 def mdef(self, name, saveable, validate, translate, value):
|
|
96 self.m_saveable[name] = saveable
|
|
97 self.m_data[name] = self.mtranslate(name, value)
|
|
98
|
|
99 def mset(self, name, value):
|
|
100 if name in self.m_data:
|
|
101 self.m_data[name] = self.mtranslate(name, value)
|
|
102 else:
|
|
103 gcm_fatal("GCMSettings.mset(): No such attribute '"+ name +"'.")
|
|
104
|
|
105 def mget(self, name):
|
|
106 if name in self.m_data:
|
|
107 return self.m_data[name]
|
|
108 else:
|
|
109 return None
|
|
110
|
|
111
|
|
112 ###
|
|
113 ### Main program starts
|
|
114 ###
|
|
115 gcm_msgbuf = []
|
|
116 signal.signal(signal.SIGINT, gcm_signal_handler)
|
|
117
|
|
118
|
|
119 ## Settings
|
|
120 cfg = GCMSettings()
|
|
121
|
|
122 cfg.mdef("debug", True, gcm_is_bool, gcm_trans_bool, False)
|
|
123
|
|
124 cfg.mdef("source_regex", True, gcm_is_string, None, "^R:\s*(.*?)\s*\(\s*(.+?)\s*\)\s*$")
|
|
125 cfg.mdef("source_regmap", False, gcm_is_list, gcm_trans_list, [1, 2])
|
|
126 cfg.mdef("source_regmap_len", False, None, None, len(cfg.source_regmap))
|
|
127
|
|
128 cfg.mdef("dest_name", True, gcm_is_string, None, u"Raahen kansainvälisyystoiminta")
|
|
129 cfg.mdef("dest_id", True, gcm_is_string, None, None)
|
|
130
|
|
131 cfg.mdef("noauth_local_webserver", False, None, None, True)
|
|
132 #cfg.mdef("auth_host_name", False, None, None, "localhost")
|
|
133 #cfg.mdef("auth_host_port", False, None, None, [8080, 8090])
|
|
134 cfg.mdef("logging_level", True, gcm_is_log_level, gcm_trans_log_level, "ERROR")
|
|
135
|
|
136 # No need to touch these
|
|
137 cfg.mdef("app_name", False, None, None, "Google Calendar MultiMerge")
|
|
138 cfg.mdef("scope", False, None, None, "https://www.googleapis.com/auth/calendar")
|
|
139 #cfg.mdef("scope", False, None, None, "https://www.googleapis.com/auth/calendar.readonly")
|
|
140 cfg.mdef("secret_file", True, gcm_is_filename, None, "client_secret.json")
|
|
141 cfg.mdef("credential_file", True, gcm_is_filename, None, "client_credentials.json")
|
|
142
|
|
143 ## Initialize and authorize API connection
|
|
144 credentials = gcm_get_credentials(cfg)
|
|
145 http = credentials.authorize(httplib2.Http())
|
|
146 service = discovery.build("calendar", "v3", http=http)
|
|
147
|
|
148
|
|
149 ## Fetch complete calendar list
|
|
150 gcm_debug("Fetching available calendars ..")
|
|
151 calendars = []
|
|
152 calPageToken = None
|
|
153 while True:
|
|
154 # We want everything except deleted and hidden calendars
|
|
155 calResult = service.calendarList().list(
|
|
156 showHidden=False,
|
|
157 showDeleted=False,
|
|
158 pageToken=calPageToken
|
|
159 ).execute()
|
|
160
|
|
161 calendars.extend(calResult.get("items", []))
|
|
162 calPageToken = calResult.get("nextPageToken")
|
|
163 if not calPageToken:
|
|
164 break
|
|
165
|
|
166 if len(calendars) == 0:
|
|
167 gcm_fatal("No calendars found?")
|
|
168
|
|
169
|