ORE Studio 0.0.4
Loading...
Searching...
No Matches
publication_repository.hpp
1/* -*- mode: c++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
2 *
3 * Copyright (C) 2025 Marco Craveiro <marco.craveiro@gmail.com>
4 *
5 * This program is free software; you can redistribute it and/or modify it under
6 * the terms of the GNU General Public License as published by the Free Software
7 * Foundation; either version 3 of the License, or (at your option) any later
8 * version.
9 *
10 * This program is distributed in the hope that it will be useful, but WITHOUT
11 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
12 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
13 * details.
14 *
15 * You should have received a copy of the GNU General Public License along with
16 * this program; if not, write to the Free Software Foundation, Inc., 51
17 * Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
18 *
19 */
20#ifndef ORES_DQ_REPOSITORY_PUBLICATION_REPOSITORY_HPP
21#define ORES_DQ_REPOSITORY_PUBLICATION_REPOSITORY_HPP
22
23#include <string>
24#include <vector>
25#include <cstdint>
26#include <sqlgen/postgres.hpp>
27#include <boost/uuid/uuid.hpp>
28#include "ores.logging/make_logger.hpp"
29#include "ores.database/domain/context.hpp"
30#include "ores.dq/domain/publication.hpp"
31
32namespace ores::dq::repository {
33
38private:
39 inline static std::string_view logger_name =
40 "ores.dq.repository.publication_repository";
41
42 [[nodiscard]] static auto& lg() {
43 using namespace ores::logging;
44 static auto instance = make_logger(logger_name);
45 return instance;
46 }
47
48public:
50
51 explicit publication_repository(context ctx);
52
58 std::vector<domain::publication>
59 read_by_dataset(const boost::uuids::uuid& dataset_id);
60
66 std::vector<domain::publication>
67 read_recent(std::uint32_t limit = 100);
68
73 void insert(const domain::publication& pub);
74
75private:
76 context ctx_;
77};
78
79}
80
81#endif
Implements logging infrastructure for ORE Studio.
Definition boost_severity.hpp:28
Context for the operations on a postgres database.
Definition context.hpp:30
Audit record for a dataset publication event.
Definition publication.hpp:37
Repository for reading and writing publication audit records.
Definition publication_repository.hpp:37
std::vector< domain::publication > read_by_dataset(const boost::uuids::uuid &dataset_id)
Reads all publication records for a dataset.
Definition publication_repository.cpp:39
void insert(const domain::publication &pub)
Inserts a new publication record.
Definition publication_repository.cpp:68
std::vector< domain::publication > read_recent(std::uint32_t limit=100)
Reads recent publication records across all datasets.
Definition publication_repository.cpp:55