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


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

  function podz()  {
    # 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 userAuth($data) {
    $username = $data['username'];
    $password = $data['password'];
    $query = "SELECT * FROM users WHERE username = '$username' AND password = '$password'";
    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 getView($uid) {
    $query = "SELECT viewXML 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);
    }

  function getFriends($uid) {
    $query = "SELECT friendsXML 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);
    }


  function updateView($data) {
    $uid = $data['uid'];
    $viewXML = $data['viewXML'];
    $query = "UPDATE users SET viewXML = '$viewXML' 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);
      }
    return(null);
    }

  function getPublicView($username) {
    $query = "SELECT viewXML FROM users WHERE username = '$username'";
    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 getPortal($pid) {
    $query = "SELECT portalXML,portalName FROM tmpP WHERE pid = $pid";
    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 cmpMail($data) {
    $query = "SELECT * FROM users WHERE uid = $data[mailTo]";
    $result = @$this->mysqli->query($query);
    $userInfo = $result->fetch_array(MYSQLI_ASSOC);

    $name = $userInfo['firstName'] . " " . $userInfo['lastName'];

    switch($data['pid']) {
      case -1:
        $podName = "Mega Pod";
        break;
      case -3:
        $podName = "Friends Pod";
        break;
      default:
        $query = "SELECT * FROM podz WHERE pid = $data[pid]";
        $result = @$this->mysqli->query($query);
        $podInfo = $result->fetch_array(MYSQLI_ASSOC);
        $podName = $podInfo['podName'];
        break;
      }

    return(array(array('mailTo' => $name,'toUID' => $data['mailTo'],'podName' => $podName,'pid' => $data['pid'])));
    }

  function getPod($pid) {
    $query = "SELECT * FROM podz WHERE pid = $pid";
    if (!$result=@$this->mysqli->query($query)) {
      $errno=$this->mysqli->errno;
      $this->mysqli->close();
      trigger_error("AMFPHP Remoting database SELECT query error: [$query] " . $errno);
      }
    while ($row = $result->fetch_assoc()) {
      $return_array[] = $row;
      }
    return($return_array);
    }

  function sendMail($data) {
    $query = "SELECT username FROM users WHERE uid = $data[toUID]";
    $result = $this->mysqli->query($query);
    $userInfo = $result->fetch_array(MYSQLI_ASSOC);

    $email = $userInfo['username'] . "@podz.ubixos.com";
    $from = "From: " . $data['fromName'] . " <" . $data['fromEmail'] . "@cupid.ubixos.com>";
    mail($email,$data['subject'],$data['message'],$from);
    
    return;
    }


  }
?>