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
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
|
// SPDX-FileCopyrightText: 2019 - 2023 UnionTech Software Technology Co., Ltd.
//
// SPDX-License-Identifier: GPL-3.0-or-later
#include "dldbushandler.h"
#include <QDebug>
#include <QStandardPaths>
#include <QLoggingCategory>
#ifdef QT_DEBUG
Q_LOGGING_CATEGORY(logDBusHandler, "org.deepin.log.viewer.dbus.handler")
#else
Q_LOGGING_CATEGORY(logDBusHandler, "org.deepin.log.viewer.dbus.handler", QtInfoMsg)
#endif
DLDBusHandler *DLDBusHandler::m_statichandeler = nullptr;
DLDBusHandler *DLDBusHandler::instance(QObject *parent)
{
if (parent != nullptr && m_statichandeler == nullptr) {
m_statichandeler = new DLDBusHandler(parent);
}
return m_statichandeler;
}
DLDBusHandler::~DLDBusHandler()
{
quit();
}
DLDBusHandler::DLDBusHandler(QObject *parent)
: QObject(parent)
{
m_dbus = new DeepinLogviewerInterface("com.deepin.logviewer",
"/com/deepin/logviewer",
QDBusConnection::systemBus(),
this);
//Note: when dealing with remote objects, it is not always possible to determine if it exists when creating a QDBusInterface.
if (!m_dbus->isValid() && !m_dbus->lastError().message().isEmpty()) {
qCCritical(logDBusHandler) << "dbus com.deepin.logviewer isValid false error:" << m_dbus->lastError() << m_dbus->lastError().message();
}
qCDebug(logDBusHandler) << "dbus com.deepin.logviewer isValid true";
}
/*!
* \~chinese \brief DLDBusHandler::readLog 读取日志文件
* \~chinese \param filePath 文件路径
* \~chinese \return 读取的日志
*/
QString DLDBusHandler::readLog(const QString &filePath)
{
QString tempFilePath = createFilePathCacheFile(filePath);
QFile file(tempFilePath);
if (!file.open(QIODevice::ReadOnly)) {
qWarning() << "Failed to open filePath cache file:" << tempFilePath;
return QString("");
}
const int fd = file.handle();
if (fd <= 0) {
qWarning() << "originPath file fd error. filePath cache file:" << tempFilePath;
return QString("");
}
QDBusUnixFileDescriptor dbusFd(fd);
QString log = m_dbus->readLog(dbusFd);
file.close();
releaseFilePathCacheFile(tempFilePath);
return log;
}
/*!
* \~chinese \brief DLDBusHandler::readLogLinesInRange 获取指定行数范围的日志内容，默认读取500条数据
* \~chinese \param filePath 文件路径
* \~chinese \param startLine 起始行
* \~chinese \param lineCount 获取行数
* \~chinese \return 读取的日志
*/
QStringList DLDBusHandler::readLogLinesInRange(const QString &filePath, qint64 startLine, qint64 lineCount, bool bReverse)
{
QString tempFilePath = createFilePathCacheFile(filePath);
QFile file(tempFilePath);
if (!file.open(QIODevice::ReadOnly)) {
qWarning() << "Failed to open filePath cache file:" << tempFilePath;
return QStringList();
}
const int fd = file.handle();
if (fd <= 0) {
qWarning() << "originPath file fd error. filePath cache file:" << tempFilePath;
return QStringList();
}
QDBusUnixFileDescriptor dbusFd(fd);
QStringList lines = m_dbus->readLogLinesInRange(dbusFd, startLine, lineCount, bReverse);
file.close();
releaseFilePathCacheFile(tempFilePath);
return lines;
}
QString DLDBusHandler::openLogStream(const QString &filePath)
{
return m_dbus->openLogStream(filePath);
}
QString DLDBusHandler::readLogInStream(const QString &token)
{
return m_dbus->readLogInStream(token);
}
QStringList DLDBusHandler::whiteListOutPaths()
{
return m_dbus->whiteListOutPaths();
}
/*!
* \~chinese \brief DLDBusHandler::exitCode 返回进程状态
* \~chinese \return 进程返回值
*/
int DLDBusHandler::exitCode()
{
return m_dbus->exitCode();
}
/*!
* \~chinese \brief DLDBusHandler::quit 退出服务端程序
*/
void DLDBusHandler::quit()
{
m_dbus->quit();
}
QStringList DLDBusHandler::getFileInfo(const QString &flag, bool unzip)
{
QDBusPendingReply<QStringList> reply = m_dbus->getFileInfo(flag, unzip);
reply.waitForFinished();
if (reply.isError()) {
qCWarning(logDBusHandler) << "call dbus iterface 'getFileInfo()' failed. error info:" << reply.error().message();
} else {
filePath = reply.value();
}
return filePath;
}
QStringList DLDBusHandler::getOtherFileInfo(const QString &flag, bool unzip)
{
QDBusPendingReply<QStringList> reply = m_dbus->getOtherFileInfo(flag, unzip);
reply.waitForFinished();
QStringList filePathList;
if (reply.isError()) {
qCWarning(logDBusHandler) << "call dbus iterface 'getOtherFileInfo()' failed. error info:" << reply.error().message();
} else {
filePathList = reply.value();
}
return filePathList;
}
bool DLDBusHandler::exportLog(const QString &outDir, const QString &in, bool isFile)
{
return m_dbus->exportLog(outDir, in, isFile);
}
bool DLDBusHandler::isFileExist(const QString &filePath)
{
QString ret = m_dbus->isFileExist(filePath);
return ret == "exist";
}
quint64 DLDBusHandler::getFileSize(const QString &filePath)
{
return m_dbus->getFileSize(filePath);
}
qint64 DLDBusHandler::getLineCount(const QString &filePath)
{
return m_dbus->getLineCount(filePath);
}
QString DLDBusHandler::executeCmd(const QString &cmd)
{
return m_dbus->executeCmd(cmd);
}
QString DLDBusHandler::createFilePathCacheFile(const QString &logFilePath)
{
QString tempFilePath = m_tempDir.path() + QDir::separator() + "Log_file_path.txt";
QFile tmpFile(tempFilePath);
if (!tmpFile.open(QIODevice::WriteOnly | QIODevice::Text)) {
qWarning() << "Failed to open temp file:" << tempFilePath;
return QString("");
}
QTextStream in(&tmpFile);
in << logFilePath;
tmpFile.close();
return tempFilePath;
}
void DLDBusHandler::releaseFilePathCacheFile(const QString &cacheFilePath)
{
if (!cacheFilePath.isEmpty())
QFile::remove(cacheFilePath);
}
|
