Actually update profile after setting changing the name

Author: WyriHaximus

examples/profile-update-name-async.php

@@ -22,7 +22,8 @@
 ))->withAccessToken(
     $config['access_token']['token'],
     $config['access_token']['secret']
-)->profile()->done(function (ProfileInterface $profile) use ($argv) {
+)->profile()->then(function (ProfileInterface $profile) use ($argv) {
+    echo 'Fetched profile', PHP_EOL;
     resource_pretty_print($profile);
     $emojis = [
         '😈 ',
@@ -72,11 +73,18 @@
         '🎵',
         '🎶',
     ];
+    echo 'Setting new name', PHP_EOL;
     $profile = $profile->withName(sprintf(
         $argv[1],
         $emojis[random_int(0, count($emojis) - 1)]
     ));
     resource_pretty_print($profile);
+
+    echo 'Updating profile', PHP_EOL;
+    return $profile->putProfile();
+})->done(function (ProfileInterface $profile) {
+    echo 'Profile updated', PHP_EOL;
+    resource_pretty_print($profile);
 });
 
 $loop->run();

src/Resource/Async/Profile.php

@@ -3,9 +3,31 @@
 namespace ApiClients\Client\Twitter\Resource\Async;
 
 use ApiClients\Client\Twitter\Resource\Profile as BaseProfile;
+use ApiClients\Foundation\Hydrator\CommandBus\Command\HydrateCommand;
+use ApiClients\Foundation\Transport\CommandBus\Command\RequestCommand;
+use Psr\Http\Message\ResponseInterface;
+use React\Promise\PromiseInterface;
+use RingCentral\Psr7\Request;
+use function React\Promise\resolve;
 
 class Profile extends BaseProfile
 {
+    public function putProfile(): PromiseInterface
+    {
+        $fields = [];
+        foreach ($this->changedFields as $field) {
+            $fields[$field] = $this->$field;
+        }
+
+        $uri = 'account/update_profile.json?' . http_build_query($fields);
+
+        return $this->handleCommand(new RequestCommand(
+            new Request('POST', $uri)
+        ))->then(function (ResponseInterface $response) {
+            return resolve($this->handleCommand(new HydrateCommand('Profile', $response->getBody()->getJson())));
+        });
+    }
+
     public function refresh() : Profile
     {
         throw new \Exception('TODO: create refresh method!');

src/Resource/EmptyProfile.php

@@ -71,4 +71,9 @@ public function withName(string $name): ProfileInterface
     {
         return clone $this;
     }
+
+    public function putProfile()
+    {
+
+    }
 }

src/Resource/Profile.php

@@ -45,6 +45,11 @@ abstract class Profile extends AbstractResource implements ProfileInterface
      */
     protected $description;
 
+    /**
+     * @var array
+     */
+    protected $changedFields = [];
+
     /**
      * @return int
      */
@@ -109,6 +114,12 @@ public function withName(string $name): ProfileInterface
     {
         $clone = clone $this;
         $clone->name = $name;
+        $clone->changedFields['name'] = 'name';
         return $clone;
     }
+
+    public function putProfile()
+    {
+
+    }
 }

src/Resource/ProfileInterface.php

@@ -48,4 +48,9 @@ public function description() : string;
      * @return static
      */
     public function withName(string $name);
+
+    /**
+     * @return static
+     */
+    public function putProfile();
 }

src/Resource/Sync/Profile.php

@@ -8,6 +8,11 @@
 
 class Profile extends BaseProfile
 {
+    public function putProfile()
+    {
+        // TODO: Implement putProfile() method.
+    }
+
     public function refresh() : Profile
     {
         return $this->wait($this->handleCommand(new BuildAsyncFromSyncCommand(self::HYDRATE_CLASS, $this))->then(function (ProfileInterface $profile) {