From e62a549a92ca93697ffee5990d76eb545b7cf619 Mon Sep 17 00:00:00 2001
From: Dane MacFadden <danem1000@hotmail.com>
Date: Sat, 9 Aug 2025 16:50:44 -0600
Subject: [PATCH] readd input thread

---
 main.c | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/main.c b/main.c
index a3f971c..c2b4347 100644
--- a/main.c
+++ b/main.c
@@ -31,19 +31,19 @@ int row, col;
 char s[INET6_ADDRSTRLEN];
 char closed[] = "Connection closed.";
 
-/*
 void *input(void *arg) {
   char msg[128];
   while (1) {
+    pthread_mutex_unlock(&sendmut);
     memset(msg, 0, 128);
-    printf("Typpe a message: ");
-    fgets(msg, sizeof(msg), stdin);
-    pthread_mutex_lock(&sendmut);
+    mvprintw(row - 1, 0, "Type a message: ");
+    getstr(msg);
     ListAppend(sendlist, msg);
     pthread_mutex_unlock(&sendmut);
   }	
 	return 0;
 }
+/*
 void *output(void *arg) {
   char msg[128];
   while (1) {
@@ -61,16 +61,15 @@ void *output(void *arg) {
   return 0;
 }
 */
-
 void *sender(void *arg) {
   char msg[128];
   int bytes;
   char error[] = "pthread sender exit";
   
   while (1) {
-    memset(msg, 0, 128);
-    mvprintw(row - 1, 0, "Type a message: ");
-    getstr(msg); 
+    pthread_mutex_unlock(&sendmut);
+    ListFirst(sendlist);
+    strcpy(msg, (char*)ListCurr(sendlist)); 
     bytes = send(confd, msg, sizeof(msg), 0);
     move(0, 0);
     deleteln();
@@ -82,12 +81,14 @@ void *sender(void *arg) {
     refresh();
     if ((strncmp(msg, "/c", 2)) == 0) {
       pthread_cancel(receive_thread);
+      pthread_cancel(input_thread);
       pthread_exit(&closed);
     }
     if (bytes == -1) {
       perror("send");
       pthread_exit(&error);
     }
+    pthread_mutex_unlock(&sendmut);
   }
   return 0;	
 }
@@ -266,6 +267,7 @@ int main(int argc, char* argv[]) {
   getmaxyx(stdscr, row, col);
 	keypad(stdscr, TRUE);
  
+  pthread_create(&input_thread, NULL, input, NULL);
   pthread_create(&send_thread, NULL, sender, NULL);
 	pthread_create(&receive_thread, NULL, receiver,  NULL);