const AWS = require('aws-sdk');
var mysql = require('mysql');
var apn = require("apn");

exports.handler = (event, context, callback) => {

    var connection = mysql.createConnection({
        host: "databaseHost",
        user: "databaseUser",
        password: "databasePassword",
        database: "databaseName",
    });

    var sql = "INSERT INTO some_table SET some_id = ?";
    var inserts = [event.someId];

    connection.query(sql, inserts, function (error, results, fields) {
        connection.end();
        if (error) {
            callback(error);
        } else {
            var options = {
                token: {
                    key: "key.p8",
                    keyId: "keyId",
                    teamId: "teamId"
                },
                production: true
            };
            var message = "Some Message";
            var apnProvider = new apn.Provider(options);

            var deviceTokens = event.deviceTokenArray;

            var notification = new apn.Notification();
            notification.alert = message;

            notification.topic = "com.example.example";

            apnProvider.send(notification, deviceTokens).then((response) => {
                callback(null, event.arguments.input);
            });
        }
    });
};