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
|
/**
* This file does not contain test cases.
*
* This file defines the minimum APIs for crypt_shared to be successfully loaded
* (but not necessarily fully used) by libmongocrypt. This is only used to test
* the loading and un-loading of the crypt_shared dynamic library file by
* libmongocrypt.
*/
#define MONGO_CRYPT_SUPPORT_COMPILING
#include <mongo_crypt-v1.h>
#include <bson/bson.h>
#include <cinttypes>
#include <cstring>
struct mongo_crypt_v1_status {};
typedef mongo_crypt_v1_status status_t;
status_t *mongo_crypt_v1_status_create(void) {
return new status_t;
}
void mongo_crypt_v1_status_destroy(status_t *st) {
delete st;
}
int mongo_crypt_v1_status_get_error(const status_t *) {
return 0;
}
const char *mongo_crypt_v1_status_get_explanation(const status_t *) {
return "nothing here";
}
int mongo_crypt_v1_status_get_code(const status_t *) {
return 0;
}
struct mongo_crypt_v1_lib {};
typedef mongo_crypt_v1_lib lib_t;
lib_t *mongo_crypt_v1_lib_create(status_t *) {
return new lib_t;
}
int mongo_crypt_v1_lib_destroy(lib_t *lib, status_t *) {
delete lib;
return MONGO_CRYPT_V1_SUCCESS;
}
uint64_t mongo_crypt_v1_get_version(void) {
#ifdef UINT64_C
return UINT64_C(0x000600020001000);
#else
return 0x000600020001000;
#endif
}
const char *mongo_crypt_v1_get_version_str(void) {
return "stubbed-crypt_shared";
}
struct mongo_crypt_v1_query_analyzer {};
typedef mongo_crypt_v1_query_analyzer query_analyzer_t;
query_analyzer_t *mongo_crypt_v1_query_analyzer_create(lib_t *, status_t *) {
return new query_analyzer_t;
}
void mongo_crypt_v1_query_analyzer_destroy(query_analyzer_t *qa) {
delete qa;
}
uint8_t *mongo_crypt_v1_analyze_query(query_analyzer_t *qa,
const uint8_t *doc_bson,
const char *ns_str,
uint32_t ns_len,
uint32_t *bson_len_out,
status_t *) {
std::uint32_t doc_len;
std::copy_n(doc_bson, sizeof doc_len, reinterpret_cast<char *>(&doc_len));
doc_len = BSON_UINT32_FROM_LE(doc_len);
bson_t *given = bson_new_from_data(doc_bson, doc_len);
bson_t doc = BSON_INITIALIZER;
BSON_APPEND_DOCUMENT(&doc, "originalCommand", given);
bson_t tmp_doc;
bson_init_from_json( //
&tmp_doc,
R"({
"markedDocument": true
})",
-1,
NULL);
BSON_APPEND_DOCUMENT(&doc, "result", &tmp_doc);
uint8_t *buf = new uint8_t[doc.len];
std::copy_n(bson_get_data(&doc), doc.len, buf);
*bson_len_out = doc.len;
bson_destroy(given);
bson_destroy(&tmp_doc);
return buf;
}
void mongo_crypt_v1_bson_free(uint8_t *bson) {
delete[] bson;
}
|
