intialized all multiplexer and cli target + setup base request sending and replying

Author: da-moon

Makefile

@@ -44,7 +44,7 @@ run-client: client
 	- $(CLEAR)
 	- ./bin/client ${SERVER_IP} ${SERVER_PORT}
 
-server: 
+server: clean
 	- $(CLEAR)
 	- $(MKDIR) ./bin
 	- $(RM) ./bin/server

README.md

@@ -118,7 +118,7 @@ When adding/modifying different protocols , this is the main library that needs
 
 In the following paragraphs, I will explain the workflow for adding a new protocol.
 
-1- Adding the protocol type to `MessageType` enum in `handlers.h` file . assuming you would like to use characters to define a protocol , you can find their corresponding hex value in the following [`page`](https://www.ibm.com/support/knowledgecenter/en/SSVSD8_8.4.1/com.ibm.websphere.dtx.dsgnstud.doc/references/r_design_studio_intro_Hex_Decimal_and_Symbol_Values.htm). You must define a unique hex value for request and a unique hex value for reply . I use uppercase character hex representation for reques and its lowercase for for reply
+1- Adding the protocol type to `MessageType` enum in `handlers.h` file . assuming you would like to use characters to define a protocol , you can find their corresponding hex value in the following [`page`](https://www.ibm.com/support/knowledgecenter/en/SSVSD8_8.4.1/com.ibm.websphere.dtx.dsgnstud.doc/references/r_design_studio_intro_Hex_Decimal_and_Symbol_Values.htm). You must define a unique hex value for request and a unique hex value for reply . I use uppercase character hex representation for request and its lowercase for for reply
 2- define prototype for client and server methods in `handlers.h` file. as a general rule, you must define the prototypes with the following signature :
 
 - `{PROTOCOL NAME}HandleServerReply(int socket)` : this method is invoked on the client side . It is supposed to read the server reply and have the client binary perform the unique action it is supposed to perform on based on what was recieved from server.

bin/client

@@ -105,13 +105,30 @@ void Loop(int socket) {
               printf("Your choice is Echo Protocol\n");
               EchoProtocolSendRequestToServer(socket);
             }
-            // Echo-----------------------------------------------------------------------------------------
+            // Download-----------------------------------------------------------------------------------------
             if (!bcmp(choice, "2", 1)) {
               printf("Your choice is Download Protocol\n");
               DownloadProtocolSendRequestToServer(socket);
             }
+            // Upload-----------------------------------------------------------------------------------------
+            if (!bcmp(choice, "3", 1)) {
+              printf("Your choice is Upload Protocol\n");
+              UploadProtocolSendRequestToServer(socket);
+            }
+            // Change
+            // Directory-----------------------------------------------------------------------------------------
+
+            if (!bcmp(choice, "4", 1)) {
+              printf("Your choice is ChangeDirectory Protocol\n");
+              ChangeDirectoryProtocolSendRequestToServer(socket);
+            }
+            // List
+            // Directory-----------------------------------------------------------------------------------------
+            if (!bcmp(choice, "5", 1)) {
+              printf("Your choice is List Directory Protocol\n");
+              ListDirectoryProtocolSendRequestToServer(socket);
+            }
           }
-          printf("MSG WAS SENT SUCCEFULLY\n");
         }
         continue;
       }

pkg/client/client.c

@@ -12,7 +12,8 @@ void ChangeDirectoryProtocolSendRequestToServer(int socket) {
   if (send(socket, request, strlen(arr_ptr) + PROTOCOL_HEADER_LEN, 0) == -1)
     perror("write failed: ");
   fprintf(stderr,
-          "[DEBUG] client : sending download reques for file %s to server\n",
+          "[DEBUG] client : sending change directory request for file %s to "
+          "server\n",
           message.body);
 }
 void ChangeDirectoryProtocolServerHandler(int socket, Message message) {
@@ -22,5 +23,6 @@ void ChangeDirectoryProtocolServerHandler(int socket, Message message) {
   int mesg_length = MarshallMessage(reply, 0xC0DE, message.protocol, arr_ptr);
   if (send(socket, reply, strlen(arr_ptr) + PROTOCOL_HEADER_LEN, 0) == -1)
     perror("write failed: ");
-  fprintf(stderr, "[DEBUG] Echo Handler Server : Replying bac .... \n");
+  fprintf(stderr,
+          "[DEBUG] Change Directory Handler Server : Replying back .... \n");
 }

pkg/handlers/change_directory.c

@@ -14,7 +14,7 @@ void DownloadProtocolSendRequestToServer(int socket) {
   if (send(socket, request, strlen(arr_ptr) + PROTOCOL_HEADER_LEN, 0) == -1)
     perror("write failed: ");
   fprintf(stderr,
-          "[DEBUG] client : sending download reques for file %s to server\n",
+          "[DEBUG] client : sending download request for file %s to server\n",
           message.body);
 }
 void DownloadProtocolServerHandler(int socket, Message message) {
@@ -25,5 +25,5 @@ void DownloadProtocolServerHandler(int socket, Message message) {
   int mesg_length = MarshallMessage(reply, 0xC0DE, FILE_REPLY, arr_ptr);
   if (send(socket, reply, strlen(arr_ptr) + PROTOCOL_HEADER_LEN, 0) == -1)
     perror("write failed: ");
-  fprintf(stderr, "[DEBUG] Echo Handler Server : Replying bac .... \n");
+  fprintf(stderr, "[DEBUG] Download Handler Server : Replying back .... \n");
 }

pkg/handlers/download.c

@@ -21,5 +21,5 @@ void EchoProtocolServerHandler(int socket, Message message) {
   int mesg_length = MarshallMessage(reply, 0xC0DE, ECHO_REPLY, arr_ptr);
   if (send(socket, reply, strlen(arr_ptr) + PROTOCOL_HEADER_LEN, 0) == -1)
     perror("write failed: ");
-  fprintf(stderr, "[DEBUG] Echo Handler Server : Replying bac .... \n");
+  fprintf(stderr, "[DEBUG] Echo Handler Server : Replying back .... \n");
 }

pkg/handlers/echo.c

@@ -24,11 +24,31 @@ void *ServerRequestHandler(void *arg) {
           }
           break;
         }
+        case DOWNLOAD_REQUEST: {
+          printf("[DEBUG] Server Recieved Download Request\n");
+          //   DownloadProtocolServerHandler(socket, message);
+          break;
+        }
+        case UPLOAD_REQUEST: {
+          printf("[DEBUG] Server Recieved Upload Request\n");
+          //   UploadProtocolServerHandler(socket, message);
+          break;
+        }
+        case CHANGE_DIR_REQUEST: {
+          printf("[DEBUG] Server Recieved Change Directory Request\n");
+          //   ChangeDirectoryProtocolServerHandler(socket, message);
+          break;
+        }
+        case LIST_DIR_REQUEST: {
+          printf("[DEBUG] Server Recieved List Directory Request\n");
+          //   ListDirectoryProtocolServerHandler(socket, message);
+          break;
+        }
         default: {
           break;
         }
         }
       }
     }
   }
