X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=inc%2Ffilters.php;h=df664c279ed92e2b75b909f8745215d5e41baf4b;hb=bebd6c9b98a4e1a0219e3e2b0ce382fbe7d8335c;hp=8cdf48783328dfbaa2dd42682105ff8877cda7c4;hpb=b8c86fa12322603c24a88ea2b0fd3dbeba612752;p=mailer.git diff --git a/inc/filters.php b/inc/filters.php index 8cdf487833..df664c279e 100644 --- a/inc/filters.php +++ b/inc/filters.php @@ -10,7 +10,12 @@ * -------------------------------------------------------------------- * * Kurzbeschreibung : Funktionen fuer Filter-System * * -------------------------------------------------------------------- * - * * + * $Revision:: 856 $ * + * $Date:: $ * + * $Tag:: 0.2.1-FINAL $ * + * $Author:: $ * + * Needs to be in all Files and every File needs "svn propset * + * svn:keywords Date Revision" (autoprobset!) at least!!!!!! * * -------------------------------------------------------------------- * * Copyright (c) 2003 - 2008 by Roland Haeder * * For more information visit: http://www.mxchange.org * @@ -69,7 +74,7 @@ function INIT_FILTER_SYSTEM () { // Load all active filers $result = SQL_QUERY("SELECT `filter_name`, `filter_function`, `filter_active`".$ADD." FROM `{!_MYSQL_PREFIX!}_filters` -ORDER BY `filter_id` ASC", __FILE__, __LINE__); +ORDER BY `filter_id` ASC", __FUNCTION__, __LINE__); // Are there entries? if (SQL_NUMROWS($result) > 0) { @@ -185,7 +190,7 @@ function UNREGISTER_FILTER ($filterName, $filterFunction, $force = false, $dry_r } // "Runs" the given filters, data is optional and can be any type of data -function RUN_FILTER ($filterName, $data = null, $silentAbort = true) { +function runFilterChain ($filterName, $data = null, $silentAbort = true) { // Is that filter chain there? if (!isset($GLOBALS['filters']['chains'][$filterName])) { // Then abort here (quick'N'dirty hack) @@ -235,10 +240,14 @@ function RUN_FILTER ($filterName, $data = null, $silentAbort = true) { // Filter for flushing all new filters to the database function FILTER_FLUSH_FILTERS () { - global $SQLs; - // Clear all previous SQL queries - $SQLs = array(); + INIT_SQLS(); + + // Are we installing? + if (isInstalling()) { + // Then silently skip this filter + return true; + } // END - if // Is a database link here and not in installation mode? if ((!SQL_IS_LINK_UP()) && (!isInstalling())) { @@ -283,7 +292,7 @@ function FILTER_FLUSH_FILTERS () { $insertSQL = substr($insertSQL, 0, -1); // And run it - $SQLs[] = $insertSQL; + ADD_SQL($insertSQL); } // END - if // Something has been removed? @@ -292,7 +301,7 @@ function FILTER_FLUSH_FILTERS () { $removeSQL = substr($removeSQL, 0, -2) . "LIMIT ".$removed; // And run it - $SQLs[] = $removeSQL; + ADD_SQL($removeSQL); } // END - if // Shall we update usage counters (ONLY FOR DEBUGGING!) @@ -302,17 +311,17 @@ function FILTER_FLUSH_FILTERS () { // Walk through all filters foreach ($filterArray as $filterFunction => $cnt) { // Construct and add the query - $SQLs[] = sprintf("UPDATE `{!_MYSQL_PREFIX!}_filters` SET `filter_counter`=%s WHERE `filter_name`='%s' AND `filter_function`='%s' LIMIT 1", + ADD_SQL(sprintf("UPDATE `{!_MYSQL_PREFIX!}_filters` SET `filter_counter`=%s WHERE `filter_name`='%s' AND `filter_function`='%s' LIMIT 1", bigintval($cnt), $filterName, $filterFunction - ); + )); } // END - foreach } // END - foreach } // END - if // Run the run_sqls filter in non-dry mode - RUN_FILTER('run_sqls', array('dry_run' => false, 'sqls' => $SQLs)); + runFilterChain('run_sqls'); } // Filter for calling the handler for login failures @@ -348,11 +357,8 @@ function FILTER_REDIRECT_TO_LOGOUT_SQL_PATCHES () { // Filter for auto-activation of a extension function FILTER_AUTO_ACTIVATE_EXTENSION ($data) { - // @TODO Try to rewrite this - global $EXT_ALWAYS_ACTIVE; - // Is this extension always activated? - if ($EXT_ALWAYS_ACTIVE == "Y") { + if (EXT_GET_ALWAYS_ACTIVE() == "Y") { // Then activate the extension //* DEBUG: */ echo __FUNCTION__."(".__LINE__."): ext_name={$data['ext_name']}
\n"; ACTIVATE_EXTENSION($data['ext_name']); @@ -411,23 +417,35 @@ function FILTER_LOAD_INCLUDES ($data) { // Filter for running SQL commands function FILTER_RUN_SQLS ($data) { + // Debug message + //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, " - Entered!"); + // Is the array there? - if ((isset($data['sqls'])) && ((!isset($data['dry_run'])) || ($data['dry_run'] == false))) { + if ((IS_SQLS_VALID()) && ((!isset($data['dry_run'])) || ($data['dry_run'] == false))) { // Run SQL commands - foreach ($data['sqls'] as $sql) { + //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, " - Found ".COUNT_SQLS()." queries to run."); + foreach (GET_SQLS() as $sql) { + // Trim spaces away $sql = trim($sql); + + // Is there still a query left? if (!empty($sql)) { // Do we have an "ALTER TABLE" command? if (substr(strtolower($sql), 0, 11) == "alter table") { // Analyse the alteration command - SQL_ALTER_TABLE($sql, __FILE__, __LINE__); + //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, "Alterting table: {$sql}"); + SQL_ALTER_TABLE($sql, __FUNCTION__, __LINE__); } else { // Run regular SQL command - $result = SQL_QUERY($sql, __FILE__, __LINE__, false); + //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, "Running regular query: {$sql}"); + $result = SQL_QUERY($sql, __FUNCTION__, __LINE__, false); } } // END - if } // END - foreach } // END - if + + // Debug message + //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, " - Left!"); } // Filter for updating/validating login data @@ -439,11 +457,11 @@ function FILTER_UPDATE_LOGIN_DATA () { if (!IS_MEMBER()) return false; // Secure user ID - $GLOBALS['userid'] = bigintval(get_session('userid')); + setUserId(get_session('userid')); // Load last module and last online time $result = SQL_QUERY_ESC("SELECT last_module, last_online FROM `{!_MYSQL_PREFIX!}_user_data` WHERE userid=%s LIMIT 1", - array($GLOBALS['userid']), __FILE__, __LINE__); + array(getUserId()), __FUNCTION__, __LINE__); // Entry found? if (SQL_NUMROWS($result) == 1) { @@ -467,7 +485,7 @@ function FILTER_UPDATE_LOGIN_DATA () { // Update last module / online time SQL_QUERY_ESC("UPDATE `{!_MYSQL_PREFIX!}_user_data` SET last_module='%s', last_online=UNIX_TIMESTAMP(), REMOTE_ADDR='%s' WHERE userid=%s LIMIT 1", - array($GLOBALS['what'], GET_REMOTE_ADDR(), $GLOBALS['userid']), __FILE__, __LINE__); + array($GLOBALS['what'], GET_REMOTE_ADDR(), getUserId()), __FUNCTION__, __LINE__); } else { // Destroy session, we cannot update! destroy_user_session();