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

Supporting both comma and new line as delimiters for manifests (#133 )
* Supporting both comma and new line as delimiters for manifests * Removing whitespace from manifests * Comments * PR comments * Adding ; as delimiter * Added lib files * Changed to CRLF
2026-06-21 18:59:27 +08:00 · 2021-08-17 16:39:17 +05:30 · 2021-04-29 15:40:03 +05:30 · 2020-10-08 15:39:06 +05:30 · 2020-10-07 11:46:45 +05:30
22 changed files with 5085 additions and 12035 deletions
@@ -7,12 +7,10 @@ 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 { getWorkflowAnnotationKeyLabel, getWorkflowAnnotationsJson } from '../src/constants';
+import { workflowAnnotations } 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';
@@ -38,47 +36,13 @@ 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\',\'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"}}'
+    '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"}}'
 };

-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';
@@ -88,7 +52,6 @@ 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 () => {
@@ -203,6 +166,111 @@ 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;

@@ -250,11 +318,9 @@ 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();
@@ -280,11 +346,9 @@ 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();
@@ -292,18 +356,13 @@ test("deployment - deploy() - deploy force flag on", async () => {
    deploySpy.mockRestore();
 });

-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);
+test("deployment - deploy() - Annotate resources", async () => {
    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);
@@ -311,28 +370,21 @@ test("deployment - deploy() - Annotate & label 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.annotate).toHaveBeenNthCalledWith(1, 'namespace', 'default', annotationKeyValStr);
-    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"], annotationKeyValStr);
+    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"], workflowAnnotations, true);
    expect(kubeCtl.annotate).toBeCalledTimes(2);
-    expect(kubeCtl.labelFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp"],
-        [`workflowFriendlyName=workflow.yml`, `workflow=${getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW)}`]);
 });

-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);
+test("deployment - deploy() - Skip Annotate namespace", async () => {
+    process.env['GITHUB_REPOSITORY'] = 'test1Repo';
    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);
@@ -340,14 +392,14 @@ test("deployment - deploy() - Annotate & label resources for a new workflow", as
    kubeCtl.getNewReplicaSet = jest.fn().mockReturnValue("testpod-776cbc86f9");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue("");
-    kubeCtl.labelFiles = jest.fn();
+
+    const consoleOutputSpy = jest.spyOn(process.stdout, "write").mockImplementation();
+
    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
-    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)}`]);
+    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)
 });

 test("deployment - deploy() - Annotate resources failed", async () => {
@@ -369,24 +421,10 @@ 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);
 });
@@ -45,10 +45,6 @@ inputs:
    description: 'Deploy when a previous deployment already exists. If true then --force argument is added to the apply command.'
    required: false
    default: false
-  token:
-    description: 'Github token'
-    default: ${{ github.token }}
-    required: true

 branding:
  color: 'green' # optional, decorates the entry in the GitHub Marketplace
@@ -1,6 +1,6 @@
 'use strict';
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getWorkflowAnnotationKeyLabel = exports.getWorkflowAnnotationsJson = exports.workloadTypesWithRolloutStatus = exports.workloadTypes = exports.deploymentTypes = exports.ServiceTypes = exports.DiscoveryAndLoadBalancerResource = exports.KubernetesWorkload = void 0;
+exports.workflowAnnotations = exports.workloadTypesWithRolloutStatus = exports.workloadTypes = exports.deploymentTypes = exports.ServiceTypes = exports.DiscoveryAndLoadBalancerResource = exports.KubernetesWorkload = void 0;
 class KubernetesWorkload {
 }
 exports.KubernetesWorkload = KubernetesWorkload;
@@ -25,30 +25,15 @@ 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, 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;
+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`
+];
@@ -1,31 +0,0 @@
-"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;
@@ -1,35 +0,0 @@
-"use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.GitHubClient = void 0;
-const core = require("@actions/core");
-const httpClient_1 = require("./utilities/httpClient");
-class GitHubClient {
-    constructor(repository, token) {
-        this._repository = repository;
-        this._token = token;
-    }
-    getWorkflows() {
-        return __awaiter(this, void 0, void 0, function* () {
-            const getWorkflowFileNameUrl = `https://api.github.com/repos/${this._repository}/actions/workflows`;
-            const webRequest = new httpClient_1.WebRequest();
-            webRequest.method = "GET";
-            webRequest.uri = getWorkflowFileNameUrl;
-            webRequest.headers = {
-                Authorization: `Bearer ${this._token}`
-            };
-            core.debug(`Getting workflows for repo: ${this._repository}`);
-            const response = yield httpClient_1.sendRequest(webRequest);
-            return Promise.resolve(response);
-        });
-    }
-}
-exports.GitHubClient = GitHubClient;
@@ -1,25 +1,21 @@
 'use strict';
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.githubToken = exports.forceDeployment = exports.args = exports.baselineAndCanaryReplicas = exports.trafficSplitMethod = exports.deploymentStrategy = exports.canaryPercentage = exports.manifests = exports.imagePullSecrets = exports.containers = exports.namespace = void 0;
+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');
+exports.manifests = core.getInput('manifests').split(/[\n,;]+/).filter(manifest => manifest.trim().length > 0);
 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) {
@@ -37,24 +37,21 @@ class Kubectl {
        }
        return newReplicaSet;
    }
