pubsub_callbacks.js

admin.initializeApp(functions.config().firebase);
var db = admin.database();
var refRunning = db.ref('/running-jobs');
var refFinished = db.ref('/finished-jobs');
// [END import]

// [START RunningJobsPubSub]
exports.RunningJobsPubSub = functions.pubsub.topic('bqtop-running-jobs').onPublish(event => {
// [END trigger]

    const pubSubMessage = event.data;
    return refRunning.push(pubSubMessage.json);
})
// [END RunningJobsPubSub]


// [START FinishedJobsPubSub]
exports.FinishedJobsPubSub = functions.pubsub.topic('bqtop-finished-jobs').onPublish(event => {
    const pubSubMessage = event.data;
    return refFinished.push(pubSubMessage.json);
})

// [END FinishedJobsPubSub]