mirror of
https://github.com/openstreetmap/mod_tile.git
synced 2025-07-28 23:23:55 +00:00
Cleaning up tests (#424)
This commit is contained in:
181
tests/catch_test_common.cpp
Normal file
181
tests/catch_test_common.cpp
Normal file
@ -0,0 +1,181 @@
|
||||
/*
|
||||
* Copyright (c) 2007 - 2023 by mod_tile contributors (see AUTHORS file)
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU General Public License
|
||||
* as published by the Free Software Foundation; either version 2
|
||||
* of the License, or (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; If not, see http://www.gnu.org/licenses/.
|
||||
*/
|
||||
|
||||
#include <glib.h>
|
||||
#include <iostream>
|
||||
#include <stdio.h>
|
||||
#include <string>
|
||||
#include <tuple>
|
||||
#include <unistd.h>
|
||||
|
||||
#include "catch_test_common.hpp"
|
||||
#include "pstreams/pstream.hpp"
|
||||
|
||||
extern int foreground;
|
||||
|
||||
std::string err_log_lines, out_log_lines;
|
||||
|
||||
captured_stdio captured_stderr;
|
||||
captured_stdio captured_stdout;
|
||||
|
||||
int run_command(std::string file, std::vector<std::string> argv, std::string input)
|
||||
{
|
||||
auto mode = redi::pstreams::pstdout | redi::pstreams::pstderr | redi::pstreams::pstdin;
|
||||
|
||||
argv.insert(argv.begin(), file);
|
||||
|
||||
redi::pstream proc(file, argv, mode);
|
||||
|
||||
std::string line;
|
||||
err_log_lines = "";
|
||||
out_log_lines = "";
|
||||
|
||||
if (!input.empty()) {
|
||||
proc << input << redi::peof;
|
||||
}
|
||||
|
||||
while (std::getline(proc.err(), line)) {
|
||||
err_log_lines += line;
|
||||
}
|
||||
|
||||
proc.clear();
|
||||
|
||||
while (std::getline(proc.out(), line)) {
|
||||
out_log_lines += line;
|
||||
}
|
||||
|
||||
return proc.close();
|
||||
}
|
||||
|
||||
std::string read_stderr(int buffer_size)
|
||||
{
|
||||
char buffer[buffer_size];
|
||||
read(captured_stderr.pipes[0], buffer, buffer_size);
|
||||
return buffer;
|
||||
}
|
||||
|
||||
void capture_stderr()
|
||||
{
|
||||
// Flush stderr first if you've previously printed something
|
||||
fflush(stderr);
|
||||
|
||||
// Save stderr so it can be restored later
|
||||
int temp_stderr;
|
||||
temp_stderr = dup(fileno(stderr));
|
||||
|
||||
// Redirect stderr to a new pipe
|
||||
int pipes[2];
|
||||
pipe(pipes);
|
||||
dup2(pipes[1], fileno(stderr));
|
||||
|
||||
captured_stderr.temp_fd = temp_stderr;
|
||||
captured_stderr.pipes[0] = pipes[0];
|
||||
captured_stderr.pipes[1] = pipes[1];
|
||||
}
|
||||
|
||||
std::string get_captured_stderr(bool print)
|
||||
{
|
||||
// Terminate captured output with a zero
|
||||
write(captured_stderr.pipes[1], "", 1);
|
||||
|
||||
// Restore stderr
|
||||
fflush(stderr);
|
||||
dup2(captured_stderr.temp_fd, fileno(stderr));
|
||||
|
||||
// Save & return the captured stderr
|
||||
std::string log_lines = read_stderr();
|
||||
|
||||
if (print) {
|
||||
std::cout << "err_log_lines: " << log_lines << "\n";
|
||||
}
|
||||
|
||||
return log_lines;
|
||||
}
|
||||
|
||||
std::string read_stdout(int buffer_size)
|
||||
{
|
||||
char buffer[buffer_size];
|
||||
read(captured_stdout.pipes[0], buffer, buffer_size);
|
||||
return buffer;
|
||||
}
|
||||
|
||||
void capture_stdout()
|
||||
{
|
||||
// Flush stdout first if you've previously printed something
|
||||
fflush(stdout);
|
||||
|
||||
// Save stdout so it can be restored later
|
||||
int temp_stdout;
|
||||
temp_stdout = dup(fileno(stdout));
|
||||
|
||||
// Redirect stdout to a new pipe
|
||||
int pipes[2];
|
||||
pipe(pipes);
|
||||
dup2(pipes[1], fileno(stdout));
|
||||
|
||||
captured_stdout.temp_fd = temp_stdout;
|
||||
captured_stdout.pipes[0] = pipes[0];
|
||||
captured_stdout.pipes[1] = pipes[1];
|
||||
}
|
||||
|
||||
std::string get_captured_stdout(bool print)
|
||||
{
|
||||
// Terminate captured output with a zero
|
||||
write(captured_stdout.pipes[1], "", 1);
|
||||
|
||||
// Restore stdout
|
||||
fflush(stdout);
|
||||
dup2(captured_stdout.temp_fd, fileno(stdout));
|
||||
|
||||
// Save & return the captured stdout
|
||||
std::string log_lines = read_stdout();
|
||||
|
||||
if (print) {
|
||||
std::cout << "out_log_lines: " << log_lines << "\n";
|
||||
}
|
||||
|
||||
return log_lines;
|
||||
}
|
||||
|
||||
void start_capture(bool debug)
|
||||
{
|
||||
foreground = debug ? 1 : 0;
|
||||
|
||||
if (debug) {
|
||||
setenv("G_MESSAGES_DEBUG", "all", 1);
|
||||
#if GLIB_MAJOR_VERSION == 2 && GLIB_MINOR_VERSION >= 79
|
||||
// https://gitlab.gnome.org/GNOME/glib/-/merge_requests/3710
|
||||
std::cout << "Resetting G_MESSAGES_DEBUG env var in runtime no longer has an effect.\n";
|
||||
const gchar *domains[] = {"all", NULL};
|
||||
g_log_writer_default_set_debug_domains(domains);
|
||||
#endif
|
||||
}
|
||||
|
||||
capture_stderr();
|
||||
capture_stdout();
|
||||
}
|
||||
|
||||
std::tuple<std::string, std::string> end_capture(bool print)
|
||||
{
|
||||
setenv("G_MESSAGES_DEBUG", "", 1);
|
||||
#if GLIB_MAJOR_VERSION == 2 && GLIB_MINOR_VERSION >= 79
|
||||
g_log_writer_default_set_debug_domains(NULL);
|
||||
#endif
|
||||
foreground = 0;
|
||||
|
||||
return std::tuple<std::string, std::string>(get_captured_stderr(print), get_captured_stdout(print));
|
||||
}
|
Reference in New Issue
Block a user