implement backfilling for newly discovered actors

1 files changed, 44 insertions, 0 deletions

diff --git a/Digitigrade/Job/ProcessIncomingSimplePush.php b/Digitigrade/Job/ProcessIncomingSimplePush.php
new file mode 100644
index 0000000..a48a70b
--- /dev/null
+++ b/Digitigrade/Job/ProcessIncomingSimplePush.php
@@ -0,0 +1,44 @@
+<?php
+namespace Digitigrade\Job;
+
+use Digitigrade\Job;
+use Digitigrade\JobQueue;
+use Digitigrade\Logger;
+
+class ProcessIncomingSimplePush extends Job {
+    public string $uri;
+
+    public function __construct(string $uri) {
+        $this->uri = $uri;
+        $this->remainingTries = 3;
+    }
+
+    public function run() {
+        $log = Logger::getInstance();
+
+        $log->info("processing simple push for $this->uri");
+
+        $result = send_request_authenticated($this->uri);
+        if (!str_contains($result->headers[0], '200')) {
+            throw new \RuntimeException("unable to fetch given simple push uri: $this->uri");
+        }
+        $obj = json_decode($result->body);
+
+        if ($obj === null) {
+            throw new \RuntimeException("fetched content doesn't look like valid json");
+        }
+        if (!isset($obj->type, $obj->self)) {
+            throw new \RuntimeException('the object needs to have `type` and `self` properties');
+        }
+        if ($obj->self != $this->uri) {
+            throw new \RuntimeException("fetched object has a different uri from the one provided ($obj->self != $this->uri)");
+        }
+
+        $log->info('fetch successful, pushed object will be dealt with soon');
+        (new ProcessIncomingPush($obj))->submit();
+    }
+
+    public function submitDelayed(int $delaySecs) {
+        JobQueue::getInstance()->submitDelayed($this, $delaySecs);
+    }
+}
\ No newline at end of file