Compare commits

..

1 Commits

Author SHA1 Message Date
693ebfefb2 pthread added 2020-10-26 20:36:57 +01:00
5 changed files with 552 additions and 1127 deletions

1
.gitignore vendored
View File

@ -1 +0,0 @@
.vscode/

413
client.c
View File

@ -8,7 +8,6 @@
#include <stdio.h> #include <stdio.h>
#include <string.h> #include <string.h>
#include <stdbool.h> #include <stdbool.h>
#include <termios.h>
#define BUF 1024 #define BUF 1024
void remN(char *s) { void remN(char *s) {
@ -31,218 +30,226 @@ bool startsWith(const char *pre, const char *str)
} }
int main (int argc, char **argv) { int main (int argc, char **argv) {
int create_socket;
char buffer[BUF];
struct sockaddr_in address;
int size;
if( argc < 3 ){ int create_socket;
printf("Usage: %s ServerAdresse Port\n", argv[0]); char buffer[BUF];
exit(EXIT_FAILURE); struct sockaddr_in address;
} int size;
if ((create_socket = socket (AF_INET, SOCK_STREAM, 0)) == -1)
{ if( argc < 3 ){
perror("Socket error"); printf("Usage: %s ServerAdresse Port\n", argv[0]);
return EXIT_FAILURE; exit(EXIT_FAILURE);
} }
memset(&address,0,sizeof(address));
address.sin_family = AF_INET; if ((create_socket = socket (AF_INET, SOCK_STREAM, 0)) == -1)
address.sin_port = htons (atoi(argv[2])); {
inet_aton (argv[1], &address.sin_addr); perror("Socket error");
if (connect ( create_socket, (struct sockaddr *) &address, sizeof (address)) == 0) return EXIT_FAILURE;
{ }
printf ("\x1b[32mConnection with server (%s) established\n\x1b[0m", inet_ntoa (address.sin_addr));
size=recv(create_socket,buffer,BUF-1, 0); memset(&address,0,sizeof(address));
if (size>0) address.sin_family = AF_INET;
{ address.sin_port = htons (atoi(argv[2]));
buffer[size]= '\0'; inet_aton (argv[1], &address.sin_addr);
printf("\x1b[36m%s\x1b[0m",buffer);
if (connect ( create_socket, (struct sockaddr *) &address, sizeof (address)) == 0)
{
printf ("Connection with server (%s) established\n", inet_ntoa (address.sin_addr));
size=recv(create_socket,buffer,BUF-1, 0);
if (size>0)
{
buffer[size]= '\0';
printf("%s",buffer);
}
}
else
{
perror("Connect error - no server available");
return EXIT_FAILURE;
}
do {
//command vom user überprüfen
char command[6] = "";
printf ("\nEnter Command: \n");
fgets (command, 6, stdin);
//je nach command wird was audgeführt
if(startsWith("send", command) == true) {
char sender[8] = "";
char empfaenger[8] = "";
char betreff[80] = "";
char nachricht[128] = "";
char bufferString[BUF] = "";
strcpy(bufferString, "");
strcat(bufferString, "send");
//User Dateneingabe und daten einlesen
printf("<Sender max. 8 Zeichen>\n");
fgets (sender, 8, stdin);
printf("<Empfänger max. 8 Zeichen>\n");
fgets (empfaenger, 8, stdin);
printf("<Betreff max. 80 Zeichen>\n");
fgets (betreff, 80, stdin);
printf("<Nachricht, beliebige Anzahl an Zeilen>\n");
fgets (nachricht, 80, stdin);
//Buffer formatieren
strcat(bufferString, ";");
strcat(bufferString, sender);
strcat(bufferString, ";");
strcat(bufferString, empfaenger);
strcat(bufferString, ";");
strcat(bufferString, betreff);
strcat(bufferString, ";");
strcat(bufferString, nachricht);
remN(bufferString);
//printf("Buffer: %s", bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
//Response vom Server (OK oder ERR) empfangen und ausgeben
char readBuffer[BUF] = "";
int valread = read(create_socket , readBuffer, 1024);
printf("\n%s\n", readBuffer);
} }
}
else
{
perror("\x1b[31mConnect error - no server available\x1b[0m");
return EXIT_FAILURE;
}
bool login = false;
do {
//command vom user überprüfen
char command[7] = "";
printf ("\n\x1b[35mEnter Command:\x1b[0m \n");
fgets (command, 7, stdin);
if (startsWith("login", command) == true && login == false) else if(startsWith("list", command) == true) {
{ char bufferString[BUF] = "list";
char username[10] = ""; char username[8] = "";
char pw[50] = ""; char p[20] = "";
char bufferString[BUF] = ""; int counter = 0;
strcpy(bufferString, "login;");
//User Dateneingabe und daten einlesen
printf("\x1b[35m<Username max. 8 Zeichen>\x1b[0m\n");
fgets (username, 10, stdin);
printf("\x1b[35m<Passwort max. 50 Zeichen>\x1b[0m\n");
//PW eingabe unsichtbar machen
struct termios term, term_orig;
tcgetattr(STDIN_FILENO, &term);
term_orig = term;
term.c_lflag &= ~ECHO;
tcsetattr(STDIN_FILENO, TCSANOW, &term);
scanf("%s", pw);
// Eingabe wieder sichtbar schalten
tcsetattr(STDIN_FILENO, TCSANOW, &term_orig);
strcat(bufferString, username); printf("<Username max. 8 Zeichen>\n");
strcat(bufferString, ";"); fgets (username, 8, stdin);
strcat(bufferString, pw); printf("<Posteingang oder Postausgang>\n");
remN(bufferString); fgets (p, 20, stdin);
send(create_socket, bufferString, strlen (bufferString), 0);
//Response vom Server (OK oder ERR) empfangen und ausgeben strcat(bufferString, ";");
char readBuffer[BUF] = ""; strcat(bufferString, username);
read(create_socket , readBuffer, 1023); strcat(bufferString, ";");
remN(readBuffer); strcat(bufferString, p);
if (strcmp("OK", readBuffer) == 0) remN(bufferString);
{ printf("%s ", bufferString);
printf("\n\x1b[32m%s\x1b[0m\n", readBuffer); send(create_socket, bufferString, strlen (bufferString), 0);
login = true;
}else if (strcmp("ERR", readBuffer) == 0 || strcmp("Client Gesperrt", readBuffer) == 0) char readBuffer[BUF] = "";
{ int valread = read(create_socket , readBuffer, 1024);
printf("\n\x1b[31m%s\x1b[0m\n", readBuffer);
char delimiter[] = ";";
char *ptr;
ptr = strtok(readBuffer, delimiter);
while(ptr != NULL) {
if(strcmp(ptr, ".") == 0) {
} }
}else if (login == false && startsWith("quit", command) == true)
{
strcpy(buffer, "quit\n");
}else if (login == false)
{
printf("\x1b[33mBitte zuerst <login> eingeben. Erst danach können sie auf das Program zugreifen!\x1b[0m\n");
}
if(login == true){
//je nach command wird was audgeführt
if(startsWith("send", command) == true) {
char sender[10] = "";
char empfaenger[10] = "";
char betreff[82] = "";
char nachricht[128] = "";
char bufferString[BUF] = "";
strcpy(bufferString, "");
strcat(bufferString, "send");
//User Dateneingabe und daten einlesen
printf("\x1b[35m<Sender max. 8 Zeichen>\x1b[0m\n");
fgets (sender, 10, stdin);
printf("\x1b[35m<Empfänger max. 8 Zeichen>\x1b[0m\n");
fgets (empfaenger, 10, stdin);
printf("\x1b[35m<Betreff max. 80 Zeichen>\x1b[0m\n");
fgets (betreff, 82, stdin);
printf("\x1b[35m<Nachricht, beliebige Anzahl an Zeilen>\x1b[0m\n");
fgets (nachricht, 82, stdin);
//Buffer formatieren
strcat(bufferString, ";");
strcat(bufferString, sender);
strcat(bufferString, ";");
strcat(bufferString, empfaenger);
strcat(bufferString, ";");
strcat(bufferString, betreff);
strcat(bufferString, ";");
strcat(bufferString, nachricht);
remN(bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
//Response vom Server (OK oder ERR) empfangen und ausgeben
char readBuffer[BUF] = "";
read(create_socket , readBuffer, 1024);
printf("\n%s\n", readBuffer);
}else if(startsWith("list", command) == true) {
char bufferString[BUF] = "list";
char username[10] = "";
char p[22] = "";
int counter = 0;
printf("\x1b[35m<Username max. 8 Zeichen>\x1b[0m\n");
fgets (username, 10, stdin);
printf("\x1b[35m<Posteingang oder Postausgang>\x1b[0m\n");
fgets (p, 22, stdin);
strcat(bufferString, ";"); else if(strcmp(ptr, "..") == 0) {
strcat(bufferString, username);
strcat(bufferString, ";");
strcat(bufferString, p);
remN(bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
char readBuffer[BUF] = "";
read(create_socket , readBuffer, 1024);
char delimiter[] = ";";
char *ptr;
ptr = strtok(readBuffer, delimiter);
while(ptr != NULL) {
if(strcmp(ptr, ".") == 0) {
}else if(strcmp(ptr, "..") == 0) {
}else if (counter == 0) {
printf("\x1b[35m<Anzahl der Nachrichten für den User: %s>\x1b[0m\n", ptr);
}else {
printf("Betreff: %s \n", ptr);
}
counter = counter + 1;
// naechsten Abschnitt erstellen
ptr = strtok(NULL, delimiter);
} }
}else if(startsWith("read", command) == true) {
char bufferString[BUF] = "read";
char username[10] = "";
char nid[82] = "";
char folder[22] = "";
printf("\x1b[35m<Username max. 8 Zeichen>\x1b[0m\n"); else if (counter == 0) {
fgets (username, 10, stdin); printf("<Anzahl der Nachrichten für den User: %s>\n", ptr);
printf("\x1b[35m<posteingang oder postausgang>\x1b[0m\n"); }
fgets (folder, 22, stdin);
printf("\x1b[35m<Nachrichten-Nummer>\x1b[0m\n");
fgets (nid, 82, stdin);
strcat(bufferString, ";"); else {
strcat(bufferString, username); printf("Betreff: %s \n", ptr);
strcat(bufferString, ";"); //printf("%.*s", 17, ptr + 5);
strcat(bufferString, folder); }
strcat(bufferString, ";");
strcat(bufferString, nid); counter = counter + 1;
remN(bufferString);
send(create_socket, bufferString, strlen (bufferString), 0); // naechsten Abschnitt erstellen
char readBuffer[BUF] = ""; ptr = strtok(NULL, delimiter);
read(create_socket , readBuffer, 1000);
printf("\n%s\n", readBuffer );
}else if(startsWith("del", command) == true) {
char username[10] = "";
char nachrichtennummer[82] = "";
char bufferString[BUF] = "del";
char p[22] = "";
printf("\x1b[35m<Username max. 8 Zeichen>\x1b[0m\n");
fgets (username, 10, stdin);
printf("\x1b[35m<Posteingang oder Postausgang>\x1b[0m\n");
fgets (p, 22, stdin);
printf("\x1b[35m<Nachrichten-Nummer>\x1b[0m\n");
fgets (nachrichtennummer, 82, stdin);
strcat(bufferString, ";");
strcat(bufferString, username);
strcat(bufferString, ";");
strcat(bufferString, p);
strcat(bufferString, ";");
strcat(bufferString, nachrichtennummer);
remN(bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
char readBuffer[BUF] = "";
read(create_socket , readBuffer, 1024);
printf("\n%s\n", readBuffer );
}else if(startsWith("quit", command) == true) {
strcpy(buffer, "quit\n");
}else {
printf("DAS IST KEIN COMMAND!!!!!");
} }
} }
}while (strcmp (buffer, "quit\n") != 0);
close (create_socket); else if(startsWith("read", command) == true) {
return EXIT_SUCCESS; char bufferString[BUF] = "read";
char username[8] = "";
char nid[80] = "";
char folder[20] = "";
printf("<Username max. 8 Zeichen>\n");
fgets (username, 8, stdin);
printf("<posteingang oder postausgang>\n");
fgets (folder, 20, stdin);
printf("<Nachrichten-Nummer>\n");
fgets (nid, 80, stdin);
strcat(bufferString, ";");
strcat(bufferString, username);
strcat(bufferString, ";");
strcat(bufferString, folder);
strcat(bufferString, ";");
strcat(bufferString, nid);
remN(bufferString);
//printf("%s ", bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
//strcpy(buffer, "");
//buffer[size]= '\0';
char readBuffer[BUF] = "";
int valread = read(create_socket , readBuffer, 1000);
printf("\n%s\n", readBuffer );
}
else if(startsWith("del", command) == true) {
//printf("\n del");
char username[8] = "";
char nachrichtennummer[80] = "";
char bufferString[BUF] = "del";
char p[20] = "";
printf("<Username max. 8 Zeichen>\n");
fgets (username, 8, stdin);
printf("<Posteingang oder Postausgang>\n");
fgets (p, 20, stdin);
printf("<Nachrichten-Nummer>\n");
fgets (nachrichtennummer, 80, stdin);
strcat(bufferString, ";");
strcat(bufferString, username);
strcat(bufferString, ";");
strcat(bufferString, p);
strcat(bufferString, ";");
strcat(bufferString, nachrichtennummer);
remN(bufferString);
//printf("%s ", bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
char readBuffer[BUF] = "";
int valread = read(create_socket , readBuffer, 1024);
printf("\n%s\n", readBuffer );
}
else if(startsWith("quit", command) == true) {
strcpy(buffer, "quit\n");
}
else {
printf("DAS IST KEIN COMMAND!!!!!");
}
}
while (strcmp (buffer, "quit\n") != 0);
close (create_socket);
return EXIT_SUCCESS;
} }

View File

@ -1,8 +1,7 @@
#Client und Server kompilieren #Client und Server kompilieren
all: server.c client.c all: server.c client.c
gcc -Wall -o server server.c -lldap -llber -lpthread gcc server.c -o server -lpthread
gcc -Wall -o client client.c -lldap -llber -lpthread gcc client.c -o client -lpthread
#Kompilierten Client und Server löschen #Kompilierten Client und Server löschen
clean: client server clean: client server
@ -10,11 +9,11 @@ clean: client server
#Nur den Client kompilieren: #Nur den Client kompilieren:
client: client.c client: client.c
gcc -Wall -o client client.c -lldap -llber -lpthread gcc client.c -o client -lpthread
#Nur den Server kompilieren: #Nur den Server kompilieren:
server: server.c server: server.c
gcc -Wall -o server server.c -lldap -llber -lpthread gcc server.c -o server -lpthread
#Kompilierten Server löschen #Kompilierten Server löschen
cleanS: server cleanS: server

View File

@ -2,43 +2,10 @@
# Protokoll 🔧 # Protokoll 🔧
``` ```
Als erstes muss der User immer der Befehl eingegeben (send, read, list oder delete). Danach schreibt der Client
immer eine Zeile, was der User als nächstes eingeben soll. Die Buffer Strings der Befehle sind folgerndermaßen
aufgebaut:
SEND: send;sender;empänger;betreff;nachricht SEND: send;sender;empänger;betreff;nachricht
LIST: list;username;postEinAusgang LIST: list:username;postEinAusgang
READ: read;username;postEinAusgang;nid READ: read;username;postEinAusgang;nid
DEL: del;username;postEinAusgang;nid DEL: del;username;postEinAusgang;nid
Der Buffer wird immer als Ganzes (wie oben beschrieben) vom Client an den Server übertragen (nicht Blockweise).
Der Client fügt die Usereingaben als String zusammen und trennt sie mit einem ";". Der Server splittet den Befehl
dann anhand des Delimiters ";" und geht jedes einzelne Attribut (z.B. username, nid) in einer Schleife durch und
führt den entsprechende Aktionen aus. Als erstes Attribut steht immer der Befehl, damit der Server sofort erkennt,
welche Aktion er ausführen soll. Die nid (Nachrichten ID) wird am Server erzeugt und setzt sich aus einem Timestamp
+ dem Betreff zusammen.
Bei send und delete sendet der Server entweder OK oder ERR zurück. Bei list, die Anzahl der Nachrichten und pro
Zeile den Betreff. Bei read wird die gesamte Nachricht (nid, Sent From/To, Betreff, Nachricht) zurückgesendet.
Am Server gibt es die Verzeichnisse Posteingang und Postausgang. Darin sind Verzeichniss mit den jeweiligen
Usernamen und darin befinden sich .txt Dateien mit den Nachrichten.
Eine Nachricht wird zb. folgerndermaßen am Server gespeichert:
ID: 2020-10-2918:05:32hallo
Sent to: if20b206
Betreff: hallo
Message: wie gehts
```
# Installation
```
sudo apt-get install ldap-utils
sudo apt-get install libldap
sudo apt-get update -y
sudo apt-get install -y libldap-dev
``` ```
# Erstellt von # Erstellt von

1221
server.c

File diff suppressed because it is too large Load Diff