/*
*	Mäluga mängimise server
*	Autorid: Paavo Viilup, Margo Pohlak, Kaupo Toom
*   (C)2001
*	Kui kasutad koodi ilma autoreid mainimata, saad lõuga :-)
*/

import java.io.*;
import java.net.*;
import java.util.*;
import java.util.Vector;		//siin on kõik siililegi selge, kaasatakse kõik vajalikud paketid
import java.util.Date;
import java.applet.Applet;

/**
*Main-meetod loob serveri värati "ss" ning vektori "uhendused" ühenduste hoidmiseks.
*Seejärel asutakse väratit kuulama ning iga uue ühenduse korral käivitatakse lõim "MaluLoim"
*/
public class Malumang{
  public static void main(String argumendid[]) throws IOException{
	ServerSocket ss=new ServerSocket(3001);
    Vector uhendused=new Vector();
	System.out.println("Valmis yhenduste loomiseks!");
	while(true){
      Socket sc=ss.accept();
      uhendused.add(sc);
      new MaluLoim(sc, uhendused);
	}
  }
}

/**
*Siin tehakse ära põhiline töö. Alustuseks luuakse vajalikud muutujad ning vahendid.
*Siis pannakse konstruktoris vajalikud komponendid (värat ja vektor) paika.
*/
class MaluLoim extends Thread{
  Vector v;
  Socket sc;
  String nimi, rida, punkte;
  /**Muutuja tsüklitele.*/int i;
  /**Küsimuse ja vastuse asukoht vastavates baasides.*/int index;		  
  /**Kasutatakse kasutaja konto kontrollimiseks. "0" ei ole kontot, "1" konto olemas"*/int onolemas;
  /**Kasutaja punktid. Saadakse failist.*/int skoor;
  
  /**Kasutatakse juhusliku küsimuse valimiseks*/Random rand=new Random();
  /**Konstruktor, kus pannakse paika vajalikud komponendid ning käivitatakse "run" meetod*/public MaluLoim(Socket uus_sc, Vector uus_v){
    v=uus_v;
    sc=uus_sc;
    start();
  }

