fix smi weight bug

Sending a warning instead of throwing error when KUBECONFIG is missing. (#144 )
Create defaultLabels.yml (#140 )
2026-06-21 10:39:26 +08:00 · 2021-11-29 14:00:40 -05:00 · 2021-08-17 16:39:38 +05:30 · 2021-06-27 08:54:24 +05:30 · 2021-06-18 11:50:08 +05:30 · 2021-06-15 22:57:14 +05:30
47 changed files with 5523 additions and 3971 deletions
@@ -0,0 +1,20 @@
+---
+name: Blue Green Bug Bash
+about: Issues found in blue-green strategy bug bash
+title: "[Blue-Green Bug Bash] "
+labels: 'blue-green-bug-bash'
+assignees: ajinkya599
+
+---
+
+Repro steps:
+- Add steps to repro the issue here
+- 
+
+Current behaviour:
+- What is the current behaviour?
+- 
+
+Expected behaviour:
+- What is the expected behaviour?
+-
@@ -4,14 +4,14 @@ repository=$3
 prNumber=$4
 frombranch=$5
 tobranch=$6
-
+patUser=$7
 getPayLoad() {
    cat <<EOF
 {
    "event_type": "K8sDeployActionPR", 
    "client_payload": 
    {
-        "action": "CreateSecret", 
+        "action": "K8sDeploy", 
        "commit": "$commit", 
        "repository": "$repository", 
        "prNumber": "$prNumber", 
@@ -22,11 +22,11 @@ getPayLoad() {
 EOF
 }

-response=$(curl -X POST -H "Authorization: token $token" https://api.github.com/repos/Azure/azure-actions-integration-tests/dispatches --data "$(getPayLoad)")
+response=$(curl -u $patUser:$token -X POST https://api.github.com/repos/Azure/azure-actions-integration-tests/dispatches --data "$(getPayLoad)")

 if [ "$response" == "" ]; then
    echo "Integration tests triggered successfully"
 else
    echo "Triggering integration tests failed with: '$response'"
    exit 1
-fi
+fi
@@ -0,0 +1,36 @@
+name: setting-default-labels
+
+# Controls when the action will run. 
+on:
+  schedule:
+  - cron: "0 0/3 * * *"
+
+# A workflow run is made up of one or more jobs that can run sequentially or in parallel
+jobs:
+  build:
+    # The type of runner that the job will run on
+    runs-on: ubuntu-latest
+
+    # Steps represent a sequence of tasks that will be executed as part of the job
+    steps:
+          
+      - uses: actions/stale@v3
+        name: Setting issue as idle
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+          stale-issue-message: 'This issue is idle because it has been open for 14 days with no activity.'
+          stale-issue-label: 'idle'
+          days-before-stale: 14
+          days-before-close: -1
+          operations-per-run: 100
+          exempt-issue-labels: 'backlog'
+          
+      - uses: actions/stale@v3
+        name: Setting PR as idle
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+          stale-pr-message: 'This PR is idle because it has been open for 14 days with no activity.'
+          stale-pr-label: 'idle'
+          days-before-stale: 14
+          days-before-close: -1
+          operations-per-run: 100
@@ -1,12 +1,8 @@
 name: "Trigger Integration tests"
 on:
-  # push:
-  #   branches:
-  #     - master
-  #     - 'releases/*'
  pull_request:
    branches:
-      - master
+      - main
      - 'releases/*'
 jobs: 
    trigger-integration-tests:
@@ -20,4 +16,4 @@ jobs:
            
        - name: Trigger Test run
          run: |
-            bash ./IntegrationTests/.github/workflows/TriggerIntegrationTests.sh ${{ secrets.L2_REPO_TOKEN }} ${{ github.event.pull_request.head.sha }} ${{ github.repository }} ${{ github.event.pull_request.number }} ${{ github.event.pull_request.head.ref }} ${{ github.event.pull_request.base.ref }}
+            bash ./IntegrationTests/.github/workflows/TriggerIntegrationTests.sh ${{ secrets.L2_REPO_TOKEN }} ${{ github.event.pull_request.head.sha }} ${{ github.repository }} ${{ github.event.pull_request.number }} ${{ github.event.pull_request.head.ref }} ${{ github.event.pull_request.base.ref }} ${{ secrets.L2_REPO_USER }}
@@ -1,4 +1,4 @@
-name: "build-test"
+name: "Run unit tests."
 on: # rebuild any PRs and main branch changes
  pull_request:
    branches:
@@ -16,5 +16,4 @@ jobs:
    - uses: actions/checkout@v1
    - run: |
        npm install
-        npm build
        npm test
@@ -1,329 +1,2 @@
-## Ignore Visual Studio temporary files, build results, and
-## files generated by popular Visual Studio add-ons.
-##
-## Get latest from https://github.com/github/gitignore/blob/master/VisualStudio.gitignore
-
-# User-specific files
-*.suo
-*.user
-*.userosscache
-*.sln.docstates
-
-# User-specific files (MonoDevelop/Xamarin Studio)
-*.userprefs
-
-# Build results
-[Dd]ebug/
-[Dd]ebugPublic/
-[Rr]elease/
-[Rr]eleases/
-x64/
-x86/
-bld/
-[Bb]in/
-[Oo]bj/
-[Ll]og/
-
-# Visual Studio 2015/2017 cache/options directory
-.vs/
-# Uncomment if you have tasks that create the project's static files in wwwroot
-#wwwroot/
-
-# Visual Studio 2017 auto generated files
-Generated\ Files/
-
-# MSTest test Results
-[Tt]est[Rr]esult*/
-[Bb]uild[Ll]og.*
-
-# NUNIT
-*.VisualState.xml
-TestResult.xml
-
-# Build Results of an ATL Project
-[Dd]ebugPS/
-[Rr]eleasePS/
-dlldata.c
-
-# Benchmark Results
-BenchmarkDotNet.Artifacts/
-
-# .NET Core
-project.lock.json
-project.fragment.lock.json
-artifacts/
-**/Properties/launchSettings.json
-
-# StyleCop
-StyleCopReport.xml
-
-# Files built by Visual Studio
-*_i.c
-*_p.c
-*_i.h
-*.ilk
-*.meta
-*.obj
-*.iobj
-*.pch
-*.pdb
-*.ipdb
-*.pgc
-*.pgd
-*.rsp
-*.sbr
-*.tlb
-*.tli
-*.tlh
-*.tmp
-*.tmp_proj
-*.log
-*.vspscc
-*.vssscc
-.builds
-*.pidb
-*.svclog
-*.scc
-
-# Chutzpah Test files
-_Chutzpah*
-
-# Visual C++ cache files
-ipch/
-*.aps
-*.ncb
-*.opendb
-*.opensdf
-*.sdf
-*.cachefile
-*.VC.db
-*.VC.VC.opendb
-
-# Visual Studio profiler
-*.psess
-*.vsp
-*.vspx
-*.sap
-
-# Visual Studio Trace Files
-*.e2e
-
-# TFS 2012 Local Workspace
-$tf/
-
-# Guidance Automation Toolkit
-*.gpState
-
-# ReSharper is a .NET coding add-in
-_ReSharper*/
-*.[Rr]e[Ss]harper
-*.DotSettings.user
-
-# JustCode is a .NET coding add-in
-.JustCode
-
-# TeamCity is a build add-in
-_TeamCity*
-
-# DotCover is a Code Coverage Tool
-*.dotCover
-
-# AxoCover is a Code Coverage Tool
-.axoCover/*
-!.axoCover/settings.json
-
-# Visual Studio code coverage results
-*.coverage
-*.coveragexml
-
-# NCrunch
-_NCrunch_*
-.*crunch*.local.xml
-nCrunchTemp_*
-
-# MightyMoose
-*.mm.*
-AutoTest.Net/
-
-# Web workbench (sass)
-.sass-cache/
-
-# Installshield output folder
-[Ee]xpress/
-
-# DocProject is a documentation generator add-in
-DocProject/buildhelp/
-DocProject/Help/*.HxT
-DocProject/Help/*.HxC
-DocProject/Help/*.hhc
-DocProject/Help/*.hhk
-DocProject/Help/*.hhp
-DocProject/Help/Html2
-DocProject/Help/html
-
-# Click-Once directory
-publish/
-
-# Publish Web Output
-*.[Pp]ublish.xml
-*.azurePubxml
-# Note: Comment the next line if you want to checkin your web deploy settings,
-# but database connection strings (with potential passwords) will be unencrypted
-*.pubxml
-*.publishproj
-
-# Microsoft Azure Web App publish settings. Comment the next line if you want to
-# checkin your Azure Web App publish settings, but sensitive information contained
-# in these scripts will be unencrypted
-PublishScripts/
-
-# NuGet Packages
-*.nupkg
-# The packages folder can be ignored because of Package Restore
-**/[Pp]ackages/*
-# except build/, which is used as an MSBuild target.
-!**/[Pp]ackages/build/
-# Uncomment if necessary however generally it will be regenerated when needed
-#!**/[Pp]ackages/repositories.config
-# NuGet v3's project.json files produces more ignorable files
-*.nuget.props
-*.nuget.targets
-
-# Microsoft Azure Build Output
-csx/
-*.build.csdef
-
-# Microsoft Azure Emulator
-ecf/
-rcf/
-
-# Windows Store app package directories and files
-AppPackages/
-BundleArtifacts/
-Package.StoreAssociation.xml
-_pkginfo.txt
-*.appx
-
-# Visual Studio cache files
-# files ending in .cache can be ignored
-*.[Cc]ache
-# but keep track of directories ending in .cache
-!*.[Cc]ache/
-
-# Others
-ClientBin/
-~$*
-*~
-*.dbmdl
-*.dbproj.schemaview
-*.jfm
-*.pfx
-*.publishsettings
-orleans.codegen.cs
-
-# Including strong name files can present a security risk 
-# (https://github.com/github/gitignore/pull/2483#issue-259490424)
-#*.snk
-
-# Since there are multiple workflows, uncomment next line to ignore bower_components
-# (https://github.com/github/gitignore/pull/1529#issuecomment-104372622)
-#bower_components/
-
-# RIA/Silverlight projects
-Generated_Code/
-
-# Backup & report files from converting an old project file
-# to a newer Visual Studio version. Backup files are not needed,
-# because we have git ;-)
-_UpgradeReport_Files/
-Backup*/
-UpgradeLog*.XML
-UpgradeLog*.htm
-ServiceFabricBackup/
-*.rptproj.bak
-
-# SQL Server files
-*.mdf
-*.ldf
-*.ndf
-
-# Business Intelligence projects
-*.rdl.data
-*.bim.layout
-*.bim_*.settings
-*.rptproj.rsuser
-
-# Microsoft Fakes
-FakesAssemblies/
-
-# GhostDoc plugin setting file
-*.GhostDoc.xml
-
-# Node.js Tools for Visual Studio
-.ntvs_analysis.dat
-
-# Visual Studio 6 build log
-*.plg
-
-# Visual Studio 6 workspace options file
-*.opt
-
-# Visual Studio 6 auto-generated workspace file (contains which files were open etc.)
-*.vbw
-
-# Visual Studio LightSwitch build output
-**/*.HTMLClient/GeneratedArtifacts
-**/*.DesktopClient/GeneratedArtifacts
-**/*.DesktopClient/ModelManifest.xml
-**/*.Server/GeneratedArtifacts
-**/*.Server/ModelManifest.xml
-_Pvt_Extensions
-
-# Paket dependency manager
-.paket/paket.exe
-paket-files/
-
-# FAKE - F# Make
-.fake/
-
-# JetBrains Rider
-.idea/
-*.sln.iml
-
-# CodeRush
-.cr/
-
-# Python Tools for Visual Studio (PTVS)
-__pycache__/
-*.pyc
-
-# Cake - Uncomment if you are using it
-# tools/**
-# !tools/packages.config
-
-# Tabs Studio
-*.tss
-
-# Telerik's JustMock configuration file
-*.jmconfig
-
-# BizTalk build output
-*.btp.cs
-*.btm.cs
-*.odx.cs
-*.xsd.cs
-
-# OpenCover UI analysis results
-OpenCover/
-
-# Azure Stream Analytics local run output 
-ASALocalRun/
-
-# MSBuild Binary and Structured Log
-*.binlog
-
-# NVidia Nsight GPU debugger configuration file
-*.nvuser
-
-# MFractors (Xamarin productivity tool) working folder 
-.mfractor/
+node_modules
+lib
@@ -103,7 +103,7 @@ Following are the key capabilities of this action:
 ### Basic deployment (without any deployment strategy)

 ```yaml
- uses: Azure/k8s-deploy@v1
+- uses: Azure/k8s-deploy@v1.4
  with:
    namespace: 'myapp'
    manifests: |
@@ -119,7 +119,7 @@ Following are the key capabilities of this action:
 ### Deployment Strategies - Canary deployment without service mesh

 ```yaml
- uses: Azure/k8s-deploy@v1
+- uses: Azure/k8s-deploy@v1.4
  with:
    namespace: 'myapp'
    images: 'contoso.azurecr.io/myapp:${{ event.run_id }}'
@@ -136,7 +136,7 @@ Following are the key capabilities of this action:
 ### To promote/reject the canary created by the above snippet, the following YAML snippet could be used:

 ```yaml
- uses: Azure/k8s-deploy@v1
+- uses: Azure/k8s-deploy@v1.4
  with:
    namespace: 'myapp'
    images: 'contoso.azurecr.io/myapp:${{ event.run_id }}'
@@ -153,7 +153,7 @@ Following are the key capabilities of this action:
 ### Deployment Strategies - Canary deployment based on Service Mesh Interface

 ```yaml
- uses: Azure/k8s-deploy@v1
+- uses: Azure/k8s-deploy@v1.4
  with:
    namespace: 'myapp'
    images: 'contoso.azurecr.io/myapp:${{ event.run_id }}'
@@ -170,7 +170,7 @@ Following are the key capabilities of this action:
 ```
 ### To promote/reject the canary created by the above snippet, the following YAML snippet could be used:
 ```yaml
- uses: Azure/k8s-deploy@v1
+- uses: Azure/k8s-deploy@v1.4
  with:
    namespace: 'myapp'
    images: 'contoso.azurecr.io/myapp:${{ event.run_id }} '
@@ -187,7 +187,7 @@ Following are the key capabilities of this action:
 ### Deployment Strategies - Blue-Green deployment with different route methods

 ```yaml
- uses: Azure/k8s-deploy@v1
+- uses: Azure/k8s-deploy@v1.4
  with:
    namespace: 'myapp'
    images: 'contoso.azurecr.io/myapp:${{ event.run_id }}'
@@ -206,7 +206,7 @@ Following are the key capabilities of this action:
 ### **To promote/reject the green workload created by the above snippet, the following YAML snippet could be used:**

 ```yaml
- uses: Azure/k8s-deploy@v1
+- uses: Azure/k8s-deploy@v1.4
  with:
    namespace: 'myapp'
    images: 'contoso.azurecr.io/myapp:${{ event.run_id }}'
@@ -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
 ```

@@ -261,7 +261,7 @@ jobs:
        container-registry-password: ${{ secrets.REGISTRY_PASSWORD }}
        secret-name: demo-k8s-secret

-    - uses: Azure/k8s-deploy@v1
+    - uses: Azure/k8s-deploy@v1.4
      with:
        manifests: |
          manifests/deployment.yml
@@ -304,7 +304,7 @@ jobs:
        container-registry-password: ${{ secrets.REGISTRY_PASSWORD }}
        secret-name: demo-k8s-secret

-    - uses: Azure/k8s-deploy@v1
+    - uses: Azure/k8s-deploy@v1.4
      with:
        manifests: |
          manifests/deployment.yml
@@ -314,6 +314,138 @@ jobs:
        imagepullsecrets: |
          demo-k8s-secret
 ```
+## Sample workflows for new traceability fields support 
+
+ - Environment variable `HELM_CHART_PATHS` is a list of helmchart files expected by k8s-deploy - it will be populated automatically if you are using `k8s-bake` to generate the manifests.
+ - Use script to build image and add `dockerfile-path` label to it. 
+   The value expected is the link to the dockerfile : `https://github.com/${{github.repo}}/blob/${{github.sha}}/Dockerfile`
+   If your dockerfile is in the same repo and branch where the workflow is run, it can be a relative path and it will be converted to a link for traceability.
+ - Run docker login action for each image registry - in case image build and image deploy are 2 distinct jobs in the same or separate workflows.
+
+### End to end workflow for building and deploying container images 
+
+```yaml
+on: [push]
+env:
+  NAMESPACE: demo-ns2
+
+jobs:
+  build-and-deploy:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@master
+    
+    - uses: Azure/docker-login@v1
+      with:
+        login-server: contoso.azurecr.io
+        username: ${{ secrets.REGISTRY_USERNAME }}
+        password: ${{ secrets.REGISTRY_PASSWORD }}
+    
+    - run: |
+        docker build . -t contoso.azurecr.io/k8sdemo:${{ github.sha }} --label dockerfile-path=./Dockerfile
+        docker push contoso.azurecr.io/k8sdemo:${{ github.sha }}
+      
+    # Set the target AKS cluster.
+    - uses: Azure/aks-set-context@v1
+      with:
+        creds: '${{ secrets.AZURE_CREDENTIALS }}'
+        cluster-name: contoso
+        resource-group: contoso-rg
+        
+    - uses: Azure/k8s-create-secret@v1
+      with:
+        container-registry-url: contoso.azurecr.io
+        container-registry-username: ${{ secrets.REGISTRY_USERNAME }}
+        container-registry-password: ${{ secrets.REGISTRY_PASSWORD }}
+        secret-name: demo-k8s-secret
+
+    - uses: Azure/k8s-deploy@v1.2
+      with:
+        manifests: |
+          manifests/deployment.yml
+          manifests/service.yml
+        images: |
+          contoso.azurecr.io/k8sdemo:${{ github.sha }}
+        imagepullsecrets: |
+          demo-k8s-secret
+```
+
+### CI workflow to build image and add `dockerfile-path` label to it. This image can then be used in another CD workflow.
+
+```yaml
+on: [push]
+env:
+  NAMESPACE: demo-ns2
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@master
+    
+    - uses: Azure/docker-login@v1
+      with:
+        login-server: contoso.azurecr.io
+        username: ${{ secrets.REGISTRY_USERNAME }}
+        password: ${{ secrets.REGISTRY_PASSWORD }}
+    
+    - run: |
+        docker build . -t contoso.azurecr.io/k8sdemo:${{ github.sha }} --label dockerfile-path=https://github.com/${{github.repo}}/blob/${{github.sha}}/Dockerfile
+        docker push contoso.azurecr.io/k8sdemo:${{ github.sha }}
+ ```     
+
+### CD workflow using bake action to get manifests deploying to a Kubernetes cluster 
+
+```yaml
+on: [push]
+env:
+  NAMESPACE: demo-ns2
+
+jobs:
+  deploy:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@master
+
+    - uses: Azure/docker-login@v1
+      with:
+        login-server: contoso.azurecr.io
+        username: ${{ secrets.REGISTRY_USERNAME }}
+        password: ${{ secrets.REGISTRY_PASSWORD }}
+      
+    # Set the target AKS cluster.
+    - uses: Azure/aks-set-context@v1
+      with:
+        creds: '${{ secrets.AZURE_CREDENTIALS }}'
+        cluster-name: contoso
+        resource-group: contoso-rg
+        
+    - uses: Azure/k8s-create-secret@v1
+      with:
+        namespace: ${{ env.NAMESPACE  }}
+        container-registry-url: contoso.azurecr.io
+        container-registry-username: ${{ secrets.REGISTRY_USERNAME }}
+        container-registry-password: ${{ secrets.REGISTRY_PASSWORD }}
+        secret-name: demo-k8s-secret
+
+    - uses: azure/k8s-bake@v1
+      with:
+        renderEngine: 'helm'
+        helmChart: './aks-helloworld/'
+        overrideFiles: './aks-helloworld/values-override.yaml'
+        overrides: |     
+          replicas:2
+        helm-version: 'latest' 
+      id: bake
+
+    - uses: Azure/k8s-deploy@v1.2
+      with:
+        manifests: ${{ steps.bake.outputs.manifestsBundle }}
+        images: |
+          contoso.azurecr.io/k8sdemo:${{ github.sha }}
+        imagepullsecrets: |
+          demo-k8s-secret
+```

 # Contributing

@@ -327,4 +459,4 @@ provided by the bot. You will only need to do this once across all repos using o

 This project has adopted the [Microsoft Open Source Code of Conduct](https://opensource.microsoft.com/codeofconduct/).
 For more information see the [Code of Conduct FAQ](https://opensource.microsoft.com/codeofconduct/faq/) or
-contact [opencode@microsoft.com](mailto:opencode@microsoft.com) with any additional questions or comments.
+contact [opencode@microsoft.com](mailto:opencode@microsoft.com) with any additional questions or comments.
@@ -6,11 +6,14 @@ import * as deployment from '../src/utilities/strategy-helpers/deployment-helper
 import * as fs from 'fs';
 import * as io from '@actions/io';
 import * as toolCache from '@actions/tool-cache';
+import * as util from 'util';
 import * as fileHelper from '../src/utilities/files-helper';
-import { workflowAnnotations } from '../src/constants';
+import { getWorkflowAnnotationKeyLabel, getWorkflowAnnotationsJson } from '../src/constants';
 import * as inputParam from '../src/input-parameters';

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

 import { getkubectlDownloadURL } from "../src/utilities/kubectl-util";
 import { mocked } from 'ts-jest/utils';
@@ -21,6 +24,7 @@ const os = require("os");
 const coreMock = mocked(core, true);
 const ioMock = mocked(io, true);
 const inputParamMock = mocked(inputParam, true);
+const osMock = mocked(os, true);

 const toolCacheMock = mocked(toolCache, true);
 const fileUtility = mocked(fs, true);
@@ -36,14 +40,48 @@ const getAllPodsMock = {

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

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

 beforeEach(() => {
    deploymentYaml = fs.readFileSync(path.join(__dirname, 'manifests', 'deployment.yml'), 'utf8');
- 
+    jest.spyOn(Date, 'now').mockImplementation(() => 1234561234567);
+
    process.env["KUBECONFIG"] = 'kubeConfig';
    process.env['GITHUB_RUN_ID'] = '12345';
    process.env['GITHUB_WORKFLOW'] = '.github/workflows/workflow.yml';
@@ -52,12 +90,18 @@ 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 () => {
+test.each([
+    ['arm', 'arm'],
+    ['arm64', 'arm64'],
+    ['x64', 'amd64']
+])("setKubectlPath() - install a particular version on %s", async (osArch, kubectlArch) => {
    const kubectlVersion = 'v1.18.0'
    //Mocks
    coreMock.getInput = jest.fn().mockReturnValue(kubectlVersion);
+    osMock.arch = jest.fn().mockReturnValue(osArch);
    toolCacheMock.find = jest.fn().mockReturnValue(undefined);
    toolCacheMock.downloadTool = jest.fn().mockReturnValue('downloadpath');
    toolCacheMock.cacheFile = jest.fn().mockReturnValue('cachepath');
@@ -66,7 +110,7 @@ test("setKubectlPath() - install a particular version", async () => {
    //Invoke and assert
    await expect(action.run()).resolves.not.toThrow();
    expect(toolCacheMock.find).toBeCalledWith('kubectl', kubectlVersion);
-    expect(toolCacheMock.downloadTool).toBeCalledWith(getkubectlDownloadURL(kubectlVersion));
+    expect(toolCacheMock.downloadTool).toBeCalledWith(getkubectlDownloadURL(kubectlVersion, kubectlArch));
 });

 test("setKubectlPath() - install a latest version", async () => {
@@ -166,6 +210,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;

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

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

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

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

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

-test("deployment - deploy() - Annotate resources", async () => {
+test("deployment - deploy() - Annotate & label resources", async () => {
+    let deploymentConfig: 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);
    KubernetesObjectUtilityMock.getResources = jest.fn().mockReturnValue(resources);
    const fileHelperMock = mocked(fileHelper, true);
    const fsMock = (mocked(fs, true));
-    fileHelperMock.getTempDirectory = jest.fn().mockReturnValue("Local/Temp/");
-    fsMock.writeFileSync =jest.fn().mockReturnValue("");
+    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("");
    kubeCtl.getResource = jest.fn().mockReturnValue(getNamespaceMock);
@@ -267,23 +425,31 @@ test("deployment - deploy() - Annotate resources", async () => {
    kubeCtl.getNewReplicaSet = jest.fn().mockReturnValue("testpod-776cbc86f9");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue("");
-
+    kubeCtl.labelFiles = jest.fn();
    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
-    expect(kubeCtl.annotateFiles).toBeCalledWith(["Local/Temp/deployment.yaml"], workflowAnnotations, true);
+    expect(kubeCtl.annotate).toHaveBeenNthCalledWith(1, 'namespace', 'default', annotationKeyValStr);
+    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp/deployment.yaml"], annotationKeyValStr);
    expect(kubeCtl.annotate).toBeCalledTimes(2);
+    expect(kubeCtl.labelFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp/deployment.yaml"],
+        [`workflowFriendlyName=workflow.yml`, `workflow=${getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW)}`]);
 });

-test("deployment - deploy() - Skip Annotate namespace", async () => {
-    process.env['GITHUB_REPOSITORY'] = 'test1Repo';
+test("deployment - deploy() - Annotate & label resources for a new workflow", async () => {
+    process.env.GITHUB_WORKFLOW = '.github/workflows/New Workflow.yml';
+    let deploymentConfig: utility.DeploymentConfig = { manifestFilePaths: ['manifests/deployment.yaml'], helmChartFilePaths: [], dockerfilePaths: {} }
+    let annotationKeyValStr = getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW) + '=' + getWorkflowAnnotationsJson('NA', '.github/workflows/New Workflow.yml', deploymentConfig);
    const KubernetesManifestUtilityMock = mocked(KubernetesManifestUtility, true);
    KubernetesManifestUtilityMock.checkManifestStability = jest.fn().mockReturnValue("");
    const KubernetesObjectUtilityMock = mocked(KubernetesObjectUtility, true);
    KubernetesObjectUtilityMock.getResources = jest.fn().mockReturnValue(resources);
    const fileHelperMock = mocked(fileHelper, true);
    const fsMock = (mocked(fs, true));
-    fileHelperMock.getTempDirectory = jest.fn().mockReturnValue("Local/Temp/");
-    fsMock.writeFileSync =jest.fn().mockReturnValue("");
+    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("");
    kubeCtl.getResource = jest.fn().mockReturnValue(getNamespaceMock);
@@ -291,14 +457,14 @@ test("deployment - deploy() - Skip Annotate namespace", async () => {
    kubeCtl.getNewReplicaSet = jest.fn().mockReturnValue("testpod-776cbc86f9");
    kubeCtl.annotateFiles = jest.fn().mockReturnValue("");
    kubeCtl.annotate = jest.fn().mockReturnValue("");
-
-    const consoleOutputSpy = jest.spyOn(process.stdout, "write").mockImplementation();
-
+    kubeCtl.labelFiles = jest.fn();
    //Invoke and assert
    await expect(deployment.deploy(kubeCtl, ['manifests/deployment.yaml'], undefined)).resolves.not.toThrowError();
-    expect(kubeCtl.annotateFiles).toBeCalledWith(["Local/Temp/deployment.yaml"], workflowAnnotations, true);
-    expect(kubeCtl.annotate).toBeCalledTimes(1);
-    expect(consoleOutputSpy).toHaveBeenNthCalledWith(1, `##[debug]Skipping 'annotate namespace' as namespace annotated by other workflow` + os.EOL)
+    expect(kubeCtl.annotate).toHaveBeenNthCalledWith(1, 'namespace', 'default', annotationKeyValStr);
+    expect(kubeCtl.annotateFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp/deployment.yaml"], annotationKeyValStr);
+    expect(kubeCtl.annotate).toBeCalledTimes(2);
+    expect(kubeCtl.labelFiles).toBeCalledWith(["~/Deployment_testapp_currentTimestamp/deployment.yaml"],
+        [`workflowFriendlyName=New_Workflow.yml`, `workflow=${getWorkflowAnnotationKeyLabel(process.env.GITHUB_WORKFLOW)}`]);
 });

 test("deployment - deploy() - Annotate resources failed", async () => {
@@ -320,10 +486,39 @@ 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(1, '##[warning]kubectl annotate failed' + os.EOL)
-});
+    expect(consoleOutputSpy).toHaveBeenNthCalledWith(1, '::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);
+});
+
+test("action - run() - Throw kubectl error on 404 response", async () => {
+    const kubectlVersion = 'v1.18.0'
+    const arch = 'arm128';
+    // Mock
+    coreMock.getInput = jest.fn().mockReturnValue(kubectlVersion);
+    osMock.arch = jest.fn().mockReturnValue(arch);
+    toolCacheMock.find = jest.fn().mockReturnValue(undefined);
+    toolCacheMock.downloadTool = jest.fn().mockImplementation(_ => {
+        throw new toolCache.HTTPError(httpClient.StatusCodes.NOT_FOUND);
+    });
+
+    //Invoke and assert
+    await expect(action.run()).rejects.toThrow(util.format("Kubectl '%s' for '%s' arch not found.", kubectlVersion, arch));
+});
@@ -53,6 +53,10 @@ inputs:
    description: 'Deploy when a previous deployment already exists. If true then --force argument is added to the apply command'
    required: false
    default: false
+  token:
+    description: 'Github token'
+    default: ${{ github.token }}
+    required: true

 branding:
  color: 'green' # optional, decorates the entry in the GitHub Marketplace
@@ -1,107 +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.promote = void 0;
-const core = require("@actions/core");
-const deploymentHelper = require("../utilities/strategy-helpers/deployment-helper");
-const canaryDeploymentHelper = require("../utilities/strategy-helpers/canary-deployment-helper");
-const SMICanaryDeploymentHelper = require("../utilities/strategy-helpers/smi-canary-deployment-helper");
-const utils = require("../utilities/manifest-utilities");
-const TaskInputParameters = require("../input-parameters");
-const manifest_utilities_1 = require("../utilities/manifest-utilities");
-const KubernetesObjectUtility = require("../utilities/resource-object-utility");
-const models = require("../constants");
-const KubernetesManifestUtility = require("../utilities/manifest-stability-utility");
-const blue_green_helper_1 = require("../utilities/strategy-helpers/blue-green-helper");
-const blue_green_helper_2 = require("../utilities/strategy-helpers/blue-green-helper");
-const service_blue_green_helper_1 = require("../utilities/strategy-helpers/service-blue-green-helper");
-const ingress_blue_green_helper_1 = require("../utilities/strategy-helpers/ingress-blue-green-helper");
-const smi_blue_green_helper_1 = require("../utilities/strategy-helpers/smi-blue-green-helper");
-const kubectl_object_model_1 = require("../kubectl-object-model");
-function promote() {
-    return __awaiter(this, void 0, void 0, function* () {
-        const kubectl = new kubectl_object_model_1.Kubectl(yield utils.getKubectl(), TaskInputParameters.namespace, true);
-        if (canaryDeploymentHelper.isCanaryDeploymentStrategy()) {
-            yield promoteCanary(kubectl);
-        }
-        else if (blue_green_helper_2.isBlueGreenDeploymentStrategy()) {
-            yield promoteBlueGreen(kubectl);
-        }
-        else {
-            core.debug('Strategy is not canary or blue-green deployment. Invalid request.');
-            throw ('InvalidPromotetActionDeploymentStrategy');
-        }
-    });
-}
-exports.promote = promote;
-function promoteCanary(kubectl) {
-    return __awaiter(this, void 0, void 0, function* () {
-        let includeServices = false;
-        if (canaryDeploymentHelper.isSMICanaryStrategy()) {
-            includeServices = true;
-            // In case of SMI traffic split strategy when deployment is promoted, first we will redirect traffic to
-            // Canary deployment, then update stable deployment and then redirect traffic to stable deployment
-            core.debug('Redirecting traffic to canary deployment');
-            SMICanaryDeploymentHelper.redirectTrafficToCanaryDeployment(kubectl, TaskInputParameters.manifests);
-            core.debug('Deploying input manifests with SMI canary strategy');
-            yield deploymentHelper.deploy(kubectl, TaskInputParameters.manifests, 'None');
-            core.debug('Redirecting traffic to stable deployment');
-            SMICanaryDeploymentHelper.redirectTrafficToStableDeployment(kubectl, TaskInputParameters.manifests);
-        }
-        else {
-            core.debug('Deploying input manifests');
-            yield deploymentHelper.deploy(kubectl, TaskInputParameters.manifests, 'None');
-        }
-        core.debug('Deployment strategy selected is Canary. Deleting canary and baseline workloads.');
-        try {
-            canaryDeploymentHelper.deleteCanaryDeployment(kubectl, TaskInputParameters.manifests, includeServices);
-        }
-        catch (ex) {
-            core.warning('Exception occurred while deleting canary and baseline workloads. Exception: ' + ex);
-        }
-    });
-}
-function promoteBlueGreen(kubectl) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // updated container images and pull secrets
-        let inputManifestFiles = manifest_utilities_1.getUpdatedManifestFiles(TaskInputParameters.manifests);
-        const manifestObjects = blue_green_helper_1.getManifestObjects(inputManifestFiles);
-        core.debug('deleting old deployment and making new ones');
-        let result;
-        if (blue_green_helper_2.isIngressRoute()) {
-            result = yield ingress_blue_green_helper_1.promoteBlueGreenIngress(kubectl, manifestObjects);
-        }
-        else if (blue_green_helper_2.isSMIRoute()) {
-            result = yield smi_blue_green_helper_1.promoteBlueGreenSMI(kubectl, manifestObjects);
-        }
-        else {
-            result = yield service_blue_green_helper_1.promoteBlueGreenService(kubectl, manifestObjects);
-        }
-        // checking stability of newly created deployments 
-        const deployedManifestFiles = result.newFilePaths;
-        const resources = KubernetesObjectUtility.getResources(deployedManifestFiles, models.deploymentTypes.concat([models.DiscoveryAndLoadBalancerResource.service]));
-        yield KubernetesManifestUtility.checkManifestStability(kubectl, resources);
-        core.debug('routing to new deployments');
-        if (blue_green_helper_2.isIngressRoute()) {
-            ingress_blue_green_helper_1.routeBlueGreenIngress(kubectl, null, manifestObjects.serviceNameMap, manifestObjects.ingressEntityList);
-            blue_green_helper_1.deleteWorkloadsAndServicesWithLabel(kubectl, blue_green_helper_2.GREEN_LABEL_VALUE, manifestObjects.deploymentEntityList, manifestObjects.serviceEntityList);
-        }
-        else if (blue_green_helper_2.isSMIRoute()) {
-            smi_blue_green_helper_1.routeBlueGreenSMI(kubectl, blue_green_helper_2.NONE_LABEL_VALUE, manifestObjects.serviceEntityList);
-            blue_green_helper_1.deleteWorkloadsWithLabel(kubectl, blue_green_helper_2.GREEN_LABEL_VALUE, manifestObjects.deploymentEntityList);
-            smi_blue_green_helper_1.cleanupSMI(kubectl, manifestObjects.serviceEntityList);
-        }
-        else {
-            service_blue_green_helper_1.routeBlueGreenService(kubectl, blue_green_helper_2.NONE_LABEL_VALUE, manifestObjects.serviceEntityList);
-            blue_green_helper_1.deleteWorkloadsWithLabel(kubectl, blue_green_helper_2.GREEN_LABEL_VALUE, manifestObjects.deploymentEntityList);
-        }
-    });
-}
@@ -1,65 +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.reject = void 0;
-const core = require("@actions/core");
-const canaryDeploymentHelper = require("../utilities/strategy-helpers/canary-deployment-helper");
-const SMICanaryDeploymentHelper = require("../utilities/strategy-helpers/smi-canary-deployment-helper");
-const kubectl_object_model_1 = require("../kubectl-object-model");
-const utils = require("../utilities/manifest-utilities");
-const TaskInputParameters = require("../input-parameters");
-const service_blue_green_helper_1 = require("../utilities/strategy-helpers/service-blue-green-helper");
-const ingress_blue_green_helper_1 = require("../utilities/strategy-helpers/ingress-blue-green-helper");
-const smi_blue_green_helper_1 = require("../utilities/strategy-helpers/smi-blue-green-helper");
-const blue_green_helper_1 = require("../utilities/strategy-helpers/blue-green-helper");
-const deployment_helper_1 = require("../utilities/strategy-helpers/deployment-helper");
-function reject() {
-    return __awaiter(this, void 0, void 0, function* () {
-        const kubectl = new kubectl_object_model_1.Kubectl(yield utils.getKubectl(), TaskInputParameters.namespace, true);
-        if (canaryDeploymentHelper.isCanaryDeploymentStrategy()) {
-            yield rejectCanary(kubectl);
-        }
-        else if (blue_green_helper_1.isBlueGreenDeploymentStrategy()) {
-            yield rejectBlueGreen(kubectl);
-        }
-        else {
-            core.debug('Strategy is not canary or blue-green deployment. Invalid request.');
-            throw ('InvalidDeletetActionDeploymentStrategy');
-        }
-    });
-}
-exports.reject = reject;
-function rejectCanary(kubectl) {
-    return __awaiter(this, void 0, void 0, function* () {
-        let includeServices = false;
-        if (canaryDeploymentHelper.isSMICanaryStrategy()) {
-            core.debug('Reject deployment with SMI canary strategy');
-            includeServices = true;
-            SMICanaryDeploymentHelper.redirectTrafficToStableDeployment(kubectl, TaskInputParameters.manifests);
-        }
-        core.debug('Deployment strategy selected is Canary. Deleting baseline and canary workloads.');
-        canaryDeploymentHelper.deleteCanaryDeployment(kubectl, TaskInputParameters.manifests, includeServices);
-    });
-}
-function rejectBlueGreen(kubectl) {
-    return __awaiter(this, void 0, void 0, function* () {
-        let inputManifestFiles = deployment_helper_1.getManifestFiles(TaskInputParameters.manifests);
-        if (blue_green_helper_1.isIngressRoute()) {
-            yield ingress_blue_green_helper_1.rejectBlueGreenIngress(kubectl, inputManifestFiles);
-        }
-        else if (blue_green_helper_1.isSMIRoute()) {
-            yield smi_blue_green_helper_1.rejectBlueGreenSMI(kubectl, inputManifestFiles);
-        }
-        else {
-            yield service_blue_green_helper_1.rejectBlueGreenService(kubectl, inputManifestFiles);
-        }
-    });
-}
@@ -1,39 +0,0 @@
-'use strict';
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.workflowAnnotations = exports.workloadTypesWithRolloutStatus = exports.workloadTypes = exports.deploymentTypes = exports.ServiceTypes = exports.DiscoveryAndLoadBalancerResource = exports.KubernetesWorkload = void 0;
-class KubernetesWorkload {
-}
-exports.KubernetesWorkload = KubernetesWorkload;
-KubernetesWorkload.pod = 'Pod';
-KubernetesWorkload.replicaset = 'Replicaset';
-KubernetesWorkload.deployment = 'Deployment';
-KubernetesWorkload.statefulSet = 'StatefulSet';
-KubernetesWorkload.daemonSet = 'DaemonSet';
-KubernetesWorkload.job = 'job';
-KubernetesWorkload.cronjob = 'cronjob';
-class DiscoveryAndLoadBalancerResource {
-}
-exports.DiscoveryAndLoadBalancerResource = DiscoveryAndLoadBalancerResource;
-DiscoveryAndLoadBalancerResource.service = 'service';
-DiscoveryAndLoadBalancerResource.ingress = 'ingress';
-class ServiceTypes {
-}
-exports.ServiceTypes = ServiceTypes;
-ServiceTypes.loadBalancer = 'LoadBalancer';
-ServiceTypes.nodePort = 'NodePort';
-ServiceTypes.clusterIP = 'ClusterIP';
-exports.deploymentTypes = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset'];
-exports.workloadTypes = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset', 'job', 'cronjob'];
-exports.workloadTypesWithRolloutStatus = ['deployment', 'daemonset', 'statefulset'];
-exports.workflowAnnotations = [
-    `run=${process.env['GITHUB_RUN_ID']}`,
-    `repository=${process.env['GITHUB_REPOSITORY']}`,
-    `workflow=${process.env['GITHUB_WORKFLOW']}`,
-    `jobName=${process.env['GITHUB_JOB']}`,
-    `createdBy=${process.env['GITHUB_ACTOR']}`,
-    `runUri=https://github.com/${process.env['GITHUB_REPOSITORY']}/actions/runs/${process.env['GITHUB_RUN_ID']}`,
-    `commit=${process.env['GITHUB_SHA']}`,
-    `branch=${process.env['GITHUB_REF']}`,
-    `deployTimestamp=${Date.now()}`,
-    `provider=GitHub`
-];
@@ -1,53 +0,0 @@
-'use strict';
-Object.defineProperty(exports, "__esModule", { value: true });
-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;
-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.canaryPercentage = core.getInput('percentage');
-exports.deploymentStrategy = core.getInput('strategy');
-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';
-if (!exports.namespace) {
-    core.debug('Namespace was not supplied; using "default" namespace instead.');
-    exports.namespace = 'default';
-}
-try {
-    const pe = parseInt(exports.canaryPercentage);
-    if (pe < 0 || pe > 100) {
-        core.setFailed('A valid percentage value is between 0 and 100');
-        process.exit(1);
-    }
-}
-catch (ex) {
-    core.setFailed("Enter a valid 'percentage' integer value ");
-    process.exit(1);
-}
-try {
-    const pe = parseInt(exports.baselineAndCanaryReplicas);
-    if (pe < 0 || pe > 100) {
-        core.setFailed('A valid baseline-and-canary-replicas value is between 0 and 100');
-        process.exit(1);
-    }
-}
-catch (ex) {
-    core.setFailed("Enter a valid 'baseline-and-canary-replicas' integer value");
-    process.exit(1);
-}
-try {
-    const pe = parseInt(exports.versionSwitchBuffer);
-    if (pe < 0 || pe > 300) {
-        core.setFailed('Invalid buffer time, valid version-switch-buffer is a value more than or equal to 0 and lesser than or equal 300');
-        process.exit(1);
-    }
-}
-catch (ex) {
-    core.setFailed("Enter a valid 'version-switch-buffer' integer value");
-    process.exit(1);
-}
@@ -1,114 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.Kubectl = void 0;
-const tool_runner_1 = require("./utilities/tool-runner");
-class Kubectl {
-    constructor(kubectlPath, namespace, ignoreSSLErrors) {
-        this.kubectlPath = kubectlPath;
-        this.ignoreSSLErrors = !!ignoreSSLErrors;
-        if (!!namespace) {
-            this.namespace = namespace;
-        }
-        else {
-            this.namespace = 'default';
-        }
-    }
-    apply(configurationPaths, force) {
-        let applyArgs = ['apply', '-f', this.createInlineArray(configurationPaths)];
-        if (!!force) {
-            console.log("force flag is on, deployment will continue even if previous deployment already exists");
-            applyArgs.push('--force');
-        }
-        return this.execute(applyArgs);
-    }
-    describe(resourceType, resourceName, silent) {
-        return this.execute(['describe', resourceType, resourceName], silent);
-    }
-    getNewReplicaSet(deployment) {
-        let newReplicaSet = '';
-        const result = this.describe('deployment', deployment, true);
-        if (result && result.stdout) {
-            const stdout = result.stdout.split('\n');
-            stdout.forEach((line) => {
-                if (!!line && line.toLowerCase().indexOf('newreplicaset') > -1) {
-                    newReplicaSet = line.substr(14).trim().split(' ')[0];
-                }
-            });
-        }
-        return newReplicaSet;
-    }
-    annotate(resourceType, resourceName, annotations, overwrite) {
-        let args = ['annotate', resourceType, resourceName];
-        args = args.concat(annotations);
-        if (!!overwrite) {
-            args.push(`--overwrite`);
-        }
-        return this.execute(args);
-    }
-    annotateFiles(files, annotations, overwrite) {
-        let args = ['annotate'];
-        args = args.concat(['-f', this.createInlineArray(files)]);
-        args = args.concat(annotations);
-        if (!!overwrite) {
-            args.push(`--overwrite`);
-        }
-        return this.execute(args);
-    }
-    getAllPods() {
-        return this.execute(['get', 'pods', '-o', 'json'], true);
-    }
-    getClusterInfo() {
-        return this.execute(['cluster-info'], true);
-    }
-    checkRolloutStatus(resourceType, name) {
-        return this.execute(['rollout', 'status', resourceType + '/' + name]);
-    }
-    getResource(resourceType, name) {
-        return this.execute(['get', resourceType + '/' + name, '-o', 'json']);
-    }
-    getResources(applyOutput, filterResourceTypes) {
-        const outputLines = applyOutput.split('\n');
-        const results = [];
-        outputLines.forEach(line => {
-            const words = line.split(' ');
-            if (words.length > 2) {
-                const resourceType = words[0].trim();
-                const resourceName = JSON.parse(words[1].trim());
-                if (filterResourceTypes.filter(type => !!type && resourceType.toLowerCase().startsWith(type.toLowerCase())).length > 0) {
-                    results.push({
-                        type: resourceType,
-                        name: resourceName
-                    });
-                }
-            }
-        });
-        return results;
-    }
-    executeCommand(customCommand, args) {
-        if (!customCommand)
-            throw new Error('NullCommandForKubectl');
-        return args ? this.execute([customCommand, args]) : this.execute([customCommand]);
-    }
-    delete(args) {
-        if (typeof args === 'string')
-            return this.execute(['delete', args]);
-        else
-            return this.execute(['delete'].concat(args));
-    }
-    execute(args, silent) {
-        if (this.ignoreSSLErrors) {
-            args.push('--insecure-skip-tls-verify');
-        }
-        args = args.concat(['--namespace', this.namespace]);
-        const command = new tool_runner_1.ToolRunner(this.kubectlPath);
-        command.arg(args);
-        return command.execSync({ silent: !!silent });
-    }
-    createInlineArray(str) {
-        if (typeof str === 'string') {
-            return str;
-        }
-        return str.join(',');
-    }
-}
-exports.Kubectl = Kubectl;
@@ -1,80 +0,0 @@
-"use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    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) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-const os = require("os");
-const path = require("path");
-const util = require("util");
-const fs = require("fs");
-const toolCache = require("@actions/tool-cache");
-const core = require("@actions/core");
-const kubectlToolName = 'kubectl';
-const stableKubectlVersion = 'v1.15.0';
-const stableVersionUrl = 'https://storage.googleapis.com/kubernetes-release/release/stable.txt';
-function getExecutableExtension() {
-    if (os.type().match(/^Win/)) {
-        return '.exe';
-    }
-    return '';
-}
-function getkubectlDownloadURL(version) {
-    switch (os.type()) {
-        case 'Linux':
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/linux/amd64/kubectl', version);
-        case 'Darwin':
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/darwin/amd64/kubectl', version);
-        case 'Windows_NT':
-        default:
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/windows/amd64/kubectl.exe', version);
-    }
-}
-function getStableKubectlVersion() {
-    return __awaiter(this, void 0, void 0, function* () {
-        return toolCache.downloadTool(stableVersionUrl).then((downloadPath) => {
-            let version = fs.readFileSync(downloadPath, 'utf8').toString().trim();
-            if (!version) {
-                version = stableKubectlVersion;
-            }
-            return version;
-        }, (error) => {
-            core.debug(error);
-            core.warning('GetStableVersionFailed');
-            return stableKubectlVersion;
-        });
-    });
-}
-exports.getStableKubectlVersion = getStableKubectlVersion;
-function downloadKubectl(version) {
-    return __awaiter(this, void 0, void 0, function* () {
-        let cachedToolpath = toolCache.find(kubectlToolName, version);
-        let kubectlDownloadPath = '';
-        if (!cachedToolpath) {
-            try {
-                kubectlDownloadPath = yield toolCache.downloadTool(getkubectlDownloadURL(version));
-            }
-            catch (exception) {
-                throw new Error('DownloadKubectlFailed');
-            }
-            cachedToolpath = yield toolCache.cacheFile(kubectlDownloadPath, kubectlToolName + getExecutableExtension(), kubectlToolName, version);
-        }
-        const kubectlPath = path.join(cachedToolpath, kubectlToolName + getExecutableExtension());
-        fs.chmodSync(kubectlPath, '777');
-        return kubectlPath;
-    });
-}
-exports.downloadKubectl = downloadKubectl;
-function getTrafficSplitAPIVersion(kubectl) {
-    const result = kubectl.executeCommand('api-versions');
-    const trafficSplitAPIVersion = result.stdout.split('\n').find(version => version.startsWith('split.smi-spec.io'));
-    if (trafficSplitAPIVersion == null || typeof trafficSplitAPIVersion == 'undefined') {
-        throw new Error('UnableToCreateTrafficSplitManifestFile');
-    }
-    return trafficSplitAPIVersion;
-}
-exports.getTrafficSplitAPIVersion = getTrafficSplitAPIVersion;
@@ -1,91 +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.run = void 0;
-const core = require("@actions/core");
-const io = require("@actions/io");
-const path = require("path");
-const toolCache = require("@actions/tool-cache");
-const kubectl_util_1 = require("./utilities/kubectl-util");
-const utility_1 = require("./utilities/utility");
-const kubectl_object_model_1 = require("./kubectl-object-model");
-const deployment_helper_1 = require("./utilities/strategy-helpers/deployment-helper");
-const promote_1 = require("./actions/promote");
-const reject_1 = require("./actions/reject");
-let kubectlPath = "";
-function setKubectlPath() {
-    return __awaiter(this, void 0, void 0, function* () {
-        if (core.getInput('kubectl-version')) {
-            const version = core.getInput('kubectl-version');
-            kubectlPath = toolCache.find('kubectl', version);
-            if (!kubectlPath) {
-                kubectlPath = yield installKubectl(version);
-            }
-        }
-        else {
-            kubectlPath = yield io.which('kubectl', false);
-            if (!kubectlPath) {
-                const allVersions = toolCache.findAllVersions('kubectl');
-                kubectlPath = allVersions.length > 0 ? toolCache.find('kubectl', allVersions[0]) : '';
-                if (!kubectlPath) {
-                    throw new Error('Kubectl is not installed, either add install-kubectl action or provide "kubectl-version" input to download kubectl');
-                }
-                kubectlPath = path.join(kubectlPath, `kubectl${utility_1.getExecutableExtension()}`);
-            }
-        }
-    });
-}
-function installKubectl(version) {
-    return __awaiter(this, void 0, void 0, function* () {
-        if (utility_1.isEqual(version, 'latest')) {
-            version = yield kubectl_util_1.getStableKubectlVersion();
-        }
-        return yield kubectl_util_1.downloadKubectl(version);
-    });
-}
-function checkClusterContext() {
-    if (!process.env["KUBECONFIG"]) {
-        throw new Error('Cluster context not set. Use k8ssetcontext action to set cluster context');
-    }
-}
-function run() {
-    return __awaiter(this, void 0, void 0, function* () {
-        checkClusterContext();
-        yield setKubectlPath();
-        let manifestsInput = core.getInput('manifests');
-        if (!manifestsInput) {
-            core.setFailed('No manifests supplied to deploy');
-            return;
-        }
-        let namespace = core.getInput('namespace');
-        if (!namespace) {
-            namespace = 'default';
-        }
-        let action = core.getInput('action');
-        let manifests = manifestsInput.split('\n');
-        if (action === 'deploy') {
-            let strategy = core.getInput('strategy');
-            console.log("strategy: ", strategy);
-            yield deployment_helper_1.deploy(new kubectl_object_model_1.Kubectl(kubectlPath, namespace), manifests, strategy);
-        }
-        else if (action === 'promote') {
-            yield promote_1.promote();
-        }
-        else if (action === 'reject') {
-            yield reject_1.reject();
-        }
-        else {
-            core.setFailed('Not a valid action. The allowed actions are deploy, promote, reject');
-        }
-    });
-}
-exports.run = run;
-run().catch(core.setFailed);
@@ -1,78 +0,0 @@
-'use strict';
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.writeManifestToFile = exports.writeObjectsToFile = exports.assertFileExists = exports.ensureDirExists = exports.getNewUserDirPath = exports.getTempDirectory = void 0;
-const fs = require("fs");
-const path = require("path");
-const core = require("@actions/core");
-const os = require("os");
-function getTempDirectory() {
-    return process.env['runner.tempDirectory'] || os.tmpdir();
-}
-exports.getTempDirectory = getTempDirectory;
-function getNewUserDirPath() {
-    let userDir = path.join(getTempDirectory(), 'kubectlTask');
-    ensureDirExists(userDir);
-    userDir = path.join(userDir, getCurrentTime().toString());
-    ensureDirExists(userDir);
-    return userDir;
-}
-exports.getNewUserDirPath = getNewUserDirPath;
-function ensureDirExists(dirPath) {
-    if (!fs.existsSync(dirPath)) {
-        fs.mkdirSync(dirPath);
-    }
-}
-exports.ensureDirExists = ensureDirExists;
-function assertFileExists(path) {
-    if (!fs.existsSync(path)) {
-        core.error(`FileNotFoundException : ${path}`);
-        throw new Error(`FileNotFoundException:  ${path}`);
-    }
-}
-exports.assertFileExists = assertFileExists;
-function writeObjectsToFile(inputObjects) {
-    const newFilePaths = [];
-    if (!!inputObjects) {
-        inputObjects.forEach((inputObject) => {
-            try {
-                const inputObjectString = JSON.stringify(inputObject);
-                if (!!inputObject.kind && !!inputObject.metadata && !!inputObject.metadata.name) {
-                    const fileName = getManifestFileName(inputObject.kind, inputObject.metadata.name);
-                    fs.writeFileSync(path.join(fileName), inputObjectString);
-                    newFilePaths.push(fileName);
-                }
-                else {
-                    core.debug('Input object is not proper K8s resource object. Object: ' + inputObjectString);
-                }
-            }
-            catch (ex) {
-                core.debug('Exception occurred while writing object to file : ' + inputObject + ' . Exception: ' + ex);
-            }
-        });
-    }
-    return newFilePaths;
-}
-exports.writeObjectsToFile = writeObjectsToFile;
-function writeManifestToFile(inputObjectString, kind, name) {
-    if (inputObjectString) {
-        try {
-            const fileName = getManifestFileName(kind, name);
-            fs.writeFileSync(path.join(fileName), inputObjectString);
-            return fileName;
-        }
-        catch (ex) {
-            core.debug('Exception occurred while writing object to file : ' + inputObjectString + ' . Exception: ' + ex);
-        }
-    }
-    return '';
-}
-exports.writeManifestToFile = writeManifestToFile;
-function getManifestFileName(kind, name) {
-    const filePath = kind + '_' + name + '_' + getCurrentTime().toString();
-    const tempDirectory = getTempDirectory();
-    const fileName = path.join(tempDirectory, path.basename(filePath));
-    return fileName;
-}
-function getCurrentTime() {
-    return new Date().getTime();
-}
@@ -1,84 +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.getTrafficSplitAPIVersion = exports.downloadKubectl = exports.getStableKubectlVersion = exports.getkubectlDownloadURL = void 0;
-const core = require("@actions/core");
-const fs = require("fs");
-const os = require("os");
-const path = require("path");
-const toolCache = require("@actions/tool-cache");
-const util = require("util");
-const kubectlToolName = 'kubectl';
-const stableKubectlVersion = 'v1.15.0';
-const stableVersionUrl = 'https://storage.googleapis.com/kubernetes-release/release/stable.txt';
-const trafficSplitAPIVersionPrefix = 'split.smi-spec.io';
-function getExecutableExtension() {
-    if (os.type().match(/^Win/)) {
-        return '.exe';
-    }
-    return '';
-}
-function getkubectlDownloadURL(version) {
-    switch (os.type()) {
-        case 'Linux':
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/linux/amd64/kubectl', version);
-        case 'Darwin':
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/darwin/amd64/kubectl', version);
-        case 'Windows_NT':
-        default:
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/windows/amd64/kubectl.exe', version);
-    }
-}
-exports.getkubectlDownloadURL = getkubectlDownloadURL;
-function getStableKubectlVersion() {
-    return __awaiter(this, void 0, void 0, function* () {
-        return toolCache.downloadTool(stableVersionUrl).then((downloadPath) => {
-            let version = fs.readFileSync(downloadPath, 'utf8').toString().trim();
-            if (!version) {
-                version = stableKubectlVersion;
-            }
-            return version;
-        }, (error) => {
-            core.debug(error);
-            core.warning('GetStableVersionFailed');
-            return stableKubectlVersion;
-        });
-    });
-}
-exports.getStableKubectlVersion = getStableKubectlVersion;
-function downloadKubectl(version) {
-    return __awaiter(this, void 0, void 0, function* () {
-        let cachedToolpath = toolCache.find(kubectlToolName, version);
-        let kubectlDownloadPath = '';
-        if (!cachedToolpath) {
-            try {
-                kubectlDownloadPath = yield toolCache.downloadTool(getkubectlDownloadURL(version));
-            }
-            catch (exception) {
-                throw new Error('DownloadKubectlFailed');
-            }
-            cachedToolpath = yield toolCache.cacheFile(kubectlDownloadPath, kubectlToolName + getExecutableExtension(), kubectlToolName, version);
-        }
-        const kubectlPath = path.join(cachedToolpath, kubectlToolName + getExecutableExtension());
-        fs.chmodSync(kubectlPath, '777');
-        return kubectlPath;
-    });
-}
-exports.downloadKubectl = downloadKubectl;
-function getTrafficSplitAPIVersion(kubectl) {
-    const result = kubectl.executeCommand('api-versions');
-    const trafficSplitAPIVersion = result.stdout.split('\n').find(version => version.startsWith(trafficSplitAPIVersionPrefix));
-    if (!trafficSplitAPIVersion) {
-        throw new Error('UnableToCreateTrafficSplitManifestFile');
-    }
-    return trafficSplitAPIVersion;
-}
-exports.getTrafficSplitAPIVersion = getTrafficSplitAPIVersion;
@@ -1,158 +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.checkPodStatus = exports.checkManifestStability = void 0;
-const core = require("@actions/core");
-const utils = require("./utility");
-const KubernetesConstants = require("../constants");
-function checkManifestStability(kubectl, resources) {
-    return __awaiter(this, void 0, void 0, function* () {
-        let rolloutStatusHasErrors = false;
-        const numberOfResources = resources.length;
-        for (let i = 0; i < numberOfResources; i++) {
-            const resource = resources[i];
-            if (KubernetesConstants.workloadTypesWithRolloutStatus.indexOf(resource.type.toLowerCase()) >= 0) {
-                try {
-                    var result = kubectl.checkRolloutStatus(resource.type, resource.name);
-                    utils.checkForErrors([result]);
-                }
-                catch (ex) {
-                    core.error(ex);
-                    kubectl.describe(resource.type, resource.name);
-                    rolloutStatusHasErrors = true;
-                }
-            }
-            if (utils.isEqual(resource.type, KubernetesConstants.KubernetesWorkload.pod, true)) {
-                try {
-                    yield checkPodStatus(kubectl, resource.name);
-                }
-                catch (ex) {
-                    core.warning(`CouldNotDeterminePodStatus ${JSON.stringify(ex)}`);
-                    kubectl.describe(resource.type, resource.name);
-                }
-            }
-            if (utils.isEqual(resource.type, KubernetesConstants.DiscoveryAndLoadBalancerResource.service, true)) {
-                try {
-                    const service = getService(kubectl, resource.name);
-                    const spec = service.spec;
-                    const status = service.status;
-                    if (utils.isEqual(spec.type, KubernetesConstants.ServiceTypes.loadBalancer, true)) {
-                        if (!isLoadBalancerIPAssigned(status)) {
-                            yield waitForServiceExternalIPAssignment(kubectl, resource.name);
-                        }
-                        else {
-                            console.log('ServiceExternalIP', resource.name, status.loadBalancer.ingress[0].ip);
-                        }
-                    }
-                }
-                catch (ex) {
-                    core.warning(`CouldNotDetermineServiceStatus of: ${resource.name} Error: ${JSON.stringify(ex)}`);
-                    kubectl.describe(resource.type, resource.name);
-                }
-            }
-        }
-        if (rolloutStatusHasErrors) {
-            throw new Error('RolloutStatusTimedout');
-        }
-    });
-}
-exports.checkManifestStability = checkManifestStability;
-function checkPodStatus(kubectl, podName) {
-    return __awaiter(this, void 0, void 0, function* () {
-        const sleepTimeout = 10 * 1000; // 10 seconds
-        const iterations = 60; // 60 * 10 seconds timeout = 10 minutes max timeout
-        let podStatus;
-        let kubectlDescribeNeeded = false;
-        for (let i = 0; i < iterations; i++) {
-            yield utils.sleep(sleepTimeout);
-            core.debug(`Polling for pod status: ${podName}`);
-            podStatus = getPodStatus(kubectl, podName);
-            if (podStatus.phase && podStatus.phase !== 'Pending' && podStatus.phase !== 'Unknown') {
-                break;
-            }
-        }
-        podStatus = getPodStatus(kubectl, podName);
-        switch (podStatus.phase) {
-            case 'Succeeded':
-            case 'Running':
-                if (isPodReady(podStatus)) {
-                    console.log(`pod/${podName} is successfully rolled out`);
-                }
-                else {
-                    kubectlDescribeNeeded = true;
-                }
-                break;
-            case 'Pending':
-                if (!isPodReady(podStatus)) {
-                    core.warning(`pod/${podName} rollout status check timedout`);
-                    kubectlDescribeNeeded = true;
-                }
-                break;
-            case 'Failed':
-                core.error(`pod/${podName} rollout failed`);
-                kubectlDescribeNeeded = true;
-                break;
-            default:
-                core.warning(`pod/${podName} rollout status: ${podStatus.phase}`);
-        }
-        if (kubectlDescribeNeeded) {
-            kubectl.describe('pod', podName);
-        }
-    });
-}
-exports.checkPodStatus = checkPodStatus;
-function getPodStatus(kubectl, podName) {
-    const podResult = kubectl.getResource('pod', podName);
-    utils.checkForErrors([podResult]);
-    const podStatus = JSON.parse(podResult.stdout).status;
-    core.debug(`Pod Status: ${JSON.stringify(podStatus)}`);
-    return podStatus;
-}
-function isPodReady(podStatus) {
-    let allContainersAreReady = true;
-    podStatus.containerStatuses.forEach(container => {
-        if (container.ready === false) {
-            console.log(`'${container.name}' status: ${JSON.stringify(container.state)}`);
-            allContainersAreReady = false;
-        }
-    });
-    if (!allContainersAreReady) {
-        core.warning('AllContainersNotInReadyState');
-    }
-    return allContainersAreReady;
-}
-function getService(kubectl, serviceName) {
-    const serviceResult = kubectl.getResource(KubernetesConstants.DiscoveryAndLoadBalancerResource.service, serviceName);
-    utils.checkForErrors([serviceResult]);
-    return JSON.parse(serviceResult.stdout);
-}
-function waitForServiceExternalIPAssignment(kubectl, serviceName) {
-    return __awaiter(this, void 0, void 0, function* () {
-        const sleepTimeout = 10 * 1000; // 10 seconds
-        const iterations = 18; // 18 * 10 seconds timeout = 3 minutes max timeout
-        for (let i = 0; i < iterations; i++) {
-            console.log(`waitForServiceIpAssignment : ${serviceName}`);
-            yield utils.sleep(sleepTimeout);
-            let status = (getService(kubectl, serviceName)).status;
-            if (isLoadBalancerIPAssigned(status)) {
-                console.log('ServiceExternalIP', serviceName, status.loadBalancer.ingress[0].ip);
-                return;
-            }
-        }
-        core.warning(`waitForServiceIpAssignmentTimedOut ${serviceName}`);
-    });
-}
-function isLoadBalancerIPAssigned(status) {
-    if (status && status.loadBalancer && status.loadBalancer.ingress && status.loadBalancer.ingress.length > 0) {
-        return true;
-    }
-    return false;
-}
@@ -1,283 +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.isWorkloadEntity = exports.getUpdatedManifestFiles = exports.updateImagePullSecrets = exports.substituteImageNameInSpecFile = exports.getDeleteCmdArgs = exports.createKubectlArgs = exports.getKubectl = exports.getManifestFiles = void 0;
-const core = require("@actions/core");
-const fs = require("fs");
-const yaml = require("js-yaml");
-const path = require("path");
-const kubectlutility = require("./kubectl-util");
-const io = require("@actions/io");
-const utility_1 = require("./utility");
-const fileHelper = require("./files-helper");
-const KubernetesObjectUtility = require("./resource-object-utility");
-const TaskInputParameters = require("../input-parameters");
-function getManifestFiles(manifestFilePaths) {
-    if (!manifestFilePaths) {
-        core.debug('file input is not present');
-        return null;
-    }
-    return manifestFilePaths;
-}
-exports.getManifestFiles = getManifestFiles;
-function getKubectl() {
-    return __awaiter(this, void 0, void 0, function* () {
-        try {
-            return Promise.resolve(io.which('kubectl', true));
-        }
-        catch (ex) {
-            return kubectlutility.downloadKubectl(yield kubectlutility.getStableKubectlVersion());
-        }
-    });
-}
-exports.getKubectl = getKubectl;
-function createKubectlArgs(kinds, names) {
-    let args = '';
-    if (!!kinds && kinds.size > 0) {
-        args = args + createInlineArray(Array.from(kinds.values()));
-    }
-    if (!!names && names.size > 0) {
-        args = args + ' ' + Array.from(names.values()).join(' ');
-    }
-    return args;
-}
-exports.createKubectlArgs = createKubectlArgs;
-function getDeleteCmdArgs(argsPrefix, inputArgs) {
-    let args = '';
-    if (!!argsPrefix && argsPrefix.length > 0) {
-        args = argsPrefix;
-    }
-    if (!!inputArgs && inputArgs.length > 0) {
-        if (args.length > 0) {
-            args = args + ' ';
-        }
-        args = args + inputArgs;
-    }
-    return args;
-}
-exports.getDeleteCmdArgs = getDeleteCmdArgs;
-/*
-    For example,
-        currentString: `image: "example/example-image"`
-        imageName: `example/example-image`
-        imageNameWithNewTag: `example/example-image:identifiertag`
-
-    This substituteImageNameInSpecFile function would return
-        return Value: `image: "example/example-image:identifiertag"`
-*/
-function substituteImageNameInSpecFile(currentString, imageName, imageNameWithNewTag) {
-    if (currentString.indexOf(imageName) < 0) {
-        core.debug(`No occurence of replacement token: ${imageName} found`);
-        return currentString;
-    }
-    return currentString.split('\n').reduce((acc, line) => {
-        const imageKeyword = line.match(/^ *image:/);
-        if (imageKeyword) {
-            let [currentImageName, currentImageTag] = line
-                .substring(imageKeyword[0].length) // consume the line from keyword onwards
-                .trim()
-                .replace(/[',"]/g, '') // replace allowed quotes with nothing
-                .split(':');
-            if (!currentImageTag && currentImageName.indexOf(' ') > 0) {
-                currentImageName = currentImageName.split(' ')[0]; // Stripping off comments
-            }
-            if (currentImageName === imageName) {
-                return acc + `${imageKeyword[0]} ${imageNameWithNewTag}\n`;
-            }
-        }
-        return acc + line + '\n';
-    }, '');
-}
-exports.substituteImageNameInSpecFile = substituteImageNameInSpecFile;
-function createInlineArray(str) {
-    if (typeof str === 'string') {
-        return str;
-    }
-    return str.join(',');
-}
-function getImagePullSecrets(inputObject) {
-    if (!inputObject || !inputObject.spec) {
-        return;
-    }
-    if (utility_1.isEqual(inputObject.kind, 'pod')
-        && inputObject
-        && inputObject.spec
-        && inputObject.spec.imagePullSecrets) {
-        return inputObject.spec.imagePullSecrets;
-    }
-    else if (utility_1.isEqual(inputObject.kind, 'cronjob')
-        && inputObject
-        && inputObject.spec
-        && inputObject.spec.jobTemplate
-        && inputObject.spec.jobTemplate.spec
-        && inputObject.spec.jobTemplate.spec.template
-        && inputObject.spec.jobTemplate.spec.template.spec
-        && inputObject.spec.jobTemplate.spec.template.spec.imagePullSecrets) {
-        return inputObject.spec.jobTemplate.spec.template.spec.imagePullSecrets;
-    }
-    else if (inputObject
-        && inputObject.spec
-        && inputObject.spec.template
-        && inputObject.spec.template.spec
-        && inputObject.spec.template.spec.imagePullSecrets) {
-        return inputObject.spec.template.spec.imagePullSecrets;
-    }
-}
-function setImagePullSecrets(inputObject, newImagePullSecrets) {
-    if (!inputObject || !inputObject.spec || !newImagePullSecrets) {
-        return;
-    }
-    if (utility_1.isEqual(inputObject.kind, 'pod')) {
-        if (inputObject
-            && inputObject.spec) {
-            if (newImagePullSecrets.length > 0) {
-                inputObject.spec.imagePullSecrets = newImagePullSecrets;
-            }
-            else {
-                delete inputObject.spec.imagePullSecrets;
-            }
-        }
-    }
-    else if (utility_1.isEqual(inputObject.kind, 'cronjob')) {
-        if (inputObject
-            && inputObject.spec
-            && inputObject.spec.jobTemplate
-            && inputObject.spec.jobTemplate.spec
-            && inputObject.spec.jobTemplate.spec.template
-            && inputObject.spec.jobTemplate.spec.template.spec) {
-            if (newImagePullSecrets.length > 0) {
-                inputObject.spec.jobTemplate.spec.template.spec.imagePullSecrets = newImagePullSecrets;
-            }
-            else {
-                delete inputObject.spec.jobTemplate.spec.template.spec.imagePullSecrets;
-            }
-        }
-    }
-    else if (!!inputObject.spec.template && !!inputObject.spec.template.spec) {
-        if (inputObject
-            && inputObject.spec
-            && inputObject.spec.template
-            && inputObject.spec.template.spec) {
-            if (newImagePullSecrets.length > 0) {
-                inputObject.spec.template.spec.imagePullSecrets = newImagePullSecrets;
-            }
-            else {
-                delete inputObject.spec.template.spec.imagePullSecrets;
-            }
-        }
-    }
-}
-function substituteImageNameInSpecContent(currentString, imageName, imageNameWithNewTag) {
-    if (currentString.indexOf(imageName) < 0) {
-        core.debug(`No occurence of replacement token: ${imageName} found`);
-        return currentString;
-    }
-    return currentString.split('\n').reduce((acc, line) => {
-        const imageKeyword = line.match(/^ *image:/);
-        if (imageKeyword) {
-            const [currentImageName, currentImageTag] = line
-                .substring(imageKeyword[0].length) // consume the line from keyword onwards
-                .trim()
-                .replace(/[',"]/g, '') // replace allowed quotes with nothing
-                .split(':');
-            if (currentImageName === imageName) {
-                return acc + `${imageKeyword[0]} ${imageNameWithNewTag}\n`;
-            }
-        }
-        return acc + line + '\n';
-    }, '');
-}
-function updateContainerImagesInManifestFiles(filePaths, containers) {
-    if (!!containers && containers.length > 0) {
-        const newFilePaths = [];
-        const tempDirectory = fileHelper.getTempDirectory();
-        filePaths.forEach((filePath) => {
-            let contents = fs.readFileSync(filePath).toString();
-            containers.forEach((container) => {
-                let imageName = container.split(':')[0];
-                if (imageName.indexOf('@') > 0) {
-                    imageName = imageName.split('@')[0];
-                }
-                if (contents.indexOf(imageName) > 0) {
-                    contents = substituteImageNameInSpecFile(contents, imageName, container);
-                }
-            });
-            const fileName = path.join(tempDirectory, path.basename(filePath));
-            fs.writeFileSync(path.join(fileName), contents);
-            newFilePaths.push(fileName);
-        });
-        return newFilePaths;
-    }
-    return filePaths;
-}
-function updateImagePullSecrets(inputObject, newImagePullSecrets) {
-    if (!inputObject || !inputObject.spec || !newImagePullSecrets) {
-        return;
-    }
-    let newImagePullSecretsObjects;
-    if (newImagePullSecrets.length > 0) {
-        newImagePullSecretsObjects = Array.from(newImagePullSecrets, x => { return !!x ? { 'name': x } : null; });
-    }
-    else {
-        newImagePullSecretsObjects = [];
-    }
-    let existingImagePullSecretObjects = getImagePullSecrets(inputObject);
-    if (!existingImagePullSecretObjects) {
-        existingImagePullSecretObjects = new Array();
-    }
-    existingImagePullSecretObjects = existingImagePullSecretObjects.concat(newImagePullSecretsObjects);
-    setImagePullSecrets(inputObject, existingImagePullSecretObjects);
-}
-exports.updateImagePullSecrets = updateImagePullSecrets;
-function updateImagePullSecretsInManifestFiles(filePaths, imagePullSecrets) {
-    if (!!imagePullSecrets && imagePullSecrets.length > 0) {
-        const newObjectsList = [];
-        filePaths.forEach((filePath) => {
-            const fileContents = fs.readFileSync(filePath).toString();
-            yaml.safeLoadAll(fileContents, function (inputObject) {
-                if (!!inputObject && !!inputObject.kind) {
-                    const kind = inputObject.kind;
-                    if (KubernetesObjectUtility.isWorkloadEntity(kind)) {
-                        KubernetesObjectUtility.updateImagePullSecrets(inputObject, imagePullSecrets, false);
-                    }
-                    newObjectsList.push(inputObject);
-                }
-            });
-        });
-        core.debug('New K8s objects after adding imagePullSecrets are :' + JSON.stringify(newObjectsList));
-        const newFilePaths = fileHelper.writeObjectsToFile(newObjectsList);
-        return newFilePaths;
-    }
-    return filePaths;
-}
-function getUpdatedManifestFiles(manifestFilePaths) {
-    let inputManifestFiles = getManifestFiles(manifestFilePaths);
-    if (!inputManifestFiles || inputManifestFiles.length === 0) {
-        throw new Error(`ManifestFileNotFound : ${manifestFilePaths}`);
-    }
-    // artifact substitution
-    inputManifestFiles = updateContainerImagesInManifestFiles(inputManifestFiles, TaskInputParameters.containers);
-    // imagePullSecrets addition
-    inputManifestFiles = updateImagePullSecretsInManifestFiles(inputManifestFiles, TaskInputParameters.imagePullSecrets);
-    return inputManifestFiles;
-}
-exports.getUpdatedManifestFiles = getUpdatedManifestFiles;
-const workloadTypes = ['deployment', 'replicaset', 'daemonset', 'pod', 'statefulset', 'job', 'cronjob'];
-function isWorkloadEntity(kind) {
-    if (!kind) {
-        core.debug('ResourceKindNotDefined');
-        return false;
-    }
-    return workloadTypes.some((type) => {
-        return utility_1.isEqual(type, kind);
-    });
-}
-exports.isWorkloadEntity = isWorkloadEntity;
@@ -1,277 +0,0 @@
-'use strict';
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.getResources = exports.updateSelectorLabels = exports.updateSpecLabels = exports.updateImagePullSecrets = exports.updateObjectAnnotations = exports.updateObjectLabels = exports.getReplicaCount = exports.isIngressEntity = exports.isServiceEntity = exports.isWorkloadEntity = exports.isDeploymentEntity = void 0;
-const fs = require("fs");
-const core = require("@actions/core");
-const yaml = require("js-yaml");
-const constants_1 = require("../constants");
-const string_comparison_1 = require("./string-comparison");
-const INGRESS = "Ingress";
-function isDeploymentEntity(kind) {
-    if (!kind) {
-        throw ('ResourceKindNotDefined');
-    }
-    return constants_1.deploymentTypes.some((type) => {
-        return string_comparison_1.isEqual(type, kind, string_comparison_1.StringComparer.OrdinalIgnoreCase);
-    });
-}
-exports.isDeploymentEntity = isDeploymentEntity;
-function isWorkloadEntity(kind) {
-    if (!kind) {
-        throw ('ResourceKindNotDefined');
-    }
-    return constants_1.workloadTypes.some((type) => {
-        return string_comparison_1.isEqual(type, kind, string_comparison_1.StringComparer.OrdinalIgnoreCase);
-    });
-}
-exports.isWorkloadEntity = isWorkloadEntity;
-function isServiceEntity(kind) {
-    if (!kind) {
-        throw ('ResourceKindNotDefined');
-    }
-    return string_comparison_1.isEqual("Service", kind, string_comparison_1.StringComparer.OrdinalIgnoreCase);
-}
-exports.isServiceEntity = isServiceEntity;
-function isIngressEntity(kind) {
-    if (!kind) {
-        throw ('ResourceKindNotDefined');
-    }
-    return string_comparison_1.isEqual(INGRESS, kind, string_comparison_1.StringComparer.OrdinalIgnoreCase);
-}
-exports.isIngressEntity = isIngressEntity;
-function getReplicaCount(inputObject) {
-    if (!inputObject) {
-        throw ('NullInputObject');
-    }
-    if (!inputObject.kind) {
-        throw ('ResourceKindNotDefined');
-    }
-    const kind = inputObject.kind;
-    if (!string_comparison_1.isEqual(kind, constants_1.KubernetesWorkload.pod, string_comparison_1.StringComparer.OrdinalIgnoreCase) && !string_comparison_1.isEqual(kind, constants_1.KubernetesWorkload.daemonSet, string_comparison_1.StringComparer.OrdinalIgnoreCase)) {
-        return inputObject.spec.replicas;
-    }
-    return 0;
-}
-exports.getReplicaCount = getReplicaCount;
-function updateObjectLabels(inputObject, newLabels, override) {
-    if (!inputObject) {
-        throw ('NullInputObject');
-    }
-    if (!inputObject.metadata) {
-        throw ('NullInputObjectMetadata');
-    }
-    if (!newLabels) {
-        return;
-    }
-    if (override) {
-        inputObject.metadata.labels = newLabels;
-    }
-    else {
-        let existingLabels = inputObject.metadata.labels;
-        if (!existingLabels) {
-            existingLabels = new Map();
-        }
-        Object.keys(newLabels).forEach(function (key) {
-            existingLabels[key] = newLabels[key];
-        });
-        inputObject.metadata.labels = existingLabels;
-    }
-}
-exports.updateObjectLabels = updateObjectLabels;
-function updateObjectAnnotations(inputObject, newAnnotations, override) {
-    if (!inputObject) {
-        throw ('NullInputObject');
-    }
-    if (!inputObject.metadata) {
-        throw ('NullInputObjectMetadata');
-    }
-    if (!newAnnotations) {
-        return;
-    }
-    if (override) {
-        inputObject.metadata.annotations = newAnnotations;
-    }
-    else {
-        let existingAnnotations = inputObject.metadata.annotations;
-        if (!existingAnnotations) {
-            existingAnnotations = new Map();
-        }
-        Object.keys(newAnnotations).forEach(function (key) {
-            existingAnnotations[key] = newAnnotations[key];
-        });
-        inputObject.metadata.annotations = existingAnnotations;
-    }
-}
-exports.updateObjectAnnotations = updateObjectAnnotations;
-function updateImagePullSecrets(inputObject, newImagePullSecrets, override) {
-    if (!inputObject || !inputObject.spec || !newImagePullSecrets) {
-        return;
-    }
-    const newImagePullSecretsObjects = Array.from(newImagePullSecrets, x => { return { 'name': x }; });
-    let existingImagePullSecretObjects = getImagePullSecrets(inputObject);
-    if (override) {
-        existingImagePullSecretObjects = newImagePullSecretsObjects;
-    }
-    else {
-        if (!existingImagePullSecretObjects) {
-            existingImagePullSecretObjects = new Array();
-        }
-        existingImagePullSecretObjects = existingImagePullSecretObjects.concat(newImagePullSecretsObjects);
-    }
-    setImagePullSecrets(inputObject, existingImagePullSecretObjects);
-}
-exports.updateImagePullSecrets = updateImagePullSecrets;
-function updateSpecLabels(inputObject, newLabels, override) {
-    if (!inputObject) {
-        throw ('NullInputObject');
-    }
-    if (!inputObject.kind) {
-        throw ('ResourceKindNotDefined');
-    }
-    if (!newLabels) {
-        return;
-    }
-    let existingLabels = getSpecLabels(inputObject);
-    if (override) {
-        existingLabels = newLabels;
-    }
-    else {
-        if (!existingLabels) {
-            existingLabels = new Map();
-        }
-        Object.keys(newLabels).forEach(function (key) {
-            existingLabels[key] = newLabels[key];
-        });
-    }
-    setSpecLabels(inputObject, existingLabels);
-}
-exports.updateSpecLabels = updateSpecLabels;
-function updateSelectorLabels(inputObject, newLabels, override) {
-    if (!inputObject) {
-        throw ('NullInputObject');
-    }
-    if (!inputObject.kind) {
-        throw ('ResourceKindNotDefined');
-    }
-    if (!newLabels) {
-        return;
-    }
-    if (string_comparison_1.isEqual(inputObject.kind, constants_1.KubernetesWorkload.pod, string_comparison_1.StringComparer.OrdinalIgnoreCase)) {
-        return;
-    }
-    let existingLabels = getSpecSelectorLabels(inputObject);
-    if (override) {
-        existingLabels = newLabels;
-    }
-    else {
-        if (!existingLabels) {
-            existingLabels = new Map();
-        }
-        Object.keys(newLabels).forEach(function (key) {
-            existingLabels[key] = newLabels[key];
-        });
-    }
-    setSpecSelectorLabels(inputObject, existingLabels);
-}
-exports.updateSelectorLabels = updateSelectorLabels;
-function getResources(filePaths, filterResourceTypes) {
-    if (!filePaths) {
-        return [];
-    }
-    const resources = [];
-    filePaths.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            const inputObjectKind = inputObject ? inputObject.kind : '';
-            if (filterResourceTypes.filter(type => string_comparison_1.isEqual(inputObjectKind, type, string_comparison_1.StringComparer.OrdinalIgnoreCase)).length > 0) {
-                const resource = {
-                    type: inputObject.kind,
-                    name: inputObject.metadata.name
-                };
-                resources.push(resource);
-            }
-        });
-    });
-    return resources;
-}
-exports.getResources = getResources;
-function getSpecLabels(inputObject) {
-    if (!inputObject) {
-        return null;
-    }
-    if (string_comparison_1.isEqual(inputObject.kind, constants_1.KubernetesWorkload.pod, string_comparison_1.StringComparer.OrdinalIgnoreCase)) {
-        return inputObject.metadata.labels;
-    }
-    if (!!inputObject.spec && !!inputObject.spec.template && !!inputObject.spec.template.metadata) {
-        return inputObject.spec.template.metadata.labels;
-    }
-    return null;
-}
-function getImagePullSecrets(inputObject) {
-    if (!inputObject || !inputObject.spec) {
-        return null;
-    }
-    if (string_comparison_1.isEqual(inputObject.kind, constants_1.KubernetesWorkload.cronjob, string_comparison_1.StringComparer.OrdinalIgnoreCase)) {
-        try {
-            return inputObject.spec.jobTemplate.spec.template.spec.imagePullSecrets;
-        }
-        catch (ex) {
-            core.debug(`Fetching imagePullSecrets failed due to this error: ${JSON.stringify(ex)}`);
-            return null;
-        }
-    }
-    if (string_comparison_1.isEqual(inputObject.kind, constants_1.KubernetesWorkload.pod, string_comparison_1.StringComparer.OrdinalIgnoreCase)) {
-        return inputObject.spec.imagePullSecrets;
-    }
-    if (!!inputObject.spec.template && !!inputObject.spec.template.spec) {
-        return inputObject.spec.template.spec.imagePullSecrets;
-    }
-    return null;
-}
-function setImagePullSecrets(inputObject, newImagePullSecrets) {
-    if (!inputObject || !inputObject.spec || !newImagePullSecrets) {
-        return;
-    }
-    if (string_comparison_1.isEqual(inputObject.kind, constants_1.KubernetesWorkload.pod, string_comparison_1.StringComparer.OrdinalIgnoreCase)) {
-        inputObject.spec.imagePullSecrets = newImagePullSecrets;
-        return;
-    }
-    if (string_comparison_1.isEqual(inputObject.kind, constants_1.KubernetesWorkload.cronjob, string_comparison_1.StringComparer.OrdinalIgnoreCase)) {
-        try {
-            inputObject.spec.jobTemplate.spec.template.spec.imagePullSecrets = newImagePullSecrets;
-        }
-        catch (ex) {
-            core.debug(`Overriding imagePullSecrets failed due to this error: ${JSON.stringify(ex)}`);
-            //Do nothing
-        }
-        return;
-    }
-    if (!!inputObject.spec.template && !!inputObject.spec.template.spec) {
-        inputObject.spec.template.spec.imagePullSecrets = newImagePullSecrets;
-        return;
-    }
-    return;
-}
-function setSpecLabels(inputObject, newLabels) {
-    let specLabels = getSpecLabels(inputObject);
-    if (!!newLabels) {
-        specLabels = newLabels;
-    }
-}
-function getSpecSelectorLabels(inputObject) {
-    if (!!inputObject && !!inputObject.spec && !!inputObject.spec.selector) {
-        if (isServiceEntity(inputObject.kind)) {
-            return inputObject.spec.selector;
-        }
-        else {
-            return inputObject.spec.selector.matchLabels;
-        }
-    }
-    return null;
-}
-function setSpecSelectorLabels(inputObject, newLabels) {
-    let selectorLabels = getSpecSelectorLabels(inputObject);
-    if (!!selectorLabels) {
-        selectorLabels = newLabels;
-    }
-}
@@ -1,305 +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.fetchResource = exports.isServiceSelectorSubsetOfMatchLabel = exports.getServiceSelector = exports.getDeploymentMatchLabels = exports.getBlueGreenResourceName = exports.addBlueGreenLabelsAndAnnotations = exports.getNewBlueGreenObject = exports.createWorkloadsWithLabel = exports.isServiceRouted = exports.getManifestObjects = exports.getSuffix = exports.deleteObjects = exports.deleteWorkloadsAndServicesWithLabel = exports.deleteWorkloadsWithLabel = exports.routeBlueGreen = exports.isSMIRoute = exports.isIngressRoute = exports.isBlueGreenDeploymentStrategy = exports.STABLE_SUFFIX = exports.GREEN_SUFFIX = exports.BLUE_GREEN_VERSION_LABEL = exports.NONE_LABEL_VALUE = exports.GREEN_LABEL_VALUE = exports.BLUE_GREEN_DEPLOYMENT_STRATEGY = void 0;
-const core = require("@actions/core");
-const fs = require("fs");
-const yaml = require("js-yaml");
-const utility_1 = require("../utility");
-const constants_1 = require("../../constants");
-const fileHelper = require("../files-helper");
-const helper = require("../resource-object-utility");
-const TaskInputParameters = require("../../input-parameters");
-const service_blue_green_helper_1 = require("./service-blue-green-helper");
-const ingress_blue_green_helper_1 = require("./ingress-blue-green-helper");
-const smi_blue_green_helper_1 = require("./smi-blue-green-helper");
-exports.BLUE_GREEN_DEPLOYMENT_STRATEGY = 'BLUE-GREEN';
-exports.GREEN_LABEL_VALUE = 'green';
-exports.NONE_LABEL_VALUE = 'None';
-exports.BLUE_GREEN_VERSION_LABEL = 'k8s.deploy.color';
-exports.GREEN_SUFFIX = '-green';
-exports.STABLE_SUFFIX = '-stable';
-const INGRESS_ROUTE = 'INGRESS';
-const SMI_ROUTE = 'SMI';
-function isBlueGreenDeploymentStrategy() {
-    const deploymentStrategy = TaskInputParameters.deploymentStrategy;
-    return deploymentStrategy && deploymentStrategy.toUpperCase() === exports.BLUE_GREEN_DEPLOYMENT_STRATEGY;
-}
-exports.isBlueGreenDeploymentStrategy = isBlueGreenDeploymentStrategy;
-function isIngressRoute() {
-    const routeMethod = TaskInputParameters.routeMethod;
-    return routeMethod && routeMethod.toUpperCase() === INGRESS_ROUTE;
-}
-exports.isIngressRoute = isIngressRoute;
-function isSMIRoute() {
-    const routeMethod = TaskInputParameters.routeMethod;
-    return routeMethod && routeMethod.toUpperCase() === SMI_ROUTE;
-}
-exports.isSMIRoute = isSMIRoute;
-function routeBlueGreen(kubectl, inputManifestFiles) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // get buffer time
-        let bufferTime = parseInt(TaskInputParameters.versionSwitchBuffer);
-        //logging start of buffer time
-        let dateNow = new Date();
-        console.log(`Starting buffer time of ${bufferTime} minute(s) at ${dateNow.toISOString()}`);
-        // waiting
-        yield utility_1.sleep(bufferTime * 1000 * 60);
-        // logging end of buffer time
-        dateNow = new Date();
-        console.log(`Stopping buffer time of ${bufferTime} minute(s) at ${dateNow.toISOString()}`);
-        const manifestObjects = getManifestObjects(inputManifestFiles);
-        // routing to new deployments
-        if (isIngressRoute()) {
-            ingress_blue_green_helper_1.routeBlueGreenIngress(kubectl, exports.GREEN_LABEL_VALUE, manifestObjects.serviceNameMap, manifestObjects.ingressEntityList);
-        }
-        else if (isSMIRoute()) {
-            smi_blue_green_helper_1.routeBlueGreenSMI(kubectl, exports.GREEN_LABEL_VALUE, manifestObjects.serviceEntityList);
-        }
-        else {
-            service_blue_green_helper_1.routeBlueGreenService(kubectl, exports.GREEN_LABEL_VALUE, manifestObjects.serviceEntityList);
-        }
-    });
-}
-exports.routeBlueGreen = routeBlueGreen;
-function deleteWorkloadsWithLabel(kubectl, deleteLabel, deploymentEntityList) {
-    let resourcesToDelete = [];
-    deploymentEntityList.forEach((inputObject) => {
-        const name = inputObject.metadata.name;
-        const kind = inputObject.kind;
-        if (deleteLabel === exports.NONE_LABEL_VALUE) {
-            // if dellabel is none, deletes stable deployments
-            const resourceToDelete = { name: name, kind: kind };
-            resourcesToDelete.push(resourceToDelete);
-        }
-        else {
-            // if dellabel is not none, then deletes new green deployments
-            const resourceToDelete = { name: getBlueGreenResourceName(name, exports.GREEN_SUFFIX), kind: kind };
-            resourcesToDelete.push(resourceToDelete);
-        }
-    });
-    // deletes the deployments
-    deleteObjects(kubectl, resourcesToDelete);
-}
-exports.deleteWorkloadsWithLabel = deleteWorkloadsWithLabel;
-function deleteWorkloadsAndServicesWithLabel(kubectl, deleteLabel, deploymentEntityList, serviceEntityList) {
-    // need to delete services and deployments
-    const deletionEntitiesList = deploymentEntityList.concat(serviceEntityList);
-    let resourcesToDelete = [];
-    deletionEntitiesList.forEach((inputObject) => {
-        const name = inputObject.metadata.name;
-        const kind = inputObject.kind;
-        if (deleteLabel === exports.NONE_LABEL_VALUE) {
-            // if not dellabel, delete stable objects
-            const resourceToDelete = { name: name, kind: kind };
-            resourcesToDelete.push(resourceToDelete);
-        }
-        else {
-            // else delete green labels
-            const resourceToDelete = { name: getBlueGreenResourceName(name, exports.GREEN_SUFFIX), kind: kind };
-            resourcesToDelete.push(resourceToDelete);
-        }
-    });
-    deleteObjects(kubectl, resourcesToDelete);
-}
-exports.deleteWorkloadsAndServicesWithLabel = deleteWorkloadsAndServicesWithLabel;
-function deleteObjects(kubectl, deleteList) {
-    // delete services and deployments
-    deleteList.forEach((delObject) => {
-        try {
-            const result = kubectl.delete([delObject.kind, delObject.name]);
-            utility_1.checkForErrors([result]);
-        }
-        catch (ex) {
-            // Ignore failures of delete if doesn't exist
-        }
-    });
-}
-exports.deleteObjects = deleteObjects;
-function getSuffix(label) {
-    if (label === exports.GREEN_LABEL_VALUE) {
-        return exports.GREEN_SUFFIX;
-    }
-    else {
-        return '';
-    }
-}
-exports.getSuffix = getSuffix;
-// other common functions
-function getManifestObjects(filePaths) {
-    const deploymentEntityList = [];
-    const routedServiceEntityList = [];
-    const unroutedServiceEntityList = [];
-    const ingressEntityList = [];
-    const otherEntitiesList = [];
-    let serviceNameMap = new Map();
-    filePaths.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            if (!!inputObject) {
-                const kind = inputObject.kind;
-                const name = inputObject.metadata.name;
-                if (helper.isDeploymentEntity(kind)) {
-                    deploymentEntityList.push(inputObject);
-                }
-                else if (helper.isServiceEntity(kind)) {
-                    if (isServiceRouted(inputObject, deploymentEntityList)) {
-                        routedServiceEntityList.push(inputObject);
-                        serviceNameMap.set(name, getBlueGreenResourceName(name, exports.GREEN_SUFFIX));
-                    }
-                    else {
-                        unroutedServiceEntityList.push(inputObject);
-                    }
-                }
-                else if (helper.isIngressEntity(kind)) {
-                    ingressEntityList.push(inputObject);
-                }
-                else {
-                    otherEntitiesList.push(inputObject);
-                }
-            }
-        });
-    });
-    return { serviceEntityList: routedServiceEntityList, serviceNameMap: serviceNameMap, unroutedServiceEntityList: unroutedServiceEntityList, deploymentEntityList: deploymentEntityList, ingressEntityList: ingressEntityList, otherObjects: otherEntitiesList };
-}
-exports.getManifestObjects = getManifestObjects;
-function isServiceRouted(serviceObject, deploymentEntityList) {
-    let shouldBeRouted = false;
-    const serviceSelector = getServiceSelector(serviceObject);
-    if (!!serviceSelector) {
-        if (deploymentEntityList.some((depObject) => {
-            // finding if there is a deployment in the given manifests the service targets
-            const matchLabels = getDeploymentMatchLabels(depObject);
-            return (!!matchLabels && isServiceSelectorSubsetOfMatchLabel(serviceSelector, matchLabels));
-        })) {
-            shouldBeRouted = true;
-        }
-    }
-    return shouldBeRouted;
-}
-exports.isServiceRouted = isServiceRouted;
-function createWorkloadsWithLabel(kubectl, deploymentObjectList, nextLabel) {
-    const newObjectsList = [];
-    deploymentObjectList.forEach((inputObject) => {
-        // creating deployment with label
-        const newBlueGreenObject = getNewBlueGreenObject(inputObject, nextLabel);
-        core.debug('New blue-green object is: ' + JSON.stringify(newBlueGreenObject));
-        newObjectsList.push(newBlueGreenObject);
-    });
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    const result = kubectl.apply(manifestFiles);
-    return { 'result': result, 'newFilePaths': manifestFiles };
-}
-exports.createWorkloadsWithLabel = createWorkloadsWithLabel;
-function getNewBlueGreenObject(inputObject, labelValue) {
-    const newObject = JSON.parse(JSON.stringify(inputObject));
-    // Updating name only if label is green label is given
-    if (labelValue === exports.GREEN_LABEL_VALUE) {
-        newObject.metadata.name = getBlueGreenResourceName(inputObject.metadata.name, exports.GREEN_SUFFIX);
-    }
-    // Adding labels and annotations
-    addBlueGreenLabelsAndAnnotations(newObject, labelValue);
-    return newObject;
-}
-exports.getNewBlueGreenObject = getNewBlueGreenObject;
-function addBlueGreenLabelsAndAnnotations(inputObject, labelValue) {
-    //creating the k8s.deploy.color label
-    const newLabels = new Map();
-    newLabels[exports.BLUE_GREEN_VERSION_LABEL] = labelValue;
-    // updating object labels and selector labels
-    helper.updateObjectLabels(inputObject, newLabels, false);
-    helper.updateSelectorLabels(inputObject, newLabels, false);
-    // updating spec labels if it is a service
-    if (!helper.isServiceEntity(inputObject.kind)) {
-        helper.updateSpecLabels(inputObject, newLabels, false);
-    }
-}
-exports.addBlueGreenLabelsAndAnnotations = addBlueGreenLabelsAndAnnotations;
-function getBlueGreenResourceName(name, suffix) {
-    return `${name}${suffix}`;
-}
-exports.getBlueGreenResourceName = getBlueGreenResourceName;
-function getDeploymentMatchLabels(deploymentObject) {
-    if (!!deploymentObject && deploymentObject.kind.toUpperCase() == constants_1.KubernetesWorkload.pod.toUpperCase() && !!deploymentObject.metadata && !!deploymentObject.metadata.labels) {
-        return deploymentObject.metadata.labels;
-    }
-    else if (!!deploymentObject && deploymentObject.spec && deploymentObject.spec.selector && deploymentObject.spec.selector.matchLabels) {
-        return deploymentObject.spec.selector.matchLabels;
-    }
-    return null;
-}
-exports.getDeploymentMatchLabels = getDeploymentMatchLabels;
-function getServiceSelector(serviceObject) {
-    if (!!serviceObject && serviceObject.spec && serviceObject.spec.selector) {
-        return serviceObject.spec.selector;
-    }
-    else
-        return null;
-}
-exports.getServiceSelector = getServiceSelector;
-function isServiceSelectorSubsetOfMatchLabel(serviceSelector, matchLabels) {
-    let serviceSelectorMap = new Map();
-    let matchLabelsMap = new Map();
-    JSON.parse(JSON.stringify(serviceSelector), (key, value) => {
-        serviceSelectorMap.set(key, value);
-    });
-    JSON.parse(JSON.stringify(matchLabels), (key, value) => {
-        matchLabelsMap.set(key, value);
-    });
-    let isMatch = true;
-    serviceSelectorMap.forEach((value, key) => {
-        if (!!key && (!matchLabelsMap.has(key) || matchLabelsMap.get(key)) != value) {
-            isMatch = false;
-        }
-    });
-    return isMatch;
-}
-exports.isServiceSelectorSubsetOfMatchLabel = isServiceSelectorSubsetOfMatchLabel;
-function fetchResource(kubectl, kind, name) {
-    const result = kubectl.getResource(kind, name);
-    if (result == null || !!result.stderr) {
-        return null;
-    }
-    if (!!result.stdout) {
-        const resource = JSON.parse(result.stdout);
-        try {
-            UnsetsClusterSpecficDetails(resource);
-            return resource;
-        }
-        catch (ex) {
-            core.debug('Exception occurred while Parsing ' + resource + ' in Json object');
-            core.debug(`Exception:${ex}`);
-        }
-    }
-    return null;
-}
-exports.fetchResource = fetchResource;
-function UnsetsClusterSpecficDetails(resource) {
-    if (resource == null) {
-        return;
-    }
-    // Unsets the cluster specific details in the object
-    if (!!resource) {
-        const metadata = resource.metadata;
-        const status = resource.status;
-        if (!!metadata) {
-            const newMetadata = {
-                'annotations': metadata.annotations,
-                'labels': metadata.labels,
-                'name': metadata.name
-            };
-            resource.metadata = newMetadata;
-        }
-        if (!!status) {
-            resource.status = {};
-        }
-    }
-}
@@ -1,187 +0,0 @@
-'use strict';
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.getStableResourceName = exports.getBaselineResourceName = exports.getCanaryResourceName = exports.isSMICanaryStrategy = exports.isCanaryDeploymentStrategy = exports.fetchResource = exports.fetchCanaryResource = exports.getNewCanaryResource = exports.getNewBaselineResource = exports.getStableResource = exports.isResourceMarkedAsStable = exports.markResourceAsStable = exports.deleteCanaryDeployment = exports.STABLE_LABEL_VALUE = exports.STABLE_SUFFIX = exports.CANARY_LABEL_VALUE = exports.BASELINE_LABEL_VALUE = exports.CANARY_VERSION_LABEL = exports.TRAFFIC_SPLIT_STRATEGY = exports.CANARY_DEPLOYMENT_STRATEGY = void 0;
-const fs = require("fs");
-const yaml = require("js-yaml");
-const core = require("@actions/core");
-const TaskInputParameters = require("../../input-parameters");
-const helper = require("../resource-object-utility");
-const constants_1 = require("../../constants");
-const string_comparison_1 = require("../string-comparison");
-const utility_1 = require("../utility");
-const utils = require("../manifest-utilities");
-exports.CANARY_DEPLOYMENT_STRATEGY = 'CANARY';
-exports.TRAFFIC_SPLIT_STRATEGY = 'SMI';
-exports.CANARY_VERSION_LABEL = 'workflow/version';
-const BASELINE_SUFFIX = '-baseline';
-exports.BASELINE_LABEL_VALUE = 'baseline';
-const CANARY_SUFFIX = '-canary';
-exports.CANARY_LABEL_VALUE = 'canary';
-exports.STABLE_SUFFIX = '-stable';
-exports.STABLE_LABEL_VALUE = 'stable';
-function deleteCanaryDeployment(kubectl, manifestFilePaths, includeServices) {
-    // get manifest files
-    const inputManifestFiles = utils.getManifestFiles(manifestFilePaths);
-    if (inputManifestFiles == null || inputManifestFiles.length == 0) {
-        throw new Error('ManifestFileNotFound');
-    }
-    // create delete cmd prefix
-    cleanUpCanary(kubectl, inputManifestFiles, includeServices);
-}
-exports.deleteCanaryDeployment = deleteCanaryDeployment;
-function markResourceAsStable(inputObject) {
-    if (isResourceMarkedAsStable(inputObject)) {
-        return inputObject;
-    }
-    const newObject = JSON.parse(JSON.stringify(inputObject));
-    // Adding labels and annotations.
-    addCanaryLabelsAndAnnotations(newObject, exports.STABLE_LABEL_VALUE);
-    core.debug("Added stable label: " + JSON.stringify(newObject));
-    return newObject;
-}
-exports.markResourceAsStable = markResourceAsStable;
-function isResourceMarkedAsStable(inputObject) {
-    return inputObject &&
-        inputObject.metadata &&
-        inputObject.metadata.labels &&
-        inputObject.metadata.labels[exports.CANARY_VERSION_LABEL] == exports.STABLE_LABEL_VALUE;
-}
-exports.isResourceMarkedAsStable = isResourceMarkedAsStable;
-function getStableResource(inputObject) {
-    var replicaCount = isSpecContainsReplicas(inputObject.kind) ? inputObject.metadata.replicas : 0;
-    return getNewCanaryObject(inputObject, replicaCount, exports.STABLE_LABEL_VALUE);
-}
-exports.getStableResource = getStableResource;
-function getNewBaselineResource(stableObject, replicas) {
-    return getNewCanaryObject(stableObject, replicas, exports.BASELINE_LABEL_VALUE);
-}
-exports.getNewBaselineResource = getNewBaselineResource;
-function getNewCanaryResource(inputObject, replicas) {
-    return getNewCanaryObject(inputObject, replicas, exports.CANARY_LABEL_VALUE);
-}
-exports.getNewCanaryResource = getNewCanaryResource;
-function fetchCanaryResource(kubectl, kind, name) {
-    return fetchResource(kubectl, kind, getCanaryResourceName(name));
-}
-exports.fetchCanaryResource = fetchCanaryResource;
-function fetchResource(kubectl, kind, name) {
-    const result = kubectl.getResource(kind, name);
-    if (result == null || !!result.stderr) {
-        return null;
-    }
-    if (!!result.stdout) {
-        const resource = JSON.parse(result.stdout);
-        try {
-            UnsetsClusterSpecficDetails(resource);
-            return resource;
-        }
-        catch (ex) {
-            core.debug('Exception occurred while Parsing ' + resource + ' in Json object');
-            core.debug(`Exception:${ex}`);
-        }
-    }
-    return null;
-}
-exports.fetchResource = fetchResource;
-function isCanaryDeploymentStrategy() {
-    const deploymentStrategy = TaskInputParameters.deploymentStrategy;
-    return deploymentStrategy && deploymentStrategy.toUpperCase() === exports.CANARY_DEPLOYMENT_STRATEGY;
-}
-exports.isCanaryDeploymentStrategy = isCanaryDeploymentStrategy;
-function isSMICanaryStrategy() {
-    const deploymentStrategy = TaskInputParameters.trafficSplitMethod;
-    return isCanaryDeploymentStrategy() && deploymentStrategy && deploymentStrategy.toUpperCase() === exports.TRAFFIC_SPLIT_STRATEGY;
-}
-exports.isSMICanaryStrategy = isSMICanaryStrategy;
-function getCanaryResourceName(name) {
-    return name + CANARY_SUFFIX;
-}
-exports.getCanaryResourceName = getCanaryResourceName;
-function getBaselineResourceName(name) {
-    return name + BASELINE_SUFFIX;
-}
-exports.getBaselineResourceName = getBaselineResourceName;
-function getStableResourceName(name) {
-    return name + exports.STABLE_SUFFIX;
-}
-exports.getStableResourceName = getStableResourceName;
-function UnsetsClusterSpecficDetails(resource) {
-    if (resource == null) {
-        return;
-    }
-    // Unsets the cluster specific details in the object
-    if (!!resource) {
-        const metadata = resource.metadata;
-        const status = resource.status;
-        if (!!metadata) {
-            const newMetadata = {
-                'annotations': metadata.annotations,
-                'labels': metadata.labels,
-                'name': metadata.name
-            };
-            resource.metadata = newMetadata;
-        }
-        if (!!status) {
-            resource.status = {};
-        }
-    }
-}
-function getNewCanaryObject(inputObject, replicas, type) {
-    const newObject = JSON.parse(JSON.stringify(inputObject));
-    // Updating name
-    if (type === exports.CANARY_LABEL_VALUE) {
-        newObject.metadata.name = getCanaryResourceName(inputObject.metadata.name);
-    }
-    else if (type === exports.STABLE_LABEL_VALUE) {
-        newObject.metadata.name = getStableResourceName(inputObject.metadata.name);
-    }
-    else {
-        newObject.metadata.name = getBaselineResourceName(inputObject.metadata.name);
-    }
-    // Adding labels and annotations.
-    addCanaryLabelsAndAnnotations(newObject, type);
-    // Updating no. of replicas
-    if (isSpecContainsReplicas(newObject.kind)) {
-        newObject.spec.replicas = replicas;
-    }
-    return newObject;
-}
-function isSpecContainsReplicas(kind) {
-    return !string_comparison_1.isEqual(kind, constants_1.KubernetesWorkload.pod, string_comparison_1.StringComparer.OrdinalIgnoreCase) &&
-        !string_comparison_1.isEqual(kind, constants_1.KubernetesWorkload.daemonSet, string_comparison_1.StringComparer.OrdinalIgnoreCase) &&
-        !helper.isServiceEntity(kind);
-}
-function addCanaryLabelsAndAnnotations(inputObject, type) {
-    const newLabels = new Map();
-    newLabels[exports.CANARY_VERSION_LABEL] = type;
-    helper.updateObjectLabels(inputObject, newLabels, false);
-    helper.updateObjectAnnotations(inputObject, newLabels, false);
-    helper.updateSelectorLabels(inputObject, newLabels, false);
-    if (!helper.isServiceEntity(inputObject.kind)) {
-        helper.updateSpecLabels(inputObject, newLabels, false);
-    }
-}
-function cleanUpCanary(kubectl, files, includeServices) {
-    var deleteObject = function (kind, name) {
-        try {
-            const result = kubectl.delete([kind, name]);
-            utility_1.checkForErrors([result]);
-        }
-        catch (ex) {
-            // Ignore failures of delete if doesn't exist
-        }
-    };
-    files.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            const name = inputObject.metadata.name;
-            const kind = inputObject.kind;
-            if (helper.isDeploymentEntity(kind) || (includeServices && helper.isServiceEntity(kind))) {
-                const canaryObjectName = getCanaryResourceName(name);
-                const baselineObjectName = getBaselineResourceName(name);
-                deleteObject(kind, canaryObjectName);
-                deleteObject(kind, baselineObjectName);
-            }
-        });
-    });
-}
@@ -1,148 +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.getManifestFiles = exports.deploy = void 0;
-const fs = require("fs");
-const core = require("@actions/core");
-const yaml = require("js-yaml");
-const canaryDeploymentHelper = require("./canary-deployment-helper");
-const KubernetesObjectUtility = require("../resource-object-utility");
-const TaskInputParameters = require("../../input-parameters");
-const models = require("../../constants");
-const fileHelper = require("../files-helper");
-const utils = require("../manifest-utilities");
-const KubernetesManifestUtility = require("../manifest-stability-utility");
-const KubernetesConstants = require("../../constants");
-const manifest_utilities_1 = require("../manifest-utilities");
-const pod_canary_deployment_helper_1 = require("./pod-canary-deployment-helper");
-const smi_canary_deployment_helper_1 = require("./smi-canary-deployment-helper");
-const utility_1 = require("../utility");
-const blue_green_helper_1 = require("./blue-green-helper");
-const service_blue_green_helper_1 = require("./service-blue-green-helper");
-const ingress_blue_green_helper_1 = require("./ingress-blue-green-helper");
-const smi_blue_green_helper_1 = require("./smi-blue-green-helper");
-function deploy(kubectl, manifestFilePaths, deploymentStrategy) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // get manifest files
-        let inputManifestFiles = manifest_utilities_1.getUpdatedManifestFiles(manifestFilePaths);
-        // deployment
-        const deployedManifestFiles = deployManifests(inputManifestFiles, kubectl, isCanaryDeploymentStrategy(deploymentStrategy), blue_green_helper_1.isBlueGreenDeploymentStrategy());
-        // check manifest stability
-        const resourceTypes = KubernetesObjectUtility.getResources(deployedManifestFiles, models.deploymentTypes.concat([KubernetesConstants.DiscoveryAndLoadBalancerResource.service]));
-        yield checkManifestStability(kubectl, resourceTypes);
-        // route blue-green deployments
-        if (blue_green_helper_1.isBlueGreenDeploymentStrategy()) {
-            yield blue_green_helper_1.routeBlueGreen(kubectl, inputManifestFiles);
-        }
-        // print ingress resources
-        const ingressResources = KubernetesObjectUtility.getResources(deployedManifestFiles, [KubernetesConstants.DiscoveryAndLoadBalancerResource.ingress]);
-        ingressResources.forEach(ingressResource => {
-            kubectl.getResource(KubernetesConstants.DiscoveryAndLoadBalancerResource.ingress, ingressResource.name);
-        });
-        // annotate resources
-        let allPods;
-        try {
-            allPods = JSON.parse((kubectl.getAllPods()).stdout);
-        }
-        catch (e) {
-            core.debug("Unable to parse pods; Error: " + e);
-        }
-        annotateResources(deployedManifestFiles, kubectl, resourceTypes, allPods);
-    });
-}
-exports.deploy = deploy;
-function getManifestFiles(manifestFilePaths) {
-    const files = utils.getManifestFiles(manifestFilePaths);
-    if (files == null || files.length === 0) {
-        throw new Error(`ManifestFileNotFound : ${manifestFilePaths}`);
-    }
-    return files;
-}
-exports.getManifestFiles = getManifestFiles;
-function deployManifests(files, kubectl, isCanaryDeploymentStrategy, isBlueGreenDeploymentStrategy) {
-    let result;
-    if (isCanaryDeploymentStrategy) {
-        let canaryDeploymentOutput;
-        if (canaryDeploymentHelper.isSMICanaryStrategy()) {
-            canaryDeploymentOutput = smi_canary_deployment_helper_1.deploySMICanary(kubectl, files);
-        }
-        else {
-            canaryDeploymentOutput = pod_canary_deployment_helper_1.deployPodCanary(kubectl, files);
-        }
-        result = canaryDeploymentOutput.result;
-        files = canaryDeploymentOutput.newFilePaths;
-    }
-    else if (isBlueGreenDeploymentStrategy) {
-        let blueGreenDeploymentOutput;
-        if (blue_green_helper_1.isIngressRoute()) {
-            blueGreenDeploymentOutput = ingress_blue_green_helper_1.deployBlueGreenIngress(kubectl, files);
-        }
-        else if (blue_green_helper_1.isSMIRoute()) {
-            blueGreenDeploymentOutput = smi_blue_green_helper_1.deployBlueGreenSMI(kubectl, files);
-        }
-        else {
-            blueGreenDeploymentOutput = service_blue_green_helper_1.deployBlueGreenService(kubectl, files);
-        }
-        result = blueGreenDeploymentOutput.result;
-        files = blueGreenDeploymentOutput.newFilePaths;
-    }
-    else {
-        if (canaryDeploymentHelper.isSMICanaryStrategy()) {
-            const updatedManifests = appendStableVersionLabelToResource(files, kubectl);
-            result = kubectl.apply(updatedManifests, TaskInputParameters.forceDeployment);
-        }
-        else {
-            result = kubectl.apply(files, TaskInputParameters.forceDeployment);
-        }
-    }
-    utility_1.checkForErrors([result]);
-    return files;
-}
-function appendStableVersionLabelToResource(files, kubectl) {
-    const manifestFiles = [];
-    const newObjectsList = [];
-    files.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            const kind = inputObject.kind;
-            if (KubernetesObjectUtility.isDeploymentEntity(kind)) {
-                const updatedObject = canaryDeploymentHelper.markResourceAsStable(inputObject);
-                newObjectsList.push(updatedObject);
-            }
-            else {
-                manifestFiles.push(filePath);
-            }
-        });
-    });
-    const updatedManifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    manifestFiles.push(...updatedManifestFiles);
-    return manifestFiles;
-}
-function checkManifestStability(kubectl, resources) {
-    return __awaiter(this, void 0, void 0, function* () {
-        yield KubernetesManifestUtility.checkManifestStability(kubectl, resources);
-    });
-}
-function annotateResources(files, kubectl, resourceTypes, allPods) {
-    const annotateResults = [];
-    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, allPods)
-                .forEach(execResult => annotateResults.push(execResult));
-        }
-    });
-    utility_1.checkForErrors(annotateResults, true);
-}
-function isCanaryDeploymentStrategy(deploymentStrategy) {
-    return deploymentStrategy != null && deploymentStrategy.toUpperCase() === canaryDeploymentHelper.CANARY_DEPLOYMENT_STRATEGY.toUpperCase();
-}
@@ -1,158 +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.updateIngressBackend = exports.getUpdatedBlueGreenIngress = exports.validateIngressesState = exports.routeBlueGreenIngress = exports.rejectBlueGreenIngress = exports.promoteBlueGreenIngress = exports.deployBlueGreenIngress = void 0;
-const core = require("@actions/core");
-const fileHelper = require("../files-helper");
-const blue_green_helper_1 = require("./blue-green-helper");
-const blue_green_helper_2 = require("./blue-green-helper");
-const BACKEND = 'BACKEND';
-function deployBlueGreenIngress(kubectl, filePaths) {
-    // get all kubernetes objects defined in manifest files
-    const manifestObjects = blue_green_helper_1.getManifestObjects(filePaths);
-    // create deployments with green label value
-    const result = blue_green_helper_1.createWorkloadsWithLabel(kubectl, manifestObjects.deploymentEntityList, blue_green_helper_2.GREEN_LABEL_VALUE);
-    // create new services and other objects 
-    let newObjectsList = [];
-    manifestObjects.serviceEntityList.forEach(inputObject => {
-        const newBlueGreenObject = blue_green_helper_1.getNewBlueGreenObject(inputObject, blue_green_helper_2.GREEN_LABEL_VALUE);
-        ;
-        core.debug('New blue-green object is: ' + JSON.stringify(newBlueGreenObject));
-        newObjectsList.push(newBlueGreenObject);
-    });
-    newObjectsList = newObjectsList.concat(manifestObjects.otherObjects).concat(manifestObjects.unroutedServiceEntityList);
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    kubectl.apply(manifestFiles);
-    // return results to check for manifest stability
-    return result;
-}
-exports.deployBlueGreenIngress = deployBlueGreenIngress;
-function promoteBlueGreenIngress(kubectl, manifestObjects) {
-    return __awaiter(this, void 0, void 0, function* () {
-        //checking if anything to promote
-        if (!validateIngressesState(kubectl, manifestObjects.ingressEntityList, manifestObjects.serviceNameMap)) {
-            throw ('NotInPromoteStateIngress');
-        }
-        // create stable deployments with new configuration
-        const result = blue_green_helper_1.createWorkloadsWithLabel(kubectl, manifestObjects.deploymentEntityList, blue_green_helper_2.NONE_LABEL_VALUE);
-        // create stable services with new configuration
-        const newObjectsList = [];
-        manifestObjects.serviceEntityList.forEach((inputObject) => {
-            const newBlueGreenObject = blue_green_helper_1.getNewBlueGreenObject(inputObject, blue_green_helper_2.NONE_LABEL_VALUE);
-            core.debug('New blue-green object is: ' + JSON.stringify(newBlueGreenObject));
-            newObjectsList.push(newBlueGreenObject);
-        });
-        const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-        kubectl.apply(manifestFiles);
-        // returning deployments to check for rollout stability
-        return result;
-    });
-}
-exports.promoteBlueGreenIngress = promoteBlueGreenIngress;
-function rejectBlueGreenIngress(kubectl, filePaths) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // get all kubernetes objects defined in manifest files
-        const manifestObjects = blue_green_helper_1.getManifestObjects(filePaths);
-        // routing ingress to stables services
-        routeBlueGreenIngress(kubectl, null, manifestObjects.serviceNameMap, manifestObjects.ingressEntityList);
-        // deleting green services and deployments
-        blue_green_helper_1.deleteWorkloadsAndServicesWithLabel(kubectl, blue_green_helper_2.GREEN_LABEL_VALUE, manifestObjects.deploymentEntityList, manifestObjects.serviceEntityList);
-    });
-}
-exports.rejectBlueGreenIngress = rejectBlueGreenIngress;
-function routeBlueGreenIngress(kubectl, nextLabel, serviceNameMap, ingressEntityList) {
-    let newObjectsList = [];
-    if (!nextLabel) {
-        newObjectsList = newObjectsList.concat(ingressEntityList);
-    }
-    else {
-        ingressEntityList.forEach((inputObject) => {
-            if (isIngressRouted(inputObject, serviceNameMap)) {
-                const newBlueGreenIngressObject = getUpdatedBlueGreenIngress(inputObject, serviceNameMap, blue_green_helper_2.GREEN_LABEL_VALUE);
-                newObjectsList.push(newBlueGreenIngressObject);
-            }
-            else {
-                newObjectsList.push(inputObject);
-            }
-        });
-    }
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    kubectl.apply(manifestFiles);
-}
-exports.routeBlueGreenIngress = routeBlueGreenIngress;
-function validateIngressesState(kubectl, ingressEntityList, serviceNameMap) {
-    let areIngressesTargetingNewServices = true;
-    ingressEntityList.forEach((inputObject) => {
-        if (isIngressRouted(inputObject, serviceNameMap)) {
-            //querying existing ingress
-            let existingIngress = blue_green_helper_1.fetchResource(kubectl, inputObject.kind, inputObject.metadata.name);
-            if (!!existingIngress) {
-                let currentLabel;
-                // checking its label
-                try {
-                    currentLabel = existingIngress.metadata.labels[blue_green_helper_2.BLUE_GREEN_VERSION_LABEL];
-                }
-                catch (_a) {
-                    // if no label exists, then not an ingress targeting green deployments
-                    areIngressesTargetingNewServices = false;
-                }
-                if (currentLabel != blue_green_helper_2.GREEN_LABEL_VALUE) {
-                    // if not green label, then wrong configuration
-                    areIngressesTargetingNewServices = false;
-                }
-            }
-            else {
-                // no ingress at all, so nothing to promote
-                areIngressesTargetingNewServices = false;
-            }
-        }
-    });
-    return areIngressesTargetingNewServices;
-}
-exports.validateIngressesState = validateIngressesState;
-function isIngressRouted(ingressObject, serviceNameMap) {
-    let isIngressRouted = false;
-    // sees if ingress targets a service in the given manifests
-    JSON.parse(JSON.stringify(ingressObject), (key, value) => {
-        if (key === 'serviceName' && serviceNameMap.has(value)) {
-            isIngressRouted = true;
-        }
-        return value;
-    });
-    return isIngressRouted;
-}
-function getUpdatedBlueGreenIngress(inputObject, serviceNameMap, type) {
-    if (!type) {
-        // returning original with no modifications
-        return inputObject;
-    }
-    const newObject = JSON.parse(JSON.stringify(inputObject));
-    // adding green labels and values
-    blue_green_helper_1.addBlueGreenLabelsAndAnnotations(newObject, type);
-    // Updating ingress labels
-    let finalObject = updateIngressBackend(newObject, serviceNameMap);
-    return finalObject;
-}
-exports.getUpdatedBlueGreenIngress = getUpdatedBlueGreenIngress;
-function updateIngressBackend(inputObject, serviceNameMap) {
-    inputObject = JSON.parse(JSON.stringify(inputObject), (key, value) => {
-        if (key.toUpperCase() === BACKEND) {
-            let serviceName = value.serviceName;
-            if (serviceNameMap.has(serviceName)) {
-                // updating service name with corresponding bluegreen name only if service is provied in given manifests
-                value.serviceName = serviceNameMap.get(serviceName);
-            }
-        }
-        return value;
-    });
-    return inputObject;
-}
-exports.updateIngressBackend = updateIngressBackend;
@@ -1,58 +0,0 @@
-'use strict';
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.deployPodCanary = void 0;
-const core = require("@actions/core");
-const fs = require("fs");
-const yaml = require("js-yaml");
-const TaskInputParameters = require("../../input-parameters");
-const fileHelper = require("../files-helper");
-const helper = require("../resource-object-utility");
-const canaryDeploymentHelper = require("./canary-deployment-helper");
-function deployPodCanary(kubectl, filePaths) {
-    const newObjectsList = [];
-    const percentage = parseInt(TaskInputParameters.canaryPercentage);
-    filePaths.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            const name = inputObject.metadata.name;
-            const kind = inputObject.kind;
-            if (helper.isDeploymentEntity(kind)) {
-                core.debug('Calculating replica count for canary');
-                const canaryReplicaCount = calculateReplicaCountForCanary(inputObject, percentage);
-                core.debug('Replica count is ' + canaryReplicaCount);
-                // Get stable object
-                core.debug('Querying stable object');
-                const stableObject = canaryDeploymentHelper.fetchResource(kubectl, kind, name);
-                if (!stableObject) {
-                    core.debug('Stable object not found. Creating only canary object');
-                    // If stable object not found, create canary deployment.
-                    const newCanaryObject = canaryDeploymentHelper.getNewCanaryResource(inputObject, canaryReplicaCount);
-                    core.debug('New canary object is: ' + JSON.stringify(newCanaryObject));
-                    newObjectsList.push(newCanaryObject);
-                }
-                else {
-                    core.debug('Stable object found. Creating canary and baseline objects');
-                    // If canary object not found, create canary and baseline object.
-                    const newCanaryObject = canaryDeploymentHelper.getNewCanaryResource(inputObject, canaryReplicaCount);
-                    const newBaselineObject = canaryDeploymentHelper.getNewBaselineResource(stableObject, canaryReplicaCount);
-                    core.debug('New canary object is: ' + JSON.stringify(newCanaryObject));
-                    core.debug('New baseline object is: ' + JSON.stringify(newBaselineObject));
-                    newObjectsList.push(newCanaryObject);
-                    newObjectsList.push(newBaselineObject);
-                }
-            }
-            else {
-                // Updating non deployment entity as it is.
-                newObjectsList.push(inputObject);
-            }
-        });
-    });
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    const result = kubectl.apply(manifestFiles, TaskInputParameters.forceDeployment);
-    return { 'result': result, 'newFilePaths': manifestFiles };
-}
-exports.deployPodCanary = deployPodCanary;
-function calculateReplicaCountForCanary(inputObject, percentage) {
-    const inputReplicaCount = helper.getReplicaCount(inputObject);
-    return Math.round((inputReplicaCount * percentage) / 100);
-}
@@ -1,97 +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.getServiceSpecLabel = exports.validateServicesState = exports.routeBlueGreenService = exports.rejectBlueGreenService = exports.promoteBlueGreenService = exports.deployBlueGreenService = void 0;
-const fileHelper = require("../files-helper");
-const blue_green_helper_1 = require("./blue-green-helper");
-const blue_green_helper_2 = require("./blue-green-helper");
-function deployBlueGreenService(kubectl, filePaths) {
-    // get all kubernetes objects defined in manifest files
-    const manifestObjects = blue_green_helper_1.getManifestObjects(filePaths);
-    // create deployments with green label value
-    const result = blue_green_helper_1.createWorkloadsWithLabel(kubectl, manifestObjects.deploymentEntityList, blue_green_helper_2.GREEN_LABEL_VALUE);
-    // create other non deployment and non service entities
-    const newObjectsList = manifestObjects.otherObjects.concat(manifestObjects.ingressEntityList).concat(manifestObjects.unroutedServiceEntityList);
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    kubectl.apply(manifestFiles);
-    // returning deployment details to check for rollout stability
-    return result;
-}
-exports.deployBlueGreenService = deployBlueGreenService;
-function promoteBlueGreenService(kubectl, manifestObjects) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // checking if services are in the right state ie. targeting green deployments
-        if (!validateServicesState(kubectl, manifestObjects.serviceEntityList)) {
-            throw ('NotInPromoteState');
-        }
-        // creating stable deployments with new configurations
-        const result = blue_green_helper_1.createWorkloadsWithLabel(kubectl, manifestObjects.deploymentEntityList, blue_green_helper_2.NONE_LABEL_VALUE);
-        // returning deployment details to check for rollout stability
-        return result;
-    });
-}
-exports.promoteBlueGreenService = promoteBlueGreenService;
-function rejectBlueGreenService(kubectl, filePaths) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // get all kubernetes objects defined in manifest files
-        const manifestObjects = blue_green_helper_1.getManifestObjects(filePaths);
-        // routing to stable objects
-        routeBlueGreenService(kubectl, blue_green_helper_2.NONE_LABEL_VALUE, manifestObjects.serviceEntityList);
-        // deleting the new deployments with green suffix
-        blue_green_helper_1.deleteWorkloadsWithLabel(kubectl, blue_green_helper_2.GREEN_LABEL_VALUE, manifestObjects.deploymentEntityList);
-    });
-}
-exports.rejectBlueGreenService = rejectBlueGreenService;
-function routeBlueGreenService(kubectl, nextLabel, serviceEntityList) {
-    const newObjectsList = [];
-    serviceEntityList.forEach((serviceObject) => {
-        const newBlueGreenServiceObject = getUpdatedBlueGreenService(serviceObject, nextLabel);
-        newObjectsList.push(newBlueGreenServiceObject);
-    });
-    // configures the services
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    kubectl.apply(manifestFiles);
-}
-exports.routeBlueGreenService = routeBlueGreenService;
-// adding green labels to configure existing service
-function getUpdatedBlueGreenService(inputObject, labelValue) {
-    const newObject = JSON.parse(JSON.stringify(inputObject));
-    // Adding labels and annotations.
-    blue_green_helper_1.addBlueGreenLabelsAndAnnotations(newObject, labelValue);
-    return newObject;
-}
-function validateServicesState(kubectl, serviceEntityList) {
-    let areServicesGreen = true;
-    serviceEntityList.forEach((serviceObject) => {
-        // finding the existing routed service
-        const existingService = blue_green_helper_1.fetchResource(kubectl, serviceObject.kind, serviceObject.metadata.name);
-        if (!!existingService) {
-            let currentLabel = getServiceSpecLabel(existingService);
-            if (currentLabel != blue_green_helper_2.GREEN_LABEL_VALUE) {
-                // service should be targeting deployments with green label
-                areServicesGreen = false;
-            }
-        }
-        else {
-            // service targeting deployment doesn't exist
-            areServicesGreen = false;
-        }
-    });
-    return areServicesGreen;
-}
-exports.validateServicesState = validateServicesState;
-function getServiceSpecLabel(inputObject) {
-    if (!!inputObject && inputObject.spec && inputObject.spec.selector && inputObject.spec.selector[blue_green_helper_2.BLUE_GREEN_VERSION_LABEL]) {
-        return inputObject.spec.selector[blue_green_helper_2.BLUE_GREEN_VERSION_LABEL];
-    }
-    return '';
-}
-exports.getServiceSpecLabel = getServiceSpecLabel;
@@ -1,184 +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.cleanupSMI = exports.validateTrafficSplitsState = exports.routeBlueGreenSMI = exports.getSMIServiceResource = exports.setupSMI = exports.rejectBlueGreenSMI = exports.promoteBlueGreenSMI = exports.deployBlueGreenSMI = void 0;
-const kubectlUtils = require("../kubectl-util");
-const fileHelper = require("../files-helper");
-const blue_green_helper_1 = require("./blue-green-helper");
-const blue_green_helper_2 = require("./blue-green-helper");
-let trafficSplitAPIVersion = "";
-const TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX = '-trafficsplit';
-const TRAFFIC_SPLIT_OBJECT = 'TrafficSplit';
-const MIN_VAL = '0';
-const MAX_VAL = '100';
-function deployBlueGreenSMI(kubectl, filePaths) {
-    // get all kubernetes objects defined in manifest files
-    const manifestObjects = blue_green_helper_1.getManifestObjects(filePaths);
-    // creating services and other objects
-    const newObjectsList = manifestObjects.otherObjects.concat(manifestObjects.serviceEntityList).concat(manifestObjects.ingressEntityList).concat(manifestObjects.unroutedServiceEntityList);
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    kubectl.apply(manifestFiles);
-    // make extraservices and trafficsplit
-    setupSMI(kubectl, manifestObjects.serviceEntityList);
-    // create new deloyments
-    const result = blue_green_helper_1.createWorkloadsWithLabel(kubectl, manifestObjects.deploymentEntityList, blue_green_helper_2.GREEN_LABEL_VALUE);
-    // return results to check for manifest stability
-    return result;
-}
-exports.deployBlueGreenSMI = deployBlueGreenSMI;
-function promoteBlueGreenSMI(kubectl, manifestObjects) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // checking if there is something to promote
-        if (!validateTrafficSplitsState(kubectl, manifestObjects.serviceEntityList)) {
-            throw ('NotInPromoteStateSMI');
-        }
-        // create stable deployments with new configuration
-        const result = blue_green_helper_1.createWorkloadsWithLabel(kubectl, manifestObjects.deploymentEntityList, blue_green_helper_2.NONE_LABEL_VALUE);
-        // return result to check for stability
-        return result;
-    });
-}
-exports.promoteBlueGreenSMI = promoteBlueGreenSMI;
-function rejectBlueGreenSMI(kubectl, filePaths) {
-    return __awaiter(this, void 0, void 0, function* () {
-        // get all kubernetes objects defined in manifest files
-        const manifestObjects = blue_green_helper_1.getManifestObjects(filePaths);
-        // routing trafficsplit to stable deploymetns
-        routeBlueGreenSMI(kubectl, blue_green_helper_2.NONE_LABEL_VALUE, manifestObjects.serviceEntityList);
-        // deleting rejected new bluegreen deplyments 
-        blue_green_helper_1.deleteWorkloadsWithLabel(kubectl, blue_green_helper_2.GREEN_LABEL_VALUE, manifestObjects.deploymentEntityList);
-        //deleting trafficsplit and extra services
-        cleanupSMI(kubectl, manifestObjects.serviceEntityList);
-    });
-}
-exports.rejectBlueGreenSMI = rejectBlueGreenSMI;
-function setupSMI(kubectl, serviceEntityList) {
-    const newObjectsList = [];
-    const trafficObjectList = [];
-    serviceEntityList.forEach((serviceObject) => {
-        // create a trafficsplit for service
-        trafficObjectList.push(serviceObject);
-        // setting up the services for trafficsplit
-        const newStableService = getSMIServiceResource(serviceObject, blue_green_helper_2.STABLE_SUFFIX);
-        const newGreenService = getSMIServiceResource(serviceObject, blue_green_helper_2.GREEN_SUFFIX);
-        newObjectsList.push(newStableService);
-        newObjectsList.push(newGreenService);
-    });
-    // creating services
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    kubectl.apply(manifestFiles);
-    // route to stable service
-    trafficObjectList.forEach((inputObject) => {
-        createTrafficSplitObject(kubectl, inputObject.metadata.name, blue_green_helper_2.NONE_LABEL_VALUE);
-    });
-}
-exports.setupSMI = setupSMI;
-function createTrafficSplitObject(kubectl, name, nextLabel) {
-    // getting smi spec api version 
-    if (!trafficSplitAPIVersion) {
-        trafficSplitAPIVersion = kubectlUtils.getTrafficSplitAPIVersion(kubectl);
-    }
-    // deciding weights based on nextlabel
-    let stableWeight;
-    let greenWeight;
-    if (nextLabel === blue_green_helper_2.GREEN_LABEL_VALUE) {
-        stableWeight = parseInt(MIN_VAL);
-        greenWeight = parseInt(MAX_VAL);
-    }
-    else {
-        stableWeight = parseInt(MAX_VAL);
-        greenWeight = parseInt(MIN_VAL);
-    }
-    //traffic split json
-    const trafficSplitObject = `{
-        "apiVersion": "${trafficSplitAPIVersion}",
-        "kind": "TrafficSplit",
-        "metadata": {
-            "name": "${blue_green_helper_1.getBlueGreenResourceName(name, TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX)}"
-        },
-        "spec": {
-            "service": "${name}",
-            "backends": [
-                {
-                    "service": "${blue_green_helper_1.getBlueGreenResourceName(name, blue_green_helper_2.STABLE_SUFFIX)}",
-                    "weight": ${stableWeight}
-                },
-                {
-                    "service": "${blue_green_helper_1.getBlueGreenResourceName(name, blue_green_helper_2.GREEN_SUFFIX)}",
-                    "weight": ${greenWeight}
-                }
-            ]
-        }
-    }`;
-    // creating trafficplit object
-    const trafficSplitManifestFile = fileHelper.writeManifestToFile(trafficSplitObject, TRAFFIC_SPLIT_OBJECT, blue_green_helper_1.getBlueGreenResourceName(name, TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX));
-    kubectl.apply(trafficSplitManifestFile);
-}
-function getSMIServiceResource(inputObject, suffix) {
-    const newObject = JSON.parse(JSON.stringify(inputObject));
-    if (suffix === blue_green_helper_2.STABLE_SUFFIX) {
-        // adding stable suffix to service name
-        newObject.metadata.name = blue_green_helper_1.getBlueGreenResourceName(inputObject.metadata.name, blue_green_helper_2.STABLE_SUFFIX);
-        return blue_green_helper_1.getNewBlueGreenObject(newObject, blue_green_helper_2.NONE_LABEL_VALUE);
-    }
-    else {
-        // green label will be added for these
-        return blue_green_helper_1.getNewBlueGreenObject(newObject, blue_green_helper_2.GREEN_LABEL_VALUE);
-    }
-}
-exports.getSMIServiceResource = getSMIServiceResource;
-function routeBlueGreenSMI(kubectl, nextLabel, serviceEntityList) {
-    serviceEntityList.forEach((serviceObject) => {
-        // routing trafficsplit to given label
-        createTrafficSplitObject(kubectl, serviceObject.metadata.name, nextLabel);
-    });
-}
-exports.routeBlueGreenSMI = routeBlueGreenSMI;
-function validateTrafficSplitsState(kubectl, serviceEntityList) {
-    let areTrafficSplitsInRightState = true;
-    serviceEntityList.forEach((serviceObject) => {
-        const name = serviceObject.metadata.name;
-        let trafficSplitObject = blue_green_helper_1.fetchResource(kubectl, TRAFFIC_SPLIT_OBJECT, blue_green_helper_1.getBlueGreenResourceName(name, TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX));
-        if (!trafficSplitObject) {
-            // no trafficplit exits
-            areTrafficSplitsInRightState = false;
-        }
-        trafficSplitObject = JSON.parse(JSON.stringify(trafficSplitObject));
-        trafficSplitObject.spec.backends.forEach(element => {
-            // checking if trafficsplit in right state to deploy
-            if (element.service === blue_green_helper_1.getBlueGreenResourceName(name, blue_green_helper_2.GREEN_SUFFIX)) {
-                if (element.weight != MAX_VAL) {
-                    // green service should have max weight
-                    areTrafficSplitsInRightState = false;
-                }
-            }
-            if (element.service === blue_green_helper_1.getBlueGreenResourceName(name, blue_green_helper_2.STABLE_SUFFIX)) {
-                if (element.weight != MIN_VAL) {
-                    // stable service should have 0 weight
-                    areTrafficSplitsInRightState = false;
-                }
-            }
-        });
-    });
-    return areTrafficSplitsInRightState;
-}
-exports.validateTrafficSplitsState = validateTrafficSplitsState;
-function cleanupSMI(kubectl, serviceEntityList) {
-    const deleteList = [];
-    serviceEntityList.forEach((serviceObject) => {
-        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);
-}
-exports.cleanupSMI = cleanupSMI;
@@ -1,199 +0,0 @@
-'use strict';
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.redirectTrafficToStableDeployment = exports.redirectTrafficToCanaryDeployment = exports.deploySMICanary = void 0;
-const core = require("@actions/core");
-const fs = require("fs");
-const yaml = require("js-yaml");
-const util = require("util");
-const TaskInputParameters = require("../../input-parameters");
-const fileHelper = require("../files-helper");
-const helper = require("../resource-object-utility");
-const utils = require("../manifest-utilities");
-const kubectlUtils = require("../kubectl-util");
-const canaryDeploymentHelper = require("./canary-deployment-helper");
-const utility_1 = require("../utility");
-const TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX = '-workflow-rollout';
-const TRAFFIC_SPLIT_OBJECT = 'TrafficSplit';
-let trafficSplitAPIVersion = "";
-function deploySMICanary(kubectl, filePaths) {
-    const newObjectsList = [];
-    const canaryReplicaCount = parseInt(TaskInputParameters.baselineAndCanaryReplicas);
-    core.debug('Replica count is ' + canaryReplicaCount);
-    filePaths.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            const name = inputObject.metadata.name;
-            const kind = inputObject.kind;
-            if (helper.isDeploymentEntity(kind)) {
-                // Get stable object
-                core.debug('Querying stable object');
-                const stableObject = canaryDeploymentHelper.fetchResource(kubectl, kind, name);
-                if (!stableObject) {
-                    core.debug('Stable object not found. Creating only canary object');
-                    // If stable object not found, create canary deployment.
-                    const newCanaryObject = canaryDeploymentHelper.getNewCanaryResource(inputObject, canaryReplicaCount);
-                    core.debug('New canary object is: ' + JSON.stringify(newCanaryObject));
-                    newObjectsList.push(newCanaryObject);
-                }
-                else {
-                    if (!canaryDeploymentHelper.isResourceMarkedAsStable(stableObject)) {
-                        throw (`StableSpecSelectorNotExist : ${name}`);
-                    }
-                    core.debug('Stable object found. Creating canary and baseline objects');
-                    // If canary object not found, create canary and baseline object.
-                    const newCanaryObject = canaryDeploymentHelper.getNewCanaryResource(inputObject, canaryReplicaCount);
-                    const newBaselineObject = canaryDeploymentHelper.getNewBaselineResource(stableObject, canaryReplicaCount);
-                    core.debug('New canary object is: ' + JSON.stringify(newCanaryObject));
-                    core.debug('New baseline object is: ' + JSON.stringify(newBaselineObject));
-                    newObjectsList.push(newCanaryObject);
-                    newObjectsList.push(newBaselineObject);
-                }
-            }
-            else {
-                // Updating non deployment entity as it is.
-                newObjectsList.push(inputObject);
-            }
-        });
-    });
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    const result = kubectl.apply(manifestFiles, TaskInputParameters.forceDeployment);
-    createCanaryService(kubectl, filePaths);
-    return { 'result': result, 'newFilePaths': manifestFiles };
-}
-exports.deploySMICanary = deploySMICanary;
-function createCanaryService(kubectl, filePaths) {
-    const newObjectsList = [];
-    const trafficObjectsList = [];
-    filePaths.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            const name = inputObject.metadata.name;
-            const kind = inputObject.kind;
-            if (helper.isServiceEntity(kind)) {
-                const newCanaryServiceObject = canaryDeploymentHelper.getNewCanaryResource(inputObject);
-                core.debug('New canary service object is: ' + JSON.stringify(newCanaryServiceObject));
-                newObjectsList.push(newCanaryServiceObject);
-                const newBaselineServiceObject = canaryDeploymentHelper.getNewBaselineResource(inputObject);
-                core.debug('New baseline object is: ' + JSON.stringify(newBaselineServiceObject));
-                newObjectsList.push(newBaselineServiceObject);
-                core.debug('Querying for stable service object');
-                const stableObject = canaryDeploymentHelper.fetchResource(kubectl, kind, canaryDeploymentHelper.getStableResourceName(name));
-                if (!stableObject) {
-                    const newStableServiceObject = canaryDeploymentHelper.getStableResource(inputObject);
-                    core.debug('New stable service object is: ' + JSON.stringify(newStableServiceObject));
-                    newObjectsList.push(newStableServiceObject);
-                    core.debug('Creating the traffic object for service: ' + name);
-                    const trafficObject = createTrafficSplitManifestFile(kubectl, name, 0, 0, 1000);
-                    core.debug('Creating the traffic object for service: ' + trafficObject);
-                    trafficObjectsList.push(trafficObject);
-                }
-                else {
-                    let updateTrafficObject = true;
-                    const trafficObject = canaryDeploymentHelper.fetchResource(kubectl, TRAFFIC_SPLIT_OBJECT, getTrafficSplitResourceName(name));
-                    if (trafficObject) {
-                        const trafficJObject = JSON.parse(JSON.stringify(trafficObject));
-                        if (trafficJObject && trafficJObject.spec && trafficJObject.spec.backends) {
-                            trafficJObject.spec.backends.forEach((s) => {
-                                if (s.service === canaryDeploymentHelper.getCanaryResourceName(name) && s.weight === "1000m") {
-                                    core.debug('Update traffic objcet not required');
-                                    updateTrafficObject = false;
-                                }
-                            });
-                        }
-                    }
-                    if (updateTrafficObject) {
-                        core.debug('Stable service object present so updating the traffic object for service: ' + name);
-                        trafficObjectsList.push(updateTrafficSplitObject(kubectl, name));
-                    }
-                }
-            }
-        });
-    });
-    const manifestFiles = fileHelper.writeObjectsToFile(newObjectsList);
-    manifestFiles.push(...trafficObjectsList);
-    const result = kubectl.apply(manifestFiles, TaskInputParameters.forceDeployment);
-    utility_1.checkForErrors([result]);
-}
-function redirectTrafficToCanaryDeployment(kubectl, manifestFilePaths) {
-    adjustTraffic(kubectl, manifestFilePaths, 0, 1000);
-}
-exports.redirectTrafficToCanaryDeployment = redirectTrafficToCanaryDeployment;
-function redirectTrafficToStableDeployment(kubectl, manifestFilePaths) {
-    adjustTraffic(kubectl, manifestFilePaths, 1000, 0);
-}
-exports.redirectTrafficToStableDeployment = redirectTrafficToStableDeployment;
-function adjustTraffic(kubectl, manifestFilePaths, stableWeight, canaryWeight) {
-    // get manifest files
-    const inputManifestFiles = utils.getManifestFiles(manifestFilePaths);
-    if (inputManifestFiles == null || inputManifestFiles.length == 0) {
-        return;
-    }
-    const trafficSplitManifests = [];
-    const serviceObjects = [];
-    inputManifestFiles.forEach((filePath) => {
-        const fileContents = fs.readFileSync(filePath);
-        yaml.safeLoadAll(fileContents, function (inputObject) {
-            const name = inputObject.metadata.name;
-            const kind = inputObject.kind;
-            if (helper.isServiceEntity(kind)) {
-                trafficSplitManifests.push(createTrafficSplitManifestFile(kubectl, name, stableWeight, 0, canaryWeight));
-                serviceObjects.push(name);
-            }
-        });
-    });
-    if (trafficSplitManifests.length <= 0) {
-        return;
-    }
-    const result = kubectl.apply(trafficSplitManifests, TaskInputParameters.forceDeployment);
-    core.debug('serviceObjects:' + serviceObjects.join(',') + ' result:' + result);
-    utility_1.checkForErrors([result]);
-}
-function updateTrafficSplitObject(kubectl, serviceName) {
-    const percentage = parseInt(TaskInputParameters.canaryPercentage) * 10;
-    const baselineAndCanaryWeight = percentage / 2;
-    const stableDeploymentWeight = 1000 - percentage;
-    core.debug('Creating the traffic object with canary weight: ' + baselineAndCanaryWeight + ',baseling weight: ' + baselineAndCanaryWeight + ',stable: ' + stableDeploymentWeight);
-    return createTrafficSplitManifestFile(kubectl, serviceName, stableDeploymentWeight, baselineAndCanaryWeight, baselineAndCanaryWeight);
-}
-function createTrafficSplitManifestFile(kubectl, serviceName, stableWeight, baselineWeight, canaryWeight) {
-    const smiObjectString = getTrafficSplitObject(kubectl, serviceName, stableWeight, baselineWeight, canaryWeight);
-    const manifestFile = fileHelper.writeManifestToFile(smiObjectString, TRAFFIC_SPLIT_OBJECT, serviceName);
-    if (!manifestFile) {
-        throw new Error('UnableToCreateTrafficSplitManifestFile');
-    }
-    return manifestFile;
-}
-function getTrafficSplitObject(kubectl, name, stableWeight, baselineWeight, canaryWeight) {
-    if (!trafficSplitAPIVersion) {
-        trafficSplitAPIVersion = kubectlUtils.getTrafficSplitAPIVersion(kubectl);
-    }
-    const trafficSplitObjectJson = `{
-        "apiVersion": "${trafficSplitAPIVersion}",
-        "kind": "TrafficSplit",
-        "metadata": {
-            "name": "%s"
-        },
-        "spec": {
-            "backends": [
-                {
-                    "service": "%s",
-                    "weight": "%sm"
-                },
-                {
-                    "service": "%s",
-                    "weight": "%sm"
-                },
-                {
-                    "service": "%s",
-                    "weight": "%sm"
-                }
-            ],
-            "service": "%s"
-        }
-    }`;
-    const trafficSplitObject = util.format(trafficSplitObjectJson, getTrafficSplitResourceName(name), canaryDeploymentHelper.getStableResourceName(name), stableWeight, canaryDeploymentHelper.getBaselineResourceName(name), baselineWeight, canaryDeploymentHelper.getCanaryResourceName(name), canaryWeight, name);
-    return trafficSplitObject;
-}
-function getTrafficSplitResourceName(name) {
-    return name + TRAFFIC_SPLIT_OBJECT_NAME_SUFFIX;
-}
@@ -1,26 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.isEqual = exports.StringComparer = void 0;
-var StringComparer;
-(function (StringComparer) {
-    StringComparer[StringComparer["Ordinal"] = 0] = "Ordinal";
-    StringComparer[StringComparer["OrdinalIgnoreCase"] = 1] = "OrdinalIgnoreCase";
-})(StringComparer = exports.StringComparer || (exports.StringComparer = {}));
-function isEqual(str1, str2, stringComparer) {
-    if (str1 == null && str2 == null) {
-        return true;
-    }
-    if (str1 == null) {
-        return false;
-    }
-    if (str2 == null) {
-        return false;
-    }
-    if (stringComparer == StringComparer.OrdinalIgnoreCase) {
-        return str1.toUpperCase() === str2.toUpperCase();
-    }
-    else {
-        return str1 === str2;
-    }
-}
-exports.isEqual = isEqual;
@@ -1,527 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ToolRunner = void 0;
-const os = require("os");
-const events = require("events");
-const child = require("child_process");
-const core = require("@actions/core");
-class ToolRunner extends events.EventEmitter {
-    constructor(toolPath) {
-        super();
-        if (!toolPath) {
-            throw new Error('Parameter \'toolPath\' cannot be null or empty.');
-        }
-        this.toolPath = toolPath;
-        this.args = [];
-        core.debug('toolRunner toolPath: ' + toolPath);
-    }
-    _debug(message) {
-        this.emit('debug', message);
-    }
-    _argStringToArray(argString) {
-        var args = [];
-        var inQuotes = false;
-        var escaped = false;
-        var lastCharWasSpace = true;
-        var arg = '';
-        var append = function (c) {
-            // we only escape double quotes.
-            if (escaped && c !== '"') {
-                arg += '\\';
-            }
-            arg += c;
-            escaped = false;
-        };
-        for (var i = 0; i < argString.length; i++) {
-            var c = argString.charAt(i);
-            if (c === ' ' && !inQuotes) {
-                if (!lastCharWasSpace) {
-                    args.push(arg);
-                    arg = '';
-                }
-                lastCharWasSpace = true;
-                continue;
-            }
-            else {
-                lastCharWasSpace = false;
-            }
-            if (c === '"') {
-                if (!escaped) {
-                    inQuotes = !inQuotes;
-                }
-                else {
-                    append(c);
-                }
-                continue;
-            }
-            if (c === "\\" && escaped) {
-                append(c);
-                continue;
-            }
-            if (c === "\\" && inQuotes) {
-                escaped = true;
-                continue;
-            }
-            append(c);
-            lastCharWasSpace = false;
-        }
-        if (!lastCharWasSpace) {
-            args.push(arg.trim());
-        }
-        return args;
-    }
-    _getCommandString(options, noPrefix) {
-        let toolPath = this._getSpawnFileName();
-        let args = this._getSpawnArgs(options);
-        let cmd = noPrefix ? '' : '[command]'; // omit prefix when piped to a second tool
-        if (process.platform == 'win32') {
-            // Windows + cmd file
-            if (this._isCmdFile()) {
-                cmd += toolPath;
-                args.forEach((a) => {
-                    cmd += ` ${a}`;
-                });
-            }
-            // Windows + verbatim
-            else if (options.windowsVerbatimArguments) {
-                cmd += `"${toolPath}"`;
-                args.forEach((a) => {
-                    cmd += ` ${a}`;
-                });
-            }
-            // Windows (regular)
-            else {
-                cmd += this._windowsQuoteCmdArg(toolPath);
-                args.forEach((a) => {
-                    cmd += ` ${this._windowsQuoteCmdArg(a)}`;
-                });
-            }
-        }
-        else {
-            // OSX/Linux - this can likely be improved with some form of quoting.
-            // creating processes on Unix is fundamentally different than Windows.
-            // on Unix, execvp() takes an arg array.
-            cmd += toolPath;
-            args.forEach((a) => {
-                cmd += ` ${a}`;
-            });
-        }
-        // append second tool
-        if (this.pipeOutputToTool) {
-            cmd += ' | ' + this.pipeOutputToTool._getCommandString(options, /*noPrefix:*/ true);
-        }
-        return cmd;
-    }
-    _getSpawnFileName() {
-        if (process.platform == 'win32') {
-            if (this._isCmdFile()) {
-                return process.env['COMSPEC'] || 'cmd.exe';
-            }
-        }
-        return this.toolPath;
-    }
-    _getSpawnArgs(options) {
-        if (process.platform == 'win32') {
-            if (this._isCmdFile()) {
-                let argline = `/D /S /C "${this._windowsQuoteCmdArg(this.toolPath)}`;
-                for (let i = 0; i < this.args.length; i++) {
-                    argline += ' ';
-                    argline += options.windowsVerbatimArguments ? this.args[i] : this._windowsQuoteCmdArg(this.args[i]);
-                }
-                argline += '"';
-                return [argline];
-            }
-            if (options.windowsVerbatimArguments) {
-                // note, in Node 6.x options.argv0 can be used instead of overriding args.slice and args.unshift.
-                // for more details, refer to https://github.com/nodejs/node/blob/v6.x/lib/child_process.js
-                let args = this.args.slice(0); // copy the array
-                // override slice to prevent Node from creating a copy of the arg array.
-                // we need Node to use the "unshift" override below.
-                args.slice = function () {
-                    if (arguments.length != 1 || arguments[0] != 0) {
-                        throw new Error('Unexpected arguments passed to args.slice when windowsVerbatimArguments flag is set.');
-                    }
-                    return args;
-                };
-                // override unshift
-                //
-                // when using the windowsVerbatimArguments option, Node does not quote the tool path when building
-                // the cmdline parameter for the win32 function CreateProcess(). an unquoted space in the tool path
-                // causes problems for tools when attempting to parse their own command line args. tools typically
-                // assume their arguments begin after arg 0.
-                //
-                // by hijacking unshift, we can quote the tool path when it pushed onto the args array. Node builds
-                // the cmdline parameter from the args array.
-                //
-                // note, we can't simply pass a quoted tool path to Node for multiple reasons:
-                //   1) Node verifies the file exists (calls win32 function GetFileAttributesW) and the check returns
-                //      false if the path is quoted.
-                //   2) Node passes the tool path as the application parameter to CreateProcess, which expects the
-                //      path to be unquoted.
-                //
-                // also note, in addition to the tool path being embedded within the cmdline parameter, Node also
-                // passes the tool path to CreateProcess via the application parameter (optional parameter). when
-                // present, Windows uses the application parameter to determine which file to run, instead of
-                // interpreting the file from the cmdline parameter.
-                args.unshift = function () {
-                    if (arguments.length != 1) {
-                        throw new Error('Unexpected arguments passed to args.unshift when windowsVerbatimArguments flag is set.');
-                    }
-                    return Array.prototype.unshift.call(args, `"${arguments[0]}"`); // quote the file name
-                };
-                return args;
-            }
-        }
-        return this.args;
-    }
-    _isCmdFile() {
-        let upperToolPath = this.toolPath.toUpperCase();
-        return this._endsWith(upperToolPath, '.CMD') || this._endsWith(upperToolPath, '.BAT');
-    }
-    _endsWith(str, end) {
-        return str.slice(-end.length) == end;
-    }
-    _windowsQuoteCmdArg(arg) {
-        // for .exe, apply the normal quoting rules that libuv applies
-        if (!this._isCmdFile()) {
-            return this._uv_quote_cmd_arg(arg);
-        }
-        // otherwise apply quoting rules specific to the cmd.exe command line parser.
-        // the libuv rules are generic and are not designed specifically for cmd.exe
-        // command line parser.
-        //
-        // for a detailed description of the cmd.exe command line parser, refer to
-        // http://stackoverflow.com/questions/4094699/how-does-the-windows-command-interpreter-cmd-exe-parse-scripts/7970912#7970912
-        // need quotes for empty arg
-        if (!arg) {
-            return '""';
-        }
-        // determine whether the arg needs to be quoted
-        const cmdSpecialChars = [' ', '\t', '&', '(', ')', '[', ']', '{', '}', '^', '=', ';', '!', '\'', '+', ',', '`', '~', '|', '<', '>', '"'];
-        let needsQuotes = false;
-        for (let char of arg) {
-            if (cmdSpecialChars.some(x => x == char)) {
-                needsQuotes = true;
-                break;
-            }
-        }
-        // short-circuit if quotes not needed
-        if (!needsQuotes) {
-            return arg;
-        }
-        // the following quoting rules are very similar to the rules that by libuv applies.
-        //
-        // 1) wrap the string in quotes
-        //
-        // 2) double-up quotes - i.e. " => ""
-        //
-        //    this is different from the libuv quoting rules. libuv replaces " with \", which unfortunately
-        //    doesn't work well with a cmd.exe command line.
-        //
-        //    note, replacing " with "" also works well if the arg is passed to a downstream .NET console app.
-        //    for example, the command line:
-        //          foo.exe "myarg:""my val"""
-        //    is parsed by a .NET console app into an arg array:
-        //          [ "myarg:\"my val\"" ]
-        //    which is the same end result when applying libuv quoting rules. although the actual
-        //    command line from libuv quoting rules would look like:
-        //          foo.exe "myarg:\"my val\""
-        //
-        // 3) double-up slashes that preceed a quote,
-        //    e.g.  hello \world    => "hello \world"
-        //          hello\"world    => "hello\\""world"
-        //          hello\\"world   => "hello\\\\""world"
-        //          hello world\    => "hello world\\"
-        //
-        //    technically this is not required for a cmd.exe command line, or the batch argument parser.
-        //    the reasons for including this as a .cmd quoting rule are:
-        //
-        //    a) this is optimized for the scenario where the argument is passed from the .cmd file to an
-        //       external program. many programs (e.g. .NET console apps) rely on the slash-doubling rule.
-        //
-        //    b) it's what we've been doing previously (by deferring to node default behavior) and we
-        //       haven't heard any complaints about that aspect.
-        //
-        // note, a weakness of the quoting rules chosen here, is that % is not escaped. in fact, % cannot be
-        // escaped when used on the command line directly - even though within a .cmd file % can be escaped
-        // by using %%.
-        //
-        // the saving grace is, on the command line, %var% is left as-is if var is not defined. this contrasts
-        // the line parsing rules within a .cmd file, where if var is not defined it is replaced with nothing.
-        //
-        // one option that was explored was replacing % with ^% - i.e. %var% => ^%var^%. this hack would
-        // often work, since it is unlikely that var^ would exist, and the ^ character is removed when the
-        // variable is used. the problem, however, is that ^ is not removed when %* is used to pass the args
-        // to an external program.
-        //
-        // an unexplored potential solution for the % escaping problem, is to create a wrapper .cmd file.
-        // % can be escaped within a .cmd file.
-        let reverse = '"';
-        let quote_hit = true;
-        for (let i = arg.length; i > 0; i--) { // walk the string in reverse
-            reverse += arg[i - 1];
-            if (quote_hit && arg[i - 1] == '\\') {
-                reverse += '\\'; // double the slash
-            }
-            else if (arg[i - 1] == '"') {
-                quote_hit = true;
-                reverse += '"'; // double the quote
-            }
-            else {
-                quote_hit = false;
-            }
-        }
-        reverse += '"';
-        return reverse.split('').reverse().join('');
-    }
-    _uv_quote_cmd_arg(arg) {
-        // Tool runner wraps child_process.spawn() and needs to apply the same quoting as
-        // Node in certain cases where the undocumented spawn option windowsVerbatimArguments
-        // is used.
-        //
-        // Since this function is a port of quote_cmd_arg from Node 4.x (technically, lib UV,
-        // see https://github.com/nodejs/node/blob/v4.x/deps/uv/src/win/process.c for details),
-        // pasting copyright notice from Node within this function:
-        //
-        //      Copyright Joyent, Inc. and other Node contributors. All rights reserved.
-        //
-        //      Permission is hereby granted, free of charge, to any person obtaining a copy
-        //      of this software and associated documentation files (the "Software"), to
-        //      deal in the Software without restriction, including without limitation the
-        //      rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
-        //      sell copies of the Software, and to permit persons to whom the Software is
-        //      furnished to do so, subject to the following conditions:
-        //
-        //      The above copyright notice and this permission notice shall be included in
-        //      all copies or substantial portions of the Software.
-        //
-        //      THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-        //      IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-        //      FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-        //      AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-        //      LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
-        //      FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
-        //      IN THE SOFTWARE.
-        if (!arg) {
-            // Need double quotation for empty argument
-            return '""';
-        }
-        if (arg.indexOf(' ') < 0 && arg.indexOf('\t') < 0 && arg.indexOf('"') < 0) {
-            // No quotation needed
-            return arg;
-        }
-        if (arg.indexOf('"') < 0 && arg.indexOf('\\') < 0) {
-            // No embedded double quotes or backslashes, so I can just wrap
-            // quote marks around the whole thing.
-            return `"${arg}"`;
-        }
-        // Expected input/output:
-        //   input : hello"world
-        //   output: "hello\"world"
-        //   input : hello""world
-        //   output: "hello\"\"world"
-        //   input : hello\world
-        //   output: hello\world
-        //   input : hello\\world
-        //   output: hello\\world
-        //   input : hello\"world
-        //   output: "hello\\\"world"
-        //   input : hello\\"world
-        //   output: "hello\\\\\"world"
-        //   input : hello world\
-        //   output: "hello world\\" - note the comment in libuv actually reads "hello world\"
-        //                             but it appears the comment is wrong, it should be "hello world\\"
-        let reverse = '"';
-        let quote_hit = true;
-        for (let i = arg.length; i > 0; i--) { // walk the string in reverse
-            reverse += arg[i - 1];
-            if (quote_hit && arg[i - 1] == '\\') {
-                reverse += '\\';
-            }
-            else if (arg[i - 1] == '"') {
-                quote_hit = true;
-                reverse += '\\';
-            }
-            else {
-                quote_hit = false;
-            }
-        }
-        reverse += '"';
-        return reverse.split('').reverse().join('');
-    }
-    _cloneExecOptions(options) {
-        options = options || {};
-        let result = {
-            cwd: options.cwd || process.cwd(),
-            env: options.env || process.env,
-            silent: options.silent || false,
-            failOnStdErr: options.failOnStdErr || false,
-            ignoreReturnCode: options.ignoreReturnCode || false,
-            windowsVerbatimArguments: options.windowsVerbatimArguments || false
-        };
-        result.outStream = options.outStream || process.stdout;
-        result.errStream = options.errStream || process.stderr;
-        return result;
-    }
-    _getSpawnSyncOptions(options) {
-        let result = {};
-        result.cwd = options.cwd;
-        result.env = options.env;
-        result['windowsVerbatimArguments'] = options.windowsVerbatimArguments || this._isCmdFile();
-        return result;
-    }
-    /**
-     * Add argument
-     * Append an argument or an array of arguments
-     * returns ToolRunner for chaining
-     *
-     * @param     val        string cmdline or array of strings
-     * @returns   ToolRunner
-     */
-    arg(val) {
-        if (!val) {
-            return this;
-        }
-        if (val instanceof Array) {
-            core.debug(this.toolPath + ' arg: ' + JSON.stringify(val));
-            this.args = this.args.concat(val);
-        }
-        else if (typeof (val) === 'string') {
-            core.debug(this.toolPath + ' arg: ' + val);
-            this.args = this.args.concat(val.trim());
-        }
-        return this;
-    }
-    /**
-     * Parses an argument line into one or more arguments
-     * e.g. .line('"arg one" two -z') is equivalent to .arg(['arg one', 'two', '-z'])
-     * returns ToolRunner for chaining
-     *
-     * @param     val        string argument line
-     * @returns   ToolRunner
-     */
-    line(val) {
-        if (!val) {
-            return this;
-        }
-        core.debug(this.toolPath + ' arg: ' + val);
-        this.args = this.args.concat(this._argStringToArray(val));
-        return this;
-    }
-    /**
-     * Add argument(s) if a condition is met
-     * Wraps arg().  See arg for details
-     * returns ToolRunner for chaining
-     *
-     * @param     condition     boolean condition
-     * @param     val     string cmdline or array of strings
-     * @returns   ToolRunner
-     */
-    argIf(condition, val) {
-        if (condition) {
-            this.arg(val);
-        }
-        return this;
-    }
-    /**
-     * Pipe output of exec() to another tool
-     * @param tool
-     * @param file  optional filename to additionally stream the output to.
-     * @returns {ToolRunner}
-     */
-    pipeExecOutputToTool(tool, file) {
-        this.pipeOutputToTool = tool;
-        return this;
-    }
-    /**
-     * Exec a tool synchronously.
-     * Output will be *not* be streamed to the live console.  It will be returned after execution is complete.
-     * Appropriate for short running tools
-     * Returns IExecSyncResult with output and return code
-     *
-     * @param     tool     path to tool to exec
-     * @param     options  optional exec options.  See IExecSyncOptions
-     * @returns   IExecSyncResult
-     */
-    execSync(options) {
-        core.debug('exec tool: ' + this.toolPath);
-        core.debug('arguments:');
-        this.args.forEach((arg) => {
-            core.debug('   ' + arg);
-        });
-        options = this._cloneExecOptions(options);
-        if (!options.silent) {
-            options.outStream.write(this._getCommandString(options) + os.EOL);
-        }
-        var r = child.spawnSync(this._getSpawnFileName(), this._getSpawnArgs(options), this._getSpawnSyncOptions(options));
-        var res = { code: r.status, error: r.error };
-        if (!options.silent && r.stdout && r.stdout.length > 0) {
-            options.outStream.write(r.stdout);
-        }
-        if (!options.silent && r.stderr && r.stderr.length > 0) {
-            options.errStream.write(r.stderr);
-        }
-        res.stdout = (r.stdout) ? r.stdout.toString() : '';
-        res.stderr = (r.stderr) ? r.stderr.toString() : '';
-        return res;
-    }
-}
-exports.ToolRunner = ToolRunner;
-class ExecState extends events.EventEmitter {
-    constructor(options, toolPath) {
-        super();
-        this.delay = 10000; // 10 seconds
-        this.timeout = null;
-        if (!toolPath) {
-            throw new Error('toolPath must not be empty');
-        }
-        this.options = options;
-        this.toolPath = toolPath;
-        let delay = process.env['TASKLIB_TEST_TOOLRUNNER_EXITDELAY'];
-        if (delay) {
-            this.delay = parseInt(delay);
-        }
-    }
-    CheckComplete() {
-        if (this.done) {
-            return;
-        }
-        if (this.processClosed) {
-            this._setResult();
-        }
-        else if (this.processExited) {
-            this.timeout = setTimeout(ExecState.HandleTimeout, this.delay, this);
-        }
-    }
-    _setResult() {
-        // determine whether there is an error
-        let error;
-        if (this.processExited) {
-            if (this.processError) {
-                error = new Error(`LIB_ProcessError: \n tool: ${this.toolPath} \n error: ${this.processError}`);
-            }
-            else if (this.processExitCode != 0 && !this.options.ignoreReturnCode) {
-                error = new Error(`LIB_ProcessExitCode\n tool: ${this.toolPath} \n Exit Code: ${this.processExitCode}`);
-            }
-            else if (this.processStderr && this.options.failOnStdErr) {
-                error = new Error(`LIB_ProcessStderr', ${this.toolPath}`);
-            }
-        }
-        // clear the timeout
-        if (this.timeout) {
-            clearTimeout(this.timeout);
-            this.timeout = null;
-        }
-        this.done = true;
-        this.emit('done', error, this.processExitCode);
-    }
-    static HandleTimeout(state) {
-        if (state.done) {
-            return;
-        }
-        if (!state.processClosed && state.processExited) {
-            core.debug(`LIB_StdioNotClosed`);
-        }
-        state._setResult();
-    }
-}
@@ -1,108 +0,0 @@
-"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) {
-                for (let ownerRef of owners) {
-                    if (ownerRef.name === owner) {
-                        commandExecutionResults.push(kubectl.annotate('pod', pod.metadata.name, constants_1.workflowAnnotations, true));
-                        break;
-                    }
-                }
-            }
-        });
-    }
-    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.stderr) {
-            return result;
-        }
-        else if (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/tool-cache": "^1.0.0",
+        "@actions/tool-cache": "1.1.2",
        "@actions/io": "^1.0.0",
-        "@actions/core": "^1.0.0",
+        "@actions/core": "^1.2.6",
        "@actions/exec": "^1.0.0",
        "js-yaml": "3.13.1"
    },
    "devDependencies": {
        "@types/node": "^12.0.10",
-        "jest": "^25.0.0",
-        "@types/jest": "^25.2.2",
+        "jest": "^26.0.0",
+        "@types/jest": "^26.0.0",
        "ts-jest": "^25.5.1",
        "typescript": "3.9.5"
    }
