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

* Changed dockerfile, manifest, helmchart links and README

__tests__/run.test.ts

@@ -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 () => {
@@ -166,111 +203,6 @@ test("run() - deploy - Manifiest not provided", async () => {
     expect(coreMock.setFailed).toBeCalledWith('No manifests supplied to deploy');
 });
 
-test("run() - deploy - Only one manifest with no delimiters", async () => {
-    const kubectlVersion = 'v1.18.0'
-    coreMock.getInput = jest.fn().mockImplementation((name) => {
-        if (name == 'manifests') {
-            return "bg-smi.yml";
-        }
-        if (name == 'action') {
-            return 'deploy';
-        }
-        return kubectlVersion;
-    });
-    coreMock.setFailed = jest.fn();
-    toolCacheMock.find = jest.fn().mockReturnValue(undefined);
-    toolCacheMock.downloadTool = jest.fn().mockReturnValue('downloadpath');
-    toolCacheMock.cacheFile = jest.fn().mockReturnValue('cachepath');
-    fileUtility.chmodSync = jest.fn();
-
-    //Invoke and assert
-    await expect(action.run()).resolves.not.toThrow();
-});
-
-test("run() - deploy - Manifests provided by new line delimiter", async () => {
-    const kubectlVersion = 'v1.18.0'
-    coreMock.getInput = jest.fn().mockImplementation((name) => {
-        if (name == 'manifests') {
-            return "bg-smi.yml\n  bg.yml\ndeployment.yml";
-        }
-        if (name == 'action') {
-            return 'deploy';
-        }
-        return kubectlVersion;
-    });
-    coreMock.setFailed = jest.fn();
-    toolCacheMock.find = jest.fn().mockReturnValue(undefined);
-    toolCacheMock.downloadTool = jest.fn().mockReturnValue('downloadpath');
-    toolCacheMock.cacheFile = jest.fn().mockReturnValue('cachepath');
-    fileUtility.chmodSync = jest.fn();
-
-    //Invoke and assert
-    await expect(action.run()).resolves.not.toThrow();
-});
-
-test("run() - deploy - Manifests provided by comma as a delimiter", async () => {
-    const kubectlVersion = 'v1.18.0'
-    coreMock.getInput = jest.fn().mockImplementation((name) => {
-        if (name == 'manifests') {
-            return "bg-smi.yml, bg.yml, deployment.yml";
-        }
-        if (name == 'action') {
-            return 'deploy';
-        }
-        return kubectlVersion;
-    });
-    coreMock.setFailed = jest.fn();
-    toolCacheMock.find = jest.fn().mockReturnValue(undefined);
-    toolCacheMock.downloadTool = jest.fn().mockReturnValue('downloadpath');
-    toolCacheMock.cacheFile = jest.fn().mockReturnValue('cachepath');
-    fileUtility.chmodSync = jest.fn();
-
-    //Invoke and assert
-    await expect(action.run()).resolves.not.toThrow();
-});
-
-test("run() - deploy - Manifests provided by both new line and comma as a delimiter", async () => {
-    const kubectlVersion = 'v1.18.0'
-    coreMock.getInput = jest.fn().mockImplementation((name) => {
-        if (name == 'manifests') {
-            return "bg-smi.yml\nbg.yml,deployment.yml";
-        }
-        if (name == 'action') {
-            return 'deploy';
-        }
-        return kubectlVersion;
-    });
-    coreMock.setFailed = jest.fn();
-    toolCacheMock.find = jest.fn().mockReturnValue(undefined);
-    toolCacheMock.downloadTool = jest.fn().mockReturnValue('downloadpath');
-    toolCacheMock.cacheFile = jest.fn().mockReturnValue('cachepath');
-    fileUtility.chmodSync = jest.fn();
-
-    //Invoke and assert
-    await expect(action.run()).resolves.not.toThrow();
-});
-
-test("run() - deploy - Manifests provided by both new line and comma and semi-colon as a delimiter", async () => {
-    const kubectlVersion = 'v1.18.0'
-    coreMock.getInput = jest.fn().mockImplementation((name) => {
-        if (name == 'manifests') {
-            return "bg-smi.yml\nbg.yml,deployment.yml;bg.yml";
-        }
-        if (name == 'action') {
-            return 'deploy';
-        }
-        return kubectlVersion;
-    });
-    coreMock.setFailed = jest.fn();
-    toolCacheMock.find = jest.fn().mockReturnValue(undefined);
-    toolCacheMock.downloadTool = jest.fn().mockReturnValue('downloadpath');
-    toolCacheMock.cacheFile = jest.fn().mockReturnValue('cachepath');
-    fileUtility.chmodSync = jest.fn();
-
-    //Invoke and assert
-    await expect(action.run()).resolves.not.toThrow();
-});
-
 test("deployment - deploy() - Invokes with no manifestfiles", async () => {
     const kubeCtl: jest.Mocked<Kubectl> = new Kubectl("") as any;
 
@@ -318,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();
@@ -346,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();
@@ -356,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);
@@ -370,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);
@@ -392,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 () => {
@@ -421,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)
+});
+
+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);
 });

