Adding telemetry.

# Conflicts:
#	Tasks/DockerV0/container.ts
#	Tasks/DockerV1/container.ts

Author: Harshil Lodhi

Tasks/DockerV0/container.ts

@@ -35,12 +35,12 @@ var action = tl.getInput("action", true);
 var telemetry = {
     registryType: registryType,
     command: action
-    command: action !== "Run a Docker command" ? action : tl.getInput("customCommand", true)
 };
 
- console.log("##vso[telemetry.publish area=%s;feature=%s]%s",
-     "TaskEndpointId",
-     "DockerV0",
+console.log("##vso[telemetry.publish area=%s;feature=%s]%s",
+    "TaskEndpointId",
+    "DockerV0",
+    JSON.stringify(telemetry));
      JSON.stringify(telemetry));
 /* tslint:disable:no-var-requires */
 require({

Tasks/DockerV1/container.ts

@@ -55,6 +55,15 @@ console.log("##vso[telemetry.publish area=%s;feature=%s]%s",
 
 var commandImplementation = require("./containercommand");
 if (command in dockerCommandMap) {
+    var telemetry = {
+        registryType: registryType,
+        command: command
+    };
+
+    console.log("##vso[telemetry.publish area=%s;feature=%s]%s",
+        "TaskEndpointId",
+        "DockerV1",
+        JSON.stringify(telemetry));
     commandImplementation = require(dockerCommandMap[command]);
 }
 

Tasks/HelmDeployV0/src/helm.ts

@@ -58,6 +58,16 @@ async function run() {
 
     var helmCli : helmcli = new helmcli();
     helmCli.login();
+    var connectionType = tl.getInput("connectionType", true);
+    var telemetry = {
+        connectionType: connectionType,
+        command: command
+    };
+
+    console.log("##vso[telemetry.publish area=%s;feature=%s]%s",
+        "TaskEndpointId",
+        "HelmDeployV0",
+        JSON.stringify(telemetry));
 
     try {
         switch (command){

Tasks/KubernetesV0/src/kubernetes.ts

@@ -72,6 +72,15 @@ function executeKubectlCommand(clusterConnection: ClusterConnection) : any {
     var command = tl.getInput("command", true);
     var result = "";
     var ouputVariableName =  tl.getInput("kubectlOutput", false);  
+    var telemetry = {
+        registryType: registryType,
+        command: command
+    };
+
+    console.log("##vso[telemetry.publish area=%s;feature=%s]%s",
+        "TaskEndpointId",
+        "KubernetesV0",
+        JSON.stringify(telemetry));
     return kubectl.run(clusterConnection, command, (data) => result += data)
     .fin(function cleanup() {
         if(ouputVariableName) {

Tasks/KubernetesV1/src/kubernetes.ts

@@ -11,7 +11,9 @@ tl.setResourcePath(path.join(__dirname, '..' , 'task.json'));
 // Change to any specified working directory
 tl.cd(tl.getInput("cwd"));
 
+var registryType = tl.getInput("containerRegistryType", true);
 var command = tl.getInput("command", true);
+
 var kubeconfigfilePath;
 if (command === "logout") {
     kubeconfigfilePath = tl.getVariable("KUBECONFIG");
@@ -67,6 +69,15 @@ function executeKubectlCommand(clusterConnection: ClusterConnection, command: st
         commandImplementation = require(commandMap[command]);
     }
 
+    var telemetry = {
+        registryType: registryType,
+        command: command
+    };
+
+    console.log("##vso[telemetry.publish area=%s;feature=%s]%s",
+        "TaskEndpointId",
+        "KubernetesV1",
+        JSON.stringify(telemetry));
     var result = "";
     return commandImplementation.run(clusterConnection, command, (data) => result += data)
     .fin(function cleanup() {