Subversion Repositories SmartDukaan

package in.shop2020.utils;

import java.io.File;

import java.io.IOException;

import java.io.OutputStreamWriter;

import java.io.RandomAccessFile;

import java.io.UnsupportedEncodingException;

import java.net.MalformedURLException;

import java.net.URL;

import java.net.URLConnection;

import java.net.URLEncoder;

import java.text.SimpleDateFormat;

import java.util.EventObject;

import java.util.ResourceBundle;

import in.shop2020.datalogger.EventType;

import in.shop2020.datalogger.event.Event;

import org.apache.commons.lang.StringUtils;

import org.apache.log4j.Logger;

import org.json.JSONObject;

public class GAEFailedEventUploader {

	private static String filePath;

	private static File file = null;

	private static RandomAccessFile reader = null;

	private static ResourceBundle properties = ResourceBundle.getBundle(DataLogger.class.getName());

    private static String googleAppUrl = properties.getString("googleappurl");

	/**

	 * @param args

	 */

	public static void main(String[] args) {

		if(args.length!=1) {

			System.out.println("Use only one argument containing log-file path");

			System.exit(0);

		}

		Logger rootLogger = Logger.getRootLogger();

		long uploadedEventCount = 0;

		long totalEventCount = 0;

		try {

			filePath = args[0];

			file = new File(filePath);

			reader = new RandomAccessFile(file,"r");

			reader.seek(0);

			String line = null;

			while (!((line = reader.readLine()) == null)) {

				totalEventCount++;

				try {

					String[] eventTokens = line.split(", ");

					String[] logData = new String[eventTokens.length-5];

					Long time = new SimpleDateFormat("yyyy-MM-dd/hh:mm:ss.SSS").parse(eventTokens[0].substring(0,eventTokens[0].length()-4)).getTime();

					for(int tokenIndex = 5,logDataIndex=0;tokenIndex<eventTokens.length;tokenIndex++,logDataIndex++) {

						logData[logDataIndex] = eventTokens[tokenIndex];

					}

					EventType eType = EventType.valueOf(eventTokens[1]);

		            Event event = Event.createEvent(eType, eventTokens[2], Long.parseLong(eventTokens[3]), eventTokens[4], logData);

		            JSONObject logDataInJson = event.getLogDataInJson();

	                String data = URLEncoder.encode("time", "UTF-8") + "=" + URLEncoder.encode(time.toString(), "UTF-8");

	                data += "&" + URLEncoder.encode("eventType", "UTF-8") + "=" + URLEncoder.encode(eventTokens[1], "UTF-8");

	                data += "&" + URLEncoder.encode("sessionId", "UTF-8") + "=" + URLEncoder.encode(eventTokens[2], "UTF-8");

	                data += "&" + URLEncoder.encode("userId", "UTF-8") + "=" + URLEncoder.encode(eventTokens[3], "UTF-8");

	                data += "&" + URLEncoder.encode("email", "UTF-8") + "=" + URLEncoder.encode(eventTokens[4], "UTF-8");

	                if (logDataInJson != null) {

	                    data += "&" + URLEncoder.encode("jsonLogData", "UTF-8")

	                            + "=" + URLEncoder.encode(logDataInJson.toString(), "UTF-8");

	                }

	                // Send data

	                URL url = new URL("http://" + googleAppUrl + "/add-data-log");

	                URLConnection conn = url.openConnection();

	                conn.setDoOutput(true);

	                OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream());

	                wr.write(data);

	                wr.close();

	                conn.getInputStream().close();

	                uploadedEventCount++;

				} catch(Exception e) {

					rootLogger.error(e);

					continue;

				}

			}

		} catch(IOException ioEx) {

			System.exit(0);

		}

		System.out.println(uploadedEventCount + " Events uploaded out of " + totalEventCount);

	}

}