flashii/glovechat
Archived
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

removed client placeholders because kuroukou corocorocodile

Browse source
This commit is contained in:
malloc 2019-02-06 10:42:35 -06:00
parent 8e80275652
commit b9caa18137
16 changed files with 5 additions and 539 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
CMakeLists.txt
View file

@ -2,17 +2,17 @@ cmake_minimum_required(VERSION 3.7)
set(CMAKE_C_STANDARD 99) set(CMAKE_C_STANDARD 99)
project(glovechat C) project(glovechat C)
file(GLOB_RECURSE server_src file(GLOB_RECURSE glv_src
"src/server/*.h" "src/*.h"
"src/server/*.c" "src/*.c"
) )
find_package(OpenSSL) find_package(OpenSSL)
add_executable(server ${server_src}) add_executable(server ${glv_src})
target_include_directories(server target_include_directories(server
PRIVATE ${OPENSSL_INCLUDE_DIR} PRIVATE ${OPENSSL_INCLUDE_DIR}
PRIVATE ${PROJECT_SOURCE_DIR}/src/server) PRIVATE ${PROJECT_SOURCE_DIR}/src)
target_link_libraries(server ${OPENSSL_LIBRARIES}) target_link_libraries(server ${OPENSSL_LIBRARIES})
install(TARGETS server RUNTIME DESTINATION bin/server) install(TARGETS server RUNTIME DESTINATION bin/server)

1
resources/client/native/NULL
View file

@ -1 +0,0 @@
NULL

1
resources/server/NULL
View file

@ -1 +0,0 @@
NULL

1
src/client/native/NULL
View file

@ -1 +0,0 @@
NULL

1
src/client/web/NULL
View file

@ -1 +0,0 @@
NULL

9
src/server/main.c
View file

@ -1,9 +0,0 @@
#include <stdio.h>
#include "util/ipaddr.h"
int main(int argc, char** argv) {
ipaddr_t a = glv_ip_aton("127.0.0.1/24");
ipaddr_t b = glv_ip_aton("1234:5678::b00b:b00b:def0");
char* out = glv_ipv6_ntoa(&a);
return 0;
}

58
src/server/sock/tcp.h
View file

@ -1,58 +0,0 @@
#ifndef GLV_SOCK_TCP_H
#define GLV_SOCK_TCP_H
#ifdef _WIN32
#define WIN32_LEAN_AND_MEAN
#ifdef __MINGW32__
#undef _WIN32_WINNT
#define _WIN32_WINNT _WIN32_WINNT_WIN8
#endif
#include <winsock2.h>
#include <ws2tcpip.h>
typedef SOCKET glv_sock_t;
typedef SOCKADDR_IN glv_addr_t;
#else
#include <arpa/inet.h>
#include <errno.h>
#include <fcntl.h>
#include <netdb.h>
#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
typedef int glv_sock_t;
typedef struct sockaddr_in glv_addr_t;
#endif
#include <stdint.h>
#include "util/ipaddr.h"
#define GLV_TCP_FLAG_TYPE 1
#define GLV_TCP_FLAG_NBIO 2
#define GLV_TCP_RECV_APPEND 1
#define GLV_TCP_RECV_BLOCK 2
typedef struct {
glv_sock_t socket;
glv_addr_t addr;
uint32_t flags;
} glv_tcp_t;
glv_tcp_t* glv_tcp_create_server();
glv_tcp_t* glv_tcp_create_client();
int glv_tcp_send(glv_tcp_t* sock, const char* data, unsigned int length);
int glv_tcp_recv(glv_tcp_t* sock, char* data, unsigned int length, int flags);
int glv_tcp_data_ready(glv_tcp_t* sock);
int glv_tcp_is_open(glv_tcp_t* sock);
int glv_tcp_is_secure(glv_tcp_t* sock);
ipaddr_t glv_tcp_get_ip(glv_tcp_t* sock);
void glv_tcp_destroy(glv_tcp_t* sock);
#endif

6
src/server/sock/tcp_bsd.c
View file

@ -1,6 +0,0 @@
#ifndef _WIN32
#include "tcp.h"
#endif

4
src/server/sock/tcp_win.c
View file

@ -1,4 +0,0 @@
#ifdef _WIN32
#include "tcp.h"
#endif

248
src/server/util/ipaddr.c
View file

