summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSadie Powell <sadie@witchery.services>2025-05-09 12:36:42 +0100
committerSadie Powell <sadie@witchery.services>2025-05-09 12:36:42 +0100
commitb76b407b33973bf1ac00a842b5b325fb8e378170 (patch)
tree7c909c4d68a6adb452f33999a4c16a014cc1c799
parent8b089ab1a7c91f8de5a7eabf1ad493cbef96282f (diff)
Move HTTP types to the HTTP namespace.
-rw-r--r--include/modules/httpd.h85
-rw-r--r--include/modules/rpc.h6
-rw-r--r--modules/extra/xmlrpc.cpp12
-rw-r--r--modules/httpd.cpp54
-rw-r--r--modules/protocol/inspircd.cpp2
-rw-r--r--modules/rpc/jsonrpc.cpp12
-rw-r--r--modules/rpc/rpc_data.cpp20
-rw-r--r--modules/rpc/rpc_message.cpp6
-rw-r--r--modules/rpc/rpc_system.cpp4
-rw-r--r--modules/webcpanel/pages/chanserv/access.cpp4
-rw-r--r--modules/webcpanel/pages/chanserv/akick.cpp4
-rw-r--r--modules/webcpanel/pages/chanserv/chanserv.h12
-rw-r--r--modules/webcpanel/pages/chanserv/drop.cpp8
-rw-r--r--modules/webcpanel/pages/chanserv/info.cpp4
-rw-r--r--modules/webcpanel/pages/chanserv/modes.cpp6
-rw-r--r--modules/webcpanel/pages/chanserv/set.cpp6
-rw-r--r--modules/webcpanel/pages/chanserv/utils.cpp2
-rw-r--r--modules/webcpanel/pages/confirm.cpp2
-rw-r--r--modules/webcpanel/pages/confirm.h2
-rw-r--r--modules/webcpanel/pages/hostserv/hostserv.h2
-rw-r--r--modules/webcpanel/pages/hostserv/request.cpp4
-rw-r--r--modules/webcpanel/pages/index.cpp18
-rw-r--r--modules/webcpanel/pages/index.h2
-rw-r--r--modules/webcpanel/pages/logout.cpp4
-rw-r--r--modules/webcpanel/pages/logout.h2
-rw-r--r--modules/webcpanel/pages/memoserv/memos.cpp10
-rw-r--r--modules/webcpanel/pages/memoserv/memoserv.h2
-rw-r--r--modules/webcpanel/pages/nickserv/alist.cpp2
-rw-r--r--modules/webcpanel/pages/nickserv/cert.cpp2
-rw-r--r--modules/webcpanel/pages/nickserv/confirm.cpp2
-rw-r--r--modules/webcpanel/pages/nickserv/info.cpp4
-rw-r--r--modules/webcpanel/pages/nickserv/nickserv.h8
-rw-r--r--modules/webcpanel/pages/operserv/akill.cpp10
-rw-r--r--modules/webcpanel/pages/operserv/operserv.h2
-rw-r--r--modules/webcpanel/pages/register.cpp2
-rw-r--r--modules/webcpanel/pages/register.h2
-rw-r--r--modules/webcpanel/static_fileserver.cpp6
-rw-r--r--modules/webcpanel/static_fileserver.h4
-rw-r--r--modules/webcpanel/template_fileserver.cpp6
-rw-r--r--modules/webcpanel/template_fileserver.h2
-rw-r--r--modules/webcpanel/webcpanel.cpp8
-rw-r--r--modules/webcpanel/webcpanel.h20
42 files changed, 200 insertions, 175 deletions
diff --git a/include/modules/httpd.h b/include/modules/httpd.h
index 03d157df0..3d524a27e 100644
--- a/include/modules/httpd.h
+++ b/include/modules/httpd.h
@@ -8,28 +8,39 @@
#pragma once
-enum HTTPError
+namespace HTTP
{
- HTTP_ERROR_OK = 200,
- HTTP_FOUND = 302,
- HTTP_BAD_REQUEST = 400,
- HTTP_PAGE_NOT_FOUND = 404,
- HTTP_NOT_SUPPORTED = 505
-};
+ class Reply;
+ class Message;
+ class Page;
+ class Client;
+ class Provider;
+
+ enum Error
+ {
+ OK = 200,
+ FOUND = 302,
+ BAD_REQUEST = 400,
+ PAGE_NOT_FOUND = 404,
+ NOT_SUPPORTED = 505,
+ };
+}
/* A message to someone */
-struct HTTPReply final
+struct HTTP::Reply final
{
- HTTPError error = HTTP_ERROR_OK;
+ HTTP::Error error = HTTP::OK;
Anope::string content_type;
std::map<Anope::string, Anope::string, ci::less> headers;
typedef std::list<std::pair<Anope::string, Anope::string> > cookie;
std::vector<cookie> cookies;
- HTTPReply() = default;
- HTTPReply &operator=(const HTTPReply &) = default;
+ Reply() = default;
+ Reply &operator=(const HTTP::Reply &) = default;
- HTTPReply(const HTTPReply &other) : error(other.error), length(other.length)
+ Reply(const HTTP::Reply &other)
+ : error(other.error)
+ , length(other.length)
{
content_type = other.content_type;
headers = other.headers;
@@ -39,7 +50,7 @@ struct HTTPReply final
out.push_back(new Data(datum->buf, datum->len));
}
- ~HTTPReply()
+ ~Reply()
{
for (const auto *datum : out)
delete datum;
@@ -81,7 +92,7 @@ struct HTTPReply final
};
/* A message from someone */
-struct HTTPMessage final
+struct HTTP::Message final
{
std::map<Anope::string, Anope::string, ci::less> headers;
std::map<Anope::string, Anope::string, ci::less> cookies;
@@ -90,17 +101,18 @@ struct HTTPMessage final
Anope::string content;
};
-class HTTPClient;
-class HTTPProvider;
-
-class HTTPPage
+class HTTP::Page
: public virtual Base
{
Anope::string url;
Anope::string content_type;
public:
- HTTPPage(const Anope::string &u, const Anope::string &ct = "text/html") : url(u), content_type(ct) { }
+ Page(const Anope::string &u, const Anope::string &ct = "text/html")
+ : url(u)
+ , content_type(ct)
+ {
+ }
const Anope::string &GetURL() const { return this->url; }
@@ -113,10 +125,10 @@ public:
* @param The HTTP header sent from the client to request the page
* @param The HTTP header that will be sent back to the client
*/
- virtual bool OnRequest(HTTPProvider *, const Anope::string &, HTTPClient *, HTTPMessage &, HTTPReply &) = 0;
+ virtual bool OnRequest(HTTP::Provider *, const Anope::string &, HTTP::Client *, HTTP::Message &, HTTP::Reply &) = 0;
};
-class HTTPClient
+class HTTP::Client
: public ClientSocket
, public BinarySocket
, public Base
@@ -128,18 +140,24 @@ protected:
}
public:
- HTTPClient(ListenSocket *l, int f, const sockaddrs &a) : ClientSocket(l, a), BinarySocket() { }
+ Client(ListenSocket *l, int f, const sockaddrs &a)
+ : ClientSocket(l, a)
+ , BinarySocket()
+ {
+ }
virtual const Anope::string GetIP()
{
return this->clientaddr.addr();
}
- virtual void SendError(HTTPError err, const Anope::string &msg) = 0;
- virtual void SendReply(HTTPReply *) = 0;
+ virtual void SendError(HTTP::Error err, const Anope::string &msg) = 0;
+ virtual void SendReply(HTTP::Reply *) = 0;
};
-class HTTPProvider
+#define HTTP_PROVIDER "HTTP::Provider"
+
+class HTTP::Provider
: public ListenSocket
, public Service
{
@@ -150,7 +168,14 @@ public:
std::vector<Anope::string> ext_ips;
std::vector<Anope::string> ext_headers;
- HTTPProvider(Module *c, const Anope::string &n, const Anope::string &i, const unsigned short p, bool s) : ListenSocket(i, p, i.find(':') != Anope::string::npos), Service(c, "HTTPProvider", n), ip(i), port(p), ssl(s) { }
+ Provider(Module *c, const Anope::string &n, const Anope::string &i, const unsigned short p, bool s)
+ : ListenSocket(i, p, i.find(':') != Anope::string::npos)
+ , Service(c, HTTP_PROVIDER, n)
+ , ip(i)
+ , port(p)
+ , ssl(s)
+ {
+ }
const Anope::string &GetIP() const
{
@@ -167,12 +192,12 @@ public:
return this->ssl;
}
- virtual bool RegisterPage(HTTPPage *page) = 0;
- virtual void UnregisterPage(HTTPPage *page) = 0;
- virtual HTTPPage *FindPage(const Anope::string &name) = 0;
+ virtual bool RegisterPage(HTTP::Page *page) = 0;
+ virtual void UnregisterPage(HTTP::Page *page) = 0;
+ virtual HTTP::Page *FindPage(const Anope::string &name) = 0;
};
-namespace HTTPUtils
+namespace HTTP
{
inline Anope::string URLDecode(const Anope::string &url)
{
diff --git a/include/modules/rpc.h b/include/modules/rpc.h
index 1c3dec811..e4fb9fb59 100644
--- a/include/modules/rpc.h
+++ b/include/modules/rpc.h
@@ -148,9 +148,9 @@ public:
Anope::string name;
Anope::string id;
std::deque<Anope::string> data;
- HTTPReply &reply;
+ HTTP::Reply &reply;
- Request(HTTPReply &r)
+ Request(HTTP::Reply &r)
: reply(r)
{
}
@@ -188,7 +188,7 @@ public:
const auto &GetMinParams() const { return minparams; }
- virtual bool Run(ServiceInterface *iface, HTTPClient *client, Request &request) = 0;
+ virtual bool Run(ServiceInterface *iface, HTTP::Client *client, Request &request) = 0;
};
struct RPC::Token final
diff --git a/modules/extra/xmlrpc.cpp b/modules/extra/xmlrpc.cpp
index 3e6a8af76..54e2752d9 100644
--- a/modules/extra/xmlrpc.cpp
+++ b/modules/extra/xmlrpc.cpp
@@ -20,10 +20,10 @@ template<class... Ts> overloaded(Ts...) -> overloaded<Ts...>;
class XMLRPCServiceInterface final
: public RPC::ServiceInterface
- , public HTTPPage
+ , public HTTP::Page
{
private:
- static void SendError(HTTPReply &reply, xmlrpc_env &env)
+ static void SendError(HTTP::Reply &reply, xmlrpc_env &env)
{
Log(LOG_DEBUG) << "XML-RPC error " << env.fault_code << ": " << env.fault_string;
@@ -69,11 +69,11 @@ public:
XMLRPCServiceInterface(Module *creator)
: RPC::ServiceInterface(creator)
- , HTTPPage("/xmlrpc", "text/xml")
+ , HTTP::Page("/xmlrpc", "text/xml")
{
}
- bool OnRequest(HTTPProvider *provider, const Anope::string &page_name, HTTPClient *client, HTTPMessage &message, HTTPReply &reply) override
+ bool OnRequest(HTTP::Provider *provider, const Anope::string &page_name, HTTP::Client *client, HTTP::Message &message, HTTP::Reply &reply) override
{
xmlrpc_env env;
xmlrpc_env_init(&env);
@@ -276,7 +276,7 @@ class ModuleXMLRPC final
: public Module
{
private:
- ServiceReference<HTTPProvider> httpref;
+ ServiceReference<HTTP::Provider> httpref;
XMLRPCServiceInterface xmlrpcinterface;
public:
@@ -316,7 +316,7 @@ public:
XMLRPCServiceInterface::enable_i8 = modconf.Get<bool>("enable_i8", "yes");
XMLRPCServiceInterface::enable_nil = modconf.Get<bool>("enable_nil", "yes");
- this->httpref = ServiceReference<HTTPProvider>("HTTPProvider", modconf.Get<const Anope::string>("server", "httpd/main"));
+ this->httpref = ServiceReference<HTTP::Provider>(HTTP_PROVIDER, modconf.Get<const Anope::string>("server", "httpd/main"));
if (!httpref)
throw ConfigException("Unable to find http reference, is httpd loaded?");
diff --git a/modules/httpd.cpp b/modules/httpd.cpp
index a21b78ae4..8aaacd7f4 100644
--- a/modules/httpd.cpp
+++ b/modules/httpd.cpp
@@ -18,19 +18,19 @@ static Anope::string BuildDate()
return timebuf;
}
-static Anope::string GetStatusFromCode(HTTPError err)
+static Anope::string GetStatusFromCode(HTTP::Error err)
{
switch (err)
{
- case HTTP_ERROR_OK:
+ case HTTP::OK:
return "200 OK";
- case HTTP_FOUND:
+ case HTTP::FOUND:
return "302 Found";
- case HTTP_BAD_REQUEST:
+ case HTTP::BAD_REQUEST:
return "400 Bad Request";
- case HTTP_PAGE_NOT_FOUND:
+ case HTTP::PAGE_NOT_FOUND:
return "404 Not Found";
- case HTTP_NOT_SUPPORTED:
+ case HTTP::NOT_SUPPORTED:
return "505 HTTP Version Not Supported";
}
@@ -38,13 +38,13 @@ static Anope::string GetStatusFromCode(HTTPError err)
}
class MyHTTPClient final
- : public HTTPClient
+ : public HTTP::Client
{
- HTTPProvider *provider;
- HTTPMessage message;
+ HTTP::Provider *provider;
+ HTTP::Message message;
bool header_done = false, served = false;
Anope::string page_name;
- Reference<HTTPPage> page;
+ Reference<HTTP::Page> page;
Anope::string ip;
unsigned content_length = 0;
@@ -64,7 +64,7 @@ class MyHTTPClient final
if (!this->page)
{
- this->SendError(HTTP_PAGE_NOT_FOUND, "Page not found");
+ this->SendError(HTTP::PAGE_NOT_FOUND, "Page not found");
return;
}
@@ -83,7 +83,7 @@ class MyHTTPClient final
Log(LOG_DEBUG, "httpd") << "httpd: Serving page " << this->page_name << " to " << this->ip;
- HTTPReply reply;
+ HTTP::Reply reply;
reply.content_type = this->page->GetContentType();
if (this->page->OnRequest(this->provider, this->page_name, this, this->message, reply))
@@ -93,7 +93,7 @@ class MyHTTPClient final
public:
time_t created;
- MyHTTPClient(HTTPProvider *l, int f, const sockaddrs &a) : Socket(f, l->GetFamily()), HTTPClient(l, f, a), provider(l), ip(a.addr()), created(Anope::CurTime)
+ MyHTTPClient(HTTP::Provider *l, int f, const sockaddrs &a) : Socket(f, l->GetFamily()), HTTP::Client(l, f, a), provider(l), ip(a.addr()), created(Anope::CurTime)
{
Log(LOG_DEBUG, "httpd") << "Accepted connection " << f << " from " << a.addr();
}
@@ -142,7 +142,7 @@ public:
size_t sz = token.find('=');
if (sz == Anope::string::npos || !sz || sz + 1 >= token.length())
continue;
- this->message.post_data[token.substr(0, sz)] = HTTPUtils::URLDecode(token.substr(sz + 1));
+ this->message.post_data[token.substr(0, sz)] = HTTP::URLDecode(token.substr(sz + 1));
Log(LOG_DEBUG_2) << "HTTP POST from " << this->clientaddr.addr() << ": " << token.substr(0, sz) << ": " << this->message.post_data[token.substr(0, sz)];
}
@@ -163,13 +163,13 @@ public:
if (params.empty() || (params[0] != "GET" && params[0] != "POST"))
{
- this->SendError(HTTP_BAD_REQUEST, "Unknown operation");
+ this->SendError(HTTP::BAD_REQUEST, "Unknown operation");
return true;
}
if (params.size() != 3)
{
- this->SendError(HTTP_BAD_REQUEST, "Invalid parameters");
+ this->SendError(HTTP::BAD_REQUEST, "Invalid parameters");
return true;
}
@@ -191,7 +191,7 @@ public:
size_t sz = token.find('=');
if (sz == Anope::string::npos || !sz || sz + 1 >= token.length())
continue;
- this->message.get_data[token.substr(0, sz)] = HTTPUtils::URLDecode(token.substr(sz + 1));
+ this->message.get_data[token.substr(0, sz)] = HTTP::URLDecode(token.substr(sz + 1));
}
}
@@ -229,9 +229,9 @@ public:
return true;
}
- void SendError(HTTPError err, const Anope::string &msg) override
+ void SendError(HTTP::Error err, const Anope::string &msg) override
{
- HTTPReply h;
+ HTTP::Reply h;
h.error = err;
@@ -240,7 +240,7 @@ public:
this->SendReply(&h);
}
- void SendReply(HTTPReply *msg) override
+ void SendReply(HTTP::Reply *msg) override
{
this->WriteClient("HTTP/1.1 " + GetStatusFromCode(msg->error));
this->WriteClient("Date: " + BuildDate());
@@ -281,17 +281,17 @@ public:
};
class MyHTTPProvider final
- : public HTTPProvider
+ : public HTTP::Provider
, public Timer
{
int timeout;
- std::map<Anope::string, HTTPPage *> pages;
+ std::map<Anope::string, HTTP::Page *> pages;
std::list<Reference<MyHTTPClient> > clients;
public:
MyHTTPProvider(Module *c, const Anope::string &n, const Anope::string &i, const unsigned short p, const int t, bool s)
: Socket(-1, i.find(':') == Anope::string::npos ? AF_INET : AF_INET6)
- , HTTPProvider(c, n, i, p, s)
+ , HTTP::Provider(c, n, i, p, s)
, Timer(c, 10, true)
, timeout(t)
{
@@ -317,17 +317,17 @@ public:
return c;
}
- bool RegisterPage(HTTPPage *page) override
+ bool RegisterPage(HTTP::Page *page) override
{
return this->pages.emplace(page->GetURL(), page).second;
}
- void UnregisterPage(HTTPPage *page) override
+ void UnregisterPage(HTTP::Page *page) override
{
this->pages.erase(page->GetURL());
}
- HTTPPage *FindPage(const Anope::string &pname) override
+ HTTP::Page *FindPage(const Anope::string &pname) override
{
if (this->pages.count(pname) == 0)
return NULL;
@@ -443,7 +443,7 @@ public:
for (std::map<Anope::string, MyHTTPProvider *>::iterator it = this->providers.begin(), it_end = this->providers.end(); it != it_end;)
{
- HTTPProvider *p = it->second;
+ HTTP::Provider *p = it->second;
++it;
if (existing.count(p->name) == 0)
diff --git a/modules/protocol/inspircd.cpp b/modules/protocol/inspircd.cpp
index 49b359857..9535778ae 100644
--- a/modules/protocol/inspircd.cpp
+++ b/modules/protocol/inspircd.cpp
@@ -91,7 +91,7 @@ namespace
if (split == Anope::string::npos)
res = modmap.emplace(datapair, "");
else
- res = modmap.emplace(datapair.substr(0, split), HTTPUtils::URLDecode(datapair.substr(split + 1)));
+ res = modmap.emplace(datapair.substr(0, split), HTTP::URLDecode(datapair.substr(split + 1)));
if (Anope::ProtocolDebug && res.second)
Log(LOG_DEBUG) << "Parsed module data: key=" << res.first->first << " value=" << res.first->second;
diff --git a/modules/rpc/jsonrpc.cpp b/modules/rpc/jsonrpc.cpp
index 2e8753b8a..dfb6ce2e5 100644
--- a/modules/rpc/jsonrpc.cpp
+++ b/modules/rpc/jsonrpc.cpp
@@ -23,7 +23,7 @@ inline Anope::string yyjson_get_astr(yyjson_val *val, const char *key)
class JSONRPCServiceInterface final
: public RPC::ServiceInterface
- , public HTTPPage
+ , public HTTP::Page
{
private:
static std::pair<yyjson_mut_doc *, yyjson_mut_val *> CreateReply(const Anope::string &id)
@@ -43,7 +43,7 @@ private:
return { doc, root };
}
- static void SendError(HTTPReply &reply, int64_t code, const Anope::string &message, const Anope::string &id = "")
+ static void SendError(HTTP::Reply &reply, int64_t code, const Anope::string &message, const Anope::string &id = "")
{
Log(LOG_DEBUG) << "JSON-RPC error " << code << ": " << message;
@@ -91,11 +91,11 @@ public:
JSONRPCServiceInterface(Module *creator)
: RPC::ServiceInterface(creator)
- , HTTPPage("/jsonrpc", "application/json")
+ , HTTP::Page("/jsonrpc", "application/json")
{
}
- bool OnRequest(HTTPProvider *provider, const Anope::string &page_name, HTTPClient *client, HTTPMessage &message, HTTPReply &reply) override
+ bool OnRequest(HTTP::Provider *provider, const Anope::string &page_name, HTTP::Client *client, HTTP::Message &message, HTTP::Reply &reply) override
{
yyjson_read_err error;
const auto flags = YYJSON_READ_ALLOW_TRAILING_COMMAS | YYJSON_READ_ALLOW_INVALID_UNICODE;
@@ -275,7 +275,7 @@ class ModuleJSONRPC final
: public Module
{
private:
- ServiceReference<HTTPProvider> httpref;
+ ServiceReference<HTTP::Provider> httpref;
JSONRPCServiceInterface jsonrpcinterface;
public:
@@ -299,7 +299,7 @@ public:
const auto &modconf = conf.GetModule(this);
JSONRPCServiceInterface::integer_bits = modconf.Get<unsigned>("integer_bits", "64");
- this->httpref = ServiceReference<HTTPProvider>("HTTPProvider", modconf.Get<const Anope::string>("server", "httpd/main"));
+ this->httpref = ServiceReference<HTTP::Provider>(HTTP_PROVIDER, modconf.Get<const Anope::string>("server", "httpd/main"));
if (!httpref)
throw ConfigException("Unable to find http reference, is httpd loaded?");
diff --git a/modules/rpc/rpc_data.cpp b/modules/rpc/rpc_data.cpp
index 13dec3cf2..bfc1fa565 100644
--- a/modules/rpc/rpc_data.cpp
+++ b/modules/rpc/rpc_data.cpp
@@ -139,7 +139,7 @@ public:
users.Reply(u->nick);
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
const auto detail = request.data.empty() ? "name" : request.data[0];
if (detail.equals_ci("name"))
@@ -171,7 +171,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
auto *na = NickAlias::Find(request.data[0]);
if (!na)
@@ -249,7 +249,7 @@ public:
users.Reply(uc->status.BuildModePrefixList() + uc->user->nick);
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
const auto detail = request.data.empty() ? "name" : request.data[0];
if (detail.equals_ci("name"))
@@ -281,7 +281,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
auto *c = Channel::Find(request.data[0]);
if (!c)
@@ -347,7 +347,7 @@ public:
root.Reply("vhost", o->vhost);
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
const auto detail = request.data.empty() ? "name" : request.data[0];
if (detail.equals_ci("name"))
@@ -379,7 +379,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
auto *o = Oper::Find(request.data[0]);
if (!o)
@@ -425,7 +425,7 @@ public:
root.Reply("uplink", nullptr);
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
const auto detail = request.data.empty() ? "name" : request.data[0];
if (detail.equals_ci("name"))
@@ -457,7 +457,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
auto *s = Server::Find(request.data[0]);
if (!s)
@@ -552,7 +552,7 @@ public:
root.Reply("vident", u->GetIdent());
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
const auto detail = request.data.empty() ? "name" : request.data[0];
if (detail.equals_ci("name"))
@@ -584,7 +584,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
auto *u = User::Find(request.data[0]);
if (!u)
diff --git a/modules/rpc/rpc_message.cpp b/modules/rpc/rpc_message.cpp
index 304f3f3ac..63de7d8e5 100644
--- a/modules/rpc/rpc_message.cpp
+++ b/modules/rpc/rpc_message.cpp
@@ -36,7 +36,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
if (!global)
{
@@ -63,7 +63,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
if (!global)
{
@@ -94,7 +94,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
auto *bi = BotInfo::Find(request.data[0], true);
if (!bi)
diff --git a/modules/rpc/rpc_system.cpp b/modules/rpc/rpc_system.cpp
index e20800268..cf8e9f4a5 100644
--- a/modules/rpc/rpc_system.cpp
+++ b/modules/rpc/rpc_system.cpp
@@ -27,7 +27,7 @@ public:
#endif
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
// For both the map type and array type we test that we can handle:
//
@@ -88,7 +88,7 @@ public:
{
}
- bool Run(RPC::ServiceInterface *iface, HTTPClient *client, RPC::Request &request) override
+ bool Run(RPC::ServiceInterface *iface, HTTP::Client *client, RPC::Request &request) override
{
auto &root = request.Root<RPC::Array>();
for (const auto &event : Service::GetServiceKeys(RPC_EVENT))
diff --git a/modules/webcpanel/pages/chanserv/access.cpp b/modules/webcpanel/pages/chanserv/access.cpp
index 18a265152..f6cfcb130 100644
--- a/modules/webcpanel/pages/chanserv/access.cpp
+++ b/modules/webcpanel/pages/chanserv/access.cpp
@@ -11,7 +11,7 @@ WebCPanel::ChanServ::Access::Access(const Anope::string &cat, const Anope::strin
{
}
-bool WebCPanel::ChanServ::Access::OnRequest(HTTPProvider *server, const Anope::string &page_name, HTTPClient *client, HTTPMessage &message, HTTPReply &reply, NickAlias *na, TemplateFileServer::Replacements &replacements)
+bool WebCPanel::ChanServ::Access::OnRequest(HTTP::Provider *server, const Anope::string &page_name, HTTP::Client *client, HTTP::Message &message, HTTP::Reply &reply, NickAlias *na, TemplateFileServer::Replacements &replacements)
{
TemplateFileServer Page("chanserv/access.html");
const Anope::string &chname = message.get_data["channel"];
@@ -95,7 +95,7 @@ bool WebCPanel::ChanServ::Access::OnRequest(HTTPProvider *server, const Anope::s
/* command might have invalidated u_access */
u_access = ci->AccessFor(na->nc);
- replacements["ESCAPED_CHANNEL"] = HTTPUtils::URLEncode(chname);
+ replacements["ESCAPED_CHANNEL"] = HTTP::URLEncode(chname);
replacements["ACCESS_CHANGE"] = u_access.HasPriv("ACCESS_CHANGE") ? "YES" : "NO";
for (unsigned i = 0; i < ci->GetAccessCount(); ++i)
diff --git a/modules/webcpanel/pages/chanserv/akick.cpp b/modules/webcpanel/pages/chanserv/akick.cpp
index dbb9520be..314ed458f 100644
--- a/modules/webcpanel/pages/chanserv/akick.cpp
+++ b/modules/webcpanel/pages/chanserv/akick.cpp
@@ -11,7 +11,7 @@ WebCPanel::ChanServ::Akick::Akick(const Anope::string &cat, const Anope::string
{
}
-bool WebCPanel::ChanServ::Akick::OnRequest(HTTPProvider *server, const Anope::string &page_name, HTTPClient *client, HTTPMessage &message, HTTPReply &reply, NickAlias *na, TemplateFileServer::Replacements &replacements)
+bool WebCPanel::ChanServ::Akick::OnRequest(HTTP::Provider *server, const Anope::string &page_name, HTTP::Client *client, HTTP::Message &message, HTTP::Reply &reply, NickAlias *na, TemplateFileServer::Replacements &replacements)
{
const Anope::string &chname = message.get_data["channel"];
TemplateFileServer Page("chanserv/akick.html");
@@ -66,7 +66,7 @@ bool WebCPanel::ChanServ::Akick::OnRequest(HTTPProvider *server, const Anope::st
WebPanel::RunCommand(client, na->nc->display, na->nc, "ChanServ", "chanserv/akick", params, replacements);
}
- replacements["ESCAPED_CHANNEL"] = HTTPUtils::URLEncode(chname);
+ replacements["ESCAPED_CHANNEL"] = HTTP::URLEncode(chname);
for (unsigned i = 0; i < ci->GetAkickCount(); ++i)
{