- <?php
- namespace App\Jobs;
-
- use DB, Log;
- use App\Jobs\Job;
- use Illuminate\Contracts\Bus\SelfHandling;
- use Illuminate\Contracts\Queue\ShouldQueue;
- use DateTime, DateTimeZone;
-
- class NotifyOfNewLocations extends Job implements SelfHandling, ShouldQueue
- {
- private $_dbid;
-
- public function __construct($dbid) {
- $this->_dbid = $dbid;
- }
-
- public function handle() {
- $db = DB::table('databases')->where('id','=',$this->_dbid)->first();
- $urls = preg_split('/\s+/', $db->ping_urls);
-
- $location = [
- 'location' => json_decode($db->last_location, true)
- ];
-
- if($db->current_trip)
- $location['trip'] = json_decode($db->current_trip, true);
-
- $location = json_encode($location, JSON_UNESCAPED_SLASHES);
-
- foreach($urls as $url) {
- if(trim($url)) {
- $ch = curl_init($url);
- curl_setopt($ch, CURLOPT_POST, true);
- curl_setopt($ch, CURLOPT_HTTPHEADER, [
- 'Content-Type: application/json',
- 'Authorization: Bearer '.$db->read_token,
- 'Compass-Url: '.env('BASE_URL').'api/last?token='.$db->read_token.'&geocode=1'
- ]);
- curl_setopt($ch, CURLOPT_POSTFIELDS, $location);
- curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
- $response = curl_exec($ch);
- $timestamp = '';
- if($db->last_location) {
- $timestamp = json_decode($db->last_location)->properties->timestamp;
- }
- Log::info("Notifying ".$url." with current location: ".$timestamp);
- Log::info($response);
- }
- }
- }
- }
|