kickbykick / elastic-cloud Goto Github PK

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const { Client } = require('@elastic/elasticsearch')

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

const env = functions.config();
const auth = {
  username: env.elasticsearch.username,
  password: env.elasticsearch.password,
};

const client = new Client({
    node: env.elasticsearch.url,
    auth: auth,
})


exports.createPost = functions.firestore
    .document('chores/{choreId}')
    .onCreate( async (snap, context) => {

      console.log(snap.data());
        await client.index({
            index: 'chores',
            type: '_doc',
            id: snap.id,
            body: snap.data()
        })
    });

exports.updatePost = functions.firestore
    .document('chores/{choreId}')
    .onUpdate( async (snap, context) => {
        await client.update({
            index: 'chores',
            type: '_doc',
            id: context.params.choreId,
            body: snap.after.data()
        })
    });

exports.deletePost = functions.firestore
    .document('chores/{choreId}')
    .onDelete( snap => {
        client.delete({
            index: 'chores',
            type: '_doc',
            id: snap.id,
        })
    });