mythic-insight/calcom
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 5

Prepared google calendar deletion

Browse source
This commit is contained in:
nicolas 2021-06-07 01:10:56 +02:00
parent d05ae49e8d
commit b376e9e5a4
3 changed files with 115 additions and 56 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

165
lib/calendarClient.ts
View file

@ -1,4 +1,3 @@
const {google} = require('googleapis'); const {google} = require('googleapis');
import createNewEventEmail from "./emails/new-event"; import createNewEventEmail from "./emails/new-event";
@ -9,7 +8,7 @@ const googleAuth = () => {
function handleErrors(response) { function handleErrors(response) {
if (!response.ok) { if (!response.ok) {
response.json().then( console.log ); response.json().then(console.log);
throw Error(response.statusText); throw Error(response.statusText);
} }
return response.json(); return response.json();
@ -22,7 +21,7 @@ const o365Auth = (credential) => {
const refreshAccessToken = (refreshToken) => fetch('https://login.microsoftonline.com/common/oauth2/v2.0/token', { const refreshAccessToken = (refreshToken) => fetch('https://login.microsoftonline.com/common/oauth2/v2.0/token', {
method: 'POST', method: 'POST',
headers: { 'Content-Type': 'application/x-www-form-urlencoded' }, headers: {'Content-Type': 'application/x-www-form-urlencoded'},
body: new URLSearchParams({ body: new URLSearchParams({
'scope': 'User.Read Calendars.Read Calendars.ReadWrite', 'scope': 'User.Read Calendars.Read Calendars.ReadWrite',
'client_id': process.env.MS_GRAPH_CLIENT_ID, 'client_id': process.env.MS_GRAPH_CLIENT_ID,
@ -31,19 +30,24 @@ const o365Auth = (credential) => {
'client_secret': process.env.MS_GRAPH_CLIENT_SECRET, 'client_secret': process.env.MS_GRAPH_CLIENT_SECRET,
}) })
}) })
.then(handleErrors) .then(handleErrors)
.then( (responseBody) => { .then((responseBody) => {
credential.key.access_token = responseBody.access_token; credential.key.access_token = responseBody.access_token;
credential.key.expiry_date = Math.round((+(new Date()) / 1000) + responseBody.expires_in); credential.key.expiry_date = Math.round((+(new Date()) / 1000) + responseBody.expires_in);
return credential.key.access_token; return credential.key.access_token;
}) })
return { return {
getToken: () => ! isExpired(credential.key.expiry_date) ? Promise.resolve(credential.key.access_token) : refreshAccessToken(credential.key.refresh_token) getToken: () => !isExpired(credential.key.expiry_date) ? Promise.resolve(credential.key.access_token) : refreshAccessToken(credential.key.refresh_token)
}; };
}; };
interface Person { name?: string, email: string, timeZone: string } interface Person {
name?: string,
email: string,
timeZone: string
}
interface CalendarEvent { interface CalendarEvent {
type: string; type: string;
title: string; title: string;
@ -57,6 +61,11 @@ interface CalendarEvent {
interface CalendarApiAdapter { interface CalendarApiAdapter {
createEvent(event: CalendarEvent): Promise<any>; createEvent(event: CalendarEvent): Promise<any>;
updateEvent(uid: String, event: CalendarEvent);
deleteEvent(uid: String);
getAvailability(dateFrom, dateTo): Promise<any>; getAvailability(dateFrom, dateTo): Promise<any>;
} }
@ -68,7 +77,7 @@ const MicrosoftOffice365Calendar = (credential): CalendarApiAdapter => {
let optional = {}; let optional = {};
if (event.location) { if (event.location) {
optional.location = { displayName: event.location }; optional.location = {displayName: event.location};
} }
return { return {
@ -99,7 +108,7 @@ const MicrosoftOffice365Calendar = (credential): CalendarApiAdapter => {
return { return {
getAvailability: (dateFrom, dateTo) => { getAvailability: (dateFrom, dateTo) => {
const payload = { const payload = {
schedules: [ credential.key.email ], schedules: [credential.key.email],
startTime: { startTime: {
dateTime: dateFrom, dateTime: dateFrom,
timeZone: 'UTC', timeZone: 'UTC',
@ -120,25 +129,34 @@ const MicrosoftOffice365Calendar = (credential): CalendarApiAdapter => {
}, },
body: JSON.stringify(payload) body: JSON.stringify(payload)
}) })
.then(handleErrors) .then(handleErrors)
.then( responseBody => { .then(responseBody => {
return responseBody.value[0].scheduleItems.map( (evt) => ({ start: evt.start.dateTime + 'Z', end: evt.end.dateTime + 'Z' })) return responseBody.value[0].scheduleItems.map((evt) => ({
}) start: evt.start.dateTime + 'Z',
).catch( (err) => { end: evt.end.dateTime + 'Z'
}))
})
).catch((err) => {
console.log(err); console.log(err);
}); });
}, },
createEvent: (event: CalendarEvent) => auth.getToken().then( accessToken => fetch('https://graph.microsoft.com/v1.0/me/calendar/events', { createEvent: (event: CalendarEvent) => auth.getToken().then(accessToken => fetch('https://graph.microsoft.com/v1.0/me/calendar/events', {
method: 'POST', method: 'POST',
headers: { headers: {
'Authorization': 'Bearer ' + accessToken, 'Authorization': 'Bearer ' + accessToken,
'Content-Type': 'application/json', 'Content-Type': 'application/json',
}, },
body: JSON.stringify(translateEvent(event)) body: JSON.stringify(translateEvent(event))
}).then(handleErrors).then( (responseBody) => ({ }).then(handleErrors).then((responseBody) => ({
...responseBody, ...responseBody,
disableConfirmationEmail: true, disableConfirmationEmail: true,
}))) }))),
deleteEvent: (uid: String) => {
//TODO Implement
},
updateEvent: (uid: String, event: CalendarEvent) => {
//TODO Implement
},
} }
}; };
@ -146,34 +164,34 @@ const GoogleCalendar = (credential): CalendarApiAdapter => {
const myGoogleAuth = googleAuth(); const myGoogleAuth = googleAuth();
myGoogleAuth.setCredentials(credential.key); myGoogleAuth.setCredentials(credential.key);
return { return {
getAvailability: (dateFrom, dateTo) => new Promise( (resolve, reject) => { getAvailability: (dateFrom, dateTo) => new Promise((resolve, reject) => {
const calendar = google.calendar({ version: 'v3', auth: myGoogleAuth }); const calendar = google.calendar({version: 'v3', auth: myGoogleAuth});
calendar.calendarList calendar.calendarList
.list() .list()
.then(cals => { .then(cals => {
calendar.freebusy.query({ calendar.freebusy.query({
requestBody: { requestBody: {
timeMin: dateFrom, timeMin: dateFrom,
timeMax: dateTo, timeMax: dateTo,
items: cals.data.items items: cals.data.items
} }
}, (err, apires) => { }, (err, apires) => {
if (err) { if (err) {
reject(err); reject(err);
} }
resolve( resolve(
Object.values(apires.data.calendars).flatMap( Object.values(apires.data.calendars).flatMap(
(item) => item["busy"] (item) => item["busy"]
) )
) )
});
})
.catch((err) => {
reject(err);
}); });
})
.catch((err) => {
reject(err);
});
}), }),
createEvent: (event: CalendarEvent) => new Promise( (resolve, reject) => { createEvent: (event: CalendarEvent) => new Promise((resolve, reject) => {
const payload = { const payload = {
summary: event.title, summary: event.title,
description: event.description, description: event.description,
@ -198,12 +216,31 @@ const GoogleCalendar = (credential): CalendarApiAdapter => {
payload['location'] = event.location; payload['location'] = event.location;
} }
const calendar = google.calendar({version: 'v3', auth: myGoogleAuth }); const calendar = google.calendar({version: 'v3', auth: myGoogleAuth});
calendar.events.insert({ calendar.events.insert({
auth: myGoogleAuth, auth: myGoogleAuth,
calendarId: 'primary', calendarId: 'primary',
resource: payload, resource: payload,
}, function(err, event) { }, function (err, event) {
if (err) {
console.log('There was an error contacting the Calendar service: ' + err);
return reject(err);
}
return resolve(event.data);
});
}),
updateEvent: (uid: String, event: CalendarEvent) => new Promise((resolve, reject) => {
//TODO implement
}),
deleteEvent: (uid: String) => new Promise( (resolve, reject) => {
const calendar = google.calendar({version: 'v3', auth: myGoogleAuth});
calendar.events.delete({
auth: myGoogleAuth,
calendarId: 'primary',
eventId: uid,
sendNotifications: true,
sendUpdates: true,
}, function (err, event) {
if (err) { if (err) {
console.log('There was an error contacting the Calendar service: ' + err); console.log('There was an error contacting the Calendar service: ' + err);
return reject(err); return reject(err);
@ -215,10 +252,12 @@ const GoogleCalendar = (credential): CalendarApiAdapter => {
}; };
// factory // factory
const calendars = (withCredentials): CalendarApiAdapter[] => withCredentials.map( (cred) => { const calendars = (withCredentials): CalendarApiAdapter[] => withCredentials.map((cred) => {
switch(cred.type) { switch (cred.type) {
case 'google_calendar': return GoogleCalendar(cred); case 'google_calendar':
case 'office365_calendar': return MicrosoftOffice365Calendar(cred); return GoogleCalendar(cred);
case 'office365_calendar':
return MicrosoftOffice365Calendar(cred);
default: default:
return; // unknown credential, could be legacy? In any case, ignore return; // unknown credential, could be legacy? In any case, ignore
} }
@ -226,15 +265,15 @@ const calendars = (withCredentials): CalendarApiAdapter[] => withCredentials.map
const getBusyTimes = (withCredentials, dateFrom, dateTo) => Promise.all( const getBusyTimes = (withCredentials, dateFrom, dateTo) => Promise.all(
calendars(withCredentials).map( c => c.getAvailability(dateFrom, dateTo) ) calendars(withCredentials).map(c => c.getAvailability(dateFrom, dateTo))
).then( ).then(
(results) => results.reduce( (acc, availability) => acc.concat(availability), []) (results) => results.reduce((acc, availability) => acc.concat(availability), [])
); );
const createEvent = (credential, calEvent: CalendarEvent): Promise<any> => { const createEvent = (credential, calEvent: CalendarEvent): Promise<any> => {
createNewEventEmail( createNewEventEmail(
calEvent, calEvent,
); );
if (credential) { if (credential) {
@ -244,4 +283,20 @@ const createEvent = (credential, calEvent: CalendarEvent): Promise<any> => {
return Promise.resolve({}); return Promise.resolve({});
}; };
export { getBusyTimes, createEvent, CalendarEvent }; const updateEvent = (credential, uid: String, calEvent: CalendarEvent): Promise<any> => {
if (credential) {
return calendars([credential])[0].updateEvent(uid, calEvent);
}
return Promise.resolve({});
};
const deleteEvent = (credential, uid: String): Promise<any> => {
if (credential) {
return calendars([credential])[0].deleteEvent(uid);
}
return Promise.resolve({});
};
export {getBusyTimes, createEvent, CalendarEvent};

5
pages/api/book/[user].ts
View file

@ -53,7 +53,10 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
userId: currentUser.id, userId: currentUser.id,
references: { references: {
create: [ create: [
//TODO Create references {
type: currentUser.credentials[0].type,
uid: result.id
}
] ]
}, },
eventTypeId: eventType.id, eventTypeId: eventType.id,

1
pages/api/cancel.ts
View file

@ -28,6 +28,7 @@ export default async function handler(req, res) {
}); });
//TODO Delete booking from calendar integrations //TODO Delete booking from calendar integrations
//TODO Perhaps send emails to user and client to tell about the cancellation
const deleteBooking = await prisma.booking.delete({ const deleteBooking = await prisma.booking.delete({
where: { where: {