cron.php

<?php
// Copyright (C) 2019 Remy van Elst

// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Affero General Public License for more details.

// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

error_reporting(E_ALL & ~E_NOTICE);
$result = array();
if (php_sapi_name() == "cli") {
  foreach (glob( __DIR__ . "/functions/*.php") as $filename) {
    require($filename);
  }

  $removal_queue = array();
  $tmp_check_file = $check_file . ".tmp";
  if (!copy($check_file, $tmp_check_file)) {
    echo "\nFailed to copy $check_file to $tmp_check_file.\n";
    die();
  }

  $file = file_get_contents($tmp_check_file);
  if ($file === FALSE) {
    $result['errors'][] = "Can't open database.";
  }
  $json_a = json_decode($file, true);
  if ($json_a === null && json_last_error() !== JSON_ERROR_NONE) {
    $result['errors'][] = "Can't read database: " . htmlspecialchars(json_last_error());
    
  }

  if (count($json_a) == 0) {
    echo "\nEmpty checklist.\n";
    die();
  }

  echo "\n===== start " . date('Y-m-d H:i:s') . "=====\n";

  foreach ($json_a as $key => $value) {
    $domain = $value['domain'];
    $email = $value['email'];

    $val_domain = validate_domains($domain);
    if (count($val_domain['errors']) >= 1 ) {
      $errors = $val_domain['errors'];
      $errortexts = '';
      foreach ($errors as $error_value) {
        echo "\n" . $error_value . "  Domain: " . $domain . "\n";
        $errortexts .= $error_value . "\n";
        send_error_mail($domain, $email, $errors);
        continue;
      }
      
      $json_a[$key]['errors'] += 1;
      $check_json = json_encode($json_a); 
      if(file_put_contents($check_file, $check_json, LOCK_EX)) {
        echo "\nError count updated to " . $json_a[$key]['errors'] . " for " . $domain . "\n";
      } else {
        echo "\nCan't write database.\n";
        continue;
      }
      if ($json_a[$key]['errors'] >= 7) {
        echo "\nToo many errors. Adding " . $domain . " to removal queue.\n";
        $removal_queue[] = $key;
        continue;
      }

      #if (strpos($errortexts,'\nDomain has expired certificate in chain') !== false) {
      #  continue;
      #}
    }
    $raw_chain = get_raw_chain($domain);
    $counter = 0;
    if (count($raw_chain['chain']) > 0) {
      foreach ($raw_chain['chain'] as $chain_key => $chain_value) {
        $counter += 1;
        $cert_exp_date = cert_expiry_date($chain_value);
        $cert_cn = cert_cn($chain_value);
        $cert_expiry = cert_expiry($chain_value);

        #echo "\tCert Chain #" . $counter . ". Expiry Date: " . date("Y-m-d H:i:s T", $cert_exp_date) . ". Common Name: " . $cert_cn . "\n";

        cert_expiry_emails($domain, $email, $cert_expiry, $chain_value);
      }

    }
    $file = file_get_contents($check_file);
    if ($file === FALSE) {
      echo "\nCan't open database.\n";
      continue;
    }
    $json_a = json_decode($file, true);
    if ($json_a === null && json_last_error() !== JSON_ERROR_NONE) {
      echo "\nCan't read database\n";
      continue;
    }
    if ($json_a[$key]['errors'] != 0) {
      if (strpos($errortexts,'Domain has expired certificate in chain') !== false) {
        $json_a[$key]['errors'] = 0;
        $check_json = json_encode($json_a); 
        if(file_put_contents($check_file, $check_json, LOCK_EX)) {
          echo "\nExpired certificate. Error count reset to 0 for " . $domain . "\n";
        } else {
          echo "\nCan't write database.\n";
          die();
        }
      }
    }

    echo ".";
    
  } 
  echo "\n===== end " . date('Y-m-d H:i:s') . "=====\n";


  if ( count($removal_queue) != 0 ) {
   echo "Processing removal queue.\n";
   foreach ($removal_queue as $remove_key => $remove_value) {
    $unsub_url = "https://" . $current_link . "/unsubscribe.php?cron=auto&id=" . $remove_value;
     $file = file_get_contents($unsub_url);
     if ($file === FALSE) {
       $error = error_get_last();
       echo "HTTP request failed. Error was: " . $error['message'];
       echo "\tRemoval Error.\n";
       continue;
     } else {
       echo "\tRemoved $remove_value.\n";
     }
   }
 }

    // remove non-confirmed subs older than 7 days
 $tmp_pre_check_file = $pre_check_file . ".tmp";
 if (!copy($pre_check_file, $tmp_pre_check_file)) {
  echo "Failed to copy $pre_check_file to $tmp_pre_check_file.\n";
  die();
}

$tmp_pre_file = file_get_contents($tmp_pre_check_file);
if ($tmp_pre_file === FALSE) {
  echo "Can't open database.\n";
  die();
}
$tmp_pre_json_a = json_decode($tmp_pre_file, true);
if ($tmp_pre_json_a === null && json_last_error() !== JSON_ERROR_NONE) {
  echo "Can't read database.\n";
  die();
}

if (count($tmp_pre_json_a) == 0) {
  echo "Empty pre-checklist.\n";
  die();
}

foreach ($tmp_pre_json_a as $pre_key => $pre_value) {
  $today = strtotime(date("Y-m-d"));
  $pre_add_date = strtotime(date("Y-m-d",$pre_value['pre_add_date']));
  $pre_add_diff = $today - $pre_add_date;
  if ($pre_add_diff > "604800") {
    unset($tmp_pre_json_a[$pre_key]);
    $tmp_pre_json = json_encode($tmp_pre_json_a); 
    if(file_put_contents($pre_check_file, $tmp_pre_json, LOCK_EX)) {
      echo "Subscription for " . $pre_value['domain'] . " from " . $pre_value['email'] . " older than 7 days. Removing from subscription list.\n";
    } else {
      echo "Failed to remove subscription for " . $pre_value['domain'] . " from " . $pre_value['email'] . " older than 7 days from subscription list.\n";
    }
  }
}

} else {
  header('HTTP/1.0 301 Moved Permanently');  
  header('Location: /');
}

?>