Plexus sample / firebase

functions.js

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const bigquery = require('@google-cloud/bigquery')();
const cors = require('cors')({ origin: true });

admin.initializeApp(functions.config().firebase);

const db = admin.database();

/**
 * @see https://github.com/alvarowolfx/weather-station-gcp-mongoose-os/blob/master/functions/index.js
 */
exports.setDeviceCapturedData = functions.pubsub
    .topic('iot-topic')
    .onPublish(event => {
        // Set device data
        let data = event.data.json;
        data.updatedAt = event.timestamp;

        return Promise.all([
            updateRealtime(
                event.data.attributes['clientId'],
                event.data.attributes['deviceId'],
                data
            )
        ]);
});

/**
 * Updates firebase realtime data, with the most resent data captured by a device.
 *
 * @param {string} clientId ID of the client the device belongs to.
 * @param {string} deviceId Device ID.
 * @param {object} data     Data captured by device.
 */
function updateRealtime(clientId, deviceId, data)
{
    return db.ref(`${clientId}/devices/${deviceId}`).set(data);
}