add risky room expiry

Author: DistractedCat

collab/main.go

@@ -10,6 +10,7 @@ import (
 	"os"
 	"strconv"
 	"sync"
+	"time"
 
 	"github.com/gin-gonic/gin"
 	"github.com/gorilla/websocket"
@@ -351,10 +352,25 @@ func handleMessages(
 				Type:    msgData.Type,
 				UserID:  msgData.UserID,
 			}
+
+			extendExpiryTime(msgData.UserID, persistMappings)
 		} else {
 			log.Printf("Unknown message type: %s", msgData.Type)
-		}
 	}
+	}
+}
+
+func extendExpiryTime(userId string, persistMappings *verify.PersistMappings) {
+		
+	ctx := context.Background()
+	if err := persistMappings.Conn.Expire(ctx, userId, time.Minute * 10).Err(); err != nil {
+		log.Println("Error extending room time on ping: ", err.Error())
+	} else {
+		
+		log.Printf("expiration reset for 10 minutes for user %s: ", userId)
+	}
+	
+	
 }
 
 type ClientWorkspace struct {

collab/verify/persistMappings.go

@@ -30,5 +30,7 @@ func VerifyPersist(persistMappings *PersistMappings, roomID string, userID strin
 		return false
 	}
 
+	log.Printf("current roomID: %s, expected roomID: %s", data["roomId"], roomID)
+
 	return data["roomId"] == roomID
 }

collab/verify/roomMappings.go

@@ -3,6 +3,7 @@ package verify
 import (
 	"context"
 	"log"
+	//"time"
 
 	redis "github.com/go-redis/redis/v8"
 )
@@ -54,5 +55,13 @@ func VerifyRoomAndMoveToPersist(
 		log.Printf("error sending room to persistent storage: %s", err.Error())
 	}
 
+	/*	
+	if err := persistMappings.Conn.Expire(ctx, userId, 20 * time.Second).Err(); err != nil {
+		log.Printf("error setting expiration for persisting room storage: %s", err.Error())
+	} else {
+		log.Printf("expiration set for 10 minutes for user %s: ", userId)
+	
+	}
+	*/
 	return true
 }

peerprep/components/questionpage/CollabEditor.tsx

@@ -276,7 +276,9 @@ export default function CollabEditor({
       clearInterval(interval);
       clearInterval(disconnectCheckInterval);
     };
-  }, [notifyRoomOfConnection, PING_INTERVAL_MILLISECONDS, connected, socket]);
+  }, [
+    notifyRoomOfConnection, PING_INTERVAL_MILLISECONDS, connected, socket
+    ]);
 
   const handleCloseConnection = () => {
     const confirmClose = confirm(