package uk.ac.ic.doc.markitanis.learning;

import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

import org.apache.commons.codec.binary.Base64;

import android.util.Log;

public class HttpFileUploader {

	private URL connectURL;
	
	private String responseString;
	
	private String fileName;

	private FileInputStream fileInputStream = null;
	
	private final String lineEnd = "\r\n";

	private final String twoHyphens = "--";

	private final String boundary = "*****";

	private String parameters;
	
	private final String TAG = Constants.HTTP_FILE_UPLOADER;

	public HttpFileUploader(String urlString, String fileName, String parameters) throws MalformedURLException{

			connectURL = new URL(urlString);

			this.fileName = fileName;
			
			this.parameters = parameters;

	}


	public boolean doStart(FileInputStream stream){ 
		
		fileInputStream = stream;

		return upload();
	} 

	
	private boolean upload(){

		boolean success = false;
		
		try
		{
			//------------------ CLIENT REQUEST
			Log.i(TAG, "About to upload database...");
			
			// Open a HTTP connection to the URL
			HttpURLConnection conn = (HttpURLConnection) connectURL.openConnection();
			
			// Allow Inputs
			conn.setDoInput(true);

			// Allow Outputs
			conn.setDoOutput(true);

			// Don't use a cached copy.
			conn.setUseCaches(false);

			// Use a post method.
			conn.setRequestMethod("POST");

			conn.setRequestProperty("Connection", "Keep-Alive");

			conn.setRequestProperty("Content-Type", "multipart/form-data;boundary="+boundary);
			
			  // stuff the Authorization request header
		    byte[] encodedPassword = ( "************" + ":" + "***********" ).getBytes();
		    
		    String encoded = new String(Base64.encodeBase64(encodedPassword));

		    conn.setRequestProperty( "Authorization", "Basic " + encoded);

			DataOutputStream dos = new DataOutputStream( conn.getOutputStream() );

			dos.writeBytes(twoHyphens + boundary + lineEnd);

			dos.writeBytes("Content-Disposition: form-data; name=\"uploadedfile\";filename=\"" + this.fileName+"\"" + lineEnd);
			
			//TODO:
			//dos.writeBytes(this.parameters);
			
			dos.writeBytes(lineEnd);	
			
			Log.i(TAG ,"Headers have been written");

			// create a buffer of maximum size
			int bytesAvailable = fileInputStream.available();

			int maxBufferSize = 1024;
			
			int bufferSize = Math.min(bytesAvailable, maxBufferSize);
			
			byte[] buffer = new byte[bufferSize];

			// read file and write it into form...
			int bytesRead = fileInputStream.read(buffer, 0, bufferSize);

			while (bytesRead > 0)
			{
				dos.write(buffer, 0, bufferSize);

				bytesAvailable = fileInputStream.available();
				
				bufferSize = Math.min(bytesAvailable, maxBufferSize);
				
				bytesRead = fileInputStream.read(buffer, 0, bufferSize);
			}

			// send multipart form data necesssary after file data...
			dos.writeBytes(lineEnd);

			dos.writeBytes(twoHyphens + boundary + twoHyphens + lineEnd);

			// close streams
			
			Log.i(TAG ,"Database file with name " + this.fileName + " has been successfully written");
			
			fileInputStream.close();
			
			dos.flush();

			InputStream is = conn.getInputStream();
			
			// retrieve the response from server
			
			int ch;

			StringBuffer b = new StringBuffer();
			
			while( ( ch = is.read() ) != -1 ){
				b.append( (char)ch );
			}
			
			this.responseString = b.toString();
		
			if (responseString.equals("success")) {
				
				success = true;
				
			}else if (responseString.equals("error")) {
				success = false;
			}
			
			Log.i(TAG, "Response String from server:"+responseString);
			
			dos.close();

		}
		catch (MalformedURLException ex)
		{
			Log.e(TAG , "error: " + ex.getMessage());
			
		}

		catch (IOException ioe)
		{
			Log.e(TAG , "error: " + ioe.getMessage());
			
		}
		
		return success;
	}

	
	public String getResponse() {
		
		return this.responseString;
	
	}


}