client.h

Go to the documentation of this file.

#pragma once
#include <string>
#include <memory>
#include <vector>
#include "member.h"
#ifdef WEBCFACE_MESON
#include "webcface-config.h"
#else
#include "webcface/common/webcface-config.h"
#endif
 
WEBCFACE_NS_BEGIN
 
class WEBCFACE_DLL Client : public Member {
    std::shared_ptr<internal::ClientData> data;
 
  public:
    Client(const Client &) = delete;
    const Client &operator=(const Client &) = delete;
 
    Client() : Client("") {}
    explicit Client(const std::string &name,
                    const std::string &host = "127.0.0.1",
                    int port = WEBCFACE_DEFAULT_PORT)
        : Client(SharedString::encode(name), SharedString::encode(host), port) {
    }
    explicit Client(const std::wstring &name,
                    const std::wstring &host = L"127.0.0.1",
                    int port = WEBCFACE_DEFAULT_PORT)
        : Client(SharedString::encode(name), SharedString::encode(host), port) {
    }
 
    explicit Client(const SharedString &name, const SharedString &host,
                    int port);
    explicit Client(const SharedString &name,
                    const std::shared_ptr<internal::ClientData> &data);
 
    bool connected() const;
 
    template <typename F, typename std::enable_if_t<std::is_invocable_v<F>,
                                                    std::nullptr_t> = nullptr>
    const Client &onDisconnect(F callback) const {
        this->Member::onDisconnect(
            [callback = std::move(callback)](const auto &) { callback(); });
        return *this;
    }
    template <typename F, typename std::enable_if_t<std::is_invocable_v<F>,
                                                    std::nullptr_t> = nullptr>
    const Client &onConnect(F callback) const {
        this->Member::onConnect(
            [callback = std::move(callback)](const auto &) { callback(); });
        return *this;
    }
 
    ~Client();
    const Client &close() const;
 
    const Client &autoReconnect(bool enabled) const;
    bool autoReconnect() const;
 
    const Client &start() const;
    const Client &waitConnection() const;
 
  private:
    const Client &
    syncImpl(std::optional<std::chrono::microseconds> timeout) const;
 
  public:
    const Client &sync() const {
        return syncImpl(std::chrono::microseconds(0));
    }
    const Client &loopSyncFor(std::chrono::microseconds timeout) const {
        return syncImpl(timeout);
    }
    template <typename Clock, typename Duration>
    const Client &
    loopSyncUntil(std::chrono::time_point<Clock, Duration> timeout) const {
        return syncImpl(std::chrono::duration_cast<std::chrono::microseconds>(
            timeout - Clock::now()));
    }
    const Client &loopSync() const { return syncImpl(std::nullopt); }
 
    // /*!
    //  * \brief 別スレッドでsync()を自動的に呼び出す間隔を設定する。
    //  * \since ver2.0
    //  *
    //  * * start() や waitConnection() より前に設定する必要がある。
    //  * *
    //  autoSyncが有効の場合、別スレッドで一定間隔(100μs)ごとにsync()が呼び出され、
    //  * 各種コールバック (onEntry, onChange, Func::run()など)
    //  * も別のスレッドで呼ばれることになる
    //  * (そのためmutexなどを適切に設定すること)
    //  * * デフォルトでは無効なので、手動でsync()などを呼び出す必要がある
    //  *
    //  * \param enabled trueにすると自動でsync()が呼び出されるようになる
    //  * \sa sync(), loopSyncFor(), loopSyncUntil(), loopSync()
    //  */
    // void autoSync(bool enabled);
 
  private:
    Member member(const SharedString &name) const {
        if (name.empty()) {
            return *this;
        } else {
            return Member{data, name};
        }
    }
 
  public:
    Member member(std::string_view name) const {
        return member(SharedString::encode(name));
    }
    Member member(std::wstring_view name) const {
        return member(SharedString::encode(name));
    }
    std::vector<Member> members();
    std::vector<Member> members() const;
    const Client &
    onMemberEntry(std::function<void WEBCFACE_CALL_FP(Member)> callback) const;
 
    std::streambuf *loggerStreamBuf() const;
    std::streambuf *loggerStreamBuf(std::string_view name) const;
    std::ostream &loggerOStream() const;
    std::ostream &loggerOStream(std::string_view name) const;
    std::wstreambuf *loggerWStreamBuf() const;
    std::wstreambuf *loggerWStreamBuf(std::wstring_view name) const;
    std::wostream &loggerWOStream() const;
    std::wostream &loggerWOStream(std::wstring_view name) const;
 
    const std::string &serverVersion() const;
    const std::string &serverName() const;
    const std::string &serverHostName() const;
};
 
WEBCFACE_NS_END