diff --git a/python/infinity/remote_thrift/client.py b/python/infinity/remote_thrift/client.py index 83bd1ccf16..0ec764ef7b 100644 --- a/python/infinity/remote_thrift/client.py +++ b/python/infinity/remote_thrift/client.py @@ -21,7 +21,7 @@ from infinity.remote_thrift.infinity_thrift_rpc import * from infinity.remote_thrift.infinity_thrift_rpc.ttypes import * from infinity.errors import ErrorCode - +from infinity.common import InfinityException class ThriftInfinityClient: def __init__(self, uri: URI): @@ -43,7 +43,10 @@ def reconnect(self): # version: 0.2.0.dev2, client_version: 1 # version: 0.2.0.dev3, client_version: 2 - res = self.client.Connect(ConnectRequest(client_version=1)) + # version: 0.2.0.dev4, client_version: 3 + res = self.client.Connect(ConnectRequest(client_version=2)) + if res.error_code != 0: + raise InfinityException(res.error_code, res.error_msg) self.session_id = res.session_id def create_database(self, db_name: str, conflict_type: CreateConflict = CreateConflict.Error): diff --git a/src/network/infinity_thrift_service.cpp b/src/network/infinity_thrift_service.cpp index b0ab9836f9..e9288c08e5 100644 --- a/src/network/infinity_thrift_service.cpp +++ b/src/network/infinity_thrift_service.cpp @@ -64,6 +64,7 @@ namespace infinity { ClientVersions::ClientVersions() { client_version_map_[1] = String("0.2.0.dev2"); + client_version_map_[2] = String("0.2.0.dev3"); } Pair ClientVersions::GetVersionByIndex(i64 version_index) { diff --git a/src/network/infinity_thrift_service.cppm b/src/network/infinity_thrift_service.cppm index 115d55c6d8..3ef6891743 100644 --- a/src/network/infinity_thrift_service.cppm +++ b/src/network/infinity_thrift_service.cppm @@ -56,7 +56,7 @@ struct ClientVersions { export class InfinityThriftService final : public infinity_thrift_rpc::InfinityServiceIf { private: static constexpr std::string_view ErrorMsgHeader = "[THRIFT ERROR]"; - static constexpr i64 current_version_index_{1}; + static constexpr i64 current_version_index_{2}; // 0.2.0.dev3 static std::mutex infinity_session_map_mutex_; static HashMap> infinity_session_map_;