  public void run(){
    try{
		BufferedReader sisse=new BufferedReader(new InputStreamReader(sc.getInputStream()));  // sisenevate sümbolite lugeja
		PrintWriter vestleja=new PrintWriter(sc.getOutputStream(), true); // kasutajale sümbolite saatmime
		vestleja.println("Sisesta nimi: "); 
		nimi=sisse.readLine(); // loetakse nimi
		onolemas=0; //eeldatakse, et sellist kasutajat ei ole

		File fail=new File("."); 
		String[] failid=fail.list(); // jooksva kataloogi failidest luuakse massiiv
		LinkedList faililist=new LinkedList(); 

		for(i=0;i<failid.length;i++){
			faililist.add(failid[i]);  // kõikidest massiivi elementidest luuakse list
		}
		
		for(i=0;i<faililist.size();i++){
			if(nimi.equals(faililist.get(i))){
				onolemas=1;					// kui nimi vastab mõne kataloogi nimele, siis konto olemas
			}
		}

		faililist.clear();
			
		/*
			Kui kasutajal konto olemas, siis loetakse vastavast kataloogist failist "punktid.dat" punktid
		*/
		if(onolemas==1){
			BufferedReader failist=new BufferedReader(new FileReader(nimi+File.separator+"punktid.dat"));
			punkte=failist.readLine();
			vestleja.println("Tere "+nimi+"! Sinu konto leiti. Sul on "+punkte+" punkti.");
			failist.close();

		/*
			Kui ei ole olemas, siis tehakse sellise nimega kataloog ja sinna fail, kuhu kirjutatakse "0"
		*/
		}else{
			File kataloog=new File(nimi);
			kataloog.mkdir();
			PrintWriter punktid=new PrintWriter(new FileWriter(nimi+File.separator+"punktid.dat"));
			punktid.println("0");
			punktid.close();
			vestleja.println("Oled uus kasutaja. Sulle loodi konto.");
		}
		
		/*
			Siin luuakse küsimuste ja vastuste baasid.
		*/
		LinkedList kysimused=new LinkedList();
		LinkedList vastused=new LinkedList();
		BufferedReader kysimustefail=new BufferedReader(new FileReader("kysimused.txt"));
		BufferedReader vastustefail=new BufferedReader(new FileReader("vastused.txt"));
			
		vestleja.println("Loon kysimuste baasi.");
		rida=kysimustefail.readLine();
		while(rida!=null){						// loetakse failist rida ning lisatakse see baasi.
			kysimused.add(rida);
			rida=kysimustefail.readLine();
		}
		vestleja.println("Kysimuste baas mallu loodud.");

		vestleja.println("Loon vastuste baasi.");
		rida=vastustefail.readLine();
		while(rida!=null){						// sama asi vastustega
			vastused.add(rida);
			rida=vastustefail.readLine();
		}
		vestleja.println("Vastuste baas mallu loodud.");
		vestleja.println("Malumang alaku!");
		
		/*
			See tsükkel on kõige algus ja lõpp. Kordub seni, kuni kasutaja sisestab ".lopp"
		*/
		while(true){
						
			vestleja.println("5 sekundit järgmise küsimuseni");

			long loppaeg=new Date().getTime()+5000;  // mis ajaks on viis sekundit läbi
			long aeg=new Date().getTime();  // lihtsalt aeg
			
			
			while(loppaeg>new Date().getTime()){    // tsükkel kestab kuni loppajaga määratud aeg on käes
				if(sisse.ready()){					// kui sisse on midagi tulnud, siis
					String vastus=sisse.readLine(); // loetakse rida

					if(vastus.startsWith(".punktid")){ // kui rida on selline, siis kuvatakse kasutaja punktide arv
						BufferedReader failist=new BufferedReader(new FileReader(nimi+File.separator+"punktid.dat"));
						punkte=failist.readLine();
						failist.close();
						vestleja.println("Sul on hetkel "+punkte+" punkti.");
					}else if(vastus.startsWith(".lopp")){ // kui rida selline, siis ühendus katkestatakse
						sc.close();
						v.remove(sc);
					}
				}else{
						aeg=new Date().getTime();  // ...muidu kontrollime aega
				}
			}
			
			// Thread.sleep(5000);

			index=rand.nextInt(kysimused.size());  // valitakse küsimus
			vestleja.println("Küsimus: "+kysimused.get(index));
		
			loppaeg=new Date().getTime()+10000; // nüüd on tsükli ajaks 10 sekundit
			aeg=new Date().getTime();
			int kontroll=0;

			while (loppaeg>new Date().getTime()){
				if(sisse.ready()){
					String vastus=sisse.readLine();
				
					if(vastus.equals(vastused.get(index))){ // kui vastus on sama, mis realt loeti, siis...
						BufferedReader failist=new BufferedReader(new FileReader(nimi+File.separator+"punktid.dat"));
						punkte=failist.readLine();
						failist.close();
						skoor=Integer.parseInt(punkte);     // loetakse failist, liidetakse sellele 2 juurde ja kirjutatakse uuesti faili
						skoor=skoor+2;
						PrintWriter punktid=new PrintWriter(new FileWriter(nimi+File.separator+"punktid.dat"));
						punktid.println(skoor);
					    punktid.close();
						for(int i=0; i<v.size(); i++){ // öeldakse kõigile, et see kasutaja sai punkte
							Socket skt=(Socket)v.elementAt(i);
							PrintWriter koigile=new PrintWriter(skt.getOutputStream(), true);
							koigile.println(nimi+" vastas õigesti ja sai 2 punkti");
						}
						kontroll=1;
					
					}else if(vastus.startsWith(".punktid")){
						BufferedReader failist=new BufferedReader(new FileReader(nimi+File.separator+"punktid.dat"));
						punkte=failist.readLine();
						failist.close();
						vestleja.println("Sul on hetkel "+punkte+" punkti.");
					
					}else if(vastus.startsWith(".lopp")){
						sc.close();
						v.remove(sc);
					
					}else{
						vestleja.println("Vale vastus!");
					}
				}
				else{	
					aeg=new Date().getTime();
				}
			}
		
			if(kontroll==0){ // kui õigesti ei vastanud (kontroll on 0), siis...
				String vihje=(String)vastused.get(index); // tehakse vastusest vihje
				char esimene=vihje.charAt(0);			  	
				vestleja.println("Aeg läbi. Vihje: pikkus "+vihje.length()+", esimene täht/number "+"'"+esimene+"'"); // kuvatakse vastuse pikkus ja esimene täht
			
				loppaeg=new Date().getTime()+10000;
				aeg=new Date().getTime();
										
				while(loppaeg>new Date().getTime()){ // jälle tsükkel
					if(sisse.ready()){
						String vastus=sisse.readLine();
						
						if(vastus.equals(vastused.get(index))){
							BufferedReader failist=new BufferedReader(new FileReader(nimi+File.separator+"punktid.dat"));
							punkte=failist.readLine();
							failist.close();
							skoor=Integer.parseInt(punkte);
							skoor=skoor+1;
							PrintWriter punktid=new PrintWriter(new FileWriter(nimi+File.separator+"punktid.dat"));
							punktid.println(skoor);
							punktid.close();
								
							for(int i=0; i<v.size(); i++){
								Socket skt=(Socket)v.elementAt(i);
								PrintWriter koigile=new PrintWriter(skt.getOutputStream(), true);
								koigile.println(nimi+" vastas õigesti ja sai 1 punkti");
							}
							kontroll=1;
						
						}else if(vastus.startsWith(".punktid")){
							BufferedReader failist=new BufferedReader(new FileReader(nimi+File.separator+"punktid.dat"));
							punkte=failist.readLine();
							failist.close();
							vestleja.println("Sul on hetkel "+punkte+" punkti.");
					
						}else if(vastus.startsWith(".lopp")){
							sc.close();
							v.remove(sc);
					
						}else{					
							vestleja.println("Vale vastus!");
						}
					}
					else{	
						aeg=new Date().getTime();
					}
				}
			}
				
			if(kontroll==0){
				vestleja.println("Aeg läbi! Õige vastus: "+vastused.get(index)); // kui ka viimane tsükkel läbi, siis kuvatakse õige vastus ja minnakse ülemtsükli algusesse
			}
		}
	}catch(Exception e){}
  }
}