TicketServer.java

import com.sun.net.httpserver.HttpServer;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.Headers;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.util.List;
import java.util.Map;

public class TicketServer {
	
	 private static HttpServer server;

    public static void start() throws IOException {
    	//CHANGE SOCKET HERE!!!!
         server = HttpServer.create(new InetSocketAddress(8025), 0); 

        // Endpoint: GET /tickets
        server.createContext("/tickets", (HttpExchange exchange) -> {
            if (!"GET".equals(exchange.getRequestMethod())) {
                exchange.sendResponseHeaders(405, -1); // Method not allowed
                return;
            }

            List<Table> snapshot = TicketQueueManager.getSnapshot();
            String json = buildJson(snapshot);

            Headers headers = exchange.getResponseHeaders();
            headers.add("Content-Type", "application/json; charset=utf-8");
            headers.add("Access-Control-Allow-Origin", "*"); // so browser can call it

            byte[] bytes = json.getBytes("UTF-8");
            exchange.sendResponseHeaders(200, bytes.length);
            try (OutputStream os = exchange.getResponseBody()) {
                os.write(bytes);
            }
        });
        
        
        //Endpoint: POST /clear
        server.createContext("/clear", exchange -> {
            if (!"POST".equals(exchange.getRequestMethod())) {
                exchange.sendResponseHeaders(405, -1);
                return;
            }

            TicketQueueManager.clear();

            byte[] bytes = "OK".getBytes("UTF-8");
            exchange.getResponseHeaders().add("Access-Control-Allow-Origin", "*");
            exchange.sendResponseHeaders(200, bytes.length);
            try (OutputStream os = exchange.getResponseBody()) {
                os.write(bytes);
            }
        });
        
        //To remove a single ticket
        server.createContext("/ready", exchange -> {
            if (!"POST".equals(exchange.getRequestMethod())) {
                exchange.sendResponseHeaders(405, -1);
                return;
            }

            // Parse ?id=... from the query string
            String query = exchange.getRequestURI().getQuery(); // e.g. "id=1733969690123"
            long id = -1;
            if (query != null) {
                for (String part : query.split("&")) 
                {
                    String[] kv = part.split("=");
                    if (kv.length == 2 && kv[0].equals("id"))
                    {
                        try {
                            id = Long.parseLong(kv[1]);
                        } catch (NumberFormatException e) {
                            // ignore, will stay -1
                        }
                    }
                }
            }

            if (id != -1) {
                TicketQueueManager.removeById(id);
            }

            byte[] bytes = "OK".getBytes("UTF-8");
            exchange.getResponseHeaders().add("Access-Control-Allow-Origin", "*");
            exchange.sendResponseHeaders(200, bytes.length);
            try (OutputStream os = exchange.getResponseBody()) {
                os.write(bytes);
            }
        });
        
        //Complete...
        server.createContext("/complete", exchange -> {
            if (!"POST".equals(exchange.getRequestMethod())) {
                exchange.sendResponseHeaders(405, -1);
                return;
            }

            String query = exchange.getRequestURI().getQuery();
            long id = -1;
            if (query != null) {
                for (String part : query.split("&")) {
                    String[] kv = part.split("=");
                    if (kv.length == 2 && kv[0].equals("id")) {
                        try {
                            id = Long.parseLong(kv[1]);
                        } catch (NumberFormatException e) { }
                    }
                }
            }

            if (id != -1) {
                TicketQueueManager.removeById(id);
            }

            byte[] bytes = "OK".getBytes("UTF-8");
            exchange.getResponseHeaders().add("Access-Control-Allow-Origin", "*");
            exchange.sendResponseHeaders(200, bytes.length);
            try (OutputStream os = exchange.getResponseBody()) {
                os.write(bytes);
            }
        });

        
        
        server.setExecutor(null);
        server.start();
        System.out.println("TicketServer running at http://localhost:8025/tickets");
    }

    private static String buildJson(List<Table> tickets) {
        StringBuilder sb = new StringBuilder();
        sb.append("[");

        boolean firstTicket = true;
        for (Table t : tickets) {
            if (!firstTicket) sb.append(",");
            firstTicket = false;

            String status = t.isReady() ? "ready" : "pending";

            sb.append("{");
            sb.append("\"server\":\"").append(escape(t.ServerName)).append("\",");
            sb.append("\"table\":").append(t.tableNum).append(",");
            sb.append("\"guests\":").append(t.guestNum).append(",");
            sb.append("\"status\":\"").append(status).append("\",");
            sb.append("\"createdAt\":").append(t.getCreatedAt()).append(",");

            // seats array
            sb.append("\"seats\":[");
            boolean firstSeat = true;
            if (t.guest != null) {
                for (Map.Entry<Integer, guest> entry : t.guest.entrySet()) {
                    if (!firstSeat) sb.append(",");
                    firstSeat = false;

                    int seatNum = entry.getKey();
                    guest g = entry.getValue();

                    sb.append("{")
                      .append("\"seat\":").append(seatNum).append(",")
                      .append("\"drink\":\"").append(escape(g.getDrink())).append("\",")
                      .append("\"sandwich\":\"").append(escape(g.getSandwich())).append("\",")
                      .append("\"side\":\"").append(escape(g.getSide())).append("\"")
                      .append("}");
                }
            }
            sb.append("]"); // end seats array

            sb.append("}"); // end ticket object
        }

        sb.append("]");
        return sb.toString();
    }


    private static String escape(String s) {
        if (s == null) return "";
        return s.replace("\\", "\\\\").replace("\"", "\\\"");
    }

    public static void stop() 
    {
        if (server != null) 
        {
            server.stop(0);  // 0 = immediate stop
            System.out.println("TicketServer stopped.");
        }
    }

}