File: searchmp3.php

<!-- 
#
# This software may be used and distributed according to the terms
# of the GNU Public License, incorporated herein by reference.
#################################
WebNap Client copyright 2000 
Aakash Kambuj - aakash@kambuj.com 
Kalpak Kothari - kalpak@mit.edu
#################################

You are welcome to modify and distribute this code, but please retain
this copyright notice above any notices you put.  Please send us a
copy of your modified code.

Napster is a registered trademark of Napster Inc - http://www.napster.com
-->

<?

$message_type_login = 2;
$message_type_login_response = 3;
$message_type_sysmsg = 621;
$message_type_search = 200;
$message_type_search_result = 201;
$message_type_search_complete = 202;
$message_type_fileinfo_req = 203;
$message_type_fileinfo = 204;
$message_type_get_error = 206;
$server_to_use="";
// $server_socket=0;


function init_conn($napserver){

  global $server_socket;
  global $message_type_login;
  global $message_type_login_response;
  global $message_type_sysmsg;
  global $server_to_use;

  $server="";
  if (!isset($server_socket)){
    $server_socket=0;
    //$server_socket=2;
    
  }

  $already_connected = $server_socket;
  echo "Connection status is $already_connected <br>";
  if ($already_connected<=0){
    /*
      //find best redirector from napster server
      $fp = fsockopen("server.napster.com", 8875, &$errstr, &$errno); // orig_port 8875
      if(!$fp) {
      echo "$errstr ($errno)<br>\n";
      } else {
      
      echo "The master server port is $fp ";
      while(!feof($fp)) {
      $buffer=fgets($fp,128);
      $server .= $buffer;
      }
      fclose($fp);
      }
    
      $tok = strtok($server,":");
      $host = trim($tok);       //the hostname of the napster server
      $tok = strtok(":");
      $port = (int)$tok;    //the port of the server
      echo "Host is a ", gettype($host);
      echo "Port is a ", gettype($port);
    */

    //$host = "208.184.216.206";
    $host = $napserver;
    $server_to_use=$napserver;
    $port = 8888;
    echo " $host $port ";
  
    
    //now we know the hostname and port to connect to
    echo "Connecting to server <br>";
    $server_socket = fsockopen($host, $port, &$errstr, &$errno);    //open a persistent connection to the server
    if (!$server_socket){
      echo "ERROR $errstr ($errno)<br>\n";
      exit;
    }
    
    echo "Connected: server_socket is  $server_socket <br>";
    $sock = sprintf("%d", $server_socket);
    printf("Connected: server_socket is $sock <br>");
    
    //now we can send a login packet
    
    // please use your own username/password pair here
    $login_string = "idearingwn webNapster 6699 \"v2.0 BETA 6\" 10";
    
    $len = strlen($login_string);
    echo "message length is $len \r <br>";
    
    $login_packet = pack("vv", $len, $message_type_login);
    $login_packet = $login_packet . $login_string;

    fwrite($server_socket, $login_packet);
    //echo fgets($server_socket, 3);
    
    $buffer = read_packet();
    //    echo "<br> Pkt len is $buffer[0], pkt type is $buffer[1], message is $buffer[2] <br> ";
    echo "<br> $buffer[2] ";
    $buffer = read_packet();
    //    echo "<br> Pkt len is $buffer[0], pkt type is $buffer[1], message is $buffer[2]  <br> ";
    echo " $buffer[2] ";
    
    do {
      $buffer = read_packet();
      echo "\r";
      // echo " Packet len is $buffer[0], Packet type is $buffer[1], Message is $buffer[2] <br>";
      echo " $buffer[2] ";

    } while ((int)$buffer[1]==$message_type_sysmsg);

    echo "<br><br> Successfully logged into Napster server <br><br>";    
  }
}




