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

* Changed dockerfile, manifest, helmchart links and README

README.md

@@ -218,7 +218,7 @@ Following are the key capabilities of this action:
         service.yaml
         ingress-yml
     strategy: blue-green
-    strategy: ingress # should be the same as the value when action was deploy
+    route-method: ingress # should be the same as the value when action was deploy
     action: promote # substitute reject if you want to reject
 ```
 

__tests__/run.test.ts

@@ -38,7 +38,7 @@ const getAllPodsMock = {
 
 const getNamespaceMock = {
     'code': 0,
-    '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\',\'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\',\'provider\': \'GitHub\'}"}},"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 = {
@@ -293,7 +293,8 @@ test("deployment - deploy() - deploy force flag on", async () => {
 });
 
 test("deployment - deploy() - Annotate & label resources", async () => {
-    let annotationKeyValStr = getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW) + '=' + getWorkflowAnnotationsJson('currentCommit', '.github/workflows/workflow.yml');
+    var deploymentConfig: utility.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);
@@ -303,6 +304,7 @@ test("deployment - deploy() - Annotate & label resources", async () => {
     fileHelperMock.getTempDirectory = jest.fn().mockReturnValue("~/Deployment_testapp_currentTimestamp");
     fsMock.writeFileSync =jest.fn().mockReturnValue("");
     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("");
@@ -323,7 +325,8 @@ test("deployment - deploy() - Annotate & label resources", async () => {
 
 test("deployment - deploy() - Annotate & label resources for a new workflow", async () => {
     process.env.GITHUB_WORKFLOW = '.github/workflows/NewWorkflow.yml';
-    let annotationKeyValStr = getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW) + '=' + getWorkflowAnnotationsJson('NA', '.github/workflows/NewWorkflow.yml');
+    var deploymentConfig: utility.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);
@@ -333,6 +336,7 @@ test("deployment - deploy() - Annotate & label resources for a new workflow", as
     fileHelperMock.getTempDirectory = jest.fn().mockReturnValue("~/Deployment_testapp_currentTimestamp");
     fsMock.writeFileSync =jest.fn().mockReturnValue("");
     jest.spyOn(httpClient, 'sendRequest').mockImplementation(() => Promise.resolve(getWorkflowsUrlResponse));
+    jest.spyOn(utility, 'getDeploymentConfig').mockImplementation(()=> Promise.resolve(deploymentConfig));
 
     const kubeCtl: jest.Mocked<Kubectl> = new Kubectl("") as any;
     kubeCtl.apply = jest.fn().mockReturnValue("");

action.yml

@@ -42,9 +42,6 @@ inputs:
     description: 'Percentage of traffic redirect to canary deployment'
     required: false
     default: 0
-  args:
-    description: 'Arguments'
-    required: false
   action:
     description: 'deploy/promote/reject'
     required: true

lib/constants.js

@@ -25,21 +25,24 @@ ServiceTypes.clusterIP = 'ClusterIP';
 exports.deploymentTypes = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset'];
 exports.workloadTypes = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset', 'job', 'cronjob'];
 exports.workloadTypesWithRolloutStatus = ['deployment', 'daemonset', 'statefulset'];
-function getWorkflowAnnotationsJson(lastSuccessRunSha, workflowFilePath) {
-    return `{`
-        + `'run': '${process.env.GITHUB_RUN_ID}',`
-        + `'repository': '${process.env.GITHUB_REPOSITORY}',`
-        + `'workflow': '${process.env.GITHUB_WORKFLOW}',`
-        + `'workflowFileName': '${workflowFilePath.replace(".github/workflows/", "")}',`
-        + `'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}',`
-        + `'lastSuccessRunCommit': '${lastSuccessRunSha}',`
-        + `'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) {

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/input-parameters.js

@@ -1,6 +1,6 @@
 'use strict';
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.githubToken = exports.forceDeployment = exports.args = exports.baselineAndCanaryReplicas = exports.versionSwitchBuffer = exports.routeMethod = exports.trafficSplitMethod = exports.deploymentStrategy = exports.canaryPercentage = exports.manifests = exports.imagePullSecrets = exports.containers = exports.namespace = void 0;
+exports.githubToken = exports.forceDeployment = exports.baselineAndCanaryReplicas = exports.versionSwitchBuffer = exports.routeMethod = 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,7 +12,6 @@ exports.trafficSplitMethod = core.getInput('traffic-split-method');
 exports.routeMethod = core.getInput('route-method');
 exports.versionSwitchBuffer = core.getInput('version-switch-buffer');
 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) {

lib/run.js

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

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

@@ -134,15 +134,16 @@ function checkManifestStability(kubectl, resources) {
 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);
+        annotateResources(files, kubectl, resourceTypes, allPods, annotationKeyLabel, workflowFilePath, deploymentConfig);
         labelResources(files, kubectl, annotationKeyLabel);
     });
 }
