Как получить переменную из callback php?

Question

[Sun2790]

$client = new \Binance\Websocket\Spot();

$callbacks = [
    'message' => function ($conn, $msg) {
        echo $msg.PHP_EOL;
    },
    'ping' => function ($conn, $msg) {
        echo "received ping from server".PHP_EOL;
    }
];

# single pair
$client->miniTicker($callbacks, 'btcusdt');

Как вытащить сюда переменную $msg?

Что я только не пробовал. В пределах моих знаний. У меня возвращает в основном null.

Comments

[Dmitry Bay]

вас функция null позвращает.

[Dmitry Bay]

ниже echo надо
return $msg;

[Sun2790]

Dmitry Bay, вот так?
echo $msg.PHP_EOL;
return $msg;

Answer 1

[Виктор Кожухарь]

Можно использовать замыкание. Тут фишка в том, что надо использовать в замыкании не обычную строковую переменную, а объект, потому что строковая переменная будет передана в виде копии, и не получится её изменить.
В коде я заменил класс Client на его мок.

class Client {
    public function miniTicker(array $callbacks) {
        foreach ($callbacks as $key => $callback) {
            $conn = 'aaaaa';
            $msg = 'msg-'.$key;
            $callback($conn, $msg);
        }
    }
}

class Message {
    public array $messages = [];

    public function addMessage(string $msg) {
        $this->messages[] = $msg;
    }
}

$message = new Message();

$callbacks = [
    'message' => function ($conn, $msg) use ($message) {
        $message->addMessage($msg);
        
    },
    'ping' => function ($conn, $msg) use ($message) {
        $message->addMessage($msg);
    }
];

$client = new Client();
$client->miniTicker($callbacks);
var_dump($message->messages);

В результате в конце у нас выводятся все сообщения
https://onlinephp.io/?s=tVK7boQwEOyR-IctkDDSkR8gR4...

Comments

[Sun2790]

Да. Сообщения выводятся. Как это переписать? У меня --> spot.php
public function miniTicker($callback, $symbol=null)
{
if ($symbol) {
$url = "{$this->baseURL}/ws/". strtolower($symbol) . "@miniTicker";
} else {
$url = "{$this->baseURL}/ws/!miniTicker@arr";
}
$this->handleCallBack($url, $callback);
}

И сам handleCallBack в вебсокетах websocket.php
protected function handleCallBack($url, $callback)
{
if (is_array($callback)) {
foreach ($callback as $event => $func) {
if (gettype($event) == "integer") {
throw new InvalidArgumentException("callback", json_decode($callback), "Array has event type as key, e.g. ['message' => function() {}]", "Please find example at https://github.com/binance/binance-connector-php");
}
}
}
$this->createWSConnection($url)->then(function ($conn) use ($callback) {
$this->wsConnection = $conn;
if (is_callable($callback)) {
$conn->on('message', function ($msg) use ($conn, $callback) {
$callback($conn, $msg);
});
}

if (is_array($callback)) {
foreach ($callback as $event => $func) {
$event = strtolower(strval($event));
if (in_array($event, ['message', 'ping', 'pong', 'close'])) {
$conn->on($event, function ($msg) use ($conn, $func) {
call_user_func($func, $conn, $msg);
});
}
}
}
}, function ($e) {
$this->logger->error("Could not connect: {$e->getMessage()}".PHP_EOL);
});
}

[Виктор Кожухарь]

Ну вот прямо из моего примера всё и взять. У меня там класс Client - это просто имитация вашего бинансовского класса Client.

Главное - это конструкция use в коллбэках. Она замыкает переменную $message внутри этих коллбэков. А т.к. переменная $message является просто ссылкой на сам объект, то когда эта переменная копируется внутрь коллбэка через замыкание, она всё равно ссылается на тот же самый объект, и мы этим пользуемся, чтобы собирать сообщения

[Sun2790]

Виктор Кожухарь, Ну вот я так делаю
<?php
require_once __DIR__ . '/../../../vendor/autoload.php';

$client = new \Binance\Websocket\Spot();

class Client {
public function miniTicker(array $callbacks) {
foreach ($callbacks as $key => $callback) {
$conn = 'aaaaa';
$msg = 'msg-'.$key;
$callback($conn, $msg);
}
}
}

class Message {
public array $messages = [];

public function addMessage(string $msg) {
$this->messages[] = $msg;
}
}

$message = new Message();

$callbacks = [
'message' => function ($conn, $msg) use ($message) {
$message->addMessage($msg);

},
'ping' => function ($conn, $msg) use ($message) {
$message->addMessage($msg);
}
];

$client = new Client();
$client->miniTicker($callbacks);
var_dump($message->messages);

Получаю ответ
array(2) { [0]=> string(11) "msg-message" [1]=> string(8) "msg-ping" }

Как это подставить чтобы работало я не понимаю.

[Виктор Кожухарь]

<?php
require_once __DIR__ . '/../../../vendor/autoload.php';

// Этот класс Message лучше вынести в отдельный файл.
class Message {
    public array $messages = [];

    public function addMessage(string $msg) {
        $this->messages[] = $msg;
    }
}

$message = new Message();

$client = new \Binance\Websocket\Spot();

$callbacks = [
    'message' => function ($conn, $msg)  use ($message) {
        $message->addMessage($msg);
        echo $msg.PHP_EOL;
    },
    'ping' => function ($conn, $msg)  use ($message) {
       $message->addMessage($msg);
        echo "received ping from server".PHP_EOL;
    }
];

# single pair
$client->miniTicker($callbacks, 'btcusdt');
var_dump($message->messages);

[Sun2790]

Вот что получаю.
array(0) { }
Просто какой то кубик рубик.))
Пробую другими вариантами, опять же либо null , либо N;
либо O:7:"Message":1:{s:8:"messages";a:0:{}}

Answer 2

[Rsa97]

Никак не получить, да и смысла в этом нет. Каллбэк может быть вызван в любое время и неоднократно. Работать с сообщением надо прямо в нём.

Comments

[Sun2790]

Я пытаюсь записывать данные в файл
'message' => function ($conn, $msg) { // далее запишу $msg
записываю с помощью file_put_contents
но не файл не добавляется, не данные