<?php
include("./podz.inc");


// Create new service for AMFPHP Remoting as Class
class podz_mail {
  var $mysqli;

  function podz_mail()  {
    # Connect to MySQL database....
    $this->mysqli = new mysqli(DATABASE_SERVER, DATABASE_USERNAME, DATABASE_PASSWORD, DATABASE_NAME);         
    # Check MySQL connection
    if (mysqli_connect_errno()) {
      # Dont use die (Fatal Error), return useful info to the client
      trigger_error("AMFPHP Remoting 'sample' class could not connect: " . mysqli_connect_error()); 
      }
    }

  function getMail($data) {
    $uid = $data['uid'];
    $boxid = $data['boxid'];
    $query = "SELECT * FROM podmail WHERE uid = $uid AND boxid = $boxid";
    if (!$result=@$this->mysqli->query($query)) {
      $errno=$this->mysqli->errno;
      $this->mysqli->close();
      trigger_error("AMFPHP Remoting database SELECT query error: " . $errno);
      }
    while ($row = $result->fetch_assoc()) {
      $return_array[] = $row;
      }
    return($return_array);
    }

  function updateMail($data) {
    $bdata = $data['data'];
    $uid = $data['uid'];
    $boxid = $data['boxid'];
    $query = "UPDATE podmail SET data = '$bdata' WHERE uid = $uid AND boxid = $boxid";
    if (!$result=@$this->mysqli->query($query)) {
      $errno=$this->mysqli->errno;
      $this->mysqli->close();
      trigger_error("AMFPHP Remoting database SELECT query error: " . $errno);
      }
    return(null);
    }

  function getFriends($data) {
    $uid = $data['uid'];
    $query = "SELECT friends FROM users WHERE uid = $uid";
    if (!$result=@$this->mysqli->query($query)) {
      $errno=$this->mysqli->errno;
      $this->mysqli->close();
      trigger_error("AMFPHP Remoting database SELECT query error: " . $errno);
      }
    while ($row = $result->fetch_assoc()) {
      $return_array[] = $row;
      }
    return($return_array);
    }


  }
?>