Sending a warning instead of throwing error when KUBECONFIG is missing. (#146 )

Users/jysin/pm feedback changes v1.2 (#100 )
* Changed dockerfile, manifest, helmchart links and README
2026-06-21 10:39:26 +08:00 · 2021-08-17 16:38:53 +05:30 · 2021-01-07 12:52:48 +05:30 · 2020-12-30 22:17:18 +05:30 · 2020-12-29 19:11:56 +05:30 · 2020-11-25 13:31:47 +05:30
37 changed files with 12352 additions and 394 deletions
@@ -7,10 +7,12 @@ import * as fs from 'fs';
 import * as io from '@actions/io';
 import * as toolCache from '@actions/tool-cache';
 import * as fileHelper from '../src/utilities/files-helper';
-import { workflowAnnotations } from '../src/constants';
+import { getWorkflowAnnotationKeyLabel, getWorkflowAnnotationsJson } from '../src/constants';
 import * as inputParam from '../src/input-parameters';

 import { Kubectl, Resource } from '../src/kubectl-object-model';
+import *  as httpClient from '../src/utilities/httpClient';
+import * as utility from '../src/utilities/utility';

 import { getkubectlDownloadURL } from "../src/utilities/kubectl-util";
 import { mocked } from 'ts-jest/utils';
@@ -36,13 +38,47 @@ const getAllPodsMock = {

 const getNamespaceMock = {
    'code': 0,
-    'stdout': '{"apiVersion": "v1","kind": "Namespace","metadata": {"annotations": {"workflow": ".github/workflows/workflow.yml","runUri": "https://github.com/testRepo/actions/runs/12345"}},"spec": {"finalizers": ["kubernetes"]},"status": {"phase": "Active"}}'
+    'stdout': '{"apiVersion": "v1","kind": "Namespace","metadata": {"annotations": {"githubWorkflow_c11401b9d232942bac19cbc5bc32b42d": "{\'run\': \'202489005\',\'repository\': \'testUser/hello-kubernetes\',\'workflow\': \'workflow1\',\'jobName\': \'build-and-deploy\',\'createdBy\': \'testUser\',\'runUri\': \'https://github.com/testUser/hello-kubernetes/actions/runs/202489005\',\'commit\': \'currentCommit\',\'lastSuccessRunCommit\': \'lastCommit\',\'branch\': \'refs/heads/branch-rename\',\'deployTimestamp\': \'1597062957973\',\'dockerfilePaths\': \'{}\',\'manifestsPaths\': \'[]\',\'helmChartPaths\': \'[]\',\'provider\': \'GitHub\'}","githubWorkflow_21fd7a597282ca5adc05ba99018b3706": "{\'run\': \'202504411\',\'repository\': \'testUser/hello-kubernetes\',\'workflow\': \'workflowMaster\',\'jobName\': \'build-and-deploy\',\'createdBy\': \'testUser\',\'runUri\': \'https://github.com/testUser/hello-kubernetes/actions/runs/202504411\',\'commit\': \'currentCommit1\',\'lastSuccessRunCommit\': \'NA\',\'branch\': \'refs/heads/master\',\'deployTimestamp\': \'1597063919873\',\'dockerfilePaths\': \'{}\',\'manifestsPaths\': \'[]\',\'helmChartPaths\': \'[]\',\'provider\': \'GitHub\'}"}},"spec": {"finalizers": ["kubernetes"]},"status": {"phase": "Active"}}'
 };

+const getWorkflowsUrlResponse = {
+    'statusCode': httpClient.StatusCodes.OK,
+    'body': {
+        "total_count": 2,
+        "workflows": [
+            {
+                "id": 1477727,
+                "node_id": "MDg6V29ya2Zsb3cxNDYwNzI3",
+                "name": ".github/workflows/workflow.yml",
+                "path": ".github/workflows/workflow.yml",
+                "state": "active",
+                "created_at": "2020-06-03T23:41:06.000+05:30",
+                "updated_at": "2020-08-07T15:46:42.000+05:30",
+                "url": "https://api.github.com/repos/testUser/hello-kubernetes/actions/workflows/1460727",
+                "html_url": "https://github.com/testUser/hello-kubernetes/blob/master/.github/workflows/workflow.yml",
+                "badge_url": "https://github.com/testUser/hello-kubernetes/workflows/.github/workflows/workflow.yml/badge.svg"
+            },
+            {
+                "id": 1532230,
+                "node_id": "MDg6V29ya2Zsb3cxNTMyMzMw",
+                "name": "NewWorkflow",
+                "path": ".github/workflows/workflow1.yml",
+                "state": "active",
+                "created_at": "2020-06-11T16:05:23.000+05:30",
+                "updated_at": "2020-08-07T15:46:42.000+05:30",
+                "url": "https://api.github.com/repos/testUser/hello-kubernetes/actions/workflows/1532330",
+                "html_url": "https://github.com/testUser/hello-kubernetes/blob/master/.github/workflows/workflowNew.yml",
+                "badge_url": "https://github.com/testUser/hello-kubernetes/workflows/KoDeyi/badge.svg"
+            }
+        ]
+    }
+} as httpClient.WebResponse;
+
 const resources: Resource[] = [{ type: "Deployment", name: "AppName" }];

 beforeEach(() => {
    deploymentYaml = fs.readFileSync(path.join(__dirname, 'manifests', 'deployment.yml'), 'utf8');
+    jest.spyOn(Date, 'now').mockImplementation(() => 1234561234567);

    process.env["KUBECONFIG"] = 'kubeConfig';
    process.env['GITHUB_RUN_ID'] = '12345';
@@ -52,6 +88,7 @@ beforeEach(() => {
    process.env['GITHUB_REPOSITORY'] = 'testRepo';
    process.env['GITHUB_SHA'] = 'testCommit';
    process.env['GITHUB_REF'] = 'testBranch';
+    process.env['GITHUB_TOKEN'] = 'testToken';
 })

 test("setKubectlPath() - install a particular version", async () => {
@@ -213,9 +250,11 @@ test("deployment - deploy() - Invokes with manifestfiles", async () => {
    kubeCtl.describe = jest.fn().mockReturnValue("");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue("");
+    kubeCtl.labelFiles = jest.fn().mockReturnValue("");
    KubernetesManifestUtilityMock.checkManifestStability = jest.fn().mockReturnValue("");

    const readFileSpy = jest.spyOn(fs, 'readFileSync').mockImplementation(() => deploymentYaml);
+    jest.spyOn(httpClient, 'sendRequest').mockImplementation(() => Promise.resolve(getWorkflowsUrlResponse));

    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
@@ -241,9 +280,11 @@ test("deployment - deploy() - deploy force flag on", async () => {
    kubeCtl.describe = jest.fn().mockReturnValue("");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue("");
+    kubeCtl.labelFiles = jest.fn().mockReturnValue("");
    KubernetesManifestUtilityMock.checkManifestStability = jest.fn().mockReturnValue("");

    const deploySpy = jest.spyOn(kubeCtl, 'apply').mockImplementation(() => applyResMock);
+    jest.spyOn(httpClient, 'sendRequest').mockImplementation(() => Promise.resolve(getWorkflowsUrlResponse));

    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
@@ -251,13 +292,18 @@ test("deployment - deploy() - deploy force flag on", async () => {
    deploySpy.mockRestore();
 });

-test("deployment - deploy() - Annotate resources", async () => {
+test("deployment - deploy() - Annotate & label resources", async () => {
+    let deploymentConfig = { manifestFilePaths :['manifests/deployment.yaml'], helmChartFilePaths : [], dockerfilePaths :{}} ;
+    let annotationKeyValStr = getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW) + '=' + getWorkflowAnnotationsJson('currentCommit', '.github/workflows/workflow.yml', deploymentConfig);
    const KubernetesManifestUtilityMock = mocked(KubernetesManifestUtility, true);
    KubernetesManifestUtilityMock.checkManifestStability = jest.fn().mockReturnValue("");
    const KubernetesObjectUtilityMock = mocked(KubernetesObjectUtility, true);
    KubernetesObjectUtilityMock.getResources = jest.fn().mockReturnValue(resources);
    const fileHelperMock = mocked(fileHelper, true);
    fileHelperMock.writeObjectsToFile = jest.fn().mockReturnValue(["~/Deployment_testapp_currentTimestamp"]);
+    jest.spyOn(utility, 'getWorkflowFilePath').mockImplementation(() => Promise.resolve(process.env.GITHUB_WORKFLOW));
+    jest.spyOn(utility, 'getDeploymentConfig').mockImplementation(()=> Promise.resolve(deploymentConfig));
+
    const kubeCtl: jest.Mocked<Kubectl> = new Kubectl("") as any;
    kubeCtl.apply = jest.fn().mockReturnValue("");
    kubeCtl.getResource = jest.fn().mockReturnValue(getNamespaceMock);
@@ -265,21 +311,28 @@ test("deployment - deploy() - Annotate resources", async () => {
    kubeCtl.getNewReplicaSet = jest.fn().mockReturnValue("testpod-776cbc86f9");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue("");
-
+    kubeCtl.labelFiles = jest.fn();
    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
-    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"], workflowAnnotations, true);
+    expect(kubeCtl.annotate).toHaveBeenNthCalledWith(1, 'namespace', 'default', annotationKeyValStr);
+    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"], annotationKeyValStr);
    expect(kubeCtl.annotate).toBeCalledTimes(2);
+    expect(kubeCtl.labelFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"],
+        [`workflowFriendlyName=workflow.yml`, `workflow=${getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW)}`]);
 });

-test("deployment - deploy() - Skip Annotate namespace", async () => {
-    process.env['GITHUB_REPOSITORY'] = 'test1Repo';
+test("deployment - deploy() - Annotate & label resources for a new workflow", async () => {
+    process.env.GITHUB_WORKFLOW = '.github/workflows/NewWorkflow.yml';
+    let deploymentConfig = { manifestFilePaths :['manifests/deployment.yaml'], helmChartFilePaths : [], dockerfilePaths :{}} ;
+    let annotationKeyValStr = getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW) + '=' + getWorkflowAnnotationsJson('NA', '.github/workflows/NewWorkflow.yml', deploymentConfig);
    const KubernetesManifestUtilityMock = mocked(KubernetesManifestUtility, true);
    KubernetesManifestUtilityMock.checkManifestStability = jest.fn().mockReturnValue("");
    const KubernetesObjectUtilityMock = mocked(KubernetesObjectUtility, true);
    KubernetesObjectUtilityMock.getResources = jest.fn().mockReturnValue(resources);
    const fileHelperMock = mocked(fileHelper, true);
    fileHelperMock.writeObjectsToFile = jest.fn().mockReturnValue(["~/Deployment_testapp_currentTimestamp"]);
+    jest.spyOn(httpClient, 'sendRequest').mockImplementation(() => Promise.resolve(getWorkflowsUrlResponse));
+
    const kubeCtl: jest.Mocked<Kubectl> = new Kubectl("") as any;
    kubeCtl.apply = jest.fn().mockReturnValue("");
    kubeCtl.getResource = jest.fn().mockReturnValue(getNamespaceMock);
@@ -287,14 +340,14 @@ test("deployment - deploy() - Skip Annotate namespace", async () => {
    kubeCtl.getNewReplicaSet = jest.fn().mockReturnValue("testpod-776cbc86f9");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue("");
-
-    const consoleOutputSpy = jest.spyOn(process.stdout, "write").mockImplementation();
-
+    kubeCtl.labelFiles = jest.fn();
    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
-    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"], workflowAnnotations, true);
-    expect(kubeCtl.annotate).toBeCalledTimes(1);
-    expect(consoleOutputSpy).toHaveBeenNthCalledWith(2, `##[debug]Skipping 'annotate namespace' as namespace annotated by other workflow` + os.EOL)
+    expect(kubeCtl.annotate).toHaveBeenNthCalledWith(1, 'namespace', 'default', annotationKeyValStr);
+    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"], annotationKeyValStr);
+    expect(kubeCtl.annotate).toBeCalledTimes(2);
+    expect(kubeCtl.labelFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"],
+        [`workflowFriendlyName=NewWorkflow.yml`, `workflow=${getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW)}`]);
 });

 test("deployment - deploy() - Annotate resources failed", async () => {
@@ -316,10 +369,24 @@ test("deployment - deploy() - Annotate resources failed", async () => {
    kubeCtl.describe = jest.fn().mockReturnValue("");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue(annotateMock);
+    kubeCtl.labelFiles = jest.fn().mockReturnValue("");
    KubernetesManifestUtilityMock.checkManifestStability = jest.fn().mockReturnValue("");

    const consoleOutputSpy = jest.spyOn(process.stdout, "write").mockImplementation();
    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
-    expect(consoleOutputSpy).toHaveBeenNthCalledWith(2, '##[warning]kubectl annotate failed' + os.EOL)
+    expect(consoleOutputSpy).toHaveBeenNthCalledWith(2, '::warning::kubectl annotate failed' + os.EOL)
+});
+
+test("utility - getWorkflowFilePath() - Get workflow file path under API failure", async () => {
+    //Mocks
+    const errorWebResponse = {
+        'statusCode': httpClient.StatusCodes.UNAUTHORIZED,
+        'body': {}
+    } as httpClient.WebResponse
+    jest.spyOn(httpClient, 'sendRequest').mockImplementation(() => Promise.resolve(errorWebResponse));
+
+    //Invoke and assert
+    await expect(utility.getWorkflowFilePath(process.env.GITHUB_TOKEN)).resolves.not.toThrowError;
+    await expect(utility.getWorkflowFilePath(process.env.GITHUB_TOKEN)).resolves.toBe(process.env.GITHUB_WORKFLOW);
 });
@@ -45,6 +45,10 @@ inputs:
    description: 'Deploy when a previous deployment already exists. If true then --force argument is added to the apply command.'
    required: false
    default: false
+  token:
+    description: 'Github token'
+    default: ${{ github.token }}
+    required: true

 branding:
  color: 'green' # optional, decorates the entry in the GitHub Marketplace
@@ -1,6 +1,6 @@
 'use strict';
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.workflowAnnotations = exports.workloadTypesWithRolloutStatus = exports.workloadTypes = exports.deploymentTypes = exports.ServiceTypes = exports.DiscoveryAndLoadBalancerResource = exports.KubernetesWorkload = void 0;
+exports.getWorkflowAnnotationKeyLabel = exports.getWorkflowAnnotationsJson = exports.workloadTypesWithRolloutStatus = exports.workloadTypes = exports.deploymentTypes = exports.ServiceTypes = exports.DiscoveryAndLoadBalancerResource = exports.KubernetesWorkload = void 0;
 class KubernetesWorkload {
 }
 exports.KubernetesWorkload = KubernetesWorkload;
@@ -25,15 +25,30 @@ ServiceTypes.clusterIP = 'ClusterIP';
 exports.deploymentTypes = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset'];
 exports.workloadTypes = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset', 'job', 'cronjob'];
 exports.workloadTypesWithRolloutStatus = ['deployment', 'daemonset', 'statefulset'];
-exports.workflowAnnotations = [
-    `run=${process.env['GITHUB_RUN_ID']}`,
-    `repository=${process.env['GITHUB_REPOSITORY']}`,
-    `workflow=${process.env['GITHUB_WORKFLOW']}`,
-    `jobName=${process.env['GITHUB_JOB']}`,
-    `createdBy=${process.env['GITHUB_ACTOR']}`,
-    `runUri=https://github.com/${process.env['GITHUB_REPOSITORY']}/actions/runs/${process.env['GITHUB_RUN_ID']}`,
-    `commit=${process.env['GITHUB_SHA']}`,
-    `branch=${process.env['GITHUB_REF']}`,
-    `deployTimestamp=${Date.now()}`,
-    `provider=GitHub`
-];
+function getWorkflowAnnotationsJson(lastSuccessRunSha, workflowFilePath, deploymentConfig) {
+    let annotationObject = {};
+    annotationObject["run"] = process.env.GITHUB_RUN_ID;
+    annotationObject["repository"] = process.env.GITHUB_REPOSITORY;
+    annotationObject["workflow"] = process.env.GITHUB_WORKFLOW;
+    annotationObject["workflowFileName"] = workflowFilePath.replace(".github/workflows/", "");
+    annotationObject["jobName"] = process.env.GITHUB_JOB;
+    annotationObject["createdBy"] = process.env.GITHUB_ACTOR;
+    annotationObject["runUri"] = `https://github.com/${process.env.GITHUB_REPOSITORY}/actions/runs/${process.env.GITHUB_RUN_ID}`;
+    annotationObject["commit"] = process.env.GITHUB_SHA;
+    annotationObject["lastSuccessRunCommit"] = lastSuccessRunSha;
+    annotationObject["branch"] = process.env.GITHUB_REF;
+    annotationObject["deployTimestamp"] = Date.now();
+    annotationObject["dockerfilePaths"] = deploymentConfig.dockerfilePaths;
+    annotationObject["manifestsPaths"] = deploymentConfig.manifestFilePaths;
+    annotationObject["helmChartPaths"] = deploymentConfig.helmChartFilePaths;
+    annotationObject["provider"] = "GitHub";
+    return JSON.stringify(annotationObject);
+}
+exports.getWorkflowAnnotationsJson = getWorkflowAnnotationsJson;
+function getWorkflowAnnotationKeyLabel(workflowFilePath) {
+    const hashKey = require("crypto").createHash("MD5")
+        .update(`${process.env.GITHUB_REPOSITORY}/${workflowFilePath}`)
+        .digest("hex");
+    return `githubWorkflow_${hashKey}`;
+}
+exports.getWorkflowAnnotationKeyLabel = getWorkflowAnnotationKeyLabel;
@@ -0,0 +1,31 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.DockerExec = void 0;
+const tool_runner_1 = require("./utilities/tool-runner");
+class DockerExec {
+    constructor(dockerPath) {
+        this.dockerPath = dockerPath;
+    }
+    ;
+    pull(image, args, silent) {
+        args = ['pull', image, ...args];
+        let result = this.execute(args, silent);
+        if (result.stderr != '' && result.code != 0) {
+            throw new Error(`docker images pull failed with: ${result.error}`);
+        }
+    }
+    inspect(image, args, silent) {
+        args = ['inspect', image, ...args];
+        let result = this.execute(args, silent);
+        if (result.stderr != '' && result.code != 0) {
+            throw new Error(`docker inspect call failed with: ${result.error}`);
+        }
+        return result.stdout;
+    }
+    execute(args, silent) {
+        const command = new tool_runner_1.ToolRunner(this.dockerPath);
+        command.arg(args);
+        return command.execSync({ silent: !!silent });
+    }
+}
+exports.DockerExec = DockerExec;
@@ -0,0 +1,35 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.GitHubClient = void 0;
+const core = require("@actions/core");
+const httpClient_1 = require("./utilities/httpClient");
+class GitHubClient {
+    constructor(repository, token) {
+        this._repository = repository;
+        this._token = token;
+    }
+    getWorkflows() {
+        return __awaiter(this, void 0, void 0, function* () {
+            const getWorkflowFileNameUrl = `https://api.github.com/repos/${this._repository}/actions/workflows`;
+            const webRequest = new httpClient_1.WebRequest();
+            webRequest.method = "GET";
+            webRequest.uri = getWorkflowFileNameUrl;
+            webRequest.headers = {
+                Authorization: `Bearer ${this._token}`
+            };
+            core.debug(`Getting workflows for repo: ${this._repository}`);
+            const response = yield httpClient_1.sendRequest(webRequest);
+            return Promise.resolve(response);
+        });
+    }
+}
+exports.GitHubClient = GitHubClient;
@@ -1,6 +1,6 @@
 'use strict';
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.forceDeployment = exports.args = exports.baselineAndCanaryReplicas = exports.trafficSplitMethod = exports.deploymentStrategy = exports.canaryPercentage = exports.manifests = exports.imagePullSecrets = exports.containers = exports.namespace = void 0;
+exports.githubToken = exports.forceDeployment = exports.args = exports.baselineAndCanaryReplicas = exports.trafficSplitMethod = exports.deploymentStrategy = exports.canaryPercentage = exports.manifests = exports.imagePullSecrets = exports.containers = exports.namespace = void 0;
 const core = require("@actions/core");
 exports.namespace = core.getInput('namespace');
 exports.containers = core.getInput('images').split('\n');
@@ -12,10 +12,14 @@ exports.trafficSplitMethod = core.getInput('traffic-split-method');
 exports.baselineAndCanaryReplicas = core.getInput('baseline-and-canary-replicas');
 exports.args = core.getInput('arguments');
 exports.forceDeployment = core.getInput('force').toLowerCase() == 'true';
+exports.githubToken = core.getInput("token");
 if (!exports.namespace) {
    core.debug('Namespace was not supplied; using "default" namespace instead.');
    exports.namespace = 'default';
 }
+if (!exports.githubToken) {
+    core.error("'token' input is not supplied. Set it to a PAT/GITHUB_TOKEN");
+}
 try {
    const pe = parseInt(exports.canaryPercentage);
    if (pe < 0 || pe > 100) {
@@ -37,21 +37,24 @@ class Kubectl {
        }
        return newReplicaSet;
    }
-    annotate(resourceType, resourceName, annotations, overwrite) {
+    annotate(resourceType, resourceName, annotation) {
        let args = ['annotate', resourceType, resourceName];
-        args = args.concat(annotations);
-        if (!!overwrite) {
-            args.push(`--overwrite`);
-        }
+        args.push(annotation);
+        args.push(`--overwrite`);
        return this.execute(args);
    }
-    annotateFiles(files, annotations, overwrite) {
+    annotateFiles(files, annotation) {
        let args = ['annotate'];
        args = args.concat(['-f', this.createInlineArray(files)]);
-        args = args.concat(annotations);
-        if (!!overwrite) {
-            args.push(`--overwrite`);
-        }
+        args.push(annotation);
+        args.push(`--overwrite`);
+        return this.execute(args);
+    }
+    labelFiles(files, labels) {
+        let args = ['label'];
+        args = args.concat(['-f', this.createInlineArray(files)]);
+        args = args.concat(labels);
+        args.push(`--overwrite`);
        return this.execute(args);
    }
    getAllPods() {
@@ -53,7 +53,7 @@ function installKubectl(version) {
 }
 function checkClusterContext() {
    if (!process.env["KUBECONFIG"]) {
-        throw new Error('Cluster context not set. Use k8ssetcontext action to set cluster context');
+        core.warning('KUBECONFIG env is not explicitly set. Ensure cluster context is set by using k8s-set-context / aks-set-context action.');
    }
 }
 function run() {
@@ -0,0 +1,111 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.sleepFor = exports.sendRequest = exports.WebRequestOptions = exports.WebResponse = exports.WebRequest = exports.StatusCodes = void 0;
+// Taken from https://github.com/Azure/aks-set-context/blob/master/src/client.ts
+const util = require("util");
+const fs = require("fs");
+const httpClient = require("typed-rest-client/HttpClient");
+const core = require("@actions/core");
+var httpCallbackClient = new httpClient.HttpClient('GITHUB_RUNNER', null, {});
+var StatusCodes;
+(function (StatusCodes) {
+    StatusCodes[StatusCodes["OK"] = 200] = "OK";
+    StatusCodes[StatusCodes["CREATED"] = 201] = "CREATED";
+    StatusCodes[StatusCodes["ACCEPTED"] = 202] = "ACCEPTED";
+    StatusCodes[StatusCodes["UNAUTHORIZED"] = 401] = "UNAUTHORIZED";
+    StatusCodes[StatusCodes["NOT_FOUND"] = 404] = "NOT_FOUND";
+    StatusCodes[StatusCodes["INTERNAL_SERVER_ERROR"] = 500] = "INTERNAL_SERVER_ERROR";
+    StatusCodes[StatusCodes["SERVICE_UNAVAILABLE"] = 503] = "SERVICE_UNAVAILABLE";
+})(StatusCodes = exports.StatusCodes || (exports.StatusCodes = {}));
+class WebRequest {
+}
+exports.WebRequest = WebRequest;
+class WebResponse {
+}
+exports.WebResponse = WebResponse;
+class WebRequestOptions {
+}
+exports.WebRequestOptions = WebRequestOptions;
+function sendRequest(request, options) {
+    return __awaiter(this, void 0, void 0, function* () {
+        let i = 0;
+        let retryCount = options && options.retryCount ? options.retryCount : 5;
+        let retryIntervalInSeconds = options && options.retryIntervalInSeconds ? options.retryIntervalInSeconds : 2;
+        let retriableErrorCodes = options && options.retriableErrorCodes ? options.retriableErrorCodes : ["ETIMEDOUT", "ECONNRESET", "ENOTFOUND", "ESOCKETTIMEDOUT", "ECONNREFUSED", "EHOSTUNREACH", "EPIPE", "EA_AGAIN"];
+        let retriableStatusCodes = options && options.retriableStatusCodes ? options.retriableStatusCodes : [408, 409, 500, 502, 503, 504];
+        let timeToWait = retryIntervalInSeconds;
+        while (true) {
+            try {
+                if (request.body && typeof (request.body) !== 'string' && !request.body["readable"]) {
+                    request.body = fs.createReadStream(request.body["path"]);
+                }
+                let response = yield sendRequestInternal(request);
+                if (retriableStatusCodes.indexOf(response.statusCode) != -1 && ++i < retryCount) {
+                    core.debug(util.format("Encountered a retriable status code: %s. Message: '%s'.", response.statusCode, response.statusMessage));
+                    yield sleepFor(timeToWait);
+                    timeToWait = timeToWait * retryIntervalInSeconds + retryIntervalInSeconds;
+                    continue;
+                }
+                return response;
+            }
+            catch (error) {
+                if (retriableErrorCodes.indexOf(error.code) != -1 && ++i < retryCount) {
+                    core.debug(util.format("Encountered a retriable error:%s. Message: %s.", error.code, error.message));
+                    yield sleepFor(timeToWait);
+                    timeToWait = timeToWait * retryIntervalInSeconds + retryIntervalInSeconds;
+                }
+                else {
+                    if (error.code) {
+                        core.debug("error code =" + error.code);
+                    }
+                    throw error;
+                }
+            }
+        }
+    });
+}
+exports.sendRequest = sendRequest;
+function sleepFor(sleepDurationInSeconds) {
+    return new Promise((resolve, reject) => {
+        setTimeout(resolve, sleepDurationInSeconds * 1000);
+    });
+}
+exports.sleepFor = sleepFor;
+function sendRequestInternal(request) {
+    return __awaiter(this, void 0, void 0, function* () {
+        core.debug(util.format("[%s]%s", request.method, request.uri));
+        var response = yield httpCallbackClient.request(request.method, request.uri, request.body, request.headers);
+        return yield toWebResponse(response);
+    });
+}
+function toWebResponse(response) {
+    return __awaiter(this, void 0, void 0, function* () {
+        var res = new WebResponse();
+        if (response) {
+            res.statusCode = response.message.statusCode;
+            res.statusMessage = response.message.statusMessage;
+            res.headers = response.message.headers;
+            var body = yield response.readBody();
+            if (body) {
+                try {
+                    res.body = JSON.parse(body);
+                }
+                catch (error) {
+                    core.debug("Could not parse response: " + JSON.stringify(error));
+                    core.debug("Response: " + JSON.stringify(res.body));
+                    res.body = body;
+                }
+            }
+        }
+        return res;
+    });
+}
@@ -49,7 +49,7 @@ function deploy(kubectl, manifestFilePaths, deploymentStrategy) {
        catch (e) {
            core.debug("Unable to parse pods; Error: " + e);
        }
-        annotateResources(deployedManifestFiles, kubectl, resourceTypes, allPods);
+        annotateAndLabelResources(deployedManifestFiles, kubectl, resourceTypes, allPods);
    });
 }
 exports.deploy = deploy;
@@ -110,18 +110,36 @@ function checkManifestStability(kubectl, resources) {
        yield KubernetesManifestUtility.checkManifestStability(kubectl, resources);
    });
 }
-function annotateResources(files, kubectl, resourceTypes, allPods) {
+function annotateAndLabelResources(files, kubectl, resourceTypes, allPods) {
+    return __awaiter(this, void 0, void 0, function* () {
+        const workflowFilePath = yield utility_1.getWorkflowFilePath(TaskInputParameters.githubToken);
+        const deploymentConfig = yield utility_1.getDeploymentConfig();
+        const annotationKeyLabel = models.getWorkflowAnnotationKeyLabel(workflowFilePath);
+        annotateResources(files, kubectl, resourceTypes, allPods, annotationKeyLabel, workflowFilePath, deploymentConfig);
+        labelResources(files, kubectl, annotationKeyLabel);
+    });
+}
+function annotateResources(files, kubectl, resourceTypes, allPods, annotationKey, workflowFilePath, deploymentConfig) {
    const annotateResults = [];
-    annotateResults.push(utility_1.annotateNamespace(kubectl, TaskInputParameters.namespace));
-    annotateResults.push(kubectl.annotateFiles(files, models.workflowAnnotations, true));
+    const lastSuccessSha = utility_1.getLastSuccessfulRunSha(kubectl, TaskInputParameters.namespace, annotationKey);
+    let annotationKeyValStr = annotationKey + '=' + models.getWorkflowAnnotationsJson(lastSuccessSha, workflowFilePath, deploymentConfig);
+    annotateResults.push(kubectl.annotate('namespace', TaskInputParameters.namespace, annotationKeyValStr));
+    annotateResults.push(kubectl.annotateFiles(files, annotationKeyValStr));
    resourceTypes.forEach(resource => {
        if (resource.type.toUpperCase() !== models.KubernetesWorkload.pod.toUpperCase()) {
-            utility_1.annotateChildPods(kubectl, resource.type, resource.name, allPods)
+            utility_1.annotateChildPods(kubectl, resource.type, resource.name, annotationKeyValStr, allPods)
                .forEach(execResult => annotateResults.push(execResult));
        }
    });
    utility_1.checkForErrors(annotateResults, true);
 }
+function labelResources(files, kubectl, label) {
+    let workflowName = process.env.GITHUB_WORKFLOW;
+    workflowName = workflowName.startsWith('.github/workflows/') ?
+        workflowName.replace(".github/workflows/", "") : workflowName;
+    const labels = [`workflowFriendlyName=${workflowName}`, `workflow=${label}`];
+    utility_1.checkForErrors([kubectl.labelFiles(files, labels)], true);
+}
 function updateResourceObjects(filePaths, imagePullSecrets, containers) {
    const newObjectsList = [];
    const updateResourceObject = (inputObject) => {
@@ -1,105 +1,221 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.getCurrentTime = exports.getRandomInt = exports.sleep = exports.annotateNamespace = exports.annotateChildPods = exports.checkForErrors = exports.isEqual = exports.getExecutableExtension = void 0;
-const os = require("os");
-const core = require("@actions/core");
-const constants_1 = require("../constants");
-function getExecutableExtension() {
-    if (os.type().match(/^Win/)) {
-        return '.exe';
-    }
-    return '';
-}
-exports.getExecutableExtension = getExecutableExtension;
-function isEqual(str1, str2, ignoreCase) {
-    if (str1 == null && str2 == null) {
-        return true;
-    }
-    if (str1 == null || str2 == null) {
-        return false;
-    }
-    if (ignoreCase) {
-        return str1.toUpperCase() === str2.toUpperCase();
-    }
-    else {
-        return str1 === str2;
-    }
-}
-exports.isEqual = isEqual;
-function checkForErrors(execResults, warnIfError) {
-    if (execResults.length !== 0) {
-        let stderr = '';
-        execResults.forEach(result => {
-            if (result && result.stderr) {
-                if (result.code !== 0) {
-                    stderr += result.stderr + '\n';
-                }
-                else {
-                    core.warning(result.stderr);
-                }
-            }
-        });
-        if (stderr.length > 0) {
-            if (warnIfError) {
-                core.warning(stderr.trim());
-            }
-            else {
-                throw new Error(stderr.trim());
-            }
-        }
-    }
-}
-exports.checkForErrors = checkForErrors;
-function annotateChildPods(kubectl, resourceType, resourceName, allPods) {
-    const commandExecutionResults = [];
-    let owner = resourceName;
-    if (resourceType.toLowerCase().indexOf('deployment') > -1) {
-        owner = kubectl.getNewReplicaSet(resourceName);
-    }
-    if (allPods && allPods.items && allPods.items.length > 0) {
-        allPods.items.forEach((pod) => {
-            const owners = pod.metadata.ownerReferences;
-            if (owners) {
-                owners.forEach(ownerRef => {
-                    if (ownerRef.name === owner) {
-                        commandExecutionResults.push(kubectl.annotate('pod', pod.metadata.name, constants_1.workflowAnnotations, true));
-                    }
-                });
-            }
-        });
-    }
-    return commandExecutionResults;
-}
-exports.annotateChildPods = annotateChildPods;
-function annotateNamespace(kubectl, namespaceName) {
-    const result = kubectl.getResource('namespace', namespaceName);
-    if (!result) {
-        return { code: -1, stderr: 'Failed to get resource' };
-    }
-    else if (result && result.stderr) {
-        return result;
-    }
-    if (result && result.stdout) {
-        const annotationsSet = JSON.parse(result.stdout).metadata.annotations;
-        if (annotationsSet && annotationsSet.runUri) {
-            if (annotationsSet.runUri.indexOf(process.env['GITHUB_REPOSITORY']) == -1) {
-                core.debug(`Skipping 'annotate namespace' as namespace annotated by other workflow`);
-                return { code: 0, stdout: '' };
-            }
-        }
-        return kubectl.annotate('namespace', namespaceName, constants_1.workflowAnnotations, true);
-    }
-}
-exports.annotateNamespace = annotateNamespace;
-function sleep(timeout) {
-    return new Promise(resolve => setTimeout(resolve, timeout));
-}
-exports.sleep = sleep;
-function getRandomInt(max) {
-    return Math.floor(Math.random() * Math.floor(max));
-}
-exports.getRandomInt = getRandomInt;
-function getCurrentTime() {
-    return new Date().getTime();
-}
-exports.getCurrentTime = getCurrentTime;
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.getNormalizedPath = exports.isHttpUrl = exports.getCurrentTime = exports.getRandomInt = exports.sleep = exports.getDeploymentConfig = exports.annotateChildPods = exports.getWorkflowFilePath = exports.getLastSuccessfulRunSha = exports.checkForErrors = exports.isEqual = exports.getExecutableExtension = void 0;
+const os = require("os");
+const core = require("@actions/core");
+const githubClient_1 = require("../githubClient");
+const httpClient_1 = require("./httpClient");
+const inputParams = require("../input-parameters");
+const docker_object_model_1 = require("../docker-object-model");
+const io = require("@actions/io");
+function getExecutableExtension() {
+    if (os.type().match(/^Win/)) {
+        return '.exe';
+    }
+    return '';
+}
+exports.getExecutableExtension = getExecutableExtension;
+function isEqual(str1, str2, ignoreCase) {
+    if (str1 == null && str2 == null) {
+        return true;
+    }
+    if (str1 == null || str2 == null) {
+        return false;
+    }
+    if (ignoreCase) {
+        return str1.toUpperCase() === str2.toUpperCase();
+    }
+    else {
+        return str1 === str2;
+    }
+}
+exports.isEqual = isEqual;
+function checkForErrors(execResults, warnIfError) {
+    if (execResults.length !== 0) {
+        let stderr = '';
+        execResults.forEach(result => {
+            if (result && result.stderr) {
+                if (result.code !== 0) {
+                    stderr += result.stderr + '\n';
+                }
+                else {
+                    core.warning(result.stderr);
+                }
+            }
+        });
+        if (stderr.length > 0) {
+            if (warnIfError) {
+                core.warning(stderr.trim());
+            }
+            else {
+                throw new Error(stderr.trim());
+            }
+        }
+    }
+}
+exports.checkForErrors = checkForErrors;
+function getLastSuccessfulRunSha(kubectl, namespaceName, annotationKey) {
+    try {
+        const result = kubectl.getResource('namespace', namespaceName);
+        if (result) {
+            if (result.stderr) {
+                core.warning(`${result.stderr}`);
+                return process.env.GITHUB_SHA;
+            }
+            else if (result.stdout) {
+                const annotationsSet = JSON.parse(result.stdout).metadata.annotations;
+                if (annotationsSet && annotationsSet[annotationKey]) {
+                    return JSON.parse(annotationsSet[annotationKey].replace(/'/g, '"')).commit;
+                }
+                else {
+                    return 'NA';
+                }
+            }
+        }
+    }
+    catch (ex) {
+        core.warning(`Failed to get commits from cluster. ${JSON.stringify(ex)}`);
+        return '';
+    }
+}
+exports.getLastSuccessfulRunSha = getLastSuccessfulRunSha;
+function getWorkflowFilePath(githubToken) {
+    return __awaiter(this, void 0, void 0, function* () {
+        let workflowFilePath = process.env.GITHUB_WORKFLOW;
+        if (!workflowFilePath.startsWith('.github/workflows/')) {
+            const githubClient = new githubClient_1.GitHubClient(process.env.GITHUB_REPOSITORY, githubToken);
+            const response = yield githubClient.getWorkflows();
+            if (response) {
+                if (response.statusCode == httpClient_1.StatusCodes.OK
+                    && response.body
+                    && response.body.total_count) {
+                    if (response.body.total_count > 0) {
+                        for (let workflow of response.body.workflows) {
+                            if (process.env.GITHUB_WORKFLOW === workflow.name) {
+                                workflowFilePath = workflow.path;
+                                break;
+                            }
+                        }
+                    }
+                }
+                else if (response.statusCode != httpClient_1.StatusCodes.OK) {
+                    core.debug(`An error occured while getting list of workflows on the repo. Statuscode: ${response.statusCode}, StatusMessage: ${response.statusMessage}`);
+                }
+            }
+            else {
+                core.warning(`Failed to get response from workflow list API`);
+            }
+        }
+        return Promise.resolve(workflowFilePath);
+    });
+}
+exports.getWorkflowFilePath = getWorkflowFilePath;
+function annotateChildPods(kubectl, resourceType, resourceName, annotationKeyValStr, allPods) {
+    const commandExecutionResults = [];
+    let owner = resourceName;
+    if (resourceType.toLowerCase().indexOf('deployment') > -1) {
+        owner = kubectl.getNewReplicaSet(resourceName);
+    }
+    if (allPods && allPods.items && allPods.items.length > 0) {
+        allPods.items.forEach((pod) => {
+            const owners = pod.metadata.ownerReferences;
+            if (owners) {
+                owners.forEach(ownerRef => {
+                    if (ownerRef.name === owner) {
+                        commandExecutionResults.push(kubectl.annotate('pod', pod.metadata.name, annotationKeyValStr));
+                    }
+                });
+            }
+        });
+    }
+    return commandExecutionResults;
+}
+exports.annotateChildPods = annotateChildPods;
+function getDeploymentConfig() {
+    return __awaiter(this, void 0, void 0, function* () {
+        let helmChartPaths = (process.env.HELM_CHART_PATHS && process.env.HELM_CHART_PATHS.split(';').filter(path => path != "")) || [];
+        helmChartPaths = helmChartPaths.map(helmchart => getNormalizedPath(helmchart.trim()));
+        let inputManifestFiles = inputParams.manifests || [];
+        if (!helmChartPaths.length) {
+            inputManifestFiles = inputManifestFiles.map(manifestFile => getNormalizedPath(manifestFile));
+        }
+        const imageNames = inputParams.containers || [];
+        let imageDockerfilePathMap = {};
+        //Fetching from image label if available
+        for (const image of imageNames) {
+            try {
+                imageDockerfilePathMap[image] = yield getDockerfilePath(image);
+            }
+            catch (ex) {
+                core.warning(`Failed to get dockerfile path for image ${image.toString()} | ` + ex);
+            }
+        }
+        const deploymentConfig = {
+            manifestFilePaths: inputManifestFiles,
+            helmChartFilePaths: helmChartPaths,
+            dockerfilePaths: imageDockerfilePathMap
+        };
+        return Promise.resolve(deploymentConfig);
+    });
+}
+exports.getDeploymentConfig = getDeploymentConfig;
+function sleep(timeout) {
+    return new Promise(resolve => setTimeout(resolve, timeout));
+}
+exports.sleep = sleep;
+function getRandomInt(max) {
+    return Math.floor(Math.random() * Math.floor(max));
+}
+exports.getRandomInt = getRandomInt;
+function getCurrentTime() {
+    return new Date().getTime();
+}
+exports.getCurrentTime = getCurrentTime;
+function checkDockerPath() {
+    return __awaiter(this, void 0, void 0, function* () {
+        let dockerPath = yield io.which('docker', false);
+        if (!dockerPath) {
+            throw new Error('Docker is not installed.');
+        }
+    });
+}
+function getDockerfilePath(image) {
+    return __awaiter(this, void 0, void 0, function* () {
+        let imageConfig, imageInspectResult;
+        var dockerExec = new docker_object_model_1.DockerExec('docker');
+        yield checkDockerPath();
+        dockerExec.pull(image, [], true);
+        imageInspectResult = dockerExec.inspect(image, [], true);
+        imageConfig = JSON.parse(imageInspectResult)[0];
+        const DOCKERFILE_PATH_LABEL_KEY = 'dockerfile-path';
+        let pathValue = '';
+        if (imageConfig) {
+            if ((imageConfig.Config) && (imageConfig.Config.Labels) && (imageConfig.Config.Labels[DOCKERFILE_PATH_LABEL_KEY])) {
+                const pathLabel = imageConfig.Config.Labels[DOCKERFILE_PATH_LABEL_KEY];
+                pathValue = getNormalizedPath(pathLabel);
+            }
+        }
+        return pathValue;
+    });
+}
+function isHttpUrl(url) {
+    const HTTP_REGEX = /^https?:\/\/.*$/;
+    return HTTP_REGEX.test(url);
+}
+exports.isHttpUrl = isHttpUrl;
+function getNormalizedPath(pathValue) {
+    if (!isHttpUrl(pathValue)) { //if it is not an http url then convert to link from current repo and commit 
+        return `https://github.com/${process.env.GITHUB_REPOSITORY}/blob/${process.env.GITHUB_SHA}/${pathValue}`;
+    }
+    return pathValue;
+}
+exports.getNormalizedPath = getNormalizedPath;
@@ -1,3 +1,5 @@
+The MIT License (MIT)
+
 Copyright 2019 GitHub

 Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
@@ -4,45 +4,53 @@

 ## Usage

-#### Inputs/Outputs
-
-You can use this library to get inputs or set outputs:
+### Import the package

 ```js
+// javascript
 const core = require('@actions/core');

-const myInput = core.getInput('inputName', { required: true });
+// typescript
+import * as core from '@actions/core';
+```

-// Do stuff
+#### Inputs/Outputs
+
+Action inputs can be read with `getInput`.  Outputs can be set with `setOutput` which makes them available to be mapped into inputs of other actions to ensure they are decoupled.
+
+```js
+const myInput = core.getInput('inputName', { required: true });

 core.setOutput('outputKey', 'outputVal');
 ```

 #### Exporting variables

-You can also export variables for future steps. Variables get set in the environment.
+Since each step runs in a separate process, you can use `exportVariable` to add it to this step and future steps environment blocks.

 ```js
-const core = require('@actions/core');
-
-// Do stuff
-
 core.exportVariable('envVar', 'Val');
 ```

+#### Setting a secret
+
+Setting a secret registers the secret with the runner to ensure it is masked in logs.
+
+```js
+core.setSecret('myPassword');
+```
+
 #### PATH Manipulation

-You can explicitly add items to the path for all remaining steps in a workflow:
+To make a tool's path available in the path for the remainder of the job (without altering the machine or containers state), use `addPath`.  The runner will prepend the path given to the jobs PATH.

 ```js
-const core = require('@actions/core');
-
-core.addPath('pathToTool');
+core.addPath('/path/to/mytool');
 ```

 #### Exit codes

-You should use this library to set the failing exit code for your action:
+You should use this library to set the failing exit code for your action.  If status is not set and the script runs to completion, that will lead to a success.

 ```js
 const core = require('@actions/core');
@@ -55,6 +63,8 @@ catch (err) {
  core.setFailed(`Action failed with error ${err}`);
 }

+Note that `setNeutral` is not yet implemented in actions V2 but equivalent functionality is being planned.
+
 ```

 #### Logging
@@ -72,7 +82,14 @@ try {
    core.warning('myInput was not set');
  }
  
+  if (core.isDebug()) {
+    // curl -v https://github.com
+  } else {
+    // curl https://github.com
+  }
+
  // Do stuff
+  core.info('Output to the actions build log')
 }
 catch (err) {
  core.error(`Error ${err}, action may still succeed though`);
@@ -94,4 +111,37 @@ const result = await core.group('Do something async', async () => {
  const response = await doSomeHTTPRequest()
  return response
 })
-```
+```
+
+#### Action state
+
+You can use this library to save state and get state for sharing information between a given wrapper action: 
+
+**action.yml**
+```yaml
+name: 'Wrapper action sample'
+inputs:
+  name:
+    default: 'GitHub'
+runs:
+  using: 'node12'
+  main: 'main.js'
+  post: 'cleanup.js'
+```
+
+In action's `main.js`:
+
+```js
+const core = require('@actions/core');
+
+core.saveState("pidToKill", 12345);
+```
+
+In action's `cleanup.js`:
+```js
+const core = require('@actions/core');
+
+var pid = core.getState("pidToKill");
+
+process.kill(pid);
+```
@@ -1,16 +1,16 @@
 interface CommandProperties {
-    [key: string]: string;
+    [key: string]: any;
 }
 /**
 * Commands
 *
 * Command Format:
- *   ##[name key=value;key=value]message
+ *   ::name key=value,key=value::message
 *
 * Examples:
- *   ##[warning]This is the user warning message
- *   ##[set-secret name=mypassword]definitelyNotAPassword!
+ *   ::warning::This is the message
+ *   ::set-env name=MY_VAR::some value
 */
-export declare function issueCommand(command: string, properties: CommandProperties, message: string): void;
+export declare function issueCommand(command: string, properties: CommandProperties, message: any): void;
 export declare function issue(name: string, message?: string): void;
 export {};
@@ -1,15 +1,23 @@
 "use strict";
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
+    result["default"] = mod;
+    return result;
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-const os = require("os");
+const os = __importStar(require("os"));
+const utils_1 = require("./utils");
 /**
 * Commands
 *
 * Command Format:
- *   ##[name key=value;key=value]message
+ *   ::name key=value,key=value::message
 *
 * Examples:
- *   ##[warning]This is the user warning message
- *   ##[set-secret name=mypassword]definitelyNotAPassword!
+ *   ::warning::This is the message
+ *   ::set-env name=MY_VAR::some value
 */
 function issueCommand(command, properties, message) {
    const cmd = new Command(command, properties, message);
@@ -20,7 +28,7 @@ function issue(name, message = '') {
    issueCommand(name, {}, message);
 }
 exports.issue = issue;
-const CMD_PREFIX = '##[';
+const CMD_STRING = '::';
 class Command {
    constructor(command, properties, message) {
        if (!command) {
@@ -31,36 +39,41 @@ class Command {
        this.message = message;
    }
    toString() {
-        let cmdStr = CMD_PREFIX + this.command;
+        let cmdStr = CMD_STRING + this.command;
        if (this.properties && Object.keys(this.properties).length > 0) {
            cmdStr += ' ';
+            let first = true;
            for (const key in this.properties) {
                if (this.properties.hasOwnProperty(key)) {
                    const val = this.properties[key];
                    if (val) {
-                        // safely append the val - avoid blowing up when attempting to
-                        // call .replace() if message is not a string for some reason
-                        cmdStr += `${key}=${escape(`${val || ''}`)};`;
+                        if (first) {
+                            first = false;
+                        }
+                        else {
+                            cmdStr += ',';
+                        }
+                        cmdStr += `${key}=${escapeProperty(val)}`;
                    }
                }
            }
        }
-        cmdStr += ']';
-        // safely append the message - avoid blowing up when attempting to
-        // call .replace() if message is not a string for some reason
-        const message = `${this.message || ''}`;
-        cmdStr += escapeData(message);
+        cmdStr += `${CMD_STRING}${escapeData(this.message)}`;
        return cmdStr;
    }
 }
 function escapeData(s) {
-    return s.replace(/\r/g, '%0D').replace(/\n/g, '%0A');
+    return utils_1.toCommandValue(s)
+        .replace(/%/g, '%25')
+        .replace(/\r/g, '%0D')
+        .replace(/\n/g, '%0A');
 }
-function escape(s) {
-    return s
+function escapeProperty(s) {
+    return utils_1.toCommandValue(s)
+        .replace(/%/g, '%25')
        .replace(/\r/g, '%0D')
        .replace(/\n/g, '%0A')
-        .replace(/]/g, '%5D')
-        .replace(/;/g, '%3B');
+        .replace(/:/g, '%3A')
+        .replace(/,/g, '%2C');
 }
 //# sourceMappingURL=command.js.map
@@ -1 +1 @@
-{"version":3,"file":"command.js","sourceRoot":"","sources":["../src/command.ts"],"names":[],"mappings":";;AAAA,yBAAwB;AAQxB;;;;;;;;;GASG;AACH,SAAgB,YAAY,CAC1B,OAAe,EACf,UAA6B,EAC7B,OAAe;IAEf,MAAM,GAAG,GAAG,IAAI,OAAO,CAAC,OAAO,EAAE,UAAU,EAAE,OAAO,CAAC,CAAA;IACrD,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,EAAE,GAAG,EAAE,CAAC,GAAG,CAAC,CAAA;AAC/C,CAAC;AAPD,oCAOC;AAED,SAAgB,KAAK,CAAC,IAAY,EAAE,UAAkB,EAAE;IACtD,YAAY,CAAC,IAAI,EAAE,EAAE,EAAE,OAAO,CAAC,CAAA;AACjC,CAAC;AAFD,sBAEC;AAED,MAAM,UAAU,GAAG,KAAK,CAAA;AAExB,MAAM,OAAO;IAKX,YAAY,OAAe,EAAE,UAA6B,EAAE,OAAe;QACzE,IAAI,CAAC,OAAO,EAAE;YACZ,OAAO,GAAG,iBAAiB,CAAA;SAC5B;QAED,IAAI,CAAC,OAAO,GAAG,OAAO,CAAA;QACtB,IAAI,CAAC,UAAU,GAAG,UAAU,CAAA;QAC5B,IAAI,CAAC,OAAO,GAAG,OAAO,CAAA;IACxB,CAAC;IAED,QAAQ;QACN,IAAI,MAAM,GAAG,UAAU,GAAG,IAAI,CAAC,OAAO,CAAA;QAEtC,IAAI,IAAI,CAAC,UAAU,IAAI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC,MAAM,GAAG,CAAC,EAAE;YAC9D,MAAM,IAAI,GAAG,CAAA;YACb,KAAK,MAAM,GAAG,IAAI,IAAI,CAAC,UAAU,EAAE;gBACjC,IAAI,IAAI,CAAC,UAAU,CAAC,cAAc,CAAC,GAAG,CAAC,EAAE;oBACvC,MAAM,GAAG,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,CAAA;oBAChC,IAAI,GAAG,EAAE;wBACP,8DAA8D;wBAC9D,6DAA6D;wBAC7D,MAAM,IAAI,GAAG,GAAG,IAAI,MAAM,CAAC,GAAG,GAAG,IAAI,EAAE,EAAE,CAAC,GAAG,CAAA;qBAC9C;iBACF;aACF;SACF;QAED,MAAM,IAAI,GAAG,CAAA;QAEb,kEAAkE;QAClE,6DAA6D;QAC7D,MAAM,OAAO,GAAG,GAAG,IAAI,CAAC,OAAO,IAAI,EAAE,EAAE,CAAA;QACvC,MAAM,IAAI,UAAU,CAAC,OAAO,CAAC,CAAA;QAE7B,OAAO,MAAM,CAAA;IACf,CAAC;CACF;AAED,SAAS,UAAU,CAAC,CAAS;IAC3B,OAAO,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC,CAAA;AACtD,CAAC;AAED,SAAS,MAAM,CAAC,CAAS;IACvB,OAAO,CAAC;SACL,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC;SACrB,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC;SACrB,OAAO,CAAC,IAAI,EAAE,KAAK,CAAC;SACpB,OAAO,CAAC,IAAI,EAAE,KAAK,CAAC,CAAA;AACzB,CAAC"}
+{"version":3,"file":"command.js","sourceRoot":"","sources":["../src/command.ts"],"names":[],"mappings":";;;;;;;;;AAAA,uCAAwB;AACxB,mCAAsC;AAWtC;;;;;;;;;GASG;AACH,SAAgB,YAAY,CAC1B,OAAe,EACf,UAA6B,EAC7B,OAAY;IAEZ,MAAM,GAAG,GAAG,IAAI,OAAO,CAAC,OAAO,EAAE,UAAU,EAAE,OAAO,CAAC,CAAA;IACrD,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,EAAE,GAAG,EAAE,CAAC,GAAG,CAAC,CAAA;AAC/C,CAAC;AAPD,oCAOC;AAED,SAAgB,KAAK,CAAC,IAAY,EAAE,UAAkB,EAAE;IACtD,YAAY,CAAC,IAAI,EAAE,EAAE,EAAE,OAAO,CAAC,CAAA;AACjC,CAAC;AAFD,sBAEC;AAED,MAAM,UAAU,GAAG,IAAI,CAAA;AAEvB,MAAM,OAAO;IAKX,YAAY,OAAe,EAAE,UAA6B,EAAE,OAAe;QACzE,IAAI,CAAC,OAAO,EAAE;YACZ,OAAO,GAAG,iBAAiB,CAAA;SAC5B;QAED,IAAI,CAAC,OAAO,GAAG,OAAO,CAAA;QACtB,IAAI,CAAC,UAAU,GAAG,UAAU,CAAA;QAC5B,IAAI,CAAC,OAAO,GAAG,OAAO,CAAA;IACxB,CAAC;IAED,QAAQ;QACN,IAAI,MAAM,GAAG,UAAU,GAAG,IAAI,CAAC,OAAO,CAAA;QAEtC,IAAI,IAAI,CAAC,UAAU,IAAI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC,MAAM,GAAG,CAAC,EAAE;YAC9D,MAAM,IAAI,GAAG,CAAA;YACb,IAAI,KAAK,GAAG,IAAI,CAAA;YAChB,KAAK,MAAM,GAAG,IAAI,IAAI,CAAC,UAAU,EAAE;gBACjC,IAAI,IAAI,CAAC,UAAU,CAAC,cAAc,CAAC,GAAG,CAAC,EAAE;oBACvC,MAAM,GAAG,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,CAAA;oBAChC,IAAI,GAAG,EAAE;wBACP,IAAI,KAAK,EAAE;4BACT,KAAK,GAAG,KAAK,CAAA;yBACd;6BAAM;4BACL,MAAM,IAAI,GAAG,CAAA;yBACd;wBAED,MAAM,IAAI,GAAG,GAAG,IAAI,cAAc,CAAC,GAAG,CAAC,EAAE,CAAA;qBAC1C;iBACF;aACF;SACF;QAED,MAAM,IAAI,GAAG,UAAU,GAAG,UAAU,CAAC,IAAI,CAAC,OAAO,CAAC,EAAE,CAAA;QACpD,OAAO,MAAM,CAAA;IACf,CAAC;CACF;AAED,SAAS,UAAU,CAAC,CAAM;IACxB,OAAO,sBAAc,CAAC,CAAC,CAAC;SACrB,OAAO,CAAC,IAAI,EAAE,KAAK,CAAC;SACpB,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC;SACrB,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC,CAAA;AAC1B,CAAC;AAED,SAAS,cAAc,CAAC,CAAM;IAC5B,OAAO,sBAAc,CAAC,CAAC,CAAC;SACrB,OAAO,CAAC,IAAI,EAAE,KAAK,CAAC;SACpB,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC;SACrB,OAAO,CAAC,KAAK,EAAE,KAAK,CAAC;SACrB,OAAO,CAAC,IAAI,EAAE,KAAK,CAAC;SACpB,OAAO,CAAC,IAAI,EAAE,KAAK,CAAC,CAAA;AACzB,CAAC"}
@@ -19,17 +19,16 @@ export declare enum ExitCode {
    Failure = 1
 }
 /**
- * sets env variable for this action and future actions in the job
+ * Sets env variable for this action and future actions in the job
 * @param name the name of the variable to set
- * @param val the value of the variable
+ * @param val the value of the variable. Non-string values will be converted to a string via JSON.stringify
 */
-export declare function exportVariable(name: string, val: string): void;
+export declare function exportVariable(name: string, val: any): void;
 /**
- * exports the variable and registers a secret which will get masked from logs
- * @param name the name of the variable to set
- * @param val value of the secret
+ * Registers a secret which will get masked from logs
+ * @param secret value of the secret
 */
-export declare function exportSecret(name: string, val: string): void;
+export declare function setSecret(secret: string): void;
 /**
 * Prepends inputPath to the PATH (for this action and future actions)
 * @param inputPath
@@ -47,15 +46,25 @@ export declare function getInput(name: string, options?: InputOptions): string;
 * Sets the value of an output.
 *
 * @param     name     name of the output to set
- * @param     value    value to store
+ * @param     value    value to store. Non-string values will be converted to a string via JSON.stringify
 */
-export declare function setOutput(name: string, value: string): void;
+export declare function setOutput(name: string, value: any): void;
+/**
+ * Enables or disables the echoing of commands into stdout for the rest of the step.
+ * Echoing is disabled by default if ACTIONS_STEP_DEBUG is not set.
+ *
+ */
+export declare function setCommandEcho(enabled: boolean): void;
 /**
 * Sets the action status to failed.
 * When the action exits it will be with an exit code of 1
 * @param message add error issue message
 */
-export declare function setFailed(message: string): void;
+export declare function setFailed(message: string | Error): void;
+/**
+ * Gets whether Actions Step Debug is on or not
+ */
+export declare function isDebug(): boolean;
 /**
 * Writes debug message to user log
 * @param message debug message
@@ -63,14 +72,19 @@ export declare function setFailed(message: string): void;
 export declare function debug(message: string): void;
 /**
 * Adds an error issue
- * @param message error issue message
+ * @param message error issue message. Errors will be converted to string via toString()
 */
-export declare function error(message: string): void;
+export declare function error(message: string | Error): void;
 /**
 * Adds an warning issue
- * @param message warning issue message
+ * @param message warning issue message. Errors will be converted to string via toString()
 */
-export declare function warning(message: string): void;
+export declare function warning(message: string | Error): void;
+/**
+ * Writes info to log with console.log.
+ * @param message info message
+ */
+export declare function info(message: string): void;
 /**
 * Begin an output group.
 *
@@ -92,3 +106,17 @@ export declare function endGroup(): void;
 * @param fn The function to wrap in the group
 */
 export declare function group<T>(name: string, fn: () => Promise<T>): Promise<T>;
+/**
+ * Saves state for current action, the state can only be retrieved by this action's post job execution.
+ *
+ * @param     name     name of the state to store
+ * @param     value    value to store. Non-string values will be converted to a string via JSON.stringify
+ */
+export declare function saveState(name: string, value: any): void;
+/**
+ * Gets the value of an state set by this action's main execution.
+ *
+ * @param     name     name of the state to get
+ * @returns   string
+ */
+export declare function getState(name: string): string;
@@ -8,9 +8,19 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
        step((generator = generator.apply(thisArg, _arguments || [])).next());
    });
 };
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
+    result["default"] = mod;
+    return result;
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 const command_1 = require("./command");
-const path = require("path");
+const file_command_1 = require("./file-command");
+const utils_1 = require("./utils");
+const os = __importStar(require("os"));
+const path = __importStar(require("path"));
 /**
 * The code to exit an action
 */
@@ -29,34 +39,45 @@ var ExitCode;
 // Variables
 //-----------------------------------------------------------------------
 /**
- * sets env variable for this action and future actions in the job
+ * Sets env variable for this action and future actions in the job
 * @param name the name of the variable to set
- * @param val the value of the variable
+ * @param val the value of the variable. Non-string values will be converted to a string via JSON.stringify
 */
+// eslint-disable-next-line @typescript-eslint/no-explicit-any
 function exportVariable(name, val) {
-    process.env[name] = val;
-    command_1.issueCommand('set-env', { name }, val);
+    const convertedVal = utils_1.toCommandValue(val);
+    process.env[name] = convertedVal;
+    const filePath = process.env['GITHUB_ENV'] || '';
+    if (filePath) {
+        const delimiter = '_GitHubActionsFileCommandDelimeter_';
+        const commandValue = `${name}<<${delimiter}${os.EOL}${convertedVal}${os.EOL}${delimiter}`;
+        file_command_1.issueCommand('ENV', commandValue);
+    }
+    else {
+        command_1.issueCommand('set-env', { name }, convertedVal);
+    }
 }
 exports.exportVariable = exportVariable;
 /**
- * exports the variable and registers a secret which will get masked from logs
- * @param name the name of the variable to set
- * @param val value of the secret
+ * Registers a secret which will get masked from logs
+ * @param secret value of the secret
 */
-function exportSecret(name, val) {
-    exportVariable(name, val);
-    // the runner will error with not implemented
-    // leaving the function but raising the error earlier
-    command_1.issueCommand('set-secret', {}, val);
-    throw new Error('Not implemented.');
+function setSecret(secret) {
+    command_1.issueCommand('add-mask', {}, secret);
 }
-exports.exportSecret = exportSecret;
+exports.setSecret = setSecret;
 /**
 * Prepends inputPath to the PATH (for this action and future actions)
 * @param inputPath
 */
 function addPath(inputPath) {
-    command_1.issueCommand('add-path', {}, inputPath);
+    const filePath = process.env['GITHUB_PATH'] || '';
+    if (filePath) {
+        file_command_1.issueCommand('PATH', inputPath);
+    }
+    else {
+        command_1.issueCommand('add-path', {}, inputPath);
+    }
    process.env['PATH'] = `${inputPath}${path.delimiter}${process.env['PATH']}`;
 }
 exports.addPath = addPath;
@@ -68,7 +89,7 @@ exports.addPath = addPath;
 * @returns   string
 */
 function getInput(name, options) {
-    const val = process.env[`INPUT_${name.replace(' ', '_').toUpperCase()}`] || '';
+    const val = process.env[`INPUT_${name.replace(/ /g, '_').toUpperCase()}`] || '';
    if (options && options.required && !val) {
        throw new Error(`Input required and not supplied: ${name}`);
    }
@@ -79,12 +100,22 @@ exports.getInput = getInput;
 * Sets the value of an output.
 *
 * @param     name     name of the output to set
- * @param     value    value to store
+ * @param     value    value to store. Non-string values will be converted to a string via JSON.stringify
 */
+// eslint-disable-next-line @typescript-eslint/no-explicit-any
 function setOutput(name, value) {
    command_1.issueCommand('set-output', { name }, value);
 }
 exports.setOutput = setOutput;
+/**
+ * Enables or disables the echoing of commands into stdout for the rest of the step.
+ * Echoing is disabled by default if ACTIONS_STEP_DEBUG is not set.
+ *
+ */
+function setCommandEcho(enabled) {
+    command_1.issue('echo', enabled ? 'on' : 'off');
+}
+exports.setCommandEcho = setCommandEcho;
 //-----------------------------------------------------------------------
 // Results
 //-----------------------------------------------------------------------
@@ -101,6 +132,13 @@ exports.setFailed = setFailed;
 //-----------------------------------------------------------------------
 // Logging Commands
 //-----------------------------------------------------------------------
+/**
+ * Gets whether Actions Step Debug is on or not
+ */
+function isDebug() {
+    return process.env['RUNNER_DEBUG'] === '1';
+}
+exports.isDebug = isDebug;
 /**
 * Writes debug message to user log
 * @param message debug message
@@ -111,20 +149,28 @@ function debug(message) {
 exports.debug = debug;
 /**
 * Adds an error issue
- * @param message error issue message
+ * @param message error issue message. Errors will be converted to string via toString()
 */
 function error(message) {
-    command_1.issue('error', message);
+    command_1.issue('error', message instanceof Error ? message.toString() : message);
 }
 exports.error = error;
 /**
 * Adds an warning issue
- * @param message warning issue message
+ * @param message warning issue message. Errors will be converted to string via toString()
 */
 function warning(message) {
-    command_1.issue('warning', message);
+    command_1.issue('warning', message instanceof Error ? message.toString() : message);
 }
 exports.warning = warning;
+/**
+ * Writes info to log with console.log.
+ * @param message info message
+ */
+function info(message) {
+    process.stdout.write(message + os.EOL);
+}
+exports.info = info;
 /**
 * Begin an output group.
 *
@@ -165,4 +211,28 @@ function group(name, fn) {
    });
 }
 exports.group = group;
+//-----------------------------------------------------------------------
+// Wrapper action state
+//-----------------------------------------------------------------------
+/**
+ * Saves state for current action, the state can only be retrieved by this action's post job execution.
+ *
+ * @param     name     name of the state to store
+ * @param     value    value to store. Non-string values will be converted to a string via JSON.stringify
+ */
+// eslint-disable-next-line @typescript-eslint/no-explicit-any
+function saveState(name, value) {
+    command_1.issueCommand('save-state', { name }, value);
+}
+exports.saveState = saveState;
+/**
+ * Gets the value of an state set by this action's main execution.
+ *
+ * @param     name     name of the state to get
+ * @returns   string
+ */
+function getState(name) {
+    return process.env[`STATE_${name}`] || '';
+}
+exports.getState = getState;
 //# sourceMappingURL=core.js.map
@@ -1 +1 @@
-{"version":3,"file":"core.js","sourceRoot":"","sources":["../src/core.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,uCAA6C;AAE7C,6BAA4B;AAU5B;;GAEG;AACH,IAAY,QAUX;AAVD,WAAY,QAAQ;IAClB;;OAEG;IACH,6CAAW,CAAA;IAEX;;OAEG;IACH,6CAAW,CAAA;AACb,CAAC,EAVW,QAAQ,GAAR,gBAAQ,KAAR,gBAAQ,QAUnB;AAED,yEAAyE;AACzE,YAAY;AACZ,yEAAyE;AAEzE;;;;GAIG;AACH,SAAgB,cAAc,CAAC,IAAY,EAAE,GAAW;IACtD,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,GAAG,CAAA;IACvB,sBAAY,CAAC,SAAS,EAAE,EAAC,IAAI,EAAC,EAAE,GAAG,CAAC,CAAA;AACtC,CAAC;AAHD,wCAGC;AAED;;;;GAIG;AACH,SAAgB,YAAY,CAAC,IAAY,EAAE,GAAW;IACpD,cAAc,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;IAEzB,6CAA6C;IAC7C,qDAAqD;IACrD,sBAAY,CAAC,YAAY,EAAE,EAAE,EAAE,GAAG,CAAC,CAAA;IACnC,MAAM,IAAI,KAAK,CAAC,kBAAkB,CAAC,CAAA;AACrC,CAAC;AAPD,oCAOC;AAED;;;GAGG;AACH,SAAgB,OAAO,CAAC,SAAiB;IACvC,sBAAY,CAAC,UAAU,EAAE,EAAE,EAAE,SAAS,CAAC,CAAA;IACvC,OAAO,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,SAAS,GAAG,IAAI,CAAC,SAAS,GAAG,OAAO,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,CAAA;AAC7E,CAAC;AAHD,0BAGC;AAED;;;;;;GAMG;AACH,SAAgB,QAAQ,CAAC,IAAY,EAAE,OAAsB;IAC3D,MAAM,GAAG,GACP,OAAO,CAAC,GAAG,CAAC,SAAS,IAAI,CAAC,OAAO,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC,WAAW,EAAE,EAAE,CAAC,IAAI,EAAE,CAAA;IACpE,IAAI,OAAO,IAAI,OAAO,CAAC,QAAQ,IAAI,CAAC,GAAG,EAAE;QACvC,MAAM,IAAI,KAAK,CAAC,oCAAoC,IAAI,EAAE,CAAC,CAAA;KAC5D;IAED,OAAO,GAAG,CAAC,IAAI,EAAE,CAAA;AACnB,CAAC;AARD,4BAQC;AAED;;;;;GAKG;AACH,SAAgB,SAAS,CAAC,IAAY,EAAE,KAAa;IACnD,sBAAY,CAAC,YAAY,EAAE,EAAC,IAAI,EAAC,EAAE,KAAK,CAAC,CAAA;AAC3C,CAAC;AAFD,8BAEC;AAED,yEAAyE;AACzE,UAAU;AACV,yEAAyE;AAEzE;;;;GAIG;AACH,SAAgB,SAAS,CAAC,OAAe;IACvC,OAAO,CAAC,QAAQ,GAAG,QAAQ,CAAC,OAAO,CAAA;IACnC,KAAK,CAAC,OAAO,CAAC,CAAA;AAChB,CAAC;AAHD,8BAGC;AAED,yEAAyE;AACzE,mBAAmB;AACnB,yEAAyE;AAEzE;;;GAGG;AACH,SAAgB,KAAK,CAAC,OAAe;IACnC,sBAAY,CAAC,OAAO,EAAE,EAAE,EAAE,OAAO,CAAC,CAAA;AACpC,CAAC;AAFD,sBAEC;AAED;;;GAGG;AACH,SAAgB,KAAK,CAAC,OAAe;IACnC,eAAK,CAAC,OAAO,EAAE,OAAO,CAAC,CAAA;AACzB,CAAC;AAFD,sBAEC;AAED;;;GAGG;AACH,SAAgB,OAAO,CAAC,OAAe;IACrC,eAAK,CAAC,SAAS,EAAE,OAAO,CAAC,CAAA;AAC3B,CAAC;AAFD,0BAEC;AAED;;;;;;GAMG;AACH,SAAgB,UAAU,CAAC,IAAY;IACrC,eAAK,CAAC,OAAO,EAAE,IAAI,CAAC,CAAA;AACtB,CAAC;AAFD,gCAEC;AAED;;GAEG;AACH,SAAgB,QAAQ;IACtB,eAAK,CAAC,UAAU,CAAC,CAAA;AACnB,CAAC;AAFD,4BAEC;AAED;;;;;;;GAOG;AACH,SAAsB,KAAK,CAAI,IAAY,EAAE,EAAoB;;QAC/D,UAAU,CAAC,IAAI,CAAC,CAAA;QAEhB,IAAI,MAAS,CAAA;QAEb,IAAI;YACF,MAAM,GAAG,MAAM,EAAE,EAAE,CAAA;SACpB;gBAAS;YACR,QAAQ,EAAE,CAAA;SACX;QAED,OAAO,MAAM,CAAA;IACf,CAAC;CAAA;AAZD,sBAYC"}
+{"version":3,"file":"core.js","sourceRoot":"","sources":["../src/core.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;AAAA,uCAA6C;AAC7C,iDAA+D;AAC/D,mCAAsC;AAEtC,uCAAwB;AACxB,2CAA4B;AAU5B;;GAEG;AACH,IAAY,QAUX;AAVD,WAAY,QAAQ;IAClB;;OAEG;IACH,6CAAW,CAAA;IAEX;;OAEG;IACH,6CAAW,CAAA;AACb,CAAC,EAVW,QAAQ,GAAR,gBAAQ,KAAR,gBAAQ,QAUnB;AAED,yEAAyE;AACzE,YAAY;AACZ,yEAAyE;AAEzE;;;;GAIG;AACH,8DAA8D;AAC9D,SAAgB,cAAc,CAAC,IAAY,EAAE,GAAQ;IACnD,MAAM,YAAY,GAAG,sBAAc,CAAC,GAAG,CAAC,CAAA;IACxC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,YAAY,CAAA;IAEhC,MAAM,QAAQ,GAAG,OAAO,CAAC,GAAG,CAAC,YAAY,CAAC,IAAI,EAAE,CAAA;IAChD,IAAI,QAAQ,EAAE;QACZ,MAAM,SAAS,GAAG,qCAAqC,CAAA;QACvD,MAAM,YAAY,GAAG,GAAG,IAAI,KAAK,SAAS,GAAG,EAAE,CAAC,GAAG,GAAG,YAAY,GAAG,EAAE,CAAC,GAAG,GAAG,SAAS,EAAE,CAAA;QACzF,2BAAgB,CAAC,KAAK,EAAE,YAAY,CAAC,CAAA;KACtC;SAAM;QACL,sBAAY,CAAC,SAAS,EAAE,EAAC,IAAI,EAAC,EAAE,YAAY,CAAC,CAAA;KAC9C;AACH,CAAC;AAZD,wCAYC;AAED;;;GAGG;AACH,SAAgB,SAAS,CAAC,MAAc;IACtC,sBAAY,CAAC,UAAU,EAAE,EAAE,EAAE,MAAM,CAAC,CAAA;AACtC,CAAC;AAFD,8BAEC;AAED;;;GAGG;AACH,SAAgB,OAAO,CAAC,SAAiB;IACvC,MAAM,QAAQ,GAAG,OAAO,CAAC,GAAG,CAAC,aAAa,CAAC,IAAI,EAAE,CAAA;IACjD,IAAI,QAAQ,EAAE;QACZ,2BAAgB,CAAC,MAAM,EAAE,SAAS,CAAC,CAAA;KACpC;SAAM;QACL,sBAAY,CAAC,UAAU,EAAE,EAAE,EAAE,SAAS,CAAC,CAAA;KACxC;IACD,OAAO,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,GAAG,SAAS,GAAG,IAAI,CAAC,SAAS,GAAG,OAAO,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,CAAA;AAC7E,CAAC;AARD,0BAQC;AAED;;;;;;GAMG;AACH,SAAgB,QAAQ,CAAC,IAAY,EAAE,OAAsB;IAC3D,MAAM,GAAG,GACP,OAAO,CAAC,GAAG,CAAC,SAAS,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,GAAG,CAAC,CAAC,WAAW,EAAE,EAAE,CAAC,IAAI,EAAE,CAAA;IACrE,IAAI,OAAO,IAAI,OAAO,CAAC,QAAQ,IAAI,CAAC,GAAG,EAAE;QACvC,MAAM,IAAI,KAAK,CAAC,oCAAoC,IAAI,EAAE,CAAC,CAAA;KAC5D;IAED,OAAO,GAAG,CAAC,IAAI,EAAE,CAAA;AACnB,CAAC;AARD,4BAQC;AAED;;;;;GAKG;AACH,8DAA8D;AAC9D,SAAgB,SAAS,CAAC,IAAY,EAAE,KAAU;IAChD,sBAAY,CAAC,YAAY,EAAE,EAAC,IAAI,EAAC,EAAE,KAAK,CAAC,CAAA;AAC3C,CAAC;AAFD,8BAEC;AAED;;;;GAIG;AACH,SAAgB,cAAc,CAAC,OAAgB;IAC7C,eAAK,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC,CAAA;AACvC,CAAC;AAFD,wCAEC;AAED,yEAAyE;AACzE,UAAU;AACV,yEAAyE;AAEzE;;;;GAIG;AACH,SAAgB,SAAS,CAAC,OAAuB;IAC/C,OAAO,CAAC,QAAQ,GAAG,QAAQ,CAAC,OAAO,CAAA;IAEnC,KAAK,CAAC,OAAO,CAAC,CAAA;AAChB,CAAC;AAJD,8BAIC;AAED,yEAAyE;AACzE,mBAAmB;AACnB,yEAAyE;AAEzE;;GAEG;AACH,SAAgB,OAAO;IACrB,OAAO,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,KAAK,GAAG,CAAA;AAC5C,CAAC;AAFD,0BAEC;AAED;;;GAGG;AACH,SAAgB,KAAK,CAAC,OAAe;IACnC,sBAAY,CAAC,OAAO,EAAE,EAAE,EAAE,OAAO,CAAC,CAAA;AACpC,CAAC;AAFD,sBAEC;AAED;;;GAGG;AACH,SAAgB,KAAK,CAAC,OAAuB;IAC3C,eAAK,CAAC,OAAO,EAAE,OAAO,YAAY,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC,OAAO,CAAC,CAAA;AACzE,CAAC;AAFD,sBAEC;AAED;;;GAGG;AACH,SAAgB,OAAO,CAAC,OAAuB;IAC7C,eAAK,CAAC,SAAS,EAAE,OAAO,YAAY,KAAK,CAAC,CAAC,CAAC,OAAO,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC,OAAO,CAAC,CAAA;AAC3E,CAAC;AAFD,0BAEC;AAED;;;GAGG;AACH,SAAgB,IAAI,CAAC,OAAe;IAClC,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,OAAO,GAAG,EAAE,CAAC,GAAG,CAAC,CAAA;AACxC,CAAC;AAFD,oBAEC;AAED;;;;;;GAMG;AACH,SAAgB,UAAU,CAAC,IAAY;IACrC,eAAK,CAAC,OAAO,EAAE,IAAI,CAAC,CAAA;AACtB,CAAC;AAFD,gCAEC;AAED;;GAEG;AACH,SAAgB,QAAQ;IACtB,eAAK,CAAC,UAAU,CAAC,CAAA;AACnB,CAAC;AAFD,4BAEC;AAED;;;;;;;GAOG;AACH,SAAsB,KAAK,CAAI,IAAY,EAAE,EAAoB;;QAC/D,UAAU,CAAC,IAAI,CAAC,CAAA;QAEhB,IAAI,MAAS,CAAA;QAEb,IAAI;YACF,MAAM,GAAG,MAAM,EAAE,EAAE,CAAA;SACpB;gBAAS;YACR,QAAQ,EAAE,CAAA;SACX;QAED,OAAO,MAAM,CAAA;IACf,CAAC;CAAA;AAZD,sBAYC;AAED,yEAAyE;AACzE,uBAAuB;AACvB,yEAAyE;AAEzE;;;;;GAKG;AACH,8DAA8D;AAC9D,SAAgB,SAAS,CAAC,IAAY,EAAE,KAAU;IAChD,sBAAY,CAAC,YAAY,EAAE,EAAC,IAAI,EAAC,EAAE,KAAK,CAAC,CAAA;AAC3C,CAAC;AAFD,8BAEC;AAED;;;;;GAKG;AACH,SAAgB,QAAQ,CAAC,IAAY;IACnC,OAAO,OAAO,CAAC,GAAG,CAAC,SAAS,IAAI,EAAE,CAAC,IAAI,EAAE,CAAA;AAC3C,CAAC;AAFD,4BAEC"}
@@ -0,0 +1 @@
+export declare function issueCommand(command: string, message: any): void;
@@ -0,0 +1,29 @@
+"use strict";
+// For internal use, subject to change.
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
+    result["default"] = mod;
+    return result;
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+// We use any as a valid input type
+/* eslint-disable @typescript-eslint/no-explicit-any */
+const fs = __importStar(require("fs"));
+const os = __importStar(require("os"));
+const utils_1 = require("./utils");
+function issueCommand(command, message) {
+    const filePath = process.env[`GITHUB_${command}`];
+    if (!filePath) {
+        throw new Error(`Unable to find environment variable for file command ${command}`);
+    }
+    if (!fs.existsSync(filePath)) {
+        throw new Error(`Missing file at path: ${filePath}`);
+    }
+    fs.appendFileSync(filePath, `${utils_1.toCommandValue(message)}${os.EOL}`, {
+        encoding: 'utf8'
+    });
+}
+exports.issueCommand = issueCommand;
+//# sourceMappingURL=file-command.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"file-command.js","sourceRoot":"","sources":["../src/file-command.ts"],"names":[],"mappings":";AAAA,uCAAuC;;;;;;;;;AAEvC,mCAAmC;AACnC,uDAAuD;AAEvD,uCAAwB;AACxB,uCAAwB;AACxB,mCAAsC;AAEtC,SAAgB,YAAY,CAAC,OAAe,EAAE,OAAY;IACxD,MAAM,QAAQ,GAAG,OAAO,CAAC,GAAG,CAAC,UAAU,OAAO,EAAE,CAAC,CAAA;IACjD,IAAI,CAAC,QAAQ,EAAE;QACb,MAAM,IAAI,KAAK,CACb,wDAAwD,OAAO,EAAE,CAClE,CAAA;KACF;IACD,IAAI,CAAC,EAAE,CAAC,UAAU,CAAC,QAAQ,CAAC,EAAE;QAC5B,MAAM,IAAI,KAAK,CAAC,yBAAyB,QAAQ,EAAE,CAAC,CAAA;KACrD;IAED,EAAE,CAAC,cAAc,CAAC,QAAQ,EAAE,GAAG,sBAAc,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,EAAE,EAAE;QACjE,QAAQ,EAAE,MAAM;KACjB,CAAC,CAAA;AACJ,CAAC;AAdD,oCAcC"}
@@ -0,0 +1,5 @@
+/**
+ * Sanitizes an input into a string so it can be passed into issueCommand safely
+ * @param input input to sanitize into a string
+ */
+export declare function toCommandValue(input: any): string;
@@ -0,0 +1,19 @@
+"use strict";
+// We use any as a valid input type
+/* eslint-disable @typescript-eslint/no-explicit-any */
+Object.defineProperty(exports, "__esModule", { value: true });
+/**
+ * Sanitizes an input into a string so it can be passed into issueCommand safely
+ * @param input input to sanitize into a string
+ */
+function toCommandValue(input) {
+    if (input === null || input === undefined) {
+        return '';
+    }
+    else if (typeof input === 'string' || input instanceof String) {
+        return input;
+    }
+    return JSON.stringify(input);
+}
+exports.toCommandValue = toCommandValue;
+//# sourceMappingURL=utils.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"utils.js","sourceRoot":"","sources":["../src/utils.ts"],"names":[],"mappings":";AAAA,mCAAmC;AACnC,uDAAuD;;AAEvD;;;GAGG;AACH,SAAgB,cAAc,CAAC,KAAU;IACvC,IAAI,KAAK,KAAK,IAAI,IAAI,KAAK,KAAK,SAAS,EAAE;QACzC,OAAO,EAAE,CAAA;KACV;SAAM,IAAI,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,YAAY,MAAM,EAAE;QAC/D,OAAO,KAAe,CAAA;KACvB;IACD,OAAO,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,CAAA;AAC9B,CAAC;AAPD,wCAOC"}
@@ -1,37 +1,34 @@
 {
-  "_args": [
-    [
-      "@actions/core@1.1.0",
-      "E:\\k8s-actions\\deploy\\k8s-deploy"
-    ]
-  ],
-  "_from": "@actions/core@1.1.0",
-  "_id": "@actions/core@1.1.0",
+  "_from": "@actions/core@^1.2.6",
+  "_id": "@actions/core@1.2.6",
  "_inBundle": false,
-  "_integrity": "sha512-KKpo3xzo0Zsikni9tbOsEQkxZBGDsYSJZNkTvmo0gPSXrc98TBOcdTvKwwjitjkjHkreTggWdB1ACiAFVgsuzA==",
+  "_integrity": "sha512-ZQYitnqiyBc3D+k7LsgSBmMDVkOVidaagDG7j3fOym77jNunWRuYx7VSHa9GNfFZh+zh61xsCjRj4JxMZlDqTA==",
  "_location": "/@actions/core",
  "_phantomChildren": {},
  "_requested": {
-    "type": "version",
+    "type": "range",
    "registry": true,
-    "raw": "@actions/core@1.1.0",
+    "raw": "@actions/core@^1.2.6",
    "name": "@actions/core",
    "escapedName": "@actions%2fcore",
    "scope": "@actions",
-    "rawSpec": "1.1.0",
+    "rawSpec": "^1.2.6",
    "saveSpec": null,
-    "fetchSpec": "1.1.0"
+    "fetchSpec": "^1.2.6"
  },
  "_requiredBy": [
    "/",
    "/@actions/tool-cache"
  ],
-  "_resolved": "https://registry.npmjs.org/@actions/core/-/core-1.1.0.tgz",
-  "_spec": "1.1.0",
-  "_where": "E:\\k8s-actions\\deploy\\k8s-deploy",
+  "_resolved": "https://registry.npmjs.org/@actions/core/-/core-1.2.6.tgz",
+  "_shasum": "a78d49f41a4def18e88ce47c2cac615d5694bf09",
+  "_spec": "@actions/core@^1.2.6",
+  "_where": "C:\\Users\\kodey\\workspace\\github-actions\\k8s-deploy",
  "bugs": {
    "url": "https://github.com/actions/toolkit/issues"
  },
+  "bundleDependencies": false,
+  "deprecated": false,
  "description": "Actions core lib",
  "devDependencies": {
    "@types/node": "^12.0.2"
@@ -41,10 +38,10 @@
    "test": "__tests__"
  },
  "files": [
-    "lib"
+    "lib",
+    "!.DS_Store"
  ],
-  "gitHead": "a2ab4bcf78e4f7080f0d45856e6eeba16f0bbc52",
-  "homepage": "https://github.com/actions/toolkit/tree/master/packages/core",
+  "homepage": "https://github.com/actions/toolkit/tree/main/packages/core",
  "keywords": [
    "github",
    "actions",
@@ -58,11 +55,14 @@
  },
  "repository": {
    "type": "git",
-    "url": "git+https://github.com/actions/toolkit.git"
+    "url": "git+https://github.com/actions/toolkit.git",
+    "directory": "packages/core"
  },
  "scripts": {
+    "audit-moderate": "npm install && npm audit --json --audit-level=moderate > audit.json",
    "test": "echo \"Error: run tests from root\" && exit 1",
    "tsc": "tsc"
  },
-  "version": "1.1.0"
+  "types": "lib/core.d.ts",
+  "version": "1.2.6"
 }
@@ -8,16 +8,16 @@
        "test": "jest"
    },
    "dependencies": {
-        "@actions/tool-cache": "^1.0.0",
+        "@actions/core": "^1.2.6",
+        "@actions/exec": "^1.0.4",
        "@actions/io": "^1.0.0",
-        "@actions/core": "^1.0.0",
-        "@actions/exec": "^1.0.0",
+        "@actions/tool-cache": "^1.0.0",
        "js-yaml": "3.13.1"
    },
    "devDependencies": {
+        "@types/jest": "^25.2.2",
        "@types/node": "^12.0.10",
        "jest": "^25.0.0",
-        "@types/jest": "^25.2.2",
        "ts-jest": "^25.5.1",
        "typescript": "3.9.5"
    }
@@ -1,4 +1,5 @@
 'use strict';
+import { DeploymentConfig } from "./utilities/utility";

 export class KubernetesWorkload {
    public static pod: string = 'Pod';
@@ -25,15 +26,30 @@ export const deploymentTypes: string[] = ['deployment', 'replicaset', 'daemonset
 export const workloadTypes: string[] = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset', 'job', 'cronjob'];
 export const workloadTypesWithRolloutStatus: string[] = ['deployment', 'daemonset', 'statefulset'];

-export const workflowAnnotations = [
-    `run=${process.env['GITHUB_RUN_ID']}`,
-    `repository=${process.env['GITHUB_REPOSITORY']}`,
-    `workflow=${process.env['GITHUB_WORKFLOW']}`,
-    `jobName=${process.env['GITHUB_JOB']}`,
-    `createdBy=${process.env['GITHUB_ACTOR']}`,
-    `runUri=https://github.com/${process.env['GITHUB_REPOSITORY']}/actions/runs/${process.env['GITHUB_RUN_ID']}`,
-    `commit=${process.env['GITHUB_SHA']}`,
-    `branch=${process.env['GITHUB_REF']}`,
-    `deployTimestamp=${Date.now()}`,
-    `provider=GitHub`
-];
+export function getWorkflowAnnotationsJson(lastSuccessRunSha: string, workflowFilePath: string, deploymentConfig: DeploymentConfig): string {
+    let annotationObject: any = {};
+    annotationObject["run"] = process.env.GITHUB_RUN_ID;
+    annotationObject["repository"] = process.env.GITHUB_REPOSITORY;
+    annotationObject["workflow"] = process.env.GITHUB_WORKFLOW;
+    annotationObject["workflowFileName"] = workflowFilePath.replace(".github/workflows/", "");
+    annotationObject["jobName"] = process.env.GITHUB_JOB;
+    annotationObject["createdBy"] = process.env.GITHUB_ACTOR;
+    annotationObject["runUri"] = `https://github.com/${process.env.GITHUB_REPOSITORY}/actions/runs/${process.env.GITHUB_RUN_ID}`;
+    annotationObject["commit"] = process.env.GITHUB_SHA;
+    annotationObject["lastSuccessRunCommit"] = lastSuccessRunSha;
+    annotationObject["branch"] = process.env.GITHUB_REF;
+    annotationObject["deployTimestamp"] = Date.now();
+    annotationObject["dockerfilePaths"] = deploymentConfig.dockerfilePaths;
+    annotationObject["manifestsPaths"] = deploymentConfig.manifestFilePaths
+    annotationObject["helmChartPaths"] = deploymentConfig.helmChartFilePaths;
+    annotationObject["provider"] = "GitHub";
+
+    return JSON.stringify(annotationObject);
+}
+
+export function getWorkflowAnnotationKeyLabel(workflowFilePath: string): string {
+    const hashKey = require("crypto").createHash("MD5")
+        .update(`${process.env.GITHUB_REPOSITORY}/${workflowFilePath}`)
+        .digest("hex");
+    return `githubWorkflow_${hashKey}`;
+}
@@ -0,0 +1,33 @@
+import { ToolRunner, IExecOptions, IExecSyncResult } from "./utilities/tool-runner";
+
+export class DockerExec {
+    private dockerPath: string;
+
+    constructor(dockerPath: string) {
+        this.dockerPath = dockerPath;
+    };
+
+    public pull(image: string, args: string[], silent?: boolean) {
+        args = ['pull', image, ...args];
+        let result: IExecSyncResult = this.execute(args, silent);
+        if (result.stderr != '' && result.code != 0) {
+            throw new Error(`docker images pull failed with: ${result.error}`);
+        }
+    }
+
+    public inspect(image: string, args: string[], silent?: boolean): any {
+        args = ['inspect', image, ...args];
+        let result: IExecSyncResult = this.execute(args, silent);
+        if (result.stderr != '' && result.code != 0) {
+            throw new Error(`docker inspect call failed with: ${result.error}`);
+        }
+        return result.stdout;
+    }
+
+    private execute(args: string[], silent?: boolean) {
+        const command = new ToolRunner(this.dockerPath);
+        command.arg(args);
+
+        return command.execSync({ silent: !!silent } as IExecOptions);
+    }
+} 
@@ -0,0 +1,26 @@
+import * as core from '@actions/core';
+import { WebRequest, WebResponse, sendRequest } from "./utilities/httpClient";
+
+export class GitHubClient {
+    constructor(repository: string, token: string) {
+        this._repository = repository;
+        this._token = token;
+    }
+
+    public async getWorkflows(): Promise<any> {
+        const getWorkflowFileNameUrl = `https://api.github.com/repos/${this._repository}/actions/workflows`;
+        const webRequest = new WebRequest();
+        webRequest.method = "GET";
+        webRequest.uri = getWorkflowFileNameUrl;
+        webRequest.headers = {
+            Authorization: `Bearer ${this._token}`
+        };
+
+        core.debug(`Getting workflows for repo: ${this._repository}`);
+        const response: WebResponse = await sendRequest(webRequest);
+        return Promise.resolve(response);
+    }
+
+    private _repository: string;
+    private _token: string;
+}
@@ -12,12 +12,17 @@ export const trafficSplitMethod: string = core.getInput('traffic-split-method');
 export const baselineAndCanaryReplicas: string = core.getInput('baseline-and-canary-replicas');
 export const args: string = core.getInput('arguments');
 export const forceDeployment: boolean = core.getInput('force').toLowerCase() == 'true';
+export const githubToken = core.getInput("token");

 if (!namespace) {
    core.debug('Namespace was not supplied; using "default" namespace instead.');
    namespace = 'default';
 }

+if (!githubToken) {
+    core.error("'token' input is not supplied. Set it to a PAT/GITHUB_TOKEN");
+}
+
 try {
    const pe = parseInt(canaryPercentage);
    if (pe < 0 || pe > 100) {
@@ -50,18 +50,26 @@ export class Kubectl {
        return newReplicaSet;
    }

-    public annotate(resourceType: string, resourceName: string, annotations: string[], overwrite?: boolean): IExecSyncResult {
+    public annotate(resourceType: string, resourceName: string, annotation: string): IExecSyncResult {
        let args = ['annotate', resourceType, resourceName];
-        args = args.concat(annotations);
-        if (!!overwrite) { args.push(`--overwrite`); }
+        args.push(annotation);
+        args.push(`--overwrite`);
        return this.execute(args);
    }

-    public annotateFiles(files: string | string[], annotations: string[], overwrite?: boolean): IExecSyncResult {
+    public annotateFiles(files: string | string[], annotation: string): IExecSyncResult {
        let args = ['annotate'];
        args = args.concat(['-f', this.createInlineArray(files)]);
-        args = args.concat(annotations);
-        if (!!overwrite) { args.push(`--overwrite`); }
+        args.push(annotation);
+        args.push(`--overwrite`);
+        return this.execute(args);
+    }
+
+    public labelFiles(files: string | string[], labels: string[]): IExecSyncResult {
+        let args = ['label'];
+        args = args.concat(['-f', this.createInlineArray(files)]);
+        args = args.concat(labels);
+        args.push(`--overwrite`);
        return this.execute(args);
    }

@@ -42,7 +42,7 @@ async function installKubectl(version: string) {

 function checkClusterContext() {
    if (!process.env["KUBECONFIG"]) {
-        throw new Error('Cluster context not set. Use k8ssetcontext action to set cluster context');
+        core.warning('KUBECONFIG env is not explicitly set. Ensure cluster context is set by using k8s-set-context / aks-set-context action.');
    }
 }

@@ -0,0 +1,114 @@
+// Taken from https://github.com/Azure/aks-set-context/blob/master/src/client.ts
+import util = require("util");
+import fs = require('fs');
+import httpClient = require("typed-rest-client/HttpClient");
+import * as core from '@actions/core';
+
+var httpCallbackClient = new httpClient.HttpClient('GITHUB_RUNNER', null, {});
+
+export enum StatusCodes {
+    OK = 200,
+    CREATED = 201,
+    ACCEPTED = 202,
+    UNAUTHORIZED = 401,
+    NOT_FOUND = 404,
+    INTERNAL_SERVER_ERROR = 500,
+    SERVICE_UNAVAILABLE = 503
+}
+
+export class WebRequest {
+    public method: string;
+    public uri: string;
+    // body can be string or ReadableStream
+    public body: string | NodeJS.ReadableStream;
+    public headers: any;
+}
+
+export class WebResponse {
+    public statusCode: number;
+    public statusMessage: string;
+    public headers: any;
+    public body: any;
+}
+
+export class WebRequestOptions {
+    public retriableErrorCodes?: string[];
+    public retryCount?: number;
+    public retryIntervalInSeconds?: number;
+    public retriableStatusCodes?: number[];
+    public retryRequestTimedout?: boolean;
+}
+
+export async function sendRequest(request: WebRequest, options?: WebRequestOptions): Promise<WebResponse> {
+    let i = 0;
+    let retryCount = options && options.retryCount ? options.retryCount : 5;
+    let retryIntervalInSeconds = options && options.retryIntervalInSeconds ? options.retryIntervalInSeconds : 2;
+    let retriableErrorCodes = options && options.retriableErrorCodes ? options.retriableErrorCodes : ["ETIMEDOUT", "ECONNRESET", "ENOTFOUND", "ESOCKETTIMEDOUT", "ECONNREFUSED", "EHOSTUNREACH", "EPIPE", "EA_AGAIN"];
+    let retriableStatusCodes = options && options.retriableStatusCodes ? options.retriableStatusCodes : [408, 409, 500, 502, 503, 504];
+    let timeToWait: number = retryIntervalInSeconds;
+    while (true) {
+        try {
+            if (request.body && typeof (request.body) !== 'string' && !request.body["readable"]) {
+                request.body = fs.createReadStream(request.body["path"]);
+            }
+
+            let response: WebResponse = await sendRequestInternal(request);
+            if (retriableStatusCodes.indexOf(response.statusCode) != -1 && ++i < retryCount) {
+                core.debug(util.format("Encountered a retriable status code: %s. Message: '%s'.", response.statusCode, response.statusMessage));
+                await sleepFor(timeToWait);
+                timeToWait = timeToWait * retryIntervalInSeconds + retryIntervalInSeconds;
+                continue;
+            }
+
+            return response;
+        }
+        catch (error) {
+            if (retriableErrorCodes.indexOf(error.code) != -1 && ++i < retryCount) {
+                core.debug(util.format("Encountered a retriable error:%s. Message: %s.", error.code, error.message));
+                await sleepFor(timeToWait);
+                timeToWait = timeToWait * retryIntervalInSeconds + retryIntervalInSeconds;
+            }
+            else {
+                if (error.code) {
+                    core.debug("error code =" + error.code);
+                }
+
+                throw error;
+            }
+        }
+    }
+}
+
+export function sleepFor(sleepDurationInSeconds: number): Promise<any> {
+    return new Promise((resolve, reject) => {
+        setTimeout(resolve, sleepDurationInSeconds * 1000);
+    });
+}
+
+async function sendRequestInternal(request: WebRequest): Promise<WebResponse> {
+    core.debug(util.format("[%s]%s", request.method, request.uri));
+    var response: httpClient.HttpClientResponse = await httpCallbackClient.request(request.method, request.uri, request.body, request.headers);
+    return await toWebResponse(response);
+}
+
+async function toWebResponse(response: httpClient.HttpClientResponse): Promise<WebResponse> {
+    var res = new WebResponse();
+    if (response) {
+        res.statusCode = response.message.statusCode;
+        res.statusMessage = response.message.statusMessage;
+        res.headers = response.message.headers;
+        var body = await response.readBody();
+        if (body) {
+            try {
+                res.body = JSON.parse(body);
+            }
+            catch (error) {
+                core.debug("Could not parse response: " + JSON.stringify(error));
+                core.debug("Response: " + JSON.stringify(res.body));
+                res.body = body;
+            }
+        }
+    }
+
+    return res;
+}
@@ -17,7 +17,7 @@ import { IExecSyncResult } from '../../utilities/tool-runner';

 import { deployPodCanary } from './pod-canary-deployment-helper';
 import { deploySMICanary } from './smi-canary-deployment-helper';
-import { checkForErrors, annotateChildPods, annotateNamespace } from "../utility";
+import { checkForErrors, annotateChildPods, getWorkflowFilePath, getLastSuccessfulRunSha, getDeploymentConfig, DeploymentConfig } from "../utility";


 export async function deploy(kubectl: Kubectl, manifestFilePaths: string[], deploymentStrategy: string) {
@@ -49,7 +49,7 @@ export async function deploy(kubectl: Kubectl, manifestFilePaths: string[], depl
        core.debug("Unable to parse pods; Error: " + e);
    }

-    annotateResources(deployedManifestFiles, kubectl, resourceTypes, allPods);
+    annotateAndLabelResources(deployedManifestFiles, kubectl, resourceTypes, allPods);
 }

 function getManifestFiles(manifestFilePaths: string[]): string[] {
@@ -112,19 +112,37 @@ async function checkManifestStability(kubectl: Kubectl, resources: Resource[]):
    await KubernetesManifestUtility.checkManifestStability(kubectl, resources);
 }

-function annotateResources(files: string[], kubectl: Kubectl, resourceTypes: Resource[], allPods: any) {
+async function annotateAndLabelResources(files: string[], kubectl: Kubectl, resourceTypes: Resource[], allPods: any) {
+    const workflowFilePath = await getWorkflowFilePath(TaskInputParameters.githubToken);
+    const deploymentConfig = await getDeploymentConfig();
+    const annotationKeyLabel = models.getWorkflowAnnotationKeyLabel(workflowFilePath);
+    annotateResources(files, kubectl, resourceTypes, allPods, annotationKeyLabel, workflowFilePath, deploymentConfig);
+    labelResources(files, kubectl, annotationKeyLabel);
+}
+
+function annotateResources(files: string[], kubectl: Kubectl, resourceTypes: Resource[], allPods: any, annotationKey: string, workflowFilePath: string, deploymentConfig: DeploymentConfig) {
    const annotateResults: IExecSyncResult[] = [];
-    annotateResults.push(annotateNamespace(kubectl, TaskInputParameters.namespace));
-    annotateResults.push(kubectl.annotateFiles(files, models.workflowAnnotations, true));
+    const lastSuccessSha = getLastSuccessfulRunSha(kubectl, TaskInputParameters.namespace, annotationKey);
+    let annotationKeyValStr = annotationKey + '=' + models.getWorkflowAnnotationsJson(lastSuccessSha, workflowFilePath, deploymentConfig);
+    annotateResults.push(kubectl.annotate('namespace', TaskInputParameters.namespace, annotationKeyValStr));
+    annotateResults.push(kubectl.annotateFiles(files, annotationKeyValStr));
    resourceTypes.forEach(resource => {
        if (resource.type.toUpperCase() !== models.KubernetesWorkload.pod.toUpperCase()) {
-            annotateChildPods(kubectl, resource.type, resource.name, allPods)
+            annotateChildPods(kubectl, resource.type, resource.name, annotationKeyValStr, allPods)
                .forEach(execResult => annotateResults.push(execResult));
        }
    });
    checkForErrors(annotateResults, true);
 }

+function labelResources(files: string[], kubectl: Kubectl, label: string) {
+    let workflowName = process.env.GITHUB_WORKFLOW;
+    workflowName = workflowName.startsWith('.github/workflows/') ?
+        workflowName.replace(".github/workflows/", "") : workflowName;
+    const labels = [`workflowFriendlyName=${workflowName}`, `workflow=${label}`];
+    checkForErrors([kubectl.labelFiles(files, labels)], true);
+}
+
 function updateResourceObjects(filePaths: string[], imagePullSecrets: string[], containers: string[]): string[] {
    const newObjectsList = [];
    const updateResourceObject = (inputObject) => {
@@ -2,7 +2,17 @@ import * as os from 'os';
 import * as core from '@actions/core';
 import { IExecSyncResult } from './tool-runner';
 import { Kubectl } from '../kubectl-object-model';
-import { workflowAnnotations } from '../constants';
+import { GitHubClient } from '../githubClient';
+import { StatusCodes } from "./httpClient";
+import * as inputParams from "../input-parameters";
+import { DockerExec } from '../docker-object-model';
+import * as io from '@actions/io';
+
+export interface DeploymentConfig {
+    manifestFilePaths: string[];
+    helmChartFilePaths: string[];
+    dockerfilePaths: any;
+}

 export function getExecutableExtension(): string {
    if (os.type().match(/^Win/)) {
@@ -50,7 +60,61 @@ export function checkForErrors(execResults: IExecSyncResult[], warnIfError?: boo
    }
 }

-export function annotateChildPods(kubectl: Kubectl, resourceType: string, resourceName: string, allPods): IExecSyncResult[] {
+export function getLastSuccessfulRunSha(kubectl: Kubectl, namespaceName: string, annotationKey: string): string {
+    try {
+        const result = kubectl.getResource('namespace', namespaceName);
+        if (result) {
+            if (result.stderr) {
+                core.warning(`${result.stderr}`);
+                return process.env.GITHUB_SHA;
+            }
+            else if (result.stdout) {
+                const annotationsSet = JSON.parse(result.stdout).metadata.annotations;
+                if (annotationsSet && annotationsSet[annotationKey]) {
+                    return JSON.parse(annotationsSet[annotationKey].replace(/'/g, '"')).commit;
+                }
+                else {
+                    return 'NA';
+                }
+            }
+        }
+    }
+    catch (ex) {
+        core.warning(`Failed to get commits from cluster. ${JSON.stringify(ex)}`);
+        return '';
+    }
+}
+
+export async function getWorkflowFilePath(githubToken: string): Promise<string> {
+    let workflowFilePath = process.env.GITHUB_WORKFLOW;
+    if (!workflowFilePath.startsWith('.github/workflows/')) {
+        const githubClient = new GitHubClient(process.env.GITHUB_REPOSITORY, githubToken);
+        const response = await githubClient.getWorkflows();
+        if (response) {
+            if (response.statusCode == StatusCodes.OK
+                && response.body
+                && response.body.total_count) {
+                if (response.body.total_count > 0) {
+                    for (let workflow of response.body.workflows) {
+                        if (process.env.GITHUB_WORKFLOW === workflow.name) {
+                            workflowFilePath = workflow.path;
+                            break;
+                        }
+                    }
+                }
+            }
+            else if (response.statusCode != StatusCodes.OK) {
+                core.debug(`An error occured while getting list of workflows on the repo. Statuscode: ${response.statusCode}, StatusMessage: ${response.statusMessage}`);
+            }
+        }
+        else {
+            core.warning(`Failed to get response from workflow list API`);
+        }
+    }
+    return Promise.resolve(workflowFilePath);
+}
+
+export function annotateChildPods(kubectl: Kubectl, resourceType: string, resourceName: string, annotationKeyValStr: string, allPods): IExecSyncResult[] {
    const commandExecutionResults = [];
    let owner = resourceName;
    if (resourceType.toLowerCase().indexOf('deployment') > -1) {
@@ -63,37 +127,47 @@ export function annotateChildPods(kubectl: Kubectl, resourceType: string, resour
            if (owners) {
                owners.forEach(ownerRef => {
                    if (ownerRef.name === owner) {
-                        commandExecutionResults.push(kubectl.annotate('pod', pod.metadata.name, workflowAnnotations, true));
+                        commandExecutionResults.push(kubectl.annotate('pod', pod.metadata.name, annotationKeyValStr));
                    }
                });
            }
        });
    }
-
    return commandExecutionResults;
 }

-export function annotateNamespace(kubectl: Kubectl, namespaceName: string): IExecSyncResult {
-    const result = kubectl.getResource('namespace', namespaceName);
-    if (!result) {
-        return { code: -1, stderr: 'Failed to get resource' } as IExecSyncResult;
-    }
-    else if (result && result.stderr) {
-        return result;
+export async function getDeploymentConfig(): Promise<DeploymentConfig> {
+
+    let helmChartPaths: string[] = (process.env.HELM_CHART_PATHS && process.env.HELM_CHART_PATHS.split(';').filter(path => path != "")) || [];
+    helmChartPaths = helmChartPaths.map(helmchart => getNormalizedPath(helmchart.trim()));
+
+    let inputManifestFiles: string[] = inputParams.manifests || [];
+    if (!helmChartPaths.length) {
+        inputManifestFiles = inputManifestFiles.map(manifestFile => getNormalizedPath(manifestFile));
    }

-    if (result && result.stdout) {
-        const annotationsSet = JSON.parse(result.stdout).metadata.annotations;
-        if (annotationsSet && annotationsSet.runUri) {
-            if (annotationsSet.runUri.indexOf(process.env['GITHUB_REPOSITORY']) == -1) {
-                core.debug(`Skipping 'annotate namespace' as namespace annotated by other workflow`);
-                return { code: 0, stdout: '' } as IExecSyncResult;
-            }
+    const imageNames = inputParams.containers || [];
+    let imageDockerfilePathMap: { [id: string]: string; } = {};
+
+    //Fetching from image label if available
+    for (const image of imageNames) {
+        try {
+            imageDockerfilePathMap[image] = await getDockerfilePath(image);
+        }
+        catch (ex) {
+            core.warning(`Failed to get dockerfile path for image ${image.toString()} | ` + ex);
        }
-        return kubectl.annotate('namespace', namespaceName, workflowAnnotations, true);
    }
+
+    const deploymentConfig = <DeploymentConfig>{
+        manifestFilePaths: inputManifestFiles,
+        helmChartFilePaths: helmChartPaths,
+        dockerfilePaths: imageDockerfilePathMap
+    };
+    return Promise.resolve(deploymentConfig);
 }

+
 export function sleep(timeout: number) {
    return new Promise(resolve => setTimeout(resolve, timeout));
 }
@@ -105,3 +179,40 @@ export function getRandomInt(max: number) {
 export function getCurrentTime(): number {
    return new Date().getTime();
 }
+
+async function checkDockerPath() {
+    let dockerPath = await io.which('docker', false);
+    if (!dockerPath) {
+        throw new Error('Docker is not installed.');
+    }
+}
+
+async function getDockerfilePath(image: any): Promise<string> {
+    let imageConfig: any, imageInspectResult: string;
+    var dockerExec: DockerExec = new DockerExec('docker');
+    await checkDockerPath();
+    dockerExec.pull(image, [], true);
+    imageInspectResult = dockerExec.inspect(image, [], true);
+    imageConfig = JSON.parse(imageInspectResult)[0];
+    const DOCKERFILE_PATH_LABEL_KEY = 'dockerfile-path';
+    let pathValue: string = '';
+    if (imageConfig) {
+        if ((imageConfig.Config) && (imageConfig.Config.Labels) && (imageConfig.Config.Labels[DOCKERFILE_PATH_LABEL_KEY])) {
+            const pathLabel = imageConfig.Config.Labels[DOCKERFILE_PATH_LABEL_KEY];
+            pathValue = getNormalizedPath(pathLabel);
+        }
+    }
+    return pathValue;
+}
+
+export function isHttpUrl(url: string) {
+    const HTTP_REGEX = /^https?:\/\/.*$/;
+    return HTTP_REGEX.test(url);
+}
+
+export function getNormalizedPath(pathValue: string) {
+    if (!isHttpUrl(pathValue)) {  //if it is not an http url then convert to link from current repo and commit 
+        return `https://github.com/${process.env.GITHUB_REPOSITORY}/blob/${process.env.GITHUB_SHA}/${pathValue}`;
+    }
+    return pathValue;
+}
Author	SHA1	Message	Date
Koushik Dey	8249ba50bd	Sending a warning instead of throwing error when KUBECONFIG is missing. (#146 )	2021-08-17 16:38:53 +05:30
Jyotsna	d1dd574643	Users/jysin/pm feedback changes v1.2 (#100 ) * Changed dockerfile, manifest, helmchart links and README	2021-01-07 12:52:48 +05:30
Jyotsna	87674d7272	Bug fix for dockerfile path (#94 ) * Bug fix for dockerfile path	2020-12-30 22:17:18 +05:30
Jyotsna	d7d5d3429f	New traceability fields annotation changes - design changes (#89 ) * New design changes	2020-12-29 19:11:56 +05:30
Jyotsna	068b665bf3	Initial commit for config files annotations (#78 ) * Initial commit for config files annotations * Tests fixed * bug fixes * bug fixes * bug fixes * bug fixes * Fixing annotations * Fixing annotations * Fixing annotations * Review comment changes * Review comment changes * Review comment changes * JSON structure fixes of config paths * LF/CRLF fix * review comments changes * JSON structure fixes * JSON structure fixes * JSON structure fixes * JSON structure fixes * JSON structure fixes * JSON structure fixes * JSON structure fixes * JSON structure fixes * Added reading dockerfile from env var, code cleanup * Tests edited	2020-11-25 13:31:47 +05:30
Jyotsna	b5e9247a76	Minor fix	2020-11-25 13:27:21 +05:30
Jyotsna	346e5b60f0	Tests edited	2020-11-25 13:17:40 +05:30
Jyotsna	7ab8f38c56	Added reading dockerfile from env var, code cleanup	2020-11-25 13:05:58 +05:30
Jyotsna	9fa045d9cf	JSON structure fixes	2020-11-23 16:07:34 +05:30
Jyotsna	e4319ffe29	JSON structure fixes	2020-11-23 15:58:31 +05:30
Jyotsna	aee2875fcd	JSON structure fixes	2020-11-23 15:44:04 +05:30
Jyotsna	9458d67ac6	JSON structure fixes	2020-11-23 15:37:13 +05:30
Jyotsna	27085d52d5	JSON structure fixes	2020-11-23 15:15:26 +05:30
Jyotsna	d953c709a5	JSON structure fixes	2020-11-23 14:50:29 +05:30
Jyotsna	ba95de9cac	JSON structure fixes	2020-11-23 14:44:48 +05:30
Jyotsna	34bbe17ae7	JSON structure fixes	2020-11-23 14:35:04 +05:30
Jyotsna	52883f3264	review comments changes	2020-11-23 14:19:50 +05:30
Jyotsna	ef8defce31	LF/CRLF fix	2020-11-23 14:03:03 +05:30
Jyotsna	41514fca22	JSON structure fixes of config paths	2020-11-23 14:01:06 +05:30
Jyotsna	d0f7e63ea0	Review comment changes	2020-11-23 13:45:27 +05:30
Jyotsna	77dd040b09	Review comment changes	2020-11-23 13:43:26 +05:30
Jyotsna	87732d1861	Review comment changes	2020-11-23 13:37:57 +05:30
Jyotsna	d8b8394d0c	Fixing annotations	2020-11-21 00:37:13 +05:30
Jyotsna	764402d855	Fixing annotations	2020-11-21 00:18:06 +05:30
Jyotsna	db567f3869	Fixing annotations	2020-11-21 00:10:09 +05:30
Jyotsna	79d7af7e76	bug fixes	2020-11-20 23:52:46 +05:30
Jyotsna	aa2e43b5c4	bug fixes	2020-11-20 23:29:52 +05:30
Jyotsna	5f654c89dc	bug fixes	2020-11-20 23:09:58 +05:30
Jyotsna	c3ad59d720	bug fixes	2020-11-18 20:13:57 +05:30
Jyotsna	faf09632f3	Tests fixed	2020-11-18 20:08:49 +05:30
Jyotsna	bfca26e368	Initial commit for config files annotations	2020-11-17 18:15:45 +05:30
Koushik Dey	b371791f3a	Merge pull request #68 from Azure/users/koushdey/@v1.2-actions/core-1.2.6 Bump @actions/core from 1.1.0 to 1.2.6	2020-10-13 09:40:34 +05:30
Koushik Dey	7d00e7b645	Bump @actions/core from 1.1.0 to 1.2.6	2020-10-11 19:08:18 +05:30
Koushik Dey	c578d50a12	Merge pull request #57 from Azure/users/koushdey/workflowAnnotations Annotation and Label changes to handle multiple workflows across branches	2020-08-31 13:44:07 +05:30
Koushik Dey	f9acc4f772	WokflowFileName added in annotations for View All Runs in UX	2020-08-28 14:42:55 +05:30
Koushik Dey	65e1224846	Addressed review comments.	2020-08-27 17:14:59 +05:30
Koushik Dey	3a1c0b10eb	Removed success run API and edited testcases.	2020-08-25 16:37:11 +05:30
Koushik Dey	3d1e46f18f	Integrated workflow list and run API to get lastSuccessRunCommit	2020-08-25 16:29:50 +05:30
Koushik Dey	3919a9ee22	Added test cases for annotations and API integration	2020-08-25 16:29:30 +05:30
Koushik Dey	48110f8b94	GitHub API integration, labelling, annotating namespace	2020-08-25 16:28:11 +05:30
				`@@ -0,0 +1 @@`
				`export declare function issueCommand(command: string, message: any): void;`
				`@@ -0,0 +1 @@`
				{"version":3,"file":"file-command.js","sourceRoot":"","sources":["../src/file-command.ts"],"names":[],"mappings":";AAAA,uCAAuC;;;;;;;;;AAEvC,mCAAmC;AACnC,uDAAuD;AAEvD,uCAAwB;AACxB,uCAAwB;AACxB,mCAAsC;AAEtC,SAAgB,YAAY,CAAC,OAAe,EAAE,OAAY;IACxD,MAAM,QAAQ,GAAG,OAAO,CAAC,GAAG,CAAC,UAAU,OAAO,EAAE,CAAC,CAAA;IACjD,IAAI,CAAC,QAAQ,EAAE;QACb,MAAM,IAAI,KAAK,CACb,wDAAwD,OAAO,EAAE,CAClE,CAAA;KACF;IACD,IAAI,CAAC,EAAE,CAAC,UAAU,CAAC,QAAQ,CAAC,EAAE;QAC5B,MAAM,IAAI,KAAK,CAAC,yBAAyB,QAAQ,EAAE,CAAC,CAAA;KACrD;IAED,EAAE,CAAC,cAAc,CAAC,QAAQ,EAAE,GAAG,sBAAc,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,EAAE,EAAE;QACjE,QAAQ,EAAE,MAAM;KACjB,CAAC,CAAA;AACJ,CAAC;AAdD,oCAcC"}
				`@@ -0,0 +1 @@`
				`{"version":3,"file":"utils.js","sourceRoot":"","sources":["../src/utils.ts"],"names":[],"mappings":";AAAA,mCAAmC;AACnC,uDAAuD;;AAEvD;;;GAGG;AACH,SAAgB,cAAc,CAAC,KAAU;IACvC,IAAI,KAAK,KAAK,IAAI,IAAI,KAAK,KAAK,SAAS,EAAE;QACzC,OAAO,EAAE,CAAA;KACV;SAAM,IAAI,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,YAAY,MAAM,EAAE;QAC/D,OAAO,KAAe,CAAA;KACvB;IACD,OAAO,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,CAAA;AAC9B,CAAC;AAPD,wCAOC"}`