runwatch.php ➔ insert_recommendation() - Code Metrics - Inspection of "Merge pull request #567 from following5/1090-watch..." - OpencachingDeutschland/oc-server3 - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Push — development ( a1bf21...cffa7e )

by Thomas
created 2017-08-29 21:14 UTC
runwatch.php ➔ insert_recommendation() A

↳ Parent: Project
Complexity

Conditions	2
Paths	2
Size

Total Lines	10
Code Lines	7
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	2
eloc	7
nc	2
nop	3
dl	0
loc	10
rs	9.4285
c	0
b	0
f	0
#!/usr/local/bin/php -q
<?php
/***************************************************************************
 * For license information see LICENSE.md
 * Ggf. muss die Location des php-Binaries angepasst werden.
 * Dieses Script sucht nach neuen Logs und Caches, die von Usern beobachtet
 * werden und verschickt dann die Emails.
 ***************************************************************************/

// needs absolute rootpath because called as cronjob
$rootpath = __DIR__ . '/../../';
require_once __DIR__ . '/../../lib/clicompatbase.inc.php';
require_once __DIR__ . '/../../lib2/translate.class.php';
require_once __DIR__ . '/settings.inc.php';
require_once __DIR__ . '/../../lib/consts.inc.php';
require_once __DIR__ . '/../../lib2/edithelper.inc.php';
require_once __DIR__ . '/../../lib2/logic/logtypes.inc.php';

if (!Cronjobs::enabled()) {
    exit;
}

// use posix pid-files to lock process
if (!CreatePidFile($watchpid)) {
    CleanupAndExit($watchpid, 'Another instance is running!');
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    exit;
}

if (!function_exists('get_logtype_name')) {
    function get_logtype_name($logtype, $language)
/**
 * @ignore
 */
function getUser() {

}

function getUser($id, $realm) {

}
    {
        return sqlValue(
            "SELECT IFNULL(`stt`.`text`, `log_types`.`en`)
         FROM `log_types`
         LEFT JOIN `sys_trans_text` `stt` ON `stt`.`trans_id`=`log_types`.`trans_id`
         AND `stt`.`lang`='" . sql_escape($language) . "'
         WHERE `log_types`.`id`='" . sql_escape($logtype) . "'",
            ''
        );
    }
}

$sDateformat = 'Y-m-d H:i:s';
db_connect();
if ($dblink === false) {
    echo 'Unable to connect to database';
    exit;
}

/* begin owner notifies */
$rsNewLogs = sql(
    'SELECT cache_logs.id log_id, caches.user_id user_id
    FROM cache_logs, caches
    WHERE cache_logs.cache_id=caches.cache_id
    AND cache_logs.owner_notified=0'
);
$mysqlNumRows = mysql_num_rows($rsNewLogs);
for ($i = 0; $i < $mysqlNumRows; $i++) {
    $rNewLog = sql_fetch_array($rsNewLogs);

    $rsNotified = sql(
        "SELECT `id`
        FROM watches_notified
        WHERE user_id='&1'
        AND object_id='&2'
        AND object_type=1",
        $rNewLog['user_id'],
        $rNewLog['log_id']
    );
    if (mysql_num_rows($rsNotified) === 0) {
        // Benachrichtigung speichern
        sql(
            "INSERT IGNORE INTO `watches_notified` (`user_id`, `object_id`, `object_type`, `date_created`)
            VALUES ('&1', '&2', 1, NOW())",
            $rNewLog['user_id'],
            $rNewLog['log_id']
        );

        // Owner notifications are always sent, independent of user.email_problems counter.
        process_owner_log($rNewLog['user_id'], $rNewLog['log_id']);
    }
    mysql_free_result($rsNotified);

    sql("UPDATE cache_logs SET owner_notified=1 WHERE id='&1'", $rNewLog['log_id']);
}
mysql_free_result($rsNewLogs);
/* end owner notifies */