-function annotateResources(files, kubectl, resourceTypes, allPods, annotationKey, workflowFilePath) {
+function annotateResources(files, kubectl, resourceTypes, allPods, annotationKey, workflowFilePath, deploymentConfig) {
     const annotateResults = [];
     const lastSuccessSha = utility_1.getLastSuccessfulRunSha(kubectl, TaskInputParameters.namespace, annotationKey);
-    let annotationKeyValStr = annotationKey + '=' + models.getWorkflowAnnotationsJson(lastSuccessSha, workflowFilePath);
+    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 => {

lib/utilities/strategy-helpers/ingress-blue-green-helper.js

@@ -71,7 +71,7 @@ exports.rejectBlueGreenIngress = rejectBlueGreenIngress;
 function routeBlueGreenIngress(kubectl, nextLabel, serviceNameMap, ingressEntityList) {
     let newObjectsList = [];
     if (!nextLabel) {
-        newObjectsList = newObjectsList.concat(ingressEntityList);
+        newObjectsList = ingressEntityList.filter(ingress => isIngressRouted(ingress, serviceNameMap));
     }
     else {
         ingressEntityList.forEach((inputObject) => {

lib/utilities/strategy-helpers/smi-blue-green-helper.js

@@ -174,9 +174,9 @@ exports.validateTrafficSplitsState = validateTrafficSplitsState;
 function cleanupSMI(kubectl, serviceEntityList) {
     const deleteList = [];
     serviceEntityList.forEach((serviceObject) => {
+        deleteList.push({ name: blue_green_helper_1.getBlueGreenResourceName(serviceObject.metadata.name, TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX), kind: TRAFFIC_SPLIT_OBJECT });
         deleteList.push({ name: blue_green_helper_1.getBlueGreenResourceName(serviceObject.metadata.name, blue_green_helper_2.GREEN_SUFFIX), kind: serviceObject.kind });
         deleteList.push({ name: blue_green_helper_1.getBlueGreenResourceName(serviceObject.metadata.name, blue_green_helper_2.STABLE_SUFFIX), kind: serviceObject.kind });
-        deleteList.push({ name: blue_green_helper_1.getBlueGreenResourceName(serviceObject.metadata.name, TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX), kind: TRAFFIC_SPLIT_OBJECT });
     });
     // deleting all objects
     blue_green_helper_1.deleteObjects(kubectl, deleteList);

lib/utilities/utility.js

@@ -9,11 +9,14 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
     });
 };
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getCurrentTime = exports.getRandomInt = exports.sleep = exports.annotateChildPods = exports.getWorkflowFilePath = exports.getLastSuccessfulRunSha = exports.checkForErrors = exports.isEqual = exports.getExecutableExtension = void 0;
+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';
@@ -138,6 +141,34 @@ function annotateChildPods(kubectl, resourceType, resourceName, annotationKeyVal
     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));
 }
@@ -150,3 +181,42 @@ 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;

src/constants.ts

@@ -1,4 +1,5 @@
 'use strict';
+import { DeploymentConfig } from "./utilities/utility";
 
 export class KubernetesWorkload {
     public static pod: string = 'Pod';
@@ -25,21 +26,25 @@ 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 function getWorkflowAnnotationsJson(lastSuccessRunSha: string, workflowFilePath: string): string {
-    return `{`
-        + `'run': '${process.env.GITHUB_RUN_ID}',`
-        + `'repository': '${process.env.GITHUB_REPOSITORY}',`
-        + `'workflow': '${process.env.GITHUB_WORKFLOW}',`
-        + `'workflowFileName': '${workflowFilePath.replace(".github/workflows/", "")}',`
-        + `'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}',`
-        + `'lastSuccessRunCommit': '${lastSuccessRunSha}',`
-        + `'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 {

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/input-parameters.ts

@@ -12,7 +12,6 @@ export const trafficSplitMethod: string = core.getInput('traffic-split-method');
 export const routeMethod: string = core.getInput('route-method');
 export const versionSwitchBuffer: string = core.getInput('version-switch-buffer');
 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");
 

src/run.ts

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

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, getWorkflowFilePath, getLastSuccessfulRunSha } from "../utility";
+import { checkForErrors, annotateChildPods, getWorkflowFilePath, getLastSuccessfulRunSha, getDeploymentConfig, DeploymentConfig } from "../utility";
 import { isBlueGreenDeploymentStrategy, isIngressRoute, isSMIRoute, routeBlueGreen } from './blue-green-helper';
 import { deployBlueGreenService } from './service-blue-green-helper';
 import { deployBlueGreenIngress } from './ingress-blue-green-helper';
@@ -45,7 +45,7 @@ export async function deploy(kubectl: Kubectl, manifestFilePaths: string[], depl
     ingressResources.forEach(ingressResource => {
         kubectl.getResource(KubernetesConstants.DiscoveryAndLoadBalancerResource.ingress, ingressResource.name);
     });
-    
+
     // annotate resources
     let allPods: any;
     try {
@@ -79,7 +79,7 @@ function deployManifests(files: string[], kubectl: Kubectl, isCanaryDeploymentSt
         result = canaryDeploymentOutput.result;
         files = canaryDeploymentOutput.newFilePaths;
     } else if (isBlueGreenDeploymentStrategy) {
-        let blueGreenDeploymentOutput: any; 
+        let blueGreenDeploymentOutput: any;
         if (isIngressRoute()) {
             blueGreenDeploymentOutput = deployBlueGreenIngress(kubectl, files);
         } else if (isSMIRoute()) {
@@ -130,15 +130,16 @@ async function checkManifestStability(kubectl: Kubectl, resources: Resource[]):
 
 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);
+    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) {
+function annotateResources(files: string[], kubectl: Kubectl, resourceTypes: Resource[], allPods: any, annotationKey: string, workflowFilePath: string, deploymentConfig: DeploymentConfig) {
     const annotateResults: IExecSyncResult[] = [];
     const lastSuccessSha = getLastSuccessfulRunSha(kubectl, TaskInputParameters.namespace, annotationKey);
-    let annotationKeyValStr = annotationKey + '=' + models.getWorkflowAnnotationsJson(lastSuccessSha, workflowFilePath);
+    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 => {

src/utilities/strategy-helpers/ingress-blue-green-helper.ts

@@ -68,7 +68,7 @@ export async function rejectBlueGreenIngress(kubectl: Kubectl, filePaths: string
 export function routeBlueGreenIngress(kubectl: Kubectl, nextLabel: string, serviceNameMap: Map<string, string>, ingressEntityList: any[]) { 
     let newObjectsList = [];
     if (!nextLabel) {
-        newObjectsList = newObjectsList.concat(ingressEntityList);
+        newObjectsList = ingressEntityList.filter(ingress => isIngressRouted(ingress, serviceNameMap));
     } else {
         ingressEntityList.forEach((inputObject) => {
             if (isIngressRouted(inputObject, serviceNameMap)) {

src/utilities/strategy-helpers/smi-blue-green-helper.ts

@@ -177,9 +177,9 @@ export function validateTrafficSplitsState(kubectl: Kubectl, serviceEntityList:
 export function cleanupSMI(kubectl: Kubectl, serviceEntityList: any[]) { 
     const deleteList = [];
     serviceEntityList.forEach((serviceObject) => {
+        deleteList.push({ name: getBlueGreenResourceName(serviceObject.metadata.name, TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX), kind: TRAFFIC_SPLIT_OBJECT });
         deleteList.push({name: getBlueGreenResourceName(serviceObject.metadata.name, GREEN_SUFFIX), kind: serviceObject.kind});
         deleteList.push({name: getBlueGreenResourceName(serviceObject.metadata.name, STABLE_SUFFIX), kind: serviceObject.kind});
-        deleteList.push({name: getBlueGreenResourceName(serviceObject.metadata.name, TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX), kind: TRAFFIC_SPLIT_OBJECT});
     });
 
     // deleting all objects

src/utilities/utility.ts

@@ -4,6 +4,15 @@ import { IExecSyncResult } from './tool-runner';
 import { Kubectl } from '../kubectl-object-model';
 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/)) {
@@ -129,6 +138,41 @@ export function annotateChildPods(kubectl: Kubectl, resourceType: string, resour
     return commandExecutionResults;
 }
 
+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)
+        );
+    }
+
+    const imageNames: string[] = 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);
+        }
+    }
+
+    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));
 }
@@ -140,3 +184,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): boolean {
+    const HTTP_REGEX = /^https?:\/\/.*$/;
+    return HTTP_REGEX.test(url);
+}
+
+export function getNormalizedPath(pathValue: string): 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;
+}