import { Client } from 'ssh2';
import {
  SecretsManagerClient,
  GetSecretValueCommand,
} from "@aws-sdk/client-secrets-manager";
export const handler = async (event) => {
  let result = "did not send";
  if (event.subject == "You have deliveries" || event.subject == "You have a delivery") {
    // Trigger home notification
    console.info("Matched Subject, pull key");
    const keyClient = new SecretsManagerClient({ region: "us-west-2" });
    let keyResponse;
    try {
      keyResponse = await keyClient.send(new GetSecretValueCommand({
        SecretId: process.env.TRIGGER_SECRET
      }));
    } catch (err) {
      console.warn(err);
      result = err;
    }
    const command = `ssh ${process.env.INTERNAL_HOST} "/usr/bin/tmux neww -d \"/usr/bin/mplayer '${process.env.INTERNAL_FILE}'\""`;
    console.info("Import ssh2");
    const connection = new Client();
    console.info("Set Conn Info");
    connection.on('ready', () => {
      console.info("Connection READY")
      connection.exec(command, (error, stream) => {
        if (error) {
          console.warn(error);
          result = JSON.stringify(error);
        }
        stream.on('close', (code, signal) => {
          // COMPLETE
          console.info("Trigger completed", code, signal)
        }).stderr.on('data', (data) => {
          // STDERR
          console.warn(data);
        });
      });
    }).connect({
      host: process.env.TRIGGER_HOST,
      port: 22,
      username: process.env.TRIGGER_USERNAME,
      privateKey: keyResponse.SecretString
    });
  }
  const response = {
    statusCode: 200,
    body: {
      result
    },
  };
  return response;
};