class StdinToDatabase

code/stdin-db.h

#pragma once

#include "eventloop.h"
#include "database.h"

class StdinToDatabase : public InputHandler
{
public:
    StdinToDatabase(Database& db);
    void hookup(Eventloop&);
    EventAction ready(int fd) override;

private:
    Database& _db;
};

code/stdin-db.cpp

#include "stdin-db.h"

#include <unistd.h>
#include <assert.h>
#include <string.h>
#include <stdexcept>
#include <format>

StdinToDatabase::StdinToDatabase(Database& db)
: _db(db) {}

void StdinToDatabase::hookup(Eventloop& loop)
{
    loop.register_input(STDIN_FILENO, this);
}

EventAction StdinToDatabase::ready(int fd)
{
    assert(fd == STDIN_FILENO);

    char buffer[64];
    ssize_t nread = read(STDIN_FILENO, buffer, sizeof(buffer));
    if (nread == -1)
        throw std::runtime_error(std::format("read failed: {} ({})", strerror(errno), errno));

    if (nread == 0)
        return EventAction::Quit;

    std::string line(buffer, nread);
    if (Record r = split_line(line))
        _db.insert(r);
    else
        throw std::runtime_error(std::format("bad record: {}", line));

    return EventAction::Continue;
}