code sync

.github/ISSUE_TEMPLATE/bug_report.md

@@ -1,34 +0,0 @@
----
-name: "Bug Report"
-description: "Report a bug with open-appsec"
-labels: [bug]
----
-
-**Checklist**
-- Have you checked the open-appsec troubleshooting guides - https://docs.openappsec.io/troubleshooting/troubleshooting
-  - Yes / No
-- Have you checked the existing issues and discossions in github for the same issue
-  - Yes / No
-
-**Describe the bug**
-A clear and concise description of what the bug is.
-
-**To Reproduce**
-Steps to reproduce the behavior:
-1. Go to '...'
-2. Run '...'
-3. See error '...'
-
-**Expected behavior**
-A clear and concise description of what you expected to happen.
-
-**Screenshots or Logs**
-If applicable, add screenshots or logs to help explain the issue.
-
-**Environment (please complete the following information):**
-- open-appsec version: 
-- Deployment type (Docker, Kubernetes, etc.): 
-- OS:
-
-**Additional context**
-Add any other context about the problem here.

.github/ISSUE_TEMPLATE/config.yml

@@ -1,8 +0,0 @@
-blank_issues_enabled: false
-contact_links:
-  - name: "Documentation & FAQ"
-    url: "https://docs.openappsec.io/"
-    about: "Check the documentation before submitting an issue."
-  - name: "Feature Requests & Discussions"
-    url: "https://github.com/open-appsec/discussions"
-    about: "Please open a discussion for feature requests instead of an issue."

.github/ISSUE_TEMPLATE/feature_request.md

@@ -1,17 +0,0 @@
----
-name: "Feature Request"
-description: "Suggest a new feature or improvement"
-labels: [enhancement]
----
-
-**Is your feature request related to a problem? Please describe.**
-A clear and concise description of what the problem is.
-
-**Describe the solution you'd like**
-A clear and concise description of what you want to happen.
-
-**Describe alternatives you've considered**
-A clear and concise description of any alternative solutions or features you've considered.
-
-**Additional context**
-Add any other context or screenshots about the feature request here.

.github/ISSUE_TEMPLATE/nginx_version_support.md

@@ -1,17 +0,0 @@
----
-name: "Nginx Version Support Request"
-description: "Check if a specific Nginx version is supported"
----
-
-**Nginx & OS Version:**
-Which Nginx and OS version are you using? 
-
-**Output of nginx -V**
-Share the output of nginx -v
-
-**Expected Behavior:**
-What do you expect to happen with this version?
-
-**Checklist**
-- Have you considered a docker based deployment - find more information here https://docs.openappsec.io/getting-started/start-with-docker?
-  - Yes / No

components/attachment-intakers/nginx_attachment/user_identifiers_config.cc

