/src/resiprocate/resip/stack/Auth.cxx
Line | Count | Source (jump to first uncovered line) |
1 | | #if defined(HAVE_CONFIG_H) |
2 | | #include "config.h" |
3 | | #endif |
4 | | |
5 | | #include "resip/stack/Auth.hxx" |
6 | | #include "resip/stack/UnknownParameter.hxx" |
7 | | #include "rutil/Data.hxx" |
8 | | #include "rutil/DnsUtil.hxx" |
9 | | #include "rutil/Logger.hxx" |
10 | | #include "rutil/ParseBuffer.hxx" |
11 | | //#include "rutil/WinLeakCheck.hxx" // not compatible with placement new used below |
12 | | |
13 | | using namespace resip; |
14 | | using namespace std; |
15 | | |
16 | | #define RESIPROCATE_SUBSYSTEM Subsystem::SIP |
17 | | |
18 | | //==================== |
19 | | // Auth: |
20 | | //==================== |
21 | | Auth::Auth() : |
22 | | ParserCategory() |
23 | 0 | {} |
24 | | |
25 | | Auth::Auth(const HeaderFieldValue& hfv, Headers::Type type, PoolBase* pool) |
26 | | : ParserCategory(hfv, type, pool) |
27 | 6.46k | {} |
28 | | |
29 | | Auth::Auth(const Auth& rhs, PoolBase* pool) |
30 | | : ParserCategory(rhs, pool), |
31 | | mScheme(rhs.mScheme) |
32 | 0 | {} |
33 | | |
34 | | Auth& |
35 | | Auth::operator=(const Auth& rhs) |
36 | 0 | { |
37 | 0 | if (this != &rhs) |
38 | 0 | { |
39 | 0 | ParserCategory::operator=(rhs); |
40 | 0 | mScheme = rhs.mScheme; |
41 | 0 | } |
42 | 0 | return *this; |
43 | 0 | } |
44 | | |
45 | | Data& |
46 | | Auth::scheme() |
47 | 0 | { |
48 | 0 | checkParsed(); |
49 | 0 | return mScheme; |
50 | 0 | } |
51 | | |
52 | | const Data& |
53 | | Auth::scheme() const |
54 | 0 | { |
55 | 0 | checkParsed(); |
56 | 0 | return mScheme; |
57 | 0 | } |
58 | | |
59 | | void |
60 | | Auth::parse(ParseBuffer& pb) |
61 | 6.46k | { |
62 | 6.46k | const char* start; |
63 | 6.46k | start = pb.skipWhitespace(); |
64 | 6.46k | static const std::bitset<256> schemeDelimiter(Data::toBitset("\r\n\t =")); |
65 | 6.46k | pb.skipToOneOf(schemeDelimiter); |
66 | | |
67 | 6.46k | if (!pb.eof() && *pb.position() == Symbols::EQUALS[0]) |
68 | 4.60k | { |
69 | | // Authentication-Info only |
70 | | // back up, and then parse |
71 | 4.60k | pb.reset(start); |
72 | 4.60k | parseAuthParameters(pb); |
73 | 4.60k | } |
74 | 1.86k | else |
75 | 1.86k | { |
76 | | // everything else |
77 | 1.86k | pb.data(mScheme, start); |
78 | | |
79 | 1.86k | pb.skipWhitespace(); |
80 | 1.86k | parseAuthParameters(pb); |
81 | 1.86k | } |
82 | 6.46k | } |
83 | | |
84 | | EncodeStream& |
85 | | Auth::encodeParsed(EncodeStream& str) const |
86 | 0 | { |
87 | 0 | if (!mScheme.empty()) |
88 | 0 | { |
89 | 0 | str << mScheme << Symbols::SPACE; |
90 | 0 | } |
91 | |
|
92 | 0 | encodeAuthParameters(str); |
93 | |
|
94 | 0 | return str; |
95 | 0 | } |
96 | | |
97 | | ParserCategory* |
98 | | Auth::clone() const |
99 | 0 | { |
100 | 0 | return new Auth(*this); |
101 | 0 | } |
102 | | |
103 | | ParserCategory* |
104 | | Auth::clone(void* location) const |
105 | 0 | { |
106 | 0 | return new (location) Auth(*this); |
107 | 0 | } |
108 | | |
109 | | ParserCategory* |
110 | | Auth::clone(PoolBase* pool) const |
111 | 0 | { |
112 | 0 | return new (pool) Auth(*this, pool); |
113 | 0 | } |
114 | | |
115 | | void |
116 | | Auth::parseAuthParameters(ParseBuffer& pb) |
117 | 6.46k | { |
118 | 47.6k | while (!pb.eof()) |
119 | 46.2k | { |
120 | 46.2k | const char* keyStart = pb.position(); |
121 | 46.2k | static std::bitset<256> paramBegin=Data::toBitset(" \t\r\n="); |
122 | 46.2k | static std::bitset<256> terminators=Data::toBitset(" \t\r\n,"); |
123 | 46.2k | const char* keyEnd = pb.skipToOneOf(paramBegin); |
124 | 46.2k | if((int)(keyEnd-keyStart) != 0) |
125 | 45.6k | { |
126 | 45.6k | ParameterTypes::Type type = ParameterTypes::getType(keyStart, (unsigned int)(keyEnd - keyStart)); |
127 | 45.6k | Parameter* p=createParam(type, pb, terminators, getPool()); |
128 | 45.6k | if (!p) |
129 | 27.0k | { |
130 | 27.0k | mUnknownParameters.push_back(new UnknownParameter(keyStart, |
131 | 27.0k | int((keyEnd - keyStart)), pb, |
132 | 27.0k | terminators)); |
133 | 27.0k | } |
134 | 18.5k | else |
135 | 18.5k | { |
136 | | // invoke the particular factory |
137 | 18.5k | mParameters.push_back(p); |
138 | 18.5k | } |
139 | 45.6k | } |
140 | 643 | else |
141 | 643 | { |
142 | | // empty parameter name - skip and advance pb to next parameter |
143 | 643 | pb.skipToOneOf(terminators); |
144 | 643 | } |
145 | | |
146 | 46.2k | pb.skipWhitespace(); |
147 | 46.2k | if (pb.eof() || *pb.position() != Symbols::COMMA[0]) |
148 | 5.02k | { |
149 | 5.02k | break; |
150 | 5.02k | } |
151 | 41.2k | pb.skipChar(); |
152 | 41.2k | pb.skipWhitespace(); |
153 | 41.2k | } |
154 | 6.46k | } |
155 | | |
156 | | EncodeStream& |
157 | | Auth::encodeAuthParameters(EncodeStream& str) const |
158 | 0 | { |
159 | 0 | bool first = true; |
160 | 0 | for (ParameterList::const_iterator it = mParameters.begin(); |
161 | 0 | it != mParameters.end(); it++) |
162 | 0 | { |
163 | 0 | if (!first) |
164 | 0 | { |
165 | 0 | str << Symbols::COMMA; |
166 | 0 | } |
167 | 0 | first = false; |
168 | 0 | (*it)->encode(str); |
169 | 0 | } |
170 | |
|
171 | 0 | for (ParameterList::const_iterator it = mUnknownParameters.begin(); |
172 | 0 | it != mUnknownParameters.end(); it++) |
173 | 0 | { |
174 | 0 | if (!first) |
175 | 0 | { |
176 | 0 | str << Symbols::COMMA; |
177 | 0 | } |
178 | 0 | first = false; |
179 | 0 | (*it)->encode(str); |
180 | 0 | } |
181 | 0 | return str; |
182 | 0 | } |
183 | | |
184 | | ParameterTypes::Factory Auth::ParameterFactories[ParameterTypes::MAX_PARAMETER]={0}; |
185 | | |
186 | | Parameter* |
187 | | Auth::createParam(ParameterTypes::Type type, ParseBuffer& pb, const std::bitset<256>& terminators, PoolBase* pool) |
188 | 45.6k | { |
189 | 45.6k | if(type==ParameterTypes::qop) |
190 | 196 | { |
191 | 196 | DataParameter* qop = 0; |
192 | 196 | switch(mHeaderType) |
193 | 196 | { |
194 | 0 | case Headers::ProxyAuthenticate: |
195 | 0 | case Headers::WWWAuthenticate: |
196 | 0 | qop = new (pool) DataParameter(ParameterTypes::qopOptions,pb,terminators); |
197 | 0 | qop->setQuoted(true); |
198 | 0 | break; |
199 | 0 | case Headers::ProxyAuthorization: |
200 | 0 | case Headers::Authorization: |
201 | 0 | case Headers::AuthenticationInfo: |
202 | 196 | default: |
203 | 196 | qop = new (pool) DataParameter(ParameterTypes::qop,pb,terminators); |
204 | 196 | qop->setQuoted(false); |
205 | 196 | } |
206 | 195 | return qop; |
207 | 196 | } |
208 | | |
209 | 45.4k | if(type > ParameterTypes::UNKNOWN && type < ParameterTypes::MAX_PARAMETER && ParameterFactories[type]) |
210 | 18.4k | { |
211 | 18.4k | return ParameterFactories[type](type, pb, terminators, pool); |
212 | 18.4k | } |
213 | 27.0k | return 0; |
214 | 45.4k | } |
215 | | |
216 | | bool |
217 | | Auth::exists(const Param<Auth>& paramType) const |
218 | 0 | { |
219 | 0 | checkParsed(); |
220 | 0 | bool ret = getParameterByEnum(paramType.getTypeNum()) != NULL; |
221 | 0 | return ret; |
222 | 0 | } |
223 | | |
224 | | void |
225 | | Auth::remove(const Param<Auth>& paramType) |
226 | 0 | { |
227 | 0 | checkParsed(); |
228 | 0 | removeParameterByEnum(paramType.getTypeNum()); |
229 | 0 | } |
230 | | |
231 | | #define defineParam(_enum, _name, _type, _RFC_ref_ignored) \ |
232 | | _enum##_Param::DType& \ |
233 | 0 | Auth::param(const _enum##_Param& paramType) \ |
234 | 0 | { \ |
235 | 0 | checkParsed(); \ |
236 | 0 | _enum##_Param::Type* p = static_cast<_enum##_Param::Type*>(getParameterByEnum(paramType.getTypeNum())); \ |
237 | 0 | if (!p) \ |
238 | 0 | { \ |
239 | 0 | p = new _enum##_Param::Type(paramType.getTypeNum()); \ |
240 | 0 | mParameters.push_back(p); \ |
241 | 0 | } \ |
242 | 0 | return p->value(); \ |
243 | 0 | } \ Unexecuted instantiation: resip::Auth::param(resip::algorithm_Param const&) Unexecuted instantiation: resip::Auth::param(resip::cnonce_Param const&) Unexecuted instantiation: resip::Auth::param(resip::domain_Param const&) Unexecuted instantiation: resip::Auth::param(resip::nc_Param const&) Unexecuted instantiation: resip::Auth::param(resip::nonce_Param const&) Unexecuted instantiation: resip::Auth::param(resip::opaque_Param const&) Unexecuted instantiation: resip::Auth::param(resip::realm_Param const&) Unexecuted instantiation: resip::Auth::param(resip::response_Param const&) Unexecuted instantiation: resip::Auth::param(resip::stale_Param const&) Unexecuted instantiation: resip::Auth::param(resip::uri_Param const&) Unexecuted instantiation: resip::Auth::param(resip::username_Param const&) |
244 | | const _enum##_Param::DType& \ |
245 | 0 | Auth::param(const _enum##_Param& paramType) const \ |
246 | 0 | { \ |
247 | 0 | checkParsed(); \ |
248 | 0 | _enum##_Param::Type* p = static_cast<_enum##_Param::Type*>(getParameterByEnum(paramType.getTypeNum())); \ |
249 | 0 | if (!p) \ |
250 | 0 | { \ |
251 | 0 | InfoLog(<< "Missing parameter " << ParameterTypes::ParameterNames[paramType.getTypeNum()]); \ |
252 | 0 | DebugLog(<< *this); \ |
253 | 0 | throw Exception("Missing parameter", __FILE__, __LINE__); \ |
254 | 0 | } \ |
255 | 0 | return p->value(); \ |
256 | 0 | } Unexecuted instantiation: resip::Auth::param(resip::algorithm_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::cnonce_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::domain_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::nc_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::nonce_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::opaque_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::realm_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::response_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::stale_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::uri_Param const&) const Unexecuted instantiation: resip::Auth::param(resip::username_Param const&) const |
257 | | |
258 | | defineParam(algorithm, "algorithm", DataParameter, "RFC 2617"); |
259 | | defineParam(cnonce, "cnonce", QuotedDataParameter, "RFC 2617"); |
260 | | defineParam(domain, "domain", QuotedDataParameter, "RFC 3261"); |
261 | | defineParam(nc, "nc", DataParameter, "RFC 2617"); |
262 | | defineParam(nonce, "nonce", QuotedDataParameter, "RFC 2617"); |
263 | | defineParam(opaque, "opaque", QuotedDataParameter, "RFC 2617"); |
264 | | defineParam(realm, "realm", QuotedDataParameter, "RFC 2617"); |
265 | | defineParam(response, "response", QuotedDataParameter, "RFC 3261"); |
266 | | defineParam(stale, "stale", DataParameter, "RFC 2617"); |
267 | | defineParam(uri, "uri", QuotedDataParameter, "RFC 3261"); |
268 | | defineParam(username, "username", QuotedDataParameter, "RFC 3261"); |
269 | | |
270 | | DataParameter::Type& |
271 | | Auth::param(const qop_Param& paramType) |
272 | 0 | { |
273 | 0 | checkParsed(); |
274 | 0 | DataParameter* p = static_cast<DataParameter*>(getParameterByEnum(paramType.getTypeNum())); |
275 | 0 | if (!p) |
276 | 0 | { |
277 | 0 | p = new DataParameter(ParameterTypes::qop); |
278 | 0 | p->setQuoted(false); |
279 | 0 | mParameters.push_back(p); |
280 | 0 | } |
281 | 0 | return p->value(); |
282 | 0 | } |
283 | | const DataParameter::Type& |
284 | | Auth::param(const qop_Param& paramType) const |
285 | 0 | { |
286 | 0 | checkParsed(); |
287 | 0 | DataParameter* p = static_cast<DataParameter*>(getParameterByEnum(paramType.getTypeNum())); |
288 | 0 | if (!p) |
289 | 0 | { |
290 | 0 | InfoLog(<< "Missing parameter " << ParameterTypes::ParameterNames[paramType.getTypeNum()]); |
291 | 0 | DebugLog(<< *this); |
292 | 0 | throw Exception("Missing parameter", __FILE__, __LINE__); |
293 | 0 | } |
294 | 0 | return p->value(); |
295 | 0 | } |
296 | | |
297 | | DataParameter::Type& |
298 | | Auth::param(const qopOptions_Param& paramType) |
299 | 0 | { |
300 | 0 | checkParsed(); |
301 | 0 | DataParameter* p = static_cast<DataParameter*>(getParameterByEnum(paramType.getTypeNum())); |
302 | 0 | if (!p) |
303 | 0 | { |
304 | 0 | p = new DataParameter(ParameterTypes::qopOptions); |
305 | 0 | p->setQuoted(true); |
306 | 0 | mParameters.push_back(p); |
307 | 0 | } |
308 | 0 | return p->value(); |
309 | 0 | } |
310 | | const DataParameter::Type& |
311 | | Auth::param(const qopOptions_Param& paramType) const |
312 | 0 | { |
313 | 0 | checkParsed(); |
314 | 0 | DataParameter* p = static_cast<DataParameter*>(getParameterByEnum(paramType.getTypeNum())); |
315 | 0 | if (!p) |
316 | 0 | { |
317 | 0 | InfoLog(<< "Missing parameter " << ParameterTypes::ParameterNames[paramType.getTypeNum()]); |
318 | 0 | DebugLog(<< *this); |
319 | 0 | throw Exception("Missing parameter", __FILE__, __LINE__); |
320 | 0 | } |
321 | 0 | return p->value(); |
322 | 0 | } |
323 | | |
324 | | |
325 | | #undef defineParam |
326 | | |
327 | | /* ==================================================================== |
328 | | * The Vovida Software License, Version 1.0 |
329 | | * |
330 | | * Copyright (c) 2000 Vovida Networks, Inc. All rights reserved. |
331 | | * |
332 | | * Redistribution and use in source and binary forms, with or without |
333 | | * modification, are permitted provided that the following conditions |
334 | | * are met: |
335 | | * |
336 | | * 1. Redistributions of source code must retain the above copyright |
337 | | * notice, this list of conditions and the following disclaimer. |
338 | | * |
339 | | * 2. Redistributions in binary form must reproduce the above copyright |
340 | | * notice, this list of conditions and the following disclaimer in |
341 | | * the documentation and/or other materials provided with the |
342 | | * distribution. |
343 | | * |
344 | | * 3. The names "VOCAL", "Vovida Open Communication Application Library", |
345 | | * and "Vovida Open Communication Application Library (VOCAL)" must |
346 | | * not be used to endorse or promote products derived from this |
347 | | * software without prior written permission. For written |
348 | | * permission, please contact vocal@vovida.org. |
349 | | * |
350 | | * 4. Products derived from this software may not be called "VOCAL", nor |
351 | | * may "VOCAL" appear in their name, without prior written |
352 | | * permission of Vovida Networks, Inc. |
353 | | * |
354 | | * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED |
355 | | * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
356 | | * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND |
357 | | * NON-INFRINGEMENT ARE DISCLAIMED. IN NO EVENT SHALL VOVIDA |
358 | | * NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES |
359 | | * IN EXCESS OF $1,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL, |
360 | | * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, |
361 | | * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR |
362 | | * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY |
363 | | * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
364 | | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE |
365 | | * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH |
366 | | * DAMAGE. |
367 | | * |
368 | | * ==================================================================== |
369 | | * |
370 | | * This software consists of voluntary contributions made by Vovida |
371 | | * Networks, Inc. and many individuals on behalf of Vovida Networks, |
372 | | * Inc. For more information on Vovida Networks, Inc., please see |
373 | | * <http://www.vovida.org/>. |
374 | | * |
375 | | */ |