From: Philippe Antoine Date: Mon, 26 Apr 2021 13:50:44 +0000 (+0200) Subject: http2: http.cookie keyword now works for HTTP2 X-Git-Tag: suricata-6.0.3~23 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=41054a68eff36d2209081c2e3ecbecef1590f587;p=thirdparty%2Fsuricata.git http2: http.cookie keyword now works for HTTP2 (cherry picked from commit 999327ba1f02904f219c4ffe6ff1d952facddc92) --- diff --git a/rust/src/http2/detect.rs b/rust/src/http2/detect.rs index 87e078e56c..da572dfbd8 100644 --- a/rust/src/http2/detect.rs +++ b/rust/src/http2/detect.rs @@ -564,6 +564,38 @@ pub unsafe extern "C" fn rs_http2_tx_get_useragent( return 0; } +#[no_mangle] +pub unsafe extern "C" fn rs_http2_tx_get_status( + tx: &mut HTTP2Transaction, buffer: *mut *const u8, buffer_len: *mut u32, +) -> u8 { + if let Ok(value) = http2_frames_get_header_value(&tx.frames_tc, ":status") { + *buffer = value.as_ptr(); //unsafe + *buffer_len = value.len() as u32; + return 1; + } + return 0; +} + +#[no_mangle] +pub unsafe extern "C" fn rs_http2_tx_get_cookie( + tx: &mut HTTP2Transaction, direction: u8, buffer: *mut *const u8, buffer_len: *mut u32, +) -> u8 { + if direction == STREAM_TOSERVER { + if let Ok(value) = http2_frames_get_header_value(&tx.frames_ts, "cookie") { + *buffer = value.as_ptr(); //unsafe + *buffer_len = value.len() as u32; + return 1; + } + } else { + if let Ok(value) = http2_frames_get_header_value(&tx.frames_tc, "set-cookie") { + *buffer = value.as_ptr(); //unsafe + *buffer_len = value.len() as u32; + return 1; + } + } + return 0; +} + #[no_mangle] pub unsafe extern "C" fn rs_http2_tx_get_header_value( tx: &mut HTTP2Transaction, direction: u8, strname: *const std::os::raw::c_char, diff --git a/src/detect-http-cookie.c b/src/detect-http-cookie.c index a1068da0f0..81e887eb34 100644 --- a/src/detect-http-cookie.c +++ b/src/detect-http-cookie.c @@ -76,7 +76,12 @@ static InspectionBuffer *GetResponseData(DetectEngineThreadCtx *det_ctx, const DetectEngineTransforms *transforms, Flow *_f, const uint8_t _flow_flags, void *txv, const int list_id); - +static InspectionBuffer *GetRequestData2(DetectEngineThreadCtx *det_ctx, + const DetectEngineTransforms *transforms, Flow *_f, const uint8_t _flow_flags, void *txv, + const int list_id); +static InspectionBuffer *GetResponseData2(DetectEngineThreadCtx *det_ctx, + const DetectEngineTransforms *transforms, Flow *_f, const uint8_t _flow_flags, void *txv, + const int list_id); /** * \brief Registration function for keyword: http_cookie */ @@ -116,6 +121,16 @@ void DetectHttpCookieRegister(void) PrefilterGenericMpmRegister, GetResponseData, ALPROTO_HTTP, HTP_REQUEST_HEADERS); + DetectAppLayerInspectEngineRegister2("http_cookie", ALPROTO_HTTP2, SIG_FLAG_TOSERVER, + HTTP2StateDataClient, DetectEngineInspectBufferGeneric, GetRequestData2); + DetectAppLayerInspectEngineRegister2("http_cookie", ALPROTO_HTTP2, SIG_FLAG_TOCLIENT, + HTTP2StateDataServer, DetectEngineInspectBufferGeneric, GetResponseData2); + + DetectAppLayerMpmRegister2("http_cookie", SIG_FLAG_TOSERVER, 2, PrefilterGenericMpmRegister, + GetRequestData2, ALPROTO_HTTP2, HTTP2StateDataClient); + DetectAppLayerMpmRegister2("http_cookie", SIG_FLAG_TOCLIENT, 2, PrefilterGenericMpmRegister, + GetResponseData2, ALPROTO_HTTP2, HTTP2StateDataServer); + DetectBufferTypeSetDescriptionByName("http_cookie", "http cookie header"); @@ -217,6 +232,48 @@ static InspectionBuffer *GetResponseData(DetectEngineThreadCtx *det_ctx, return buffer; } +static InspectionBuffer *GetRequestData2(DetectEngineThreadCtx *det_ctx, + const DetectEngineTransforms *transforms, Flow *_f, const uint8_t _flow_flags, void *txv, + const int list_id) +{ + InspectionBuffer *buffer = InspectionBufferGet(det_ctx, list_id); + if (buffer->inspect == NULL) { + uint32_t b_len = 0; + const uint8_t *b = NULL; + + if (rs_http2_tx_get_cookie(txv, STREAM_TOSERVER, &b, &b_len) != 1) + return NULL; + if (b == NULL || b_len == 0) + return NULL; + + InspectionBufferSetup(det_ctx, list_id, buffer, b, b_len); + InspectionBufferApplyTransforms(buffer, transforms); + } + + return buffer; +} + +static InspectionBuffer *GetResponseData2(DetectEngineThreadCtx *det_ctx, + const DetectEngineTransforms *transforms, Flow *_f, const uint8_t _flow_flags, void *txv, + const int list_id) +{ + InspectionBuffer *buffer = InspectionBufferGet(det_ctx, list_id); + if (buffer->inspect == NULL) { + uint32_t b_len = 0; + const uint8_t *b = NULL; + + if (rs_http2_tx_get_cookie(txv, STREAM_TOCLIENT, &b, &b_len) != 1) + return NULL; + if (b == NULL || b_len == 0) + return NULL; + + InspectionBufferSetup(det_ctx, list_id, buffer, b, b_len); + InspectionBufferApplyTransforms(buffer, transforms); + } + + return buffer; +} + /******************************** UNITESTS **********************************/ #ifdef UNITTESTS