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

public class UserServerThread extends Thread {

  public UserServerThread(Socket sock, Vector users) {
    this.sock = sock;
    this.users = users;
    try {
      // inicijalizuj ulazni stream
      in = new BufferedReader(
        new InputStreamReader(
          sock.getInputStream()));

      // inicijalizuj izlazni stream
      out = new PrintWriter(
        new BufferedWriter(
          new OutputStreamWriter(
            sock.getOutputStream())), true);
      // pokreni thread
      start();
    } catch (Exception ex) {
      ex.printStackTrace();
    }
  }

  public void run() {
    String response = "";
    try {
      // procitaj zahtev
      String request = in.readLine();

      // dodaj u listu
      response = clientResponse(request);

      // posalji odgovor
      out.println(response);

      // zatvori konekciju
      in.close();
      out.close();
      sock.close();
    } catch (Exception ex) {
      ex.printStackTrace();
    }
  }


  /**
   * Generisanje odgovora za klijenta
   */
  private String clientResponse(String request) {
      request=request.trim();
      String retVal = "";
      if (request.startsWith("add "))
      {
          request=request.substring(4, request.length());

          StringTokenizer strTok= new StringTokenizer(",");
          String niz[]= request.split(",");

          for(int i=0;i<niz.length;i++)
          {
              niz[i]=niz[i].trim();
              String newUser = niz[i];
              users.addElement(newUser);


          }

          retVal+="Korisnici "+ request +" su uspesno dodati.\n";
      }
    if(request.equals("list")){

        for (int i = 0; i < users.size(); i++) {
          String user = (String)users.elementAt(i);
          retVal += user + "\n";
        }

    }

    if (request.startsWith("remove ")){

        request=request.substring(7, request.length());

        for(int i=0;i<users.size();i++)
            if (users.get(i).equals(request))
            {
                users.remove(i);
                retVal += "Korisnik "+request+" je ukolonjen" + "\n";
            }


    }
if (request.startsWith("find ")){

        request=request.substring(5, request.length());
        boolean nadjen=false;
        for(int i=0;i<users.size();i++){
            if (users.get(i).equals(request)){

                nadjen=true;
                retVal=retVal+"Nadjen je: "+users.get(i)+"\n";
            }
        }
        if(!nadjen)
                retVal=retVal+"Nije nadjen: "+request+"\n";

    }



    retVal+="END";
    return retVal;
  }

  private Socket sock;
  private Vector users;
  private BufferedReader in;
  private PrintWriter out;
}