Method stream_endpoint

apps/proxy/hls_proxy/server.py:876–959

(self, channel_id: str)

    # Update methods to return data instead of Flask Response objects
    def stream_endpoint(self, channel_id: str):
        if channel_id not in self.stream_managers:
            return 'Channel not found', 404
            
        manager = self.stream_managers[channel_id]
        
        # Wait for initial buffer
        if not manager.buffer_ready.wait(Config.BUFFER_READY_TIMEOUT):
            logging.error(f"Timeout waiting for initial buffer for channel {channel_id}")
            return 'Initial buffer not ready', 503
        
        try:
            if (channel_id not in self.stream_managers) or (not self.stream_managers[channel_id].running):
                return 'Channel not found', 404
            
            manager = self.stream_managers[channel_id]
            buffer = self.stream_buffers[channel_id]
            
            # Record client activity and enable cleanup
            client_ip = request.remote_addr
            manager.enable_cleanup()
            self.client_managers[channel_id].record_activity(client_ip)
            
            # Wait for first segment with timeout
            start_time = time.time()
            while True:
                with buffer.lock:
                    available = sorted(buffer.keys())
                    if available:
                        break
                    
                if time.time() - start_time > Config.FIRST_SEGMENT_TIMEOUT:
                    logging.warning(f"Timeout waiting for first segment for channel {channel_id}")
                    return 'No segments available', 503
                    
                time.sleep(0.1)  # Short sleep to prevent CPU spinning
            
            # Rest of manifest generation code...
            with buffer.lock:
                max_seq = max(available)
                # Find the first segment after any discontinuity
                discontinuity_start = min(available)
                for seq in available:
                    if seq in manager.source_changes:
                        discontinuity_start = seq
                        break
                
                # Calculate window bounds starting from discontinuity
                if len(available) <= Config.INITIAL_SEGMENTS:
                    min_seq = discontinuity_start
                else:
                    min_seq = max(
                        discontinuity_start,
                        max_seq - Config.WINDOW_SIZE + 1
                    )
                
                # Build manifest with proper tags
                new_manifest = ['#EXTM3U']