Remove unused and Playground-specific code

Author: JanJakes

packages/wp-mysql-proxy/src/mysql-server.php

@@ -658,82 +658,6 @@ public function get_buffer_size(): int {
 	}
 }
 
-class SingleUseMySQLSocketServer {
-	private $server;
-	private $socket;
-	private $port;
-
-	public function __construct( MySQLQueryHandler $query_handler, $options = array() ) {
-		$this->server = new MySQLGateway( $query_handler );
-		$this->port   = $options['port'] ?? 3306;
-	}
-
-	public function start() {
-		$this->socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
-		socket_bind( $this->socket, '0.0.0.0', $this->port );
-		socket_listen( $this->socket );
-		echo "MySQL PHP Server listening on port {$this->port}...\n";
-
-		// Accept a single client for simplicity
-		$client = socket_accept( $this->socket );
-		if ( ! $client ) {
-			exit( "Failed to accept connection\n" );
-		}
-		$this->handle_client( $client );
-		socket_close( $client );
-		socket_close( $this->socket );
-	}
-
-	private function handle_client( $client ) {
-		// Send initial handshake
-		$handshake = $this->server->get_initial_handshake();
-		socket_write( $client, $handshake );
-
-		while ( true ) {
-			// Read available data (up to 4096 bytes at a time)
-			$data = @socket_read( $client, 4096 ); // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged
-			if ( false === $data || '' === $data ) {
-				break;  // connection closed
-			}
-
-			try {
-				// Process the data
-				$response = $this->server->receive_bytes( $data );
-				if ( $response ) {
-					socket_write( $client, $response );
-				}
-
-				// If there's still data in the buffer, process it immediately
-				while ( $this->server->has_buffered_data() ) {
-					try {
-						// Try to process more complete packets from the buffer
-						$response = $this->server->receive_bytes( '' );
-						if ( $response ) {
-							socket_write( $client, $response );
-						}
-					} catch ( IncompleteInputException $e ) {
-						// Not enough data to complete another packet, wait for more
-						break;
-					}
-				}
-			} catch ( IncompleteInputException $e ) {
-				// Not enough data yet, continue reading
-				continue;
-			}
-		}
-
-		echo "Client disconnected, terminating the server.\n";
-		$this->server->reset();
-	}
-}
-
-if ( ! function_exists( 'post_message_to_js' ) ) {
-	function post_message_to_js( string $message ) {
-		echo 'The "post_message_to_js" function is only available in WordPress Playground but you are running it in a standalone PHP environment.' . PHP_EOL;
-		echo 'The message was: ' . $message . PHP_EOL;
-	}
-}
-
 class MySQLSocketServer {
 	private $query_handler;
 	private $socket;
@@ -846,120 +770,3 @@ public function start() {
 		}
 	}
 }
-
-
-class MySQLPlaygroundYieldServer {
-	private $query_handler;
-	private $clients        = array();
-	private $client_servers = array();
-	private $port;
-
-	public function __construct( MySQLQueryHandler $query_handler, $options = array() ) {
-		$this->query_handler = $query_handler;
-		$this->port          = $options['port'] ?? 3306;
-	}
-
-	public function start() {
-		echo "MySQL PHP Server listening via message passing on port {$this->port}...\n";
-
-		// Main event loop
-		while ( true ) {
-			// Wait for a message from JS
-			$message = post_message_to_js(
-				json_encode(
-					array(
-						'type' => 'ready_for_event',
-					)
-				)
-			);
-
-			$command = json_decode( $message, true );
-			var_dump( 'decoded event', $command );
-			if ( ! $command || ! isset( $command['type'] ) ) {
-				continue;
-			}
-
-			switch ( $command['type'] ) {
-				case 'new_connection':
-					$this->handle_new_connection( $command['clientId'] );
-					break;
-
-				case 'data_received':
-					$this->handle_data_received( $command['clientId'], $command['data'] );
-					break;
-
-				case 'client_disconnected':
-					$this->handle_client_disconnected( $command['clientId'] );
-					break;
-			}
-		}
-	}
-
-	private function handle_new_connection( $client_id ) {
-		echo "New client connected (ID: $client_id).\n";
-		$this->clients[]                    = $client_id;
-		$this->client_servers[ $client_id ] = new MySQLGateway( $this->query_handler );
-
-		// Send initial handshake
-		$handshake = $this->client_servers[ $client_id ]->get_initial_handshake();
-		$this->send_response( $client_id, $handshake );
-	}
-
-	private function handle_data_received( $client_id, $encoded_data ) {
-		if ( ! isset( $this->client_servers[ $client_id ] ) ) {
-			throw new IncompleteInputException( 'No client server found' );
-		}
-
-		$data = base64_decode( $encoded_data );
-
-		try {
-			// Process the data
-			$response = $this->client_servers[ $client_id ]->receive_bytes( $data );
-			if ( $response ) {
-				$this->send_response( $client_id, $response );
-			} else {
-				throw new IncompleteInputException( 'No response from client' );
-			}
-
-			// Process any buffered data
-			while ( $this->client_servers[ $client_id ]->has_buffered_data() ) {
-				try {
-					$response = $this->client_servers[ $client_id ]->receive_bytes( '' );
-					if ( $response ) {
-						$this->send_response( $client_id, $response );
-					}
-				} catch ( IncompleteInputException $e ) {
-					throw $e;
-				}
-			}
-		} catch ( IncompleteInputException $e ) {
-			// Not enough data yet, wait for mo
-			throw $e;
-		}
-	}
-
-	private function handle_client_disconnected( $client_id ) {
-		echo "Client disconnected (ID: $client_id).\n";
-		if ( isset( $this->client_servers[ $client_id ] ) ) {
-			$this->client_servers[ $client_id ]->reset();
-			unset( $this->client_servers[ $client_id ] );
-		}
-
-		$index = array_search( $client_id, $this->clients, true );
-		if ( false !== $index ) {
-			unset( $this->clients[ $index ] );
-		}
-	}
-
-	private function send_response( $client_id, $data ) {
-		var_dump( 'sending response' );
-		$response = json_encode(
-			array(
-				'type'     => 'response_from_php',
-				'clientId' => $client_id,
-				'data'     => base64_encode( $data ),
-			)
-		);
-		post_message_to_js( $response );
-	}
-}