0.1.1

fix socket leak
handle error of file not found

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>com.github.immueggpain</groupId>
 	<artifactId>simple-streaming</artifactId>
-	<version>0.1.0</version>
+	<version>0.1.1</version>
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/com/github/immueggpain/simplestreaming/Launcher.java

@@ -11,7 +11,7 @@
 		subcommands = { HelpCommand.class, StreamUpload.class, StreamServer.class, Serve.class })
 public class Launcher implements Callable<Void> {
 
-	public static final String VERSTR = "0.1.0";
+	public static final String VERSTR = "0.1.1";
 	public static final int LOCAL_PORT = 2233;
 	public static final int LOCAL_OVPN_PORT = 1194;
 	public static final int BUFLEN = 1024 * 256;

src/main/java/com/github/immueggpain/simplestreaming/StreamUpload.java

@@ -1,5 +1,6 @@
 package com.github.immueggpain.simplestreaming;
 
+import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.io.OutputStream;
 import java.io.RandomAccessFile;
@@ -20,13 +21,13 @@ public class StreamUpload implements Callable<Void> {
 
 	@Override
 	public Void call() throws Exception {
-		try {
-			Socket socket = new Socket(serverName, serverPort);
+		try (Socket socket = new Socket(serverName, serverPort)) {
 
 			OutputStream os = socket.getOutputStream();
 			byte[] buf = new byte[Launcher.BUFLEN];
 
-			RandomAccessFile file = new RandomAccessFile(filepath, "r");
+			RandomAccessFile file;
+			file = new RandomAccessFile(filepath, "r");
 			file.seek(file.length());
 
 			try {
@@ -43,9 +44,11 @@ public Void call() throws Exception {
 				e.printStackTrace();
 			}
 
-			System.out.println("close socket");
 			file.close();
-			socket.close();
+
+		} catch (FileNotFoundException e) {
+			System.out.println("File not found, please start OBS and record first!");
+			return null;
 		} catch (Exception e) {
 			e.printStackTrace();
 		}