dergeorg/twmailer_vsys
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Blocked Clients, Colored Console, Auto Dir Create

Browse Source
This commit is contained in:
Georg Reisinger
2020-10-28 15:34:51 +01:00
parent ddada8bb82
commit fe32554e3c
3 changed files with 556 additions and 327 deletions
Download Patch File Download Diff File Expand all files Collapse all files

414
server.c
View File

@@ -18,44 +18,284 @@
#include <termios.h>
#define MAXCHAR 1000
#define BUF 1024
char *verzeichnis;
bool startsWith(const char *pre, const char *str)
{
size_t lenpre = strlen(pre),
lenstr = strlen(str);
return lenstr < lenpre ? false : memcmp(pre, str, lenpre) == 0;
// Entfernt das \n und macht \0 daraus
void remN(char *s) {
char *p2 = s;
while(*s != '\0') {
if(*s != '\t' && *s != '\n') {
*p2++ = *s++;
} else {
++s;
}
}
*p2 = '\0';
}
void mstore_data(const char *filepath, const char *data)
{
FILE *fp = fopen(filepath, "ab");
if (fp != NULL)
{
fputs(data, fp);
fclose(fp);
}
//Checkt ob ein dir bereits existiert
bool dirExists(const char path[300]){
struct stat st = {0};
char cwd[300];
if (getcwd(cwd, sizeof(cwd)) != NULL) {
//printf("Current working dir: %s\n", cwd);
} else {
perror("getcwd() error");
}
strcat(cwd, path);
if (stat(cwd, &st) == 0) {
printf("\x1b[32mDir: %s exists!\x1b[0m\n", cwd);
return true;
}else
{
printf("\x1b[31mDir: %s gibt es NICHT!\x1b[0m\n", cwd);
return false;
}
}
//Erstellt ein Dir wenn nicht bereits vorhanden
void createDir(const char dir[]){
if(dirExists(dir) == false){
char cwd[300];
if (getcwd(cwd, sizeof(cwd)) != NULL) {
//printf("Current working dir: %s\n", cwd);
} else {
perror("getcwd() error");
}
strcat(cwd, dir);
if(mkdir(cwd, 0700) == -1)
{
printf("\x1b[31mFailed to create %s\x1b[0m\n", cwd);
perror("mkdir");
exit(EXIT_FAILURE);
}
else{
printf("\x1b[33mCreated directory: %s\x1b[0m\n", cwd);
}
}
}
// Die Denyfiles werden gelöscht -1 ist error
int stopDenyUser(char username[10]){
char cwd[300];
if (getcwd(cwd, sizeof(cwd)) != NULL) {
//printf("Current working dir: %s\n", cwd);
} else {
perror("getcwd() error");
}
strcat(cwd, "/");
strcat(cwd, verzeichnis);
strcat(cwd, "/deny/");
strcat(cwd, username);
DIR *d = opendir(cwd);
size_t path_len = strlen(cwd);
int r = -1;
if (d) {
struct dirent *p;
r = 0;
while (!r && (p=readdir(d))) {
int r2 = -1;
char *buf;
size_t len;
/* Skip the names "." and ".." as we don't want to recurse on them. */
if (!strcmp(p->d_name, ".") || !strcmp(p->d_name, ".."))
continue;
len = path_len + strlen(p->d_name) + 2;
buf = malloc(len);
if (buf) {
struct stat statbuf;
snprintf(buf, len, "%s/%s", cwd, p->d_name);
if (!stat(buf, &statbuf)) {
if (S_ISDIR(statbuf.st_mode))
r2 = stopDenyUser(buf);
else
r2 = unlink(buf);
}
free(buf);
}
r = r2;
}
closedir(d);
}
if (!r)
r = rmdir(cwd);
return r;
}
// Zählt wv denys ein user bereits hat
int countDenyUser(char username[10]){
char dir[50];
strcpy(dir, "/");
strcat(dir, verzeichnis);
strcat(dir, "/deny/");
strcat(dir, username);
if (dirExists(dir) == false)
{
printf("\x1b[31mDIR Exists NICHT!\x1b[0m\n");
return 0;
}else
{
int file_count = 0;
DIR * dirp;
struct dirent * entry;
char cwd[1000];
if (getcwd(cwd, sizeof(cwd)) != NULL) {
//printf("Current working dir: %s\n", cwd);
} else {
perror("getcwd() error");
}
strcat(cwd, "/");
strcat(cwd, verzeichnis);
strcat(cwd, "/deny/");
strcat(cwd, username);
dirp = opendir(cwd); /* There should be error handling after this */
while ((entry = readdir(dirp)) != NULL) {
if (entry->d_type == DT_REG) { /* If the entry is a regular file */
file_count++;
}
}
closedir(dirp);
return file_count;
}
}
// Wenn der User 3 Deny Files hat, ist er gesperrt und es kommt true zurück
bool userDenied(char username[10]){
if (countDenyUser(username) == 3)
{
printf("\x1b[31mUser: %s ist gesperrt!\x1b[0m\n", username);
return true;
}else
{
printf("\x1b[32mUser: %s ist NICHT gesperrt!\x1b[0m\n", username);
return false;
}
}
// Erstellt ein Deny User eintrag
void createDenyUser(char username[10]){
char filename[1000];
strcpy(filename, "/");
strcat(filename, verzeichnis);
strcat(filename, "/deny/");
strcat(filename, username);
createDir(filename);
FILE *fp;
// Datum besorgen
char timeStr[22];
time_t now = time(NULL);
struct tm *t = localtime(&now);
strftime(timeStr, sizeof(timeStr)-1, "%H:%M:%S", t);
char cwd[300];
if (getcwd(cwd, sizeof(cwd)) != NULL) {
//printf("Current working dir: %s\n", cwd);
} else {
perror("getcwd() error");
}
// Filename erstellen
strcpy(filename, cwd);
strcat(filename, "/");
strcat(filename, verzeichnis);
strcat(filename, "/deny/");
strcat(filename, username);
strcat(filename,"/");
strcat(filename,timeStr);
strcat(filename, ".txt");
// File erstellen
fp = fopen(filename, "w");
if(fp == NULL){
perror("fopen");
}
fprintf(fp, "DENY");
fclose(fp);
}
// True wenn der user wieder zugelassen werden darf
bool checkDeniedUser(char username[10]){
time_t now;
time(&now);
struct tm*local = localtime(&now);
int readHour = 0, readMinutes = 0, readSekundes = 0;
char cwd[1000];
if (getcwd(cwd, sizeof(cwd)) != NULL) {
//printf("Current working dir: %s\n", cwd);
} else {
perror("getcwd() error");
}
strcat(cwd, "/");
strcat(cwd, verzeichnis);
strcat(cwd, "/deny/");
strcat(cwd, username);
DIR *d;
struct dirent *dir;
d = opendir(cwd);
if (d)
{
while ((dir = readdir(d)) != NULL)
{
if(strcmp(dir->d_name, ".") != 0 && strcmp(dir->d_name, "..") != 0){
//printf("%s\n", dir->d_name);
sscanf(dir->d_name, "%2d:%2d:%2d", &readHour, &readMinutes, &readSekundes);
struct tm breakdown = {0};
breakdown.tm_sec = readSekundes;
breakdown.tm_hour = readHour;
breakdown.tm_min = readMinutes;
breakdown.tm_year = local->tm_year;
breakdown.tm_mon = local->tm_mon;
breakdown.tm_mday = local->tm_mday;
time_t result;
if ((result = mktime(&breakdown)) == (time_t)-1) {
fprintf(stderr, "Could not convert time input to time_t\n");
perror("checkDeniedUser Read time from file");
}
double diff_t;
diff_t = difftime(now, result);
printf("\x1b[34mZeitdifferenz: %f\x1b[0m\n", diff_t);
if (diff_t >= 300 || diff_t <= -300) //300 = 5min
{
return true;
}
}
}
closedir(d);
}
return false;
}
bool startsWith(const char *pre, const char *str){
size_t lenpre = strlen(pre),
lenstr = strlen(str);
return lenstr < lenpre ? false : memcmp(pre, str, lenpre) == 0;
}
void mstore_data(const char *filepath, const char *data){
FILE *fp = fopen(filepath, "ab");
if (fp != NULL)
{
fputs(data, fp);
fclose(fp);
}
}
int countFiles(char path[]) {
int file_count = 0;
DIR * dirp;
struct dirent * entry;
int file_count = 0;
DIR * dirp;
struct dirent * entry;
dirp = opendir(path); /* There should be error handling after this */
while ((entry = readdir(dirp)) != NULL) {
if (entry->d_type == DT_REG) { /* If the entry is a regular file */
file_count++;
}
}
closedir(dirp);
return file_count;
dirp = opendir(path);
while ((entry = readdir(dirp)) != NULL) {
if (entry->d_type == DT_REG) {
file_count++;
}
}
closedir(dirp);
return file_count;
}
int login_user(char username[8], char pw[50])
{
int login_user(char username[10], char pw[50]){
////////////////////////////////////////////////////////////////////////////
// LDAP config
// anonymous bind with user and pw empty
@@ -67,14 +307,10 @@ int login_user(char username[8], char pw[50])
char rawLdapUser[128];
strcpy(rawLdapUser, username);
sprintf(ldapBindUser, "uid=%s,ou=people,dc=technikum-wien,dc=at", rawLdapUser);
printf("user set to: %s\n", ldapBindUser);
// read password (bash: export ldappw=<yourPW>)
char ldapBindPassword[256];
strcpy(ldapBindPassword, pw);
printf("pw taken over from commandline: %s\n", pw);
// search settings
const char *ldapSearchBaseDomainComponent = "dc=technikum-wien,dc=at";
@@ -95,7 +331,7 @@ int login_user(char username[8], char pw[50])
fprintf(stderr, "ldap_init failed\n");
return 0;
}
printf("connected to LDAP server %s\n", ldapUri);
printf("\x1b[32mconnected to LDAP server %s\x1b[0m\n", ldapUri);
////////////////////////////////////////////////////////////////////////////
// set verison options
@@ -208,7 +444,7 @@ int login_user(char username[8], char pw[50])
return 0;
}
// https://linux.die.net/man/3/ldap_count_entries
printf("Total results: %d\n", ldap_count_entries(ldapHandle, searchResult));
printf("\x1b[34mTotal results: %d\x1b[0m\n", ldap_count_entries(ldapHandle, searchResult));
////////////////////////////////////////////////////////////////////////////
// get result of search
@@ -222,7 +458,7 @@ int login_user(char username[8], char pw[50])
/////////////////////////////////////////////////////////////////////////
// Base Information of the search result entry
// https://linux.die.net/man/3/ldap_get_dn
printf("DN: %s\n", ldap_get_dn(ldapHandle, searchResultEntry));
printf("\x1b[35mDN: %s\x1b[0m\n", ldap_get_dn(ldapHandle, searchResultEntry));
/////////////////////////////////////////////////////////////////////////
// Attributes
@@ -244,10 +480,10 @@ int login_user(char username[8], char pw[50])
{
for (int i = 0; i < ldap_count_values_len(vals); i++)
{
printf("\t%s: %s\n", searchResultEntryAttribute, vals[i]->bv_val);
printf("\t\x1b[35m%s: %s\x1b[0m\n", searchResultEntryAttribute, vals[i]->bv_val);
if(strcmp(searchResultEntryAttribute,"uid") == 0){
if(strcmp(vals[i]->bv_val,rawLdapUser) == 0){
printf("\n\nGEFUNDEN!!!!!!!!!!!!!!!!!\n\n");
printf("\n\n\x1b[32mGEFUNDEN!!!!!!!!!!!!!!!!!\x1b[0m\n\n");
// Free Memory
ldap_value_free_len(vals);
ldap_memfree(searchResultEntryAttribute);
@@ -307,6 +543,7 @@ void *threadFun(void *arg){
buffer[size] = '\0';
if (login == false)
{
// Do login
if (strncmp("login", buffer, 5) == 0)
{
@@ -315,7 +552,7 @@ void *threadFun(void *arg){
//den buffer mit dem seperator splitten
ptr = strtok(buffer, delimiter);
int counter = 0;
char username[9];
char username[10];
char pw[50];
while(ptr != NULL) {
if (counter == 1) {
@@ -329,17 +566,38 @@ void *threadFun(void *arg){
ptr = strtok(NULL, delimiter);
}
if(login_user(username, pw) == 1){
login = true;
printf("Login geschafft!!");
//OK an den client zurücksenden
char suc[] = "OK";
send(new_socket , suc , strlen(suc) , 0 );
printf("\x1b[32mUser: %s hat den Login geschafft!!\x1b[0m\n", username);
if(checkDeniedUser(username) == true){
stopDenyUser(username);
}
if(userDenied(username) == true){
//ERR an den client zurücksenden
char err[] = "Client Gesperrt";
send(new_socket , err , strlen(err) , 0 );
}else{
//OK an den client zurücksenden
char suc[] = "OK";
login = true;
send(new_socket , suc , strlen(suc) , 0 );
stopDenyUser(username);
}
}else
{
printf("Login error!!!");
//OK an den client zurücksenden
char err[] = "ERR";
send(new_socket , err , strlen(err) , 0 );
printf("\x1b[31mUser: %s hat den Login NICHT geschafft!!\x1b[0m\n", username);
if(userDenied(username) == false){
createDenyUser(username);
//ERR an den client zurücksenden
char err[] = "ERR";
send(new_socket , err , strlen(err) , 0 );
}else{
//ERR an den client zurücksenden
char err[] = "Client Gesperrt";
send(new_socket , err , strlen(err) , 0 );
if(checkDeniedUser(username) == true){
stopDenyUser(username);
}
}
}
}
@@ -355,14 +613,14 @@ void *threadFun(void *arg){
ptr = strtok(buffer, delimiter);
int counter = 0;
char sender[8] = "";
char empfaenger[8] = "";
char betreff[80] = "";
char sender[10] = "";
char empfaenger[10] = "";
char betreff[82] = "";
//timestamp als ersten teil der id erstellen
char ts[20];
char ts[22];
time_t now = time(NULL);
strftime(ts, 20, "%Y-%m-%d%H:%M:%S", localtime(&now));
strftime(ts, 22, "%Y-%m-%d%H:%M:%S", localtime(&now));
//den gesplitteten buffer schritt für schritt durchgehen
@@ -405,7 +663,7 @@ void *threadFun(void *arg){
strcat(ts, betreff);
//Pfad erstellen für den sender und file erstellen
char fb[100] = "touch ./data/postausgang/";
char fb[300] = "touch ./data/postausgang/";
strcat(fb, "/");
strcat(fb, sender);
strcat(fb, "/");
@@ -429,7 +687,7 @@ void *threadFun(void *arg){
//printf("4 %s \n", ptr);
//file content für den empfänger erstellen
char fp[100] = "./data/posteingang/";
char fp[300] = "./data/posteingang/";
char content1[1000] = "";
strcpy(content1, "ID: ");
strcat(content1, ts);
@@ -493,10 +751,10 @@ void *threadFun(void *arg){
int counter = 0;
char username[8] = "";
char nid[80] = "";
char p[20] = "";
char path[100] = "";
char username[10] = "";
char nid[82] = "";
char p[22] = "";
char path[300] = "";
while(ptr != NULL) {
@@ -548,10 +806,10 @@ void *threadFun(void *arg){
ptr = strtok(buffer, delimiter);
int counter = 0;
char username[8] = "";
char nid[80] = "";
char betreff[80] = "";
char folder[20] = "";
char username[10] = "";
char nid[82] = "";
char betreff[82] = "";
char folder[22] = "";
while(ptr != NULL) {
@@ -619,9 +877,9 @@ void *threadFun(void *arg){
ptr = strtok(buffer, delimiter);
int counter = 0;
char username[8] = "";
char p[20] = "";
char path[100] = "";
char username[10] = "";
char p[22] = "";
char path[300] = "";
while(ptr != NULL) {
@@ -702,7 +960,7 @@ void *threadFun(void *arg){
}
else if (size == 0)
{
printf("Client closed remote socket\n");
printf("\x1b[33mClient closed remote socket\x1b[0m\n");
break;
}
else
@@ -743,16 +1001,32 @@ int main (int argc, char **argv) {
addrlen = sizeof (struct sockaddr_in);
//Verzeichniss erstellen
//Verzeichnisse erstellen
verzeichnis = argv[2];
char tmpVerzeichnis[300];
strcpy(tmpVerzeichnis, "/");
strcat(tmpVerzeichnis, verzeichnis);
createDir(tmpVerzeichnis);
char denyDir[300];
strcpy(denyDir, tmpVerzeichnis);
strcat(denyDir, "/deny");
createDir(denyDir);
char postausgang[300];
char posteingang[300];
strcpy(postausgang, tmpVerzeichnis);
strcat(postausgang, "/postausgang");
strcpy(posteingang, tmpVerzeichnis);
strcat(posteingang, "/posteingang");
createDir(postausgang);
createDir(posteingang);
mkdir(argv[2], 0711);
pthread_t tid;
while (1) {
printf("Waiting for connections...\n");
printf("\x1b[34mWaiting for connections...\x1b[0m\n");
new_socket = accept ( create_socket, (struct sockaddr *) &cliaddress, &addrlen );
if (new_socket > 0)
{
printf ("Client connected from %s:%d...\n", inet_ntoa (cliaddress.sin_addr),ntohs(cliaddress.sin_port));
printf ("\x1b[32mClient connected from %s:%d...\x1b[0m\n", inet_ntoa (cliaddress.sin_addr),ntohs(cliaddress.sin_port));
}
if (pthread_create(&tid, NULL, threadFun, &new_socket) != 0)
{