diff --git a/src/ZM/API/CQAPI.php b/src/ZM/API/CQAPI.php index 68819329..727e88cc 100644 --- a/src/ZM/API/CQAPI.php +++ b/src/ZM/API/CQAPI.php @@ -29,25 +29,15 @@ trait CQAPI public function processWebsocketAPI($connection, $reply, $function = false) { $api_id = ZMAtomic::get("wait_msg_id")->add(1); $reply["echo"] = $api_id; - SpinLock::lock("wait_api"); - $r = LightCacheInside::get("wait_api", "wait_api"); - $r[$api_id] = [ - "data" => $reply, - "time" => microtime(true), - "self_id" => $connection->getOption("connect_id"), - "echo" => $api_id - ]; - LightCacheInside::set("wait_api", "wait_api", $r); - SpinLock::unlock("wait_api"); if (server()->push($connection->getFd(), json_encode($reply))) { if ($function === true) { - return CoMessage::yieldByWS($r[$api_id], ["echo"], 60); - } else { - SpinLock::lock("wait_api"); - $r = LightCacheInside::get("wait_api", "wait_api"); - unset($r[$api_id]); - LightCacheInside::set("wait_api", "wait_api", $r); - SpinLock::unlock("wait_api"); + $obj = [ + "data" => $reply, + "time" => microtime(true), + "self_id" => $connection->getOption("connect_id"), + "echo" => $api_id + ]; + return CoMessage::yieldByWS($obj, ["echo"], 60); } return true; } else { diff --git a/src/ZM/ConsoleApplication.php b/src/ZM/ConsoleApplication.php index 760b0b96..69960d47 100644 --- a/src/ZM/ConsoleApplication.php +++ b/src/ZM/ConsoleApplication.php @@ -18,8 +18,8 @@ use ZM\Utils\DataProvider; class ConsoleApplication extends Application { - const VERSION_ID = 388; - const VERSION = "2.3.1"; + const VERSION_ID = 395; + const VERSION = "2.3.2"; public function __construct(string $name = 'UNKNOWN') { define("ZM_VERSION_ID", self::VERSION_ID); diff --git a/src/ZM/DB/Table.php b/src/ZM/DB/Table.php index dc2e8155..94253ce9 100644 --- a/src/ZM/DB/Table.php +++ b/src/ZM/DB/Table.php @@ -61,7 +61,7 @@ class Table if ($msg == "") { $msg .= $k . " $operator ? "; } else { - $msg .= "AND " . $k . " $operator ?"; + $msg .= " AND " . $k . " $operator ?"; } $param[] = $v; }