/* begin cache_watches */
$rscw = sql(
    'SELECT `watches_logqueue`.`log_id`, `watches_logqueue`.`user_id`, `cache_logs`.`cache_id`
     FROM `watches_logqueue`
     INNER JOIN `cache_logs` ON `watches_logqueue`.`log_id`=`cache_logs`.`id`'
);
while ($rcw = mysql_fetch_assoc($rscw)) {
    // Benachrichtigung speichern
    sql(
        "INSERT IGNORE INTO `watches_notified` (`user_id`, `object_id`, `object_type`, `date_created`)
        VALUES ('&1', '&2', 1, NOW())",
        $rcw['user_id'],
        $rcw['log_id']
    );

    // Throttle email sending after undeliverable mails. See also runwatch.php.
    // See also stored procedure sp_notify_new_cache().
    // See http://forum.opencaching.de/index.php?topic=3123.0 on AOL.
    if (sqlValue(
        "SELECT `email_problems` = 0 OR DATEDIFF(NOW(),`last_email_problem`) > 1+DATEDIFF(`last_email_problem`,
                `first_email_problem`)
         FROM `user` WHERE `user_id`='" . sql_escape($rcw['user_id']) . "'",
        1
    )) {
        process_log_watch($rcw['user_id'], $rcw['log_id']);
    }

    sql("DELETE FROM `watches_logqueue` WHERE `log_id`='&1' AND `user_id`='&2'", $rcw['log_id'], $rcw['user_id']);
}
mysql_free_result($rscw);
/* end cache_watches */

/* begin send out everything that has to be sent */

$email_headers = 'From: "' . $mailfrom . '" <' . $mailfrom . '>';

$rsUsers = sql(
    "SELECT
        `user`.`user_id`,
        `user`.`username`,
        `user`.`email`,
        `user`.`watchmail_mode`,
        `user`.`watchmail_hour`,
        `user`.`watchmail_day`,
        `user`.`watchmail_nextmail`,
        IFNULL(`user`.`language`,'&1') `language`,
        `domain`
    FROM `user`
    INNER JOIN `watches_waiting`
        ON `user`.`user_id`=`watches_waiting`.`user_id`
    WHERE `user`.`watchmail_nextmail`<NOW()",
    $opt['template']['default']['locale']
);
$mysqlNumRows = mysql_num_rows($rsUsers);
for ($i = 0; $i < $mysqlNumRows; $i++) {
    $rUser = sql_fetch_array($rsUsers);

    if ($rUser['watchmail_nextmail'] != '0000-00-00 00:00:00') {
        $nologs = $translate->t('No new log entries.', '', basename(__FILE__), __LINE__, '', 1, $rUser['language']);

        $rsWatches = sql("SELECT COUNT(*) count FROM watches_waiting WHERE user_id='&1'", $rUser['user_id']);
        if (mysql_num_rows($rsWatches) > 0) {
            $r = sql_fetch_array($rsWatches);
            if ($r['count'] > 0) {
                // ok, eine mail ist fäig
                $mailbody = fetch_email_template('watchlist', $rUser['language'], $rUser['domain']);
                $mailbody = mb_ereg_replace('{username}', $rUser['username'], $mailbody);

                $rsWatchesOwner = sql(
                    "SELECT id, watchtext
                    FROM watches_waiting
                    WHERE user_id='&1'
                    AND watchtype=1
                    ORDER BY id DESC",
                    $rUser['user_id']
                );
                if (mysql_num_rows($rsWatchesOwner) > 0) {
                    $logtexts = '';
                    $mysqlNumRowsWatchesOwner = mysql_num_rows($rsWatchesOwner);
                    for ($j = 0; $j < $mysqlNumRowsWatchesOwner; $j++) {
                        $rWatch = sql_fetch_array($rsWatchesOwner);
                        $logtexts .= $rWatch['watchtext'];
                    }

                    while ((mb_substr($logtexts, -1) == "\n") || (mb_substr($logtexts, -1) == "\r")) {
                        $logtexts = mb_substr($logtexts, 0, mb_strlen($logtexts) - 1);
                    }

                    $mailbody = mb_ereg_replace('{ownerlogs}', $logtexts, $mailbody);
                } else {
                    $mailbody = mb_ereg_replace('{ownerlogs}', $nologs, $mailbody);
                }
                mysql_free_result($rsWatchesOwner);

                $rsWatchesLog = sql(
                    "SELECT id, watchtext
                    FROM watches_waiting
                    WHERE user_id='&1'
                    AND watchtype = 2
                    ORDER BY id DESC",
                    $rUser['user_id']
                );
                if (mysql_num_rows($rsWatchesLog) > 0) {
                    $logtexts = '';
                    $mysqlNumRowsWatchesLog = mysql_num_rows($rsWatchesLog);
                    for ($j = 0; $j < $mysqlNumRowsWatchesLog; $j++) {
                        $rWatch = sql_fetch_array($rsWatchesLog);
                        $logtexts .= $rWatch['watchtext'];
                    }

                    while ((mb_substr($logtexts, -1) == "\n") || (mb_substr($logtexts, -1) == "\r")) {
                        $logtexts = mb_substr($logtexts, 0, mb_strlen($logtexts) - 1);
                    }

                    $mailbody = mb_ereg_replace('{watchlogs}', $logtexts, $mailbody);
                } else {
                    $mailbody = mb_ereg_replace('{watchlogs}', $nologs, $mailbody);
                }
                mysql_free_result($rsWatchesLog);

                // mail versenden
                if ($debug == true) {
                    $mailadr = $debug_mailto;
                } else {
                    $mailadr = $rUser['email'];
                }

                if ($mailadr != '') {
                    if (is_existent_maildomain(getToMailDomain($mailadr))) {
                        $language = $rUser['language'] ? $rUser['language'] : $opt['template']['default']['locale'];
                        $mailsubject =
                            '[' . $maildomain . '] ' . $translate->t(
                                'Your watchlist of',
                                '',
                                basename(__FILE__),
                                __LINE__,
                                '',
                                1,
                                $language
                            ) . ' ' . date($opt['locale'][$language]['format']['phpdate']);
                        mb_send_mail($mailadr, $mailsubject, $mailbody, $email_headers);

                        // logentry($module, $eventid, $userid, $objectid1, $objectid2, $logtext, $details)

                        logentry('watchlist', 2, $rUser['user_id'], 0, 0, 'Sending mail to ' . $mailadr, []);
                    }
                }

                // entries entfernen
                sql("DELETE FROM watches_waiting WHERE user_id='&1' AND watchtype IN (1, 2)", $rUser['user_id']);
            }
        }
    }

    // Zeitpunkt der nästen Mail berechnen
    if ($rUser['watchmail_mode'] == 0) {
        $nextmail = date($sDateformat);
    } elseif ($rUser['watchmail_mode'] == 1) {
        $nextmail = date($sDateformat, mktime($rUser['watchmail_hour'], 0, 0, date('n'), date('j') + 1, date('Y')));
    } elseif ($rUser['watchmail_mode'] == 2) {
        $weekday = date('w');
        if ($weekday == 0) {
            $weekday = 7;
        }

        if ($weekday == $rUser['watchmail_day']) {
            $nextmail = date($sDateformat, mktime($rUser['watchmail_hour'], 0, 0, date('n'), date('j') + 7, date('Y')));
        } elseif ($weekday > $rUser['watchmail_day']) {
            $nextmail = date(
                $sDateformat,
                mktime(
                    $rUser['watchmail_hour'],
                    0,
                    0,
                    date('n'),
                    date('j') - $weekday + $rUser['watchmail_day'] + 7,
                    date('Y')
                )
            );
        } else {
            $nextmail = date(
                $sDateformat,
                mktime(
                    $rUser['watchmail_hour'],
                    0,
                    0,
                    date('n'),
                    date('j') + 6 - $rUser['watchmail_day'],
                    date('Y')
                )
            );
        }
    }

    sql("UPDATE user SET watchmail_nextmail='&1' WHERE user_id='&2'", $nextmail, $rUser['user_id']);
}
mysql_free_result($rsUsers);

