Get rid of lighter color for pending strokes

Author: bchou9

backend/services/graphql_retry_queue.py

@@ -67,8 +67,8 @@ def add_to_retry_queue(stroke_id: str, asset_data: Dict[str, Any]) -> None:
         logger.info(f"Added stroke {stroke_id} to GraphQL retry queue")
     except redis.exceptions.RedisError as e:
         # Critical: Redis is down, log prominently
-        logger.critical(f"⚠️ REDIS DOWN: Cannot queue stroke {stroke_id} for retry: {e}")
-        logger.critical(f"⚠️ Stroke {stroke_id} will NOT be synced to blockchain unless manually recovered")
+        logger.critical(f"REDIS DOWN: Cannot queue stroke {stroke_id} for retry: {e}")
+        logger.critical(f"Stroke {stroke_id} will NOT be synced to blockchain unless manually recovered")
     except Exception as e:
         logger.error(f"Failed to add stroke {stroke_id} to retry queue: {e}")
 
@@ -191,7 +191,7 @@ def process_retry_queue(max_items: int = 50) -> Dict[str, int]:
                 }
 
                 txn_id = commit_transaction_via_graphql(prep)
-                logger.info(f"✅ RETRY SUCCESS: Stroke {stroke_id} committed to ResilientDB: {txn_id}")
+                logger.info(f"RETRY SUCCESS: Stroke {stroke_id} committed to ResilientDB: {txn_id}")
 
                 # Remove from queue on success - use deterministic JSON serialization
                 retry_item_json = json.dumps(item, sort_keys=True)
@@ -201,7 +201,7 @@ def process_retry_queue(max_items: int = 50) -> Dict[str, int]:
             except Exception as e:
                 # Increment attempts and keep in queue
                 new_attempts = increment_retry_attempts(stroke_id)
-                logger.warning(f"⚠️ RETRY FAILED (attempt {new_attempts}/{MAX_RETRY_ATTEMPTS}): Stroke {stroke_id}: {str(e)}")
+                logger.warning(f"RETRY FAILED (attempt {new_attempts}/{MAX_RETRY_ATTEMPTS}): Stroke {stroke_id}: {str(e)}")
                 stats["failed"] += 1
 
         if stats["success"] > 0 or stats["failed"] > 0:

backend/services/graphql_retry_worker.py

@@ -27,7 +27,7 @@ def _retry_worker_loop():
     # Wait a bit for Redis/MongoDB to be fully ready before starting
     time.sleep(2)
 
-    logger.info("🚀 GraphQL Retry Worker started (background thread)")
+    logger.info("GraphQL Retry Worker started (background thread)")
     logger.info(f"Configuration: RETRY_INTERVAL={RETRY_INTERVAL_SECONDS}s, BATCH_SIZE={BATCH_SIZE}")
 
     iteration = 0

backend/workers/graphql_retry_worker.py

@@ -34,7 +34,7 @@
 
 def main():
     """Main worker loop."""
-    logger.info("🚀 GraphQL Retry Worker starting...")
+    logger.info("GraphQL Retry Worker starting...")
     logger.info(f"Configuration: RETRY_INTERVAL={RETRY_INTERVAL_SECONDS}s, BATCH_SIZE={BATCH_SIZE}")
 
     iteration = 0
@@ -48,15 +48,15 @@ def main():
                 queue_size = get_queue_size()
 
                 if queue_size > 0:
-                    logger.info(f"📊 Iteration {iteration}: Processing retry queue ({queue_size} items pending)")
+                    logger.info(f"Iteration {iteration}: Processing retry queue ({queue_size} items pending)")
 
                     # Process batch
                     stats = process_retry_queue(max_items=BATCH_SIZE)
 
                     if stats['success'] > 0 or stats['failed'] > 0:
                         remaining = get_queue_size()
                         logger.info(
-                            f"✅ Batch complete: {stats['success']} synced, "
+                            f"Batch complete: {stats['success']} synced, "
                             f"{stats['failed']} failed, {stats['skipped']} skipped. "
                             f"Remaining: {remaining}"
                         )
