mirror of
https://github.com/OPM/ResInsight.git
synced 2026-10-28 16:10:24 -05:00
Jørgen Herje
5afb5c8a17
- Fetch SUMO summary data using ri-cloud-api - Update ri-cloud-api submodule to get improved speed on sumo search
96 lines
3.6 KiB
C++
96 lines
3.6 KiB
C++
/////////////////////////////////////////////////////////////////////////////////
|
|
//
|
|
// Copyright (C) 2026- Equinor ASA
|
|
//
|
|
// ResInsight is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// ResInsight 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 General Public License at <http://www.gnu.org/licenses/gpl.html>
|
|
// for more details.
|
|
//
|
|
/////////////////////////////////////////////////////////////////////////////////
|
|
|
|
#pragma once
|
|
|
|
#include <QObject>
|
|
#include <QPointer>
|
|
#include <QProcessEnvironment>
|
|
#include <QTimer>
|
|
|
|
class QProcess;
|
|
class QNetworkAccessManager;
|
|
|
|
//==================================================================================================
|
|
///
|
|
/// Manages the life cycle of the local "ri_cloud_api" uvicorn service.
|
|
///
|
|
/// The service is a long-lived localhost process (unlike the single-shot script worker process in
|
|
/// RiaApplication). It is started when Sumo cloud authentication is performed and from the Cloud Data
|
|
/// user interface, bound to the first available port at or above the wanted port, polled for liveness
|
|
/// on its /alive endpoint, restarted if it stops responding, and killed when ResInsight closes.
|
|
///
|
|
/// A restart scans for a port again, so the port in use can change during a session. Always read the
|
|
/// current address from serverUrl() instead of caching it.
|
|
///
|
|
//==================================================================================================
|
|
class RiaCloudApiService : public QObject
|
|
{
|
|
Q_OBJECT
|
|
public:
|
|
// The server address is the base URL without the port, e.g. "http://127.0.0.1". The wanted port is
|
|
// where the search for an available port starts.
|
|
RiaCloudApiService( const QString& serverAddress, int wantedPort, QObject* parent = nullptr );
|
|
~RiaCloudApiService() override;
|
|
|
|
void start();
|
|
void stop();
|
|
void restart();
|
|
|
|
// True as soon as the process has been launched, which is not the same as the service being
|
|
// usable: uvicorn may still be booting, or may be about to exit on a missing dependency.
|
|
bool isRunning() const;
|
|
|
|
// True once the service has answered a health check, i.e. it is actually serving requests.
|
|
bool isResponding() const;
|
|
|
|
int port() const;
|
|
|
|
// Base URL of the service, including the port actually in use, e.g. "http://127.0.0.1:8001". Empty
|
|
// when the service is not running.
|
|
QString serverUrl() const;
|
|
|
|
signals:
|
|
// Emitted when isRunning() or isResponding() changes, so that user interface elements showing
|
|
// the server status can refresh. The status changes without any user interaction, driven by the
|
|
// health check and by the process exiting on its own.
|
|
void statusChanged();
|
|
|
|
private slots:
|
|
void onHealthCheck();
|
|
void onReadyReadStandardOutput();
|
|
|
|
private:
|
|
static int findAvailablePortNumber( int firstPort );
|
|
static QString serviceWorkingDirectory();
|
|
static QProcessEnvironment buildProcessEnvironment( const QString& workingDirectory );
|
|
|
|
private:
|
|
QPointer<QProcess> m_process;
|
|
QNetworkAccessManager* m_networkAccessManager;
|
|
QTimer m_startupTimer;
|
|
QTimer m_healthTimer;
|
|
|
|
const QString m_serverAddress;
|
|
const int m_wantedPort;
|
|
|
|
int m_port;
|
|
int m_consecutiveFailures;
|
|
bool m_isResponding;
|
|
};
|