kkudi

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;

    }


}