A Java program stores EEG data with timestamp.

A Java program stores EEG data with
timestamp.

.classpath

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>
+	<classpathentry kind="lib" path="src/json.jar"/>
+	<classpathentry kind="output" path="bin"/>
+</classpath>

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>JsonReader</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+	</natures>
+</projectDescription>

.settings/org.eclipse.jdt.core.prefs

@@ -0,0 +1,11 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.source=1.8

src/JsonReader.java

@@ -0,0 +1,114 @@
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.Socket;
+import java.nio.charset.Charset;
+import java.sql.Timestamp;
+
+import org.json.JSONException;
+import org.json.JSONObject;
+
+public class JsonReader {
+	static String thinkgearHost = "127.0.0.1";
+	static int thinkgearPort = 13854;
+	static String command = "{\"enableRawOutput\": false, \"format\": \"Json\"}\n";
+	public static InputStream input;
+	public static OutputStream output;
+	public static BufferedReader reader;
+	public static boolean flag = true;
+	public static String timeStamp;
+	public static String poorSignalLevel;
+	public static String attention;
+	public static String meditation;
+	public static String delta;
+	public static String theta;
+	public static String lowAlpha;
+	public static String highAlpha;
+	public static String lowBeta;
+	public static String highBeta;
+	public static String lowGamma;
+	public static String highGamma;
+	public static String blinkStrength;
+	public static void main(String[] args) throws IOException, JSONException {
+		System.out.println("Connecting to host = " + thinkgearHost + ", port = " + thinkgearPort);
+		Socket clientSocket = new Socket(thinkgearHost, thinkgearPort);
+		input = clientSocket.getInputStream();
+		output = clientSocket.getOutputStream();
+		System.out.println("Sending command "+command);
+		write(command);
+		reader = new BufferedReader(new InputStreamReader(input, Charset.forName("UTF-8")));
+		//DosyayaEkle("timeStamp;poorSignalLevel;attention;meditation;delta;theta;lowAlpha;highAlpha;lowBeta;highBeta;lowGamma;highGamma;blinkStrength", "mindStream.csv");
+		while(true == flag) {
+			clientEvent();
+		}
+		clientSocket.close();
+	}
+	public static void write(String data) { 
+		try {
+			output.write(data.getBytes());  
+			output.flush();   
+		} catch (Exception e) { // null pointer or serial port dead
+			e.printStackTrace();
+		}
+	}
+	public static void clientEvent() throws NumberFormatException, IOException {
+		// Sample JSON data:
+		// {"eSense":{"attention":91,"meditation":41},"eegPower":{"delta":1105014,"theta":211310,"lowAlpha":7730,"highAlpha":68568,"lowBeta":12949,"highBeta":47455,"lowGamma":55770,"highGamma":28247},"poorSignalLevel":0}
+		if (reader.ready()) {
+			String jsonText = reader.readLine();
+			java.util.Date date = new java.util.Date();
+			timeStamp = ""+new Timestamp(date.getTime());
+			try {
+				String uniText = "";
+				JSONObject json = new JSONObject(jsonText);
+				if(json.has("blinkStrength")){
+					blinkStrength = json.getString("blinkStrength");
+					uniText = timeStamp+";NA;NA;NA;NA;NA;NA;NA;NA;NA;NA;NA;"+blinkStrength;
+				}
+				else{
+					poorSignalLevel = json.getString("poorSignalLevel");
+
+					JSONObject esense = json.getJSONObject("eSense");
+					if (esense != null) {
+						attention = esense.getString("attention");
+						meditation = esense.getString("meditation"); 
+					}
+
+					JSONObject eegPower = json.getJSONObject("eegPower");
+					if (eegPower != null) {
+						delta = eegPower.getString("delta");
+						theta = eegPower.getString("theta"); 
+						lowAlpha = eegPower.getString("lowAlpha");
+						highAlpha = eegPower.getString("highAlpha");  
+						lowBeta = eegPower.getString("lowBeta");
+						highBeta = eegPower.getString("highBeta");
+						lowGamma = eegPower.getString("lowGamma");
+						highGamma = eegPower.getString("highGamma");
+					}
+					uniText = timeStamp+";"+poorSignalLevel+";"+attention+";"+meditation+";"+delta+";"+theta+";"+lowAlpha+";"+highAlpha+";"+lowBeta+";"+highBeta+";"+lowGamma+";"+highGamma+";NA";
+				}
+				DosyayaEkle(uniText, "rtMindOut.csv");
+			}
+			catch (JSONException e) {
+				System.out.println("There was an error parsing the JSONObject." + e);
+			};
+		}
+	}
+	public static void DosyayaEkle(String metin, String filename){
+		try{
+			File dosya = new File("C:\\Users\\XmasX\\Desktop\\Real-time\\"+filename);
+			FileWriter yazici = new FileWriter(dosya,true);
+			BufferedWriter yaz = new BufferedWriter(yazici);
+			yaz.write(metin+"\n");
+			yaz.close();
+		}
+		catch (Exception hata){
+			hata.printStackTrace();
+		}
+	}
+}