pgsql: don't always return error for parsing errors

This allows the app-proto to continue onto parsing next PDUs, if
possible.

Bug #5524

diff --git a/rust/src/pgsql/pgsql.rs b/rust/src/pgsql/pgsql.rs
index e9356ad45677b66551a0a3f127345a0ef21517fc..a8976d87b75363b1b1da12ae2a5a2a5b234f0979 100644 (file)
--- a/rust/src/pgsql/pgsql.rs
+++ b/rust/src/pgsql/pgsql.rs
@@ -1,4 +1,4 @@
-/* Copyright (C) 2022-2024 Open Information Security Foundation
+/* Copyright (C) 2022-2025 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
@@ -399,7 +399,26 @@ impl PgsqlState {
                     );
                     return AppLayerResult::incomplete(consumed as u32, needed_estimation as u32);
                 }
+                Err(Err::Error(err)) => {
+                    match err {
+                        PgsqlParseError::InvalidLength => {
+                            // TODO set event invalid length event
+                            // If we don't get a valid length, we can't know how to proceed
+                            return AppLayerResult::err();
+                        }
+                        PgsqlParseError::NomError(_i, error_kind) => {
+                            if error_kind == nom7::error::ErrorKind::Switch {
+                                // TODO set event switch / PgsqlEvent::MalformedData // or something like that
+                            }
+                            SCLogDebug!("Parsing error: {:?}", error_kind);
+                        }
+                    }
+                    // If we have parsed the message length, let's assume we can
+                    // move onto the next PDU even if we can't parse the current message
+                    return AppLayerResult::ok();
+                }
                 Err(_) => {
+                    SCLogDebug!("Error while parsing PGSQL request");
                     return AppLayerResult::err();
                 }
             }
@@ -573,8 +592,26 @@ impl PgsqlState {
                     );
                     return AppLayerResult::incomplete(consumed as u32, needed_estimation as u32);
                 }
+                Err(Err::Error(err)) => {
+                    match err {
+                        PgsqlParseError::InvalidLength => {
+                            // TODO set event invalid length event
+                            // If we don't get a valid length, we can't know how to proceed
+                            return AppLayerResult::err();
+                        }
+                        PgsqlParseError::NomError(_i, error_kind) => {
+                            if error_kind == nom7::error::ErrorKind::Switch {
+                                // TODO set event switch / PgsqlEvent::MalformedData // or something like that
+                            }
+                            SCLogDebug!("Parsing error: {:?}", error_kind);
+                        }
+                    }
+                    // If we have parsed the message length, let's assume we can
+                    // move onto the next PDU even if we can't parse the current message
+                    return AppLayerResult::ok();
+                }
                 Err(_) => {
-                    SCLogDebug!("Error while parsing PostgreSQL response");
+                    SCLogDebug!("Error while parsing PGSQL response");
                     return AppLayerResult::err();
                 }
             }