@ -1,248 +0,0 @@
#include "ipaddr.h"
#define MAX(X,Y) (((X)>(Y))?(X):(Y))
#define MIN(X,Y) (((X)<(Y))?(X):(Y))
const ipaddr_t error_addr = {{0, 0, 0, 0, 0, 0, 0, 0}, -1};
ipaddr_t glv_ip_aton(const char* addr) {
const int length = strlen(addr);
ipaddr_t addr_out = {{0, 0, 0, 0, 0, 0, 0, 0}, 128};
char token[5] = {0, 0, 0, 0, 0};
int i, j = 0, k = 0, cidr = 0, gap = -2, valid, tmp;
if(strchr(addr, ':') != NULL && strchr(addr, '.') != NULL)
return error_addr;
if(strcnt(addr, '/') > 1)
return error_addr;
if(strchr(addr, '.') != NULL) {
if(strcnt(addr, '.') != 3)
return error_addr;
addr_out.addr[5] = 0xFFFF;
for(i = 0; i < length; ++i) {
if(addr[i] == ' ')
continue;
valid = 0;
if(isdigit(addr[i])) {
valid = 1;
if(j == 3)
return error_addr;
token[j++] = addr[i];
}
if(addr[i] == '.' || addr[i] == '/' || i == length - 1) {
valid = 1;
if(j == 0)
return error_addr;
token[j] = 0;
if((tmp = atoi(token)) > 255)
return error_addr;
if(k < 4) {
addr_out.addr[6 + (k / 2)] |=
(tmp << (k % 2 == 0 ? 8 : 0));
j = 0;
++k;
} else {
if(tmp > 32)
return error_addr;
addr_out.cidr = tmp + 96;
}
if(addr[i] == '/' && k != 4)
return error_addr;
}
if(!valid)
return error_addr;
}
} else {
if(strcnt(addr, ':') > 7)
return error_addr;
for(i = 0; i < length; ++i) {
if(addr[i] == ' ')
continue;
valid = 0;
if((isxdigit(addr[i]) && !cidr) || (isdigit(addr[i]) && cidr)) {
valid = 1;
if(j == 4)
return error_addr;
token[j++] = addr[i];
}
if(addr[i] == ':' || addr[i] == '/' || i == length - 1) {
valid = 1;
if (j == 0 &&
!(k == 0 && i != length - 1 && addr[i + 1] == ':') &&
!(i - 2 >= 0 && addr[i] == '/' &&
addr[i - 1] == ':' && addr[i - 2] == ':'))
{
return error_addr;
}
token[j] = 0;
tmp = cidr ? atoi(token) : axtoi(token);
if(cidr) {
if(tmp > 128)
return error_addr;
addr_out.cidr = tmp;
} else if(j != 0) {
addr_out.addr[k] = tmp;
j = 0;
++k;
}
if(addr[i] == '/')
cidr = 1;
if(addr[i] == ':') {
if(cidr)
return error_addr;
if(i == length - 1)
return error_addr;
if(addr[i + 1] == ':') {
if(gap == -2) {
++i;
gap = k - 1;
continue;
} else
return error_addr;
}
}
}
if(!valid)
return error_addr;
}
if(gap > -2) {
for(i = k - 1; i > gap; --i) {
addr_out.addr[7 - (k - 1 - i)] = addr_out.addr[i];
addr_out.addr[i] = 0;
}
}
}
return addr_out;
}
ipaddr_t glv_ip_raw(const uint16_t* addr, uint8_t cidr) {
ipaddr_t addr_out;
memcpy(addr_out.addr, addr, 16);
addr_out.cidr = cidr;
return addr_out;
}
int glv_ip_check(const char* addr) {
ipaddr_t test = glv_ip_aton(addr);
return glv_ip_valid(&test);
}
int glv_ip_compare(const ipaddr_t* lhs, const ipaddr_t* rhs) {
int i = 0, lhs_cidr = lhs->cidr, rhs_cidr = rhs->cidr, mask;
for(i = 0; i < 8; ++i) {
mask = 0xFFFF
& ~((1 << (16 - MIN(16, lhs_cidr))) - 1)
& ~((1 << (16 - MIN(16, rhs_cidr))) - 1);
if(mask == 0)
break;
if((lhs->addr[i] & mask) != (rhs->addr[i] & mask))
return 0;
lhs_cidr = MAX(0, lhs_cidr - 16);
rhs_cidr = MAX(0, rhs_cidr - 16);
}
return 1;
}
int glv_ip_identical(const ipaddr_t* lhs, const ipaddr_t* rhs) {
int i;
for(i = 0; i < 8; ++i)
if(lhs->addr[i] != rhs->addr[i])
return 0;
return 1;
}
int glv_ip_isv4(const ipaddr_t* addr) {
return addr->addr[0] == 0 && addr->addr[1] == 0 &&
addr->addr[2] == 0 && addr->addr[3] == 0 &&
addr->addr[4] == 0 && addr->addr[5] == 0xFFFF;
}
int glv_ip_valid(const ipaddr_t* addr) {
return addr->cidr <= 128;
}
char* glv_ip_ntoa(const ipaddr_t* addr) {
if(!glv_ip_isv4(addr))
return glv_ipv6_ntoa(addr);
if(!glv_ip_valid(addr))
return NULL;
char* ip = malloc(18 * sizeof(char));
if(addr->cidr == 128) {
sprintf(ip, "%i.%i.%i.%i",
(addr->addr[6] >> 8) & 0xFF,
(addr->addr[6]) & 0xFF,
(addr->addr[7] >> 8) & 0xFF,
(addr->addr[7]) & 0xFF
);
} else {
sprintf(ip, "%i.%i.%i.%i/%i",
(addr->addr[6] >> 8) & 0xFF,
(addr->addr[6]) & 0xFF,
(addr->addr[7] >> 8) & 0xFF,
(addr->addr[7]) & 0xFF,
(addr->cidr - 96)
);
}
return ip;
}
char* glv_ipv6_ntoa(const ipaddr_t* addr) {
if(!glv_ip_valid(addr))
return NULL;
char* ip = malloc(43 * sizeof(char));
int i, jmp = 0, largest_gap_pos = -1, largest_gap_len = 0, curr_gap_len = 0;
for(i = 0; i < 8; ++i) {
if(addr->addr[i] == 0 && i < 7)
++curr_gap_len;
else {
if(curr_gap_len > largest_gap_len && curr_gap_len > 1) {
largest_gap_len = curr_gap_len;
largest_gap_pos = i - curr_gap_len;
}
curr_gap_len = 0;
}
}
for(i = 0; i < 8; ++i) {
if(i == largest_gap_pos) {
sprintf(ip, (i == 0 ? "::" : "%s:") , ip);
i += largest_gap_len - 1;
jmp = 1;
} else if(!(jmp && i == 7)) {
sprintf(ip, (i == 7 ? "%s%x" : "%s%x:"), ip, addr->addr[i]);
jmp = 0;
}
}
if(addr->cidr < 128)
sprintf(ip, "%s/%i", ip, addr->cidr);
return ip;
}

