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
|
#ifndef NEWSBEUTER_CACHE__H
#define NEWSBEUTER_CACHE__H
#include <sqlite3.h>
#include <rss.h>
#include <configcontainer.h>
#include <mutex>
namespace newsbeuter {
typedef std::vector<std::string> schema_queries_list;
class cache {
public:
cache(const std::string& cachefile, configcontainer * c);
~cache();
void externalize_rssfeed(std::shared_ptr<rss_feed> feed, bool reset_unread);
std::shared_ptr<rss_feed> internalize_rssfeed(std::string rssurl, rss_ignores * ign);
void update_rssitem_unread_and_enqueued(std::shared_ptr<rss_item> item, const std::string& feedurl);
void update_rssitem_unread_and_enqueued(rss_item* item, const std::string& feedurl);
void cleanup_cache(std::vector<std::shared_ptr<rss_feed>>& feeds);
void do_vacuum();
std::vector<std::shared_ptr<rss_item>> search_for_items(const std::string& querystr, const std::string& feedurl);
void mark_all_read(const std::string& feedurl = "");
void mark_all_read(std::shared_ptr<rss_feed> feed);
void update_rssitem_flags(rss_item* item);
void fetch_lastmodified(const std::string& uri, time_t& t, std::string& etag);
void update_lastmodified(const std::string& uri, time_t t, const std::string& etag);
unsigned int get_unread_count();
void mark_item_deleted(const std::string& guid, bool b);
void remove_old_deleted_items(const std::string& rssurl, const std::vector<std::string>& guids);
void mark_items_read_by_guid(const std::vector<std::string>& guids);
std::vector<std::string> get_read_item_guids();
void fetch_descriptions(rss_feed * feed);
private:
void populate_tables();
void set_pragmas();
void delete_item(const std::shared_ptr<rss_item>& item);
void clean_old_articles();
void update_rssitem_unlocked(std::shared_ptr<rss_item> item, const std::string& feedurl, bool reset_unread);
std::string prepare_query(const std::string& format);
template<typename... Args>
std::string prepare_query(
const std::string& format, const std::string& arg, Args... args);
template<typename T, typename... Args>
std::string prepare_query(
const std::string& format, const T& arg, Args... args);
void run_sql(
const std::string& query,
int (*callback)(void*,int,char**,char**) = nullptr,
void * callback_argument = nullptr);
void run_sql_nothrow(
const std::string& query,
int (*callback)(void*,int,char**,char**) = nullptr,
void * callback_argument = nullptr);
void run_sql_impl(
const std::string& query,
int (*callback)(void*,int,char**,char**),
void * callback_argument,
bool do_throw);
sqlite3 * db;
configcontainer * cfg;
std::mutex mtx;
};
}
#endif
|