function searchmp3($keywords) {

  global $server_socket;


  echo "The status of the socket is $server_socket";
  echo "<br><br>Keyword  is $keywords <br><br>";

  flush();
  $songs = find_song($keywords);

  //now $songs contains the list of songs we have

  for ($i=0;$i<count($songs);$i++){

    $songlist[$i] = new Song;
    $songlist[$i]->init_song($songs[$i]);
    $songlist[$i]->print_song();

    //echo "    ",$songs[$i],"  <br> ";
  }

  fclose($server_socket);


}

function getmp3($songid){

  global  $server_socket;

  //we have already logged in. The find song code can then be called
  //repeatedly

  //First check the connection to the server

  if ($server_socket<=0){
    echo "ERROR. Connection failed!";
  }     

       
  echo "<br><br> Works so far <br><br>";
  echo "<br> the song id is $songid<br>";
     
  $songinfo = urldecode("$songid");              
  echo "After decode songid is $songinfo<br>";

  $songinfo = unserialize(stripslashes($songinfo));
  echo "<br> after unser songinfo is $songinfo<br>";  
       
       
  $curr_song = new Song;
  $curr_song->unpack_data($songinfo);
  $curr_song->print_song();             
  $curr_song->download_song();
  
  flush();
  echo "<br> All Done!";
     
  fclose($server_socket);  //remove this after development is done


}


function find_song($keywords){

  global $message_type_search;
  global $message_type_search_complete;
  global $message_type_search_result;

  $find_str = "FILENAME CONTAINS \"";
  $find_str .= $keywords;
  $find_str .= "\" MAX_RESULTS 100";

  write_packet($message_type_search, $find_str);

  $songs[0]="";
  $search_done = FALSE;
  $i=0;

  do {
 
    $search_result = read_packet();
 
    switch ($search_result[1]) {
   
    case $message_type_search_complete:
      $search_done = TRUE;
      break;

    case $message_type_search_result:
      $songs[$i]=trim($search_result[2]);
      $i++;
      break;

    default:
      break;
   
    } //end of switch
   
  } while (!$search_done);

  return $songs;

}



function write_packet($m_type, $m_mesg){


  global $server_socket;


  $pkt_len = strlen($m_mesg);
 
  $packet = pack("vv",$pkt_len, $m_type);

  $packet = $packet . $m_mesg;

  fwrite($server_socket, $packet);


}



function read_packet() {

  global $server_socket;

  $data_array="";
     
  $buf = fread($server_socket, 4);
  $buf1 = unpack("v2vals",$buf);
  $len1 = $buf1["vals1"];
  $msg_type1 = $buf1["vals2"];

  //  echo "<br> len1 is $len1  messagetype is $msg_type1 ";
    
  if ($len1 <=0 ) {
    //    echo " EMPTY PACKET->";
    echo "<br><br>";

    $data_array[0] = $len1;
    $data_array[1] = $msg_type1;
    $data_array[2] = "";
  }
  else {
    
    $data = fread($server_socket, $len1);

    $data_array[0] = $len1;
    $data_array[1] = $msg_type1;
    $data_array[2] = $data;
  }

  return $data_array;

}


function uinttoip($hostname){

  echo "$hostname <br>";
  $flag=0;
  $storage = $hostname;
  $temp = (double) $hostname;
  $temp = $temp - 2147483648.0;
  echo "$temp <br>";
  $hostname = (int)$temp;
  if ($hostname < 0 ){
    $hostname = (int) $storage;
  }
  else $flag=1;

  $dig4 = ($hostname & 2130706432) >> 24;

  if ($flag == 1)
    $dig4 += 128;

  $dig3 = ($hostname & 16711680) >> 16;
  $dig2 = ($hostname & 65280) >> 8;
  $dig1 = $hostname & 255;  

  echo "<br> hostname is $hostname<br>";
  echo "<br> dig1 is $dig1  dig2 is $dig2  dig3 is $dig3  dig4 is
$dig4<br>";

  $hname = (string) $dig1;
  $hname = $hname . ".";
  $hname = $hname . (string)$dig2;
  $hname = $hname . ".";
  $hname = $hname . (string)$dig3;
  $hname = $hname . ".";
  $hname = $hname . (string)$dig4;

  echo "<br> Hostname is $hname<br>";
  

  return (string)$hname;


}