29
src/server/util/ipaddr.h
View file

@ -1,29 +0,0 @@
#ifndef GLV_UTIL_IPADDR_H
#define GLV_UTIL_IPADDR_H
#include <stdio.h>
#include <string.h>
#include <stdint.h>
#include <stdlib.h>
#include <ctype.h>
#include "util/string.h"
typedef struct {
uint16_t addr[8];
uint8_t cidr;
} ipaddr_t;
ipaddr_t glv_ip_aton(const char* addr);
ipaddr_t glv_ip_raw(const uint16_t* addr, uint8_t cidr);
int glv_ip_check(const char* addr);
int glv_ip_compare(const ipaddr_t* lhs, const ipaddr_t* rhs);
int glv_ip_identical(const ipaddr_t* lhs, const ipaddr_t* rhs);
int glv_ip_isv4(const ipaddr_t* addr);
int glv_ip_valid(const ipaddr_t* addr);
char* glv_ip_ntoa(const ipaddr_t* addr);
char* glv_ipv6_ntoa(const ipaddr_t* addr);
#endif

25
src/server/util/string.c
View file

@ -1,25 +0,0 @@
#include "string.h"
int axtoi(const char* str) {
int value = 0, i;
for(i = 0; i < strlen(str); ++i) {
value *= 16;
if(str[i] >= '0' && str[i] <= '9')
value += str[i] - '0';
else if(str[i] >= 'a' && str[i] <= 'f')
value += (str[i] - 'a') + 10;
else if(str[i] >= 'A' && str[i] <= 'F')
value += (str[i] - 'A') + 10;
}
return value;
}
int strcnt(const char* str, char c) {
int cnt = 0, i;
for(i = 0; i < strlen(str); ++i)
if(str[i] == c)
++cnt;
return cnt;
}

9
src/server/util/string.h
View file

