1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "chrome/browser/extensions/api/log_private/syslog_parser.h"
6
7 #include <string>
8 #include <vector>
9
10 #include "base/logging.h"
11 #include "base/memory/linked_ptr.h"
12 #include "base/memory/singleton.h"
13 #include "base/strings/string_number_conversions.h"
14 #include "base/strings/string_split.h"
15 #include "base/strings/string_tokenizer.h"
16 #include "base/time/time.h"
17 #include "chrome/browser/extensions/api/log_private/filter_handler.h"
18 #include "chrome/browser/extensions/api/log_private/log_parser.h"
19 #include "chrome/browser/extensions/api/log_private/log_private_api.h"
20 #include "chrome/common/extensions/api/log_private.h"
21
22 namespace extensions {
23
24 namespace {
25
26 const char kProcessInfoDelimiters[] = "[]";
27
28 } // namespace
29
SyslogParser()30 SyslogParser::SyslogParser() {}
31
~SyslogParser()32 SyslogParser::~SyslogParser() {}
33
ParseEntry(const std::string & input,std::vector<linked_ptr<api::log_private::LogEntry>> * output,FilterHandler * filter_handler) const34 SyslogParser::Error SyslogParser::ParseEntry(
35 const std::string& input,
36 std::vector<linked_ptr<api::log_private::LogEntry> >* output,
37 FilterHandler* filter_handler) const {
38 linked_ptr<api::log_private::LogEntry> entry(new api::log_private::LogEntry);
39
40 base::StringTokenizer tokenizer(input, " ");
41 if (!tokenizer.GetNext()) {
42 LOG(ERROR)
43 << "Error when parsing data. Expect: At least 3 tokens. Actual: 0";
44 return TOKENIZE_ERROR;
45 }
46 std::string time = tokenizer.token();
47 if (ParseTime(time, &(entry->timestamp)) != SyslogParser::SUCCESS) {
48 return SyslogParser::PARSE_ERROR;
49 }
50 // Skips "localhost" field.
51 if (!tokenizer.GetNext()) {
52 LOG(ERROR)
53 << "Error when parsing data. Expect: At least 3 tokens. Actual: 1";
54 return TOKENIZE_ERROR;
55 }
56 if (!tokenizer.GetNext()) {
57 LOG(ERROR)
58 << "Error when parsing data. Expect: At least 3 tokens. Actual: 2";
59 return TOKENIZE_ERROR;
60 }
61 ParseProcess(tokenizer.token(), entry.get());
62 ParseLevel(input, entry.get());
63 entry->full_entry = input;
64
65 if (filter_handler->IsValidLogEntry(*(entry.get()))) {
66 output->push_back(entry);
67 }
68
69 return SyslogParser::SUCCESS;
70 }
71
ParseTime(const std::string & input,double * output) const72 SyslogParser::Error SyslogParser::ParseTime(const std::string& input,
73 double* output) const {
74 base::Time parsed_time;
75 if (!base::Time::FromString(input.c_str(), &parsed_time)) {
76 LOG(ERROR) << "Error when parsing time";
77 return SyslogParser::PARSE_ERROR;
78 }
79
80 *output = parsed_time.ToJsTime();
81 return SyslogParser::SUCCESS;
82 }
83
ParseProcess(const std::string & input,api::log_private::LogEntry * entry) const84 SyslogParser::Error SyslogParser::ParseProcess(
85 const std::string& input,
86 api::log_private::LogEntry* entry) const {
87 base::StringTokenizer tokenizer(input, kProcessInfoDelimiters);
88 if (!tokenizer.GetNext()) {
89 LOG(ERROR)
90 << "Error when parsing data. Expect: At least 1 token. Actual: 0";
91 return SyslogParser::PARSE_ERROR;
92 }
93 entry->process = tokenizer.token();
94 entry->process_id = "unknown";
95 if (tokenizer.GetNext()) {
96 std::string token = tokenizer.token();
97 int tmp;
98 if (base::StringToInt(token, &tmp)) {
99 entry->process_id = token;
100 }
101 }
102 return SyslogParser::SUCCESS;
103 }
104
ParseLevel(const std::string & input,api::log_private::LogEntry * entry) const105 void SyslogParser::ParseLevel(const std::string& input,
106 api::log_private::LogEntry* entry) const {
107 if (input.find("ERROR") != std::string::npos) {
108 entry->level = "error";
109 } else if (input.find("WARN") != std::string::npos) {
110 entry->level = "warning";
111 } else if (input.find("INFO") != std::string::npos) {
112 entry->level = "info";
113 } else {
114 entry->level = "unknown";
115 }
116 }
117
118 } // namespace extensions
119