function addheader($type){
  switch($type) {
  case 0:
    echo "<html>";
    echo "<title>WebNap v0.2</title>";
    echo "<body bgcolor=white>";
    echo "<center><h1>WebNap v0.2</h1>";
    echo "<hr noshade size=1></center>";
    echo "<br><b>Debug version running</b><br>";       
    break;
  case 1:
    break;
  default:
    echo "<html>";
    echo "<title>WebNap v0.2</title>";
    echo "<body bgcolor=white>";
    echo "<center><h1>WebNap v0.2</h1>";
    echo "<hr noshade size=1></center>";
    echo "<br><b>Debug version running</b><br>";
    break;
  }
}




class Song {

  var $data=array();
  var $user="";
  var $title="";
  var $filename="";
  var $checksum="";
  var $size=0;
  var $bitrate=0;
  var $frequency=0;
  var $time=0;
  var $nick="";
  var $nick_ip="";
  var $conn_speed =0;

  function init_song($str){

    //first, get the pathname of the song
  
    for ($i=(strlen($str)-1);$i>=0 && strcmp($str[$i],'"')!=0;$i--);

    $this->title = substr($str,0,$i+1);
    $this->data["title"]=substr($str,0,$i+1);
    $index = $i;
  
    //now get song name

    for ($i=(strlen($this->title)-1);$i>=0 && strcmp($str[$i],'\\')!=0;$i--);
  

    if ($i==-1){
      $this->filename = $this->title;
      $this->data["filename"] = $this->title;
    }
    else {
      $this->filename = substr($this->title, $i+1, strlen($this->title)-2);
      $this->data["filename"] = substr($this->title, $i+1, strlen($this->title)-2);
    }
    
    $info = substr($str, $index+2);
  
    $tok = strtok($info," ");
  
    $this->checksum = $tok;
    $this->data["checksum"] = $tok;
  
    for ($i=0;$i<7;$i++){
      $tok = strtok(" ");
  
      switch($i){

      case 0:
    $this->size = (int)$tok;
    $this->data["size"] = (int)$tok;
    break;
      
      case 1:
    $this->bitrate = (int)$tok;
    $this->data["bitrate"]=(int)$tok;
    break;
     
      case 2:
    $this->frequency = (int)$tok;
    $this->data["frequency"]=(int)$tok;
    break;

      case 3:
    $this->time = (int)$tok;
    $this->data["time"]=(int)$tok;
    break;
     
      case 4:
    $this->nick = $tok;
    $this->data["nick"]=$tok;
    break;
     
      case 5:
    $this->nick_ip = $tok;
    $this->data["nick_ip"]=$tok;
    break;
       
      case 6:
    $this->conn_speed = (int)$tok;
    $this->data["conn_speed"]=(int)$tok;
    break;

      default:
    break;
      }
    }



  }


  function print_song() {

    global $server_socket;
    global $server_to_use;
    $sock = sprintf("%d", $server_socket);
    
    print( "<br><br>");
    print( "Title is $this->title <br>");
    $stream = urlencode(serialize($this->data));
    print ("Filename is <a href=\"searchmp3.php?napserver=$server_to_use&songid=$stream\">$this->filename</a><br>");
    print( "Nick is $this->nick <br>");
    print( "Checksum is $this->checksum <br>");
    print( "Size is $this->size <br>");
    print( "Bitrate is $this->bitrate <br>");
    print( "Frequency is $this->frequency <br>");
    print( "Song length is $this->time <br>");
    print( "Connection speed is $this->conn_speed <br>");
    print( "<br>");
    flush();

  }


