<?php
namespace Gravity_Forms\Gravity_Forms\Telemetry;
use Gravity_Forms\Gravity_Forms\GF_Service_Container;
use Gravity_Forms\Gravity_Forms\GF_Service_Provider;
use GFCommon;
use GFFormsModel;
/**
* Class GF_Telemetry_Service_Provider
*
* Service provider for the telemetry Service.
*
* @package Gravity_Forms\Gravity_Forms\Telemetry;
*/
class GF_Telemetry_Service_Provider extends GF_Service_Provider {
const TELEMETRY_SCHEDULED_TASK = 'gravityforms_telemetry_dispatcher';
const BATCH_SIZE = 10;
/**
* Register services to the container.
*
* @since
*
* @param GF_Service_Container $container
*/
public function register( GF_Service_Container $container ) {
require_once GF_PLUGIN_DIR_PATH . 'includes/telemetry/class-gf-telemetry-data.php';
require_once GF_PLUGIN_DIR_PATH . 'includes/telemetry/class-gf-telemetry-snapshot-data.php';
}
/**
* Initialize the scheduler.
*
* @since
*
* @param GF_Service_Container $container
*
* @return void
*/
public function init( GF_Service_Container $container ) {
add_action( self::TELEMETRY_SCHEDULED_TASK, array( $this, 'enqueue_telemetry_batches' ) );
}
/**
* Enqueue batches of telemetry events to be processed in the background.
*
* @since
*
* @return void
*/
public function enqueue_telemetry_batches() {
// Only run once a week.
$last_run = get_option( 'gf_last_telemetry_run', 0 );
$current_time = time();
if ( $current_time - $last_run < 60 * 60 * 24 * 7 ) {
return;
}
update_option( 'gf_last_telemetry_run', $current_time );
\GFCommon::log_debug( __METHOD__ . sprintf( '(): Enqueuing telemetry batches' ) );
GF_Telemetry_Data::take_snapshot();
$processor = $this->container->get( \Gravity_Forms\Gravity_Forms\Async\GF_Background_Process_Service_Provider::TELEMETRY );
$full_telemetry_data = GF_Telemetry_Data::get_data();
$snapshot = $full_telemetry_data['snapshot'];
// Enqueue the snapshot first, alone, to be sent to its own endpoint.
$processor->push_to_queue( $snapshot );
$processor->save()->dispatch();
$full_telemetry_data = array_chunk( $full_telemetry_data['events'], self::BATCH_SIZE, true );
foreach ( $full_telemetry_data as $batch ) {
$processor->push_to_queue( $batch );
$processor->save()->dispatch();
}
// Clear saved telemetry data except the snapshot.
update_option(
'gf_telemetry_data',
array(
'snapshot' => $snapshot,
'events' => array(),
),
false
);
}
}