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
|
/*
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
distributed with this work for additional information
regarding copyright ownership. The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
//////////////////////////////////////////////////////////////////////////////////////////////
// factory.cc: Factory functions for operators, conditions and condition variables.
//
//
#include <string>
#include "operators.h"
#include "conditions.h"
#include "conditions_geo.h"
///////////////////////////////////////////////////////////////////////////////
// "Factory" functions, processing the parsed lines
//
Operator *
operator_factory(const std::string &op)
{
Operator *o = nullptr;
if (op == "rm-header") {
o = new OperatorRMHeader();
} else if (op == "set-header") {
o = new OperatorSetHeader();
} else if (op == "add-header") {
o = new OperatorAddHeader();
} else if (op == "set-config") {
o = new OperatorSetConfig();
} else if (op == "set-status") {
o = new OperatorSetStatus();
} else if (op == "set-status-reason") {
o = new OperatorSetStatusReason();
} else if (op == "set-destination") {
o = new OperatorSetDestination();
} else if (op == "rm-destination") {
o = new OperatorRMDestination();
} else if (op == "set-redirect") {
o = new OperatorSetRedirect();
} else if (op == "timeout-out") {
o = new OperatorSetTimeoutOut();
} else if (op == "skip-remap") {
o = new OperatorSkipRemap();
} else if (op == "no-op") {
o = new OperatorNoOp();
} else if (op == "counter") {
o = new OperatorCounter();
} else if (op == "rm-cookie") {
o = new OperatorRMCookie();
} else if (op == "set-cookie") {
o = new OperatorSetCookie();
} else if (op == "add-cookie") {
o = new OperatorAddCookie();
} else if (op == "set-conn-dscp") {
o = new OperatorSetConnDSCP();
} else if (op == "set-conn-mark") {
o = new OperatorSetConnMark();
} else if (op == "set-debug") {
o = new OperatorSetDebug();
} else if (op == "set-body") {
o = new OperatorSetBody();
} else if (op == "set-http-cntl") {
o = new OperatorSetHttpCntl();
} else {
TSError("[%s] Unknown operator: %s", PLUGIN_NAME, op.c_str());
return nullptr;
}
return o;
}
Condition *
condition_factory(const std::string &cond)
{
Condition *c = nullptr;
std::string c_name, c_qual;
std::string::size_type pos = cond.find_first_of(':');
if (pos != std::string::npos) {
c_name = cond.substr(0, pos);
c_qual = cond.substr(pos + 1);
} else {
c_name = cond;
c_qual = "";
}
if (c_name == "TRUE") {
c = new ConditionTrue();
} else if (c_name == "FALSE") {
c = new ConditionFalse();
} else if (c_name == "STATUS") {
c = new ConditionStatus();
} else if (c_name == "RANDOM") {
c = new ConditionRandom();
} else if (c_name == "ACCESS") {
c = new ConditionAccess();
} else if (c_name == "COOKIE") {
c = new ConditionCookie();
} else if (c_name == "HEADER") { // This condition adapts to the hook
c = new ConditionHeader();
} else if (c_name == "CLIENT-HEADER") {
c = new ConditionHeader(true);
} else if (c_name == "CLIENT-URL") { // This condition adapts to the hook
c = new ConditionUrl(ConditionUrl::CLIENT);
} else if (c_name == "URL") {
c = new ConditionUrl(ConditionUrl::URL);
} else if (c_name == "FROM-URL") {
c = new ConditionUrl(ConditionUrl::FROM);
} else if (c_name == "TO-URL") {
c = new ConditionUrl(ConditionUrl::TO);
} else if (c_name == "DBM") {
c = new ConditionDBM();
} else if (c_name == "INTERNAL-TRANSACTION") {
c = new ConditionInternalTxn();
} else if (c_name == "INTERNAL-TXN") {
c = new ConditionInternalTxn();
} else if (c_name == "IP") {
c = new ConditionIp();
} else if (c_name == "METHOD") {
c = new ConditionMethod();
} else if (c_name == "TXN-COUNT") {
c = new ConditionTransactCount();
} else if (c_name == "NOW") {
c = new ConditionNow();
} else if (c_name == "GEO") {
#if TS_USE_HRW_GEOIP
c = new GeoIPConditionGeo();
#elif TS_USE_HRW_MAXMINDDB
c = new MMConditionGeo();
#else
c = new ConditionGeo();
#endif
} else if (c_name == "ID") {
c = new ConditionId();
} else if (c_name == "CIDR") {
c = new ConditionCidr();
} else if (c_name == "INBOUND") {
c = new ConditionInbound();
} else if (c_name == "SSN-TXN-COUNT") {
c = new ConditionSessionTransactCount();
} else if (c_name == "TCP-INFO") {
c = new ConditionTcpInfo();
} else if (c_name == "CACHE") {
c = new ConditionCache();
} else if (c_name == "NEXT-HOP") { // This condition adapts to the hook
c = new ConditionNextHop();
} else {
TSError("[%s] Unknown condition %s", PLUGIN_NAME, c_name.c_str());
return nullptr;
}
if (c_qual != "") {
c->set_qualifier(c_qual);
}
return c;
}
|