@@ -67,16 +67,16 @@ def main():
             except KeyboardInterrupt:
                 raise  # Re-raise to exit gracefully
             except Exception as e:
-                logger.error(f"❌ Error in worker iteration {iteration}: {e}")
+                logger.error(f"Error in worker iteration {iteration}: {e}")
                 logger.exception("Full traceback:")
 
             # Wait before next iteration
             time.sleep(RETRY_INTERVAL_SECONDS)
 
     except KeyboardInterrupt:
-        logger.info("🛑 Worker stopped by user (Ctrl+C)")
+        logger.info("Worker stopped by user (Ctrl+C)")
     except Exception as e:
-        logger.error(f"💥 Worker crashed: {e}")
+        logger.error(f"Worker crashed: {e}")
         logger.exception("Full traceback:")
         sys.exit(1)
 

frontend/src/components/Canvas.js

@@ -918,8 +918,6 @@ function Canvas({
         drawingType: "stamp",
         stampData: stamp,
         stampSettings: settings,
-        isPending: true,  // Mark as pending for visual confirmation
-        opacity: 0.5,     // Reduced opacity for pending stamps
       }
     );
 
@@ -952,14 +950,7 @@ function Canvas({
           console.log("Stamp submitted successfully:", stampDrawing.drawingId);
 
           // Mark stamp as confirmed
-          stampDrawing.isPending = false;
-          stampDrawing.opacity = 1.0;
           confirmedStrokesRef.current.add(stampDrawing.drawingId);
-          
-          // Trigger a redraw to show the confirmed state
-          requestAnimationFrame(() => {
-            drawAllDrawings();
-          });
 
           if (currentRoomId) {
             checkUndoRedoAvailability(
@@ -2064,10 +2055,8 @@ function Canvas({
           }
         }
 
-        // Apply opacity for pending strokes (visual confirmation)
-        if (drawing.isPending) {
-          offscreenContext.globalAlpha *= 0.5;
-        } else if (drawing.opacity !== undefined && drawing.opacity !== 1.0) {
+        // Apply custom opacity if specified
+        if (drawing.opacity !== undefined && drawing.opacity !== 1.0) {
           offscreenContext.globalAlpha *= drawing.opacity;
         }
 
@@ -3457,8 +3446,6 @@ function Canvas({
           brushType: currentBrushType,
           brushParams: brushParams,
           drawingType: "stroke",
-          isPending: true,  // Mark as pending for visual confirmation
-          opacity: 0.5,     // Reduced opacity for pending strokes
         }
       );
       newDrawing.roomId = currentRoomId;
@@ -3497,15 +3484,8 @@ function Canvas({
               setRedoAvailable
             );
 
-            // Mark stroke as confirmed by updating it in userData
-            newDrawing.isPending = false;
-            newDrawing.opacity = 1.0;
+            // Mark stroke as confirmed
             confirmedStrokesRef.current.add(newDrawing.drawingId);
-            
-            // Trigger a redraw to show the confirmed state
-            requestAnimationFrame(() => {
-              drawAllDrawings();
-            });
 
             if (currentRoomId) {
               checkUndoRedoAvailability(
@@ -3609,8 +3589,6 @@ function Canvas({
           brushType: currentBrushType,
           brushParams: brushParams,
           drawingType: "shape",
-          isPending: true,  // Mark as pending for visual confirmation
-          opacity: 0.5,     // Reduced opacity for pending strokes
         }
       );
       newDrawing.roomId = currentRoomId;
@@ -3641,14 +3619,7 @@ function Canvas({
           );
 
           // Mark stroke as confirmed
-          newDrawing.isPending = false;
-          newDrawing.opacity = 1.0;
           confirmedStrokesRef.current.add(newDrawing.drawingId);
-          
-          // Trigger a redraw to show the confirmed state
-          requestAnimationFrame(() => {
-            drawAllDrawings();
-          });
 
           // Update undo/redo availability after shape submission
           if (currentRoomId) {