SerializedOIDCSession.h

#ifndef TENDUKE_OIDC_SERIALIZEDOIDCSESSION_H
#define TENDUKE_OIDC_SERIALIZEDOIDCSESSION_H
 
#include "./OIDCSession.h"
 
#include <chrono>
#include <memory>
#include <mutex>
 
namespace tenduke { namespace oidc {

const std::chrono::seconds DEFAULT_SESSION_CONCURRENCY_TIMEOUT = std::chrono::minutes(5);
 

class SerializedOIDCSession : public tenduke::oidc::OIDCSession
{
public:
    SerializedOIDCSession(
        const std::shared_ptr<tenduke::oidc::OIDCSession> &session,
        const std::chrono::milliseconds &concurrencyTimeout
    );
 
    // tenduke::oidc::OIDCSession interface
public:
    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;
 
private:
    const std::shared_ptr<tenduke::oidc::OIDCSession> session;
 
    const std::chrono::milliseconds concurrencyTimeout;
    std::recursive_timed_mutex serializeStateAccess;
};
 
}}
 
#endif //TENDUKE_OIDC_SERIALIZEDOIDCSESSION_H