more logs

Author: georgiy.rusanov

.github/workflows/ci.yml

@@ -130,6 +130,10 @@ jobs:
           # Test WebSocket connection with proper authentication parameters
           curl -i -N -H "Connection: Upgrade" -H "Upgrade: websocket" -H "Sec-WebSocket-Version: 13" -H "Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw==" "http://127.0.0.1:54321/realtime/v1/websocket?apikey=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6ImFub24iLCJleHAiOjE5ODM4MTI5OTZ9.CRXP1A7WOeoJeXxjNni43kdQwgnWNReilDMblYTn_I0&vsn=1.0.0" || echo "WS connection failed"
 
+          echo "Testing direct WebSocket connection to realtime service (bypassing Kong)"
+          # Test direct connection to realtime service on port 4000
+          curl -i -N -H "Connection: Upgrade" -H "Upgrade: websocket" -H "Sec-WebSocket-Version: 13" -H "Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw==" "http://127.0.0.1:4000/socket/websocket?apikey=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6ImFub24iLCJleHAiOjE5ODM4MTI5OTZ9.CRXP1A7WOeoJeXxjNni43kdQwgnWNReilDMblYTn_I0&vsn=1.0.0" || echo "Direct WS connection failed"
+
           echo "Testing realtime endpoint directly"
           curl -v http://127.0.0.1:54321/realtime/v1/ || echo "Realtime endpoint failed"
 
@@ -142,6 +146,47 @@ jobs:
           echo "Testing realtime subscription endpoint"
           curl -v -X POST -H "Content-Type: application/json" -H "apikey: eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6ImFub24iLCJleHAiOjE5ODM4MTI5OTZ9.CRXP1A7WOeoJeXxjNni43kdQwgnWNReilDMblYTn_I0" -d '{"channel":"test-channel","type":"broadcast"}' http://127.0.0.1:54321/realtime/v1/api/broadcast || echo "Realtime broadcast failed"
 
+          echo "Testing direct realtime service endpoints"
+          curl -v http://127.0.0.1:4000/api/ping || echo "Direct realtime ping failed"
+          curl -v -H "apikey: eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6ImFub24iLCJleHAiOjE5ODM4MTI5OTZ9.CRXP1A7WOeoJeXxjNni43kdQwgnWNReilDMblYTn_I0" http://127.0.0.1:4000/api/ping || echo "Direct realtime ping with auth failed"
+
+          echo "Testing WebSocket connection with Node.js"
+          npm install ws || echo "Failed to install ws package"
+          node -e "
+          const WebSocket = require('ws');
+          const ws = new WebSocket('ws://127.0.0.1:54321/realtime/v1/websocket?apikey=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6ImFub24iLCJleHAiOjE5ODM4MTI5OTZ9.CRXP1A7WOeoJeXxjNni43kdQwgnWNReilDMblYTn_I0&vsn=1.0.0');
+
+          ws.on('open', () => {
+            console.log('WebSocket connection opened');
+            // Send a phx_join message
+            const joinMessage = JSON.stringify({
+              topic: 'realtime:test-channel',
+              event: 'phx_join',
+              payload: { config: { broadcast: { self: false }, presence: { key: '' }, private: false } },
+              ref: '1'
+            });
+            console.log('Sending join message:', joinMessage);
+            ws.send(joinMessage);
+          });
+
+          ws.on('message', (data) => {
+            console.log('Received message:', data.toString());
+          });
+
+          ws.on('error', (error) => {
+            console.log('WebSocket error:', error.message);
+          });
+
+          ws.on('close', (code, reason) => {
+            console.log('WebSocket closed:', code, reason.toString());
+          });
+
+          setTimeout(() => {
+            console.log('Closing WebSocket connection');
+            ws.close();
+          }, 5000);
+          " || echo "Node.js WebSocket test failed"
+
           docker ps --format '{{.Names}}'
 
           echo "docker logs"

examples/expo-app/app/index.tsx

@@ -49,6 +49,12 @@ export default function Index() {
       console.log('Channel state after status:', channel.state)
       console.log('Channel topic:', channel.topic)
 
+      // Add more detailed debugging for WebSocket state
+      if (supabase.realtime.conn) {
+        console.log('WebSocket readyState:', supabase.realtime.conn.readyState)
+        console.log('WebSocket URL:', supabase.realtime.conn.url)
+      }
+
       // Show all statuses, not just SUBSCRIBED
       setRealtimeStatus(status)
     })
@@ -61,11 +67,28 @@ export default function Index() {
       console.log('Timeout check - Channel state:', channel.state)
       console.log('Timeout check - Channel topic:', channel.topic)
 
+      // Check WebSocket connection state
+      if (supabase.realtime.conn) {
+        console.log('Timeout check - WebSocket readyState:', supabase.realtime.conn.readyState)
+        console.log('Timeout check - WebSocket URL:', supabase.realtime.conn.url)
+      }
+
+      // Check if join push was sent
+      if (channel.joinPush) {
+        console.log('Timeout check - Join push sent:', channel.joinPush.sent)
+        console.log('Timeout check - Join push ref:', channel.joinPush.ref)
+        console.log('Timeout check - Join push receivedResp:', channel.joinPush.receivedResp)
+      }
+
       // Try to manually check the connection
       try {
         console.log('Attempting to check realtime connection manually...')
         // This might help us understand what's happening
         console.log('All channels:', supabase.getChannels())
+
+        // Check connection state
+        console.log('Realtime connection state:', supabase.realtime.connectionState())
+        console.log('Realtime is connected:', supabase.realtime.isConnected())
       } catch (error) {
         console.log('Error checking channels:', error)
       }