@ -1,9 +0,0 @@
#ifndef GLV_UTIL_STRING_H
#define GLV_UTIL_STRING_H
#include <string.h>
int axtoi(const char* str);
int strcnt(const char* str, char c);
#endif

37
src/server/util/thread.h
View file

@ -1,37 +0,0 @@
#ifndef GLV_UTIL_THREAD_H
#define GLV_UTIL_THREAD_H
#ifdef _WIN32
#define WIN32_LEAN_AND_MEAN
#ifdef __MINGW32__
#undef _WIN32_WINNT
#define _WIN32_WINNT _WIN32_WINNT_WIN8
#endif
#include <windows.h>
typedef HANDLE glv_thread_t;
typedef HANDLE glv_mutex_t;
#else
#include <pthread.h>
typedef pthread_t glv_thread_t;
typedef pthread_mutex_t glv_mutex_t;
#endif
#include <stdlib.h>
typedef void(*glv_func_t)(void*);
glv_thread_t* glv_thread_create(glv_func_t func, void* args);
void glv_thread_join(glv_thread_t* thread);
void glv_thread_destroy(glv_thread_t* thread);
/** END THREAD DECLS **/
/**********************/
/** BEGIN MUTX DECLS **/
glv_mutex_t* glv_mutex_create();
void glv_mutex_lock(glv_mutex_t* mutex);
void glv_mutex_unlock(glv_mutex_t* mutex);
void glv_mutex_destroy(glv_mutex_t* mutex);
#endif

61
src/server/util/thread_posix.c
View file

@ -1,61 +0,0 @@
#ifndef _WIN32
#include "thread.h"
typedef struct {
glv_func_t func;
void* args;
} wrapper_t;
static void* _wrapper_func(void* proxy) {
wrapper_t wrapper = *((wrapper_t*)proxy);
free(proxy);
wrapper.func(wrapper.args);
}
glv_thread_t* glv_thread_create(glv_func_t func, void* args) {
wrapper_t* proxy = malloc(sizeof(wrapper_t));
proxy->func = func;
proxy->args = args;
glv_thread_t* thread = malloc(sizeof(glv_thread_t));
if(pthread_create(thread, NULL, _wrapper_func, proxy) == 0)
return thread;
else
return NULL;
}
void glv_thread_join(glv_thread_t* thread) {
pthread_join(*thread, NULL);
}
void glv_thread_destroy(glv_thread_t* thread) {
free(thread);
}
/** END THREAD IMPL **/
/*********************/
/** BEGIN MUTX IMPL **/
glv_mutex_t* glv_mutex_create() {
glv_mutex_t* mtx = malloc(sizeof(glv_mutex_t));
if(pthread_mutex_init(mtx, NULL) == 0)
return mtx;
else
return NULL;
}
void glv_mutex_lock(glv_mutex_t* mutex) {
pthread_mutex_lock(mutex);
}
void glv_mutex_unlock(glv_mutex_t* mutex) {
pthread_mutex_unlock(mutex);
}
void glv_mutex_destroy(glv_mutex_t* mutex) {
pthread_mutex_destroy(mutex);
free(mutex);
}
#endif

44
src/server/util/thread_win.c
View file

@ -1,44 +0,0 @@
#ifdef _WIN32
#include "thread.h"
glv_thread_t* glv_thread_create(glv_func_t func, void* args) {
glv_thread_t* thread = malloc(sizeof(glv_thread_t));
*thread = (glv_thread_t)_beginthread(func, 0, args);
return thread;
}
void glv_thread_join(glv_thread_t* thread) {
WaitForSingleObject(*thread, INFINITE);
}
void glv_thread_destroy(glv_thread_t* thread) {
CloseHandle(*thread);
free(thread);
}
/** END THREAD IMPL **/
/*********************/
/** BEGIN MUTX IMPL **/
glv_mutex_t* glv_mutex_create() {
glv_mutex_t* mutex = malloc(sizeof(glv_mutex_t));
*mutex = CreateMutexA(NULL, NULL, NULL);
return mutex;
}
void glv_mutex_lock(glv_mutex_t* mutex) {
WaitForSingleObject(*mutex, INFINITE);
}
void glv_mutex_unlock(glv_mutex_t* mutex) {
ReleaseMutex(*mutex);
}
void glv_mutex_destroy(glv_mutex_t* mutex) {
CloseHandle(*mutex);
free(mutex);
}
#endif