use seekat\API;
use React\Promise\PromiseInterface;
+use seekat\API\Links\ {
+ function first, function last, function next, function prev
+};
describe("API", function() {
- it("should return API on property access", function() {
- expect($this->api->users)->to->be->instanceof(API::class);
- });
+ describe("Interface", function() {
+ it("should return API on property access", function() {
+ expect($this->api->users)->to->be->instanceof(API::class);
+ });
- it("should return a clone on property access", function() {
- expect($this->api->users)->to->not->equal($this->api);
- });
+ it("should return a clone on property access", function() {
+ expect($this->api->users)->to->not->equal($this->api);
+ });
- it("should return PromiseInterface on function call", function() {
- expect($this->api->users->m6w6())->to->be->instanceof(PromiseInterface::class);
+ it("should return PromiseInterface on function call", function() {
+ expect($this->api->users->m6w6())->to->be->instanceof(PromiseInterface::class);
+ });
});
- it("should successfully request /users/m6w6", function() {
- $this->api->users->m6w6()->then(function($json) use(&$m6w6) {
- $m6w6 = $json;
- })->otherwise(function($error) use(&$errors) {
- $errors[] = (string) $error;
+ describe("Requests", function() {
+
+ it("should successfully request /users/m6w6", function() {
+ $this->api->users->m6w6()->then(function($json) use(&$m6w6) {
+ $m6w6 = $json;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+
+ $this->api->send();
+
+ expect($errors)->to->be->empty;
+ expect($m6w6->login)->to->loosely->equal("m6w6");
});
- $this->api->send();
+ it("should export an array of data, url, type, links and headers", function() {
+ $this->api->users->m6w6()->then(function($json) use(&$m6w6) {
+ $m6w6 = $json;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
- expect($errors)->to->be->empty;
- expect($m6w6->login)->to->loosely->equal("m6w6");
- });
+ $this->api->send();
- it("should return the count of followers when accessing /users/m6w6->followers", function() {
- $this->api->users->m6w6()->then(function($m6w6) use(&$followers) {
- $followers = $m6w6->followers;
- })->otherwise(function($error) use(&$errors) {
- $errors[] = (string) $error;
+ expect($errors)->to->be->empty();
+ expect($m6w6->export())->to->be->an("array")->and->contain->keys([
+ "data", "url", "type", "links", "headers"
+ ]);
});
- $this->api->send();
+ it("should return the count of followers when accessing /users/m6w6->followers", function() {
+ $this->api->users->m6w6()->then(function($m6w6) use(&$followers) {
+ $followers = $m6w6->followers;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
- expect($errors)->to->be->empty();
- expect($followers->export())->to->be->an("integer");
- });
+ $this->api->send();
- it("should fetch followers_url when accessing /users/m6w6->followers_url", function() {
- $this->api->users->m6w6()->then(function($m6w6) use(&$followers, &$errors) {
- $m6w6->followers_url()->then(function($json) use(&$followers) {
- $followers = $json;
- })->otherwise(function($error) use(&$errors) {
+ expect($errors)->to->be->empty();
+ expect($followers->export()["data"])->to->be->an("integer");
+ });
+
+ it("should fetch followers_url when accessing /users/m6w6->followers_url", function() {
+ $this->api->users->m6w6()->then(function($m6w6) use(&$followers, &$errors) {
+ $m6w6->followers_url()->then(function($json) use(&$followers) {
+ $followers = $json;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+ }, function($error) use(&$errors) {
$errors[] = (string) $error;
});
- })->otherwise(function($error) use(&$errors) {
- $errors[] = (string) $error;
+
+ $this->api->send();
+
+ expect($errors)->to->be->empty;
+ expect($followers->export()["data"])->to->be->an("array");
+ expect(count($followers))->to->be->above(0);
});
- $this->api->send();
+ it("should provide access to array indices", function() {
+ $this->api->users->m6w6()->then(function($m6w6) use(&$followers, &$errors) {
+ $m6w6->followers_url()->then(function($json) use(&$followers) {
+ $followers = $json;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+
+ $this->api->send();
+
+ expect($errors)->to->be->empty;
+ expect($followers->{0})->to->be->an("object");
+ expect($followers->export()["data"][0])->to->be->an("object");
+ });
+
+ it("should handle a few requests in parallel", function() {
+ $this->api->users->m6w6()->then(function($m6w6) use(&$count, &$errors) {
+ foreach ($m6w6 as $key => $val) {
+ switch ($key) {
+ case "html_url":
+ case "avatar_url":
+ break;
+ default:
+ if (substr($key, -4) === "_url") {
+ $val->get()->then(function() use(&$count) {
+ ++$count;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+ }
+ }
+ }
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+
+ $this->api->send();
+
+ expect($errors)->to->be->empty;
+ expect($count)->to->be->above(2);
+ });
- expect($errors)->to->be->empty;
- expect($followers->export())->to->be->an("array");
- expect(count($followers))->to->be->above(0);
});
- it("should handle a few requests in parallel", function() {
- $this->api->users->m6w6()->then(function($m6w6) use(&$count, &$errors) {
- foreach ($m6w6 as $key => $val) {
- switch ($key) {
- case "html_url":
- case "avatar_url":
- break;
- default:
- if (substr($key, -4) === "_url") {
- $val->get()->then(function() use(&$count) {
- ++$count;
- })->otherwise(function($error) use(&$errors) {
- $errors[] = (string) $error;
- });
- }
+ describe("Cache", function() {
+ it("should cache successive calls", function() {
+ $cache = new API\Call\Cache\Service\Hollow();
+ $this->api->users->m6w6(null, null, $cache)->then(function($json) use(&$m6w6) {
+ $m6w6 = $json;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+
+ $this->api->send();
+
+ $data = $cache->getStorage();
+ $this->api->users->m6w6(null, null, $cache)->then(function($json) use(&$m6w6_) {
+ $m6w6_ = $json;
+ }, function($error) use(&$errors) {
+ $errors[] = (string) $error;
+ });
+
+ $this->api->send();
+
+ expect($errors)->to->be->empty;
+ expect($m6w6->login)->to->loosely->equal("m6w6");
+ expect($m6w6_->login)->to->loosely->equal("m6w6");
+ expect($data)->to->equal($cache->getStorage());
+ expect(count($cache->getStorage()))->to->equal(1);
+ });
+ xit("should refresh stale cache entries");
+ });
+
+ describe("Generators", function() {
+ it("should iterate over a generator of promises", function() {
+ ($this->api)(function($api) use(&$gists_count, &$files_count) {
+ $gists = yield $api->users->m6w6->gists();
+ $gists_count = count($gists);
+ foreach ($gists as $gist) {
+ $files_count += count($gist->files);
}
- }
- })->otherwise(function($error) use(&$errors) {
- $errors[] = (string) $error;
+ });
+ expect($gists_count)->to->be->above(0);
+ expect($files_count)->to->be->at->least($gists_count);
+ });
+ it("should iterate over a generator of promises with links", function() {
+ ($this->api)(function($api) use(&$repos, &$first, &$next, &$last, &$prev) {
+ $repos = yield $api->users->m6w6->repos(["per_page" => 1]);
+ $last = yield last($repos);
+ $prev = yield prev($last);
+ $next = yield next($prev);
+ $first = yield first($prev);
+ return -123;
+ })->done(function($value) use(&$result) {
+ $result = $value;
+ });
+
+ expect($result)->to->equal(-123);
+ expect($repos->export()["data"])->to->loosely->equal($first->export()["data"]);
+ expect($last->export()["data"])->to->loosely->equal($next->export()["data"]);
});
+ });
- $this->api->send();
+ describe("Errors", function() {
+ it("should handle cancellation gracefully", function() {
+ $this->api->users->m6w6()->then(function($value) use(&$result) {
+ $result = $value;
+ }, function($error) use(&$message) {
+ $message = \seekat\Exception\message($error);
+ })->cancel();
+ expect($result)->to->be->empty();
+ expect($message)->to->equal("Cancelled");
+ });
- expect($errors)->to->be->empty;
- expect($count)->to->be->above(2);
+ it("should handle request errors gracefully", function() {
+ $this->api->generate->a404()->then(function($value) use(&$result) {
+ $result = $value;
+ }, function($error) use(&$message) {
+ $message = \seekat\Exception\message($error);
+ });
+ $this->api->send();
+ expect($result)->to->be->empty();
+ expect($message)->to->equal("Not Found");
+ });
});
});
projects / m6w6 / seekat / blobdiff