PHP8

[m6w6/seekat] / examples / watchowned.php

diff --git a/examples/watchowned.php b/examples/watchowned.php
new file mode 100755 (executable)
index 0000000..d1ff879
--- /dev/null
+++ b/examples/watchowned.php
@@ -0,0 +1,46 @@
+#!/usr/bin/env php
+<?php
+
+use http\Client;
+use Monolog\Handler\StreamHandler;
+use Monolog\Logger;
+use seekat\API;
+use seekat\API\Links;
+
+require_once __DIR__."/../vendor/autoload.php";
+
+$log = new Monolog\Logger("seekat");
+$log->pushHandler((new Monolog\Handler\StreamHandler(STDERR))
+       ->setLevel(Monolog\Logger::WARNING));
+
+$cli = new http\Client("curl", "seekat");
+
+$api = new API(API\Future\amp(), [
+       "Authorization" => "token ".getenv("GITHUB_TOKEN")
+], null, $cli, $log);
+
+$api(function($api) {
+       $count = 0;
+       $subscribed = yield $api->user->subscriptions(["per_page" => 3]);
+
+       while ($subscribed) {
+               /* pro-actively queue the next request */
+               $next = Links\next($subscribed);
+               foreach ($subscribed->getData() as $subscription) {
+                       if ($subscription->fork) {
+                               printf("skipping fork %s\n", $subscription->full_name);
+                               continue;
+                       }
+                       ++$count;
+                       printf("watching %s owned by %s (repo is %s)\n",
+                               $subscription->full_name,
+                               $subscription->owner->login,
+                               $subscription->private ? "private" : "public"
+                       );
+               }
+               $subscribed = yield $next;
+       }
+       return $count;
+})->onResolve(function($error, $count) {
+       printf("Listed %d repos\n", $count);
+});