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
|
/* This file is part of KDevelop
Copyright 2019 Daniel Mensinger <daniel@mensinger-ka.de>
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Library General Public License for more details.
You should have received a copy of the GNU Library General Public License
along with this library; see the file COPYING.LIB. If not, write to
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
Boston, MA 02110-1301, USA.
*/
#include "mesonrewriterjob.h"
#include "mesonconfig.h"
#include "interfaces/iproject.h"
#include "util/path.h"
#include <KLocalizedString>
#include <KProcess>
#include <QJsonArray>
#include <QJsonDocument>
#include <QTemporaryFile>
#include <QtConcurrentRun>
#include "debug.h"
using namespace KDevelop;
MesonRewriterJob::MesonRewriterJob(IProject* project, const QVector<MesonRewriterActionPtr>& actions, QObject* parent)
: KJob(parent)
, m_project(project)
, m_actions(actions)
{
connect(&m_futureWatcher, &QFutureWatcher<QString>::finished, this, &MesonRewriterJob::finished);
}
QString MesonRewriterJob::execute()
{
QJsonArray command;
for (auto& i : m_actions) {
command.append(i->command());
}
QTemporaryFile tempFile;
tempFile.setAutoRemove(false);
if (!tempFile.open()) {
return i18n("Failed to create a temporary file.");
}
QJsonDocument doc(command);
tempFile.write(doc.toJson());
tempFile.flush();
Meson::BuildDir buildDir = Meson::currentBuildDir(m_project);
KProcess proc(this);
proc.setWorkingDirectory(m_project->path().toLocalFile());
proc.setOutputChannelMode(KProcess::SeparateChannels);
proc.setProgram(buildDir.mesonExecutable.toLocalFile());
proc << QStringLiteral("rewrite") << QStringLiteral("command") << tempFile.fileName();
int ret = proc.execute();
if (ret != 0) {
return i18n("%1 returned %2", proc.program().join(QLatin1Char(' ')), ret);
}
auto rawData = proc.readAllStandardError();
if (rawData.isEmpty()) {
return QString();
}
QJsonParseError error;
QJsonDocument result = QJsonDocument::fromJson(rawData, &error);
if (error.error) {
return i18n("JSON parser error: %1", error.errorString());
}
if (!result.isObject()) {
return i18n("The rewriter output of '%1' is not an object", proc.program().join(QLatin1Char(' ')));
}
for (auto& i : m_actions) {
i->parseResult(result.object());
}
return QString();
}
void MesonRewriterJob::finished()
{
QString result = m_futureWatcher.result();
if (!result.isEmpty()) {
qCWarning(KDEV_Meson) << "REWRITER " << result;
setError(true);
setErrorText(result);
emitResult();
return;
}
qCDebug(KDEV_Meson) << "REWRITER: Meson rewriter job finished";
emitResult();
}
bool MesonRewriterJob::doKill()
{
if (m_futureWatcher.isRunning()) {
m_futureWatcher.cancel();
}
return true;
}
void MesonRewriterJob::start()
{
auto future = QtConcurrent::run(this, &MesonRewriterJob::execute);
m_futureWatcher.setFuture(future);
}
|
