entrouvert
/
OvhKvm
17
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

parallelize fetching of server info

This commit is contained in:
Pierre Ducroquet 2024-01-15 11:35:32 +01:00
parent bb8047be1a
commit ba8a41ef6f
2 changed files with 75 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

130
dedicatedservergroupwidget.cpp
View File

@ -14,19 +14,23 @@ DedicatedServerGroupWidget::DedicatedServerGroupWidget(OvhApi *api, const QStrin
ui(new Ui::DedicatedServerGroupWidget),
api(api),
_groupName(groupName),
_servers(servers)
_servers(servers),
totalMonthlyCost(0),
incompletePricing(false)
{
ui->setupUi(this);
ui->serverTable->hideColumn(0);
ui->serverTable->setRowCount(servers.count());
QTimer::singleShot(0, this, &DedicatedServerGroupWidget::fetchOvhData);
connect(this, &DedicatedServerGroupWidget::requestSingleServerData, this, &DedicatedServerGroupWidget::fetchSingleServerData);
if (_monitoringWithIntervention.isEmpty()) {
_monitoringWithIntervention = tr("Enabled with intervention");
_monitoringWithoutIntervention = tr("Enabled without intervention");
_noMonitoring = tr("Disabled");
}
fetchOvhData();
}
DedicatedServerGroupWidget::~DedicatedServerGroupWidget()
@ -34,72 +38,74 @@ DedicatedServerGroupWidget::~DedicatedServerGroupWidget()
delete ui;
}
QCoro::Task<> DedicatedServerGroupWidget::fetchOvhData()
void DedicatedServerGroupWidget::fetchOvhData()
{
ui->groupLabel->setText(tr("Group %1").arg(_groupName));
double totalMonthlyCost = 0;
bool incompletePricing = false;
QString currency;
int i = 0;
for (auto &&server: _servers) {
int c = 0;
qDebug() << server;
auto serverInfo = (co_await api->get("/dedicated/server/" + server, 1h)).object();
auto tableItem = new QTableWidgetItem(server);
ui->serverTable->setItem(i, c++, tableItem);
tableItem = new QTableWidgetItem(serverInfo["reverse"].toString());
ui->serverTable->setItem(i, c++, tableItem);
auto networkInfo = (co_await api->get(QString("/dedicated/server/%1/specifications/network").arg(server), 240h)).object();
auto routingInfo = networkInfo["routing"].toObject();
auto v4Info = routingInfo["ipv4"].toObject();
tableItem = new QTableWidgetItem(v4Info["ip"].toString());
ui->serverTable->setItem(i, c++, tableItem);
if (serverInfo["monitoring"].toBool()) {
if (serverInfo["noIntervention"].toBool())
tableItem = new QTableWidgetItem(_monitoringWithoutIntervention);
else
tableItem = new QTableWidgetItem(_monitoringWithIntervention);
} else {
tableItem = new QTableWidgetItem(_noMonitoring);
}
ui->serverTable->setItem(i, c++, tableItem);
auto hardwareInfo = (co_await api->get(QString("/dedicated/server/%1/specifications/hardware").arg(server), 240h)).object();
tableItem = new QTableWidgetItem(hardwareInfo["description"].toString());
ui->serverTable->setItem(i, c++, tableItem);
// Calculate monthly cost, using the /services API
auto serviceInfo = (co_await api->get(QString("/dedicated/server/%1/serviceInfos").arg(server), 1h)).object();
auto serviceId = serviceInfo["serviceId"].toInt();
auto servicesData = (co_await api->get(QString("/services/%1").arg(serviceId), 6h)).object();
auto billingData = servicesData["billing"].toObject();
auto pricingData = billingData["pricing"].toObject();
double totalCost = pricingData["price"].toObject()["value"].toDouble();
totalCost = totalCost / pricingData["interval"].toInt();
tableItem = new QTableWidgetItem(QString::number(totalCost));
ui->serverTable->setItem(i, c++, tableItem);
if (billingData["pricing"].isNull()) {
incompletePricing = true;
} else {
qDebug() << pricingData["price"] << pricingData["interval"];
if (currency.isEmpty())
currency = pricingData["price"].toObject()["currency"].toString();
// TODO: else ??
totalMonthlyCost += totalCost;
}
ui->serverTable->resizeColumnsToContents();
emit requestSingleServerData(i, server);
i++;
}
}
QCoro::Task<> DedicatedServerGroupWidget::fetchSingleServerData(int i, QString server)
{
qDebug() << "in fetch single";
qDebug() << "Fetching for row " << i;
int c = 0;
qDebug() << server;
auto serverInfo = (co_await api->get("/dedicated/server/" + server, 1h)).object();
auto tableItem = new QTableWidgetItem(server);
ui->serverTable->setItem(i, c++, tableItem);
tableItem = new QTableWidgetItem(serverInfo["reverse"].toString());
ui->serverTable->setItem(i, c++, tableItem);
auto networkInfo = (co_await api->get(QString("/dedicated/server/%1/specifications/network").arg(server), 240h)).object();
auto routingInfo = networkInfo["routing"].toObject();
auto v4Info = routingInfo["ipv4"].toObject();
tableItem = new QTableWidgetItem(v4Info["ip"].toString());
ui->serverTable->setItem(i, c++, tableItem);
if (serverInfo["monitoring"].toBool()) {
if (serverInfo["noIntervention"].toBool())
tableItem = new QTableWidgetItem(_monitoringWithoutIntervention);
else
tableItem = new QTableWidgetItem(_monitoringWithIntervention);
} else {
tableItem = new QTableWidgetItem(_noMonitoring);
}
ui->serverTable->setItem(i, c++, tableItem);
auto hardwareInfo = (co_await api->get(QString("/dedicated/server/%1/specifications/hardware").arg(server), 240h)).object();
tableItem = new QTableWidgetItem(hardwareInfo["description"].toString());
ui->serverTable->setItem(i, c++, tableItem);
// Calculate monthly cost, using the /services API
auto serviceInfo = (co_await api->get(QString("/dedicated/server/%1/serviceInfos").arg(server), 1h)).object();
auto serviceId = serviceInfo["serviceId"].toInt();
auto servicesData = (co_await api->get(QString("/services/%1").arg(serviceId), 6h)).object();
auto billingData = servicesData["billing"].toObject();
auto pricingData = billingData["pricing"].toObject();
double totalCost = pricingData["price"].toObject()["value"].toDouble();
totalCost = totalCost / pricingData["interval"].toInt();
tableItem = new QTableWidgetItem(QString::number(totalCost));
ui->serverTable->setItem(i, c++, tableItem);
if (billingData["pricing"].isNull()) {
incompletePricing = true;
} else {
qDebug() << pricingData["price"] << pricingData["interval"];
if (currency.isEmpty())
currency = pricingData["price"].toObject()["currency"].toString();
// TODO: else ??
totalMonthlyCost += totalCost;
}
ui->serverTable->resizeColumnsToContents();
if (incompletePricing) {
ui->monthlyCost->setText(tr("(incomplete!) %1 %2").arg(totalMonthlyCost).arg(currency));

8
dedicatedservergroupwidget.h
View File

@ -20,12 +20,18 @@ public:
~DedicatedServerGroupWidget();
QString groupName() const { return _groupName; }
private slots:
QCoro::Task<> fetchOvhData();
void fetchOvhData();
QCoro::Task<> fetchSingleServerData(int row, QString serverName);
signals:
void requestSingleServerData(int row, QString serverName);
private:
Ui::DedicatedServerGroupWidget *ui;
OvhApi *api;
QString _groupName;
QStringList _servers;
double totalMonthlyCost;
bool incompletePricing;
QString currency;
};
#endif // DEDICATEDSERVERGROUPWIDGET_H