support for purge method (not bulk)

nodejs has (in C) a method whitelist

Author: splitice

src/core/http.h

@@ -21,7 +21,7 @@
 #define LONGEST_REQMETHOD 6
 #define REQUEST_HTTPADMIN 0x0200
 #define REQUEST_HTTPGET 0x0100
-#define REQUEST_HTTPBULK 0x0080
+#define REQUEST_HTTPPURGE 0x0080
 #define REQUEST_HTTPPUT 0x0040
 #define REQUEST_HTTPDELETE 0x0020
 #define REQUEST_HTTPHEAD 0x0010

src/core/http_parse.cpp

@@ -202,9 +202,9 @@ static inline state_action http_read_requeststartmethod(int epfd, cache_connecti
 			RBUF_READMOVE(connection->input, n + 1);
 			return needs_more;
 		}
-		else if (n == 4 && rbuf_cmpn(&connection->input, "BULK", 4) == 0) {
+		else if (n == 4 && (rbuf_cmpn(&connection->input, "BULK", 4) == 0 || rbuf_cmpn(&connection->input, "PURGE", 5) == 0)) {
 			//This is a BULK request
-			connection->type = REQUEST_HTTPBULK;
+			connection->type = REQUEST_HTTPPURGE;
 			assert(REQUEST_IS(connection->type, connection->type));
 			RBUF_READMOVE(connection->input, n + 1);
 			DEBUG("[#%d] HTTP BULK Request\n", connection->client_sock);
@@ -276,7 +276,7 @@ static inline state_action http_read_requeststarturl1(int epfd, cache_connection
 			return needs_more;
 		}
 		else if (*buffer == ' ') {
-			if (REQUEST_IS(connection->type, REQUEST_HTTPGET) || REQUEST_IS(connection->type, REQUEST_HTTPDELETE) || REQUEST_IS(connection->type, REQUEST_HTTPBULK)) {
+			if (REQUEST_IS(connection->type, REQUEST_HTTPGET) || REQUEST_IS(connection->type, REQUEST_HTTPDELETE) || REQUEST_IS(connection->type, REQUEST_HTTPPURGE)) {
 				//Request for "/"
 				if (n == 1) {
 					//Stats Command
@@ -374,7 +374,7 @@ static state_action http_read_headers(int epfd, cache_connection* connection, ch
 				return needs_more;
 			}
 		}
-		else if (REQUEST_IS(connection->type, REQUEST_HTTPBULK | REQUEST_LEVELTABLE)) {
+		else if (REQUEST_IS(connection->type, REQUEST_HTTPPURGE | REQUEST_LEVELTABLE)) {
 			if (bytes == 8 && rbuf_cmpn(&connection->input, "X-Delete", 8) == 0) {
 				DEBUG("[#%d] Found X-Delete header\n", connection->client_sock);
 				RBUF_READMOVE(connection->input, bytes + 1);
@@ -441,7 +441,7 @@ static state_action http_read_headers(int epfd, cache_connection* connection, ch
 				db_table_handle_delete(connection->target.table.table);
 				return http_write_response(epfd, connection, HTTPTEMPLATE_FULLHTTP200DELETED);
 			}
-			if (REQUEST_IS(connection->type, REQUEST_HTTPBULK)) {
+			if (REQUEST_IS(connection->type, REQUEST_HTTPPURGE)) {
 				return http_write_response(epfd, connection, HTTPTEMPLATE_BULK_OK);
 			}
 			if (REQUEST_IS(connection->type, REQUEST_HTTPADMIN)) {
@@ -573,7 +573,7 @@ static state_action http_read_header_extraction(int epfd, cache_connection* conn
 			break;
 
 		case HEADER_XDELETE:
-			if (REQUEST_IS(connection->type, REQUEST_HTTPBULK | REQUEST_LEVELTABLE) && connection->target.table.table != NULL) {
+			if (REQUEST_IS(connection->type, REQUEST_HTTPPURGE | REQUEST_LEVELTABLE) && connection->target.table.table != NULL) {
 				char* key = (char*)malloc(length);
 				rbuf_copyn(&connection->input, key, length);
 				cache_entry* entry = db_entry_get_delete(connection->target.table.table, key, length);