chore: removed redundant logs

Author: itsskofficial

src/client/app/actions.js

@@ -68,7 +68,6 @@ export async function subscribeUser(subscription) {
 			{ upsert: true }
 		)
 
-		console.log(`[Actions] Subscription saved for user: ${userId}`)
 		return { success: true }
 	} catch (error) {
 		console.error("[Actions] Error saving subscription:", error)
@@ -95,9 +94,6 @@ export async function unsubscribeUser(endpoint) {
 			{ $pull: { "userData.pwa_subscriptions": { endpoint: endpoint } } }
 		)
 
-		console.log(
-			`[Actions] Subscription with endpoint ${endpoint} removed for user: ${userId}`
-		)
 		return { success: true }
 	} catch (error) {
 		console.error("[Actions] Error removing subscription:", error)
@@ -144,9 +140,6 @@ export async function sendNotificationToCurrentUser(payload) {
 			!Array.isArray(subscriptions) ||
 			subscriptions.length === 0
 		) {
-			console.log(
-				`[Actions] No push subscription found for user ${userId}.`
-			)
 			return { success: false, error: "No subscription found for user." }
 		}
 
@@ -156,9 +149,6 @@ export async function sendNotificationToCurrentUser(payload) {
 				.sendNotification(subscription, JSON.stringify(payload))
 				.then(() => {
 					successCount++
-					console.log(
-						`[Actions] Push notification sent successfully to endpoint for user ${userId}.`
-					)
 				})
 				.catch(async (error) => {
 					console.error(

src/client/app/chat/page.js

@@ -979,9 +979,6 @@ export default function ChatPage() {
 				onDisconnected: () => handleStatusChange("disconnected"),
 				onAudioStream: (stream) => {
 					if (remoteAudioRef.current) {
-						console.log(
-							"Received remote audio stream, attaching to audio element."
-						)
 						remoteAudioRef.current.srcObject = stream
 						remoteAudioRef.current
 							.play()

src/client/app/page.js

@@ -88,7 +88,6 @@ const Home = () => {
 
 		if (!user) {
 			// User is not authenticated. Redirect to the Auth0 login page.
-			console.log("No user session found, redirecting to login.")
 			router.push("/auth/login")
 			return
 		}

src/client/components/LayoutWrapper.js

@@ -288,14 +288,12 @@ export default function LayoutWrapper({ children }) {
 			// The 'load' event ensures that SW registration doesn't delay page rendering.
 			window.addEventListener("load", function () {
 				navigator.serviceWorker.register("/sw.js").then(
-					function (registration) {
-						console.log(
-							"ServiceWorker registration successful with scope: ",
-							registration.scope
-						)
-					},
+					function (registration) {},
 					function (err) {
-						console.log("ServiceWorker registration failed: ", err)
+						console.error(
+							"ServiceWorker registration failed: ",
+							err
+						)
 					}
 				)
 			})
@@ -356,7 +354,6 @@ export default function LayoutWrapper({ children }) {
 
 	const subscribeToPushNotifications = useCallback(async () => {
 		if (!("serviceWorker" in navigator) || !("PushManager" in window)) {
-			console.log("Push notifications not supported by this browser.")
 			return
 		}
 		if (!process.env.NEXT_PUBLIC_VAPID_PUBLIC_KEY) {
@@ -377,7 +374,6 @@ export default function LayoutWrapper({ children }) {
 					return
 				}
 
-				console.log("Permission granted. Subscribing...")
 				const applicationServerKey = urlBase64ToUint8Array(
 					process.env.NEXT_PUBLIC_VAPID_PUBLIC_KEY
 				)
@@ -387,12 +383,9 @@ export default function LayoutWrapper({ children }) {
 					applicationServerKey
 				})
 
-				console.log("New subscription created:", subscription)
 				const serializedSub = JSON.parse(JSON.stringify(subscription))
 				await subscribeUser(serializedSub)
 				toast.success("Subscribed to push notifications!")
-			} else {
-				console.log("User is already subscribed.")
 			}
 		} catch (error) {
 			console.error("Error during push notification subscription:", error)
@@ -420,8 +413,6 @@ export default function LayoutWrapper({ children }) {
 		)
 	}
 
-	console.log(user?.[`${process.env.NEXT_PUBLIC_AUTH0_NAMESPACE}/roles`])
-
 	// ... (rest of the component is unchanged)
 	return (
 		<PlanContext.Provider

src/client/lib/webrtc-client.js

@@ -19,10 +19,6 @@ export class WebRTCClient {
 	}
 
 	async connect(deviceId, authToken, rtcToken) {
-		console.log("Connecting WebRTC client with deviceId:", deviceId)
-		console.log("Using authToken:", authToken)
-		console.log("Using rtcToken:", rtcToken)
-
 		if (!authToken) {
 			throw new Error("Authentication token is required to connect.")
 		}
@@ -37,49 +33,27 @@ export class WebRTCClient {
 			this.peerConnection = new RTCPeerConnection({
 				iceServers: this.iceServers
 			})
-			console.log("Created RTCPeerConnection with config:", {
-				iceServers: this.iceServers
-			})
-
-			console.log("Created RTCPeerConnection:", this.peerConnection)
 
 			// --- MODIFICATION: Queue ICE candidates instead of sending immediately ---
 			this.peerConnection.onicecandidate = (event) => {
 				if (event.candidate) {
-					console.log(
-						"ICE Candidate Found, queueing:",
-						event.candidate
-					)
 					this.iceCandidateQueue.push(event.candidate)
-				} else {
-					console.log("All ICE candidates have been gathered.")
 				}
 			}
 
 			this.peerConnection.oniceconnectionstatechange = (event) => {
 				const state = this.peerConnection.iceConnectionState
-				console.log(
-					`%cICE Connection State Change: ${state}`,
-					"font-weight: bold; color: blue;"
-				)
 			}
 
 			this.peerConnection.onconnectionstatechange = (event) => {
 				const state = this.peerConnection.connectionState
-				console.log(
-					`%cPeer Connection State Change: ${state}`,
-					"font-weight: bold; color: green;"
-				)
 
 				// --- START MODIFICATION: Handle temporary disconnections ---
 				// If connection is established or re-established, clear any pending disconnect timer.
 				if (state === "connected") {
 					if (this.disconnectTimer) {
 						clearTimeout(this.disconnectTimer)
 						this.disconnectTimer = null
-						console.log(
-							"WebRTC reconnected. Disconnect timer cleared."
-						)
 					}
 					this.options.onConnected?.()
 				}
@@ -113,13 +87,6 @@ export class WebRTCClient {
 				// --- END MODIFICATION ---
 			}
 
-			this.peerConnection.ondatachannel = (event) => {
-				console.log(
-					"Data Channel established by remote peer:",
-					event.channel
-				)
-			}
-
 			const audioConstraints = {
 				...(deviceId && { deviceId: { exact: deviceId } }),
 				noiseSuppression: false,
@@ -130,7 +97,6 @@ export class WebRTCClient {
 			})
 
 			this.setupAudioAnalysis()
-			console.log("Acquired media stream:", this.mediaStream)
 
 			this.mediaStream.getTracks().forEach((track) => {
 				if (this.peerConnection) {
@@ -139,7 +105,6 @@ export class WebRTCClient {
 			})
 
 			this.peerConnection.addEventListener("track", (event) => {
-				console.log("Received track event:", event)
 				this.options.onAudioStream?.(event.streams[0])
 			})
 
@@ -181,13 +146,9 @@ export class WebRTCClient {
 			}
 
 			const serverResponse = await response.json()
-			console.log("Received server answer:", serverResponse)
 			await this.peerConnection.setRemoteDescription(serverResponse)
 
 			// --- MODIFICATION: Send all queued ICE candidates now ---
-			console.log(
-				`Sending ${this.iceCandidateQueue.length} queued ICE candidates...`
-			)
 			for (const candidate of this.iceCandidateQueue) {
 				fetch(`${this.serverUrl}/voice/webrtc/offer`, {
 					method: "POST",
@@ -207,9 +168,6 @@ export class WebRTCClient {
 			}
 			this.iceCandidateQueue = [] // Clear the queue
 
-			console.log(
-				"WebRTC signaling complete. Waiting for connection to establish..."
-			)
 		} catch (error) {
 			console.error("Error connecting WebRTC:", error)
 			this.disconnect()
@@ -277,10 +235,6 @@ export class WebRTCClient {
 	}
 
 	disconnect() {
-		// --- NEW: Add a log here for clarity on manual disconnects ---
-		console.log("Disconnect called. Cleaning up WebRTC resources.")
-		// --- END NEW ---
-
 		if (this.disconnectTimer) {
 			clearTimeout(this.disconnectTimer)
 			this.disconnectTimer = null

src/client/utils/webSocketAudioClient.js

@@ -18,8 +18,6 @@ export class WebSocketClient {
 		this.analyser = null
 		this.token = null
 		this.chatId = null
-
-		console.log(`[VoiceClient] Initialized. Server URL: ${this.serverUrl}`)
 	}
 
 	async connect(deviceId, token) {
@@ -71,7 +69,6 @@ export class WebSocketClient {
 
 		try {
 			await this.audioContext.audioWorklet.addModule("/audioProcessor.js")
-			console.log("[VoiceClient] AudioWorklet module loaded.")
 		} catch (e) {
 			console.error("[VoiceClient] Failed to load AudioWorklet:", e)
 			throw new Error("Could not load audio processor.")
@@ -128,7 +125,6 @@ export class WebSocketClient {
 		if (!this.ws) return
 
 		this.ws.onopen = () => {
-			console.log("[VoiceClient] WebSocket connection opened.")
 			if (this.token) {
 				this.ws.send(
 					JSON.stringify({
@@ -173,9 +169,6 @@ export class WebSocketClient {
 		}
 
 		this.ws.onclose = (event) => {
-			console.log(
-				`[VoiceClient] WebSocket closed: Code=${event.code}, Reason: ${event.reason}`
-			)
 			this.options.onDisconnected?.()
 			this.cleanup()
 		}

src/server/main/analytics.py

@@ -1,16 +1,19 @@
 import os
 from posthog import Posthog
+import logging
 
 # It's important to use the API key directly, not the public/project key, for backend events.
 POSTHOG_KEY = os.getenv("POSTHOG_KEY") 
 POSTHOG_HOST = os.getenv("POSTHOG_HOST")
 
+logger = logging.getLogger(__name__)
+
 posthog_client = None
 if POSTHOG_KEY and POSTHOG_HOST:
     posthog_client = Posthog(project_api_key=POSTHOG_KEY, host=POSTHOG_HOST)
-    print("PostHog client initialized for backend tracking.")
+    logger.info("PostHog client initialized for backend tracking.")
 else:
-    print("PostHog API key or host not found. Backend event tracking is disabled.")
+    logger.warning("PostHog API key or host not found. Backend event tracking is disabled.")
 
 def capture_event(user_id: str, event_name: str, properties: dict = None):
     """

src/server/main/app.py

@@ -2,14 +2,15 @@
 import datetime
 from datetime import timezone
 START_TIME = time.time()
-print(f"[{datetime.datetime.now()}] [STARTUP] Main Server application script execution started.")
 
 import os
 import platform
 import logging
 logging.basicConfig(level=logging.INFO)
 import socket
 
+logger = logging.getLogger(__name__)
+
 if platform.system() == 'Windows':
     s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
     try:
@@ -19,8 +20,8 @@
         local_ip = '127.0.0.1'
     finally:
         s.close()
-        
-    logging.info(f"Detected local IP: {local_ip}")
+
+    logger.info(f"Detected local IP: {local_ip}")
 
     os.environ['WEBRTC_IP'] = local_ip
 
@@ -130,17 +131,17 @@ def initialize_tts():
 
 @asynccontextmanager
 async def lifespan(app_instance: FastAPI):
-    print(f"[{datetime.datetime.now(timezone.utc).isoformat()}] [LIFESPAN] App startup...")
+    logger.info("App startup...")
     await mongo_manager.initialize_db()
     initialize_stt()
     initialize_tts()
-    print(f"[{datetime.datetime.now(timezone.utc).isoformat()}] [LIFESPAN] App startup complete.")
+    logger.info("App startup complete.")
     yield 
-    print(f"[{datetime.datetime.now(timezone.utc).isoformat()}] [LIFESPAN] App shutdown sequence initiated...")    
+    logger.info("App shutdown sequence initiated...")
     if mongo_manager and mongo_manager.client:
         mongo_manager.client.close()
     await close_memories_pg_pool()
-    print(f"[{datetime.datetime.now(timezone.utc).isoformat()}] [LIFESPAN] App shutdown complete.")
+    logger.info("App shutdown complete.")
 
 app = FastAPI(title="Sentient Main Server", version="2.2.0", docs_url="/docs", redoc_url="/redoc", lifespan=lifespan)
 
@@ -186,7 +187,7 @@ async def health():
     }
 
 END_TIME = time.time()
-print(f"[{datetime.datetime.now()}] [APP_PY_LOADED] Main Server app.py loaded in {END_TIME - START_TIME:.2f} seconds.")
+logger.info(f"Main Server app.py loaded in {END_TIME - START_TIME:.2f} seconds.")
 
 if __name__ == "__main__":
     import uvicorn