53 lines
1.7 KiB
C++
53 lines
1.7 KiB
C++
#pragma once
|
|
#include "spore/core/NodeContext.h"
|
|
#include "spore/types/NodeInfo.h"
|
|
#include "spore/core/TaskManager.h"
|
|
#include <Arduino.h>
|
|
#include <ESP8266WiFi.h>
|
|
#include <ArduinoJson.h>
|
|
#include <ESP8266HTTPClient.h>
|
|
#include <map>
|
|
#include <vector>
|
|
#include <functional>
|
|
|
|
class ClusterManager {
|
|
public:
|
|
ClusterManager(NodeContext& ctx, TaskManager& taskMgr);
|
|
void registerTasks();
|
|
void sendDiscovery();
|
|
void listen();
|
|
void addOrUpdateNode(const String& nodeHost, IPAddress nodeIP);
|
|
void updateAllNodeStatuses();
|
|
void removeDeadNodes();
|
|
void printMemberList();
|
|
const std::map<String, NodeInfo>& getMemberList() const { return *ctx.memberList; }
|
|
void fetchNodeInfo(const IPAddress& ip);
|
|
void updateLocalNodeResources();
|
|
void heartbeatTaskCallback();
|
|
void updateAllMembersInfoTaskCallback();
|
|
private:
|
|
NodeContext& ctx;
|
|
TaskManager& taskManager;
|
|
struct MessageHandler {
|
|
bool (*predicate)(const char*);
|
|
std::function<void(const char*)> handle;
|
|
const char* name;
|
|
};
|
|
void initMessageHandlers();
|
|
void handleIncomingMessage(const char* incoming);
|
|
static bool isDiscoveryMsg(const char* msg);
|
|
static bool isHeartbeatMsg(const char* msg);
|
|
static bool isResponseMsg(const char* msg);
|
|
static bool isNodeInfoMsg(const char* msg);
|
|
static bool isClusterEventMsg(const char* msg);
|
|
static bool isRawMsg(const char* msg);
|
|
void onDiscovery(const char* msg);
|
|
void onHeartbeat(const char* msg);
|
|
void onResponse(const char* msg);
|
|
void onNodeInfo(const char* msg);
|
|
void onClusterEvent(const char* msg);
|
|
void onRawMessage(const char* msg);
|
|
unsigned long lastHeartbeatSentAt = 0;
|
|
std::vector<MessageHandler> messageHandlers;
|
|
};
|