bugfix for
This commit is contained in:
+11
-9
@@ -1,11 +1,11 @@
|
|||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
from time import sleep
|
||||||
|
|
||||||
from google.oauth2 import service_account
|
from google.oauth2 import service_account
|
||||||
from googleapiclient.discovery import build
|
from googleapiclient.discovery import build
|
||||||
from googleapiclient.errors import HttpError
|
from googleapiclient.errors import HttpError
|
||||||
|
|
||||||
from event import Event
|
from event import Event
|
||||||
from time import sleep
|
|
||||||
|
|
||||||
|
|
||||||
class CalGrab(object):
|
class CalGrab(object):
|
||||||
@@ -31,14 +31,16 @@ class CalGrab(object):
|
|||||||
try:
|
try:
|
||||||
start = None
|
start = None
|
||||||
while True:
|
while True:
|
||||||
now = datetime.utcnow() # 'Z' indicates UTC time
|
now = datetime.utcnow() # 'Z' indicates UTC time
|
||||||
now_str = now.isoformat() + 'Z'
|
if start == None:
|
||||||
if start ==None:
|
|
||||||
start = now
|
start = now
|
||||||
print('Getting the upcoming 10 events')
|
events_result = self.service.events().list(
|
||||||
events_result = self.service.events().list(calendarId='loskorep@productiveedge.com', timeMin=now_str,
|
calendarId='loskorep@productiveedge.com',
|
||||||
maxResults=10, singleEvents=True,
|
timeMin=now.isoformat() + 'Z',
|
||||||
orderBy='startTime').execute()
|
maxResults=10,
|
||||||
|
singleEvents=True,
|
||||||
|
orderBy='startTime'
|
||||||
|
).execute()
|
||||||
events = events_result.get('items', [])
|
events = events_result.get('items', [])
|
||||||
|
|
||||||
if not events:
|
if not events:
|
||||||
@@ -48,7 +50,7 @@ class CalGrab(object):
|
|||||||
events = [Event.get_from_gcal_api_json(json) for json in events]
|
events = [Event.get_from_gcal_api_json(json) for json in events]
|
||||||
for callback in self.callbacks:
|
for callback in self.callbacks:
|
||||||
callback(events)
|
callback(events)
|
||||||
if time_to_update > 0 and (now-start).total_seconds() > time_to_update:
|
if time_to_update > 0 and (now - start).total_seconds() > time_to_update:
|
||||||
return
|
return
|
||||||
sleep(frequency)
|
sleep(frequency)
|
||||||
except HttpError as error:
|
except HttpError as error:
|
||||||
|
|||||||
Reference in New Issue
Block a user