@@ -1,4 +1,5 @@
 'use strict';
+import { DeploymentConfig } from "./utilities/utility";

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

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

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

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

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

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

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

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

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

 import { Kubectl } from '../kubectl-object-model';
+import { StatusCodes } from "./httpClient"

 const kubectlToolName = 'kubectl';
 const stableKubectlVersion = 'v1.15.0';
@@ -19,17 +20,25 @@ function getExecutableExtension(): string {
    return '';
 }

-export function getkubectlDownloadURL(version: string): string {
+function getKubectlArch(): string {
+    let arch = os.arch();
+    if (arch === 'x64') {
+        return 'amd64';
+    }
+    return arch;
+}
+
+export function getkubectlDownloadURL(version: string, arch: string): string {
    switch (os.type()) {
        case 'Linux':
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/linux/amd64/kubectl', version);
+            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/linux/%s/kubectl', version, arch);

        case 'Darwin':
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/darwin/amd64/kubectl', version);
+            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/darwin/%s/kubectl', version, arch);

        case 'Windows_NT':
        default:
-            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/windows/amd64/kubectl.exe', version);
+            return util.format('https://storage.googleapis.com/kubernetes-release/release/%s/bin/windows/%s/kubectl.exe', version, arch);

    }
 }
@@ -51,11 +60,16 @@ export async function getStableKubectlVersion(): Promise<string> {
 export async function downloadKubectl(version: string): Promise<string> {
    let cachedToolpath = toolCache.find(kubectlToolName, version);
    let kubectlDownloadPath = '';
+    let arch = getKubectlArch();
    if (!cachedToolpath) {
        try {
-            kubectlDownloadPath = await toolCache.downloadTool(getkubectlDownloadURL(version));
+            kubectlDownloadPath = await toolCache.downloadTool(getkubectlDownloadURL(version, arch));
        } catch (exception) {
-            throw new Error('DownloadKubectlFailed');
+            if (exception instanceof toolCache.HTTPError && exception.httpStatusCode === StatusCodes.NOT_FOUND) {
+                throw new Error(util.format("Kubectl '%s' for '%s' arch not found.", version, arch));
+            } else {
+                throw new Error('DownloadKubectlFailed');
+            }
        }

        cachedToolpath = await toolCache.cacheFile(kubectlDownloadPath, kubectlToolName + getExecutableExtension(), kubectlToolName, version);
@@ -17,7 +17,7 @@ import { IExecSyncResult } from '../../utilities/tool-runner';

 import { deployPodCanary } from './pod-canary-deployment-helper';
 import { deploySMICanary } from './smi-canary-deployment-helper';
-import { checkForErrors, annotateChildPods, annotateNamespace } from "../utility";
+import { checkForErrors, annotateChildPods, getWorkflowFilePath, getLastSuccessfulRunSha, DeploymentConfig, getDeploymentConfig, normaliseWorkflowStrLabel } 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 {
@@ -54,7 +54,7 @@ export async function deploy(kubectl: Kubectl, manifestFilePaths: string[], depl
        core.debug("Unable to parse pods; Error: " + e);
    }

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

 export function getManifestFiles(manifestFilePaths: string[]): string[] {
@@ -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()) {
@@ -128,19 +128,34 @@ async function checkManifestStability(kubectl: Kubectl, resources: Resource[]):
    await KubernetesManifestUtility.checkManifestStability(kubectl, resources);
 }

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

+function labelResources(files: string[], kubectl: Kubectl, label: string) {
+    const labels = [`workflowFriendlyName=${normaliseWorkflowStrLabel(process.env.GITHUB_WORKFLOW)}`, `workflow=${label}`];
+    checkForErrors([kubectl.labelFiles(files, labels)], true);
+}
+
 function isCanaryDeploymentStrategy(deploymentStrategy: string): boolean {
    return deploymentStrategy != null && deploymentStrategy.toUpperCase() === canaryDeploymentHelper.CANARY_DEPLOYMENT_STRATEGY.toUpperCase();
 }
@@ -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)) {
@@ -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
@@ -186,33 +186,31 @@ function getTrafficSplitObject(kubectl: Kubectl, name: string, stableWeight: num
    if (!trafficSplitAPIVersion) {
        trafficSplitAPIVersion = kubectlUtils.getTrafficSplitAPIVersion(kubectl);
    }
-    const trafficSplitObjectJson = `{
+
+    return `{
        "apiVersion": "${trafficSplitAPIVersion}",
        "kind": "TrafficSplit",
        "metadata": {
-            "name": "%s"
+            "name": "${getTrafficSplitResourceName(name)}"
        },
        "spec": {
            "backends": [
                {
-                    "service": "%s",
-                    "weight": "%sm"
+                    "service": "${canaryDeploymentHelper.getStableResourceName(name)}",
+                    "weight": "${stableWeight}"
                },
                {
-                    "service": "%s",
-                    "weight": "%sm"
+                    "service": "${canaryDeploymentHelper.getBaselineResourceName(name)}",
+                    "weight": "${baselineWeight}"
                },
                {
-                    "service": "%s",
-                    "weight": "%sm"
+                    "service": "${canaryDeploymentHelper.getCanaryResourceName(name)}",
+                    "weight": "${canaryWeight}"
                }
            ],
            "service": "%s"
        }
    }`;
-
-    const trafficSplitObject = util.format(trafficSplitObjectJson, getTrafficSplitResourceName(name), canaryDeploymentHelper.getStableResourceName(name), stableWeight, canaryDeploymentHelper.getBaselineResourceName(name), baselineWeight, canaryDeploymentHelper.getCanaryResourceName(name), canaryWeight, name);
-    return trafficSplitObject;
 }

 function getTrafficSplitResourceName(name: string) {
@@ -2,7 +2,17 @@ import * as os from 'os';
 import * as core from '@actions/core';
 import { IExecSyncResult } from './tool-runner';
 import { Kubectl } from '../kubectl-object-model';
-import { workflowAnnotations } from '../constants';
+import { GitHubClient } from '../githubClient';
+import { StatusCodes } from "./httpClient";
+import * as inputParams from "../input-parameters";
+import { DockerExec } from '../docker-object-model';
+import * as io from '@actions/io';
+
+export interface DeploymentConfig {
+    manifestFilePaths: string[];
+    helmChartFilePaths: string[];
+    dockerfilePaths: any;
+}

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

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

-export function annotateNamespace(kubectl: Kubectl, namespaceName: string): IExecSyncResult {
-    const result = kubectl.getResource('namespace', namespaceName);
-    if (!result) {
-        return { code: 1, stderr: 'Failed to get resource' } as IExecSyncResult;
-    }
-    else {
-        if (result.stderr) {
-            return result;
-        }
+export async function getDeploymentConfig(): Promise<DeploymentConfig> {

-        else if (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);
+    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 || helmChartPaths.length == 0) {
+        inputManifestFiles = inputManifestFiles.map(manifestFile => getNormalizedPath(manifestFile));
+    }
+
+    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);
        }
    }
+
+    const deploymentConfig = <DeploymentConfig>{
+        manifestFilePaths: inputManifestFiles,
+        helmChartFilePaths: helmChartPaths,
+        dockerfilePaths: imageDockerfilePathMap
+    };
+    return Promise.resolve(deploymentConfig);
+}
+
+export function normaliseWorkflowStrLabel(workflowName: string): string {
+    workflowName = workflowName.startsWith('.github/workflows/') ?
+    workflowName.replace(".github/workflows/", "") : workflowName;
+    return workflowName.replace(/ /g, "_");
 }

 export function sleep(timeout: number) {
@@ -108,3 +186,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 Promise.resolve(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
Oliver King	a3cef0e4cd	fix smi weight bug	2021-11-29 14:00:40 -05:00
Koushik Dey	33608d18f7	Sending a warning instead of throwing error when KUBECONFIG is missing. (#144 )	2021-08-17 16:39:38 +05:30
Koushik Dey	acd12a4705	Create defaultLabels.yml (#140 )	2021-06-27 08:54:24 +05:30
Koushik Dey	81557b8633	Bump @actions/tool-cache from 1.1.1 to 1.1.2 (#138 )	2021-06-18 11:50:08 +05:30
dependabot[bot]	e1b9842236	Bump ws from 7.4.4 to 7.4.6 (#137 ) Bumps [ws](https://github.com/websockets/ws) from 7.4.4 to 7.4.6. - [Release notes](https://github.com/websockets/ws/releases) - [Commits](https://github.com/websockets/ws/compare/7.4.4...7.4.6) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>	2021-06-15 22:57:14 +05:30
dependabot[bot]	26cb2cdb5f	Bump browserslist from 4.16.3 to 4.16.6 (#136 ) Bumps [browserslist](https://github.com/browserslist/browserslist) from 4.16.3 to 4.16.6. - [Release notes](https://github.com/browserslist/browserslist/releases) - [Changelog](https://github.com/browserslist/browserslist/blob/main/CHANGELOG.md) - [Commits](https://github.com/browserslist/browserslist/compare/4.16.3...4.16.6) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>	2021-06-15 22:00:46 +05:30
dependabot[bot]	5ebbfbbefe	Bump hosted-git-info from 2.8.8 to 2.8.9 (#135 ) Bumps [hosted-git-info](https://github.com/npm/hosted-git-info) from 2.8.8 to 2.8.9. - [Release notes](https://github.com/npm/hosted-git-info/releases) - [Changelog](https://github.com/npm/hosted-git-info/blob/v2.8.9/CHANGELOG.md) - [Commits](https://github.com/npm/hosted-git-info/compare/v2.8.8...v2.8.9) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>	2021-05-26 12:47:36 +05:30
Koushik Dey	ac49626466	Fixing label values of workflow names with spaces (#134 )	2021-05-05 15:55:02 +05:30
Ganesh S	d332939666	Merge pull request #131 from Azure/ganeshrockz/delimiterFix Supporting both comma and new line as delimiters for manifests	2021-04-15 11:51:30 +05:30
Ganeshrockz	2577009bcb	Adding ; as delimiter	2021-04-15 11:35:18 +05:30
Ganeshrockz	a58ad23e7f	PR comments	2021-04-14 20:05:45 +05:30
Ganeshrockz	ee4b5d33e0	Comments	2021-04-14 15:31:19 +05:30
Ganeshrockz	625898f6eb	Removing whitespace from manifests	2021-04-14 14:31:04 +05:30
Ganeshrockz	8d257fed50	Supporting both comma and new line as delimiters for manifests	2021-04-14 14:14:06 +05:30
Sundar	4f6b70e29a	Updated trigger for L2 tests. (#128 )	2021-03-31 17:30:09 +05:30
Deepak Sattiraju	202bacc71b	Update integration-tests.yml	2021-03-16 15:54:57 +05:30
Deepak Sattiraju	2c09684db9	Removing js files from main branch (#122 )	2021-03-15 14:28:53 +05:30
Gennady Trubach	282a81e1fc	Added arch detection to kubectl download (#117 )	2021-03-15 12:46:34 +05:30
Deepak Sattiraju	ce7c8f066f	Fixing depandabot alert node-notifier --> 8.0.2 (#121 )	2021-03-12 11:34:20 +05:30
Maxime Guerreiro	25ded46b9d	Update readme to use v1.4 (#116 ) Version 1.4 was released in December 2020. Update the readme to use this new version.	2021-03-10 13:20:41 +05:30
Jyotsna	56e4abca5e	Users/jysin/pm feedback changes for master (#99 ) * Changed dockerfile, Manifests, helmcharts links and README	2021-01-07 12:51:44 +05:30
Jyotsna	4bd69f56a9	Bug fix for dockerfile path for default (#96 ) * Bug fix for dockerfile path link	2020-12-30 21:55:39 +05:30
Jyotsna	04921d7d06	New traceability fields added to annotations (#90 ) * New traceability fields	2020-12-30 15:03:39 +05:30
Jyotsna	51b95a5ca2	Readme updated with traceability changes (#84 ) * Updated new features in Readme with sample workflows - updated changes.	2020-12-28 14:50:00 +05:30
Jyotsna	49257c6f33	Updated new features in Readme with sample workflows (#82 ) * Updated new changes in Readme for annotations with sample workflows for v1.2	2020-12-11 12:08:11 +05:30
Thomas Seljen Tvedt	895952654c	Fixing version in samples (#80 ) editing in github to fix diff? Update README.md, changing from Azure/k8s-deploy@v1 to newest version Azure/k8s-deploy@v1.3. Using @v1 I got an error message "Error: TypeError: Cannot read property 'trim' of null". When I finally realized I was on the wrong version it worked smoothly 🥳 Hopefully this will save someone else some troubleshooting?	2020-11-25 22:50:50 +05:30
Zainudeen V K	0fd84a1b0d	Update integration-tests.yml	2020-11-09 13:49:00 +05:30
Ajinkya	d35174fe93	Fixing issues found in bug bash. (#71 )	2020-10-30 13:10:27 +05:30
Koushik Dey	f80ed6c460	Merge pull request #66 from Azure/dependabot/npm_and_yarn/actions/core-1.2.6 Bump @actions/core from 1.1.0 to 1.2.6	2020-10-06 12:16:02 +05:30
Koushik Dey	72bc167726	BumpUp @actions/core, fixed failing test case	2020-10-05 18:45:39 +05:30
dependabot[bot]	21d3af2857	Bump @actions/core from 1.1.0 to 1.2.6 Bumps [@actions/core](https://github.com/actions/toolkit/tree/HEAD/packages/core) from 1.1.0 to 1.2.6. - [Release notes](https://github.com/actions/toolkit/releases) - [Changelog](https://github.com/actions/toolkit/blob/main/packages/core/RELEASES.md) - [Commits](https://github.com/actions/toolkit/commits/HEAD/packages/core) Signed-off-by: dependabot[bot] <support@github.com>	2020-10-01 17:20:23 +00:00
Koushik Dey	a80355209a	Merge pull request #64 from Azure/users/koushdey/workflowAnnotations-master (M)Annotation and Label changes to handle multiple workflows across branches	2020-09-21 14:53:50 +05:30
Koushik Dey	92589546e8	Annotation and Label changes to handle multiple workflows across branches(master)	2020-09-21 14:30:51 +05:30
Ajinkya	b9146889f3	Update issue templates (#58 ) * Update issue templates * Add label as well	2020-09-17 14:04:13 +05:30