aboutsummaryrefslogtreecommitdiffstats
path: root/src/daemon_clients/pluginhandler.h
blob: 6d39500081cdec41c39af5b56699263820a0463a (plain)
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
/* Copyright (C) 2022 The Qt Company Ltd.
 *
 * SPDX-License-Identifier: GPL-3.0-only WITH Qt-GPL-exception-1.0
*/
#pragma once

#include "clienthandler.h"

class PluginHandler : public ClientHandler {

    public:
        PluginHandler(const RequestInfo &request, const LicdSetup &settings)
                : ClientHandler(request, settings) {}

        bool isLicenseRequestDue() override { return true; } // Pluging does timed requests, so every request counts

        void buildRequestJson() override
        {
            std::stringstream pay;
            pay << "{";
            pay<< "\"license_number\":" << "\"" << m_request.licenseId << "\",";
            pay << "\"user_id\":" << "\"" << m_request.userId << "\",";
            pay << "\"hw_id\":" << "\"" << m_settings.get("hw_id") << "\",";
            pay << "\"src\":" << "\"" << m_request.appName << "\",";
            pay << "\"host_os\":" << "\"" << m_settings.get("host_os") << "\",";
            pay << "\"src_version\":" << "\"" << m_request.appVersion << "\",";
            pay << "\"email\":" << "\"" << m_request.email << "\"";
            //pay << "\"operation\":" << "\"" << m_request.operation << "\"";
            pay << "}";
            m_request.payload = pay.str();
        }

        bool isCachedReservationValid(std::string &reply) override
        {
            if (!checkLicenseExpiryTime(reply)) {
                if (checkLeewayTime(reply)) {
                    return true;
                }
            } else {
                reply = replyString[e_license_granted];
                return true;
            }
            return false;
        }

        int parseAndSaveResponse(std::string &response) override
        {
            JsonHandler json(response);
            // response JSON is converted to a reply string to the client from now on
            std::stringstream ss;

            if (json.get("status") != "true") {
                if (json.get("message") == "License fully reserved") {
                    response = replyString[e_license_pool_full];
                } else {
                    response = replyString[e_license_rejected];
                }
                // Remove the license file and return
                utils::deleteFile(m_request.licenseFile);
                return 1;
            }

            ss << replyString[e_license_granted];
            ss << " expiry_date=" << json.get("expiry_date");
            ss << " license_id=" << json.get("license_number");
            ss << " reservation_id=" << json.get("reservation_id");
            response = ss.str();

            // Save the license JSON
            int result = utils::writeToFile(m_request.licenseFile, json.dump(4));
            if (result != 0) {
                std::cout << "ERROR saving license file: '" << m_request.licenseFile << "': " << strerror(result) << std::endl;
            }
            return 0;
        }
};