Como enviar alterações de documentos do MongoDB para um canal do Slack

1
exports = function(changeEvent) {
2
3
    const docId = changeEvent.documentKey._id;
4
5
    const { updateDescription, operationType } = changeEvent;
6
7
    var object = {
8
        operationType,
9
        docId,
10
    };
11
12
    if (updateDescription) {
13
        const updatedFields = updateDescription.updatedFields; // A document containing updated fields
14
        const removedFields = updateDescription.removedFields; // An array of removed fields
15
        object = {
16
            ...object,
17
            updatedFields,
18
            removedFields
19
        };
20
    }
21
22
    const result = context.functions.execute("sendToSlack", object);
23
24
    return true;
25
};

1
var message = "";
2
if (arg.operationType == 'insert') {
3
    message += `A new document with id \`${arg.docId}\` has been inserted`;
4
} else if (arg.operationType == 'update') {
5
    message += `The document \`${arg.docId}\` has been updated.`;
6
    if (arg.updatedFields && Object.keys(arg.updatedFields).length > 0) {
7
        message += ` The fileds ${JSON.stringify(arg.updatedFields)} has been modified.`;
8
    }
9
    if (arg.removedFields && arg.removedFields.length > 0) {
10
        message += ` The fileds ${JSON.stringify(arg.removedFields)} has been removed.`;
11
    }
12
} else {
13
    message += `An unexpected operation affecting document \`${arg.docId}\` ocurred`;
14
}

1
  const { WebClient } = require('@slack/web-api');
2
  // Read a token from the environment variables
3
  const token = context.values.get('SLACK_TOKEN');
4
  // Initialize
5
  const app = new WebClient(token);

1
try {
2
    // Call the chat.postMessage method using the WebClient
3
    const result = await app.chat.postMessage({
4
        channel: channelId,
5
        text: `New Event: ${message}`
6
    });
7
8
    console.log(result);
9
}
10
catch (error) {
11
    console.error(error);
12
}

1
exports = async function(arg){
2
3
    const { WebClient } = require('@slack/web-api');
4
    // Read a token from the environment variables
5
    const token = context.values.get('SLACK_TOKEN');
6
    const channelId = context.values.get('CHANNEL_ID');
7
    // Initialize
8
    const app = new WebClient(token);
9
10
    var message = "";
11
    if (arg.operationType == 'insert') {
12
        message += `A new document with id \`${arg.docId}\` has been inserted`;
13
    } else if (arg.operationType == 'update') {
14
        message += `The document \`${arg.docId}\` has been updated.`;
15
        if (arg.updatedFields && Object.keys(arg.updatedFields).length > 0) {
16
            message += ` The fileds ${JSON.stringify(arg.updatedFields)} has been modified.`;
17
        }
18
        if (arg.removedFields && arg.removedFields.length > 0) {
19
            message += ` The fileds ${JSON.stringify(arg.removedFields)} has been removed.`;
20
        }
21
    } else {
22
        message += `An unexpected operation affecting document \`${arg.docId}\` ocurred`;
23
    }
24
25
    try {
26
        // Call the chat.postMessage method using the WebClient
27
        const result = await app.chat.postMessage({
28
            channel: channelId,
29
            text: `New Event: ${message}`
30
        });
31
        console.log(result);
32
    }
33
    catch (error) {
34
        console.error(error);
35
    }
36
37
};