Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- const AWS = require('aws-sdk');
- var mysql = require('mysql');
- var lambda = new AWS.Lambda();
- exports.handler = (event, context, callback) => {
- var connection = mysql.createConnection({
- host: "databaseHost",
- user: "databaseUser",
- password: "databasePassword",
- database: "databaseName",
- multipleStatements: true
- });
- var sql = "INSERT INTO someTable SET item_id = ?, item_name = ?"
- var inserts = [event.itemId, event.itemName];
- connection.query(sql, inserts, function (error, results, fields) {
- connection.end();
- // Handle error after the release.
- if (error) {
- callback(error);
- } else {
- if (event.userToken !== null) {
- callback(null, results);
- var pushPayload = { "deviceToken": event.deviceToken };
- var pushParams = {
- FunctionName: 'sendPushNotification',
- InvocationType: 'RequestResponse',
- LogType: 'Tail',
- Payload: JSON.stringify(pushPayload)
- };
- lambda.invoke(pushParams, function (err, data) {
- if (err) {
- context.fail(err);
- } else {
- context.succeed(data.Payload);
- }
- });
- } else {
- //callback(null, results);
- callback(null, results);
- }
- }
- });
- };
- const AWS = require('aws-sdk');
- var ssm = new AWS.SSM({ apiVersion: '2014-11-06' });
- var apn = require("apn");
- exports.handler = function (event, context) {
- var options = {
- token: {
- key: "key",
- keyId: "keyId",
- teamId: "teamId"
- },
- production: true
- };
- var token = event.deviceToken;
- var apnProvider = new apn.Provider(options);
- var notification = new apn.Notification();
- notification.alert = "message";
- notification.topic = "com.example.Example";
- context.callbackWaitsForEmptyEventLoop = false;
- apnProvider.send(notification, [deviceToken]).then((response) => {
- context.succeed(event);
- });
- };
Add Comment
Please, Sign In to add comment