-}
+}

pkg/handlers/handlers.c

@@ -38,9 +38,11 @@ typedef enum {
   // 'P' in hex
   CHANGE_DIR_REQUEST = 0x0050,
   // 'L' in hex
-  LIST_DIR_REQUEST = 0x0050,
+  LIST_DIR_REQUEST = 0x004C,
   // 'l' in hex
   LIST_DIR_REPLY = 0x006C,
+  //   'E' in hex
+  ERROR_MESSAGE = 0x0045,
   UNKNOWN_TYPE = 0xFFFF
 } MessageType;
 // RequestHandler - this is the main method

pkg/handlers/handlers.h

@@ -1,4 +1,8 @@
 #include "handlers.h"
+
+#include <dirent.h>
+#include <stdint.h>
+
 void ListDirectoryProtocolSendRequestToServer(int socket) {
   printf("Enter Directory name For server list\n");
   char input[MAX_BUFFER];
@@ -11,17 +15,50 @@ void ListDirectoryProtocolSendRequestToServer(int socket) {
 
   if (send(socket, request, strlen(arr_ptr) + PROTOCOL_HEADER_LEN, 0) == -1)
     perror("write failed: ");
-  fprintf(stderr,
-          "[DEBUG] client : sending download reques for file %s to server\n",
-          message.body);
+  fprintf(
+      stderr,
+      "[DEBUG] client : sending list directory request for file %s to server\n",
+      message.body);
 }
 void ListDirectoryProtocolServerHandler(int socket, Message message) {
-  char *arr_ptr = &message.body[0];
+
+  //  dir (pointer) -  used for keeping track of the current directory name.
+  DIR *dir;
+  char payload[MAX_BUFFER];
+  uint16_t protocol;
+  // If the directory exists.
+  if ((dir = opendir(message.body)) != NULL) {
+    struct dirent *ent;
+    protocol = LIST_DIR_REPLY;
+    /* Prepearing the File pointer for use in the while loop.
+    Pointer needed for file access and output. */
+    FILE *fp;
+
+    // While we are in a directory and there are other directories present.
+    while ((ent = readdir(dir)) != NULL) {
+      // Prints all of the data to the console.
+      printf("[DEBUG] '%s\n", ent->d_name);
+      fprintf(payload, "%s\n", ent->d_name);
+    }
+    // Closes file ponter & directory pointer, free's the data and shows where
+    // the log was saved to.
+    closedir(dir);
+  }
+  // If the directory does not exist.
+  else if (dir == NULL) {
+    fprintf(payload,
+            "You either typed the path incorrectly or the directory does not "
+            "existn");
+
+    closedir(dir);
+  }
+  char *arr_ptr = &payload[0];
   int payload_length = strlen(arr_ptr);
 
   char *reply = malloc(strlen(arr_ptr) + PROTOCOL_HEADER_LEN);
-  int mesg_length = MarshallMessage(reply, 0xC0DE, message.protocol, arr_ptr);
+  int mesg_length = MarshallMessage(reply, 0xC0DE, protocol, arr_ptr);
   if (send(socket, reply, strlen(arr_ptr) + PROTOCOL_HEADER_LEN, 0) == -1)
     perror("write failed: ");
-  fprintf(stderr, "[DEBUG] Echo Handler Server : Replying bac .... \n");
+  fprintf(stderr,
+          "[DEBUG] List Directory Handler Server : Replying kbac .... \n");
 }