StillHammer
fad105afb2
Major feature: Unified config/data/runtime tree system
**New System Architecture:**
- Unified data tree for config, persistent data, and runtime state
- Three separate roots: config/ (read-only + hot-reload), data/ (read-write + save), runtime/ (temporary)
- Support for modding, saves, and hot-reload in single system
**Interfaces:**
- IDataValue: Abstract data value interface (type-safe access)
- IDataNode: Tree node with navigation, search, and modification
- IDataTree: Root container with config/data/runtime management
**Concrete Implementations:**
- JsonDataValue: nlohmann::json backed value
- JsonDataNode: Full tree navigation with pattern matching & queries
- JsonDataTree: File-based JSON storage with hot-reload
**Features:**
- Pattern matching search (wildcards support)
- Property-based queries with predicates
- SHA256 hashing for validation/sync
- Hot-reload for config/ directory
- Save operations for data/ persistence
- Read-only enforcement for config/
**API Changes:**
- All namespaces changed from 'warfactory' to 'grove'
- IDataTree: Added getConfigRoot(), getDataRoot(), getRuntimeRoot()
- IDataTree: Added saveData(), saveNode() for persistence
- IDataNode: Added setChild(), removeChild(), clearChildren()
- CMakeLists.txt: Added OpenSSL dependency for hashing
**Usage:**
```cpp
auto tree = DataTreeFactory::create("json", "./gamedata");
auto config = tree->getConfigRoot(); // Read-only game config
auto data = tree->getDataRoot(); // Player saves
auto runtime = tree->getRuntimeRoot(); // Temporary state
// Hot-reload config on file changes
if (tree->reloadIfChanged()) { /* refresh modules */ }
// Save player progress
data->setChild("progress", progressNode);
tree->saveData();
```
🤖 Generated with [Claude Code](https://claude.com/claude-code)
Co-Authored-By: Claude <noreply@anthropic.com>
101 lines
3.2 KiB
C++
101 lines
3.2 KiB
C++
#pragma once
|
|
|
|
#include <string>
|
|
#include <vector>
|
|
#include <functional>
|
|
#include <memory>
|
|
#include "IDataNode.h"
|
|
|
|
namespace grove {
|
|
|
|
enum class IOType {
|
|
INTRA = 0, // Same process
|
|
LOCAL = 1, // Same machine
|
|
NETWORK = 2 // TCP/WebSocket
|
|
};
|
|
|
|
struct SubscriptionConfig {
|
|
bool replaceable = false; // Replace vs accumulate for low-freq
|
|
int batchInterval = 30000; // ms for low-freq batching
|
|
int maxBatchSize = 100; // Max messages per batch
|
|
bool compress = false; // Compress batched data
|
|
};
|
|
|
|
struct Message {
|
|
std::string topic;
|
|
std::unique_ptr<IDataNode> data;
|
|
uint64_t timestamp;
|
|
};
|
|
|
|
struct IOHealth {
|
|
int queueSize;
|
|
int maxQueueSize;
|
|
bool dropping = false; // Started dropping messages?
|
|
float averageProcessingRate; // Messages/second processed by module
|
|
int droppedMessageCount = 0; // Total dropped since last check
|
|
};
|
|
|
|
/**
|
|
* @brief Pub/Sub communication interface with pull-based synchronous design
|
|
*
|
|
* Pull-based pub/sub system optimized for game modules. Modules have full control
|
|
* over when they process messages, avoiding threading issues.
|
|
*
|
|
* Features:
|
|
* - Topic patterns with wildcards (e.g., "player:*", "economy:*")
|
|
* - Low-frequency subscriptions for bandwidth optimization
|
|
* - Message consumption (pull removes message from queue)
|
|
* - Engine health monitoring for backpressure management
|
|
*/
|
|
class IIO {
|
|
public:
|
|
virtual ~IIO() = default;
|
|
|
|
/**
|
|
* @brief Publish message to a topic
|
|
* @param topic Topic name (e.g., "player:123", "economy:prices")
|
|
* @param message Message data
|
|
*/
|
|
virtual void publish(const std::string& topic, std::unique_ptr<IDataNode> message) = 0;
|
|
|
|
/**
|
|
* @brief Subscribe to topic pattern (high-frequency)
|
|
* @param topicPattern Topic pattern with wildcards (e.g., "player:*")
|
|
* @param config Optional subscription configuration
|
|
*/
|
|
virtual void subscribe(const std::string& topicPattern, const SubscriptionConfig& config = {}) = 0;
|
|
|
|
/**
|
|
* @brief Subscribe to topic pattern (low-frequency batched)
|
|
* @param topicPattern Topic pattern with wildcards
|
|
* @param config Subscription configuration (batchInterval, etc.)
|
|
*/
|
|
virtual void subscribeLowFreq(const std::string& topicPattern, const SubscriptionConfig& config = {}) = 0;
|
|
|
|
/**
|
|
* @brief Get count of pending messages
|
|
* @return Number of messages waiting to be pulled
|
|
*/
|
|
virtual int hasMessages() const = 0;
|
|
|
|
/**
|
|
* @brief Pull and consume one message
|
|
* @return Message from queue (oldest first). Message is removed from queue.
|
|
* @throws std::runtime_error if no messages available
|
|
*/
|
|
virtual Message pullMessage() = 0;
|
|
|
|
/**
|
|
* @brief Get IO health status for Engine monitoring
|
|
* @return Health metrics including queue size, drop status, processing rate
|
|
*/
|
|
virtual IOHealth getHealth() const = 0;
|
|
|
|
/**
|
|
* @brief Get IO type identifier
|
|
* @return IO type enum value for identification
|
|
*/
|
|
virtual IOType getType() const = 0;
|
|
};
|
|
|
|
} // namespace grove
|