blob: fd65ffb38ef41159d41c065bc74890a94c2f686b (
plain)
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
|
#ifndef RSPAMD_FUZZY_STORAGE_H
#define RSPAMD_FUZZY_STORAGE_H
#include "config.h"
#include "rspamd.h"
#include "shingles.h"
#include "cryptobox.h"
#ifdef __cplusplus
extern "C" {
#endif
#define RSPAMD_FUZZY_VERSION 4
#define RSPAMD_FUZZY_KEYLEN 8
#define RSPAMD_FUZZY_FLAG_WEAK (1u << 7u)
/* Use lower 4 bits for the version */
#define RSPAMD_FUZZY_VERSION_MASK 0x0fu
/* Commands for fuzzy storage */
#define FUZZY_CHECK 0
#define FUZZY_WRITE 1
#define FUZZY_DEL 2
#define FUZZY_STAT 3
#define FUZZY_CLIENT_MAX 3
/* Internal commands */
#define FUZZY_REFRESH 100 /* Update expire */
#define FUZZY_DUP 101 /* Skip duplicate in update queue */
/**
* The epoch of the fuzzy client
*/
enum rspamd_fuzzy_epoch {
RSPAMD_FUZZY_EPOCH10, /**< 1.0+ encryption */
RSPAMD_FUZZY_EPOCH11, /**< 1.7+ extended reply */
RSPAMD_FUZZY_EPOCH_MAX
};
RSPAMD_PACKED(rspamd_fuzzy_cmd) {
guint8 version;
guint8 cmd;
guint8 shingles_count;
guint8 flag;
gint32 value;
guint32 tag;
gchar digest[rspamd_cryptobox_HASHBYTES];
};
RSPAMD_PACKED(rspamd_fuzzy_shingle_cmd) {
struct rspamd_fuzzy_cmd basic;
struct rspamd_shingle sgl;
};
RSPAMD_PACKED(rspamd_fuzzy_reply_v1) {
gint32 value;
guint32 flag;
guint32 tag;
float prob;
};
RSPAMD_PACKED(rspamd_fuzzy_reply) {
struct rspamd_fuzzy_reply_v1 v1;
gchar digest[rspamd_cryptobox_HASHBYTES];
guint32 ts;
guchar reserved[12];
};
RSPAMD_PACKED(rspamd_fuzzy_encrypted_req_hdr) {
guchar magic[4];
guchar key_id[RSPAMD_FUZZY_KEYLEN];
guchar pubkey[32];
guchar nonce[rspamd_cryptobox_MAX_NONCEBYTES];
guchar mac[rspamd_cryptobox_MAX_MACBYTES];
};
RSPAMD_PACKED(rspamd_fuzzy_encrypted_cmd) {
struct rspamd_fuzzy_encrypted_req_hdr hdr;
struct rspamd_fuzzy_cmd cmd;
};
RSPAMD_PACKED(rspamd_fuzzy_encrypted_shingle_cmd) {
struct rspamd_fuzzy_encrypted_req_hdr hdr;
struct rspamd_fuzzy_shingle_cmd cmd;
};
RSPAMD_PACKED(rspamd_fuzzy_encrypted_rep_hdr) {
guchar nonce[rspamd_cryptobox_MAX_NONCEBYTES];
guchar mac[rspamd_cryptobox_MAX_MACBYTES];
};
RSPAMD_PACKED(rspamd_fuzzy_encrypted_reply) {
struct rspamd_fuzzy_encrypted_rep_hdr hdr;
struct rspamd_fuzzy_reply rep;
};
static const guchar fuzzy_encrypted_magic[4] = {'r', 's', 'f', 'e'};
enum rspamd_fuzzy_extension_type {
RSPAMD_FUZZY_EXT_SOURCE_DOMAIN = 'd',
RSPAMD_FUZZY_EXT_SOURCE_IP4 = '4',
RSPAMD_FUZZY_EXT_SOURCE_IP6 = '6',
};
struct rspamd_fuzzy_cmd_extension {
enum rspamd_fuzzy_extension_type ext;
guint length;
struct rspamd_fuzzy_cmd_extension *next;
guchar *payload;
};
struct rspamd_fuzzy_stat_entry {
const gchar *name;
guint32 fuzzy_cnt;
};
RSPAMD_PACKED(fuzzy_peer_cmd) {
gint32 is_shingle;
union {
struct rspamd_fuzzy_cmd normal;
struct rspamd_fuzzy_shingle_cmd shingle;
} cmd;
};
#ifdef __cplusplus
}
#endif
#endif
|
