File indexing completed on 2024-04-21 04:43:22

 /*
     This file is part of the PolKit1-qt project
     SPDX-FileCopyrightText: 2009 Radek Novacek <rnovacek@redhat.com>
 
     SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "polkitqt1-agent-session.h"
 
 #include <QDebug>
 
 #include "polkitqt1-identity.h"
 
 #define POLKIT_AGENT_I_KNOW_API_IS_SUBJECT_TO_CHANGE 1
 #include <polkitagent/polkitagent.h>
 
 using namespace PolkitQt1::Agent;
 
 class Session::Private
 {
 public:
     Private() {}
     ~Private();
 
     static void completed(PolkitAgentSession *s, gboolean gained_authorization, gpointer user_data);
     static void request(PolkitAgentSession *s, gchar *request, gboolean echo_on, gpointer user_data);
     static void showError(PolkitAgentSession *s, gchar *text, gpointer user_data);
     static void showInfo(PolkitAgentSession *s, gchar *text, gpointer user_data);
 
     AsyncResult *result;
     PolkitAgentSession *polkitAgentSession;
 };
 
 Session::Private::~Private()
 {
     // polkitAgentSession is freed in Session d'tor
 }
 
 Session::Session(const PolkitQt1::Identity &identity, const QString &cookie, AsyncResult *result, QObject *parent)
         : QObject(parent)
         , d(new Private)
 {
     d->result = result;
     d->polkitAgentSession = polkit_agent_session_new(identity.identity(), cookie.toUtf8().data());
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "completed", G_CALLBACK(Private::completed), this);
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "request", G_CALLBACK(Private::request), this);
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "show-error", G_CALLBACK(Private::showError), this);
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "show-info", G_CALLBACK(Private::showInfo), this);
 }
 
 Session::Session(PolkitAgentSession *pkAgentSession, QObject *parent)
         : QObject(parent)
         , d(new Private)
 {
     d->polkitAgentSession = pkAgentSession;
     if (d->polkitAgentSession) {
         g_object_ref(d->polkitAgentSession);
     }
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "completed", G_CALLBACK(Private::completed), this);
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "request", G_CALLBACK(Private::request), this);
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "show-error", G_CALLBACK(Private::showError), this);
     g_signal_connect(G_OBJECT(d->polkitAgentSession), "show-info", G_CALLBACK(Private::showInfo), this);
 }
 
 Session::~Session()
 {
     if (d->polkitAgentSession)
         g_object_unref(d->polkitAgentSession);
 
     delete d;
 }
 
 void Session::initiate()
 {
     polkit_agent_session_initiate(d->polkitAgentSession);
 }
 
 void Session::setResponse(const QString &response)
 {
     polkit_agent_session_response(d->polkitAgentSession, response.toUtf8().data());
 }
 
 void Session::cancel()
 {
     polkit_agent_session_cancel(d->polkitAgentSession);
 }
 
 AsyncResult *Session::result()
 {
     return d->result;
 }
 
 void Session::Private::completed(PolkitAgentSession *s, gboolean gained_authorization, gpointer user_data)
 {
     qDebug() << "COMPLETED";
     Session *session = (Session *)user_data;
     Q_EMIT(session)->completed(gained_authorization);
 
     //free session here as polkit documentation asks
     g_object_unref(session->d->polkitAgentSession);
     session->d->polkitAgentSession = nullptr;
 }
 
 void Session::Private::request(PolkitAgentSession *s, gchar *request, gboolean echo_on, gpointer user_data)
 {
     qDebug() << "REQUEST";
     Q_EMIT((Session *)user_data)->request(QString::fromUtf8(request), echo_on);
 }
 
 void Session::Private::showError(PolkitAgentSession *s, gchar *text, gpointer user_data)
 {
     qDebug() << "showError";
     Q_EMIT((Session *)user_data)->showError(QString::fromUtf8(text));
 }
 
 void Session::Private::showInfo(PolkitAgentSession *s, gchar *text, gpointer user_data)
 {
     qDebug() << "showInfo";
     Q_EMIT((Session *)user_data)->showInfo(QString::fromUtf8(text));
 }
 
 //
 
 class AsyncResult::Private
 {
 public:
     Private(GSimpleAsyncResult *r) : result(r) {};
 
     GSimpleAsyncResult *result;
 };
 
 AsyncResult::AsyncResult(GSimpleAsyncResult *result)
         : d(new Private(result))
 {
 }
 
 AsyncResult::~AsyncResult()
 {
     if (d->result)
         g_object_unref(d->result);
 }
 
 void AsyncResult::setCompleted()
 {
     if (d->result == nullptr)
         return;
     g_simple_async_result_complete(d->result);
     // Assure that completed won't be called twice
     g_object_unref(d->result);
     d->result = nullptr;
 }
 
 void AsyncResult::setError(const QString &text)
 {
     Q_ASSERT(d->result);
     g_simple_async_result_set_error(d->result, POLKIT_ERROR, POLKIT_ERROR_FAILED, "%s", text.toUtf8().data());
 }