/* cleanup */

// Discard old queue entries of users who disabled notifications.
// This is done *after* processing so nothing is lost on systems without
// periodical runwatch processing (e.g. developer systems).
// Do NOT move this into CleanupAndExit(), which may be run without processing!

sql('DELETE FROM `watches_waiting` WHERE DATEDIFF(NOW(),`date_created`) > 35');

CleanupAndExit($watchpid);


function process_owner_log($user_id, $log_id)
{
    global $opt, $dblink, $translate;

//    echo "process_owner_log($user_id, $log_id)\n";

    $rsLog = sql(
        "SELECT
            `cache_logs`.`cache_id`,
            `cache_logs`.`type`,
            `cache_logs`.`text`,
            `cache_logs`.`text_html`,
            `cache_logs`.`date` `logdate`,
            `cache_logs`.`needs_maintenance`,
            `cache_logs`.`listing_outdated`,
            `user`.`username`,
            `caches`.`name` `cachename`,
            `caches`.`wp_oc`,
            `cr`.`user_id` IS NOT NULL AS `recommendation`
        FROM `cache_logs`
        JOIN `user` ON `cache_logs`.`user_id`=`user`.`user_id`
        JOIN `caches` ON `cache_logs`.`cache_id`=`caches`.`cache_id`
        LEFT JOIN `cache_rating` `cr` ON
            `cr`.`cache_id`=`cache_logs`.`cache_id` AND
            `cr`.`rating_date`=`cache_logs`.`date` AND
            `cache_logs`.`type` IN (1,7)
        WHERE `cache_logs`.`id` ='&1'",
        $log_id
    );
    $rLog = sql_fetch_array($rsLog);
    mysql_free_result($rsLog);

    $logtext = html2plaintext($rLog['text'], $rLog['text_html'] == 0, EMAIL_LINEWRAP);

    $language = sqlValue("SELECT `language` FROM `user` WHERE `user_id`='" . sql_escape($user_id) . "'", null);
    if (!$language) {
        $language = $opt['template']['default']['locale'];
    }
    if (strpos($rLog['logdate'], '00:00:00') > 0) {
        $dateformat = $opt['locale'][$language]['format']['phpdate'];
    } else {
        $dateformat = $opt['locale'][$language]['format']['phpdatetime'];
    }

    $watchtext =
        '{date} ' . $translate->t(
            '{user} has logged your cache "{cachename}":',
            '',
            basename(__FILE__),
            __LINE__,
            '',
            1,
            $language
        ) . ' {action}{recommendation}{maintenance_flags}' . "\n" . '{shortlink_url}{wp_oc}' . "\n\n" . '{text}' . "\n\n\n\n";

    $watchtext = mb_ereg_replace('{date}', date($dateformat, strtotime($rLog['logdate'])), $watchtext);
    $watchtext = mb_ereg_replace('{wp_oc}', $rLog['wp_oc'], $watchtext);
    $watchtext = mb_ereg_replace('{text}', $logtext, $watchtext);
if ( ! in_array($value, array('this-is-allowed', 'and-this-too'), true)) {
    throw new \InvalidArgumentException('This input is not allowed.');
}
    $watchtext = mb_ereg_replace('{user}', $rLog['username'], $watchtext);
    $watchtext = mb_ereg_replace('{cachename}', $rLog['cachename'], $watchtext);
    $watchtext = mb_ereg_replace('{action}', get_logtype_name($rLog['type'], $language), $watchtext);
    $watchtext = insert_recommendation($rLog, $language, $watchtext);
    $watchtext = insert_maintenance_flags($rLog, $language, $watchtext);

    $domain = sqlValue("SELECT `domain` FROM `user` WHERE `user_id`='" . sql_escape($user_id) . "'", null);
    $urls = get_site_urls($domain);
    if ($urls['shortlink_url']) {
        $watchtext = mb_ereg_replace("{shortlink_url}", $urls['shortlink_url'], $watchtext);
    } else {
        $watchtext = mb_ereg_replace("{shortlink_url}", $urls['site_url'], $watchtext);
    }

    sql(
        "INSERT IGNORE INTO `watches_waiting`
         (`user_id`, `object_id`, `object_type`, `date_created`, `watchtext`, `watchtype`)
         VALUES ('&1', '&2', 1, NOW(), '&3', 1)",
        $user_id,
        $log_id,
        $watchtext
    );

    // logentry($module, $eventid, $userid, $objectid1, $objectid2, $logtext, $details)

    logentry('watchlist', 1, $user_id, $log_id, 0, $watchtext, []);
}

