diff options
Diffstat (limited to 'src/blu_cat/net/client')
-rw-r--r-- | src/blu_cat/net/client/client.cpp | 64 | ||||
-rw-r--r-- | src/blu_cat/net/client/client.hpp | 61 |
2 files changed, 125 insertions, 0 deletions
diff --git a/src/blu_cat/net/client/client.cpp b/src/blu_cat/net/client/client.cpp new file mode 100644 index 0000000..6ee6046 --- /dev/null +++ b/src/blu_cat/net/client/client.cpp @@ -0,0 +1,64 @@ +/* + * Copyright 2022-2025 Frederico de Oliveira Linhares + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "client.hpp" + +namespace BluCat::NET +{ + +void +Client::connect(const char *host, const UI16 port) +{ + if(this->connection) return; + + asio::error_code error; + asio::ip::tcp::endpoint endpoint{asio::ip::make_address(host, error), port}; + + asio::ip::tcp::socket socket(this->io_context); + socket.connect(endpoint); + + this->connection = new Connection( + this, this->io_context, std::move(socket), 0); + + this->thread_context = std::thread([this](){this->io_context.run();}); +} + +void +Client::disconnect(unsigned long index) +{ + if(!this->connection) return; + + this->io_context.stop(); + delete this->connection; + this->connection = nullptr; +} + +Client::Client(const char *host, const UI16 port) +{ + this->connect(host, port); +} + +Client::Client() +{ +} + +Client::~Client() +{ + this->disconnect(0); + if(this->thread_context.joinable()) this->thread_context.join(); +} + +} diff --git a/src/blu_cat/net/client/client.hpp b/src/blu_cat/net/client/client.hpp new file mode 100644 index 0000000..ad0e298 --- /dev/null +++ b/src/blu_cat/net/client/client.hpp @@ -0,0 +1,61 @@ +/* + * Copyright 2022-2025 Frederico de Oliveira Linhares + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef BLU_CAT_NET_CLIENT_CLIENT_H +#define BLU_CAT_NET_CLIENT_CLIENT_H 1 + +#include "../../com/numbers.hpp" +#include "../common/connection.hpp" +#include "../common/connection_callback.hpp" + +namespace BluCat::NET +{ + +class Client: public ConnectionCallback +{ + asio::io_context io_context; + std::thread thread_context; + + Connection *connection; + +public: + inline bool + send(const UI32 id, std::vector<UI8> &msg) + {return this->connection->send(id, msg);}; + + inline bool + read_message(Message *m) + {return this->connection->read_message(m);}; + + inline bool + is_connected() + {return this->connection != nullptr;}; + + void + connect(const char *host, const UI16 port); + + void + disconnect(unsigned long index); + + Client( + const char *host, const UI16 port); + Client(); + ~Client(); +}; + +} + +#endif /* BLU_CAT_NET_CLIENT_CLIENT_H */ |