1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
/*
* =====================================================================================
*
* Filename: db.cpp
*
* Description: Connection to a postgres database
*
* Version: 1.0
* Created: 04/06/2023 11:40:39 AM
* Revision: none
* Compiler: gcc
*
* Author: Cara Salter (muirrum), cara@devcara.com
* Organization: Worcester Polytechnic Institute
*
* =====================================================================================
*/
#include <fmt/core.h>
#include <mutex>
#include <stdlib.h>
#include <stdio.h>
#include <iostream>
#include <142bot/db.hpp>
#include <pqxx/pqxx>
#include <fmt/format.h>
#include <cstdarg>
#include <sentry.h>
using namespace std;
namespace db {
std::mutex db_mutex;
std::string _error;
/**
* Connects to a postgres database, returns false if error
**/
pqxx::connection connect(const std::string cn_s) {
std::lock_guard<std::mutex> db_lock(db_mutex);
cout << cn_s << endl;
sentry_value_t crumb = sentry_value_new_breadcrumb("default", "Started Database Connection");
sentry_value_set_by_key(crumb, "level", sentry_value_new_string("db"));
sentry_value_set_by_key(crumb, "data", sentry_value_new_string(cn_s.c_str()));
sentry_add_breadcrumb(crumb);
try {
pqxx::connection c{cn_s};
return c;
} catch (std::exception const &e) {
_error = e.what();
throw e;
}
}
const std::string& error() {
return _error;
}
}
#include <142bot/date.h>
#include <142bot/iso_week.h>
#include <iomanip>
#include <sstream>
#include <stdexcept> // std::invalid_argument
namespace asdf
{
timestamp from_iso8601_str( const std::string& s )
{
timestamp ts;
if( !from_iso8601_str( s, ts ) )
throw std::invalid_argument{
"failed to parse "
+ s
+ " as an ISO 8601 timestamp"
};
return ts;
}
bool from_iso8601_str( const std::string& s, timestamp& ts )
{
std::istringstream stream{ s };
stream >> date::parse( "%F %T", ts );
return !stream.fail();
}
std::string to_iso8601_str( const timestamp& ts )
{
return date::format( "%F %T", ts );
}
std::string to_http_ts_str( const timestamp& ts )
{
std::stringstream weekday_abbreviation;
weekday_abbreviation << static_cast< iso_week::year_weeknum_weekday >(
std::chrono::time_point_cast< date::days >( ts )
).weekday();
return (
weekday_abbreviation.str()
// timestamps serialize to UTC/GMT by default
+ date::format(
" %d-%m-%Y %H:%M:%S GMT",
std::chrono::time_point_cast< std::chrono::seconds >( ts )
)
);
}
timestamp from_unix_time( unsigned int unix_time )
{
return timestamp{ std::chrono::duration_cast<
std::chrono::microseconds
>( std::chrono::seconds{ unix_time } ) };
}
unsigned int to_unix_time( const timestamp& ts )
{
return std::chrono::duration_cast<
std::chrono::seconds
>( ts.time_since_epoch() ).count();
}
}
|
