tmdinosaurcenter
/
tainacan
mirror of https://github.com/tainacan/tainacan
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor bg process heartbeat integration #130

This commit is contained in:
leogermani 2019-01-08 10:36:21 -02:00
parent f65a739a24
commit cbe9fdda49
2 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/importer/class-tainacan-bg-importer-heartbeat.php → src/classes/class-tainacan-background-process-heartbeat.php
View File

@ -1,17 +1,16 @@
<?php
namespace Tainacan\Importer;
use Tainacan;
namespace Tainacan;
class Background_Importer_Heartbeat {
public function __construct() {
global $wpdb;
$this->table = $wpdb->prefix . 'tnc_bg_process';
global $wpdb;
$this->table = $wpdb->prefix . 'tnc_bg_process';
add_filter( 'heartbeat_send', array( &$this, 'bg_process_feedback' ), 10, 2 );
}
/**
* Receive Heartbeat data and respond.
* Receive Heartbeat data and response.
*
* Processes data received via a Heartbeat request, and returns additional data to pass back to the front end.
*
@ -24,7 +23,7 @@ class Background_Importer_Heartbeat {
$user_q = $wpdb->prepare("AND user_id = %d", get_current_user_id());
$status_q = "";
$base_query = "FROM $this->table WHERE 1=1 $status_q $user_q ORDER BY priority DESC, queued_on DESC";
$base_query = "FROM $this->table WHERE processed_last >= NOW() - INTERVAL 10 MINUTE";
$query = "SELECT * $base_query";
$result = $wpdb->get_results($query);
@ -33,4 +32,4 @@ class Background_Importer_Heartbeat {
return $response;
}
}
}

4
src/classes/tainacan-creator.php
View File

@ -162,8 +162,8 @@ $Tainacan_Gutenberg_Block = \Tainacan\GutenbergBlock::get_instance();
$Tainacan_Search_Engine = new \Tainacan\Search_Engine();
$Tainacan_Elastic_press = new \Tainacan\Elastic_Press();
require_once(__DIR__ . '/../importer/class-tainacan-bg-importer-heartbeat.php');
$Tainacan_Importer_Heartbeat = new \Tainacan\Importer\Background_Importer_Heartbeat();
require_once(__DIR__ . '/class-tainacan-background-process-heartbeat.php');
$Tainacan_Importer_Heartbeat = new \Tainacan\Background_Importer_Heartbeat();
$Tainacan_Capabilities = \Tainacan\Capabilities::get_instance();