HTTPThreadServer/httplibrary.h at main · KevinAdhaikal/HTTPThreadServer · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
#ifndef HTTP_HEADER_INCLUDED
#define HTTP_HEADER_INCLUDED

#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <time.h>
#include <ctype.h>
#include <sys/stat.h>

#ifdef _WIN32
#include <winsock2.h>
#include <windows.h>
#include <ws2tcpip.h>
#include <mswsock.h>
#include <process.h>
#else
#include <unistd.h>
#include <pthread.h>
#include <semaphore.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/stat.h>
#if defined(__FreeBSD__) || defined(__OpenBSD__) || defined(__NetBSD__) || defined(__DragonFly__)
#include <sys/event.h>
#else
#include <sys/epoll.h>
#endif
#include <sys/sendfile.h>
#include <netinet/in.h>
#include <netdb.h>
#include <fcntl.h>
#include <ctype.h>
#include <errno.h>

#define SOCKET int
#define SD_RECEIVE SHUT_RD
#define SD_SEND SHUT_WR
#define SD_BOTH SHUT_RDWR
#endif

#include "buffer_lib.h"

#define HTTP_TEMPORARY_MAX_BUFFER 8192

typedef struct {
    char* val;
    size_t len;
} http_string;

typedef struct {
    SOCKET socket;
    // Parsing result

    #ifdef _WIN32
    void* room_pointer;
    #endif

    http_string method;
    http_string path;
    char* query_pointer;
    http_string version;
    char* headers_pointer;
    char* cookie_pointer;
    http_string body;

    char res[HTTP_TEMPORARY_MAX_BUFFER];
    size_t res_len;

    struct sockaddr_in addr;
} http_client;

typedef void (*http_callback)(http_client*);

typedef struct {
    #ifndef _WIN32
    pthread_t thread_id;
    #else
    OVERLAPPED overlapped;
    #endif
    buffer req_raw_data;
    http_client client;
    http_callback callback;
    size_t cmp_stream_status;
    size_t body_len_remaining;

    char no_need_check_request;
    char temporary_data[HTTP_TEMPORARY_MAX_BUFFER];
} http_room;

typedef struct {
    char still_on; // memberi tahu bahwa server ini masih on atau off
    #ifdef _WIN32
    int epoll_fd;
    size_t max_threads; // buat nge cek max thread
    #else
    size_t max_sockets; // buat nge cek max socket
    #endif
    SOCKET server_socket; // server socket nya
    #ifndef _WIN32
    http_room* thread_rooms; // isi isi room untuk http. (untuk linux)
    #else
    HANDLE iocp; // IOCP (untuk windows)
    #endif
    http_callback callback;
} http;

#define http_get_query(query_pointer, key) __http_get_query(query_pointer, key, sizeof(key) - 1) // HTTP Get Query
#define http_get_header(headers_pointer, key) __http_get_header(headers_pointer, key, sizeof(key) - 1) // HTTP Get Header
char* __http_get_query(char* query_pointer, const char* key, size_t key_len); // HTTP Get Query
char* __http_get_header(char* headers_pointer, const char* key, size_t key_len); // HTP Get Header
char* http_get_cookie(http_client* client, const char* key); // HTTP Get Cookie
char http_write(http_client* client, const char* data, size_t size); // HTTP Write
#define http_write_string(client, str) http_write(client, str, sizeof(str) - 1) // HTTP Write String
char http_send_file(http_client* client, const char* name_file, char manual_code, char use_cache); // HTTP Send File

#ifdef _WIN32
http* http_init_socket(const char* ip, unsigned short port, size_t max_threads, http_callback callback); // initilaize socket
#else
http* http_init_socket(const char* ip, unsigned short port, size_t max_sockets, http_callback callback); // initilaize socket
#endif

void http_start(http* http); // Start HTTP
void http_stop(http* http); // Stop HTTP

#endif // HTTP_HEADER_INCLUDED