Websocket UserData Futures

[faca5]

Hello.

How to change PHP code below to start working with FUTURES. Right now it works only on SPOT.

Thank you

PHP code:
`/**

• userData Issues userDataStream token and keepalive, subscribes to userData WebSocket

• $balance_update = function($api, $balances) {

• print_r($balances);

• echo "Balance update".PHP_EOL;

• };

• $order_update = function($api, $report) {

• echo "Order update".PHP_EOL;

• print_r($report);

• $price = $report['price'];

• $quantity = $report['quantity'];

• $symbol = $report['symbol'];

• $side = $report['side'];

• $orderType = $report['orderType'];

• $orderId = $report['orderId'];

• $orderStatus = $report['orderStatus'];

• $executionType = $report['orderStatus'];

• if( $executionType == "NEW" ) {

• if( $executionType == "REJECTED" ) {

• echo "Order Failed! Reason: {$report['rejectReason']}".PHP_EOL;

• }

• echo "{$symbol} {$side} {$orderType} ORDER #{$orderId} ({$orderStatus})".PHP_EOL;

• echo "..price: {$price}, quantity: {$quantity}".PHP_EOL;

• return;

• }

• //NEW, CANCELED, REPLACED, REJECTED, TRADE, EXPIRED

• echo "{$symbol} {$side} {$executionType} {$orderType} ORDER #{$orderId}".PHP_EOL;

• };

• $api->userData($balance_update, $order_update);

• @param $balance_callback callable function

• @param bool $execution_callback callable function

• @return null

• @throws \Exception
  */
  public function userData(&$balance_callback, &$execution_callback = false)
  {
  $response = $this->httpRequest("v1/userDataStream", "POST", []);
  $this->listenKey = $response['listenKey'];

  $this->info['balanceCallback'] = $balance_callback;
  $this->info['executionCallback'] = $execution_callback;

  $this->subscriptions['@userdata'] = true;

  $loop = \React\EventLoop\Factory::create();
  $loop->addPeriodicTimer(30*60, function () {
  $listenKey = $this->listenKey;
  $this->httpRequest("v1/listenKey={$listenKey}", "PUT", []);
  });
  $connector = new \Ratchet\Client\Connector($loop);

  // @codeCoverageIgnoreStart
  // phpunit can't cover async function
  $connector($this->getWsEndpoint() . $this->listenKey)->then(function ($ws) {
  $ws->on('message', function ($data) use ($ws) {
  if ($this->subscriptions['@userdata'] === false) {
  //$this->subscriptions[$endpoint] = null;
  $ws->close();
  return; //return $ws->close();
  }
  $json = json_decode($data);
  $type = $json->e;
  if ($type === "outboundAccountPosition") {
  $balances = $this->balanceHandler($json->B);
  $this->info['balanceCallback']($this, $balances);
  } elseif ($type === "executionReport") {
  $report = $this->executionHandler($json);
  if ($this->info['executionCallback']) {
  $this->info['executionCallback']($this, $report);
  }
  }
  });
  $ws->on('close', function ($code = null, $reason = null) {
  // WPCS: XSS OK.
  echo "userData: WebSocket Connection closed! ({$code} - {$reason})" . PHP_EOL;
  });
  }, function ($e) {
  // WPCS: XSS OK.
  echo "userData: Could not connect: {$e->getMessage()}" . PHP_EOL;
  });

  $loop->run();
  }`