/**
 * 
 */
package exam.dao;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

import exam.model.Course;

/**
 * @author 董曉煒
 *
 * Feb 13, 2009 2:12:47 PM
 */
public class CourseDaoImpByWeb implements CourseDao{
	private Socket s;
	public CourseDaoImpByWeb(Socket s){
		this.s=s;
	}

	public Course[] getCourse() {
		PrintWriter pw=null;
		BufferedReader br=null;
		List<Course> courses=new ArrayList<Course>();
		Course[] cous;
		try {
			pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream(),"UTF-8"));
			pw.println("course:");
			pw.flush();
			br=new BufferedReader(new InputStreamReader(s.getInputStream(),"UTF-8"));
			String str=null;
			while((str=br.readLine())!=null){
				String[] ss=str.split("=");
				if(str.equals("isStop"))return null;
				if(str.equals(""))break;
				if(ss.length<2)continue;
				Course course=new Course(ss[0],ss[1]);
				courses.add(course);
			}
		} catch (IOException e) {
			if(s!=null)
				try {
					s.close();
				} catch (IOException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
			e.printStackTrace();
		}
		cous=new Course[courses.size()];
		return courses.toArray(cous);
	}

}