function process_log_watch($user_id, $log_id)
{
    global $opt, $dblink, $logwatch_text, $translate;

//    echo "process_log_watch($user_id, $log_id)\n";

    $rsLog = sql(
        "SELECT
            `cache_logs`.`cache_id`,
            `cache_logs`.`type`,
            `cache_logs`.`text`,
            `cache_logs`.`text_html`,
            `cache_logs`.`date` `logdate`,
            `cache_logs`.`needs_maintenance`,
            `cache_logs`.`listing_outdated`,
            `user`.`username`,
            `caches`.`name` `cachename`,
            `caches`.`wp_oc`,
            `cr`.`user_id` IS NOT NULL AS `recommendation`
        FROM `cache_logs`
        JOIN `user` ON `cache_logs`.`user_id`=`user`.`user_id`
        JOIN `caches` ON `cache_logs`.`cache_id`=`caches`.`cache_id`
        LEFT JOIN `cache_rating` `cr` ON
            `cr`.`cache_id`=`cache_logs`.`cache_id` AND
            `cr`.`rating_date`=`cache_logs`.`date` AND
            `cache_logs`.`type` IN (1,7)
        WHERE
            `cache_logs`.`user_id`=`user`.`user_id` AND
            `cache_logs`.`cache_id`=`caches`.`cache_id` AND
            `cache_logs`.`id` = '&1'",
        $log_id
    );
    $rLog = sql_fetch_array($rsLog);
    mysql_free_result($rsLog);

    $logtext = html2plaintext($rLog['text'], $rLog['text_html'] == 0, EMAIL_LINEWRAP);

    $language = sqlValue("SELECT `language` FROM `user` WHERE `user_id`='" . sql_escape($user_id) . "'", null);
    if (!$language) {
        $language = $opt['template']['default']['locale'];
    }
    if (strpos($rLog['logdate'], '00:00:00') > 0) {
        $dateformat = $opt['locale'][$language]['format']['phpdate'];
    } else {
        $dateformat = $opt['locale'][$language]['format']['phpdatetime'];
    }

    $watchtext =
        '{date} ' . $translate->t(
            '{user} has logged the cache "{cachename}":',
            '',
            basename(__FILE__),
            __LINE__,
            '',
            1,
            $language
        ) . ' {action}{recommendation}{maintenance_flags}' . "\n" . '{shortlink_url}{wp_oc}' . "\n{cachelists}\n" . '{text}' . "\n\n\n\n";

    $watchtext = mb_ereg_replace('{date}', date($dateformat, strtotime($rLog['logdate'])), $watchtext);
    $watchtext = mb_ereg_replace('{wp_oc}', $rLog['wp_oc'], $watchtext);
    $watchtext = mb_ereg_replace('{text}', $logtext, $watchtext);
if ( ! in_array($value, array('this-is-allowed', 'and-this-too'), true)) {
    throw new \InvalidArgumentException('This input is not allowed.');
}
    $watchtext = mb_ereg_replace('{user}', $rLog['username'], $watchtext);
    $watchtext = mb_ereg_replace('{cachename}', $rLog['cachename'], $watchtext);
    $watchtext = mb_ereg_replace('{action}', get_logtype_name($rLog['type'], $language), $watchtext);
    $watchtext = insert_recommendation($rLog, $language, $watchtext);
    $watchtext = insert_maintenance_flags($rLog, $language, $watchtext);

    $rsLists = sql(
        "SELECT `name` FROM `cache_lists` cl
        JOIN `cache_list_watches` clw ON clw.`cache_list_id`=cl.`id` AND clw.`user_id`='&1'
        JOIN `cache_list_items` cli ON cli.`cache_list_id`=cl.`id` AND cli.`cache_id`='&2'
        ORDER BY `name`",
        $user_id,
        $rLog['cache_id']
    );
    $cachelist_names = sql_fetch_column($rsLists);
    switch (count($cachelist_names)) {
        case 0:
            $cachelists = '';
            break;
        case 1:
            $cachelists =
                $translate->t(
                    'Cache list:',
                    '',
                    basename(__FILE__),
                    __LINE__,
                    '',
                    1,
                    $language
                ) . ' ' . $cachelist_names[0] . "\n";
            break;
        default:
            $cachelists =
                $translate->t(
                    'Cache lists:',
                    '',
                    basename(__FILE__),
                    __LINE__,
                    '',
                    1,
                    $language
                ) . ' ' . implode(', ', $cachelist_names) . "\n";
    }
    $watchtext = mb_ereg_replace('{cachelists}', $cachelists, $watchtext);

    $domain = sqlValue("SELECT `domain` FROM `user` WHERE `user_id`='" . sql_escape($user_id) . "'", null);
    $urls = get_site_urls($domain);
    if ($urls['shortlink_url']) {
        $watchtext = mb_ereg_replace("{shortlink_url}", $urls['shortlink_url'], $watchtext);
    } else {
        $watchtext = mb_ereg_replace("{shortlink_url}", $urls['site_url'], $watchtext);
    }

    sql(
        "INSERT IGNORE INTO watches_waiting
            (`user_id`, `object_id`, `object_type`, `date_created`, `watchtext`, `watchtype`)
            VALUES ('&1', '&2', 1, NOW(), '&3', 2)",
        $user_id,
        $log_id,
        $watchtext
    );
}

