mirror of
https://gitlab.com/niansa/llama_nds.git
synced 2025-03-06 20:53:28 +01:00
44 lines
1.1 KiB
C++
44 lines
1.1 KiB
C++
#ifndef CLIENT_HPP
|
|
#define CLIENT_HPP
|
|
#include "Runtime.hpp"
|
|
#include "AsyncManager.hpp"
|
|
#include "Socket.hpp"
|
|
#include "Sender.hpp"
|
|
#include "Receiver.hpp"
|
|
#include "basic-coro/AwaitableTask.hpp"
|
|
|
|
#include <string>
|
|
#include <string_view>
|
|
#include <stdexcept>
|
|
#include <memory>
|
|
#include <functional>
|
|
#ifndef PLATFORM_WINDOWS
|
|
# include <netdb.h>
|
|
#else
|
|
# include <ws2tcpip.h>
|
|
#endif
|
|
|
|
|
|
class Client
|
|
{
|
|
struct Exception : public std::runtime_error {
|
|
using std::runtime_error::runtime_error;
|
|
};
|
|
|
|
AsyncManager& aMan;
|
|
|
|
int fd = -1;
|
|
bool sent = false;
|
|
hostent *addrInfo; // Can't be null unless request has already been sent
|
|
|
|
std::unique_ptr<SocketConnection<Sender::Simple, Receiver::Simple>> connection;
|
|
|
|
void fetchAddr(const std::string& addr, unsigned port);
|
|
|
|
public:
|
|
Client(const std::string &addr, unsigned port, AsyncManager& asyncManager);
|
|
|
|
basiccoro::AwaitableTask<AsyncResult> ask(std::string_view prompt, const std::function<basiccoro::AwaitableTask<void> (unsigned progress)>& on_progress, const std::function<basiccoro::AwaitableTask<void> (std::string_view token)>& on_token);
|
|
};
|
|
|
|
#endif // CLIENT_HPP
|