cogito/esphome_dev/esphome/components/openthread/openthread.h

68 lines
1.8 KiB
C++

#pragma once
#include "esphome/core/defines.h"
#ifdef USE_OPENTHREAD
#include "esphome/components/mdns/mdns_component.h"
#include "esphome/components/network/ip_address.h"
#include "esphome/core/component.h"
#include <openthread/thread.h>
#include <optional>
#include <vector>
namespace esphome {
namespace openthread {
class InstanceLock;
class OpenThreadComponent : public Component {
public:
OpenThreadComponent();
~OpenThreadComponent();
void setup() override;
float get_setup_priority() const override { return setup_priority::WIFI; }
bool is_connected();
network::IPAddresses get_ip_addresses();
std::optional<otIp6Address> get_omr_address();
void ot_main();
protected:
std::optional<otIp6Address> get_omr_address_(InstanceLock &lock);
};
extern OpenThreadComponent *global_openthread_component; // NOLINT(cppcoreguidelines-avoid-non-const-global-variables)
class OpenThreadSrpComponent : public Component {
public:
void set_mdns(esphome::mdns::MDNSComponent *mdns);
// This has to run after the mdns component or else no services are available to advertise
float get_setup_priority() const override { return this->mdns_->get_setup_priority() - 1.0; }
void setup() override;
protected:
esphome::mdns::MDNSComponent *mdns_{nullptr};
std::vector<esphome::mdns::MDNSService> mdns_services_;
std::vector<std::unique_ptr<uint8_t[]>> memory_pool_;
void *pool_alloc_(size_t size);
};
class InstanceLock {
public:
static std::optional<InstanceLock> try_acquire(int delay);
static InstanceLock acquire();
~InstanceLock();
// Returns the global openthread instance guarded by this lock
otInstance *get_instance();
private:
// Use a private constructor in order to force thehandling
// of acquisition failure
InstanceLock() {}
};
} // namespace openthread
} // namespace esphome
#endif