@@ -285,21 +285,17 @@ Maybe<string>
 UsersAllIdentifiersConfig::parseXForwardedFor(const string &str, ExtractType type) const
 {
     vector<string> header_values = split(str);
+
     if (header_values.empty()) return genError("No IP found in the xff header list");
 
     vector<string> xff_values = getHeaderValuesFromConfig("x-forwarded-for");
     vector<CIDRSData> cidr_values(xff_values.begin(), xff_values.end());
-    string last_valid_ip;
 
     for (auto it = header_values.rbegin(); it != header_values.rend() - 1; ++it) {
         if (!IPAddr::createIPAddr(*it).ok()) {
             dbgWarning(D_NGINX_ATTACHMENT_PARSER) << "Invalid IP address found in the xff header IPs list: " << *it;
-            if (last_valid_ip.empty()) {
+            return genError("Invalid IP address");
-                return genError("Invalid IP address");
-            }
-            return last_valid_ip;
         }
-        last_valid_ip = *it;
         if (type == ExtractType::PROXYIP) continue;
         if (!isIpTrusted(*it, cidr_values)) {
             dbgDebug(D_NGINX_ATTACHMENT_PARSER) << "Found untrusted IP in the xff header IPs list: " << *it;
@@ -311,10 +307,7 @@ UsersAllIdentifiersConfig::parseXForwardedFor(const string &str, ExtractType typ
         dbgWarning(D_NGINX_ATTACHMENT_PARSER)
             << "Invalid IP address found in the xff header IPs list: "
             << header_values[0];
-        if (last_valid_ip.empty()) {
+        return genError("Invalid IP address");
-            return genError("No Valid Ip address was found");
-        }
-        return last_valid_ip;
     }
 
     return header_values[0];

components/security_apps/central_nginx_manager/central_nginx_manager.cc

@@ -179,7 +179,7 @@ private:
     Maybe<void>
     configureSyslog()
     {
-        if (!getProfileAgentSettingWithDefault<bool>(false, "centralNginxManagement.syslogEnabled")) {
+        if (!getProfileAgentSettingWithDefault<bool>(true, "centralNginxManagement.syslogEnabled")) {
             dbgTrace(D_NGINX_MANAGER) << "Syslog is disabled via settings";
             return {};
         }
@@ -331,8 +331,6 @@ public:
             logError("Could not reload central NGINX configuration. Error: " + reload_result.getErr());
             return;
         }
-
-        logInfo("Central NGINX configuration has been successfully reloaded");
     }
 
     void
@@ -353,37 +351,11 @@ private:
     {
         LogGen log(
             error,
-            ReportIS::Level::ACTION,
             ReportIS::Audience::SECURITY,
             ReportIS::Severity::CRITICAL,
-            ReportIS::Priority::URGENT,
+            ReportIS::Priority::HIGH,
             ReportIS::Tags::POLICY_INSTALLATION
         );
-
-        log.addToOrigin(LogField("eventTopic", "Central NGINX Management"));
-        log << LogField("notificationId", "4165c3b1-e9bc-44c3-888b-863e204c1bfb");
-        log << LogField(
-            "eventRemediation",
-            "Please verify your NGINX configuration and enforce policy again. "
-            "Contact Check Point support if the issue persists."
-        );
-    }
-
-    void
-    logInfo(const string &info)
-    {
-        LogGen log(
-            info,
-            ReportIS::Level::ACTION,
-            ReportIS::Audience::SECURITY,
-            ReportIS::Severity::INFO,
-            ReportIS::Priority::LOW,
-            ReportIS::Tags::POLICY_INSTALLATION
-        );
-
-        log.addToOrigin(LogField("eventTopic", "Central NGINX Management"));
-        log << LogField("notificationId", "4165c3b1-e9bc-44c3-888b-863e204c1bfb");
-        log << LogField("eventRemediation", "No action required");
     }
 
     I_MainLoop *i_mainloop = nullptr;

components/security_apps/orchestration/details_resolver/details_resolver.cc

@@ -80,9 +80,7 @@ DetailsResolver::Impl::getHostname()
 Maybe<string>
 DetailsResolver::Impl::getPlatform()
 {
-#if defined(gaia_arm)
+#if defined(gaia)
-    return string("gaia_arm");
-#elif defined(gaia)
     return string("gaia");
 #elif defined(arm32_rpi)
     return string("glibc");

components/security_apps/orchestration/details_resolver/details_resolver_handlers/checkpoint_product_handlers.h

@@ -71,18 +71,7 @@ checkPepIdaIdnStatus(const string &command_output)
 Maybe<string>
 getRequiredNanoServices(const string &command_output)
 {
-    string idaRequiredServices[2] = {"idaSaml", "idaIdn"};
+    return command_output;
-    string platform_str = "gaia";
-#if defined(gaia_arm)
-    platform_str = "gaia_arm";
-#endif // gaia_arm
-    string result = "";
-    for(const string &serv : idaRequiredServices) {
-        string add_service = serv + "_" + platform_str;
-        result = result + add_service + ";";
-    }
-    command_output.empty(); // overcome unused variable
-    return result;
 }
 
 Maybe<string>
@@ -353,28 +342,6 @@ getSMCBasedMgmtName(const string &command_output)
     return getAttr(command_output, "Mgmt object Name was not found");
 }
 
-Maybe<string>
-getSmbObjectUid(const string &command_output)
-{
-    static const char centrally_managed_comd_output = '0';
-
-    if (command_output.empty() || command_output[0] != centrally_managed_comd_output) {
-        return genError("Object UUID was not found");
-    }
-
-    Maybe<string> obj_uuid = getAttrFromCpsdwanGetDataJson("uuid");
-    if (obj_uuid.ok()) {
-        return obj_uuid.unpack();
-    }
-
-    static const string obj_path = (getenv("FWDIR") ? string(getenv("FWDIR")) : "") + "/database/myown.C";
-    auto file_stream = std::make_shared<std::ifstream>(obj_path);
-    if (!file_stream->is_open()) {
-        return genError("Failed to open the object file");
-    }
-    return getMgmtObjAttr(file_stream, "uuid ");
-}
-
 Maybe<string>
 getSmbObjectName(const string &command_output)
 {

components/security_apps/orchestration/details_resolver/details_resolver_handlers/details_resolver_impl.h

@@ -42,6 +42,11 @@ SHELL_PRE_CMD("gunzip local.cfg", "gunzip -c $FWDIR/state/local/FW1/local.cfg.gz
 #ifdef SHELL_CMD_HANDLER
 #if defined(gaia) || defined(smb) || defined(smb_thx_v3) || defined(smb_sve_v2) || defined(smb_mrv_v1)
 SHELL_CMD_HANDLER("cpProductIntegrationMgmtObjectType", "cpprod_util CPPROD_IsMgmtMachine", getMgmtObjType)
+SHELL_CMD_HANDLER(
+    "cpProductIntegrationMgmtObjectUid",
+    "mgmt_cli --format json -r true show-session | jq -r '.[\"connected-server\"].uid'",
+    getMgmtObjUid
+)
 SHELL_CMD_HANDLER("prerequisitesForHorizonTelemetry",
     "FS_PATH=<FILESYSTEM-PREFIX>; [ -f ${FS_PATH}/cp-nano-horizon-telemetry-prerequisites.log ] "
     "&& head -1 ${FS_PATH}/cp-nano-horizon-telemetry-prerequisites.log || echo ''",
@@ -145,17 +150,12 @@ SHELL_CMD_HANDLER("hasSAMLSupportedBlade", "enabled_blades", checkSAMLSupportedB
 SHELL_CMD_HANDLER("hasIDABlade", "enabled_blades", checkIDABlade)
 SHELL_CMD_HANDLER("hasSAMLPortal", "mpclient status nac", checkSAMLPortal)
 SHELL_CMD_HANDLER("hasIdaIdnEnabled", "fw ctl get int nac_pep_identity_next_enabled", checkPepIdaIdnStatus)
-SHELL_CMD_HANDLER("requiredNanoServices", "echo ida", getRequiredNanoServices)
+SHELL_CMD_HANDLER("requiredNanoServices", "echo 'idaSaml_gaia;idaIdn_gaia;'", getRequiredNanoServices)
 SHELL_CMD_HANDLER(
     "cpProductIntegrationMgmtObjectName",
     "mgmt_cli --format json -r true show-session | jq -r '.[\"connected-server\"].name'",
     getMgmtObjName
 )
-SHELL_CMD_HANDLER(
-    "cpProductIntegrationMgmtObjectUid",
-    "mgmt_cli --format json -r true show-session | jq -r '.[\"connected-server\"].uid'",
-    getMgmtObjUid
-)
 SHELL_CMD_HANDLER(
     "cpProductIntegrationMgmtParentObjectName",
     "cat $FWDIR/database/myself_objects.C "
@@ -227,11 +227,6 @@ SHELL_CMD_HANDLER(
     "cpprod_util FwIsLocalMgmt",
     getSmbObjectName
 )
-SHELL_CMD_HANDLER(
-    "cpProductIntegrationMgmtObjectUid",
-    "cpprod_util FwIsLocalMgmt",
-    getSmbObjectUid
-)
 SHELL_CMD_HANDLER(
     "Application Control",
     "cat $FWDIR/conf/active_blades.txt | grep -o 'APCL [01]' | cut -d ' ' -f2",

components/security_apps/orchestration/orchestration_comp.cc

@@ -1470,10 +1470,9 @@ private:
             string cc_opt;
             tie(config_opt, cc_opt, nginx_version) = nginx_data.unpack();
             agent_data_report
-                << make_pair("attachmentVersion", "Legacy")
+                << make_pair("nginxVersion",     nginx_version)
-                << make_pair("nginxVersion",      nginx_version)
+                << make_pair("configureOpt",     config_opt)
-                << make_pair("configureOpt",      config_opt)
+                << make_pair("extraCompilerOpt", cc_opt);
-                << make_pair("extraCompilerOpt",  cc_opt);
         } else {
             dbgDebug(D_ORCHESTRATOR) << nginx_data.getErr();
         }
@@ -1529,7 +1528,7 @@ private:
         } else {
             curr_agent_data_report = agent_data_report;
             curr_agent_data_report.disableReportSending();
-            agent_data_report << AgentReportFieldWithLabel("timestamp", i_time->getWalltimeStr());
+            agent_data_report << AgentReportFieldWithLabel("report_timestamp", i_time->getWalltimeStr());
         }
     }
 

components/security_apps/orchestration/service_controller/service_controller.cc

@@ -208,7 +208,6 @@ ServiceDetails::sendNewConfigurations(int configuration_id, const string &policy
     MessageMetadata new_config_req_md("127.0.0.1", service_port);
     new_config_req_md.setConnectioFlag(MessageConnectionConfig::ONE_TIME_CONN);
     new_config_req_md.setConnectioFlag(MessageConnectionConfig::UNSECURE_CONN);
-    new_config_req_md.setSuspension(false);
     auto res = messaging->sendSyncMessage(
         HTTPMethod::POST,
         "/set-new-configuration",

components/security_apps/waap/waap_clib/DeepParser.cc

@@ -113,9 +113,6 @@ DeepParser::onKv(const char *k, size_t k_len, const char *v, size_t v_len, int f
         << parser_depth
         << " v_len = "
         << v_len;
-
-    dbgTrace(D_WAAP_DEEP_PARSER) << m_key;
-
     // Decide whether to push/pop the value in the keystack.
     bool shouldUpdateKeyStack = (flags & BUFFERED_RECEIVER_F_UNNAMED) == 0;
 
@@ -278,23 +275,13 @@ DeepParser::onKv(const char *k, size_t k_len, const char *v, size_t v_len, int f
     // Detect and decode potential base64 chunks in the value before further processing
 
     bool base64ParamFound = false;
-    size_t base64_offset = 0;
     Waap::Util::BinaryFileType base64BinaryFileType = Waap::Util::BinaryFileType::FILE_TYPE_NONE;
     if (m_depth == 1 && flags == BUFFERED_RECEIVER_F_MIDDLE && m_key.depth() == 1 && m_key.first() != "#base64"){
         dbgTrace(D_WAAP_DEEP_PARSER) << " === will not check base64 since prev data block was not b64-encoded ===";
     } else {
         dbgTrace(D_WAAP_DEEP_PARSER) << " ===Processing potential base64===";
-        if (isUrlPayload && m_depth == 1 && cur_val[0] == '/') {
-            dbgTrace(D_WAAP_DEEP_PARSER) << "removing leading '/' from URL param value";
-            base64_offset = 1;
-        }
         std::string decoded_val, decoded_key;
-        base64_variants base64_status = Waap::Util::b64Test(
+        base64_variants base64_status = Waap::Util::b64Test(cur_val, decoded_key, decoded_val, base64BinaryFileType);
-            cur_val,
-            decoded_key,
-            decoded_val,
-            base64BinaryFileType,
-            base64_offset);
 
         dbgTrace(D_WAAP_DEEP_PARSER)
             << " status = "
@@ -302,50 +289,16 @@ DeepParser::onKv(const char *k, size_t k_len, const char *v, size_t v_len, int f
             << " key = "
             << decoded_key
             << " value = "
-            << decoded_val
+            << decoded_val;
-            << "m_depth = "
-            << m_depth;
 
         switch (base64_status) {
             case SINGLE_B64_CHUNK_CONVERT:
-                if (base64_offset) {
+                cur_val = decoded_val;
-                    cur_val = "/" + decoded_val;
-                } else {
-                    cur_val = decoded_val;
-                }
                 base64ParamFound = true;
                 break;
-            case CONTINUE_DUAL_SCAN:
-                if (decoded_val.size() > 0) {
-                    decoded_key = "#base64";
-                    base64ParamFound = false;
-                    if (base64_offset) {
-                        decoded_val = "/" + decoded_val;
-                    }
-                    dbgTrace(D_WAAP_DEEP_PARSER) << m_key;
-                    rc = onKv(
-                        decoded_key.c_str(),
-                        decoded_key.size(),
-                        decoded_val.data(),
-                        decoded_val.size(),
-                        flags,
-                        parser_depth
-                    );
-                    dbgTrace(D_WAAP_DEEP_PARSER) << "After call to onKv with suspected value rc = " << rc;
-                    dbgTrace(D_WAAP_DEEP_PARSER) << m_key;
-                    break;
-                } else {
-                    dbgTrace(D_WAAP) << "base64 decode suspected and empty value. Skipping.";
-                    base64ParamFound = false;
-                    break;
-                }
-                break;
             case KEY_VALUE_B64_PAIR:
                 // going deep with new pair in case value is not empty
                 if (decoded_val.size() > 0) {
-                    if (base64_offset) {
-                        decoded_key = "/" + decoded_key;
-                    }
                     cur_val = decoded_val;
                     base64ParamFound = true;
                     rc = onKv(
@@ -356,13 +309,9 @@ DeepParser::onKv(const char *k, size_t k_len, const char *v, size_t v_len, int f
                         flags,
                         parser_depth
                     );
-                    dbgTrace(D_WAAP_DEEP_PARSER) << "After call to onKv with suspected value rc = " << rc;
+
-                    dbgTrace(D_WAAP_DEEP_PARSER) << m_key;
+                    dbgTrace(D_WAAP_DEEP_PARSER) << " rc = " << rc;
                     if (rc != CONTINUE_PARSING) {
-                        if (shouldUpdateKeyStack) {
-                            m_key.pop("deep parser key");
-                        }
-                        m_depth--;
                         return rc;
                     }
                 }
@@ -374,7 +323,7 @@ DeepParser::onKv(const char *k, size_t k_len, const char *v, size_t v_len, int f
         }
 
         if (base64ParamFound) {
-            dbgTrace(D_WAAP_DEEP_PARSER) << "pushing #base64 prefix to the key.";
+            dbgTrace(D_WAAP_DEEP_PARSER) << "DeepParser::onKv(): pushing #base64 prefix to the key.";
             m_key.push("#base64", 7, false);
         }
     }
@@ -488,6 +437,7 @@ DeepParser::onKv(const char *k, size_t k_len, const char *v, size_t v_len, int f
             if (shouldUpdateKeyStack) {
                 m_key.pop("deep parser key");
             }
+
             m_depth--;
             return rc;
         }
@@ -637,6 +587,7 @@ DeepParser::parseBuffer(
         if (shouldUpdateKeyStack) {
             m_key.pop("deep parser key");
         }
+
         m_depth--;
         return DONE_PARSING;
     }
@@ -958,6 +909,7 @@ DeepParser::parseAfterMisleadingMultipartBoundaryCleaned(
             return rc;
         }
     }
+
     return rc;
 }
 
@@ -1129,7 +1081,7 @@ DeepParser::createInternalParser(
         << " isBodyPayload = "
         << isBodyPayload;
     //Detect sensor_data format in body and just use dedicated filter for it
-    if ((m_depth == 1)
+    if (m_depth == 1
         && isBodyPayload
         && Waap::Util::detectKnownSource(cur_val) ==  Waap::Util::SOURCE_TYPE_SENSOR_DATA) {
         m_parsersDeque.push_back(

components/security_apps/waap/waap_clib/KeyStack.cc

@@ -37,24 +37,14 @@ void KeyStack::push(const char* subkey, size_t subkeySize, bool countDepth) {
         m_nameDepth++;
     }
 
-    dbgTrace(D_WAAP)
+    dbgTrace(D_WAAP) << "KeyStack(" << m_name << ")::push(): '" << std::string(subkey, subkeySize) <<
-        << "KeyStack("
+        "' => full_key='" << std::string(m_key.data(), m_key.size()) << "'";
-        << m_name
-        << ")::push(): '"
-        << std::string(subkey, subkeySize)
-        << "' => full_key='"
-        << std::string(m_key.data(), m_key.size())
-        << "'";
 }
 
 void KeyStack::pop(const char* log, bool countDepth) {
     // Keep depth balanced even if m_key[] buffer is full
     if (m_key.empty() || m_stack.empty()) {
-        dbgDebug(D_WAAP)
+        dbgDebug(D_WAAP) << "KeyStack(" << m_name << ")::pop(): [ERROR] ATTEMPT TO POP FROM EMPTY KEY STACK! " << log;
-            << "KeyStack("
-            << m_name
-            << ")::pop(): [ERROR] ATTEMPT TO POP FROM EMPTY KEY STACK! "
-            << log;
         return;
     }
 
@@ -65,22 +55,6 @@ void KeyStack::pop(const char* log, bool countDepth) {
     // Remove last subkey.
     m_key.erase(m_stack.back());
     m_stack.pop_back();
-    dbgTrace(D_WAAP)
+    dbgTrace(D_WAAP) << "KeyStack(" << m_name << ")::pop(): full_key='" <<
-        << "KeyStack("
+        std::string(m_key.data(), (int)m_key.size()) << "': pop_key=" << log << "'";
-        << m_name
-        << ")::pop(): full_key='"
-        << std::string(m_key.data(), (int)m_key.size())
-        << "': pop_key="
-        << log
-        << "'";
-}
-
-void KeyStack::print(std::ostream &os) const
-{
-    os
-        << "KeyStack("
-        << m_name
-        << ")::show(): full_key='"
-        << std::string(m_key.data(), (int)m_key.size())
-        << "'";
 }

components/security_apps/waap/waap_clib/KeyStack.h

@@ -28,7 +28,6 @@ public:
     void pop(const char* log, bool countDepth=true);
     bool empty() const { return m_key.empty(); }
     void clear() { m_key.clear(); m_stack.clear(); }
-    void print(std::ostream &os) const;
     size_t depth() const { return m_nameDepth; }
     size_t size() const {
         return str().size();

components/security_apps/waap/waap_clib/ParserBase.cc

@@ -111,7 +111,8 @@ int BufferedReceiver::onKvDone()
     // This must be called even if m_value is empty in order to signal the BUFFERED_RECEIVER_F_LAST flag to the
     // receiver!
     dbgTrace(D_WAAP_PARSER)
-        << " Call onKv on the remainder of the buffer not yet pushed to the receiver calling onKv()";
+        << " Call onKv on the remainder of the buffer not yet pushed to the receiver "
+        << "calling onKv()";
     int rc = onKv(m_key.data(), m_key.size(), m_value.data(), m_value.size(), m_flags, m_parser_depth);
 
     // Reset the object's state to allow reuse for other parsers

components/security_apps/waap/waap_clib/ParserPDF.cc

@@ -21,7 +21,6 @@ USE_DEBUG_FLAG(D_WAAP);
 
 const std::string ParserPDF::m_parserName = "ParserPDF";
 const char* PDF_TAIL = "%%EOF";
-const size_t PDF_TAIL_LEN = 5;
 
 ParserPDF::ParserPDF(
     IParserStreamReceiver &receiver,
@@ -45,21 +44,16 @@ ParserPDF::push(const char *buf, size_t len)
         << "' len="
         << len;
 
+    const char *c;
+
     if (m_state == s_error) {
         return 0;
     }
-
+    if (len == 0)
-    if (len == 0) {
+    {
         dbgTrace(D_WAAP_PARSER_PDF) << "ParserPDF::push(): end of stream. m_state=" << m_state;
-        if (m_state == s_body && m_tailOffset >= PDF_TAIL_LEN) {
+
-            if (m_receiver.onKey("PDF", 3) != 0) {
+        if (m_state == s_end) {
-                m_state = s_error;
-                return 0;
-            }
-            if (m_receiver.onValue("", 0) != 0) {
-                m_state = s_error;
-                return 0;
-            }
             m_receiver.onKvDone();
         } else {
             m_state = s_error;
@@ -67,43 +61,38 @@ ParserPDF::push(const char *buf, size_t len)
         return 0;
     }
 
-    size_t start = (len > MAX_PDF_TAIL_LOOKUP) ? len - MAX_PDF_TAIL_LOOKUP : 0;
     switch (m_state) {
             case s_start:
                 m_state = s_body;
                 CP_FALL_THROUGH;
             case s_body:
-                for (size_t i = start; i < len; i++) {
+                {
+                    size_t tail_lookup_offset = (len > MAX_PDF_TAIL_LOOKUP) ? len - MAX_PDF_TAIL_LOOKUP : 0;
+                    c = strstr(buf + tail_lookup_offset, PDF_TAIL);
                     dbgTrace(D_WAAP_PARSER_PDF)
-                        << "ParserPDF::push(): m_tailOffset="
+                        << "string to search: " << std::string(buf + tail_lookup_offset)
-                        << m_tailOffset
+                        << " c=" << c;
-                        << " buf[i]="
+                    if (c) {
-                        << buf[i];
+                        m_state = s_end;
-                    if (m_tailOffset  <= PDF_TAIL_LEN - 1) {
+                        CP_FALL_THROUGH;
-                        if (buf[i] == PDF_TAIL[m_tailOffset]) {
-                            m_tailOffset++;
-                        } else {
-                            m_tailOffset = 0;
-                        }
                     } else {
-                        if (buf[i] == '\r' || buf[i] == '\n' || buf[i] == ' ' || buf[i] == 0) {
+                        break;
-                            m_tailOffset++;
-                        } else {
-                            m_tailOffset = 0;
-                            i--;
-                        }
                     }
                 }
-                dbgTrace(D_WAAP_PARSER_PDF)
+            case s_end:
-                    << "ParserPDF::push()->s_body: m_tailOffset="
+                if (m_receiver.onKey("PDF", 3) != 0) {
-                    << m_tailOffset;
+                    m_state = s_error;
+                    return 0;
+                }
+                if (m_receiver.onValue("", 0) != 0) {
+                    m_state = s_error;
+                    return 0;
+                }
                 break;
             case s_error:
                 break;
             default:
-                dbgTrace(D_WAAP_PARSER_PDF)
+                dbgTrace(D_WAAP_PARSER_PDF) << "ParserPDF::push(): unknown state: " << m_state;
-                    << "ParserPDF::push(): unknown state: "
-                    << m_state;
                 m_state = s_error;
                 return 0;
     }

components/security_apps/waap/waap_clib/ParserPDF.h

@@ -34,6 +34,7 @@ private:
     enum state {
         s_start,
         s_body,
+        s_end,
         s_error
     };
 
@@ -41,7 +42,6 @@ private:
     enum state m_state;
     static const std::string m_parserName;
     size_t m_parser_depth;
-    size_t m_tailOffset = 0;
 };
 
 #endif // __PARSER_PDF_H__

components/security_apps/waap/waap_clib/Serializator.cc

@@ -617,17 +617,6 @@ void SerializeToLocalAndRemoteSyncBase::setInterval(ch::seconds newInterval)
 
 bool SerializeToLocalAndRemoteSyncBase::localSyncAndProcess()
 {
-    bool isBackupSyncEnabled = getProfileAgentSettingWithDefault<bool>(
-        true,
-        "appsecLearningSettings.backupLocalSync");
-
-    if (!isBackupSyncEnabled) {
-        dbgInfo(D_WAAP_CONFIDENCE_CALCULATOR) << "Local sync is disabled";
-        processData();
-        saveData();
-        return true;
-    }
-
     RemoteFilesList rawDataFiles;
 
     dbgTrace(D_WAAP_CONFIDENCE_CALCULATOR) << "Getting files of all agents";

components/security_apps/waap/waap_clib/WaapScores.cc

@@ -97,9 +97,7 @@ calcIndividualKeywords(
     std::sort(keywords.begin(), keywords.end());
 
     for (auto pKeyword = keywords.begin(); pKeyword != keywords.end(); ++pKeyword) {
-        addKeywordScore(
+        addKeywordScore(scoreBuilder, poolName, *pKeyword, 2.0f, 0.3f, scoresArray, coefArray);
-            scoreBuilder, poolName, *pKeyword, DEFAULT_KEYWORD_SCORE, DEFAULT_KEYWORD_COEF, scoresArray, coefArray
-        );
     }
 }
 
@@ -114,6 +112,8 @@ calcCombinations(
     std::vector<std::string>& keyword_combinations)
 {
     keyword_combinations.clear();
+    static const double max_combi_score = 1.0f;
+    double default_coef = 0.8f;
 
     for (size_t i = 0; i < keyword_matches.size(); ++i) {
         std::vector<std::string> combinations;
@@ -137,10 +137,8 @@ calcCombinations(
                 default_score += scoreBuilder.getSnapshotKeywordScore(*it, 0.0f, poolName);
             }
             // set default combination score to be the sum of its keywords, bounded by 1
-            default_score = std::min(default_score, DEFAULT_COMBI_SCORE);
+            default_score = std::min(default_score, max_combi_score);
-            addKeywordScore(
+            addKeywordScore(scoreBuilder, poolName, combination, default_score, default_coef, scoresArray, coefArray);
-                scoreBuilder, poolName, combination, default_score, DEFAULT_COMBI_COEF, scoresArray, coefArray
-            );
             keyword_combinations.push_back(combination);
         }
     }
@@ -157,7 +155,7 @@ calcArrayScore(std::vector<double>& scoreArray)
                                                     // *pScore is always positive and there's a +10 offset
         score = 10.0f - left * 10.0f / divisor;
     }
-    dbgDebug(D_WAAP_SCORE_BUILDER) << "calculated score: " << score;
+    dbgTrace(D_WAAP_SCORE_BUILDER) << "calculated score: " << score;
     return score;
 }
 
@@ -173,9 +171,7 @@ calcLogisticRegressionScore(std::vector<double> &coefArray, double intercept, do
     }
     // Apply the expit function to the log-odds to obtain the probability,
     // and multiply by 10 to obtain a 'score' in the range [0, 10]
-    double score = 1.0f / (1.0f + exp(-log_odds)) * 10.0f;
+    return 1.0f / (1.0f + exp(-log_odds)) * 10.0f;
-    dbgDebug(D_WAAP_SCORE_BUILDER) << "calculated score (log_odds): " << score << " (" << log_odds << ")";
-    return score;
 }
 
 }

components/security_apps/waap/waap_clib/WaapScores.h

@@ -32,11 +32,6 @@ struct ModelLoggingSettings {
     bool logToStream;
 };
 
-static const double DEFAULT_KEYWORD_COEF = 0.3f;
-static const double DEFAULT_KEYWORD_SCORE = 2.0f;
-static const double DEFAULT_COMBI_COEF = 0.8f;
-static const double DEFAULT_COMBI_SCORE = 1.0f;
-
 std::string getScorePoolNameByLocation(const std::string &location);
 std::string getOtherScorePoolName();
 ModelLoggingSettings getModelLoggingSettings();

components/security_apps/waap/waap_clib/Waf2Engine.cc

@@ -40,7 +40,6 @@
 #include "WaapOpenRedirectPolicy.h"
 #include "WaapErrorDisclosurePolicy.h"
 #include <boost/algorithm/string.hpp>
-#include <boost/regex.hpp>
 #include "generic_rulebase/parameters_config.h"
 #include <iostream>
 #include "ParserDelimiter.h"
@@ -1391,20 +1390,6 @@ Waf2Transaction::findHtmlTagToInject(const char* data, int data_len, int& pos)
         size_t tagHistPosCheck = m_tagHistPos;
         for (size_t i=0; i < tagSize; ++i) {
             if (tag[i] != ::tolower(m_tagHist[tagHistPosCheck])) {
-                if (i == tagSize - 1 && m_tagHist[tagHistPosCheck] == ' ') {
-                    // match regex on head element with attributes
-                    string dataStr = Waap::Util::charToString(data + pos, data_len - pos);
-                    dataStr = dataStr.substr(0, dataStr.find('>')+1);
-                    tagMatches = NGEN::Regex::regexMatch(
-                        __FILE__,
-                        __LINE__,
-                        dataStr,
-                        boost::regex("(?:\\s+[a-zA-Z_:][-a-zA-Z0-9_:.]*(?:\\s*=\\s*(\"[^\"]*\"|'[^']*'|[^\\s\"'>]*))?)*\\s*>")
-                        );
-                        pos += dataStr.length() - 1;
-                        dbgTrace(D_WAAP_BOT_PROTECTION) << "matching head element with attributes: " << dataStr << ". match: " << tagMatches;
-                    break;
-                }
                 tagMatches = false;
                 break;
             }
@@ -1418,8 +1403,12 @@ Waf2Transaction::findHtmlTagToInject(const char* data, int data_len, int& pos)
         }
     }
 
-    dbgTrace(D_WAAP_BOT_PROTECTION) << "head element tag found: " << headFound;
+    if(!headFound)
-    return headFound;
+    {
+        return false;
+    }
+
+    return true;
 }
 
 void
@@ -1588,8 +1577,6 @@ Waf2Transaction::decideFinal(
         dbgTrace(D_WAAP) << "Waf2Transaction::decideFinal(): got relevant API configuration from the I/S";
         sitePolicy = &ngenAPIConfig;
         m_overrideState = getOverrideState(sitePolicy);
-
-        // User limits
         shouldBlock = (getUserLimitVerdict() == ngx_http_cp_verdict_e::TRAFFIC_VERDICT_DROP);
     }
     else if (WaapConfigApplication::getWaapSiteConfig(ngenSiteConfig)) {
@@ -2335,11 +2322,10 @@ bool Waf2Transaction::decideResponse()
 
 bool
 Waf2Transaction::reportScanResult(const Waf2ScanResult &res) {
-    if ((get_ignoreScore() || res.score >= SCORE_THRESHOLD) &&
+    if (get_ignoreScore() || (res.score >= SCORE_THRESHOLD &&
-        (m_scanResult == nullptr || res.score > m_scanResult->score))
+        (m_scanResult == nullptr || res.score > m_scanResult->score)))
     {
-        dbgTrace(D_WAAP) << "Setting scan result. New score: " << res.score;
+        // Forget any previous scan result and replace with new
-        // Forget any previous scan result and replace wit, h new
         delete m_scanResult;
         m_scanResult = new Waf2ScanResult(res);
         return true;

components/security_apps/waap/waap_clib/Waf2Util.cc

@@ -952,145 +952,6 @@ string filterUTF7(const string& text) {
     return result;
 }
 
-//  Decides the status of a Base64 decoded string based on various parameters.
-//  @param decoded The decoded string.
-//  @param entropy The entropy of the original encoded string.
-//  @param decoded_entropy The entropy of the decoded string.
-//  @param spacer_count The number of spacer characters in the decoded string.
-//  @param nonPrintableCharsCount The count of non-printable characters in the decoded string.
-//  @param clear_on_error Flag indicating whether to clear the decoded string on error.
-//  @param terminatorCharsSeen The number of terminator characters seen.
-//  @param called_with_prefix Flag indicating if the function was called with a prefix.
-//  @return The status of the Base64 decoding process.
-//
-//  Idea:
-//  Check if input chunk should be replaced by decoded, suspected to be checked both as encoded and decoded
-//  or cleaned as binary data. Additional case - define as not base64 encoded.
-//  - in case decoded size less 5 - return invalid
-//  - check entropy delta based on that base64 encoded data has higher entropy than decoded, usually delta = 0.25
-//  - this check should rize suspect but cannot work vice versa
-//  check if decoded chunk has more than 10% of non-printable characters - this is supect for binary data encoded
-//   - if no suspect for binary data and entropy is suspected, check empiric conditions to decide if this binary data
-//     or invalid decoding
-//   - if suspect for binary data, first check is we have entropy suspection
-//     - if entropy is suspected and chunk is short and it have more than 25% of nonprintables, return invalid
-//       since this is not base64 encoded data
-//     - if entropy is not suspected and chunk is short and it have more than 50% of nonprintables, return invalid
-//       since this is not base64 encoded data
-//     - if entropy is suspected and chunk size is between 64-1024, perform additional empiric test
-//       This test will define if  returm value should be treated as suspected or as binary data(cleared)
-
-base64_decode_status decideStatusBase64Decoded(
-    string& decoded,
-    double entropy,
-    double decoded_entropy,
-    size_t spacer_count,
-    size_t nonPrintableCharsCount,
-    bool clear_on_error,
-    double terminatorCharsSeen,
-    bool called_with_prefix
-)
-{
-    base64_decode_status tmp_status = B64_DECODE_OK;
-    if (entropy - decoded_entropy + terminatorCharsSeen < BASE64_ENTROPY_THRESHOLD_DELTA) {
-        dbgTrace(D_WAAP_BASE64)
-            << "The chunk is under suspect to be base64,"
-            << "use dual processing because entropy delta is too low";
-        tmp_status = B64_DECODE_SUSPECTED;
-    }
-
-    bool empiric_condition = false;
-    if (decoded.size() >= 5) {
-        if (spacer_count > 1) {
-            nonPrintableCharsCount = nonPrintableCharsCount - spacer_count + 1;
-        }
-        dbgTrace(D_WAAP_BASE64)
-                << "(before test for unprintables):  decoded.size="
-                << decoded.size()
-                << ", nonPrintableCharsCount="
-                << nonPrintableCharsCount
-                << ", clear_on_error="
-                << clear_on_error
-                << ", called_with_prefix="
-                << called_with_prefix;
-        if (nonPrintableCharsCount * 10 < decoded.size()) {
-            dbgTrace(D_WAAP_BASE64)
-                << "(decode/replace due  to small amount of nonprintables): will decide based on entropy values";
-        } else { // more than 10% of non-printable characters
-            dbgTrace(D_WAAP_BASE64) << "large amount of nonporintables";
-            if (tmp_status == B64_DECODE_SUSPECTED) {
-                // entropy - decoded_entropy + terminatorCharsSeen < 0.25
-                if (decoded.size() < 16 &&  nonPrintableCharsCount * 4 > decoded.size())  {
-                    decoded.clear();
-                    return B64_DECODE_INVALID;
-                }
-                dbgTrace(D_WAAP_BASE64)
-                    << "(large amount of nonporintables + entropy suspect), check emprirics because decoded."
-                    << " terminatorCharsSeen="
-                    << terminatorCharsSeen;
-                    // empiric test based on investigation of real payloads
-                empiric_condition = entropy < decoded_entropy
-                    && entropy > BASE64_ENTROPY_BASE_THRESHOLD
-                    && decoded_entropy > BASE64_ENTROPY_DECODED_THRESHOLD
-                    && !called_with_prefix
-                    && decoded.size() > BASE64_MIN_SIZE_LIMIT
-                    && decoded.size() < BASE64_MAX_SIZE_LIMIT
-                    && terminatorCharsSeen != 0;
-                if (!empiric_condition) {
-                    if (clear_on_error) decoded.clear();
-                    return B64_DECODE_SUSPECTED;
-                } else {
-                    if (clear_on_error) decoded.clear();
-                    tmp_status = B64_DECODE_OK;
-                }
-            } else { // entropy - decoded_entropy + terminatorCharsSeen >= 0.25
-                // one more empiric based on uT and real payloads
-                if (decoded.size() < 16
-                        && nonPrintableCharsCount * 2 > decoded.size()
-                        && terminatorCharsSeen == 0) {
-                    decoded.clear();
-                    return B64_DECODE_INVALID;
-                }
-                dbgTrace(D_WAAP_BASE64)
-                    << "(delete as binary content) because decoded. Return B64_DECODE_INCOMPLETE";
-                if (clear_on_error) decoded.clear();
-                return B64_DECODE_INCOMPLETE;
-            }
-        } // less than 10% of non-printable characters
-        dbgTrace(D_WAAP_BASE64)
-            << "After handling unprintables checking status";
-        if (tmp_status == B64_DECODE_OK) {
-            dbgTrace(D_WAAP_BASE64) <<  "replacing with decoded data, return B64_DECODE_OK";
-            return B64_DECODE_OK;
-        } else { // tmp_status == B64_DECODE_SUSPECTED, entropy - decoded_entropy + terminatorCharsSeen < 0.25
-            dbgTrace(D_WAAP_BASE64) << "Suspected due to entropy, making empiric test";
-            // and one more empiric test based on investigation of real payloads
-            empiric_condition = entropy < decoded_entropy
-                && entropy > BASE64_ENTROPY_BASE_THRESHOLD
-                && decoded_entropy > BASE64_ENTROPY_DECODED_THRESHOLD
-                && !called_with_prefix
-                && decoded.size() > BASE64_MIN_SIZE_LIMIT
-                && decoded.size() < BASE64_MAX_SIZE_LIMIT;
-            if (empiric_condition) {
-                dbgTrace(D_WAAP_BASE64) << "Empiric test failed, non-base64 chunk, return B64_DECODE_INVALID";
-                decoded.clear();
-                return B64_DECODE_INVALID;
-            }
-            dbgTrace(D_WAAP_BASE64) << "Empiric test passed, return B64_DECODE_SUSPECTED";
-            return B64_DECODE_SUSPECTED;
-        }
-        return B64_DECODE_OK; // successfully decoded. Returns decoded data in "decoded" parameter
-    }
-
-    // If decoded size is too small - leave the encoded value (return false)
-    decoded.clear(); // discard partial data
-    dbgTrace(D_WAAP_BASE64)
-        << "(leave as-is) because decoded too small. decoded.size="
-        << decoded.size();
-    return B64_DECODE_INVALID;
-}
-
-
 // Attempts to validate and decode base64-encoded chunk.
 // Value is the full value inside which potential base64-encoded chunk was found,
 // it and end point to start and end of that chunk.
@@ -1119,28 +980,18 @@ base64_decode_status decodeBase64Chunk(
     uint32_t spacer_count = 0;
     uint32_t length = end - it;
 
-    dbgTrace(D_WAAP)
+    dbgTrace(D_WAAP) << "decodeBase64Chunk: value='" << value << "' match='" << string(it, end) << "'";
-        << "value='"
-        << value
-        << "' match='"
-        << string(it, end)
-        << "' clear_on_error='"
-        << clear_on_error
-        << "' called_with_prefix='"
-        << called_with_prefix
-        << "'";
     string::const_iterator begin = it;
 
     // The encoded data length (without the "base64," prefix) should be exactly divisible by 4
     // len % 4 is not 0 i.e. this is not base64
-        if ((end - it) % 4 == 1) {
+        if ((end - it) % 4 != 0) {
-            dbgTrace(D_WAAP_BASE64)
+            dbgTrace(D_WAAP_BASE64) <<
-                << "(leave as-is) because encoded data length should not be <4*x + 1>.";
+                "b64DecodeChunk: (leave as-is) because encoded data length should be exactly divisible by 4.";
             return B64_DECODE_INVALID;
         }
 
-        std::unordered_map<char, double> original_occurences_counter;
+        std::unordered_map<char, double> frequency;
-        std::unordered_map<char, double> decoded_occurences_counter;
 
         while (it != end) {
             unsigned char c = *it;
@@ -1148,8 +999,9 @@ base64_decode_status decodeBase64Chunk(
             if (terminatorCharsSeen) {
                 // terminator characters must all be '=', until end of match.
                 if (c != '=') {
-                    dbgTrace(D_WAAP_BASE64)
+                    dbgTrace(D_WAAP_BASE64) <<
-                    << "(leave as-is) because terminator characters must all be '=' until end of match.";
+                        "decodeBase64Chunk: (leave as-is) because terminator characters must all be '='," <<
+                        "until end of match.";
                     return B64_DECODE_INVALID;
                 }
 
@@ -1157,13 +1009,13 @@ base64_decode_status decodeBase64Chunk(
                 terminatorCharsSeen++;
 
                 if (terminatorCharsSeen > 2) {
-                    dbgTrace(D_WAAP_BASE64) << "(leave as-is) because terminatorCharsSeen > 2";
+                    dbgTrace(D_WAAP_BASE64) << "decodeBase64Chunk: (leave as-is) because terminatorCharsSeen > 2";
                     return B64_DECODE_INVALID;
                 }
 
                 // allow for more terminator characters
                 it++;
-                original_occurences_counter[c]++;
+                frequency[c]++;
                 continue;
             }
 
@@ -1188,18 +1040,12 @@ base64_decode_status decodeBase64Chunk(
                 // Start tracking terminator characters
                 terminatorCharsSeen++;
                 it++;
-                original_occurences_counter[c]++;
+                frequency[c]++;
                 continue;
             }
             else {
-                dbgTrace(D_WAAP_BASE64)
+                dbgTrace(D_WAAP_BASE64) << "decodeBase64Chunk: (leave as-is) because of non-base64 character ('" <<
-                    << "(leave as-is) because of non-base64 character ('"
+                        c << "', ASCII " << (unsigned int)c << ", offset " << (it-begin) << ")";
-                    << c
-                    << "', ASCII "
-                    << (unsigned int)c
-                    << ", offset "
-                    << (it-begin)
-                    << ")";
                 return B64_DECODE_INVALID; // non-base64 character
             }
 
@@ -1222,19 +1068,18 @@ base64_decode_status decodeBase64Chunk(
                 }
 
                 decoded += (char)code;
-                decoded_occurences_counter[(char)code]++;
             }
 
             it++;
-            original_occurences_counter[c]++;
+            frequency[c]++;
         }
 
         // end of encoded sequence decoded.
 
         dbgTrace(D_WAAP_BASE64)
-            << "decoding done: decoded.size="
+            << "decodeBase64Chunk: decoded.size="
             << decoded.size()
-            << ", uncorrected nonPrintableCharsCount="
+            << ", nonPrintableCharsCount="
             << nonPrintableCharsCount
             << ", spacer_count = "
             << spacer_count
@@ -1243,42 +1088,56 @@ base64_decode_status decodeBase64Chunk(
             << "; decoded='"
             << decoded << "'";
 
-        double entropy = 0;
+        // Check if entropy is correlates with b64 threshold (initially > 4.5)
-        double p = 0;
+        if (!called_with_prefix) {
-        double decoded_entropy = 0;
+            double entropy = 0;
-        for (const auto& pair : original_occurences_counter) {
+            double p = 0;
-            p = pair.second / length;
+            for (const auto& pair : frequency) {
-            entropy -= p * std::log2(p);
+                p = pair.second / length;
+                entropy -= p * std::log2(p);
+            }
+            dbgTrace(D_WAAP_BASE64) << " ===b64Test===:  base entropy = " << entropy << "length = " << length;
+            // Add short payload factor
+            if (length < 16)
+                entropy = entropy * 16 / length;
+            // Enforce tailoring '=' characters
+            entropy+=terminatorCharsSeen;
+
+            dbgTrace(D_WAAP_BASE64) << " ===b64Test===:  corrected entropy = " << entropy << "length = " << length;
+            if (entropy <= base64_entropy_threshold) {
+                return B64_DECODE_INVALID;
+            }
         }
-        for (const auto &pair : decoded_occurences_counter) {
+
-            p = pair.second / decoded.size();
+        // Return success only if decoded.size>=5 and there are less than 10% of non-printable
-            decoded_entropy -= p * std::log2(p);
+        // characters in output.
+        if (decoded.size() >= 5) {
+            if (spacer_count > 1) {
+                nonPrintableCharsCount = nonPrintableCharsCount - spacer_count + 1;
+            }
+            if (nonPrintableCharsCount * 10 < decoded.size()) {
+                dbgTrace(D_WAAP_BASE64) << "decodeBase64Chunk: (decode/replace) decoded.size=" << decoded.size() <<
+                        ", nonPrintableCharsCount=" << nonPrintableCharsCount << ": replacing with decoded data";
+            }
+            else {
+                dbgTrace(D_WAAP_BASE64) << "decodeBase64Chunk: (delete) because decoded.size=" << decoded.size() <<
+                        ", nonPrintableCharsCount=" << nonPrintableCharsCount <<
+                        ", clear_on_error=" << clear_on_error;
+                if (clear_on_error) decoded.clear();
+                return B64_DECODE_INCOMPLETE;
+            }
+            dbgTrace(D_WAAP_BASE64) << "returning true: successfully decoded."
+                << " Returns decoded data in \"decoded\" parameter";
+            return B64_DECODE_OK; // successfully decoded. Returns decoded data in "decoded" parameter
         }
-        dbgTrace(D_WAAP_BASE64)
-            << "Base entropy = "
-            << entropy
-            << " Decoded_entropy = "
-            << decoded_entropy
-            << "length = "
-            << length;
-
-        base64_decode_status return_status = decideStatusBase64Decoded(
-            decoded,
-            entropy,
-            decoded_entropy,
-            spacer_count,
-            nonPrintableCharsCount,
-            clear_on_error,
-            terminatorCharsSeen,
-            called_with_prefix
-        );
-
-        dbgTrace(D_WAAP_BASE64)
-            << "After decideStatusBase64Decoded return_status="
-            << return_status;
-
-        return return_status;
 
+        // If decoded size is too small - leave the encoded value (return false)
+        decoded.clear(); // discard partial data
+        dbgTrace(D_WAAP_BASE64) << "decodeBase64Chunk: (leave as-is) because decoded too small. decoded.size=" <<
+                decoded.size() <<
+                ", nonPrintableCharsCount=" << nonPrintableCharsCount <<
+                ", clear_on_error=" << clear_on_error;
+        return B64_DECODE_INVALID;
 }
 
 // Attempts to detect and validate base64 chunk.
@@ -1321,9 +1180,8 @@ b64DecodeChunk(
             return false;
         }
     }
-    base64_decode_status status = decodeBase64Chunk(value, it, end, decoded);
+
-    dbgTrace(D_WAAP_BASE64) << "b64DecodeChunk: status = " << status;
+    return decodeBase64Chunk(value, it, end, decoded) != B64_DECODE_INVALID;
-    return status != B64_DECODE_INVALID;
 }
 
 vector<string> split(const string& s, char delim) {
@@ -1423,7 +1281,6 @@ static void b64TestChunk(const string &s,
         int &deletedCount,
         string &outStr)
 {
-    dbgTrace(D_WAAP_BASE64) << " ===b64TestChunk===:  starting with = '" << s << "'";
     size_t chunkLen = (chunkEnd - chunkStart);
 
     if ((chunkEnd - chunkStart) > static_cast<int>(b64_prefix.size()) &&
@@ -1432,9 +1289,11 @@ static void b64TestChunk(const string &s,
         chunkLen -= b64_prefix.size();
     }
 
+    size_t chunkRem = chunkLen % 4;
+
+    // Only match chunk whose length is divisible by 4
     string repl;
-    dbgTrace(D_WAAP_BASE64) << " ===b64TestChunk===:  chunkLen = " << chunkLen;
+    if (chunkRem == 0 && cb(s, chunkStart, chunkEnd, repl)) {
-    if (cb(s, chunkStart, chunkEnd, repl)) {
         // Succesfully matched b64 chunk
         if (!repl.empty()) {
             outStr += repl;
@@ -1481,7 +1340,9 @@ bool detectBase64Chunk(
         dbgTrace(D_WAAP_BASE64) << " ===detectBase64Chunk===:  isB64AlphaChar = true, '" << *it << "'";
         start = it;
         end = s.end();
-        return true;
+        if ((end - start) % 4 == 0) {
+            return true;
+        }
     }
     // non base64 before supposed chunk - will not process
     return false;
@@ -1520,31 +1381,17 @@ bool isBase64PrefixProcessingOK (
         if (detectBase64Chunk(s, start, end)) {
             dbgTrace(D_WAAP_BASE64) << " ===isBase64PrefixProcessingOK===: chunk detected";
             if ((start != s.end()) && (end == s.end())) {
-                dbgTrace(D_WAAP_BASE64) << " ===isBase64PrefixProcessingOK===: chunk detected but not complete";
                 retVal = processDecodedChunk(s, start, end, value, binaryFileType, true);
-                dbgTrace(D_WAAP_BASE64)
-                    << " ===isBase64PrefixProcessingOK===: after processDecodedChunk retVal = "
-                    << retVal
-                    << " binaryFileType = "
-                    << binaryFileType;
             }
         } else if (start != s.end()) {
-            dbgTrace(D_WAAP_BASE64)
+            dbgTrace(D_WAAP_BASE64) << " ===isBase64PrefixProcessingOK===: chunk not detected."
-                << " ===isBase64PrefixProcessingOK===: chunk not detected. searching for known file header only";
+                                        " searching for known file header only";
             end = (start + MAX_HEADER_LOOKUP < s.end()) ? start + MAX_HEADER_LOOKUP : s.end();
             processDecodedChunk(s, start, end, value, binaryFileType);
             value.clear();
-            dbgTrace(D_WAAP_BASE64)
-                << " ===isBase64PrefixProcessingOK===: after processDecodedChunk binaryFileType = "
-                << binaryFileType;
             return binaryFileType != Waap::Util::BinaryFileType::FILE_TYPE_NONE;
         }
     }
-    dbgTrace(D_WAAP_BASE64)
-        << " ===isBase64PrefixProcessingOK===: retVal = "
-        << retVal
-        << " binaryFileType = "
-        << binaryFileType;
     return retVal != B64_DECODE_INVALID;
 }
 
@@ -1552,31 +1399,23 @@ base64_variants b64Test (
         const string &s,
         string &key,
         string &value,
-        BinaryFileType &binaryFileType,
+        BinaryFileType &binaryFileType)
-        const size_t offset)
 {
 
     key.clear();
+    bool retVal;
     binaryFileType = Waap::Util::BinaryFileType::FILE_TYPE_NONE;
-    auto begin = s.begin() + offset;
-    dbgTrace(D_WAAP_BASE64)
-        << " ===b64Test===: string =  "
-        << s
-        << " key = "
-        << key
-        << " value = "
-        << value
-        << " offset = "
-        << offset;
 
+    dbgTrace(D_WAAP_BASE64) << " ===b64Test===: string =  " << s
+            << " key = " << key << " value = " << value;
     // Minimal length
-    if (s.size() < 8 + offset) {
+    if (s.size() < 8) {
         return CONTINUE_AS_IS;
     }
     dbgTrace(D_WAAP_BASE64) << " ===b64Test===: minimal lenght test passed";
 
     std::string prefix_decoded_val;
-    auto it = begin;
+    string::const_iterator it = s.begin();
 
     // 1st check if we have key candidate
     if (base64_key_value_detector_re.hasMatch(s)) {
@@ -1594,7 +1433,7 @@ base64_variants b64Test (
                 break;
             case EQUAL:
                 if (*it == '=') {
-                    it = begin;
+                    it = s.begin();
                     state=MISDETECT;
                     continue;
                 }
@@ -1616,7 +1455,7 @@ base64_variants b64Test (
         if (it == s.end() || state == MISDETECT) {
             dbgTrace(D_WAAP_BASE64) << " ===b64Test===: detected  *it = s.end()" << *it;
             if (key.size() > 0) {
-                it = begin;
+                it = s.begin();
                 key.clear();
             }
         } else {
@@ -1640,7 +1479,7 @@ base64_variants b64Test (
         }
     }
 
-    auto start = s.end();
+    string::const_iterator start = s.end();
     dbgTrace(D_WAAP_BASE64) << " ===b64Test===:  B64 itself = " << *it << " =======";
     bool isB64AlphaChar = Waap::Util::isAlphaAsciiFast(*it) || isdigit(*it) || *it=='/' || *it=='+';
     if (isB64AlphaChar) {
@@ -1648,6 +1487,11 @@ base64_variants b64Test (
         dbgTrace(D_WAAP_BASE64) <<
             " ===b64Test===:  Start tracking potential b64 chunk = " << *it << " =======";
         start = it;
+        if ((s.end() - start) % 4 != 0) {
+            key.clear();
+            value.clear();
+            return CONTINUE_AS_IS;
+        }
     }
     else {
         dbgTrace(D_WAAP_BASE64) <<
@@ -1668,37 +1512,17 @@ base64_variants b64Test (
             key.pop_back();
             dbgTrace(D_WAAP_BASE64) << " ===b64Test===: FINAL key = '" << key << "'";
         }
-        base64_decode_status decode_chunk_status = decodeBase64Chunk(s, start, s.end(), value);
+        retVal = decodeBase64Chunk(s, start, s.end(), value) != B64_DECODE_INVALID;
 
-        dbgTrace(D_WAAP_BASE64)
+        dbgTrace(D_WAAP_BASE64) << " ===b64Test===: After testing and conversion value = "
-            << " ===b64Test===: After testing and conversion value = "
+                << value << "retVal = '" << retVal <<"'";
-            << value
+        if (!retVal) {
-            << "decode_chunk_status = '"
-            << decode_chunk_status
-            <<"'";
-        if (decode_chunk_status == B64_DECODE_INVALID) {
             key.clear();
             value.clear();
             return CONTINUE_AS_IS;
         }
-
+        dbgTrace(D_WAAP_BASE64) << " ===b64Test===: After tpassed retVal check = "
-        if (decode_chunk_status == B64_DECODE_INCOMPLETE) {
+            << value << "retVal = '" << retVal <<"'" << "key = '" << key << "'";
-                value.clear();
-        }
-
-        if (decode_chunk_status == B64_DECODE_SUSPECTED) {
-            return CONTINUE_DUAL_SCAN;
-        }
-
-        dbgTrace(D_WAAP_BASE64)
-            << " ===b64Test===: After tpassed retVal check = "
-            << value
-            << "decode_chunk_status = '"
-            << decode_chunk_status
-            <<"'"
-            << "key = '"
-            << key
-            << "'";
         if (key.empty()) {
             return SINGLE_B64_CHUNK_CONVERT;
         } else {
@@ -1724,7 +1548,7 @@ void b64Decode(
     deletedCount = 0;
     outStr = "";
     int offsetFix = 0;
-    dbgTrace(D_WAAP_BASE64) << " ===b64Decode===:  starting with = '" << s << "'";
+
     string::const_iterator it = s.begin();
 
     // Minimal length
@@ -1772,11 +1596,6 @@ void b64Decode(
                 }
 
                 // Decode and add chunk
-                dbgTrace(D_WAAP_BASE64)
-                    << " ===b64Decode===:  chunkStart = "
-                    << *chunkStart
-                    << " it = "
-                    << *it;
                 b64TestChunk(s, chunkStart, it, cb, decodedCount, deletedCount, outStr);
 
                 // stop tracking b64 chunk
@@ -1788,7 +1607,6 @@ void b64Decode(
     }
 
     if (chunkStart != s.end()) {
-        dbgTrace(D_WAAP_BASE64) << " ===b64Decode===:  chunkStart = " << *chunkStart;
         b64TestChunk(s, chunkStart, it, cb, decodedCount, deletedCount, outStr);
     }
 }

components/security_apps/waap/waap_clib/Waf2Util.h

@@ -32,15 +32,9 @@
 
 #define GCC_VERSION (__GNUC__ * 10000 + __GNUC_MINOR__ * 100 + __GNUC_PATCHLEVEL__)
 
-enum base64_variants {SINGLE_B64_CHUNK_CONVERT, KEY_VALUE_B64_PAIR, CONTINUE_AS_IS, CONTINUE_DUAL_SCAN};
+enum base64_variants {SINGLE_B64_CHUNK_CONVERT, KEY_VALUE_B64_PAIR, CONTINUE_AS_IS};
 enum base64_stage {BEFORE_EQUAL, EQUAL, DONE, MISDETECT};
-enum base64_decode_status {B64_DECODE_INVALID, B64_DECODE_OK, B64_DECODE_INCOMPLETE, B64_DECODE_SUSPECTED};
+enum base64_decode_status {B64_DECODE_INVALID, B64_DECODE_OK, B64_DECODE_INCOMPLETE};
-
-#define BASE64_ENTROPY_BASE_THRESHOLD 5.0
-#define BASE64_ENTROPY_DECODED_THRESHOLD 5.4
-#define BASE64_ENTROPY_THRESHOLD_DELTA 0.25
-#define BASE64_MIN_SIZE_LIMIT 16
-#define BASE64_MAX_SIZE_LIMIT 1024
 
 // This is portable version of stricmp(), which is non-standard function (not even in C).
 // Contrary to stricmp(), for a slight optimization, s2 is ASSUMED to be already in lowercase.
@@ -871,17 +865,6 @@ void unescapeUnicode(std::string &text);
 // Try to find and decode UTF7 chunks
 std::string filterUTF7(const std::string &text);
 
-base64_decode_status
-decideStatusBase64Decoded(
-    std::string& decoded,
-    double entropy,
-    double decoded_entropy,
-    size_t spacer_count,
-    size_t nonPrintableCharsCount,
-    bool clear_on_error,
-    double terminatorCharsSeen,
-    bool called_with_prefix);
-
 base64_decode_status
 decodeBase64Chunk(
     const std::string &value,
@@ -943,8 +926,7 @@ namespace Util {
             const std::string &s,
             std::string &key,
             std::string &value,
-            BinaryFileType &binaryFileType,
+            BinaryFileType &binaryFileType);
-            size_t offset = 0);
 
     // The original stdlib implementation of isalpha() supports locale settings which we do not really need.
     // It is also proven to contribute to slow performance in some of the algorithms using it.

components/utils/nginx_utils/nginx_utils.cc

@@ -20,7 +20,6 @@
 #include <vector>
 #include <dirent.h>
 #include <boost/regex.hpp>
-#include <algorithm>
 
 #include "debug.h"
 #include "maybe_res.h"
@@ -76,13 +75,13 @@ NginxConfCollector::expandIncludes(const string &include_pattern) const {
     struct dirent *entry;
     while ((entry = readdir(dir)) != nullptr) {
         if (strcmp(entry->d_name, ".") == 0 || strcmp(entry->d_name, "..") == 0) continue;
+
         if (NGEN::Regex::regexMatch(__FILE__, __LINE__, entry->d_name, pattern)) {
             matching_files.push_back(maybe_directory + "/" + entry->d_name);
             dbgTrace(D_NGINX_MANAGER) << "Matched file: " << maybe_directory << '/' << entry->d_name;
         }
     }
     closedir(dir);
-    sort(matching_files.begin(), matching_files.end());
 
     return matching_files;
 }

config/crds/open-appsec-crd-v1beta1.yaml

@@ -1,4 +1,4 @@
-apiVersion: apiextensions.k8s.io/v1
+Enter file contents hereapiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata :
   name : customresponses.openappsec.io

config/crds/open-appsec-crd-v1beta2.yaml

@@ -137,10 +137,6 @@ spec:
                   type: array
                   items:
                     type: object
-                    required:
-                    - mode
-                    - threatPreventionPractices
-                    - accessControlPractices
                     properties:
                       name:
                         type: string
@@ -1177,929 +1173,3 @@ spec:
     kind: TrustedSource
     shortNames:
       - trustedsource
-
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name: policyactivations.openappsec.io
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              properties:
-                appsecClassName:
-                  type: string
-                enabledPolicies:
-                  type: array
-                  items:
-                    type: object
-                    properties:
-                      name:
-                        type: string
-                      hosts:
-                        type: array
-                        items:
-                          type: string
-                    required:
-                      - hosts
-              required:
-                - enabledPolicies
-  scope: Cluster
-  names:
-    plural: policyactivations
-    singular: policyactivation
-    kind: PolicyActivation
-    shortNames:
-      - policyactivation
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name : policiesns.openappsec.io
-  creationTimestamp: null
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              properties:
-                appsecClassName:
-                  type: string
-                default:
-                  type: object
-                  required:
-                    - mode
-                    - threatPreventionPractices
-                    - accessControlPractices
-                  properties:
-                    mode:
-                      type: string
-                      enum:
-                        - prevent-learn
-                        - detect-learn
-                        - prevent
-                        - detect
-                        - inactive
-                      default: detect-learn
-                    threatPreventionPractices:
-                      type: array
-                      items:
-                        type: string
-                    accessControlPractices:
-                      type: array
-                      items:
-                        type: string
-                    customResponse:
-                      type: string
-                      default: "403"
-                    triggers:
-                      type: array
-                      items:
-                        type: string
-                    sourceIdentifiers:
-                      type: string
-                    trustedSources:
-                      type: string
-                    exceptions:
-                      type: array
-                      items:
-                        type: string
-                specificRules:
-                  type: array
-                  items:
-                    type: object
-                    properties:
-                      name:
-                        type: string
-                      host:
-                        type: string
-                      mode:
-                        type: string
-                        enum:
-                          - prevent-learn
-                          - detect-learn
-                          - prevent
-                          - detect
-                          - inactive
-                        default: detect-learn
-                      threatPreventionPractices:
-                        type: array
-                        items:
-                          type: string
-                      accessControlPractices:
-                        type: array
-                        items:
-                          type: string
-                      triggers:
-                        type: array
-                        items:
-                          type: string
-                      customResponse:
-                        type: string
-                      sourceIdentifiers:
-                        type: string
-                      trustedSources:
-                        type: string
-                      exceptions:
-                        type: array
-                        items:
-                          type: string
-
-  scope: Namespaced
-  names:
-    plural: policiesns
-    singular: policyns
-    kind: PolicyNS
-    shortNames:
-      - policyns
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name : accesscontrolpracticesns.openappsec.io
-  creationTimestamp: null
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              required:
-                - rateLimit
-              properties:
-                appsecClassName:
-                  type: string
-                practiceMode:
-                  type: string
-                  enum:
-                    - inherited
-                    - prevent
-                    - detect
-                    - inactive
-                  default: inherited
-                rateLimit:
-                  type: object
-                  required:
-                    - overrideMode
-                  properties:
-                    overrideMode:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inactive
-                    rules:
-                      type: array
-                      items:
-                        type: object
-                        properties:
-                          action:
-                            type: string
-                            enum:
-                              - inherited
-                              - prevent
-                              - detect
-                            default: inherited
-                          condition:
-                            type: array
-                            items:
-                              type: object
-                              required:
-                                - key
-                                - value
-                              properties:
-                                key:
-                                  type: string
-                                value:
-                                  type: string
-                          uri:
-                            type: string
-                          limit:
-                            type: integer
-                          unit:
-                            type: string
-                            enum:
-                              - minute
-                              - second
-                            default: minute
-                          triggers:
-                            type: array
-                            items:
-                              type: string
-                          comment:
-                            type: string
-  scope: Namespaced
-  names:
-    plural: accesscontrolpracticesns
-    singular: accesscontrolpracticens
-    kind: AccessControlPracticeNS
-    shortNames:
-      - acpns
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata:
-  name : customresponsesns.openappsec.io
-  creationTimestamp: null
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              required:
-                - mode
-              properties:
-                appsecClassName:
-                  type: string
-                mode:
-                  type: string
-                  enum:
-                    - block-page
-                    - redirect
-                    - response-code-only
-                  default: response-code-only
-                messageTitle:
-                  type: string
-                messageBody:
-                  type: string
-                httpResponseCode:
-                  type: integer
-                  minimum: 100
-                  maximum: 599
-                  default: 403
-                redirectUrl:
-                  type: string
-                redirectAddXEventId:
-                  type: boolean
-                  default: false
-              required:
-                - mode
-  scope: Namespaced
-  names:
-    plural: customresponsesns
-    singular: customresponsens
-    kind: CustomResponseNS
-    shortNames:
-      - customresponsens
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name: exceptionsns.openappsec.io
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              required:
-                - action
-                - condition
-              properties:
-                appsecClassName:
-                  type: string
-                action:
-                  type: string
-                  enum:
-                    - skip
-                    - accept
-                    - drop
-                    - suppressLog
-                  default: accept
-                condition:
-                  type: array
-                  items:
-                    type: object
-                    required:
-                      - key
-                      - value
-                    properties:
-                      key:
-                        type: string
-                      value:
-                        type: string
-  scope: Namespaced
-  names:
-    plural: exceptionsns
-    singular: exceptionns
-    kind: ExceptionNS
-    shortNames:
-      - exceptionns
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name : logtriggersns.openappsec.io
-  creationTimestamp: null
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              required:
-                - accessControlLogging
-                - appsecLogging
-                - additionalSuspiciousEventsLogging
-                - extendedLogging
-                - logDestination
-              properties:
-                appsecClassName:
-                  type: string
-                accessControlLogging:
-                  type: object
-                  properties:
-                    allowEvents:
-                      type: boolean
-                      default: false
-                    dropEvents:
-                      type: boolean
-                      default: true
-                appsecLogging:
-                  type: object
-                  properties:
-                    detectEvents:
-                      type: boolean
-                      default: true
-                    preventEvents:
-                      type: boolean
-                      default: true
-                    allWebRequests:
-                      type: boolean
-                      default: false
-                additionalSuspiciousEventsLogging:
-                  type: object
-                  properties:
-                    enabled:
-                      type: boolean
-                      default: true
-                    minSeverity:
-                      type: string
-                      enum:
-                        - high
-                        - critical
-                      default: high
-                    responseBody:
-                      type: boolean
-                      default: false
-                    responseCode:
-                      type: boolean
-                      default: true
-                extendedLogging:
-                  type: object
-                  properties:
-                    urlPath:
-                      type: boolean
-                      default: false
-                    urlQuery:
-                      type: boolean
-                      default: false
-                    httpHeaders:
-                      type: boolean
-                      default: false
-                    requestBody:
-                      type: boolean
-                      default: false
-                logDestination:
-                  type: object
-                  properties:
-                    cloud:
-                      type: boolean
-                      default: false
-                    syslogService:
-                      type: array
-                      items:
-                        type: object
-                        properties:
-                          address:
-                            type: string
-                          port:
-                            type: integer
-                    logToAgent:
-                      type: boolean
-                      default: true
-                    stdout:
-                      type: object
-                      properties:
-                        format:
-                          type: string
-                          enum:
-                            - json
-                            - json-formatted
-                          default: json
-                    local-tuning:
-                      type: boolean
-                    cefService:
-                      type: array
-                      items:
-                        type: object
-                        properties:
-                          address:
-                            type: string
-                          port:
-                            type: integer
-                          proto:
-                            type: string
-                            enum:
-                              - tcp
-                              - udp
-  scope: Namespaced
-  names:
-    plural: logtriggersns
-    singular: logtriggerns
-    kind: LogTriggerNS
-    shortNames:
-      - logtriggerns
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name : sourcesidentifiersns.openappsec.io
-  creationTimestamp: null
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              properties:
-              type: object
-              required:
-                - sourcesIdentifiers
-              properties:
-                appsecClassName:
-                  type: string
-                sourcesIdentifiers:
-                  type: array
-                  items:
-                    type: object
-                    required:
-                      - identifier
-                    properties:
-                      identifier:
-                        type: string
-                        enum:
-                          - headerkey
-                          - JWTKey
-                          - cookie
-                          - sourceip
-                          - x-forwarded-for
-                        default: sourceip
-                      value:
-                        type: array
-                        items:
-                          type: string
-  scope: Namespaced
-  names:
-    plural: sourcesidentifiersns
-    singular: sourcesidentifierns
-    kind: SourcesIdentifierNS
-    shortNames:
-      - sourcesidentifierns
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name : threatpreventionpracticesns.openappsec.io
-  creationTimestamp: null
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              required:
-                - webAttacks
-                - intrusionPrevention
-                - fileSecurity
-                - snortSignatures
-              properties:
-                appsecClassName:
-                  type: string
-                practiceMode:
-                  type: string
-                  enum:
-                    - inherited
-                    - prevent-learn
-                    - detect-learn
-                    - prevent
-                    - detect
-                    - inactive
-                  default: inherited
-                webAttacks:
-                  type: object
-                  required:
-                    - overrideMode
-                  properties:
-                    overrideMode:
-                      type: string
-                      enum:
-                        - prevent-learn
-                        - detect-learn
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inactive
-                    minimumConfidence:
-                      type: string
-                      enum:
-                        - medium
-                        - high
-                        - critical
-                      default: high
-                    maxUrlSizeBytes:
-                      type: integer
-                      default: 32768
-                    maxObjectDepth:
-                      type: integer
-                      default: 40
-                    maxBodySizeKb:
-                      type: integer
-                      default: 1000000
-                    maxHeaderSizeBytes:
-                      type: integer
-                      default: 102400
-                    protections:
-                      type: object
-                      properties:
-                        csrfProtection:
-                          type: string
-                          enum:
-                            - prevent-learn
-                            - detect-learn
-                            - prevent
-                            - detect
-                            - inactive
-                            - inherited
-                          default: inactive
-                        errorDisclosure:
-                          type: string
-                          enum:
-                            - prevent-learn
-                            - detect-learn
-                            - prevent
-                            - detect
-                            - inactive
-                            - inherited
-                          default: inactive
-                        openRedirect:
-                          type: string
-                          enum:
-                            - prevent-learn
-                            - detect-learn
-                            - prevent
-                            - detect
-                            - inactive
-                            - inherited
-                          default: inactive
-                        nonValidHttpMethods:
-                          type: boolean
-                          default: false
-                antiBot:
-                  type: object
-                  required:
-                    - overrideMode
-                  properties:
-                    overrideMode:
-                      type: string
-                      enum:
-                        - prevent-learn
-                        - detect-learn
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inactive
-                    injectedUris:
-                      type: array
-                      items:
-                        type: object
-                        properties:
-                          uri:
-                            type: string
-                    validatedUris:
-                      type: array
-                      items:
-                        type: object
-                        properties:
-                          uri:
-                            type: string
-                snortSignatures:
-                  type: object
-                  required:
-                    - overrideMode
-                  properties:
-                    overrideMode:
-                      type: string
-                      enum:
-                        - prevent-learn
-                        - detect-learn
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inactive
-                    configmap:
-                      type: array
-                      items:
-                        type: string
-                    files:
-                      type: array
-                      items:
-                        type: string
-                schemaValidation:
-                  type: object
-                  required:
-                    - overrideMode
-                  properties:
-                    overrideMode:
-                      type: string
-                      enum:
-                        - prevent-learn
-                        - detect-learn
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inactive
-                    enforcementLevel:
-                      type: string
-                    configmap:
-                      type: array
-                      items:
-                        type: string
-                    files:
-                      type: array
-                      items:
-                        type: string
-                intrusionPrevention:
-                  type: object
-                  required:
-                    - overrideMode
-                  properties:
-                    overrideMode:
-                      type: string
-                      enum:
-                        - prevent-learn
-                        - detect-learn
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inactive
-                    maxPerformanceImpact:
-                      type: string
-                      enum:
-                        - low
-                        - medium
-                        - high
-                      default: medium
-                    minSeverityLevel:
-                      type: string
-                      enum:
-                        - low
-                        - medium
-                        - high
-                        - critical
-                      default: medium
-                    minCveYear:
-                      type: integer
-                      default: 2016
-                    highConfidenceEventAction:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inherited
-                    mediumConfidenceEventAction:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inherited
-                    lowConfidenceEventAction:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: detect
-                fileSecurity:
-                  type: object
-                  required:
-                    - overrideMode
-                  properties:
-                    overrideMode:
-                      type: string
-                      enum:
-                        - prevent-learn
-                        - detect-learn
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inactive
-                    minSeverityLevel:
-                      type: string
-                      enum:
-                        - low
-                        - medium
-                        - high
-                        - critical
-                      default: medium
-                    highConfidenceEventAction:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inherited
-                    mediumConfidenceEventAction:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inherited
-                    lowConfidenceEventAction:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: detect
-                    archiveInspection:
-                      type: object
-                      properties:
-                        extractArchiveFiles:
-                          type: boolean
-                          default: false
-                        scanMaxFileSize:
-                          type: integer
-                          default: 10
-                        scanMaxFileSizeUnit:
-                          type: string
-                          enum:
-                            - bytes
-                            - KB
-                            - MB
-                            - GB
-                          default: MB
-                        archivedFilesWithinArchivedFiles:
-                          type: string
-                          enum:
-                            - prevent
-                            - detect
-                            - inactive
-                            - inherited
-                          default: inherited
-                        archivedFilesWhereContentExtractionFailed:
-                          type: string
-                          enum:
-                            - prevent
-                            - detect
-                            - inactive
-                            - inherited
-                          default: inherited
-                    largeFileInspection:
-                      type: object
-                      properties:
-                        fileSizeLimit:
-                          type: integer
-                          default: 10
-                        fileSizeLimitUnit:
-                          type: string
-                          enum:
-                            - bytes
-                            - KB
-                            - MB
-                            - GB
-                          default: MB
-                        filesExceedingSizeLimitAction:
-                          type: string
-                          enum:
-                            - prevent
-                            - detect
-                            - inactive
-                            - inherited
-                          default: inherited
-                    unnamedFilesAction:
-                      type: string
-                      enum:
-                        - prevent
-                        - detect
-                        - inactive
-                        - inherited
-                      default: inherited
-                    threatEmulationEnabled:
-                      type: boolean
-                      default: false
-  scope: Namespaced
-  names:
-    plural: threatpreventionpracticesns
-    singular: threatpreventionpracticens
-    kind: ThreatPreventionPracticeNS
-    shortNames:
-      - tppns
----
-apiVersion: apiextensions.k8s.io/v1
-kind: CustomResourceDefinition
-metadata :
-  name : trustedsourcesns.openappsec.io
-  creationTimestamp: null
-spec:
-  group: openappsec.io
-  versions:
-    - name: v1beta2
-      served: true
-      storage: true
-      schema:
-        openAPIV3Schema:
-          type: object
-          properties:
-            spec:
-              type: object
-              required:
-                - minNumOfSources
-                - sourcesIdentifiers
-              properties:
-                appsecClassName:
-                  type: string
-                minNumOfSources:
-                  type: integer
-                  default: 3
-                sourcesIdentifiers:
-                  type: array
-                  items:
-                    type: string
-  scope: Namespaced
-  names:
-    plural: trustedsourcesns
-    singular: trustedsourcens
-    kind: TrustedSourceNS
-    shortNames:
-      - trustedsourcens

config/k8s/v1beta1/open-appsec-k8s-default-config-v1beta1.yaml

@@ -11,58 +11,3 @@ spec:
         source-identifiers: ""
         trusted-sources: ""
         exceptions: []
----
-apiVersion: openappsec.io/v1beta1
-kind: LogTrigger
-metadata:
-    name: appsec-log-trigger
-spec:
-    access-control-logging:
-        allow-events: false
-        drop-events: true
-    appsec-logging:
-        detect-events: false
-        prevent-events: true
-        all-web-requests: false
-    additional-suspicious-events-logging:
-        enabled: true
-        minimum-severity: high
-        response-body: false
-    extended-logging:
-        url-path: false
-        url-query: false
-        http-headers: false
-        request-body: false
-    log-destination:
-        cloud: true
-        syslog-service: []
-        file: ""
-        stdout:
-            format: json
-        cef-service: []
---
-apiVersion: openappsec.io/v1beta1
-kind: Practice
-metadata:
-  name: appsec-best-practice
-spec:
-  anti-bot:
-    injected-URIs: []
-    validated-URIs: []
-  openapi-schema-validation:
-    configmap: []
-  snort-signatures:
-    configmap: []
-  web-attacks:
-    minimum-confidence: high
-    override-mode: detect-learn
---
-apiVersion: openappsec.io/v1beta1
-kind: CustomResponse
-metadata:
-  name: 403-forbidden
-spec:
-  http-response-code: 403
-  message-body: ""
-  message-title: ""
-  mode: response-code-only

config/k8s/v1beta1/open-appsec-k8s-prevent-config-v1beta1.yaml

@@ -11,58 +11,3 @@ spec:
         source-identifiers: ""
         trusted-sources: ""
         exceptions: []
----
-apiVersion: openappsec.io/v1beta1
-kind: LogTrigger
-metadata:
-    name: appsec-log-trigger
-spec:
-    access-control-logging:
-        allow-events: false
-        drop-events: true
-    appsec-logging:
-        detect-events: false
-        prevent-events: true
-        all-web-requests: false
-    additional-suspicious-events-logging:
-        enabled: true
-        minimum-severity: high
-        response-body: false
-    extended-logging:
-        url-path: false
-        url-query: false
-        http-headers: false
-        request-body: false
-    log-destination:
-        cloud: true
-        syslog-service: []
-        file: ""
-        stdout:
-            format: json
-        cef-service: []
---
-apiVersion: openappsec.io/v1beta1
-kind: Practice
-metadata:
-  name: appsec-best-practice
-spec:
-  anti-bot:
-    injected-URIs: []
-    validated-URIs: []
-  openapi-schema-validation:
-    configmap: []
-  snort-signatures:
-    configmap: []
-  web-attacks:
-    minimum-confidence: high
-    override-mode: prevent-learn
---
-apiVersion: openappsec.io/v1beta1
-kind: CustomResponse
-metadata:
-  name: 403-forbidden
-spec:
-  http-response-code: 403
-  message-body: ""
-  message-title: ""
-  mode: response-code-only

config/k8s/v1beta2/open-appsec-k8s-default-config-v1beta2.yaml

@@ -17,6 +17,16 @@ spec:
     customResponse: default-web-user-response
     triggers:
     - default-log-trigger
+  specificRules:
+    - host: www.example.com
+      # this is an example for specific rule, adjust the values as required for the protected app
+      mode: detect-learn
+      threatPreventionPractices:
+      - default-threat-prevention-practice
+      accessControlPractices:
+      - default-access-control-practice
+      triggers:
+      - default-log-trigger
 ---
 apiVersion: openappsec.io/v1beta2
 kind: ThreatPreventionPractice
@@ -102,7 +112,7 @@ spec:
     responseCode: true
   logDestination:
     cloud: true
-    logToAgent: true
+    logToAgent: false
     stdout:
       format: json
     

config/k8s/v1beta2/open-appsec-k8s-prevent-config-v1beta2.yaml

@@ -17,6 +17,16 @@ spec:
     customResponse: default-web-user-response
     triggers:
     - default-log-trigger
+  specificRules:
+    - host: www.example.com
+      # this is an example for specific rule, adjust the values as required for the protected app
+      mode: prevent-learn
+      threatPreventionPractices:
+      - default-threat-prevention-practice
+      accessControlPractices:
+      - default-access-control-practice
+      triggers:
+      - default-log-trigger
 ---
 apiVersion: openappsec.io/v1beta2
 kind: ThreatPreventionPractice

config/linux/v1beta2/example/local_policy.yaml

@@ -1,113 +0,0 @@
-apiVersion: v1beta2
-
-policies:
-  default:
-    mode: detect-learn
-    accessControlPractices: [access-control-practice-example]
-    threatPreventionPractices: [threat-prevention-practice-example]
-    triggers: [log-trigger-example]
-    customResponse: web-user-response-exmaple
-    sourceIdentifiers: ""
-    trustedSources: ""
-    exceptions:
-      - exception-example
-  specificRules:
-    - host: "example.com"
-      mode: prevent-learn
-      threatPreventionPractices: [threat-prevention-practice-example]
-      accessControlPractices: [access-control-practice-example]
-      triggers: [log-trigger-example]
-      customResponse: web-user-response-exmaple
-      sourceIdentifiers: ""
-      trustedSources: ""
-      exceptions:
-        - exception-example
-
-threatPreventionPractices:
-  - name: threat-prevention-practice-example
-    practiceMode: inherited
-    webAttacks:
-      overrideMode: inherited
-      minimumConfidence: high
-    intrusionPrevention:
-    # intrusion prevention (IPS) requires "Premium Edition"
-      overrideMode: inherited
-      maxPerformanceImpact: medium
-      minSeverityLevel: medium
-      minCveYear: 2016
-      highConfidenceEventAction: inherited
-      mediumConfidenceEventAction: inherited
-      lowConfidenceEventAction: detect
-    fileSecurity:
-    # file security requires "Premium Edition"
-      overrideMode: inherited
-      minSeverityLevel: medium
-      highConfidenceEventAction: inherited
-      mediumConfidenceEventAction: inherited
-      lowConfidenceEventAction: detect
-    snortSignatures:
-      # you must specify snort signatures in configmap or file to activate snort inspection
-      overrideMode: inherited
-      configmap: []
-      # relevant for deployments on kubernetes
-      # 0 or 1 configmaps supported in array
-      files: []
-      # relevant for docker and linux embedded deployments
-      # 0 or 1 files supported in array
-    schemaValidation: # schema validation requires "Premium Edition" 
-      overrideMode: inherited
-      configmap: []
-      # relevant for deployments on kubernetes
-      # 0 or 1 configmaps supported in array
-      files: []
-      # relevant for docker and linux embedded deployments
-      # 0 or 1 files supported in array
-    antiBot: # antibot requires "Premium Edition" 
-      overrideMode: inherited
-      injectedUris: []
-      validatedUris: []
-
-accessControlPractices:
-  - name: access-control-practice-example
-    practiceMode: inherited
-    rateLimit:
-    # specify one or more rules below to use rate limiting
-      overrideMode: inherited
-      rules: []
-
-customResponses:
-  - name: web-user-response-exmaple
-    mode: response-code-only
-    httpResponseCode: 403
-
-logTriggers:
-  - name: log-trigger-example
-    accessControlLogging:
-      allowEvents: false
-      dropEvents: true
-    appsecLogging:
-      detectEvents: true
-      preventEvents: true
-      allWebRequests: false
-    extendedLogging:
-      urlPath: true
-      urlQuery: true
-      httpHeaders: false
-      requestBody: false
-    additionalSuspiciousEventsLogging:
-      enabled: true
-      minSeverity: high
-      responseBody: false
-      responseCode: true
-    logDestination:
-      cloud: true
-      logToAgent: false
-      stdout:
-        format: json
-
-exceptions:
-  - name: exception-example
-    action: "accept"
-    condition:
-      - key: "countryCode"
-        value: "US"

core/agent_details/agent_details.cc

@@ -436,7 +436,6 @@ AgentDetails::loadProxyType(const string &proxy_type)
     }
 
 #ifdef gaia
-    (void)proxy_type;
     I_ShellCmd *shell_cmd = Singleton::Consume<I_ShellCmd>::by<AgentDetails>();
     auto proxy_ip = shell_cmd->getExecOutput("dbget proxy:ip-address| tr -d '\n'");
     if (!proxy_ip.ok()) return proxy_ip;

core/config/config.cc

@@ -203,7 +203,6 @@ private:
         MessageMetadata service_config_req_md("127.0.0.1", 7777);
         service_config_req_md.setConnectioFlag(MessageConnectionConfig::ONE_TIME_CONN);
         service_config_req_md.setConnectioFlag(MessageConnectionConfig::UNSECURE_CONN);
-        service_config_req_md.setSuspension(false);
         auto service_config_status = messaging->sendSyncMessage(
             HTTPMethod::POST,
             "/set-nano-service-config",
@@ -215,7 +214,6 @@ private:
             MessageMetadata secondary_port_req_md("127.0.0.1", 7778);
             secondary_port_req_md.setConnectioFlag(MessageConnectionConfig::ONE_TIME_CONN);
             secondary_port_req_md.setConnectioFlag(MessageConnectionConfig::UNSECURE_CONN);
-            secondary_port_req_md.setSuspension(false);
             service_config_status = messaging->sendSyncMessage(
                 HTTPMethod::POST,
                 "/set-nano-service-config",
@@ -253,7 +251,6 @@ private:
         MessageMetadata service_config_req_md("127.0.0.1", 7777);
         service_config_req_md.setConnectioFlag(MessageConnectionConfig::ONE_TIME_CONN);
         service_config_req_md.setConnectioFlag(MessageConnectionConfig::UNSECURE_CONN);
-        service_config_req_md.setSuspension(false);
         bool service_config_status = messaging->sendSyncMessageWithoutResponse(
             HTTPMethod::POST,
             "/set-reconf-status",
@@ -265,7 +262,6 @@ private:
             MessageMetadata secondary_port_req_md("127.0.0.1", 7778);
             secondary_port_req_md.setConnectioFlag(MessageConnectionConfig::ONE_TIME_CONN);
             secondary_port_req_md.setConnectioFlag(MessageConnectionConfig::UNSECURE_CONN);
-            secondary_port_req_md.setSuspension(false);
             service_config_status = messaging->sendSyncMessageWithoutResponse(
                 HTTPMethod::POST,
                 "/set-reconf-status",

core/debug_is/debug.cc

@@ -527,7 +527,7 @@ Debug::preload()
     active_streams["FOG"] = make_shared<DebugFogStream>();
 
     string branch = Version::getBranch();
-    if (branch == "open-source" || branch == "master" || branch.substr(0, 6) == "hotfix") {
+    if (branch == "master" || branch.substr(0, 6) == "hotfix") {
         should_assert_optional = false;
     } else {
         should_assert_optional = true;

core/include/services_sdk/interfaces/messaging/messaging_metadata.h

@@ -69,16 +69,14 @@ public:
         uint16_t _port_num,
         Flags<MessageConnectionConfig> _conn_flags,
         bool _should_buffer = false,
-        bool _is_to_fog = false,
+        bool _is_to_fog = false
-        bool _should_suspend = true
     ) :
         host_name(_host_name),
         port_num(_port_num),
         conn_flags(_conn_flags),
         should_buffer(_should_buffer),
         is_to_fog(_is_to_fog),
-        should_send_access_token(true),
+        should_send_access_token(true)
-        should_suspend(_should_suspend)
     {}
 
     const bool &
@@ -195,12 +193,6 @@ public:
         is_dual_auth = true;
     }
 
-    void
-    setSuspension(bool _should_suspend)
-    {
-        should_suspend = _should_suspend;
-    }
-
     void
     setExternalCertificate(const std::string &_external_certificate)
     {
@@ -219,12 +211,6 @@ public:
         return should_buffer;
     }
 
-    bool
-    shouldSuspend() const
-    {
-        return should_suspend;
-    }
-
     bool
     isProxySet() const
     {
@@ -328,7 +314,6 @@ private:
     bool is_rate_limit_block = false;
     uint rate_limit_block_time = 0;
     bool should_send_access_token = true;
-    bool should_suspend = true;
 };
 
 #endif // __MESSAGING_METADATA_H__

core/intelligence_is_v2/intelligence_request.cc

@@ -22,7 +22,7 @@ using namespace std;
 
 USE_DEBUG_FLAG(D_INTELLIGENCE);
 
-static const unsigned int upper_assets_limit = 200;
+static const unsigned int upper_assets_limit = 50;
 static const unsigned int upper_confidence_limit = 1000;
 
 Maybe<void>

core/messaging/connection/connection.cc

@@ -184,6 +184,18 @@ public:
     establishConnection()
     {
         dbgFlow(D_CONNECTION) << "Establishing a new connection";
+        // check if connection already established
+        I_MainLoop *i_mainloop = Singleton::Consume<I_MainLoop>::by<Messaging>();
+        while (lock) {
+            i_mainloop->yield(true);
+        }
+        lock = true;
+        auto unlock = make_scope_exit([&] () { lock = false; });
+
+        if (is_connected && !should_close_connection) {
+            dbgTrace(D_CONNECTION) << "Connection already established";
+            return Maybe<void>();
+        }
         auto set_socket = setSocket();
         if (!set_socket.ok()) {
             dbgWarning(D_CONNECTION) << "Failed to set socket: " << set_socket.getErr();
@@ -221,6 +233,7 @@ public:
             << (isOverProxy() ? ", Over proxy: " + settings.getProxyHost() + ":" + to_string(key.getPort()) : "");
         active = Maybe<void, chrono::seconds>();
         should_close_connection = false;
+        is_connected = true;
         return Maybe<void>();
     }
 
@@ -583,11 +596,13 @@ private:
 
         if (BIO_should_retry(bio.get())) return string();
 
+        auto fd = BIO_get_fd(bio.get(), nullptr);
+
         char error_buf[256];
         ERR_error_string(ERR_get_error(), error_buf);
         string error = receive_len == 0 ?
-            "Connection closed by peer" :
+            "Connection closed by peer (BIO fd: " + to_string(fd) + "). Error: " + string(error_buf) :
-            "Failed to read data from BIO socket. Error: " + string(error_buf);
+            "Failed to read data from BIO socket (fd: " + to_string(fd) + "). Error: " + string(error_buf);
         dbgWarning(D_CONNECTION) << error;
         return genError(HTTPResponse(HTTPStatusCode::HTTP_UNKNOWN, error));
     }
@@ -621,17 +636,28 @@ private:
     Maybe<HTTPResponse, HTTPResponse>
     sendAndReceiveData(const string &request, bool is_connect)
     {
-        dbgFlow(D_CONNECTION) << "Sending and receiving data";
+        dbgFlow(D_CONNECTION) << "Sending and receiving data, lock: " << lock;
         I_MainLoop *i_mainloop = Singleton::Consume<I_MainLoop>::by<Messaging>();
-        while (lock) {
+        while (lock && !is_connect) {
             i_mainloop->yield(true);
         }
         lock = true;
-        auto unlock = make_scope_exit([&] () { lock = false; });
+        dbgTrace(D_CONNECTION) << "acquire lock";
+        auto unlock = make_scope_exit([&] () {
+            lock = false;
+        });
 
         if (should_close_connection) {
-            dbgWarning(D_CONNECTION) << close_error.getBody();
+            dbgTrace(D_CONNECTION) << "reconnect in progress";
-            return genError(close_error);
+            while (lock) {
+                i_mainloop->yield(true);
+            }
+            if (!is_connected) {
+                dbgWarning(D_CONNECTION) << close_error.getBody();
+                return genError(close_error);
+            }
+            dbgTrace(D_CONNECTION) << "reconnected by other routine";
+            lock = true;
         }
 
         I_TimeGet *i_time = Singleton::Consume<I_TimeGet>::by<Messaging>();
@@ -651,11 +677,13 @@ private:
         dbgTrace(D_CONNECTION) << "Sent the message, now waiting for response";
         while (!http_parser.hasReachedError()) {
             if (i_time->getMonotonicTime() > receiving_end_time) {
+                is_connected = false;
                 should_close_connection = true;
                 return genError(receving_timeout);
             };
             auto receieved = receiveData();
             if (!receieved.ok()) {
+                is_connected = false;
                 should_close_connection = true;
                 return receieved.passErr();
             }
@@ -706,6 +734,7 @@ private:
     bool lock = false;
     bool should_close_connection = false;
     bool is_dual_auth = false;
+    bool is_connected = false;
     Maybe<string> sni_hostname = genError<string>("Uninitialized");
     Maybe<string> dn_host_name = genError<string>("Uninitialized");
 

core/messaging/connection/connection_comp.cc

@@ -92,12 +92,12 @@ private:
             << metadata.getPort();
         MessageConnectionKey conn_key(metadata.getHostName(), metadata.getPort(), category);
         Connection conn(conn_key, metadata);
+        persistent_connections.emplace(conn_key, conn);
 
         const auto &external_certificate = metadata.getExternalCertificate();
         if (!external_certificate.empty()) conn.setExternalCertificate(external_certificate);
 
         auto connected = conn.establishConnection();
-        persistent_connections.emplace(conn_key, conn);
 
         if (!connected.ok()) {
             string connection_err = "Failed to establish connection. Error: " + connected.getErr();

core/messaging/messaging_comp/messaging_comp.cc

@@ -125,9 +125,7 @@ MessagingComp::sendMessage(
     }
 
     Connection conn = maybe_conn.unpack();
-    if (message_metadata.shouldSuspend() && conn.isSuspended()) {
+    if (conn.isSuspended()) return suspendMessage(body, method, uri, category, message_metadata);
-        return suspendMessage(body, method, uri, category, message_metadata);
-    }
 
     bool is_to_fog = isMessageToFog(message_metadata);
     auto metadata = message_metadata;

deployment/apisix/docker-compose.yaml

@@ -37,7 +37,7 @@ services:
     environment:
       # adjust with your own email below
       - user_email=user@email.com
-      - registered_server="APISIX"
+      - registered_server="APISIX Server"
       - AGENT_TOKEN=<TOKEN>
     volumes:
       - ./appsec-config:/etc/cp/conf

deployment/docker-compose/apisix/docker-compose.yaml

@@ -28,7 +28,7 @@ services:
       - user_email=${APPSEC_USER_EMAIL}
       - AGENT_TOKEN=${APPSEC_AGENT_TOKEN}
       - autoPolicyLoad=${APPSEC_AUTO_POLICY_LOAD}
-      - registered_server=APISIX
+      - registered_server=APISIX Server
     ipc: shareable
     restart: unless-stopped
     volumes:

deployment/docker-compose/kong/docker-compose.yaml

@@ -28,7 +28,7 @@ services:
       - user_email=${APPSEC_USER_EMAIL}
       - AGENT_TOKEN=${APPSEC_AGENT_TOKEN}
       - autoPolicyLoad=${APPSEC_AUTO_POLICY_LOAD}
-      - registered_server=Kong
+      - registered_server=Kong Server
     ipc: shareable
     restart: unless-stopped
     volumes:

deployment/docker-compose/nginx/docker-compose.yaml

@@ -28,7 +28,7 @@ services:
       - user_email=${APPSEC_USER_EMAIL}
       - AGENT_TOKEN=${APPSEC_AGENT_TOKEN}
       - autoPolicyLoad=${APPSEC_AUTO_POLICY_LOAD}
-      - registered_server="NGINX"
+      - registered_server="NGINX Server"
     ipc: shareable
     restart: unless-stopped
     volumes:

deployment/docker-compose/swag/docker-compose.yaml

@@ -29,7 +29,7 @@ services:
       - user_email=${APPSEC_USER_EMAIL}
       - AGENT_TOKEN=${APPSEC_AGENT_TOKEN}
       - autoPolicyLoad=${APPSEC_AUTO_POLICY_LOAD}
-      - registered_server=SWAG
+      - registered_server=SWAG Server
     ipc: shareable
     volumes:
       - ${APPSEC_CONFIG}:/etc/cp/conf

deployment/nginx/docker-compose.yaml

@@ -11,7 +11,7 @@ services:
       - user_email=${USER_EMAIL}
     # - AGENT_TOKEN=${APPSEC_AGENT_TOKEN}
       - autoPolicyLoad=${APPSEC_AUTO_POLICY_LOAD}
-      - registered_server="NGINX"
+      - registered_server="NGINX Server"
     ipc: shareable
     volumes:
       - ${APPSEC_CONFIG}:/etc/cp/conf

deployment/swag/docker-compose.yaml

@@ -30,7 +30,7 @@ services:
     restart: unless-stopped
     environment:
       - user_email=user@email.com # adjust with your own email
-      - registered_server="SWAG"
+      - registered_server=SWAG Server
       # if autoPolicyLoad is set to true, open-appsec will apply
       # changes in local_policy.yaml automatically
       - autoPolicyLoad=true

examples/juiceshop/apisix/apisix.yaml

@@ -1,9 +0,0 @@
-routes:
-  -
-    uri: /
-    upstream:
-        nodes:
-            "juiceshop-backend:3000": 1
-        type: roundrobin
-
-#END

examples/juiceshop/envoy/envoy.yaml

@@ -1,56 +0,0 @@
-static_resources:
-  listeners:
-  - name: listener_0
-    address:
-      socket_address:
-        address: 0.0.0.0
-        port_value: 80
-    filter_chains:
-    - filters:
-      - name: envoy.filters.network.http_connection_manager
-        typed_config:
-          "@type": type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager
-          stat_prefix: ingress_http
-          http_filters:
-          ## The following 10 lines are required to load the envoy attachment filter for open-appsec
-          - name: envoy.filters.http.golang
-            typed_config:
-              "@type": type.googleapis.com/envoy.extensions.filters.http.golang.v3alpha.Config
-              library_id: cp_nano_filter
-              library_path: "/usr/lib/libenvoy_attachment.so"
-              plugin_name: cp_nano_filter
-              plugin_config:
-                "@type": type.googleapis.com/xds.type.v3.TypedStruct
-                value:
-                  prefix_localreply_body: "Configured local reply from go"
-          - name: envoy.filters.http.router
-            typed_config:
-              "@type": type.googleapis.com/envoy.extensions.filters.http.router.v3.Router
-
-##
-## The following lines allow you to deploy routing of ingress traffic to the optional juice-shop example container available in the open-appsec docker-compose.yaml file.
-##
-          route_config:
-            name: local_route
-            virtual_hosts:
-            - name: local_service
-              domains: ["*"]
-              routes:
-              - match:
-                  prefix: "/"
-                route:
-                  cluster: juiceshop
-
-  clusters:
-  - name: juiceshop
-    type: STRICT_DNS
-    lb_policy: ROUND_ROBIN
-    load_assignment:
-      cluster_name: juiceshop
-      endpoints:
-      - lb_endpoints:
-        - endpoint:
-            address:
-              socket_address:
-                address: juiceshop-backend
-                port_value: 3000

examples/juiceshop/kong/kong.yml

@@ -1,9 +0,0 @@
-_format_version: "3.0"
-
-services:
-  - name: juiceshop-service
-    url: http://juiceshop-backend:3000
-    routes:
-      - name: juiceshop-route
-        paths:
-          - /

examples/juiceshop/swag/default.conf

@@ -1,84 +0,0 @@
-## Version 2024/07/16 - Changelog: https://github.com/linuxserver/docker-swag/commits/master/root/defaults/nginx/site-confs/default.conf.sample
-
-# redirect all traffic to https
-server {
-    listen 80 default_server;
-    listen [::]:80 default_server;
-
-    location / {
-        return 301 https://$host$request_uri;
-    }
-}
-
-# main server block
-server {
-    listen 443 ssl default_server;
-    listen [::]:443 ssl default_server;
-
-    server_name _;
-
-    include /config/nginx/ssl.conf;
-
-#    root /config/www;
-#    index index.html index.htm index.php;
-
-    # enable subfolder method reverse proxy confs
-    include /config/nginx/proxy-confs/*.subfolder.conf;
-
-    # enable for ldap auth (requires ldap-location.conf in the location block)
-    #include /config/nginx/ldap-server.conf;
-
-    # enable for Authelia (requires authelia-location.conf in the location block)
-    #include /config/nginx/authelia-server.conf;
-
-    # enable for Authentik (requires authentik-location.conf in the location block)
-    #include /config/nginx/authentik-server.conf;
-
-    #location / {
-        # enable for basic auth
-        #auth_basic "Restricted";
-        #auth_basic_user_file /config/nginx/.htpasswd;
-
-        # enable for ldap auth (requires ldap-server.conf in the server block)
-        #include /config/nginx/ldap-location.conf;
-
-        # enable for Authelia (requires authelia-server.conf in the server block)
-        #include /config/nginx/authelia-location.conf;
-
-        # enable for Authentik (requires authentik-server.conf in the server block)
-        #include /config/nginx/authentik-location.conf;
-
-    #    try_files $uri $uri/ /index.html /index.htm /index.php$is_args$args;
-    #}
-
-    location ~ ^(.+\.php)(.*)$ {
-        # enable the next two lines for http auth
-        #auth_basic "Restricted";
-        #auth_basic_user_file /config/nginx/.htpasswd;
-
-        # enable for ldap auth (requires ldap-server.conf in the server block)
-        #include /config/nginx/ldap-location.conf;
-
-        # enable for Authelia (requires authelia-server.conf in the server block)
-        #include /config/nginx/authelia-location.conf;
-
-        # enable for Authentik (requires authentik-server.conf in the server block)
-        #include /config/nginx/authentik-location.conf;
-
-        fastcgi_split_path_info ^(.+\.php)(.*)$;
-        if (!-f $document_root$fastcgi_script_name) { return 404; }
-        fastcgi_pass 127.0.0.1:9000;
-        fastcgi_index index.php;
-        include /etc/nginx/fastcgi_params;
-    }
-
-    # deny access to .htaccess/.htpasswd files
-    location ~ /\.ht {
-        deny all;
-    }
-}
-
-# enable subdomain method reverse proxy confs
-include /config/nginx/proxy-confs/*.subdomain.conf;
-# enable proxy cache for auth
-proxy_cache_path cache/ keys_zone=auth_cache:10m;

examples/juiceshop/swag/juiceshop.subfolder.conf

@@ -1,22 +0,0 @@
-location / {
-    # enable the next two lines for http auth
-    #auth_basic "Restricted";
-    #auth_basic_user_file /config/nginx/.htpasswd;
-
-    # enable for ldap auth (requires ldap-server.conf in the server block)
-    #include /config/nginx/ldap-location.conf;
-
-    # enable for Authelia (requires authelia-server.conf in the server block)
-    #include /config/nginx/authelia-location.conf;
-
-    # enable for Authentik (requires authentik-server.conf in the server block)
-    #include /config/nginx/authentik-location.conf;
-
-    include /config/nginx/proxy.conf;
-    include /config/nginx/resolver.conf;
-    set $upstream_app juiceshop-backend;
-    set $upstream_port 3000;
-    set $upstream_proto http;
-    proxy_pass $upstream_proto://$upstream_app:$upstream_port;
-
-}

nodes/orchestration/package/orchestration_package.sh

@@ -110,14 +110,8 @@ if [ $retval -eq 0 ]; then
 fi
 
 if [ $var_gaia_release -eq 0 ] || [ $var_mds_release -eq 0 ]; then
-    arch=$(uname -a | awk '{print $(NF -1) }')
+    var_arch="gaia"
-    if test "${arch}" == "aarch64"; then
+    var_arch_flag="--gaia"
-        var_arch="gaia_arm"
-        var_arch_flag="--gaia_arm"
-    else
-        var_arch="gaia"
-        var_arch_flag="--gaia"
-    fi
 elif [ $var_alpine_release -eq 0 ]; then
     var_is_alpine=true
 else
@@ -328,7 +322,7 @@ while true; do
             LOG_FILE_PATH=$1
         fi
         echo "Log files path: ${LOG_FILE_PATH}"
-    elif [ "$1" = "--arm64_trustbox" ] || [ "$1" = "--arm64_linaro" ] || [ "$1" = "--arm32_rpi" ] || [ "$1" = "--gaia" ] || [ "$1" = "--gaia_arm" ] || [ "$1" = "--smb_mrv_v1" ] || [ "$1" = "--smb_sve_v2" ] || [ "$1" = "--smb_thx_v3" ] || [ "$1" = "--x86" ] || [ "$1" = "./orchestration_package.sh" ]; then
+    elif [ "$1" = "--arm64_trustbox" ] || [ "$1" = "--arm64_linaro" ] || [ "$1" = "--arm32_rpi" ] || [ "$1" = "--gaia" ] || [ "$1" = "--smb_mrv_v1" ] || [ "$1" = "--smb_sve_v2" ] || [ "$1" = "--smb_thx_v3" ] || [ "$1" = "--x86" ] || [ "$1" = "./orchestration_package.sh" ]; then
         shift
 		continue
     elif [ "$1" = "--skip_registration" ]; then
@@ -422,7 +416,7 @@ if command -v which &>/dev/null; then
     var_which_cmd_exists=1
 fi
 
-if [ $var_arch != "gaia" ] && [ $var_arch != "gaia_arm" ] && [ $var_which_cmd_exists -eq 1 ]; then 
+if [ $var_arch != "gaia" ] && [ $var_which_cmd_exists -eq 1 ]; then
     if [ -n "$(which systemctl)" ]; then
         var_startup_service="systemd"
     else
@@ -496,12 +490,12 @@ cp_copy() # Initials - cc
 
 update_cloudguard_appsec_manifest()
 {
-    if [ -z ${INFINITY_NEXT_NANO_AGENT} ] && { [ -z ${CLOUDGUARD_APPSEC_STANDALONE} ] || [ -z ${DOCKER_RPM_ENABLED} ]; }; then
+    if [ -z ${CLOUDGUARD_APPSEC_STANDALONE} ] || [ -z ${DOCKER_RPM_ENABLED} ]; then
         return
     fi
 
     selected_cloudguard_appsec_manifest_path="${TMP_FOLDER}/cloudguard_appsec_manifest.json"
-    if [ "${DOCKER_RPM_ENABLED}" = "false" ] || [ "${INFINITY_NEXT_NANO_AGENT}" = "TRUE" ]; then
+    if [ "${DOCKER_RPM_ENABLED}" = "false" ]; then
         selected_cloudguard_appsec_manifest_path="${TMP_FOLDER}/self_managed_cloudguard_appsec_manifest.json"
     fi
 
@@ -570,7 +564,7 @@ install_watchdog_gaia()
     # Add cp-nano-watchdog to DB
     dbset process:${watchdog_pm_name} t
     dbset process:${watchdog_pm_name}:path ${FILESYSTEM_PATH}/${WATCHDOG_PATH}
-    dbset process:${watchdog_pm_name}:arg:1 ${var_arch_flag}
+    dbset process:${watchdog_pm_name}:arg:1 --gaia
     dbset process:${watchdog_pm_name}:runlevel 1
     dbset :save
     tellpm ${watchdog_pm_name} t
@@ -622,7 +616,7 @@ install_watchdog()
         cp_copy service/smb/nano_agent.init /storage/nano_agent/etc/nano_agent.init
         chmod +rx /storage/nano_agent/etc/nano_agent.init
     elif [ $var_container_mode = false ]; then
-        if [ $var_arch = "gaia" ] || [ $var_arch = "gaia_arm" ]; then
+        if [ $var_arch = "gaia" ]; then
             cp_exec "ln -s ${FWDIR}/bin/curl_cli ${FWDIR}/bin/curl"
             cp_exec "ln -s ${CPDIR}/bin/cpopenssl ${CPDIR}/bin/openssl"
             cp_copy watchdog/access_pre_init $INIT_D_PATH/access_pre_init
@@ -663,7 +657,7 @@ install_watchdog()
             cp_exec "$INIT_D_PATH/nano_agent.init start"
         elif [ "$is_smb" = "1" ]; then
             cp_exec "/storage/nano_agent/etc/nano_agent.init start"
-        elif [ $var_arch = "gaia" ] || [ $var_arch = "gaia_arm" ]; then
+        elif [ $var_arch = "gaia" ]; then
             install_watchdog_gaia
         else
             cp_exec "service $NANO_AGENT_SERVICE_NAME start"
@@ -791,7 +785,7 @@ upgrade_conf_if_needed()
         cp_exec "cp -f configuration/orchestration.cfg ${FILESYSTEM_PATH}/${SERVICE_PATH}/${ORCHESTRATION_FILE_NAME}.cfg"
         execution_flags="execution_flags=\"--orchestration-mode=${var_orchestration_mode}\""
         echo $execution_flags >> ${FILESYSTEM_PATH}/${SERVICE_PATH}/${ORCHESTRATION_FILE_NAME}.cfg
-        if [ $var_arch = "gaia" -o $var_arch = "gaia_arm" -o "$is_smb" = "1" ]; then
+        if [ $var_arch = "gaia" -o "$is_smb" = "1" ]; then
             if [ -z "${gaia_ld_path}" ]; then
                 gaia_ld_path="${LD_LIBRARY_PATH}"
             fi
@@ -1007,7 +1001,7 @@ install_orchestration()
         cp_exec "cp -f configuration/orchestration.cfg ${FILESYSTEM_PATH}/${SERVICE_PATH}/${ORCHESTRATION_FILE_NAME}.cfg"
         execution_flags="execution_flags=\"--orchestration-mode=${var_orchestration_mode}\""
         echo $execution_flags >> ${FILESYSTEM_PATH}/${SERVICE_PATH}/${ORCHESTRATION_FILE_NAME}.cfg
-        if [ $var_arch = "gaia" -o $var_arch = "gaia_arm" -o "$is_smb" = "1" ]; then
+        if [ $var_arch = "gaia" -o "$is_smb" = "1" ]; then
             if [ -z "${gaia_ld_path}" ]; then
                 gaia_ld_path="${LD_LIBRARY_PATH}"
             fi
@@ -1107,14 +1101,7 @@ install_orchestration()
     if [ -z "${var_token}" ] && [ ${var_hybrid_mode} = false ] && [ ${var_offline_mode} = false ] && [ -z ${EGG_MODE} ] && [ ${var_no_otp} = false ]; then
         cp_print "Please enter OTP token []:" ${FORCE_STDOUT}
         read -r var_token
-        attempts=0
-        max_attempts=3
         while [ -z "$var_token" ]; do
-            attempts=$((attempts + 1))
-            if [ "$attempts" -gt "$max_attempts" ]; then
-                cp_print "Maximum attempts exceeded. open-appsec Nano Agent registration failed. Failed to get token" ${FORCE_STDOUT}
-                exit 1
-            fi
             cp_print "You must enter OTP token[]:" ${FORCE_STDOUT}
             read -r var_token
         done
@@ -1214,7 +1201,7 @@ install_orchestration()
 
     execution_flags="execution_flags=\"--orchestration-mode=${var_orchestration_mode}\""
     echo $execution_flags >> ${FILESYSTEM_PATH}/${SERVICE_PATH}/${ORCHESTRATION_FILE_NAME}.cfg
-    if [ $var_arch = "gaia" -o $var_arch = "gaia_arm" -o "$is_smb" = "1" ]; then
+    if [ $var_arch = "gaia" -o "$is_smb" = "1" ]; then
         sed -i '1i gaia_ld_path='"$LD_LIBRARY_PATH"'' ${FILESYSTEM_PATH}/${SERVICE_PATH}/${ORCHESTRATION_FILE_NAME}.cfg
     fi