Revize 9744d223

#7767

Zprovoznění exportu do JSON. Přidáno zpracovávání binárních zazipovaných dat. Úprava struktury.

demo_mh/Deserializer/src/deserialize/ToJSON.java

@@ -1 +1 @@
 package deserialize;
 
+import java.io.BufferedInputStream;
 import java.io.BufferedWriter;
+import java.io.ByteArrayInputStream;
+import java.io.File;
+import java.io.FileInputStream;
 import java.io.FileWriter;
 import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.concurrent.atomic.AtomicInteger;
+import java.io.ObjectInputStream;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipInputStream;
 
-import org.json.simple.JSONArray;
 import org.json.simple.JSONObject;
 
-import general.Constants;
-
 public class ToJSON extends Thread {
 	
+	private File input;
+	private File output;
+	
 	private byte buffer[];
 	
-	public ToJSON(byte buffer[]) {
-		this.buffer = buffer;
+	public ToJSON(File inputFilename, File outputFilename) {
+		this.input = inputFilename;
+		this.output = outputFilename;
 	}
 	
 	@Override
 	public void run() {
 		super.run();
 		
-		List<Byte> buffer = new ArrayList<Byte>();
-		for (int i = 0; i < this.buffer.length; i++) {
-			buffer.add(this.buffer[i]);
+		buffer = readByteArray();
+		if (buffer == null) {
+			// TODO Chyba na??t?n? dat
+		} else if (deserializeClassically()) {
+			// TODO Chyba klasick? deserializace
+		} else {
+			// Univerzalni deserializer.
+			convert();
 		}
+	}
+	
+	private void convert() {
+		System.out.println("Spoustim univerzalni deserializer.");
 		
 		Grammar g = new Grammar(buffer);
-		g.start();
-
-		/*for (int i = 0; i < buffer.length; i++) {
-			if (buffer[i] == TC_CLASSDESC) {
-				// Class name
-				int nameLength = Formatter.createInt(buffer[++i], buffer[++i]);
-				String name = new String(buffer, ++i, nameLength);
-				i += nameLength - 1;
-				System.out.println(name);
-				
-				// UID
-				ByteBuffer toLong = ByteBuffer.allocate(Long.BYTES);
-				toLong.put(buffer, i + 1, 8);
-				toLong.flip();
-		        System.out.println(toLong.getLong());
-		        
-		        // implements ...
-				i += 9;
-				System.out.println(buffer[i] == SC_SERIALIZABLE);
-				
-				// Variables
-				int vCount = Formatter.createInt(buffer[++i], buffer[++i]);
-				for (int j = 0; j < vCount; j++) {
-					// Type
-					char vType = (char) (buffer[++i]);
-					// Name
-					int vNameLength = Formatter.createInt(buffer[++i], buffer[++i]);
-					String vName = new String(buffer, ++i, vNameLength);
-					i += vNameLength - 1;
-					// toString()
-					System.out.println(typeCodes.get(vType) + " " + new String(vName));
-				}
-				
-				// TODO
-				System.out.println(buffer[++i] == TC_ENDBLOCKDATA);
-			}
-		}*/
+		JSONObject results = g.process();
+		
+		save(results);
+		
+		System.out.println("JSON byl vytvoren.");
 	}
 	
-	@SuppressWarnings("unchecked")
-	private void save() {
+	private boolean deserializeClassically() {
+		try {
+			
+			// Try to deserialize classically.
+			ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(buffer));
+			@SuppressWarnings("unused")
+			Deserializer d = (Deserializer) ois.readObject();
+			System.out.println("Klasicka deserializace probehla v poradku.");
+			ois.close();
+			
+		} catch (IOException e) {
+			
+			// Stream error.
+			System.out.println("Chyba pri otevirani (uzavirani) streamu pri pokusu o klasickou deserializaci.");
+			e.printStackTrace();
+			
+		} catch (Exception e) {
+			
+			// Others: ClassNotFoundException, ClassCastException, ...
+			// Usually due to problems with classical deserialization.
+			return false;
+			
+		}
+		return true;
+	}
+	
+	private byte[] readByteArray() {
+		byte array[] = null;
+		
 		/*
-		JSONObject countryObj = new JSONObject();
-        countryObj.put("Name", "India");
-        countryObj.put("Population", new Integer(1000000));
- 
-        JSONArray listOfStates = new JSONArray();
-        listOfStates.add("Madhya Pradesh");
-        listOfStates.add("Maharastra");
-        listOfStates.add("Rajasthan");
- 
-        countryObj.put("States", listOfStates);
- 
+		 * Note.
+		 * For ZIP - the first four bytes should be one of the following combinations:
+		 *     50 4B 03 04
+		 *     50 4B 05 06 (empty archive)
+		 *     50 4B 07 08 (spanned archive)
+		 * Source: https://en.wikipedia.org/wiki/List_of_file_signatures
+		 */
+		ZipInputStream zipInputStream = null;
+		ZipEntry entry = null;
+	    try {
+	    	zipInputStream = new ZipInputStream(new FileInputStream(input));
+	    	entry = zipInputStream.getNextEntry();
+			System.out.println("Velikost ZIP dat je " + entry.getSize() + "B.");
+		} catch (Exception e) {
+			System.out.println("Soubor neni zazipovany...");
+		}
+	    
+	    try {
+	    	if (entry != null) {
+		    	array = new byte[(int) entry.getSize()];
+				zipInputStream.read(array);
+				zipInputStream.close();
+		    } else {
+		    	array = new byte[(int) input.length()];
+				BufferedInputStream bis = new BufferedInputStream(new FileInputStream(input));
+				bis.read(array);
+				bis.close();
+		    }
+	    	System.out.println("Byty ze souboru byly v poradku nacteny.");
+	    } catch (IOException e) {
+	    	System.out.println("Pri nacitani bytu doslo k chybe.");
+	    	return null;
+	    }
+	    
+	    return array;
+	}
+	
+	private void save(JSONObject obj) {
         try {
-            // Writing to a file
-            FileWriter fw = new FileWriter(Constants.JSON_FILE);
+            FileWriter fw = new FileWriter(output);
             BufferedWriter bw = new BufferedWriter(fw);
-            System.out.println("Zapisuji JSON objekt do souboru.");
-            bw.write(countryObj.toJSONString());
+            bw.write(obj.toJSONString());
             bw.flush();
             bw.close();
+            Report.info("JSON", null, "Ulo?en? souboru prob?hlo v po??dku.");
         } catch (IOException e) {
             e.printStackTrace();
+            Report.info("JSON", null, "P?i ukl?d?n? souboru nastala chyba.");
         }
-        */
 	}
 	
 }