Adds example for sending a command to a device

iot/composer.json

@@ -2,7 +2,7 @@
     "name": "google/iot-sample",
     "type": "project",
     "require": {
-        "google/cloud-iot": "^0.1",
+        "google/cloud-iot": "^0.5.0",
         "symfony/console": "^3.3"
     },
     "autoload": {
@@ -22,6 +22,7 @@
             "src/list_registries.php",
             "src/patch_es.php",
             "src/patch_rsa.php",
+            "src/send_command_to_device.php",
             "src/set_device_config.php",
             "src/set_device_state.php",
             "src/set_iam_policy.php"

iot/iot.php

@@ -283,6 +283,23 @@
         );
     });
 
+$application->add(new Command('send-command-to-device'))
+    ->addArgument('registry', InputArgument::REQUIRED, 'the registry ID')
+    ->addArgument('device', InputArgument::REQUIRED, 'the device ID')
+    ->addArgument('command-data', InputArgument::REQUIRED, 'the binary data to send as the command')
+    ->addOption('project', '', InputOption::VALUE_REQUIRED, 'The Google Cloud project ID', getenv('GCLOUD_PROJECT'))
+    ->addOption('location', '', InputOption::VALUE_REQUIRED, 'The location of your device registries', 'us-central1')
+    ->setDescription('Sends a command to a device.')
+    ->setCode(function ($input, $output) {
+        send_command_to_device(
+            $input->getArgument('registry'),
+            $input->getArgument('device'),
+            $input->getArgument('command-data'),
+            $input->getOption('project'),
+            $input->getOption('location')
+        );
+    });
+
 $application->add(new Command('set-device-state'))
     ->addArgument('registry', InputArgument::REQUIRED, 'the registry ID')
     ->addArgument('device', InputArgument::REQUIRED, 'the device ID')

iot/src/send_command_to_device.php

@@ -0,0 +1,50 @@
+<?php
+
+/**
+ * Copyright 2018 Google Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+namespace Google\Cloud\Samples\Iot;
+
+# [START iot_send_command_to_device]
+use Google\Cloud\Iot\V1\DeviceManagerClient;
+
+/**
+ * Sends a command to a device.
+ *
+ * @param string $registryId IOT Device Registry ID
+ * @param string $deviceId IOT Device ID
+ * @param string $command The command sent to a device
+ * @param string $projectId Google Cloud project ID
+ * @param string $location (Optional) Google Cloud region
+ */
+function send_command_to_device(
+    $registryId,
+    $deviceId,
+    $command,
+    $projectId,
+    $location = 'us-central1'
+) {
+    print('Sending command to device' . PHP_EOL);
+
+    // Instantiate a client.
+    $deviceManager = new DeviceManagerClient();
+    $deviceName = $deviceManager->deviceName($projectId, $location, $registryId, $deviceId);
+
+    // Response empty on success
+    $deviceManager->sendCommandToDevice($deviceName, $command);
+
+    printf('Command sent' . PHP_EOL);
+}
+# [END iot_send_command_to_device]

iot/test/iotTest.php

@@ -180,6 +180,18 @@ public function testSetDeviceConfig()
         $this->assertContains('Data: ' . $config, $output);
     }
 
+    /** @depends testCreateRsaDevice */
+    public function testSendCommandToDevice()
+    {
+        $command = '{"data":"example of command data"}';
+        $output = $this->runCommand('send-command-to-device', [
+            'registry' => self::$registryId,
+            'device' => self::$devices[0],
+            'command-data' => $command,
+        ]);
+        $this->assertContains('not subscribed to the commands topic', $output);
+    }
+
     /** @depends testSetDeviceConfig */
     public function testGetDeviceConfigs()
     {