web/public_php/ring/join_shard.php

   1 <?php
   2         require_once('../tools/validate_cookie.php');
   3         include_once('../login/config.php');
   4         include_once('../tools/domain_info.php');
   5         include_once('ring_session_manager_itf.php');
   6
   7 class JoinShardCb extends CRingSessionManagerWeb
   8 {
   9         /**
  10          * Join the specified shard
  11          */
  12         function joinSessionResult($userId, $sessionId, $result, $shardAddr, $participantStatus)
  13         {
  14                 global $JoinSessionResultCode, $JoinSessionResultMsg;
  15                 $JoinSessionResultCode = $result;
  16                 $JoinSessionResultMsg = $shardAddr;
  17                 if ($result != 0)
  18                 {
  19                         global $FSHostLuaMode, $FSHostResult, $FSHostResultStr;
  20                         $FSHostResult = 0;
  21                         $FSHostResultStr = "Error ".$result." : '".$shardAddr."' while trying to join a shard";
  22                         if ($FSHostLuaMode)
  23                         {
  24                                 echo $FSHostResultStr;
  25                                 echo '<p><p><a href="web_start.php">Back to menu</a>';
  26                         }
  27                 }
  28                 else
  29                 {
  30                         // ok, we have the info to connect !
  31                         // generate the lua script
  32                         $cookie=convertCookieForActionHandler($_COOKIE["ryzomId"]);
  33                         global $FSHostLuaMode, $FSHostResult, $FSHostResultStr;
  34                         $FSHostResult = 1;
  35                         $FSHostResultStr = $shardAddr;
  36                         if ($FSHostLuaMode)
  37                         {
  38                                 $luaScript='runAH(nil, "on_connect_to_shard", "cookie='.$cookie.'|fsAddr='.$shardAddr.'")';
  39                                 //echo 'luaScript : '.$luaScript.'<br>';
  40                                 echo '<lua>'.$luaScript.'</lua>';
  41                                 global $verbose;
  42                                 if ($verbose)
  43                                         echo '<br>Teleporting to shard<br>';
  44                         }
  45                 }
  46         }
  47
  48         /**
  49          * Receive the result of the shard list, then call the global $getShardListCallback with the associative array as argument
  50          */
  51         function getShardsResult($userId, $resultStr)
  52         {
  53                 global $getShardListCallback;
  54
  55                 $onlineShardsBySessionId = array();
  56                 $resultArray = explode(';', $resultStr);
  57                 foreach ($resultArray as $shardInfo)
  58                 {
  59                         $shardAttr = explode(',', $shardInfo);
  60                         if (isset($shardAttr[1]))
  61                                 $onlineShardsBySessionId[$shardAttr[0]] = $shardAttr[1];
  62                 }
  63                 $getShardListCallback($onlineShardsBySessionId);
  64         }
  65 }
  66
  67 // External use
  68 $FSHostLuaMode = false;
  69 $FSHostResultStr = 0;
  70
  71 // Internal use
  72 $verbose = true;
  73 $FSHostResult = 0;
  74
  75 // THE ABOVE DECLARATIONS ARE NEEDED FOR ALL CODE BELOW THIS LINE
  76 if (isset($_POST["ml"]))
  77         joinMainlandPost();
  78 if (isset($_POST["destSessionId"]))
  79         joinShardFromIdPost($_POST["destSessionId"]);
  80
  81 /**
  82  * Authenticate and request to join a mainland shard
  83  */
  84 function joinMainlandPost()
  85 {
  86         global $FSHostLuaMode;
  87         $FSHostLuaMode = true;
  88         $domainId = -1;
  89         if (!validateCookie($userId, $domainId, $charId))
  90         {
  91                 echo "Invalid cookie !";
  92                 die();
  93         }
  94         else
  95         {
  96                 joinMainland($userId, $domainId);
  97         }
  98 }
  99
 100 /**
 101  * Authenticate and request to join the specified shard
 102  */
 103 function joinShardFromIdPost( $destSessionId )
 104 {
 105         $domainId = -1;
 106         if (!validateCookie($userId, $domainId, $charId))
 107         {
 108                 echo "Invalid cookie !";
 109                 die();
 110         }
 111         else
 112         {
 113                 joinShardFromId($userId, $domainId, $destSessionId);
 114         }
 115 }
 116
 117 /**
 118  * Request to join the specified shard
 119  */
 120 function joinShardFromId( $userId, $domainId, $destSessionId )
 121 {
 122         $domainInfo = getDomainInfo($domainId);
 123         $addr = explode(":", $domainInfo["session_manager_address"]);
 124         $RSMHost = $addr[0];
 125         $RSMPort = $addr[1];
 126
 127         // request join to the session manager
 128         $joinShard = new JoinShardCb;
 129         $res = "";
 130         $joinShard->connect($RSMHost, $RSMPort, $res);
 131         $charSlot = getCharSlot(); // if ingame (!=15), the RSM can check if this character has the right to connect to the specified shard
 132         $charId = ($userId<<4) + $charSlot;
 133         echo "Requesting teleportation of $charId/$userId to shard session ".$destSessionId."...<br>";
 134         $joinShard->joinSession($charId, $destSessionId, $domainInfo["domain_name"]);
 135
 136         // wait the the return message
 137         if ($joinShard->waitCallback() == false)
 138         {
 139                 // Note: the answer is a joinSessionResult message
 140                 echo "No response from server, joinShard failed<br>";
 141         }
 142         die();
 143 }
 144
 145 /**
 146  * Request to get the shard list
 147  */
 148 function getShardList($userId, $domainId)
 149 {
 150         $domainInfo = getDomainInfo($domainId);
 151         $addr = explode(":", $domainInfo["session_manager_address"]);
 152         $RSMHost = $addr[0];
 153         $RSMPort = $addr[1];
 154
 155         // request get to the session manager
 156         $joinShard = new JoinShardCb;
 157         $res = "";
 158         $joinShard->connect($RSMHost, $RSMPort, $res);
 159
 160         $charId = ($userId<<4)+15;
 161         echo "Retrieving online shards for $charId...<br>";
 162         $joinShard->getShards($charId);
 163
 164         // wait the the return message
 165         if ($joinShard->waitCallback() == false)
 166         {
 167                 echo "No response from server, getShards failed<br>";
 168         }
 169         die();
 170 }
 171
 172 /**
 173  * Display the list of mainland shards
 174  * This is a candidate to the callback $getShardListCallback
 175  */
 176 function displayAllShards(&$onlineShardsBySessionId)
 177 {
 178         // Get the userId and domainId back
 179         $domainId = -1;
 180         if (!validateCookie($userId, $domainId, $charId))
 181         {
 182                 echo "Invalid cookie !";
 183                 die();
 184         }
 185
 186         // List all shards of the domain, including offline ones
 187         global $DBName, $DBHost, $DBUserName, $DBPassword;
 188         $link = mysqli_connect($DBHost, $DBUserName, $DBPassword) or die("Can't connect to nel database");
 189         mysqli_select_db($link, $DBName) or die ("Can't access to the db dbname:$DBName");
 190
 191         $domainId = (int) $domainId;
 192         $query = "select * from shard where domain_id = $domainId";
 193         $resShards = mysqli_query($link, $query) or die ("Can't execute the query: ".$query." ".mysqli_error($link));
 194
 195         echo "Select a shard to join:<br>";
 196         //echo "<form name='far_tp' action='join_shard.php' method='post'>";
 197         while ($rowShard = mysqli_fetch_assoc($resShards))
 198         {
 199                 $mainlandSessionId = $rowShard['FixedSessionId'];
 200                 $isOnline = isset($onlineShardsBySessionId[$mainlandSessionId]);
 201                 // Radio button not supported by Client's html component. Instead: one form (button) per shard.
 202                 //echo "<input type='radio' name='destSessionId' value='".$mainlandSessionId."' ".($isOnline?"":"disabled ")."/>".$rowShard['Name']." (".($isOnline?"online with $nbOnlinePlayers players":"offline").", version ".$rowShard['Version'].")<br>";
 203                 echo "<form name='far_tp_".$rowShard['ShardId']."' action='join_shard.php' method='post'>";
 204                 echo "<input type='hidden' name='destSessionId' value='".$mainlandSessionId."' />";
 205                 echo "<input type='hidden' name='charSlot' value='".getCharSlot()."'>";
 206                 echo " ".$rowShard['Name']." ".$rowShard['ShardId']." (".($isOnline ? $onlineShardsBySessionId[$mainlandSessionId]." online)" : "offline)");
 207                 if ($isOnline)
 208                         echo "<input type='submit' name='button' value='Teleport' />";
 209                 echo "</form><br>";
 210         }
 211
 212         //echo "<input type='submit' name='button' value='Teleport' />";
 213         //echo "</form></font>";
 214         die();
 215 }
 216
 217
 218 /**
 219  * Auto-join a shard.
 220  * Returns true in case of success, and the FSHost address in $FSHostResultStr.
 221  * Returns false in case of error, and an explanatory string in $FSHostResultStr.
 222  */
 223 function joinMainland($userId, $domainId)
 224 {
 225         $domainInfo = getDomainInfo($domainId);
 226         $addr = explode(":", $domainInfo["session_manager_address"]);
 227         $RSMHost = $addr[0];
 228         $RSMPort = $addr[1];
 229
 230         // request get to the session manager
 231         $joinsShard = new JoinShardCb;
 232         $res = "";
 233         $joinsShard->connect($RSMHost, $RSMPort, $res);
 234
 235         // set the shard Id to allow any character (by using the special value '15')
 236         $charId = ($userId<<4)+15;
 237         global $FSHostLuaMode, $verbose;
 238         if ($FSHostLuaMode && $verbose)
 239                 echo "Joining a mainland shard for $charId...<br>";
 240         $joinsShard->joinMainland($charId, $domainInfo["domain_name"]);
 241
 242         // wait the the return message
 243         if ($joinsShard->waitCallback() == false)
 244         {
 245                 global $FSHostResultStr;
 246                 $FSHostResultStr = "No response from server for joinMainland<br>";
 247                 return false;
 248         }
 249         global $FSHostResult;
 250         return $FSHostResult;
 251 }
 252