2 Commits
1.1.1 ... 3.0.0

6 changed files with 1129 additions and 582 deletions

BIN
client

Binary file not shown.

419
client.c
View File

@ -8,6 +8,7 @@
#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) {
@ -30,226 +31,218 @@ 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;
int create_socket; if( argc < 3 ){
char buffer[BUF]; printf("Usage: %s ServerAdresse Port\n", argv[0]);
struct sockaddr_in address; exit(EXIT_FAILURE);
int size; }
if ((create_socket = socket (AF_INET, SOCK_STREAM, 0)) == -1)
if( argc < 3 ){ {
printf("Usage: %s ServerAdresse Port\n", argv[0]); perror("Socket error");
exit(EXIT_FAILURE); return EXIT_FAILURE;
} }
memset(&address,0,sizeof(address));
if ((create_socket = socket (AF_INET, SOCK_STREAM, 0)) == -1) address.sin_family = AF_INET;
{ address.sin_port = htons (atoi(argv[2]));
perror("Socket error"); inet_aton (argv[1], &address.sin_addr);
return EXIT_FAILURE; if (connect ( create_socket, (struct sockaddr *) &address, sizeof (address)) == 0)
} {
printf ("\x1b[32mConnection with server (%s) established\n\x1b[0m", inet_ntoa (address.sin_addr));
memset(&address,0,sizeof(address)); size=recv(create_socket,buffer,BUF-1, 0);
address.sin_family = AF_INET; if (size>0)
address.sin_port = htons (atoi(argv[2])); {
inet_aton (argv[1], &address.sin_addr); buffer[size]= '\0';
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);
else if(startsWith("list", command) == true) { if (startsWith("login", command) == true && login == false)
char bufferString[BUF] = "list"; {
char username[8] = ""; char username[10] = "";
char p[20] = ""; char pw[50] = "";
int counter = 0; char bufferString[BUF] = "";
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);
printf("<Username max. 8 Zeichen>\n"); strcat(bufferString, username);
fgets (username, 8, stdin); strcat(bufferString, ";");
printf("<Posteingang oder Postausgang>\n"); strcat(bufferString, pw);
fgets (p, 20, stdin); remN(bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
strcat(bufferString, ";"); //Response vom Server (OK oder ERR) empfangen und ausgeben
strcat(bufferString, username); char readBuffer[BUF] = "";
strcat(bufferString, ";"); read(create_socket , readBuffer, 1023);
strcat(bufferString, p); remN(readBuffer);
remN(bufferString); if (strcmp("OK", readBuffer) == 0)
printf("%s ", bufferString); {
send(create_socket, bufferString, strlen (bufferString), 0); printf("\n\x1b[32m%s\x1b[0m\n", readBuffer);
login = true;
char readBuffer[BUF] = ""; }else if (strcmp("ERR", readBuffer) == 0 || strcmp("Client Gesperrt", readBuffer) == 0)
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)
else if(strcmp(ptr, "..") == 0) { {
}
else if (counter == 0) {
printf("<Anzahl der Nachrichten für den User: %s>\n", ptr);
}
else {
printf("Betreff: %s \n", ptr);
//printf("%.*s", 17, ptr + 5);
}
counter = counter + 1;
// naechsten Abschnitt erstellen
ptr = strtok(NULL, delimiter);
}
}
else if(startsWith("read", command) == true) {
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"); 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);
else { strcat(bufferString, ";");
printf("DAS IST KEIN COMMAND!!!!!"); 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");
fgets (username, 10, stdin);
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, ";");
strcat(bufferString, username);
strcat(bufferString, ";");
strcat(bufferString, folder);
strcat(bufferString, ";");
strcat(bufferString, nid);
remN(bufferString);
send(create_socket, bufferString, strlen (bufferString), 0);
char readBuffer[BUF] = "";
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);
return EXIT_SUCCESS;
}
while (strcmp (buffer, "quit\n") != 0);
close (create_socket);
return EXIT_SUCCESS;
} }

View File

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

View File

@ -8,6 +8,12 @@ READ: read;username;postEinAusgang;nid
DEL: del;username;postEinAusgang;nid DEL: del;username;postEinAusgang;nid
``` ```
# Installation
```
sudo apt-install ldap-utils
sudo apt-get install libldap
```
# Erstellt von # Erstellt von
* Lukas Nowy * Lukas Nowy

BIN
server

Binary file not shown.

1277
server.c

File diff suppressed because it is too large Load Diff