  function unpack_data($datum){


    echo "<br> Miaow........DAtum is $datum<br>";


    $this->data = $datum;

    $this->data["title"] = $datum["title"];
    $this->title = $datum["title"];

    $this->data["filename"] = $datum["filename"];
    $this->filename = $datum["filename"];

    $this->data["checksum"] = $datum["checksum"];
    $this->checksum = $datum["checksum"];

    $this->data["size"] = $datum["size"];
    $this->size = $datum["size"];

    $this->data["bitrate"] = $datum["bitrate"];
    $this->bitrate = $datum["bitrate"];

    $this->data["frequency"] = $datum["frequency"];
    $this->frequency = $datum["frequency"];

    $this->data["time"] = $datum["time"];
    $this->time = $datum["time"];

    $this->data["nick"] = $datum["nick"];
    $this->nick = $datum["nick"];
  
    $this->data["nick_ip"] = $datum["nick_ip"];
    $this->nick_ip = $datum["nick_ip"];
  
  
    $this->data["conn_speed"] = $datum["conn_speed"];
    $this->conn_speed = $datum["conn_speed"];
  
  }


  function download_song() {

    global $server_socket;
    global $message_type_fileinfo_req;
    global $message_type_fileinfo;
    global $message_type_get_error;

    //send message to server
    $message = "$this->nick  ";
    $message .= "$this->title";
    print("<br>Requesting file from server message: $message<br>");


    write_packet($message_type_fileinfo_req, $message);

    $answer ="";
    print("<br>Before receiving reply from server: $answer<br>");
    print("<br>message_type_fileinfo: $message_type_fileinfo ; message_type_get_error: $message_type_get_error ;<br>");
    flush();

    $answer = read_packet();
    print("<br>The server replied $answer[1] $answer[2]<br>");

    if((int)$answer[1]==$message_type_get_error) {
      print("<br> Download Error. The remote file you requested to download is unavailable.<br>");
      flush();
      return;
    }
      
    if ((int)$answer[1]!=$message_type_fileinfo) {
      // return if we did not receive download ack
      print("<br> Download Error. Did not receive download ACK.<br>");
      flush();
      return;
    }

    /*
      while(((int)$answer[1]!=$message_type_fileinfo) or ((int)$answer[1]!=$message_type_get_error)){
      $answer = read_packet();
      print("<br>The server replied $answer[1] $answer[2]<br>");
      flush();
      }
    */

    echo "<br> Server sends IP and port of remote user <br>";
    
    $ruser = strtok($answer[2], " ");
    $rhost = strtok(" ");
    $rport = strtok(" ");
    

    //Convert the $rhost to quad dotted ip address format
      
    $rhost = uinttoip($rhost);
    flush();    

    echo "Remote Host is $rhost";
    echo "Remote Port is $rport";

    if ($rport != 0) {
      //    $title_withoutquotes = substr($this->title, 1, -1);
      $title_withoutquotes = rawurlencode($this->title);
      $filename_withoutquotes = rawurlencode($this->filename);

      echo "<br><center><a href=\"download.php?rhost=$rhost&rport=$rport&title=$title_withoutquotes&filename=$filename_withoutquotes\">Download song</a></center><br>";            
      
      fclose($server_socket); // we are still unable to use just one socket. this keeps the number of open sockets low.
    }
    else {
      echo "<br>Remote user is behind a firewall. Download option from such users is yet to implemented.";

      $local_socket = fsockopen("127.0.0.1", 6699, &$errstr, &$errno);
      if (!$local_socket) {
    echo "$errstr ($errno)<br>\n";
      } else {
    while(!feof($local_socket)) {
      echo fgets($local_socket,128);
    }
    fclose($local_socket);
      }



      fclose($server_socket);
    }
  }

}

// make sure that socket is closed when script ends (normal or "user abort")
register_shutdown_function("close_conn");

function close_conn(){
  global $server_socket;
  if ($server_socket>0) {
    fclose($server_socket);
  }
}


?>

<? 
if (isset($songid)){
  addheader(0);
  init_conn($napserver);
  getmp3($songid);
}
else {
  if (isset($keywords)){
    addheader(0);
    init_conn($napserver);
    searchmp3($keywords);
  }
}
?>

</body></html>