function insert_recommendation($rLog, $language, $watchtext)
{
    global $translate;

    $rtext =
        $rLog['recommendation']
        ? ', ' . $translate->t('Recommendation', '', basename(__FILE__), __LINE__, '', 1, $language)
        : '';
    return mb_ereg_replace('{recommendation}', $rtext, $watchtext);
}

/**
 * @param string $watchtext
 */
function insert_maintenance_flags($rLog, $language, $watchtext)
{
    global $translate;

    $flags = [''];
    if ($rLog['needs_maintenance'] > 0) {
        if ($rLog['needs_maintenance'] == 2) {
            $mstate = 'geocache needs maintenance';
        } else {
            $mstate = 'geocache is ok';
        }
        $flags[] = $translate->t($mstate, '', basename(__FILE__), __LINE__, '', 1, $language);
    }
    if ($rLog['listing_outdated'] > 0) {
        if ($rLog['listing_outdated'] == 2) {
            $mstate = 'description is outdated';
        } else {
            $mstate = 'description is ok';
        }
        $flags[] = $translate->t($mstate, '', basename(__FILE__), __LINE__, '', 1, $language);
    }
    $flagtext = implode(', ', $flags);

    return mb_ereg_replace('{maintenance_flags}', $flagtext, $watchtext);
}

