108 lines
3.5 KiB
PHP
108 lines
3.5 KiB
PHP
<?php
|
||
|
||
namespace App\Jobs;
|
||
|
||
use Twitter;
|
||
use App\Note;
|
||
use App\Contact;
|
||
use Jonnybarnes\IndieWeb\Numbers;
|
||
use Jonnybarnes\IndieWeb\NotePrep;
|
||
use Illuminate\Queue\SerializesModels;
|
||
use Illuminate\Queue\InteractsWithQueue;
|
||
use Illuminate\Contracts\Queue\ShouldQueue;
|
||
|
||
class SyndicateToTwitter extends Job implements ShouldQueue
|
||
{
|
||
use InteractsWithQueue, SerializesModels;
|
||
|
||
protected $note;
|
||
|
||
/**
|
||
* Create a new job instance.
|
||
*
|
||
* @return void
|
||
*/
|
||
public function __construct(Note $note)
|
||
{
|
||
$this->note = $note;
|
||
}
|
||
|
||
/**
|
||
* Execute the job.
|
||
*
|
||
* @param \Jonnybarnes\IndieWeb\Numbers $numbers
|
||
* @param \Jonnybarnes\IndieWeb\NotePrep $noteprep
|
||
* @return void
|
||
*/
|
||
public function handle(Numbers $numbers, NotePrep $noteprep)
|
||
{
|
||
$noteSwappedNames = $this->swapNames($this->note->getOriginal('note'));
|
||
$shorturl = 'https://' . config('url.shorturl') . '/t/' . $numbers->numto60($this->note->id);
|
||
$tweet = $noteprep->createNote($noteSwappedNames, $shorturl, 140, true);
|
||
$tweetOpts = ['status' => $tweet, 'format' => 'json'];
|
||
if ($this->note->in_reply_to) {
|
||
$tweetOpts['in_reply_to_status_id'] = $noteprep->replyTweetId($this->note->in_reply_to);
|
||
}
|
||
|
||
/*if ($this->note->location) {
|
||
$explode = explode(':', $this->note->location);
|
||
$location = (count($explode) == 2) ? explode(',', $explode[0]) : explode(',', $explode);
|
||
$lat = trim($location[0]);
|
||
$long = trim($location[1]);
|
||
$jsonPlaceId = Twitter::getGeoReverse(array('lat' => $lat, 'long' => $long, 'format' => 'json'));
|
||
$parsePlaceId = json_decode($jsonPlaceId);
|
||
$placeId = $parsePlaceId->result->places[0]->id ?: null;
|
||
$tweetOpts['lat'] = $lat;
|
||
$tweetOpts['long'] = $long;
|
||
if ($placeId) {
|
||
$tweetOpts['place_id'] = $placeId;
|
||
}
|
||
}*/
|
||
|
||
$mediaItems = $this->note->getMedia();
|
||
if (count($mediaItems) > 0) {
|
||
foreach ($mediaItems as $item) {
|
||
$uploadedMedia = Twitter::uploadMedia(['media' => file_get_contents($item->getUrl())]);
|
||
$mediaIds[] = $uploadedMedia->media_id_string;
|
||
}
|
||
$tweetOpts['media_ids'] = implode(',', $mediaIds);
|
||
}
|
||
|
||
$responseJson = Twitter::postTweet($tweetOpts);
|
||
$response = json_decode($responseJson);
|
||
$tweetId = $response->id;
|
||
$this->note->tweet_id = $tweetId;
|
||
$this->note->save();
|
||
}
|
||
|
||
/**
|
||
* Swap @names in a note.
|
||
*
|
||
* When a note is being saved and we are posting it to twitter, we want
|
||
* to swap our @local_name to Twitter’s @twitter_name so the user get’s
|
||
* mentioned on Twitter.
|
||
*
|
||
* @param string $note
|
||
* @return string $noteSwappedNames
|
||
*/
|
||
private function swapNames($note)
|
||
{
|
||
$regex = '/\[.*?\](*SKIP)(*F)|@(\w+)/'; //match @alice but not [@bob](...)
|
||
$noteSwappedNames = preg_replace_callback(
|
||
$regex,
|
||
function ($matches) {
|
||
try {
|
||
$contact = Contact::where('nick', '=', mb_strtolower($matches[1]))->firstOrFail();
|
||
} catch (\Illuminate\Database\Eloquent\ModelNotFoundException $e) {
|
||
return '@' . $matches[1];
|
||
}
|
||
$twitterHandle = $contact->twitter;
|
||
|
||
return '@' . $twitterHandle;
|
||
},
|
||
$note
|
||
);
|
||
|
||
return $noteSwappedNames;
|
||
}
|
||
}
|