OIDCSessionImpl.h

#ifndef TENDUKE_OIDC_OIDCSESSIONIMPL_H
#define TENDUKE_OIDC_OIDCSESSIONIMPL_H
 
#include "./OIDCLogin.h"
#include "./OIDCSession.h"
#include "./OIDCSessionEventListener.h"
#include "../OIDCState.h"
#include "../OIDCClient.h"
#include "time/Clock.h"
 
#include <cstdint>
#include <memory>
#include <mutex>
 
namespace tenduke { namespace oidc {

const std::chrono::milliseconds DEFAULT_SESSION_LOGIN_TIMEOUT = std::chrono::minutes(6);

class OIDCSessionImpl : public OIDCSession
{
public:
    static const std::uint64_t DEFAULT_SAFETY_MARGIN_S;

    OIDCSessionImpl(
        std::unique_ptr<tenduke::oidc::OIDCState> state,
        const std::shared_ptr<const tenduke::oidc::OIDCLogin> &oidc,
        const std::shared_ptr<const tenduke::oidc::OIDCClient> &oidcClient,
        const std::shared_ptr<tenduke::time::Clock> &clock,
        const std::shared_ptr<::tenduke::oidc::OIDCSessionEventListener> &eventListener = nullptr,
        uint64_t validitySafetyMarginS = DEFAULT_SAFETY_MARGIN_S,
        std::chrono::milliseconds loginTimeout = DEFAULT_SESSION_LOGIN_TIMEOUT
    );
 
    // tenduke::oidc::OIDCSession
public:
    void abortLogin() override;
    void ensureValidSession() override;
    std::string getAccessToken() override;
    std::shared_ptr<const tenduke::oidc::OIDCState> getOIDCState() override;
    bool heartbeat() override;
    void invalidate() override;
    bool isValid() override;
    void reEstablish() override;
    void refresh() override;
 
protected:
    virtual bool hasRefreshableState();
    virtual void refreshOrLogin();
    virtual void login();
 
protected:
    std::mutex loginMutex;
    bool abortRequested = false;

    std::shared_ptr<tenduke::oidc::OIDCState> state;
    std::shared_ptr<tenduke::oidc::OIDCLoginRequest> loginRequest;
    const std::chrono::milliseconds loginTimeout;
    const std::uint64_t validitySafetyMarginS;

    const std::shared_ptr<tenduke::time::Clock> clock;
    const std::shared_ptr<const tenduke::oidc::OIDCLogin> oidc;
    const std::shared_ptr<const tenduke::oidc::OIDCClient> oidcClient;
    const std::shared_ptr<tenduke::oidc::OIDCSessionEventListener> notify;
};
 
}}
 
#endif //TENDUKE_OIDC_OIDCSESSIONIMPL_H