From 0af2724ee9984fd4d21e4d2c65d958d745203698 Mon Sep 17 00:00:00 2001
From: tt2468 <tt2468@gmail.com>
Date: Wed, 28 Apr 2021 11:12:53 -0700
Subject: [PATCH] WebSocketSession: Add connectedAt

---
 src/WebSocketSession.cpp | 11 +++++++++++
 src/WebSocketSession.h   |  4 ++++
 2 files changed, 15 insertions(+)

diff --git a/src/WebSocketSession.cpp b/src/WebSocketSession.cpp
index ed1015a8..ff1a4be4 100644
--- a/src/WebSocketSession.cpp
+++ b/src/WebSocketSession.cpp
@@ -3,6 +3,7 @@
 #include "plugin-macros.generated.h"
 
 WebSocketSession::WebSocketSession() :
+	_connectedAt(0),
 	_incomingMessages(0),
 	_outgoingMessages(0),
 	_encoding(0),
@@ -15,6 +16,16 @@ WebSocketSession::WebSocketSession() :
 {
 }
 
+uint64_t WebSocketSession::ConnectedAt()
+{
+	return _connectedAt.load();
+}
+
+void WebSocketSession::SetConnectedAt(uint64_t at);
+{
+	_connectedAt.store(at);
+}
+
 uint64_t WebSocketSession::IncomingMessages()
 {
 	return _incomingMessages.load();
diff --git a/src/WebSocketSession.h b/src/WebSocketSession.h
index 142f4292..5a1c4594 100644
--- a/src/WebSocketSession.h
+++ b/src/WebSocketSession.h
@@ -9,6 +9,9 @@ class WebSocketSession
 	public:
 		WebSocketSession();
 
+		uint64_t ConnectedAt();
+		void SetConnectedAt(uint64_t at);
+
 		uint64_t IncomingMessages();
 		void IncrementIncomingMessages();
 
@@ -37,6 +40,7 @@ class WebSocketSession
 		void SetEventSubscriptions(uint64_t subscriptions);
 
 	private:
+		std::atomic<uint64_t> _connectedAt;
 		std::atomic<uint64_t> _incomingMessages;
 		std::atomic<uint64_t> _outgoingMessages;
 		std::atomic<uint8_t> _encoding;