-    annotate(resourceType, resourceName, annotation) {
+    annotate(resourceType, resourceName, annotations, overwrite) {
        let args = ['annotate', resourceType, resourceName];
-        args.push(annotation);
-        args.push(`--overwrite`);
+        args = args.concat(annotations);
+        if (!!overwrite) {
+            args.push(`--overwrite`);
+        }
        return this.execute(args);
    }
-    annotateFiles(files, annotation) {
+    annotateFiles(files, annotations, overwrite) {
        let args = ['annotate'];
        args = args.concat(['-f', this.createInlineArray(files)]);
-        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`);
+        args = args.concat(annotations);
+        if (!!overwrite) {
+            args.push(`--overwrite`);
+        }
        return this.execute(args);
    }
    getAllPods() {
@@ -70,7 +70,12 @@ function run() {
            namespace = 'default';
        }
        let action = core.getInput('action');
-        let manifests = manifestsInput.split('\n');
+        let manifests = manifestsInput.split(/[\n,;]+/).filter(manifest => manifest.trim().length > 0);
+        if (manifests.length > 0) {
+            manifests = manifests.map(manifest => {
+                return manifest.trim();
+            });
+        }
        if (action === 'deploy') {
            let strategy = core.getInput('strategy');
            console.log("strategy: ", strategy);
@@ -1,111 +0,0 @@
-"use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.sleepFor = exports.sendRequest = exports.WebRequestOptions = exports.WebResponse = exports.WebRequest = exports.StatusCodes = void 0;
-// Taken from https://github.com/Azure/aks-set-context/blob/master/src/client.ts
-const util = require("util");
-const fs = require("fs");
-const httpClient = require("typed-rest-client/HttpClient");
-const core = require("@actions/core");
-var httpCallbackClient = new httpClient.HttpClient('GITHUB_RUNNER', null, {});
-var StatusCodes;
-(function (StatusCodes) {
-    StatusCodes[StatusCodes["OK"] = 200] = "OK";
-    StatusCodes[StatusCodes["CREATED"] = 201] = "CREATED";
-    StatusCodes[StatusCodes["ACCEPTED"] = 202] = "ACCEPTED";
-    StatusCodes[StatusCodes["UNAUTHORIZED"] = 401] = "UNAUTHORIZED";
-    StatusCodes[StatusCodes["NOT_FOUND"] = 404] = "NOT_FOUND";
-    StatusCodes[StatusCodes["INTERNAL_SERVER_ERROR"] = 500] = "INTERNAL_SERVER_ERROR";
-    StatusCodes[StatusCodes["SERVICE_UNAVAILABLE"] = 503] = "SERVICE_UNAVAILABLE";
-})(StatusCodes = exports.StatusCodes || (exports.StatusCodes = {}));
-class WebRequest {
-}
-exports.WebRequest = WebRequest;
-class WebResponse {
-}
-exports.WebResponse = WebResponse;
-class WebRequestOptions {
-}
-exports.WebRequestOptions = WebRequestOptions;
-function sendRequest(request, options) {
-    return __awaiter(this, void 0, void 0, function* () {
-        let i = 0;
-        let retryCount = options && options.retryCount ? options.retryCount : 5;
-        let retryIntervalInSeconds = options && options.retryIntervalInSeconds ? options.retryIntervalInSeconds : 2;
-        let retriableErrorCodes = options && options.retriableErrorCodes ? options.retriableErrorCodes : ["ETIMEDOUT", "ECONNRESET", "ENOTFOUND", "ESOCKETTIMEDOUT", "ECONNREFUSED", "EHOSTUNREACH", "EPIPE", "EA_AGAIN"];
-        let retriableStatusCodes = options && options.retriableStatusCodes ? options.retriableStatusCodes : [408, 409, 500, 502, 503, 504];
-        let timeToWait = retryIntervalInSeconds;
-        while (true) {
-            try {
-                if (request.body && typeof (request.body) !== 'string' && !request.body["readable"]) {
-                    request.body = fs.createReadStream(request.body["path"]);
-                }
-                let response = yield sendRequestInternal(request);
-                if (retriableStatusCodes.indexOf(response.statusCode) != -1 && ++i < retryCount) {
-                    core.debug(util.format("Encountered a retriable status code: %s. Message: '%s'.", response.statusCode, response.statusMessage));
-                    yield sleepFor(timeToWait);
-                    timeToWait = timeToWait * retryIntervalInSeconds + retryIntervalInSeconds;
-                    continue;
-                }
-                return response;
-            }
-            catch (error) {
-                if (retriableErrorCodes.indexOf(error.code) != -1 && ++i < retryCount) {
-                    core.debug(util.format("Encountered a retriable error:%s. Message: %s.", error.code, error.message));
-                    yield sleepFor(timeToWait);
-                    timeToWait = timeToWait * retryIntervalInSeconds + retryIntervalInSeconds;
-                }
-                else {
-                    if (error.code) {
-                        core.debug("error code =" + error.code);
-                    }
-                    throw error;
-                }
-            }
-        }
-    });
-}
-exports.sendRequest = sendRequest;
-function sleepFor(sleepDurationInSeconds) {
-    return new Promise((resolve, reject) => {
-        setTimeout(resolve, sleepDurationInSeconds * 1000);
-    });
-}
-exports.sleepFor = sleepFor;
-function sendRequestInternal(request) {
-    return __awaiter(this, void 0, void 0, function* () {
-        core.debug(util.format("[%s]%s", request.method, request.uri));
-        var response = yield httpCallbackClient.request(request.method, request.uri, request.body, request.headers);
-        return yield toWebResponse(response);
-    });
-}
-function toWebResponse(response) {
-    return __awaiter(this, void 0, void 0, function* () {
-        var res = new WebResponse();
-        if (response) {
-            res.statusCode = response.message.statusCode;
-            res.statusMessage = response.message.statusMessage;
-            res.headers = response.message.headers;
-            var body = yield response.readBody();
-            if (body) {
-                try {
-                    res.body = JSON.parse(body);
-                }
-                catch (error) {
-                    core.debug("Could not parse response: " + JSON.stringify(error));
-                    core.debug("Response: " + JSON.stringify(res.body));
-                    res.body = body;
-                }
-            }
-        }
-        return res;
-    });
-}
@@ -49,7 +49,7 @@ function deploy(kubectl, manifestFilePaths, deploymentStrategy) {
        catch (e) {
            core.debug("Unable to parse pods; Error: " + e);
        }
-        annotateAndLabelResources(deployedManifestFiles, kubectl, resourceTypes, allPods);
+        annotateResources(deployedManifestFiles, kubectl, resourceTypes, allPods);
    });
 }
 exports.deploy = deploy;
@@ -110,36 +110,18 @@ function checkManifestStability(kubectl, resources) {
        yield KubernetesManifestUtility.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, deploymentConfig);
-        labelResources(files, kubectl, annotationKeyLabel);
-    });
-}
-function annotateResources(files, kubectl, resourceTypes, allPods, annotationKey, workflowFilePath, deploymentConfig) {
+function annotateResources(files, kubectl, resourceTypes, allPods) {
    const annotateResults = [];
-    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));
+    annotateResults.push(utility_1.annotateNamespace(kubectl, TaskInputParameters.namespace));
+    annotateResults.push(kubectl.annotateFiles(files, models.workflowAnnotations, true));
    resourceTypes.forEach(resource => {
        if (resource.type.toUpperCase() !== models.KubernetesWorkload.pod.toUpperCase()) {
-            utility_1.annotateChildPods(kubectl, resource.type, resource.name, annotationKeyValStr, allPods)
+            utility_1.annotateChildPods(kubectl, resource.type, resource.name, allPods)
                .forEach(execResult => annotateResults.push(execResult));
        }
    });
    utility_1.checkForErrors(annotateResults, true);
 }
-function labelResources(files, kubectl, label) {
-    let workflowName = process.env.GITHUB_WORKFLOW;
-    workflowName = workflowName.startsWith('.github/workflows/') ?
-        workflowName.replace(".github/workflows/", "") : workflowName;
-    const labels = [`workflowFriendlyName=${workflowName}`, `workflow=${label}`];
-    utility_1.checkForErrors([kubectl.labelFiles(files, labels)], true);
-}
 function updateResourceObjects(filePaths, imagePullSecrets, containers) {
    const newObjectsList = [];
    const updateResourceObject = (inputObject) => {
@@ -1,221 +1,105 @@
-"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;
+"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;
@@ -8,16 +8,16 @@
        "test": "jest"
    },
    "dependencies": {
-        "@actions/core": "^1.2.6",
-        "@actions/exec": "^1.0.4",
-        "@actions/io": "^1.0.0",
        "@actions/tool-cache": "^1.0.0",
+        "@actions/io": "^1.0.0",
+        "@actions/core": "^1.2.6",
+        "@actions/exec": "^1.0.0",
        "js-yaml": "3.13.1"
    },
    "devDependencies": {
-        "@types/jest": "^25.2.2",
        "@types/node": "^12.0.10",
        "jest": "^25.0.0",
+        "@types/jest": "^25.2.2",
        "ts-jest": "^25.5.1",
        "typescript": "3.9.5"
    }
@@ -1,5 +1,4 @@
 'use strict';
-import { DeploymentConfig } from "./utilities/utility";

 export class KubernetesWorkload {
    public static pod: string = 'Pod';
@@ -26,30 +25,15 @@ 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, 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}`;
-}
+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`
+];
@@ -1,33 +0,0 @@
-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);
-    }
-} 
@@ -1,26 +0,0 @@
-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;
-}
@@ -5,24 +5,19 @@ 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');
+export const manifests = core.getInput('manifests').split(/[\n,;]+/).filter(manifest => manifest.trim().length > 0);
 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) {
@@ -50,26 +50,18 @@ export class Kubectl {
        return newReplicaSet;
    }

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

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

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

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

 import { deployPodCanary } from './pod-canary-deployment-helper';
 import { deploySMICanary } from './smi-canary-deployment-helper';
-import { checkForErrors, annotateChildPods, getWorkflowFilePath, getLastSuccessfulRunSha, getDeploymentConfig, DeploymentConfig } from "../utility";
+import { checkForErrors, annotateChildPods, annotateNamespace } 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);
    }

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

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

-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) {
+function annotateResources(files: string[], kubectl: Kubectl, resourceTypes: Resource[], allPods: any) {
    const annotateResults: IExecSyncResult[] = [];
-    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));
+    annotateResults.push(annotateNamespace(kubectl, TaskInputParameters.namespace));
+    annotateResults.push(kubectl.annotateFiles(files, models.workflowAnnotations, true));
    resourceTypes.forEach(resource => {
        if (resource.type.toUpperCase() !== models.KubernetesWorkload.pod.toUpperCase()) {
-            annotateChildPods(kubectl, resource.type, resource.name, annotationKeyValStr, allPods)
+            annotateChildPods(kubectl, resource.type, resource.name, allPods)
                .forEach(execResult => annotateResults.push(execResult));
        }
    });
    checkForErrors(annotateResults, true);
 }

-function labelResources(files: string[], kubectl: Kubectl, label: string) {
-    let workflowName = process.env.GITHUB_WORKFLOW;
-    workflowName = workflowName.startsWith('.github/workflows/') ?
-        workflowName.replace(".github/workflows/", "") : workflowName;
-    const labels = [`workflowFriendlyName=${workflowName}`, `workflow=${label}`];
-    checkForErrors([kubectl.labelFiles(files, labels)], true);
-}
-
 function updateResourceObjects(filePaths: string[], imagePullSecrets: string[], containers: string[]): string[] {
    const newObjectsList = [];
    const updateResourceObject = (inputObject) => {
@@ -2,17 +2,7 @@ import * as os from 'os';
 import * as core from '@actions/core';
 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;
-}
+import { workflowAnnotations } from '../constants';

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

-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[] {
+export function annotateChildPods(kubectl: Kubectl, resourceType: string, resourceName: string, allPods): IExecSyncResult[] {
    const commandExecutionResults = [];
    let owner = resourceName;
    if (resourceType.toLowerCase().indexOf('deployment') > -1) {
@@ -127,47 +63,37 @@ 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, annotationKeyValStr));
+                        commandExecutionResults.push(kubectl.annotate('pod', pod.metadata.name, workflowAnnotations, true));
                    }
                });
            }
        });
    }
+
    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));
+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;
    }

-    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);
+    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;
+            }
        }
+        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));
 }
@@ -179,40 +105,3 @@ export function getRandomInt(max: number) {
 export function getCurrentTime(): number {
    return new Date().getTime();
 }
-
-async function checkDockerPath() {
-    let dockerPath = await io.which('docker', false);
-    if (!dockerPath) {
-        throw new Error('Docker is not installed.');
-    }
-}
-
-async function getDockerfilePath(image: any): Promise<string> {
-    let imageConfig: any, imageInspectResult: string;
-    var dockerExec: DockerExec = new DockerExec('docker');
-    await checkDockerPath();
-    dockerExec.pull(image, [], true);
-    imageInspectResult = dockerExec.inspect(image, [], true);
-    imageConfig = JSON.parse(imageInspectResult)[0];
-    const DOCKERFILE_PATH_LABEL_KEY = 'dockerfile-path';
-    let pathValue: string = '';
-    if (imageConfig) {
-        if ((imageConfig.Config) && (imageConfig.Config.Labels) && (imageConfig.Config.Labels[DOCKERFILE_PATH_LABEL_KEY])) {
-            const pathLabel = imageConfig.Config.Labels[DOCKERFILE_PATH_LABEL_KEY];
-            pathValue = getNormalizedPath(pathLabel);
-        }
-    }
-    return pathValue;
-}
-
-export function isHttpUrl(url: string) {
-    const HTTP_REGEX = /^https?:\/\/.*$/;
-    return HTTP_REGEX.test(url);
-}
-
-export function getNormalizedPath(pathValue: string) {
-    if (!isHttpUrl(pathValue)) {  //if it is not an http url then convert to link from current repo and commit 
-        return `https://github.com/${process.env.GITHUB_REPOSITORY}/blob/${process.env.GITHUB_SHA}/${pathValue}`;
-    }
-    return pathValue;
-}
Author	SHA1	Message	Date
Koushik Dey	2f25f49dce	Sending a warning instead of throwing error when KUBECONFIG is missing. (#145 )	2021-08-17 16:39:17 +05:30
Ganesh S	bba73cd11a	Supporting both comma and new line as delimiters for manifests (#133 ) * Supporting both comma and new line as delimiters for manifests * Removing whitespace from manifests * Comments * PR comments * Adding ; as delimiter * Added lib files * Changed to CRLF	2021-04-29 15:40:03 +05:30
Koushik Dey	88c4504f60	Merge pull request #67 from Azure/users/koushdey/@v1-actions/core-1.2.6 Bump @actions/core from 1.1.0 to 1.2.6	2020-10-08 15:39:06 +05:30
Koushik Dey	53ae0f9d04	Bump @actions/core from 1.1.0 to 1.2.6	2020-10-07 11:46:45 +05:30