From 3ba1c8a9f0ade8fff87ad79e20b540c74412bf5a Mon Sep 17 00:00:00 2001 From: Brett Laptop Date: Sat, 11 Nov 2023 22:52:33 -0500 Subject: [PATCH] files --- ihaveafile.txt | 1 + out-ihaveafile.txt | 0 src/client/Client.java | 50 +++++++++++++++++++++++++++++++++++++- src/server/Connection.java | 26 ++++++++++++++------ src/server/Server.java | 2 +- src/shared/FileHeader.java | 29 ++++++++++++++++------ 6 files changed, 90 insertions(+), 18 deletions(-) create mode 100644 ihaveafile.txt create mode 100644 out-ihaveafile.txt diff --git a/ihaveafile.txt b/ihaveafile.txt new file mode 100644 index 0000000..08a24f2 --- /dev/null +++ b/ihaveafile.txt @@ -0,0 +1 @@ +this is a test file which i can check for errors with diff --git a/out-ihaveafile.txt b/out-ihaveafile.txt new file mode 100644 index 0000000..e69de29 diff --git a/src/client/Client.java b/src/client/Client.java index 63e32b0..dc9b43b 100644 --- a/src/client/Client.java +++ b/src/client/Client.java @@ -1,11 +1,59 @@ package client; +import server.Server; +import shared.FileHeader; + +import java.io.*; +import java.net.Socket; + public class Client { - public static void main(String[] args) { + public static class ClientInvalidUsageException extends RuntimeException { + public ClientInvalidUsageException(String str){ + super(str); + } + } + private final Socket serverConnection; + private final DataOutputStream out; + private final DataInputStream in; + public Client(String address, int port) throws IOException { + serverConnection = new Socket(address, port); + out = new DataOutputStream(new BufferedOutputStream(serverConnection.getOutputStream())); + in = new DataInputStream(new BufferedInputStream(serverConnection.getInputStream())); + } + + void sendFile(String path){ + if (new File(path).isDirectory()) + throw new ClientInvalidUsageException("Unable to send directory. Did you mean sendDir()?"); + System.out.println("Sending path " + path); + new FileHeader(path).write(out); + try { + out.flush(); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + + void sendDir(String path){ } + void close(){ + try { + in.close(); + out.close(); + serverConnection.close(); + } catch (Exception ignored){} + } + + public static void main(String[] args) { + try { + new Client("localhost", Server.SERVER_PORT).sendFile("ihaveafile.txt"); + } catch (Exception e){ + e.printStackTrace(); + } + } + } diff --git a/src/server/Connection.java b/src/server/Connection.java index 08cc3e0..ff09b13 100644 --- a/src/server/Connection.java +++ b/src/server/Connection.java @@ -1,24 +1,23 @@ package server; -import java.io.BufferedReader; -import java.io.BufferedWriter; -import java.io.InputStreamReader; -import java.io.OutputStreamWriter; +import shared.FileHeader; + +import java.io.*; import java.net.Socket; public class Connection extends Thread { private final Socket clientSocket; private final Server server; - private BufferedWriter out; - private BufferedReader in; + private DataOutputStream out; + private DataInputStream in; public Connection(Server server, Socket clientSocket) { this.server = server; this.clientSocket = clientSocket; try { - out = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream())); - in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); + out = new DataOutputStream(new BufferedOutputStream(clientSocket.getOutputStream())); + in = new DataInputStream(new BufferedInputStream(clientSocket.getInputStream())); } catch (Exception ignored) { } } @@ -26,7 +25,18 @@ public class Connection extends Thread { @Override public void run() { while (server.isRunning()) { + if (!clientSocket.isConnected()) + break; + try { + if (in.available() > 0) { + byte command = in.readByte(); + if (command == FileHeader.COMMAND.WRITE.type) + FileHeader.receive(in); + } + } catch (IOException e) { + throw new RuntimeException(e); + } } try { out.close(); diff --git a/src/server/Server.java b/src/server/Server.java index 38e5752..6ea1781 100644 --- a/src/server/Server.java +++ b/src/server/Server.java @@ -25,7 +25,7 @@ public class Server { } public boolean isRunning(){ - return isRunning(); + return running; } public static void main(String[] args) { diff --git a/src/shared/FileHeader.java b/src/shared/FileHeader.java index e7e639c..78bd81e 100644 --- a/src/shared/FileHeader.java +++ b/src/shared/FileHeader.java @@ -1,5 +1,7 @@ package shared; +import client.Client; + import java.io.*; public class FileHeader { @@ -8,9 +10,9 @@ public class FileHeader { public enum COMMAND { WRITE((byte) 1); - private final byte type; + public final byte type; - private COMMAND(byte type) { + COMMAND(byte type) { this.type = type; } } @@ -19,18 +21,22 @@ public class FileHeader { private final String full_path; public FileHeader(String path) { + File pf = new File(path); + if (!pf.exists()) + throw new Client.ClientInvalidUsageException("Unable to send a file which doesn't exist!"); + if (pf.isDirectory()) + throw new Client.ClientInvalidUsageException("Path is a directory unable to send!"); String workingDirectory = System.getProperty("user.dir"); this.full_path = path; this.relative_path = path.replace(workingDirectory, ""); System.out.println(relative_path); - this.size = 0; } - void write(DataOutputStream writer) { + public void write(DataOutputStream writer) { try { DataInputStream reader = new DataInputStream(new BufferedInputStream(new FileInputStream(full_path))); - writer.write(COMMAND.WRITE.type); + writer.writeByte(COMMAND.WRITE.type); writer.writeUTF(relative_path); while (reader.available() > 0) { @@ -38,18 +44,25 @@ public class FileHeader { byte[] bytes = new byte[read]; int amount = reader.read(bytes); + if (amount <= 0) + break; + System.out.println("Writing " + amount + " bytes"); writer.writeInt(amount); writer.write(bytes, 0, amount); } + reader.close(); writer.writeInt(0); + writer.flush(); } catch (Exception ignored) { } } - void receive(DataInputStream reader) { + public static void receive(DataInputStream reader) { try { - String relative = reader.readUTF(); - DataOutputStream writer = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(relative))); + String path = System.getProperty("user.dir") + "/out-" + reader.readUTF(); + System.out.println("Writing to file: " + path); + + DataOutputStream writer = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(path))); int size = 0; while ((size = reader.readInt()) > 0){ byte[] data = new byte[size];