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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
|
/* Copyright (c) MediaArea.net SARL. All Rights Reserved.
*
* Use of this source code is governed by a BSD-style license that can
* be found in the License.html file in the root of the source tree.
*/
//+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
//
// Core functions
//
//+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
//---------------------------------------------------------------------------
#ifndef CoreH
#define CoreH
//---------------------------------------------------------------------------
//---------------------------------------------------------------------------
#include <ZenLib/CriticalSection.h>
#include <map>
#include <bitset>
#include <vector>
#include "MediaConchLib.h"
#include "Reports.h"
#include "Policies.h"
#include "Policy.h"
#include "Configuration.h"
#include "Scheduler.h"
//---------------------------------------------------------------------------
namespace MediaConch {
class Schema;
class DatabaseReport;
class WatchFoldersManager;
class PluginsManager;
class Plugin;
//***************************************************************************
// Class Core
//***************************************************************************
class Core
{
public:
//Constructor/Destructor
Core();
~Core();
//Menu
void Menu_Option_Preferences_Inform (const MediaInfoNameSpace::String &Inform);
String Menu_Option_Preferences_Option (const MediaInfoNameSpace::String &Param, const MediaInfoNameSpace::String &Value);
//***************************************************************************
// Local path
//***************************************************************************
static char get_path_separator(const std::string& path);
static std::string get_local_data_path();
static std::string get_local_config_path();
static int create_local_data_directory(const std::string& base_dir, std::string& report_dir);
static int create_local_unique_data_directory(const std::string& base_dir, const std::string& template_dir,
std::string& report_dir);
static int create_local_unique_data_filename(const std::string& base_dir, const std::string& template_file,
const std::string& template_ext, std::string& filename);
//***************************************************************************
// MediaConch General
//***************************************************************************
// Plugins
int mediaconch_get_plugins(std::vector<std::string>& plugins, std::string& error);
const std::map<std::string, Plugin*>& get_format_plugins() const;
const std::vector<Plugin*>& get_pre_hook_plugins() const;
// watch folder
int mediaconch_list_watch_folders(std::vector<std::string>& folders, std::string& error);
int mediaconch_watch_folder(const std::string& folder, const std::string& folder_reports,
const std::vector<std::string>& plugins, const std::vector<std::string>& policies,
long *in_user, bool recursive,
const std::vector<std::pair<std::string,std::string> >& options,
long& user_id, std::string& error);
int mediaconch_edit_watch_folder(const std::string& folder, const std::string& folder_reports,
std::string& error);
int mediaconch_remove_watch_folder(const std::string& folder, std::string& error);
//***************************************************************************
// Users
//***************************************************************************
void get_users_ids(std::vector<long>&, std::string&);
//***************************************************************************
// Checker
//***************************************************************************
long checker_analyze(int user, const std::string& filename, bool& registered,
const std::vector<std::pair<std::string,std::string> >& options,
const std::vector<std::string>& plugins, std::string& error,
bool force_analyze = false, bool mil_analyze=true);
long checker_analyze(int user, const std::string& filename, long src_id, size_t generated_time,
const std::string generated_log, const std::string generated_error_log,
const std::vector<std::pair<std::string,std::string> >& options,
const std::vector<std::string>& plugins, std::string& error, bool mil_analyze=true,
const std::string& alias="");
int checker_status(int user, long file, MediaConchLib::Checker_StatusRes& res, std::string& error);
int checker_clear(int user, const std::vector<long>& files, std::string& error);
int checker_stop(int user, const std::vector<long>& files, std::string& error);
int checker_list(int user, std::vector<std::string>& vec, std::string& error);
int checker_list(int user, std::vector<long>& vec, std::string& error);
int checker_file_from_id(int user, long id, std::string& file, std::string& error);
long checker_id_from_filename(int user, const std::string& filename,
const std::vector<std::pair<std::string,std::string> >& options, std::string& error);
int checker_file_information(int user, long id, MediaConchLib::Checker_FileInfo& info, std::string& error);
//***************************************************************************
// Checker Helper
//***************************************************************************
int checker_list_mediainfo_outputs(std::string& output, std::string& err);
int file_add_generated_file(int user, long src_id, long generated_id, std::string& err);
int update_file_error(int user, long id, bool has_error, const std::string& error_log, std::string& err);
int get_reports_output_Html(int user, const std::vector<long>& file,
const std::bitset<MediaConchLib::report_Max>& report_set, std::string& report);
static std::string serialize_string_from_options_vec(const std::vector<std::pair<std::string,std::string> >& options);
static std::vector<std::pair<std::string,std::string> > parse_options_vec_from_string(const std::string& options);
static std::string serialize_string_from_options_map(const std::map<std::string, std::string>& options);
static std::map<std::string, std::string> parse_options_map_from_string(const std::string& options);
//***************************************************************************
// Display
//***************************************************************************
std::string xslt_display;
//***************************************************************************
// Policy
//***************************************************************************
int policy_get_values_for_type_field(const std::string& type, const std::string& field,
std::vector<std::string>& values, std::string& err);
int policy_get_fields_for_type(const std::string& type, std::vector<std::string>& fields, std::string& err);
Policies policies;
//***************************************************************************
// Report
//***************************************************************************
Reports reports;
int get_report_saved(int user, const std::vector<long>& file, MediaConchLib::report reportKind,
MediaConchLib::format f, const std::string& options, std::string& report, std::string& err);
int transform_mixml_report(const std::string& mi_xml, const std::string& mi_inform,
const std::vector<std::pair<std::string,std::string> >& options,
std::string& report, std::string& err);
//***************************************************************************
// Configuration
//***************************************************************************
void load_configuration();
void set_default_scheduler_max_threads(size_t nb);
void set_configuration_file(const std::string& file);
const std::string& get_configuration_file() const;
void load_plugins_configuration();
void set_plugins_configuration_file(const std::string& file);
const std::map<std::string, std::string>& get_implementation_options() const;
void set_implementation_schema_file(const std::string& file);
const std::string& get_implementation_schema_file();
int create_default_implementation_schema(std::string& err);
void set_implementation_verbosity(const std::string& verbosity);
const std::string& get_implementation_verbosity();
void set_compression_mode(MediaConchLib::compression compress);
int get_ui_poll_request() const;
int get_ui_database_path(std::string& path) const;
bool is_using_daemon() const;
void get_daemon_address(std::string& addr, int& port) const;
void load_database();
bool database_is_enabled() const;
bool accepts_https();
static void unify_no_https(std::string& str);
//***************************************************************************
// Report Database access
//***************************************************************************
void set_file_analyzed_to_database(int user, long id);
void register_reports_to_database(int user, long file, MediaInfoNameSpace::MediaInfo* MI);
void register_reports_to_database(int user, long file, const std::string& report,
MediaConchLib::report report_kind, const std::string& options,
MediaInfoNameSpace::MediaInfo* curMI);
int register_mediaconch_to_database(int user, long file, const std::string& options,
std::string& report, std::string& err);
int implem_report_is_registered(int user, long file, const std::string& options, bool& registered,
std::string& err);
// TODO: removed and manage waiting time otherway
void WaitRunIsFinished();
//***************************************************************************
// Helper
//***************************************************************************
static std::string get_date();
unsigned long long mil_version();
void plugin_add_log(int level, const std::string& log);
void plugin_add_log_timestamp(int level, const std::string& log);
//***************************************************************************
// Helper Zlib
//***************************************************************************
static void compress_report(std::string& report, MediaConchLib::compression& compress);
static void compress_report_copy(std::string& report, const char* src, size_t src_len, MediaConchLib::compression& compress);
static int uncompress_report(std::string& report, MediaConchLib::compression compress);
//***************************************************************************
// Event Callback
//***************************************************************************
struct EventCallBack
{
void (*log)(struct MediaInfo_Event_Log_0* Event);
};
EventCallBack ecb;
private:
Core (const Core&);
MediaInfoNameSpace::MediaInfo *MI;
DatabaseReport* db;
CriticalSection db_mutex;
static const std::string database_name;
Configuration* config;
std::string configuration_file;
std::string plugins_configuration_file;
std::map<std::string, std::string> implementation_options;
Scheduler *scheduler;
PluginsManager *plugins_manager;
WatchFoldersManager *watch_folders_manager;
MediaConchLib::compression compression_mode;
bool has_outcome_fail(const std::string& report);
//***************************************************************************
// Helper
//***************************************************************************
long file_is_registered_and_analyzed(int user, const std::string& file, bool& analyzed,
const std::string& options, std::string& err);
long file_is_registered_and_analyzed_in_db(int user, const std::string& file, bool& analyzed,
const std::string& options, std::string& err);
long file_is_registered_in_queue(int user, const std::string& file, const std::string& options, std::string& err);
std::string get_last_modification_file(const std::string& file);
bool file_is_existing(const std::string& filename);
void register_reports_to_database(int user, long file);
void register_report_xml_to_database(int user, long file, const std::string& report,
MediaConchLib::report report_kind, const std::string& options);
void register_report_mediainfo_text_to_database(int user, long file, MediaInfoNameSpace::MediaInfo* MI);
void register_report_mediainfo_xml_to_database(int user, long file, MediaInfoNameSpace::MediaInfo* MI);
void register_report_micromediatrace_xml_to_database(int user, long file, MediaInfoNameSpace::MediaInfo* MI);
std::string get_config_file();
std::string get_database_path();
DatabaseReport *get_db();
static bool sort_pair_options(const std::pair<std::string,std::string>& a, const std::pair<std::string,std::string>& b);
};
}
#endif
|
