Rewrote 'we' word a little, rewrote mail order to use SQL_INSERTID() instead of anoth...
[mailer.git] / inc / libs / yoomedia_functions.php
index 3e02dff95c2d6f3b06a1bf00a53e4b0493b0d40a..bedb886982080d2d197b8df02e93aef986692bfb 100644 (file)
@@ -16,8 +16,8 @@
  * $Author::                                                          $ *
  * -------------------------------------------------------------------- *
  * Copyright (c) 2003 - 2009 by Roland Haeder                           *
- * Copyright (c) 2009 - 2011 by Mailer Developer Team                   *
- * For more information visit: http://www.mxchange.org                  *
+ * Copyright (c) 2009 - 2012 by Mailer Developer Team                   *
+ * For more information visit: http://mxchange.org                      *
  *                                                                      *
  * This program is free software; you can redistribute it and/or modify *
  * it under the terms of the GNU General Public License as published by *
@@ -47,21 +47,20 @@ function YOOMEDIA_QUERY_API ($script, $countQuery = true) {
 
        // Enougth queries left?
        if ((getConfig('yoomedia_requests_remain') > 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')
+               // Prepare request array
+               $requestData = array(
+                       'id'         => getConfig('yoomedia_id'),
+                       'sid'        => getConfig('yoomedia_sid'),
+                       'pw'         => getConfig('yoomedia_passwd'),
+                       'reload'     => getConfig('yoomedia_tm_max_reload'),
+                       'ma'         => getConfig('yoomedia_tm_min_wait'),
+                       'uebrig'     => getConfig('yoomedia_tm_clicks_remain'),
+                       'verguetung' => getConfig('yoomedia_tm_min_pay'),
+                       'erotik'     => getConfig('yoomedia_erotic_allowed')
                );
 
                // Run the query
-               $response = sendGetRequest($requestString);
+               $response = sendGetRequest('http://www.yoomedia.de/interface_2.0/' . $script, $requestData, true);
 
                // Convert from ISO to UTF-8 only if count is > 3 because <= 3 means timeout
                if (count($response) > 3) {
@@ -69,14 +68,6 @@ function YOOMEDIA_QUERY_API ($script, $countQuery = true) {
                        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
 
@@ -99,15 +90,18 @@ function YOOMEDIA_TEST_CONFIG ($data) {
                return false;
        } // END - if
 
-       // Transfer config data
+       // Remove 'ok'
+       unset($data['ok']);
+
+       // Merge config
        mergeConfig($data);
 
        // Temporary allow maximum
-       setConfigEntry('yoomedia_tm_max_reload'   , 100000);
-       setConfigEntry('yoomedia_tm_min_wait'     , 0);
-       setConfigEntry('yoomedia_tm_clicks_remain', 10);
-       setConfigEntry('yoomedia_tm_min_pay'      , 0);
-       setConfigEntry('yoomedia_erotic_allowed'  , 1);
+       setConfigEntry('yoomedia_tm_max_reload'   , '100000');
+       setConfigEntry('yoomedia_tm_min_wait'     , '1000');
+       setConfigEntry('yoomedia_tm_clicks_remain', '10');
+       setConfigEntry('yoomedia_tm_min_pay'      , '0.00001');
+       setConfigEntry('yoomedia_erotic_allowed'  , '1');
 
        // Query the API with a test request without couting it
        // If zero reply comes back the data is invalid!
@@ -117,27 +111,23 @@ function YOOMEDIA_TEST_CONFIG ($data) {
        $errorCode = YOOMEDIA_GET_ERRORCODE_FROM_RESULT($response);
 
        // Log the response if failed
-       if (count($response) == 0) {
+       if ((count($response) == 0) && ($errorCode > 0)) {
                // Queries depleted (as we count here!)
-               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)));
+               logDebugMessage(__FUNCTION__, __LINE__, 'Requested depleted. Maxmimum was: ' . getConfig('yoomedia_requests_total') . ',errorCode=' . $errorCode);
                $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) {
+       } elseif ((count($response) > 0) && ($errorCode != 0)) {
                // Log serialized raw response
-               logDebugMessage(__FUNCTION__, __LINE__, 'Raw response=' . base64_encode(serialize($response)));
+               logDebugMessage(__FUNCTION__, __LINE__, 'errorCode=' . $errorCode . ',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?
+       // Is some data there?
        return ($errorCode == '0');
 }
 
@@ -147,8 +137,13 @@ function YOOMEDIA_GET_PARSED_RESULT_TEXTMAILS () {
        // Get the raw response
        $response = YOOMEDIA_QUERY_API('out_textmail.php');
 
+       // By default an empty result is returned
+       $result = array();
+
        // Parse the response
-       $result = YOOMEDIA_PARSE_RESPONSE($response, 'textmail');
+       if (count($response) > 0) {
+               $result = YOOMEDIA_PARSE_RESPONSE($response, 'textmail');
+       } // END - if
 
        // Return result
        return $result;
@@ -160,30 +155,22 @@ 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.');
+               reportBug(__FUNCTION__, __LINE__, 'Empty result from API received. response()=' . count($response) . ',type=' . $type);
                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));
+       $responseLine = trim(implode(chr(10), $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);
@@ -221,20 +208,24 @@ function YOOMEDIA_PREPARE_MAIL_DELIVERY ($data) {
        }
 
        // Is the waiting time below one second? Then fix it to one (zero seconds are not yet supported!)
-       if ($data['wait'] < 1) $data['wait'] = 1;
+       if ($data['wait'] < 1) {
+               $data['wait'] = 1;
+       } // END - if
 
        // Half of waiting time is a good reward!
        $data['reward'] = round($data['wait'] / 2 + 0.4);
 
        // Is the reward below one?
-       if ($data['reward'] < 1) $data['reward'] = 1;
+       if ($data['reward'] < 1) {
+               $data['reward'] = 1;
+       } // END - if
 
        // Load template
        loadTemplate('admin_send_yoomedia', false, $data);
 }
 
 // Adds the mail to the bonus mail pool
-function YOOMEDIA_SEND_BONUS_MAIL ($data, $mode) {
+function YOOMEDIA_SEND_BONUS_MAIL ($data, $mailMode) {
        // Is this an admin?
        if (!isAdmin()) {
                // Abort here
@@ -249,7 +240,7 @@ function YOOMEDIA_SEND_BONUS_MAIL ($data, $mode) {
 
        // HTML or normal? (normal is default...)
        $type = 't';
-       if (($mode == 'html') && (isExtensionActive('html_mail'))) $type = 'h';
+       if (($mailMode == 'html') && (isExtensionActive('html_mail'))) $type = 'h';
 
        // Auto-generate URL
        $data['url'] = sprintf("http://www.yoomedia.de/code/%s-mail.php?id=%s&sid=%s",
@@ -259,23 +250,23 @@ function YOOMEDIA_SEND_BONUS_MAIL ($data, $mode) {
        );
 
        // Lock this mail for new delivery
-       YOOMEDIA_RELOAD_LOCK($data, $mode);
+       YOOMEDIA_RELOAD_LOCK($data, $mailMode);
 
        // Call the lower function
-       addNewBonusMail($data, $mode);
+       addNewBonusMail($data, $mailMode);
 }
 
 // Lockdown given id
-function YOOMEDIA_EXCLUDE_MAIL ($data, $mode) {
+function YOOMEDIA_EXCLUDE_MAIL ($data, $mailMode) {
        // Search for the entry
-       if (YOOMEDIA_CHECK_RELOAD($data['id'], $data['reload'], $mode) === false) {
+       if (YOOMEDIA_CHECK_RELOAD($data['id'], $data['reload'], $mailMode) === false) {
                // Convert mode for mails
-               $mode = YOOMEDIA_CONVERT_MODE($mode);
+               $mailMode = YOOMEDIA_CONVERT_MODE($mailMode);
 
                // 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,
+                               $mailMode,
                                bigintval($data['id']),
                                bigintval($data['reload'])
                        ), __FUNCTION__, __LINE__);
@@ -283,13 +274,13 @@ function YOOMEDIA_EXCLUDE_MAIL ($data, $mode) {
 }
 
 // Remove lock of given mail
-function YOOMEDIA_UNLIST_MAIL ($data, $mode) {
+function YOOMEDIA_UNLIST_MAIL ($data, $mailMode) {
        // Convert mode for mails
-       $mode = YOOMEDIA_CONVERT_MODE($mode);
+       $mailMode = YOOMEDIA_CONVERT_MODE($mailMode);
 
        // Add the entry
        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__);
+               array($mailMode, bigintval($data['id'])), __FUNCTION__, __LINE__);
 }
 
 // "Translates" the index number into an assosiative value
@@ -302,8 +293,8 @@ function yoomediaTranslateIndex ($type, $index) {
                // Use this element
                $return = $GLOBALS['translation_tables']['yoomedia'][$type][$index];
        } else {
-               // Not found!
-               logDebugMessage(__FUNCTION__, __LINE__, "type={$type},index={$index} not found.");
+               // Not found
+               logDebugMessage(__FUNCTION__, __LINE__, 'type=' . $type . ',index=' . $index . ' not found');
        }
 
        // Return value
@@ -317,11 +308,11 @@ function translateYooMediaError ($errorCode) {
 
        // Is the entry there?
        if (isset($GLOBALS['translation_tables']['yoomedia']['error_codes'][$errorCode])) {
-               // Entry found!
+               // Entry found
                $return = $GLOBALS['translation_tables']['yoomedia']['error_codes'][$errorCode];
        } else {
                // Log missing entries
-               debug_report_bug(__FUNCTION__, __LINE__, sprintf("Unknown error code <strong>%s[%s]</strong> detected.", $errorCode, gettype($errorCode)));
+               reportBug(__FUNCTION__, __LINE__, sprintf("Unknown error code <strong>%s[%s]</strong> detected.", $errorCode, gettype($errorCode)));
        }
 
        // Return value
@@ -361,37 +352,40 @@ function YOOMEDIA_CHECK_RELOAD ($id, $reload, $type) {
 }
 
 // Lock given mail down for reload lock
-function YOOMEDIA_RELOAD_LOCK ($data, $mode) {
+function YOOMEDIA_RELOAD_LOCK ($data, $mailMode) {
        // Search for the entry
-       if (YOOMEDIA_CHECK_RELOAD($data['id'], $data['reload'], $mode) === false) {
+       if (YOOMEDIA_CHECK_RELOAD($data['id'], $data['reload'], $mailMode) === false) {
                // Convert mode for mails
-               $mode = YOOMEDIA_CONVERT_MODE($mode);
+               $mailMode = YOOMEDIA_CONVERT_MODE($mailMode);
 
                // Add the entry
                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__);
+                       array($mailMode, bigintval($data['id']), bigintval($data['reload'])), __FUNCTION__, __LINE__);
        } // END - if
 }
 
 // Convert mode for mails
-function YOOMEDIA_CONVERT_MODE ($mode) {
+function YOOMEDIA_CONVERT_MODE ($mailMode) {
        // Convert mode for normal/html
-       switch ($mode) {
+       switch ($mailMode) {
                case 'normal':
-                       $mode = 'textmail';
+                       $mailMode = 'textmail';
                        break;
 
                case 'html':
-                       $mode = 'htmlmail';
+                       $mailMode = 'htmlmail';
                        break;
        } // END - switch
 
        // Return result
-       return $mode;
+       return $mailMode;
 }
 
 // Extract code from response
 function YOOMEDIA_GET_ERRORCODE_FROM_RESULT ($response) {
+       // The response must be an array
+       assert(is_array($response));
+
        // Bad code as default
        $code = -999;
 
@@ -402,32 +396,44 @@ function YOOMEDIA_GET_ERRORCODE_FROM_RESULT ($response) {
 
                // 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('<br />', $code);
-               $code = $codeArray[0];
-               $codeArray = explode('<br>', $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) {
+       } elseif (!empty($response[0])) {
+               // Merge response together
+               $parts = explode('|', implode('', $response));
+
+               // If we have only one part, we got an error
+               if (count($parts) > 1) {
+                       // All fine
+                       $code = '0';
+               } else {
+                       // Begin with extraction of error code
+                       $codeArray = explode(' ', $response[0]);
+                       $code = $codeArray[0];
+                       $codeArray = explode('<br />', $code);
+                       $code = $codeArray[0];
+                       $codeArray = explode('<br>', $code);
+                       $code = $codeArray[0];
+
+                       // Remove all new-line characters
+                       $codeArray = explode(chr(10), $code);
+                       $code = $codeArray[0];
+
+                       // Remove carrige-return
+                       $code = trim(str_replace(chr(10), '', $code));
+
+                       // Is it still empty?
+                       if (empty($code)) {
+                               // Then fix it
+                               $code = -999;
+                       } // END - if
+               }
+       } elseif (count($response) == 0) {
+               // All fine, but empty result
+               $code = '0';
+       } else {
                // Should not happen!
-               debug_report_bug(__FUNCTION__, __LINE__, 'Cannot parse response. Raw response:<pre>' . print_r($response, true) . '</pre>');
+               reportBug(__FUNCTION__, __LINE__, 'Cannot parse response. Raw response:<pre>' . print_r($response, true) . '</pre>');
        }
 
-       // Fix empty code to bad
-       if (empty($code)) {
-               $code = -999;
-       } // END - if
-
        // Return error code
        return $code;
 }