package com.example.schedulerapp;

import java.io.*;
import java.net.*;
import java.util.ArrayList;
import java.util.Arrays;

public class ReceiveThread extends Thread {
    private BufferedReader reader;
    private Socket socket;
    private ScheduleClient client;

    public ReceiveThread(Socket socket, ScheduleClient client) {
        this.client = client;
        this.socket = socket;

        try {
            InputStream input = socket.getInputStream();
            reader = new BufferedReader(new InputStreamReader(input));
        } catch (IOException error) {
            System.out.println("Error getting input stream: " + error.getMessage());
            error.printStackTrace();
        }
    }

    public void run() {
        while(true) {
            try {
                //System.out.println("ReceiveThread.Run.Hello"); why does this run twice.
                String response = reader.readLine();
                String[] args = response.split("/");
                //System.out.println(args[0]); testing
                switch (args[0]) {
                    case "allEmployees":
                        this.client.employees = new ArrayList<String>(Arrays.asList(args));
                        break;
                    case "Shifts":
                        this.client.shifts = new ArrayList<String>(Arrays.asList(args));
                        break;
                }

            } catch (IOException error) {
                System.out.println("Error reading from server: " + error.getMessage());
                error.printStackTrace();
                break;
            }

        }
    }
}