log_buffer.hpp

// log_buffer.hpp
// Created by Greg on 8/4/2025.
// Copyright (C) 2025 Presage Security, Inc.
//
// SPDX-License-Identifier: LGPL-3.0-or-later
 
#pragma once
 
// === standard library includes (if any) ===
#include <queue>
#include <string>
#include <mutex>
#include <condition_variable>
#include <atomic>
#include <optional>
 
// === third-party includes (if any) ===
#include "absl/strings/string_view.h"
 
namespace presage::smartspectra::grpc_bindings {
class LogBuffer {
public:
    explicit LogBuffer(size_t max_size);
 
    void AddLog(absl::string_view log);
 
    // Returns log entry, or std::nullopt if shutdown
    std::optional<std::string> GetLog();
 
    // Signal shutdown to wake up all waiting threads
    void Shutdown();
 
    // Check if buffer is in shutdown state
    bool IsShutdown() const;
 
private:
    std::queue<std::string> queue;
    std::mutex mutex;
    std::condition_variable cv;
    size_t max_size;
    std::atomic<bool> shutdown_flag{false};
};
} // namespace presage::smartspectra::grpc_bindings