action.yml

@@ -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

lib/constants.js

@@ -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;

lib/docker-object-model.js

@@ -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;

lib/githubClient.js

@@ -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;

lib/input-parameters.js

@@ -1,21 +1,25 @@
 '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');
 exports.imagePullSecrets = core.getInput('imagepullsecrets').split('\n').filter(secret => secret.trim().length > 0);
-exports.manifests = core.getInput('manifests').split(/[\n,;]+/).filter(manifest => manifest.trim().length > 0);
+exports.manifests = core.getInput('manifests').split('\n');
 exports.canaryPercentage = core.getInput('percentage');
 exports.deploymentStrategy = core.getInput('strategy');
 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) {

lib/kubectl-object-model.js

@@ -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() {

lib/run.js

@@ -70,12 +70,7 @@ function run() {
             namespace = 'default';
         }
         let action = core.getInput('action');
-        let manifests = manifestsInput.split(/[\n,;]+/).filter(manifest => manifest.trim().length > 0);
-        if (manifests.length > 0) {
-            manifests = manifests.map(manifest => {
-                return manifest.trim();
-            });
-        }
+        let manifests = manifestsInput.split('\n');
         if (action === 'deploy') {
             let strategy = core.getInput('strategy');
             console.log("strategy: ", strategy);

lib/utilities/httpClient.js

@@ -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;
+    });
+}

lib/utilities/strategy-helpers/deployment-helper.js

@@ -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) => {

lib/utilities/utility.js

@@ -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;

package.json

@@ -8,16 +8,16 @@
         "test": "jest"
     },
     "dependencies": {
-        "@actions/tool-cache": "^1.0.0",
-        "@actions/io": "^1.0.0",
         "@actions/core": "^1.2.6",
-        "@actions/exec": "^1.0.0",
+        "@actions/exec": "^1.0.4",
+        "@actions/io": "^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"
     }

src/constants.ts

@@ -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}`;
+}

src/docker-object-model.ts

@@ -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);
+    }
+} 

src/githubClient.ts

@@ -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;
+}

src/input-parameters.ts

@@ -5,19 +5,24 @@ import * as core from '@actions/core';
 export let namespace: string = core.getInput('namespace');
 export const containers: string[] = core.getInput('images').split('\n');
 export const imagePullSecrets: string[] = core.getInput('imagepullsecrets').split('\n').filter(secret => secret.trim().length > 0);
-export const manifests = core.getInput('manifests').split(/[\n,;]+/).filter(manifest => manifest.trim().length > 0);
+export const manifests = core.getInput('manifests').split('\n');
 export const canaryPercentage: string = core.getInput('percentage');
 export const deploymentStrategy: string = core.getInput('strategy');
 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) {

src/kubectl-object-model.ts

@@ -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);
     }
 

src/run.ts

@@ -59,13 +59,7 @@ export async function run() {
         namespace = 'default';
     }
     let action = core.getInput('action');
-    let manifests = manifestsInput.split(/[\n,;]+/).filter(manifest => manifest.trim().length > 0);
-
-    if (manifests.length > 0) {
-        manifests = manifests.map(manifest => {
-            return manifest.trim();
-        });
-    }
+    let manifests = manifestsInput.split('\n');
 
     if (action === 'deploy') {
         let strategy = core.getInput('strategy');

src/utilities/httpClient.ts

@@ -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;
+}

src/utilities/strategy-helpers/deployment-helper.ts

@@ -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) => {

src/utilities/utility.ts

@@ -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;
+}