diff --git a/src/Makefile.am b/src/Makefile.am index aa894b4a6c..ee1c823821 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -127,6 +127,7 @@ detect-detection-filter.c detect-detection-filter.h \ detect-http-client-body.c detect-http-client-body.h \ detect-http-stat-msg.c detect-http-stat-msg.h \ detect-asn1.c detect-asn1.h \ +detect-http-stat-code.c detect-http-stat-code.h \ util-atomic.h \ util-print.c util-print.h \ util-fmemopen.c util-fmemopen.h \ diff --git a/src/detect-http-method.c b/src/detect-http-method.c index 8f11857135..c8843b5212 100644 --- a/src/detect-http-method.c +++ b/src/detect-http-method.c @@ -968,6 +968,109 @@ end: return result; } +/** \test Check a signature with an request method and negation of the same */ +static int DetectHttpMethodSigTest04(void) +{ + int result = 0; + Flow f; + uint8_t httpbuf1[] = "GET / HTTP/1.0\r\n" + "Host: foo.bar.tld\r\n" + "\r\n"; + uint32_t httplen1 = sizeof(httpbuf1) - 1; /* minus the \0 */ + TcpSession ssn; + Packet *p = NULL; + Signature *s = NULL; + ThreadVars th_v; + DetectEngineThreadCtx *det_ctx = NULL; + HtpState *http_state = NULL; + + memset(&th_v, 0, sizeof(th_v)); + memset(&f, 0, sizeof(f)); + memset(&ssn, 0, sizeof(ssn)); + + p = UTHBuildPacket(NULL, 0, IPPROTO_TCP); + + FLOW_INITIALIZE(&f); + f.protoctx = (void *)&ssn; + f.src.family = AF_INET; + f.dst.family = AF_INET; + + p->flow = &f; + p->flowflags |= FLOW_PKT_TOSERVER; + p->flowflags |= FLOW_PKT_ESTABLISHED; + p->flags |= PKT_HAS_FLOW; + f.alproto = ALPROTO_HTTP; + + StreamTcpInitConfig(TRUE); + FlowL7DataPtrInit(&f); + + DetectEngineCtx *de_ctx = DetectEngineCtxInit(); + if (de_ctx == NULL) { + goto end; + } + + de_ctx->flags |= DE_QUIET; + + s = de_ctx->sig_list = SigInit(de_ctx, + "alert tcp any any -> any any " + "(msg:\"Testing http_method\"; " + "content:\"GET\"; " + "http_method; sid:1;)"); + if (s == NULL) { + goto end; + } + + s = s->next = SigInit(de_ctx, + "alert tcp any any -> any any " + "(msg:\"Testing http_method\"; " + "content:!\"GET\"; " + "http_method; sid:2;)"); + if (s == NULL) { + goto end; + } + + SigGroupBuild(de_ctx); + DetectEngineThreadCtxInit(&th_v, (void *)de_ctx, (void *)&det_ctx); + + int r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOSERVER, httpbuf1, httplen1); + if (r != 0) { + SCLogDebug("toserver chunk 1 returned %" PRId32 ", expected 0: ", r); + goto end; + } + + http_state = f.aldata[AlpGetStateIdx(ALPROTO_HTTP)]; + if (http_state == NULL) { + SCLogDebug("no http state: "); + goto end; + } + + SigMatchSignatures(&th_v, de_ctx, det_ctx, p); + + if (!(PacketAlertCheck(p, 1))) { + printf("sid 1 didn't match but should have: "); + goto end; + } + if (PacketAlertCheck(p, 2)) { + printf("sid 2 matched but shouldn't have: "); + goto end; + } + + result = 1; + +end: + + if (de_ctx != NULL) SigGroupCleanup(de_ctx); + if (de_ctx != NULL) SigCleanSignatures(de_ctx); + if (det_ctx != NULL) DetectEngineThreadCtxDeinit(&th_v, (void *) det_ctx); + if (de_ctx != NULL) DetectEngineCtxFree(de_ctx); + + FlowL7DataPtrFree(&f); + StreamTcpFreeConfig(TRUE); + FLOW_DESTROY(&f); + UTHFreePackets(&p, 1); + return result; +} + #endif /* UNITTESTS */ /** @@ -991,6 +1094,7 @@ void DetectHttpMethodRegisterTests(void) { UtRegisterTest("DetectHttpMethodSigTest01", DetectHttpMethodSigTest01, 1); UtRegisterTest("DetectHttpMethodSigTest02", DetectHttpMethodSigTest02, 1); UtRegisterTest("DetectHttpMethodSigTest03", DetectHttpMethodSigTest03, 1); + UtRegisterTest("DetectHttpMethodSigTest04", DetectHttpMethodSigTest04, 1); #endif /* UNITTESTS */ } diff --git a/src/detect-http-stat-code.c b/src/detect-http-stat-code.c new file mode 100644 index 0000000000..fd746a9ea5 --- /dev/null +++ b/src/detect-http-stat-code.c @@ -0,0 +1,833 @@ +/* Copyright (C) 2007-2010 Open Information Security Foundation + * + * You can copy, redistribute or modify this Program under the terms of + * the GNU General Public License version 2 as published by the Free + * Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * version 2 along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301, USA. + */ + +/** + * \file + * + * \author Gurvinder Singh + * + * Implements the http_stat_code keyword + */ + +#include "suricata-common.h" +#include "threads.h" +#include "debug.h" +#include "decode.h" +#include "detect.h" + +#include "detect-parse.h" +#include "detect-engine.h" +#include "detect-content.h" + +#include "flow.h" +#include "flow-var.h" +#include "flow-util.h" + +#include "util-debug.h" +#include "util-error.h" +#include "util-unittest.h" +#include "util-unittest-helper.h" +#include "util-spm.h" +#include "util-print.h" + +#include "app-layer.h" + +#include +#include "app-layer-htp.h" +#include "detect-http-stat-code.h" +#include "stream-tcp-private.h" +#include "stream-tcp.h" + +int DetectHttpStatCodeMatch (ThreadVars *, DetectEngineThreadCtx *, + Flow *, uint8_t , void *, Signature *, + SigMatch *); +static int DetectHttpStatCodeSetup (DetectEngineCtx *, Signature *, char *); +void DetectHttpStatCodeRegisterTests(void); +void DetectHttpStatCodeFree(void *); + +/** + * \brief Registration function for keyword: http_stat_code + */ +void DetectHttpStatCodeRegister (void) { + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].name = "http_stat_code"; + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].Match = NULL; + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].AppLayerMatch = DetectHttpStatCodeMatch; + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].alproto = ALPROTO_HTTP; + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].Setup = DetectHttpStatCodeSetup; + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].Free = DetectHttpStatCodeFree; + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].RegisterTests = DetectHttpStatCodeRegisterTests; + + sigmatch_table[DETECT_AL_HTTP_STAT_CODE].flags |= SIGMATCH_PAYLOAD; +} + +/** + * \brief match the specified content in the signature with the received http + * status code header in the http response. + * + * \param t pointer to thread vars + * \param det_ctx pointer to the pattern matcher thread + * \param f pointer to the current flow + * \param flags flags to indicate the direction of the received packet + * \param state pointer the app layer state, which will cast into HtpState + * \param s pointer to the current signature + * \param sm pointer to the sigmatch + * + * \retval 0 no match + * \retval 1 match + */ +int DetectHttpStatCodeMatch (ThreadVars *t, DetectEngineThreadCtx *det_ctx, + Flow *f, uint8_t flags, void *state, Signature *s, + SigMatch *sm) +{ + SCEnter(); + + int ret = 0; + size_t idx; + + SCMutexLock(&f->m); + SCLogDebug("got lock %p", &f->m); + + DetectHttpStatCodeData *co = (DetectHttpStatCodeData *)sm->ctx; + + HtpState *htp_state = (HtpState *)state; + if (htp_state == NULL) { + SCLogDebug("no HTTP layer state has been received, so no match"); + goto end; + } + + if (!(htp_state->flags & HTP_FLAG_STATE_OPEN)) { + SCLogDebug("HTP state not yet properly setup, so no match"); + goto end; + } + + SCLogDebug("htp_state %p, flow %p", htp_state, f); + SCLogDebug("htp_state->connp %p", htp_state->connp); + SCLogDebug("htp_state->connp->conn %p", htp_state->connp->conn); + + if (htp_state->connp == NULL || htp_state->connp->conn == NULL) { + SCLogDebug("HTTP connection structure is NULL"); + goto end; + } + + htp_tx_t *tx = NULL; + + for (idx = 0; idx < list_size(htp_state->connp->conn->transactions); idx++) + { + tx = list_get(htp_state->connp->conn->transactions, idx); + if (tx == NULL) + continue; + + SCLogDebug("we have a response message"); + if (co->code != -1) { + if (co->code == tx->response_status_number) { + SCLogDebug("Matched numeric HTTP status value"); + ret = 1; + } + } else if (tx->response_status != NULL) { + /* call the case insensitive version if nocase has been specified in + the sig */ + if (co->flags & DETECT_AL_HTTP_STAT_CODE_NOCASE) { + if (SpmNocaseSearch((uint8_t *) bstr_ptr(tx->response_status), + bstr_len(tx->response_status), co->data, co->data_len) + != NULL) + { + SCLogDebug("match has been found in received request and " + "given http_stat_code rule"); + ret = 1; + } + } else { + if (SpmSearch((uint8_t *) bstr_ptr(tx->response_status), + bstr_len(tx->response_status), co->data, co->data_len) + != NULL) + { + SCLogDebug("match has been found in received request and" + " given http_stat_code rule"); + ret = 1; + } + } + } + } + + SCMutexUnlock(&f->m); + SCReturnInt(ret ^ ((co->flags & DETECT_AL_HTTP_STAT_CODE_NEGATED) ? 1 : 0)); + +end: + SCMutexUnlock(&f->m); + SCLogDebug("released lock %p", &f->m); + SCReturnInt(ret); +} + +/** + * \brief this function clears the memory of http_stat_code modifier keyword + * + * \param ptr Pointer to the Detection Stat Code data + */ +void DetectHttpStatCodeFree(void *ptr) +{ + DetectHttpStatCodeData *hsmd = (DetectHttpStatCodeData *)ptr; + if (hsmd == NULL) + return; + if (hsmd->data != NULL) + SCFree(hsmd->data); + SCFree(hsmd); +} + +/** + * \brief this function setups the http_stat_code modifier keyword used in the rule + * + * \param de_ctx Pointer to the Detection Engine Context + * \param s Pointer to the Signature to which the current keyword belongs + * \param str Should hold an empty string always + * + * \retval 0 On success + * \retval -1 On failure + */ + +static int DetectHttpStatCodeSetup (DetectEngineCtx *de_ctx, Signature *s, char *str) +{ + SCEnter(); + DetectHttpStatCodeData *hd = NULL; + SigMatch *sm = NULL; + + /** new sig match to replace previous content */ + SigMatch *nm = NULL; + + if (str != NULL && strcmp(str, "") != 0) { + SCLogError(SC_ERR_INVALID_ARGUMENT, "http_stat_code shouldn't be supplied" + " with an argument"); + SCReturnInt(-1); + } + + SigMatch *pm = DetectContentGetLastPattern(s->pmatch_tail); + if (pm == NULL) { + SCLogWarning(SC_ERR_INVALID_SIGNATURE, "http_stat_code found inside " + "the rule, without a content context. Please use a " + "content keyword before using http_stat_code"); + return -1; + } + + /* http_stat_code should not be used with the fast_pattern rule */ + if (((DetectContentData *)pm->ctx)->flags & DETECT_CONTENT_FAST_PATTERN) { + SCLogWarning(SC_WARN_COMPATIBILITY, "http_stat_code rule can not " + "be used with the fast_pattern rule keyword. " + "Unsetting fast_pattern on this modifier. Signature ==> %s", + s->sig_str); + ((DetectContentData *)pm->ctx)->flags &= ~DETECT_CONTENT_FAST_PATTERN; + + /* http_stat_code should not be used with the rawbytes rule */ + } else if (((DetectContentData *)pm->ctx)->flags & DETECT_CONTENT_RAWBYTES) { + SCLogError(SC_ERR_INVALID_SIGNATURE, "http_stat_code rule can not " + "be used with the rawbytes rule keyword"); + SCReturnInt(-1); + } + + nm = SigMatchAlloc(); + if (nm == NULL) { + SCLogError(SC_ERR_MEM_ALLOC, "SigMatchAlloc failed"); + goto error; + } + + /* Setup the HttpStatCode data from Content data structure */ + hd = SCMalloc(sizeof(DetectHttpStatCodeData)); + if (hd == NULL) + goto error; + + memset(hd, 0, sizeof(DetectHttpStatCodeData)); + + /* Setup the http_stat_code keyword data */ + hd->data_len = ((DetectContentData *)pm->ctx)->content_len; + hd->data = ((DetectContentData *)pm->ctx)->content; + hd->flags |= (((DetectContentData *)pm->ctx)->flags & DETECT_CONTENT_NOCASE) ? + DETECT_AL_HTTP_STAT_CODE_NOCASE : 0x00; + hd->flags |= (((DetectContentData *)pm->ctx)->flags & DETECT_CONTENT_NEGATED) ? + DETECT_AL_HTTP_STAT_CODE_NEGATED : 0; + hd->code = htp_parse_positive_integer_whitespace((unsigned char *)hd->data, + hd->data_len, 10); + nm->type = DETECT_AL_HTTP_STAT_CODE; + nm->ctx = (void *)hd; + + /* pull the previous content from the pmatch list, append + * the new match to the match list */ + SigMatchReplaceContent(s, pm, nm); + + /* free the old content sigmatch, the content pattern memory + * is taken over by the new sigmatch */ + BoyerMooreCtxDeInit(((DetectContentData *)pm->ctx)->bm_ctx); + SCFree(pm->ctx); + SCFree(pm); + + /* Flagged the signature as to inspect the app layer data */ + s->flags |= SIG_FLAG_APPLAYER; + + if (s->alproto != ALPROTO_UNKNOWN && s->alproto != ALPROTO_HTTP) { + SCLogError(SC_ERR_CONFLICTING_RULE_KEYWORDS, "rule contains conflicting" + " keywords."); + goto error; + } + + s->alproto = ALPROTO_HTTP; + SCReturnInt(0); +error: + if (hd != NULL) DetectHttpStatCodeFree(hd); + if(sm !=NULL) SCFree(sm); + SCReturnInt(-1); +} + +#ifdef UNITTESTS + +/** + * \test Checks if a http_stat_code is registered in a Signature, if content is not + * specified in the signature or rawbyes is specified or fast_pattern is + * provided in the signature. + */ +int DetectHttpStatCodeTest01(void) +{ + DetectEngineCtx *de_ctx = NULL; + int result = 0; + + if ( (de_ctx = DetectEngineCtxInit()) == NULL) + goto end; + + de_ctx->flags |= DE_QUIET; + de_ctx->sig_list = SigInit(de_ctx, "alert tcp any any -> any any " + "(msg:\"Testing http_stat_code\"; http_stat_code;sid:1;)"); + if (de_ctx->sig_list != NULL) + goto end; + + de_ctx->sig_list = SigInit(de_ctx, "alert tcp any any -> any any " + "(msg:\"Testing http_stat_code\"; content:\"|FF F1|\";" + " rawbytes; http_stat_code;sid:1;)"); + if (de_ctx->sig_list != NULL) + goto end; + + de_ctx->sig_list = SigInit(de_ctx, "alert tcp any any -> any any " + "(msg:\"Testing http_stat_code\"; content:\"100\";" + "fast_pattern; http_stat_code;sid:1;)"); + if (de_ctx->sig_list == NULL || + ((DetectContentData *)de_ctx->sig_list->amatch->ctx)->flags & + DETECT_CONTENT_FAST_PATTERN) + { + goto end; + } + + result = 1; +end: + if (de_ctx != NULL) + DetectEngineCtxFree(de_ctx); + return result; +} + +/** + * \test Checks if a http_stat_code is registered in a Signature and also checks + * the nocase + */ +int DetectHttpStatCodeTest02(void) +{ + SigMatch *sm = NULL; + DetectEngineCtx *de_ctx = NULL; + int result = 0; + + if ( (de_ctx = DetectEngineCtxInit()) == NULL) + goto end; + + de_ctx->flags |= DE_QUIET; + de_ctx->sig_list = SigInit(de_ctx, "alert tcp any any -> any any " + "(msg:\"Testing http_stat_code\"; content:\"one\"; " + "http_stat_code; content:\"200\"; http_stat_code; " + "content:\"two hundred\"; nocase; http_stat_code; " + "sid:1;)"); + if (de_ctx->sig_list == NULL) { + printf("sig parse failed: "); + goto end; + } + + result = 0; + sm = de_ctx->sig_list->amatch; + if (sm == NULL) { + printf("no sigmatch(es): "); + goto end; + } + + SigMatch *prev = NULL; + while (sm != NULL) { + if (sm->type == DETECT_AL_HTTP_STAT_CODE) { + result = 1; + } else { + printf("expected DETECT_AL_HTTP_STAT_CODE, got %d: ", sm->type); + goto end; + } + prev = sm; + sm = sm->next; + } + + if (! (((DetectHttpStatCodeData *)prev->ctx)->flags & + DETECT_AL_HTTP_STAT_CODE_NOCASE)) + { + result = 0; + } +end: + if (de_ctx != NULL) + DetectEngineCtxFree(de_ctx); + return result; +} + +/** \test Check the signature working to alert when http_stat_code is matched . */ +static int DetectHttpStatCodeSigTest01(void) { + int result = 0; + Flow f; + uint8_t httpbuf1[] = "POST / HTTP/1.0\r\nUser-Agent: Mozilla/1.0\r\n\r\n"; + uint32_t httplen1 = sizeof(httpbuf1) - 1; /* minus the \0 */ + uint8_t httpbuf2[] = "HTTP/1.0 200 OK\r\n\r\n"; + uint32_t httplen2 = sizeof(httpbuf2) - 1; /* minus the \0 */ + TcpSession ssn; + Packet *p = NULL; + Signature *s = NULL; + ThreadVars th_v; + DetectEngineThreadCtx *det_ctx = NULL; + HtpState *http_state = NULL; + + memset(&th_v, 0, sizeof(th_v)); + memset(&f, 0, sizeof(f)); + memset(&ssn, 0, sizeof(ssn)); + + p = UTHBuildPacket(NULL, 0, IPPROTO_TCP); + + FLOW_INITIALIZE(&f); + f.protoctx = (void *)&ssn; + f.src.family = AF_INET; + f.dst.family = AF_INET; + + p->flow = &f; + p->flowflags |= FLOW_PKT_TOSERVER; + p->flowflags |= FLOW_PKT_ESTABLISHED; + p->flags |= PKT_HAS_FLOW; + f.alproto = ALPROTO_HTTP; + + StreamTcpInitConfig(TRUE); + FlowL7DataPtrInit(&f); + + DetectEngineCtx *de_ctx = DetectEngineCtxInit(); + if (de_ctx == NULL) { + goto end; + } + + de_ctx->flags |= DE_QUIET; + + s = de_ctx->sig_list = SigInit(de_ctx,"alert http any any -> any any (msg:" + "\"HTTP status code\"; content:\"200\"; " + "http_stat_code; sid:1;)"); + if (s == NULL) { + goto end; + } + + SigGroupBuild(de_ctx); + DetectEngineThreadCtxInit(&th_v, (void *)de_ctx, (void *)&det_ctx); + + int r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOSERVER, httpbuf1, httplen1); + if (r != 0) { + printf("toserver chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOCLIENT, httpbuf2, httplen2); + if (r != 0) { + printf("toclient chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + http_state = f.aldata[AlpGetStateIdx(ALPROTO_HTTP)]; + if (http_state == NULL) { + printf("no http state: "); + result = 0; + goto end; + } + + /* do detect */ + SigMatchSignatures(&th_v, de_ctx, det_ctx, p); + + if (!(PacketAlertCheck(p, 1))) { + printf("sid 1 didn't match but should have: "); + goto end; + } + + result = 1; +end: + if (det_ctx != NULL) { + DetectEngineThreadCtxDeinit(&th_v, (void *)det_ctx); + } + if (de_ctx != NULL) { + SigGroupCleanup(de_ctx); + DetectEngineCtxFree(de_ctx); + } + + FlowL7DataPtrFree(&f); + StreamTcpFreeConfig(TRUE); + + UTHFreePackets(&p, 1); + return result; +} + +/** \test Check the signature working to alert when http_stat_code is not matched . */ +static int DetectHttpStatCodeSigTest02(void) { + int result = 0; + Flow f; + uint8_t httpbuf1[] = "POST / HTTP/1.0\r\nUser-Agent: Mozilla/1.0\r\n\r\n"; + uint32_t httplen1 = sizeof(httpbuf1) - 1; /* minus the \0 */ + uint8_t httpbuf2[] = "HTTP/1.0 200 OK\r\n\r\n"; + uint32_t httplen2 = sizeof(httpbuf2) - 1; /* minus the \0 */ + TcpSession ssn; + Packet *p = NULL; + Signature *s = NULL; + ThreadVars th_v; + DetectEngineThreadCtx *det_ctx = NULL; + HtpState *http_state = NULL; + + memset(&th_v, 0, sizeof(th_v)); + memset(&f, 0, sizeof(f)); + memset(&ssn, 0, sizeof(ssn)); + + p = UTHBuildPacket(NULL, 0, IPPROTO_TCP); + + FLOW_INITIALIZE(&f); + f.protoctx = (void *)&ssn; + f.src.family = AF_INET; + f.dst.family = AF_INET; + + p->flow = &f; + p->flowflags |= FLOW_PKT_TOSERVER; + p->flowflags |= FLOW_PKT_ESTABLISHED; + p->flags |= PKT_HAS_FLOW; + f.alproto = ALPROTO_HTTP; + + StreamTcpInitConfig(TRUE); + FlowL7DataPtrInit(&f); + + DetectEngineCtx *de_ctx = DetectEngineCtxInit(); + if (de_ctx == NULL) { + goto end; + } + + de_ctx->flags |= DE_QUIET; + + s = de_ctx->sig_list = SigInit(de_ctx,"alert http any any -> any any (msg:" + "\"HTTP status code\"; content:\"no\"; " + "http_stat_code; sid:1;)"); + if (s == NULL) { + goto end; + } + + s->next = SigInit(de_ctx,"alert http any any -> any any (msg:\"HTTP " + "Status code\"; content:\"100\";" + "http_stat_code; sid:2;)"); + if (s->next == NULL) { + goto end; + } + + SigGroupBuild(de_ctx); + DetectEngineThreadCtxInit(&th_v, (void *)de_ctx, (void *)&det_ctx); + + int r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOSERVER, httpbuf1, httplen1); + if (r != 0) { + printf("toserver chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOCLIENT, httpbuf2, httplen2); + if (r != 0) { + printf("toclient chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + http_state = f.aldata[AlpGetStateIdx(ALPROTO_HTTP)]; + if (http_state == NULL) { + printf("no http state: "); + result = 0; + goto end; + } + + /* do detect */ + SigMatchSignatures(&th_v, de_ctx, det_ctx, p); + + if (PacketAlertCheck(p, 1)) { + printf("sid 1 matched but shouldn't: "); + goto end; + } + if ((PacketAlertCheck(p, 2))) { + printf("sid 2 match but shouldn't have: "); + goto end; + } + + result = 1; +end: + if (det_ctx != NULL) { + DetectEngineThreadCtxDeinit(&th_v, (void *)det_ctx); + } + if (de_ctx != NULL) { + SigGroupCleanup(de_ctx); + DetectEngineCtxFree(de_ctx); + } + + FlowL7DataPtrFree(&f); + StreamTcpFreeConfig(TRUE); + + UTHFreePackets(&p, 1); + return result; +} + +/** \test Check the signature working to alert when http_stat_code is matched for + * for nocase or not */ +static int DetectHttpStatCodeSigTest03(void) { + int result = 0; + Flow f; + uint8_t httpbuf1[] = "POST / HTTP/1.0\r\nUser-Agent: Mozilla/1.0\r\n\r\n"; + uint32_t httplen1 = sizeof(httpbuf1) - 1; /* minus the \0 */ + uint8_t httpbuf2[] = "HTTP/1.0 FAIL OK\r\n\r\n"; + uint32_t httplen2 = sizeof(httpbuf2) - 1; /* minus the \0 */ + TcpSession ssn; + Packet *p = NULL; + Signature *s = NULL; + ThreadVars th_v; + DetectEngineThreadCtx *det_ctx = NULL; + HtpState *http_state = NULL; + + memset(&th_v, 0, sizeof(th_v)); + memset(&f, 0, sizeof(f)); + memset(&ssn, 0, sizeof(ssn)); + + p = UTHBuildPacket(NULL, 0, IPPROTO_TCP); + + FLOW_INITIALIZE(&f); + f.protoctx = (void *)&ssn; + f.src.family = AF_INET; + f.dst.family = AF_INET; + + p->flow = &f; + p->flowflags |= FLOW_PKT_TOSERVER; + p->flowflags |= FLOW_PKT_ESTABLISHED; + p->flags |= PKT_HAS_FLOW; + f.alproto = ALPROTO_HTTP; + + StreamTcpInitConfig(TRUE); + FlowL7DataPtrInit(&f); + + DetectEngineCtx *de_ctx = DetectEngineCtxInit(); + if (de_ctx == NULL) { + goto end; + } + + de_ctx->flags |= DE_QUIET; + + s = de_ctx->sig_list = SigInit(de_ctx,"alert http any any -> any any (msg:" + "\"HTTP status code\"; content:\"FAIL\"; " + "http_stat_code; sid:1;)"); + if (s == NULL) { + goto end; + } + + s->next = SigInit(de_ctx,"alert http any any -> any any (msg:\"HTTP " + "Status code nocase\"; content:\"fail\"; nocase; " + "http_stat_code; sid:2;)"); + if (s->next == NULL) { + goto end; + } + + SigGroupBuild(de_ctx); + DetectEngineThreadCtxInit(&th_v, (void *)de_ctx, (void *)&det_ctx); + + int r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOSERVER, httpbuf1, httplen1); + if (r != 0) { + printf("toserver chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOCLIENT, httpbuf2, httplen2); + if (r != 0) { + printf("toclient chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + http_state = f.aldata[AlpGetStateIdx(ALPROTO_HTTP)]; + if (http_state == NULL) { + printf("no http state: "); + result = 0; + goto end; + } + + /* do detect */ + SigMatchSignatures(&th_v, de_ctx, det_ctx, p); + + if (!(PacketAlertCheck(p, 1))) { + printf("sid 1 didn't match but should have: "); + goto end; + } + if (!(PacketAlertCheck(p, 2))) { + printf("sid 2 didn't match but should have: "); + goto end; + } + + result = 1; +end: + if (det_ctx != NULL) { + DetectEngineThreadCtxDeinit(&th_v, (void *)det_ctx); + } + if (de_ctx != NULL) { + SigGroupCleanup(de_ctx); + DetectEngineCtxFree(de_ctx); + } + + FlowL7DataPtrFree(&f); + StreamTcpFreeConfig(TRUE); + + UTHFreePackets(&p, 1); + return result; +} + +/** \test Check the signature working to alert when http_stat_code is matched for + * for negatoin or not */ +static int DetectHttpStatCodeSigTest04(void) { + int result = 0; + Flow f; + uint8_t httpbuf1[] = "POST / HTTP/1.0\r\nUser-Agent: Mozilla/1.0\r\n\r\n"; + uint32_t httplen1 = sizeof(httpbuf1) - 1; /* minus the \0 */ + uint8_t httpbuf2[] = "HTTP/1.0 200 OK\r\n\r\n"; + uint32_t httplen2 = sizeof(httpbuf2) - 1; /* minus the \0 */ + TcpSession ssn; + Packet *p = NULL; + Signature *s = NULL; + ThreadVars th_v; + DetectEngineThreadCtx *det_ctx = NULL; + HtpState *http_state = NULL; + + memset(&th_v, 0, sizeof(th_v)); + memset(&f, 0, sizeof(f)); + memset(&ssn, 0, sizeof(ssn)); + + p = UTHBuildPacket(NULL, 0, IPPROTO_TCP); + + FLOW_INITIALIZE(&f); + f.protoctx = (void *)&ssn; + f.src.family = AF_INET; + f.dst.family = AF_INET; + + p->flow = &f; + p->flowflags |= FLOW_PKT_TOSERVER; + p->flowflags |= FLOW_PKT_ESTABLISHED; + p->flags |= PKT_HAS_FLOW; + f.alproto = ALPROTO_HTTP; + + StreamTcpInitConfig(TRUE); + FlowL7DataPtrInit(&f); + + DetectEngineCtx *de_ctx = DetectEngineCtxInit(); + if (de_ctx == NULL) { + goto end; + } + + de_ctx->flags |= DE_QUIET; + + s = de_ctx->sig_list = SigInit(de_ctx,"alert http any any -> any any (msg:" + "\"HTTP status code\"; content:\"200\"; " + "http_stat_code; sid:1;)"); + if (s == NULL) { + goto end; + } + + s->next = SigInit(de_ctx,"alert http any any -> any any (msg:\"HTTP " + "Status code negation\"; content:!\"100\"; nocase; " + "http_stat_code; sid:2;)"); + if (s->next == NULL) { + goto end; + } + + SigGroupBuild(de_ctx); + DetectEngineThreadCtxInit(&th_v, (void *)de_ctx, (void *)&det_ctx); + + int r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOSERVER, httpbuf1, httplen1); + if (r != 0) { + printf("toserver chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + r = AppLayerParse(&f, ALPROTO_HTTP, STREAM_TOCLIENT, httpbuf2, httplen2); + if (r != 0) { + printf("toclient chunk 1 returned %" PRId32 ", expected 0: ", r); + result = 0; + goto end; + } + + http_state = f.aldata[AlpGetStateIdx(ALPROTO_HTTP)]; + if (http_state == NULL) { + printf("no http state: "); + result = 0; + goto end; + } + + /* do detect */ + SigMatchSignatures(&th_v, de_ctx, det_ctx, p); + + if (!(PacketAlertCheck(p, 1))) { + printf("sid 1 didn't match but should have: "); + goto end; + } + if (!(PacketAlertCheck(p, 2))) { + printf("sid 2 didn't match but should have: "); + goto end; + } + + result = 1; +end: + if (det_ctx != NULL) { + DetectEngineThreadCtxDeinit(&th_v, (void *)det_ctx); + } + if (de_ctx != NULL) { + SigGroupCleanup(de_ctx); + DetectEngineCtxFree(de_ctx); + } + + FlowL7DataPtrFree(&f); + StreamTcpFreeConfig(TRUE); + + UTHFreePackets(&p, 1); + return result; +} + +#endif /* UNITTESTS */ + +/** + * \brief Register the UNITTESTS for the http_stat_code keyword + */ +void DetectHttpStatCodeRegisterTests (void) +{ +#ifdef UNITTESTS /* UNITTESTS */ + + UtRegisterTest("DetectHttpStatCodeTest01", DetectHttpStatCodeTest01, 1); + UtRegisterTest("DetectHttpStatCodeTest02", DetectHttpStatCodeTest02, 1); + UtRegisterTest("DetectHttpStatCodeSigTest01", DetectHttpStatCodeSigTest01, 1); + UtRegisterTest("DetectHttpStatCodeSigTest02", DetectHttpStatCodeSigTest02, 1); + UtRegisterTest("DetectHttpStatCodeSigTest03", DetectHttpStatCodeSigTest03, 1); + UtRegisterTest("DetectHttpStatCodeSigTest04", DetectHttpStatCodeSigTest04, 1); + +#endif /* UNITTESTS */ +} + diff --git a/src/detect-http-stat-code.h b/src/detect-http-stat-code.h new file mode 100644 index 0000000000..15505ad67a --- /dev/null +++ b/src/detect-http-stat-code.h @@ -0,0 +1,45 @@ +/* Copyright (C) 2007-2010 Open Information Security Foundation + * + * You can copy, redistribute or modify this Program under the terms of + * the GNU General Public License version 2 as published by the Free + * Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * version 2 along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301, USA. + */ + +/** + * \file + * + * \author Gurvinder Singh + */ + +#ifndef _DETECT_HTTP_STAT_CODE_H +#define _DETECT_HTTP_STAT_CODE_H + +#define DETECT_AL_HTTP_STAT_CODE_NOCASE 0x01 +#define DETECT_AL_HTTP_STAT_CODE_NEGATED 0x02 + +typedef struct DetectHttpStatCodeData_ { + uint8_t *data; + uint8_t data_len; + uint8_t flags; + int code; /**< Numeric HTTP status code to match */ +} DetectHttpStatCodeData; + +/* prototypes */ +int DetectHttpStatCodeMatch (ThreadVars *, DetectEngineThreadCtx *, + Flow *, uint8_t , void *, Signature *, + SigMatch *); +void DetectHttpStatCodeRegister(void); + + +#endif /* _DETECT_HTTP_STAT_CODE_H */ + diff --git a/src/detect.c b/src/detect.c index 8b4ae72aab..9b438094da 100644 --- a/src/detect.c +++ b/src/detect.c @@ -123,6 +123,7 @@ #include "detect-tls-version.h" #include "detect-ssh-proto-version.h" #include "detect-ssh-software-version.h" +#include "detect-http-stat-code.h" #include "action-globals.h" #include "tm-modules.h" @@ -3722,6 +3723,7 @@ void SigTableSetup(void) { DetectAsn1Register(); DetectSshVersionRegister(); DetectSshSoftwareVersionRegister(); + DetectHttpStatCodeRegister(); uint8_t i = 0; for (i = 0; i < DETECT_TBLSIZE; i++) { diff --git a/src/detect.h b/src/detect.h index e66bb57740..8e0092732e 100644 --- a/src/detect.h +++ b/src/detect.h @@ -878,6 +878,7 @@ enum { DETECT_AL_HTTP_HEADER, DETECT_AL_HTTP_URI, DETECT_AL_HTTP_STAT_MSG, + DETECT_AL_HTTP_STAT_CODE, DETECT_AL_SSH_PROTOVERSION, DETECT_AL_SSH_SOFTWAREVERSION,