index.js

// Intiialize the Cloud Functions library
const functions = require('firebase-functions');
const List = require('collections/list');
// Initialize the Firebase application with admin credentials
const admin = require('firebase-admin');
const firebase_tools = require('firebase-tools');

admin.initializeApp();

// Handle firestore new date format
const firestore = new admin.firestore();
const settings = {timestampsInSnapshots: true};
firestore.settings(settings);

// Check for events within a days range and send notications to the associated tokens.
exports.flutterCalendar = functions.https.onRequest((request, response) => {
  var data = [];
  var emailList = new List();
  var now = new Date();
  data.push('todays date: ' + now);
  data.push(now.getFullYear());
  data.push(now.getMonth());
  data.push(now.getDate());

  firestore.collection('calendar_events')
  .get()
  .then(docs => {
  	emailList.clear();
    docs.forEach(doc => {
      var timestamp = doc.get('time');
      var eventDate = timestamp.toDate();
      data.push('event date: ' + eventDate);
	  data.push(eventDate.getFullYear());
	  data.push(eventDate.getMonth());
	  data.push(eventDate.getDate());
      // Check if we have an event within seven days
      if (eventDate.getFullYear() === now.getFullYear() &&
          eventDate.getMonth() === now.getMonth() &&
          eventDate.getDate() === now.getDate())
      {
        // Test of adding emails to a list
        var mail = doc.get('email');
        if(!emailList.has(mail)) {
          emailList.add(mail);          
        }
        data.push(doc.data());
      }
    })

    data.push('email list size: ' + emailList.length);
    return emailList;
  })
  // Setup the query to get all the users from the 'users' collection
  .then(emailList => {
  	if(emailList.length > 0) {
	    var query = firestore.collection('users')
	    emailList.forEach(email => {
	      data.push(email);
	      query = query.where('email', '==', email.toString());
	    })
	    return query.get();
	} else {
		return null;
	}
  })
  // Get all the tokens from the 'users' collection
  .then(querySnapshot => {
    var tokenList = [];

    if(querySnapshot) {
	    data.push('querySnapshot size: ' + querySnapshot.size);
	    querySnapshot.forEach(doc => {
	      tokenList.push(doc.get('token'));
	    })
	    data.push(tokenList);
	}

    return tokenList;
  })
  // Send the push notification to each token
  .then(tokens => {
    tokens.forEach(token => {
      var message = {
        notification: {
          title: 'Event Notification',
          body: 'You have an event coming up...'
        },
        token: token
      };
      data.push(message);

      admin.messaging().send(message);
    })

    response.status(200).send("Successfully ran script!");
    return null;
  })
  .then(response => {
  	//console.log('Successfully sent message:', response);
  	return null;
  })
  .catch(error => {
    console.error('Error sending push notification: ', error);
    response.status(501).send('Error from script...');
  });
});


//=============================================================

exports.deleteContactAndSubCollections = functions.https.onCall((data, context) => {
	console.log('deleteContactAndSubCollections function');
	const contactDocumentId = data.contactDocumentId;
  const userDocumentId = data.userDocumentId

	const uid = context.auth.uid;
	const name = context.auth.token.name || null;
	const picture = context.auth.token.picture || null;
	const email = context.auth.token.email || null;

	console.log('userDocumentId: ', userDocumentId);
  console.log('contactDocumentId: ', contactDocumentId);
	console.log('uid: ', uid);
	console.log('name: ', name);
	console.log('picture: ', picture);
	console.log('email: ', email);

	// Only allow admin users to execute this function.
    if (!(uid && context.auth.token && email)) {
      throw new functions.https.HttpsError(
        'permission-denied',
        'Must be a valid user to initiate delete.'
      );
    }

    const path = 'users' + "/" + userDocumentId + "/" + 'contacts' + "/" + contactDocumentId;
    console.log(
      `User ${context.auth.uid} has requested to delete path ${path}`
    );

    // Run a recursive delete on the given document or collection path.
    // The 'token' must be set in the functions config, and can be generated
    // at the command line by running 'firebase login:ci'.
    return firebase_tools.firestore
      .delete(path, {
        project: process.env.GCLOUD_PROJECT,
        recursive: true,
        yes: true,
        //token: functions.config().fb.token
      })
      .then(() => {
        return {
          path: path
        };
      });
});