1 /* Copyright (c) 2013-2014 Jeffrey Pfau
2 *
3 * This Source Code Form is subject to the terms of the Mozilla Public
4 * License, v. 2.0. If a copy of the MPL was not distributed with this
5 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
6 #include "GBAApp.h"
7
8 #include "AudioProcessor.h"
9 #include "CoreController.h"
10 #include "CoreManager.h"
11 #include "ConfigController.h"
12 #include "Display.h"
13 #include "LogController.h"
14 #include "VFileDevice.h"
15 #include "Window.h"
16
17 #include <QFileInfo>
18 #include <QFileOpenEvent>
19 #include <QFontDatabase>
20 #include <QIcon>
21
22 #include <mgba-util/socket.h>
23 #include <mgba-util/vfs.h>
24
25 #ifdef USE_SQLITE3
26 #include "feature/sqlite3/no-intro.h"
27 #endif
28
29 #ifdef USE_DISCORD_RPC
30 #include "DiscordCoordinator.h"
31 #endif
32
33 using namespace QGBA;
34
35 static GBAApp* g_app = nullptr;
36
37 mLOG_DEFINE_CATEGORY(QT, "Qt", "platform.qt");
38
GBAApp(int & argc,char * argv[],ConfigController * config)39 GBAApp::GBAApp(int& argc, char* argv[], ConfigController* config)
40 : QApplication(argc, argv)
41 , m_configController(config)
42 , m_monospace(QFontDatabase::systemFont(QFontDatabase::FixedFont))
43 {
44 g_app = this;
45
46 #ifdef BUILD_SDL
47 SDL_Init(SDL_INIT_NOPARACHUTE);
48 #endif
49
50 SocketSubsystemInit();
51 qRegisterMetaType<const uint32_t*>("const uint32_t*");
52 qRegisterMetaType<mCoreThread*>("mCoreThread*");
53
54 if (!m_configController->getQtOption("displayDriver").isNull()) {
55 Display::setDriver(static_cast<Display::Driver>(m_configController->getQtOption("displayDriver").toInt()));
56 }
57
58 reloadGameDB();
59
60 m_manager.setConfig(m_configController->config());
61 m_manager.setMultiplayerController(&m_multiplayer);
62
63 if (!m_configController->getQtOption("audioDriver").isNull()) {
64 AudioProcessor::setDriver(static_cast<AudioProcessor::Driver>(m_configController->getQtOption("audioDriver").toInt()));
65 }
66
67 LogController::global()->load(m_configController);
68
69 #ifdef USE_DISCORD_RPC
70 ConfigOption* useDiscordPresence = m_configController->addOption("useDiscordPresence");
71 useDiscordPresence->addBoolean(tr("Enable Discord Rich Presence"));
72 useDiscordPresence->connect([](const QVariant& value) {
73 if (value.toBool()) {
74 DiscordCoordinator::init();
75 } else {
76 DiscordCoordinator::deinit();
77 }
78 }, this);
79 m_configController->updateOption("useDiscordPresence");
80 #endif
81
82 connect(this, &GBAApp::aboutToQuit, this, &GBAApp::cleanup);
83 }
84
cleanup()85 void GBAApp::cleanup() {
86 m_workerThreads.waitForDone();
87
88 while (!m_workerJobs.isEmpty()) {
89 finishJob(m_workerJobs.firstKey());
90 }
91
92 #ifdef USE_SQLITE3
93 if (m_db) {
94 NoIntroDBDestroy(m_db);
95 }
96 #endif
97
98 #ifdef USE_DISCORD_RPC
99 DiscordCoordinator::deinit();
100 #endif
101 }
102
event(QEvent * event)103 bool GBAApp::event(QEvent* event) {
104 if (event->type() == QEvent::FileOpen) {
105 CoreController* core = m_manager.loadGame(static_cast<QFileOpenEvent*>(event)->file());
106 m_windows[0]->setController(core, static_cast<QFileOpenEvent*>(event)->file());
107 return true;
108 }
109 return QApplication::event(event);
110 }
111
newWindow()112 Window* GBAApp::newWindow() {
113 if (m_windows.count() >= MAX_GBAS) {
114 return nullptr;
115 }
116 Window* w = new Window(&m_manager, m_configController, m_multiplayer.attached());
117 connect(w, &Window::destroyed, [this, w]() {
118 m_windows.removeAll(w);
119 for (Window* w : m_windows) {
120 w->updateMultiplayerStatus(m_windows.count() < MAX_GBAS);
121 }
122 });
123 m_windows.append(w);
124 w->setAttribute(Qt::WA_DeleteOnClose);
125 w->loadConfig();
126 w->show();
127 w->multiplayerChanged();
128 for (Window* w : m_windows) {
129 w->updateMultiplayerStatus(m_windows.count() < MAX_GBAS);
130 }
131 return w;
132 }
133
app()134 GBAApp* GBAApp::app() {
135 return g_app;
136 }
137
pauseAll(QList<Window * > * paused)138 void GBAApp::pauseAll(QList<Window*>* paused) {
139 for (auto& window : m_windows) {
140 if (!window->controller() || window->controller()->isPaused()) {
141 continue;
142 }
143 window->controller()->setPaused(true);
144 paused->append(window);
145 }
146 }
147
continueAll(const QList<Window * > & paused)148 void GBAApp::continueAll(const QList<Window*>& paused) {
149 for (auto& window : paused) {
150 if (window->controller()) {
151 window->controller()->setPaused(false);
152 }
153 }
154 }
155
getOpenFileName(QWidget * owner,const QString & title,const QString & filter)156 QString GBAApp::getOpenFileName(QWidget* owner, const QString& title, const QString& filter) {
157 QList<Window*> paused;
158 pauseAll(&paused);
159 QString filename = QFileDialog::getOpenFileName(owner, title, m_configController->getOption("lastDirectory"), filter);
160 continueAll(paused);
161 if (!filename.isEmpty()) {
162 m_configController->setOption("lastDirectory", QFileInfo(filename).dir().canonicalPath());
163 }
164 return filename;
165 }
166
getOpenFileNames(QWidget * owner,const QString & title,const QString & filter)167 QStringList GBAApp::getOpenFileNames(QWidget* owner, const QString& title, const QString& filter) {
168 QList<Window*> paused;
169 pauseAll(&paused);
170 QStringList filenames = QFileDialog::getOpenFileNames(owner, title, m_configController->getOption("lastDirectory"), filter);
171 continueAll(paused);
172 if (!filenames.isEmpty()) {
173 m_configController->setOption("lastDirectory", QFileInfo(filenames.at(0)).dir().canonicalPath());
174 }
175 return filenames;
176 }
177
getSaveFileName(QWidget * owner,const QString & title,const QString & filter)178 QString GBAApp::getSaveFileName(QWidget* owner, const QString& title, const QString& filter) {
179 QList<Window*> paused;
180 pauseAll(&paused);
181 QString filename = QFileDialog::getSaveFileName(owner, title, m_configController->getOption("lastDirectory"), filter);
182 continueAll(paused);
183 if (!filename.isEmpty()) {
184 m_configController->setOption("lastDirectory", QFileInfo(filename).dir().canonicalPath());
185 }
186 return filename;
187 }
188
getOpenDirectoryName(QWidget * owner,const QString & title,const QString & path)189 QString GBAApp::getOpenDirectoryName(QWidget* owner, const QString& title, const QString& path) {
190 QList<Window*> paused;
191 pauseAll(&paused);
192 QString filename = QFileDialog::getExistingDirectory(owner, title, !path.isNull() ? path : m_configController->getOption("lastDirectory"));
193 continueAll(paused);
194 if (path.isNull() && !filename.isEmpty()) {
195 m_configController->setOption("lastDirectory", QFileInfo(filename).dir().canonicalPath());
196 }
197 return filename;
198 }
199
dataDir()200 QString GBAApp::dataDir() {
201 #ifdef DATADIR
202 QString path = QString::fromUtf8(DATADIR);
203 #else
204 QString path = QCoreApplication::applicationDirPath();
205 #ifdef Q_OS_MAC
206 path += QLatin1String("/../Resources");
207 #endif
208 #endif
209 return path;
210 }
211
212 #ifdef USE_SQLITE3
reloadGameDB()213 bool GBAApp::reloadGameDB() {
214 NoIntroDB* db = nullptr;
215 db = NoIntroDBLoad((ConfigController::configDir() + "/nointro.sqlite3").toUtf8().constData());
216 if (db && m_db) {
217 NoIntroDBDestroy(m_db);
218 }
219 if (db) {
220 std::shared_ptr<GameDBParser> parser = std::make_shared<GameDBParser>(db);
221 submitWorkerJob(std::bind(&GameDBParser::parseNoIntroDB, parser));
222 m_db = db;
223 return true;
224 }
225 return false;
226 }
227 #else
reloadGameDB()228 bool GBAApp::reloadGameDB() {
229 return false;
230 }
231 #endif
232
submitWorkerJob(std::function<void ()> job,std::function<void ()> callback)233 qint64 GBAApp::submitWorkerJob(std::function<void ()> job, std::function<void ()> callback) {
234 return submitWorkerJob(job, nullptr, callback);
235 }
236
submitWorkerJob(std::function<void ()> job,QObject * context,std::function<void ()> callback)237 qint64 GBAApp::submitWorkerJob(std::function<void ()> job, QObject* context, std::function<void ()> callback) {
238 qint64 jobId = m_nextJob;
239 ++m_nextJob;
240 WorkerJob* jobRunnable = new WorkerJob(jobId, job, this);
241 m_workerJobs.insert(jobId, jobRunnable);
242 if (callback) {
243 waitOnJob(jobId, context, callback);
244 }
245 m_workerThreads.start(jobRunnable);
246 return jobId;
247 }
248
removeWorkerJob(qint64 jobId)249 bool GBAApp::removeWorkerJob(qint64 jobId) {
250 for (auto& job : m_workerJobCallbacks.values(jobId)) {
251 disconnect(job);
252 }
253 m_workerJobCallbacks.remove(jobId);
254 if (!m_workerJobs.contains(jobId)) {
255 return true;
256 }
257 bool success = false;
258 #if (QT_VERSION >= QT_VERSION_CHECK(5, 9, 0))
259 success = m_workerThreads.tryTake(m_workerJobs[jobId]);
260 #endif
261 if (success) {
262 m_workerJobs.remove(jobId);
263 }
264 return success;
265 }
266
267
waitOnJob(qint64 jobId,QObject * context,std::function<void ()> callback)268 bool GBAApp::waitOnJob(qint64 jobId, QObject* context, std::function<void ()> callback) {
269 if (!m_workerJobs.contains(jobId)) {
270 return false;
271 }
272 if (!context) {
273 context = this;
274 }
275 QMetaObject::Connection connection = connect(this, &GBAApp::jobFinished, context, [jobId, callback](qint64 testedJobId) {
276 if (jobId != testedJobId) {
277 return;
278 }
279 callback();
280 });
281 m_workerJobCallbacks.insert(m_nextJob, connection);
282 return true;
283 }
284
finishJob(qint64 jobId)285 void GBAApp::finishJob(qint64 jobId) {
286 m_workerJobs.remove(jobId);
287 emit jobFinished(jobId);
288 m_workerJobCallbacks.remove(jobId);
289 }
290
WorkerJob(qint64 id,std::function<void ()> job,GBAApp * owner)291 GBAApp::WorkerJob::WorkerJob(qint64 id, std::function<void ()> job, GBAApp* owner)
292 : m_id(id)
293 , m_job(job)
294 , m_owner(owner)
295 {
296 setAutoDelete(true);
297 }
298
run()299 void GBAApp::WorkerJob::run() {
300 m_job();
301 QMetaObject::invokeMethod(m_owner, "finishJob", Q_ARG(qint64, m_id));
302 }
303
304 #ifdef USE_SQLITE3
GameDBParser(NoIntroDB * db,QObject * parent)305 GameDBParser::GameDBParser(NoIntroDB* db, QObject* parent)
306 : QObject(parent)
307 , m_db(db)
308 {
309 // Nothing to do
310 }
311
parseNoIntroDB()312 void GameDBParser::parseNoIntroDB() {
313 VFile* vf = VFileDevice::open(GBAApp::dataDir() + "/nointro.dat", O_RDONLY);
314 if (vf) {
315 NoIntroDBLoadClrMamePro(m_db, vf);
316 vf->close(vf);
317 }
318 }
319
320 #endif
321