/**
 * @param string $domain
 */
function is_existent_maildomain($domain)
/**
 * @ignore
 */
function getUser() {

}

function getUser($id, $realm) {

}
{
    $smtp_serverlist = [];
    $smtp_serverweight = [];

    if (getmxrr($domain, $smtp_serverlist, $smtp_serverweight) != false) {

        if (count($smtp_serverlist) > 0) {
            return true;
        }
    }

    // check if A exists
    $a = dns_get_record($domain, DNS_A);
    if (count($a) > 0) {
        return true;
    }

    return false;
}


function getToMailDomain($mail)
/**
 * @ignore
 */
function getUser() {

}

function getUser($id, $realm) {

}
{
    if ($mail == '') {
        return '';
    }

    if (strrpos($mail, '@') === false) {
        $domain = 'localhost';
    } else {
        $domain = substr($mail, strrpos($mail, '@') + 1);
    }

    return $domain;
}


//
// checks if other instance is running, creates pid-file for locking
//
function CreatePidFile($PidFile)
{
    if (!CheckDaemon($PidFile)) {
        return false;
    }

    if (file_exists($PidFile)) {
        echo "Error: Pidfile (" . $PidFile . ") already present at " . __FILE__ . ":" . __LINE__ . "!\n";

        return false;
    } else {
        if ($pidfile = @fopen($PidFile, "w")) {
            fputs($pidfile, posix_getpid());
            fclose($pidfile);

            return true;
        } else {
            echo "can't create Pidfile $PidFile at " . __FILE__ . ":" . __LINE__ . "!\n";

            return false;
        }
    }
}

//
// checks if other instance of process is running..
//
function CheckDaemon($PidFile)
{
    if ($pidfile = @fopen($PidFile, 'rb')) {
        $pid_daemon = fgets($pidfile, 20);
        fclose($pidfile);

        $pid_daemon = (int) $pid_daemon;

        // process running?
        if (posix_kill($pid_daemon, 0)) {
            // yes, good bye
            echo "Error: process already running with pid=$pid_daemon!\n";
            false;
        } else {
            // no, remove pid_file
            echo 'process not running, removing old pid_file (' . $PidFile . ")\n";
            unlink($PidFile);

            return true;
        }
    } else {
        return true;
    }
}

//
// deletes pid-file
//
function CleanupAndExit($PidFile, $message = false)
{
    if ($pidfile = @fopen($PidFile, 'rb')) {
        $pid = fgets($pidfile, 20);
        fclose($pidfile);
        if ($pid == posix_getpid()) {
            unlink($PidFile);
        }
    } else {
        echo "Error: can't delete own pidfile (" . $PidFile . ") at " . __FILE__ . ":" . __LINE__ . "!\n";
    }

    if ($message) {
        echo $message . "\n";
    }
}

Push — development ( a1bf21...cffa7e )

runwatch.php ➔ insert_recommendation() A

Complexity

Size

Duplication

Importance

2 paths for user data to reach this point

General Strategies to prevent injection

2 paths for user data to reach this point

General Strategies to prevent injection

OpencachingDeutschland / oc-server3

Push — development ( a1bf21...cffa7e )

runwatch.php ➔ insert_recommendation() A

Complexity

Size

Duplication

Importance

2 paths for user data to reach this point

General Strategies to prevent injection

2 paths for user data to reach this point

General Strategies to prevent injection

Duplication Side-by-Side

Filter issues like
