| Server IP : 104.21.38.3 / Your IP : 162.158.189.116 Web Server : Apache System : Linux krdc-ubuntu-s-2vcpu-4gb-amd-blr1-01.localdomain 5.15.0-142-generic #152-Ubuntu SMP Mon May 19 10:54:31 UTC 2025 x86_64 User : www ( 1000) PHP Version : 7.4.33 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /www/wwwroot/coircraft.com/wp-content/plugins/caldera-forms/cf2/RestApi/Queue/ |
Upload File : |
<?php
namespace calderawp\calderaforms\cf2\RestApi\Queue;
use calderawp\calderaforms\cf2\RestApi\AuthorizesRestApiRequestWithCfProKeys;
use calderawp\calderaforms\cf2\RestApi\Endpoint;
use calderawp\calderaforms\cf2\Services\QueueSchedulerService;
class RunQueue extends Endpoint
{
use AuthorizesRestApiRequestWithCfProKeys;
public function getUri()
{
return 'queue';
}
/** @inheritdoc */
protected function getArgs()
{
return [
'methods' => 'POST',
'callback' => [$this, 'runQueue'],
'permission_callback' => [$this, 'checkKeys' ],
'args' => [
'jobs' => [
'description' => __('Total jobs to run per back', 'caldera-forms'),
'required' => false,
'default' => 10,
'sanitize_callback' => 'absint'
],
'public' => [
'type' => 'string',
'required' => false,
'default' => ''
]
]
];
}
/**
* Trigger queue manger from remote ping
*
* @since 1.8.0
*
* @param \WP_REST_Request $request
* @return \WP_REST_Response
*/
/**
* @param \WP_REST_Request $request
* @return mixed|null|\WP_REST_Response
*/
public function runQueue(\WP_REST_Request $request)
{
$totalJobs = caldera_forms_get_v2_container()
->getService(QueueSchedulerService::class )
->runJobs($request['jobs']);
$statusCode = $totalJobs > 0 ? 201 : 200;
$response = rest_ensure_response(['totalJobs' => $totalJobs]);
$response->set_status($statusCode);
return $response;
}
}