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
173
174
175
176
177
178
179
180
181
182
183
184
185
|
/* OperServ core functions
*
* (C) 2003-2022 Anope Team
* Contact us at team@anope.org
*
* Please read COPYING and README for further details.
*
* Based on the original code of Epona by Lara.
* Based on the original code of Services by Andy Church.
*/
#include "module.h"
static unsigned int HARDMAX = 65536;
class CommandOSLogSearch : public Command
{
static inline Anope::string CreateLogName(const Anope::string &file, time_t t = Anope::CurTime)
{
char timestamp[32];
tm *tm = localtime(&t);
strftime(timestamp, sizeof(timestamp), "%Y%m%d", tm);
return Anope::LogDir + "/" + file + "." + timestamp;
}
public:
CommandOSLogSearch(Module *creator) : Command(creator, "operserv/logsearch", 1, 3)
{
this->SetDesc(_("Searches logs for a matching pattern"));
this->SetSyntax(_("[+\037days\037d] [+\037limit\037l] \037pattern\037"));
}
void Execute(CommandSource &source, const std::vector<Anope::string> ¶ms) anope_override
{
int days = 7, replies = 50;
unsigned i;
for (i = 0; i < params.size() && params[i][0] == '+'; ++i)
{
switch (params[i][params[i].length() - 1])
{
case 'd':
if (params[i].length() > 2)
{
Anope::string dur = params[i].substr(1, params[i].length() - 2);
try
{
days = convertTo<int>(dur);
if (days <= 0)
throw ConvertException();
}
catch (const ConvertException &)
{
source.Reply(_("Invalid duration %s, using %d days."), dur.c_str(), days);
}
}
break;
case 'l':
if (params[i].length() > 2)
{
Anope::string dur = params[i].substr(1, params[i].length() - 2);
try
{
replies = convertTo<int>(dur);
if (replies <= 0)
throw ConvertException();
}
catch (const ConvertException &)
{
source.Reply(_("Invalid limit %s, using %d."), dur.c_str(), replies);
}
}
break;
default:
source.Reply(_("Unknown parameter: %s"), params[i].c_str());
}
}
if (i >= params.size())
{
this->OnSyntaxError(source, "");
return;
}
Anope::string search_string = params[i++];
for (; i < params.size(); ++i)
search_string += " " + params[i];
Log(LOG_ADMIN, source, this) << "for " << search_string;
bool wildcard = search_string.find_first_of("?*") != Anope::string::npos;
bool regex = search_string.empty() == false && search_string[0] == '/' && search_string[search_string.length() - 1] == '/';
const Anope::string &logfile_name = Config->GetModule(this->owner)->Get<const Anope::string>("logname");
std::vector<Anope::string> matches;
for (int d = days - 1; d >= 0; --d)
{
Anope::string lf_name = CreateLogName(logfile_name, Anope::CurTime - (d * 86400));
Log(LOG_DEBUG) << "Searching " << lf_name;
std::fstream fd(lf_name.c_str(), std::ios_base::in);
if (!fd.is_open())
continue;
for (Anope::string buf, token; std::getline(fd, buf.str());)
{
bool match = false;
if (regex)
match = Anope::Match(buf, search_string, false, true);
else if (wildcard)
match = Anope::Match(buf, "*" + search_string + "*");
else
match = buf.find_ci(search_string) != Anope::string::npos;
if (match)
{
matches.push_back(buf);
if (matches.size() >= HARDMAX)
break;
}
}
fd.close();
}
unsigned int found = matches.size();
if (!found)
{
source.Reply(_("No matches for \002%s\002 found."), search_string.c_str());
return;
}
if (matches.size() >= HARDMAX)
{
source.Reply(_("Too many results for \002%s\002."), search_string.c_str());
return;
}
if (matches.size() > static_cast<unsigned int>(replies))
{
matches.erase(matches.begin(), matches.begin() + (matches.size() - static_cast<unsigned int>(replies)));
}
source.Reply(_("Matches for \002%s\002:"), search_string.c_str());
unsigned int count = 0;
for (std::vector<Anope::string>::iterator it = matches.begin(), it_end = matches.end(); it != it_end; ++it)
source.Reply("#%d: %s", ++count, it->c_str());
source.Reply(_("Showed %d/%d matches for \002%s\002."), matches.size(), found, search_string.c_str());
}
bool OnHelp(CommandSource &source, const Anope::string &subcommand) anope_override
{
this->SendSyntax(source);
source.Reply(" ");
source.Reply(_("This command searches the Services logfiles for messages\n"
"that match the given pattern. The day and limit argument\n"
"may be used to specify how many days of logs to search\n"
"and the number of replies to limit to. By default this\n"
"command searches one week of logs, and limits replies\n"
"to 50.\n"
" \n"
"For example:\n"
" \002LOGSEARCH +21d +500l Anope\002\n"
" Searches the last 21 days worth of logs for messages\n"
" containing Anope and lists the most recent 500 of them."));
return true;
}
};
class OSLogSearch : public Module
{
CommandOSLogSearch commandoslogsearch;
public:
OSLogSearch(const Anope::string &modname, const Anope::string &creator) : Module(modname, creator, VENDOR),
commandoslogsearch(this)
{
}
};
MODULE_INIT(OSLogSearch)
|
