attempt to disconnect and reconnect from the database between jobs

lib/Telegraph/Webmention.php

@@ -37,6 +37,8 @@ class Webmention {
   }
 
   public static function send($id, $client=false, $http=false) {
+    initdb();
+
     $webmention = ORM::for_table('webmentions')->where('id', $id)->find_one();
     if(!$webmention) {
       echo 'Webmention '.$id.' was not found'."\n";
@@ -98,7 +100,10 @@ class Webmention {
 
     $webmention->save();
 
-    return self::updateStatus($webmention, $response['code'], $status, $response['body']);
+    $result = self::updateStatus($webmention, $response['code'], $status, $response['body']);
+    $pdo = ORM::get_db();
+    $pdo = null;
+    return $result;
   }
 
 }

lib/helpers.php

@@ -7,9 +7,11 @@ if(array_key_exists('ENV', $_ENV)) {
   require(dirname(__FILE__).'/../config.php');
 }
 
-ORM::configure('mysql:host=' . Config::$db['host'] . ';dbname=' . Config::$db['database']);
-ORM::configure('username', Config::$db['username']);
-ORM::configure('password', Config::$db['password']);
+function initdb() {
+  ORM::configure('mysql:host=' . Config::$db['host'] . ';dbname=' . Config::$db['database']);
+  ORM::configure('username', Config::$db['username']);
+  ORM::configure('password', Config::$db['password']);
+}
 
 function view($template, $data=[]) {
   global $templates;

public/index.php

@@ -2,6 +2,8 @@
 chdir('..');
 include('vendor/autoload.php');
 
+initdb();
+
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
 $router = new League\Route\RouteCollection;