<?php
$bot_name = "smeagol_lotr_bot";
$bot_api = require('api_key.php');

// Checks whether the given command is the same as the entered command
function check_command($command) {
  global $bot_name;
  global $decoded;
  $command_list = explode(" ", $decoded->{"message"}->{"text"});
  if ($command_list[0] == $command || $command_list[0] == $command . "@" . $bot_name) {
    return True;
  }
  else {
    return False;
  }
}

// Send html back to the sender.
function send_html($post_message, $reply=false) {
  global $decoded;
  global $bot_api;
  global $chat_id;
  $url = 'https://api.telegram.org/bot' . $bot_api . '/sendMessage';
  $post_msg = array('chat_id' => $chat_id, 'text' =>$post_message, 'parse_mode' => 'html');
  if ($reply != false) {
    if ($reply === true){
      $post_msg['reply_to_message_id'] = $decoded->{'message'}->{'message_id'};
    }
    else {
      $post_msg['reply_to_message_id'] = $reply;
    }
  }
  $options = array(
    'http' => array(
      'header' => "Content-type: application/x-www-form-urlencoded\r\n",
      'method' => 'POST',
      'content' => http_build_query($post_msg)
    )
  );
  $context = stream_context_create($options);
  $result = file_get_contents($url, false, $context);
}

// Edits existing pinned message
function edit_html($post_message, $reply=false) {
  global $decoded;
  global $bot_api;
  global $chat_id;
  $message_id = require("message.php");
  $url = 'https://api.telegram.org/bot' . $bot_api . '/editMessageText';
  $post_msg = array('chat_id' => $chat_id, 'text' =>$post_message, 'message_id' => $message_id, 'parse_mode' => 'html');
  if ($reply != false) {
    if ($reply === true){
      $post_msg['reply_to_message_id'] = $decoded->{'message'}->{'message_id'};
    }
    else {
      $post_msg['reply_to_message_id'] = $reply;
    }
  }
  $options = array(
    'http' => array(
      'header' => "Content-type: application/x-www-form-urlencoded\r\n",
      'method' => 'POST',
      'content' => http_build_query($post_msg)
    )
  );
  $context = stream_context_create($options);
  $result = file_get_contents($url, false, $context);
}

function add_requirement() {
  global $command_list;
  $item_id = $command_list[1];
  $item_name = "";
  for ($i = 2; $i < count($command_list) - 1; $i++){
    $item_name .= $command_list[$i];
    if ($i != count($command_list) - 2){
      $item_name .= " ";
    }
  }
  $quantity = $command_list[count($command_list) - 1];

  $mysql = require('mysql_credentials.php');
  $conn = new mysqli($mysql['servername'], $mysql['username'], $mysql['password'], $mysql['database']);
  if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error);
  }
  $stmt = $conn->prepare("DELETE FROM req where id = ?;");
  $stmt->bind_param('s', $item_id);
  $stmt->execute();
  $stmt = $conn->prepare("INSERT INTO req (id, name, quantity) VALUES (?,?,?);");
  $stmt->bind_param('ssi', $item_id, $item_name, $quantity);
  $stmt->execute();
  $conn->close();
  send_html("Added to requirements");
  edit_html(get_updated_req());
}

function deposit(){
  global $command_list;
  $item_id = $command_list[1];
  $quantity = 1;
  if (isset($command_list[2])){
    $quantity = $command_list[2];
  }

  $mysql = require('mysql_credentials.php');
  $conn = new mysqli($mysql['servername'], $mysql['username'], $mysql['password'], $mysql['database']);
  if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error);
  }
  $stmt = $conn->prepare("UPDATE req set quantity = quantity - ? where id = ?;");
  $stmt->bind_param('is', $quantity, $item_id);
  $stmt->execute();
  $conn->close();
  send_html("Deposited!");
  edit_html(get_updated_req());
}

function get_updated_req() {
  $mysql = require('mysql_credentials.php');
  $conn = new mysqli($mysql['servername'], $mysql['username'], $mysql['password'], $mysql['database']);
  if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error);
  }
  $sql = "SELECT name, quantity FROM req WHERE quantity > 0;";
  $result = $conn->query($sql);

  $text = "#requirements\n";
  if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
      $text .= $row["name"] . "  " . $row["quantity"] . "\n";
    }
  } else {
    $text .= "Everything is complete";
  }
  return $text;
}

function everyone() {
  global $command_list;
  $text = "@ceda_ei @bryan2810 @TrueHanash @jrioln @JD_the_fish @wand_maker @Tropics888 @chickadeer @amolith @lindyyyy @quilombola @Trixity ";
  for ($i = 1; $i < count($command_list); $i++){
    $text .= $command_list[$i];
    $text .= " ";
  }
  send_html($text);
}

function get_req() {
  send_html(get_updated_req());
}

// Get JSON from post, store it and decode it.
$var = file_get_contents('php://input');
$decoded = json_decode($var);

// Store the chat ID
$chat_id = $decoded->{"message"}->{"chat"}->{"id"};

if ($chat_id != -1001279314046){
  exit();
}

$modules = array(
  array(
    "command" => "/deposit",
    "function" => "deposit();"
  ),
  array(
    "command" => "/g_deposit",
    "function" => "deposit();"
  ),
  array(
    "command" => "/add",
    "function" => "add_requirement();"
  ),
  array(
    "command" => "/everyone",
    "function" => "everyone();"
  ),
  array(
    "command" => "/get",
    "function" => "get_req();"
  )
);

$command_list = explode(" ", $decoded->{"message"}->{"text"});

foreach ($modules as $module ) {
  if (check_command($module["command"])) {
    eval($module["function"]);
    exit();
  }
}
?>