|
0
|
1 /* |
|
|
2 * connection.cpp -- value wrapper for connecting to irccd |
|
|
3 * |
|
|
4 * Copyright (c) 2013-2016 David Demelier <markand@malikania.fr> |
|
|
5 * |
|
|
6 * Permission to use, copy, modify, and/or distribute this software for any |
|
|
7 * purpose with or without fee is hereby granted, provided that the above |
|
|
8 * copyright notice and this permission notice appear in all copies. |
|
|
9 * |
|
|
10 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES |
|
|
11 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF |
|
|
12 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR |
|
|
13 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES |
|
|
14 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN |
|
|
15 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF |
|
|
16 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. |
|
|
17 */ |
|
|
18 |
|
|
19 #include <logger.h> |
|
|
20 |
|
|
21 #include "connection.h" |
|
|
22 |
|
|
23 namespace irccd { |
|
|
24 |
|
|
25 json::Value Connection::next(const std::string &name, int timeout) |
|
|
26 { |
|
|
27 m_timer.reset(); |
|
|
28 |
|
|
29 while (isConnected()) { |
|
|
30 json::Value object = next(clamp(timeout)); |
|
|
31 |
|
|
32 if (object.isObject() && object["response"].toString() == name) |
|
|
33 return object; |
|
|
34 } |
|
|
35 |
|
|
36 throw std::runtime_error("connection lost"); |
|
|
37 } |
|
|
38 |
|
|
39 void Connection::verify(const std::string &name, int timeout) |
|
|
40 { |
|
|
41 auto object = next(name, timeout); |
|
|
42 auto value = object.at("status").toString(); |
|
|
43 |
|
|
44 if (!value.empty() && value != "ok") |
|
|
45 throw std::runtime_error(object.at("error").toString()); |
|
|
46 } |
|
|
47 |
|
|
48 } // !irccd |
