X-Git-Url: https://git.mxchange.org/?p=mailer.git;a=blobdiff_plain;f=inc%2Flibs%2Fyoomedia_functions.php;h=e3e1a739a223b19b6a7c5746887f3c0b9ffa719d;hp=97e3ba3b41e26df8ff4c7d77247addce58c94682;hb=0f3a135204757cc8750262871c8e62c42300acb4;hpb=fb7120ffa230b62b54895bcf95952e1cf30f8594 diff --git a/inc/libs/yoomedia_functions.php b/inc/libs/yoomedia_functions.php index 97e3ba3b41..e3e1a739a2 100644 --- a/inc/libs/yoomedia_functions.php +++ b/inc/libs/yoomedia_functions.php @@ -1,7 +1,7 @@ 0) || ($countQuery === false)) { + // Prepare the low-level request + $requestString = sprintf("http://www.yoomedia.de/interface_2.0/%s?id=%s&sid=%s&pw=%s&reload=%s&ma=%s&uebrig=%s&verguetung=%s&erotik=%s", + $script, + getConfig('yoomedia_id'), + getConfig('yoomedia_sid'), + getConfig('yoomedia_passwd'), + getConfig('yoomedia_tm_max_reload'), + getConfig('yoomedia_tm_min_wait'), + getConfig('yoomedia_tm_clicks_remain'), + getConfig('yoomedia_tm_min_pay'), + getConfig('yoomedia_erotic_allowed') + ); + + // Run the query + $response = sendGetRequest($requestString); + + // Convert from ISO to UTF-8 only if count is > 3 because <= 3 means timeout + if (count($response) > 3) { + // Convert all lines to UTF-8 + foreach ($response as $k => $v) { + // Convert the line + $response[$k] = iconv('windows-1252', 'UTF-8//TRANSLIT', $v); + /* + // iconv()-less ISO-8859-1 -> UTF-8 + $response[$k] = preg_replace( + "/([\x80-\xFF])/e", + "chr(0xC0|ord('\\1')>>6).chr(0x80|ord('\\1')&0x3F)", + $v + ); + */ + } // END - foreach + } // END - if + + // Shall we count the query as used? + if ($countQuery === true) { + // Then update the config! + updateConfiguration('yoomedia_requests_remain', 1, '-'); + } // END - if + } // END - if + + // Return the data + return $response; } // Test if the extension settings did work function YOOMEDIA_TEST_CONFIG ($data) { // Is this admin? - if (!IS_ADMIN()) { + if (!isAdmin()) { // No admin! return false; } // END - if @@ -54,7 +103,7 @@ function YOOMEDIA_TEST_CONFIG ($data) { mergeConfig($data); // Temporary allow maximum - setConfigEntry('yoomedia_tm_max_reload' , 1000); + setConfigEntry('yoomedia_tm_max_reload' , 100000); setConfigEntry('yoomedia_tm_min_wait' , 0); setConfigEntry('yoomedia_tm_clicks_remain', 10); setConfigEntry('yoomedia_tm_min_pay' , 0); @@ -62,63 +111,44 @@ function YOOMEDIA_TEST_CONFIG ($data) { // Query the API with a test request without couting it // If zero reply comes back the data is invalid! - $response = YOOMEDIA_QUERY_API("out_textmail.php", true); // @TODO Ask Yoo!Media for test script + $response = YOOMEDIA_QUERY_API('out_textmail.php', true); // @TODO Ask Yoo!Media for test script + + // Default error code is 0 = all fine! + $errorCode = YOOMEDIA_GET_ERRORCODE_FROM_RESULT($response); // Log the response if failed if (count($response) == 0) { // Queries depleted (as we count here!) - DEBUG_LOG(__FUNCTION__, __LINE__, " Requested depleted. Maxmimum was: ".getConfig('yoomedia_requests_total')); - } elseif (count($response) <= 10) { + logDebugMessage(__FUNCTION__, __LINE__, 'Requested depleted. Maxmimum was: ' . getConfig('yoomedia_requests_total')); + $errorCode = -1; + } elseif (!isset($response[8])) { + // Invalid response + logDebugMessage(__FUNCTION__, __LINE__, 'Missing response line [8]. Raw response=' . base64_encode(serialize($response))); + $errorCode = -1; + } elseif ((($errorCode <= 4) && ($errorCode > 0)) || ($errorCode >= 8)) { + // An error has returned from the account + logDebugMessage(__FUNCTION__, __LINE__, 'Unexpected error code ' . $errorCode . ' received.'); + } elseif (count($response) < 9) { // Log serialized raw response - DEBUG_LOG(__FUNCTION__, __LINE__, " Raw response=".base64_encode(serialize($response))); - } // END - if + logDebugMessage(__FUNCTION__, __LINE__, 'Raw response=' . base64_encode(serialize($response))); + $errorCode = -1; + } else { + // This is fine, because the result array is okay and the response code on element 8 is fine + $errorCode = '0'; + } // Do we have some data there? - return (count($response) > 10); -} - -// Queries the given Yoo!Media API 2.0 script -function YOOMEDIA_QUERY_API ($script, $countQuery = true) { - // Init response array - $response = array(); - - // Enougth queries left? - if ((getConfig('yoomedia_requests_remain') > 0) || (!$countQuery)) { - // Prepare the low-level request - $requestString = sprintf("http://www.yoomedia.de/interface_2.0/%s?id=%s&sid=%s&pw=%s&reload=%s&ma=%s&uebrig=%s&verguetung=%s&erotik=%s", - $script, - getConfig(('yoomedia_id')), - getConfig(('yoomedia_sid')), - getConfig('yoomedia_passwd'), - getConfig(('yoomedia_tm_max_reload')), - getConfig(('yoomedia_tm_min_wait')), - getConfig(('yoomedia_tm_clicks_remain')), - getConfig(('yoomedia_tm_min_pay')), - getConfig(('yoomedia_erotic_allowed')) - ); - - // Run the query - $response = GET_URL($requestString); - - // Shall we count the query as used? - if ($countQuery) { - // Then update the config! - UPDATE_CONFIG("yoomedia_requests_remain", 1, "-"); - } // END - if - } // END - if - - // Return the data - return $response; + return ($errorCode == '0'); } // "Getter" for a parsed result for all text mails. This means an array without // the header lines will be returned function YOOMEDIA_GET_PARSED_RESULT_TEXTMAILS () { // Get the raw response - $response = YOOMEDIA_QUERY_API("out_textmail.php"); + $response = YOOMEDIA_QUERY_API('out_textmail.php'); // Parse the response - $result = YOOMEDIA_PARSE_RESPONSE($response, "textmail"); + $result = YOOMEDIA_PARSE_RESPONSE($response, 'textmail'); // Return result return $result; @@ -130,41 +160,40 @@ function YOOMEDIA_PARSE_RESPONSE ($response, $type) { $result = array(); // Cut off the header - $dummy = $response; - foreach ($response as $line) { - // Remove line - array_shift($dummy); - - // Is this line empty? - if (empty($line)) { - // Then stop here - break; - } // END - if - } // END - foreach + $dummy = removeHttpHeaderFromResponse($response); + + // If we have no result, abort here + if (count($dummy) == 0) { + // Empty response from API + logDebugMessage(__FUNCTION__, __LINE__, 'Empy result from API received.'); + return array(); + } // END - if // The result is now still raw, so we must split it up and trim spaces away $responseLine = trim(implode("\n", $dummy)); // Last line should never be a pipe! - if (substr($responseLine, -1, 1) == "|") $responseLine = substr($responseLine, 0, -1); + if (substr($responseLine, -1, 1) == '|') { + $responseLine = substr($responseLine, 0, -1); + } // END - if // Now, explode all in one array - $dataArray = explode("|", $responseLine); + $dataArray = explode('|', $responseLine); // Now make the result array with two dimensions - $cnt = 0; $entry = 0; + $count = '0'; $entry = '0'; foreach ($dataArray as $line) { // Add the line - $result[$entry][YOOMEDIA_TRANSLATE_INDEX($type, $cnt)] = $line; + $result[$entry][yoomediaTranslateIndex($type, $count)] = $line; // End of data of first entry reached? - if ($cnt == 6) { + if ($count == 6) { // Then advance to next entry and reset counter $entry++; - $cnt = 0; + $count = '0'; } else { // Count up - $cnt++; + $count++; } } // END - foreach @@ -172,13 +201,13 @@ function YOOMEDIA_PARSE_RESPONSE ($response, $type) { return $result; } -// Prepares a bonus mail for delivery. Works only if extension "bonus" is active +// Prepares a bonus mail for delivery. Works only if extension 'bonus' is active function YOOMEDIA_PREPARE_MAIL_DELIVERY ($data) { // Is this an admin? - if (!IS_ADMIN()) { + if (!isAdmin()) { // Abort here return false; - } elseif (!EXT_IS_ACTIVE("bonus")) { + } elseif (!isExtensionActive('bonus')) { // Abort here return false; } @@ -192,36 +221,27 @@ function YOOMEDIA_PREPARE_MAIL_DELIVERY ($data) { // Is the reward below one? if ($data['reward'] < 1) $data['reward'] = 1; - // Add website id - $data['sid'] = getConfig('yoomedia_sid'); - - // Add total receivers - $data['all'] = TRANSLATE_COMMA(GET_TOTAL_RECEIVERS()); - - // Add categories - $data['categories'] = ADD_CATEGORY_OPTIONS("normal"); - // Load template - LOAD_TEMPLATE("admin_send_yoomedia", false, $data); + loadTemplate('admin_send_yoomedia', false, $data); } // Adds the mail to the bonus mail pool function YOOMEDIA_SEND_BONUS_MAIL ($data, $mode) { // Is this an admin? - if (!IS_ADMIN()) { + if (!isAdmin()) { // Abort here return false; - } elseif (!EXT_IS_ACTIVE("bonus")) { + } elseif (!isExtensionActive('bonus')) { // Abort here return false; } // Add dummy receiver to avoid notice - $data['receiver'] = 0; + $data['receiver'] = '0'; // HTML or normal? (normal is default...) - $type = "t"; - if (($mode == "html") && (EXT_IS_ACTIVE("html"))) $type = "h"; + $type = 't'; + if (($mode == 'html') && (isExtensionActive('html_mail'))) $type = 'h'; // Auto-generate URL $data['url'] = sprintf("http://www.yoomedia.de/code/%s-mail.php?id=%s&sid=%s", @@ -234,7 +254,7 @@ function YOOMEDIA_SEND_BONUS_MAIL ($data, $mode) { YOOMEDIA_RELOAD_LOCK($data, $mode); // Call the lower function - ADD_NEW_BONUS_MAIL($data, $mode); + addNewBonusMail($data, $mode); } // Lockdown given id @@ -245,8 +265,12 @@ function YOOMEDIA_EXCLUDE_MAIL ($data, $mode) { $mode = YOOMEDIA_CONVERT_MODE($mode); // Add the entry - SQL_QUERY_ESC("INSERT INTO `{!_MYSQL_PREFIX!}_yoomedia_reload` (`type`,`y_id`,`y_reload`,`inserted`) VALUES ('%s',%s,%s,'0000-00-00 00:00')", - array($mode, bigintval($data['id']), bigintval($data['reload'])), __FUNCTION__, __LINE__); + SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_yoomedia_reload` (`type`,`y_id`,`y_reload`,`inserted`) VALUES ('%s',%s,%s,'0000-00-00 00:00')", + array( + $mode, + bigintval($data['id']), + bigintval($data['reload']) + ), __FUNCTION__, __LINE__); } // END - if } @@ -256,24 +280,22 @@ function YOOMEDIA_UNLIST_MAIL ($data, $mode) { $mode = YOOMEDIA_CONVERT_MODE($mode); // Add the entry - SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{!_MYSQL_PREFIX!}_yoomedia_reload` WHERE `type`='%s' AND `y_id`=%s LIMIT 1", + SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_yoomedia_reload` WHERE `type`='%s' AND `y_id`=%s LIMIT 1", array($mode, bigintval($data['id'])), __FUNCTION__, __LINE__); } // "Translates" the index number into an assosiative value -function YOOMEDIA_TRANSLATE_INDEX ($type, $index) { - global $yoomediaTranslationTable; - +function yoomediaTranslateIndex ($type, $index) { // Default is the index $return = $index; // Is the element there? - if (isset($yoomediaTranslationTable[$type][$index])) { + if (isset($GLOBALS['translation_tables']['yoomedia'][$type][$index])) { // Use this element - $return = $yoomediaTranslationTable[$type][$index]; + $return = $GLOBALS['translation_tables']['yoomedia'][$type][$index]; } else { - // Not found! - DEBUG_LOG(__FUNCTION__, __LINE__, " type={$type},index={$index} not found."); + // Not found + logDebugMessage(__FUNCTION__, __LINE__, 'type=' . $type . ',index=' . $index . ' not found'); } // Return value @@ -281,19 +303,17 @@ function YOOMEDIA_TRANSLATE_INDEX ($type, $index) { } // "Translate" error code -function YOOMEDIA_TRANSLATE_ERROR ($errorCode) { - global $yoomediaTranslationTable; - - // Default is "failed" - $return = "failed"; +function translateYooMediaError ($errorCode) { + // Default is 'failed' + $return = 'failed (Code: ' . $errorCode . ')'; // Is the entry there? - if (isset($yoomediaTranslationTable['error_codes'][$errorCode])) { - // Entry found! - $return = $yoomediaTranslationTable['error_codes'][$errorCode]; + if (isset($GLOBALS['translation_tables']['yoomedia']['error_codes'][$errorCode])) { + // Entry found + $return = $GLOBALS['translation_tables']['yoomedia']['error_codes'][$errorCode]; } else { // Log missing entries - DEBUG_LOG(__FUNCTION__, __LINE__, " errorCode={$errorCode}"); + debug_report_bug(__FUNCTION__, __LINE__, sprintf("Unknown error code %s[%s] detected.", $errorCode, gettype($errorCode))); } // Return value @@ -306,7 +326,7 @@ function YOOMEDIA_CHECK_RELOAD ($id, $reload, $type) { $reloaded = false; // Query database - $result = SQL_QUERY_ESC("SELECT `id`, UNIX_TIMESTAMP(`inserted`) AS inserted FROM `{!_MYSQL_PREFIX!}_yoomedia_reload` WHERE `type`='%s' AND `y_id`=%s LIMIT 1", + $result = SQL_QUERY_ESC("SELECT `id`, UNIX_TIMESTAMP(`inserted`) AS inserted FROM `{?_MYSQL_PREFIX?}_yoomedia_reload` WHERE `type`='%s' AND `y_id`=%s LIMIT 1", array($type, bigintval($id)), __FUNCTION__, __LINE__); // Entry found? @@ -317,7 +337,7 @@ function YOOMEDIA_CHECK_RELOAD ($id, $reload, $type) { // Are we ready to sent again? if (((time() - $time) >= ($reload * 60*60)) && ($time > 0)) { // Remove entry - SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{!_MYSQL_PREFIX!}_yoomedia_reload` WHERE id=%s LIMIT 1", + SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_yoomedia_reload` WHERE `id`=%s LIMIT 1", array($id), __FUNCTION__, __LINE__); } else { // Dont' sent again this mail @@ -340,7 +360,7 @@ function YOOMEDIA_RELOAD_LOCK ($data, $mode) { $mode = YOOMEDIA_CONVERT_MODE($mode); // Add the entry - SQL_QUERY_ESC("INSERT INTO `{!_MYSQL_PREFIX!}_yoomedia_reload` (`type`,`y_id`,`y_reload`) VALUES ('%s',%s,%s)", + SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_yoomedia_reload` (`type`,`y_id`,`y_reload`) VALUES ('%s',%s,%s)", array($mode, bigintval($data['id']), bigintval($data['reload'])), __FUNCTION__, __LINE__); } // END - if } @@ -349,12 +369,12 @@ function YOOMEDIA_RELOAD_LOCK ($data, $mode) { function YOOMEDIA_CONVERT_MODE ($mode) { // Convert mode for normal/html switch ($mode) { - case "normal": - $mode = "textmail"; + case 'normal': + $mode = 'textmail'; break; - case "html": - $mode = "htmlmail"; + case 'html': + $mode = 'htmlmail'; break; } // END - switch @@ -362,5 +382,47 @@ function YOOMEDIA_CONVERT_MODE ($mode) { return $mode; } -// +// Extract code from response +function YOOMEDIA_GET_ERRORCODE_FROM_RESULT ($response) { + // Bad code as default + $code = -999; + + // Which response should we parse? + if ((isset($response[8])) && (count($response) == 9)) { + // Use error code from element 8 (mostly API errors) + $codeArray = explode('
', $response[8]); + + // Use only the first element + $code = bigintval($codeArray[0]); + } elseif ((is_array($response[0])) && (isset($response[0]['id']))) { + // Begin with extraction + $codeArray = explode(' ', $response[0]['id']); + $code = $codeArray[0]; + $codeArray = explode('
', $code); + $code = $codeArray[0]; + $codeArray = explode('
', $code); + $code = $codeArray[0]; + + // Remove all new-line characters + $codeArray = explode("\n", $code); + $code = $codeArray[0]; + + // Remove carrige-return + $code = str_replace("\n", '', $code); + + } elseif (count($response) < 9) { + // Should not happen! + debug_report_bug(__FUNCTION__, __LINE__, 'Cannot parse response. Raw response:
' . print_r($response, true) . '
'); + } + + // Fix empty code to bad + if (empty($code)) { + $code = -999; + } // END - if + + // Return error code + return $code; +} + +// [EOF] ?>