Jonny Barnes
d7da42b626
We don’t need the complexity of S3. Sepcifically the complexity of managing my own AWS account, flysystem made the Laravel side easy. A command is added to copy the the S3 files over to local storage.
122 lines
4.2 KiB
PHP
122 lines
4.2 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace App\Jobs;
|
||
|
||
use App\Exceptions\RemoteContentNotFoundException;
|
||
use App\Models\Note;
|
||
use App\Models\WebMention;
|
||
use GuzzleHttp\Client;
|
||
use GuzzleHttp\Exception\GuzzleException;
|
||
use GuzzleHttp\Exception\RequestException;
|
||
use Illuminate\Bus\Queueable;
|
||
use Illuminate\Contracts\Queue\ShouldQueue;
|
||
use Illuminate\Queue\InteractsWithQueue;
|
||
use Illuminate\Queue\SerializesModels;
|
||
use Jonnybarnes\WebmentionsParser\Exceptions\InvalidMentionException;
|
||
use Jonnybarnes\WebmentionsParser\Parser;
|
||
use Mf2;
|
||
|
||
class ProcessWebMention implements ShouldQueue
|
||
{
|
||
use InteractsWithQueue;
|
||
use Queueable;
|
||
use SerializesModels;
|
||
|
||
/**
|
||
* Create a new job instance.
|
||
*/
|
||
public function __construct(
|
||
protected Note $note,
|
||
protected string $source
|
||
) {}
|
||
|
||
/**
|
||
* Execute the job.
|
||
*
|
||
* @throws RemoteContentNotFoundException
|
||
* @throws GuzzleException
|
||
* @throws InvalidMentionException
|
||
*/
|
||
public function handle(Parser $parser, Client $guzzle): void
|
||
{
|
||
try {
|
||
$response = $guzzle->request('GET', $this->source);
|
||
} catch (RequestException $e) {
|
||
throw new RemoteContentNotFoundException;
|
||
}
|
||
$this->saveRemoteContent((string) $response->getBody(), $this->source);
|
||
$microformats = Mf2\parse((string) $response->getBody(), $this->source);
|
||
$webmentions = WebMention::where('source', $this->source)->get();
|
||
foreach ($webmentions as $webmention) {
|
||
// check webmention still references target
|
||
// we try each type of mention (reply/like/repost)
|
||
if ($webmention->type === 'in-reply-to') {
|
||
if ($parser->checkInReplyTo($microformats, $this->note->longurl) === false) {
|
||
// it doesn’t so delete
|
||
$webmention->delete();
|
||
|
||
return;
|
||
}
|
||
// webmention is still a reply, so update content
|
||
dispatch(new SaveProfileImage($microformats));
|
||
$webmention->mf2 = json_encode($microformats);
|
||
$webmention->save();
|
||
|
||
return;
|
||
}
|
||
if ($webmention->type === 'like-of') {
|
||
if ($parser->checkLikeOf($microformats, $this->note->longurl) === false) {
|
||
// it doesn’t so delete
|
||
$webmention->delete();
|
||
|
||
return;
|
||
} // note we don’t need to do anything if it still is a like
|
||
}
|
||
if ($webmention->type === 'repost-of') {
|
||
if ($parser->checkRepostOf($microformats, $this->note->longurl) === false) {
|
||
// it doesn’t so delete
|
||
$webmention->delete();
|
||
|
||
return;
|
||
} // again, we don’t need to do anything if it still is a repost
|
||
}
|
||
}// foreach
|
||
|
||
// no webmention in the db so create new one
|
||
$webmention = new WebMention;
|
||
$type = $parser->getMentionType($microformats); // throw error here?
|
||
dispatch(new SaveProfileImage($microformats));
|
||
$webmention->source = $this->source;
|
||
$webmention->target = $this->note->longurl;
|
||
$webmention->commentable_id = $this->note->id;
|
||
$webmention->commentable_type = Note::class;
|
||
$webmention->type = $type;
|
||
$webmention->mf2 = json_encode($microformats);
|
||
$webmention->save();
|
||
}
|
||
|
||
/**
|
||
* Save the HTML of a webmention for future use.
|
||
*/
|
||
private function saveRemoteContent(string $html, string $url): void
|
||
{
|
||
$filenameFromURL = str_replace(
|
||
['https://', 'http://'],
|
||
['https/', 'http/'],
|
||
$url
|
||
);
|
||
if (str_ends_with($url, '/')) {
|
||
$filenameFromURL .= 'index.html';
|
||
}
|
||
$path = storage_path() . '/HTML/' . $filenameFromURL;
|
||
$parts = explode('/', $path);
|
||
$name = array_pop($parts);
|
||
$dir = implode('/', $parts);
|
||
if (! is_dir($dir) && ! mkdir($dir, 0755, true) && ! is_dir($dir)) {
|
||
throw new \RuntimeException(sprintf('Directory "%s" was not created', $dir));
|
||
}
|
||
file_put_contents("$dir/$name", $html);
|
||
}
|
||
}
|