c922e73c11
Flake lock file updates:
• Updated input 'nix':
'github:NixOS/nix/f5f4de6a550327b4b1a06123c2e450f1b92c73b6' (2023-10-02)
→ 'github:NixOS/nix/50f8f1c8bc019a4c0fd098b9ac674b94cfc6af0d' (2023-11-27)
50 lines
1.1 KiB
C++
50 lines
1.1 KiB
C++
#pragma once
|
|
|
|
#include <pqxx/pqxx>
|
|
|
|
#include "environment-variables.hh"
|
|
#include "util.hh"
|
|
|
|
|
|
struct Connection : pqxx::connection
|
|
{
|
|
Connection() : pqxx::connection(getFlags()) { };
|
|
|
|
std::string getFlags()
|
|
{
|
|
using namespace nix;
|
|
auto s = getEnv("HYDRA_DBI").value_or("dbi:Pg:dbname=hydra;");
|
|
|
|
std::string lower_prefix = "dbi:Pg:";
|
|
std::string upper_prefix = "DBI:Pg:";
|
|
|
|
if (hasPrefix(s, lower_prefix) || hasPrefix(s, upper_prefix)) {
|
|
return concatStringsSep(" ", tokenizeString<Strings>(std::string(s, lower_prefix.size()), ";"));
|
|
}
|
|
|
|
throw Error("$HYDRA_DBI does not denote a PostgreSQL database");
|
|
}
|
|
};
|
|
|
|
|
|
class receiver : public pqxx::notification_receiver
|
|
{
|
|
std::optional<std::string> status;
|
|
|
|
public:
|
|
|
|
receiver(pqxx::connection_base & c, const std::string & channel)
|
|
: pqxx::notification_receiver(c, channel) { }
|
|
|
|
void operator() (const std::string & payload, int pid) override
|
|
{
|
|
status = payload;
|
|
};
|
|
|
|
std::optional<std::string> get() {
|
|
auto s = status;
|
|
status = std::nullopt;
|
|
return s;
|
|
}
|
|
};
|