From 7b2035bcd0217e5f918ff92969c4cfe1a4b5b7dd Mon Sep 17 00:00:00 2001
From: David Festal <dfestal@redhat.com>
Date: Mon, 15 Jul 2024 18:53:32 +0200
Subject: [PATCH] Add scheduled workflow to update plugin repo refs

Signed-off-by: David Festal <dfestal@redhat.com>
---
 .github/workflows/create-pr-if-necessary.js   | 161 ++++++++++++++
 .../workflows/update-plugins-repo-refs.yaml   | 196 ++++++++++++++++++
 branches.json                                 |   3 +
 3 files changed, 360 insertions(+)
 create mode 100644 .github/workflows/create-pr-if-necessary.js
 create mode 100644 .github/workflows/update-plugins-repo-refs.yaml
 create mode 100644 branches.json

diff --git a/.github/workflows/create-pr-if-necessary.js b/.github/workflows/create-pr-if-necessary.js
new file mode 100644
index 0000000..a9b8a35
--- /dev/null
+++ b/.github/workflows/create-pr-if-necessary.js
@@ -0,0 +1,161 @@
+module.exports = async ({
+  github,
+  core,
+  owner,
+  repo,
+  pluginsRepoOwner,
+  pluginsRepo,
+  prBranchName,
+  workspaceCommit,
+  workspaceJson,
+}) => {
+  try {    
+    const githubClient = github.rest;
+        
+    const workspace = JSON.parse(workspaceJson);
+    const targetBranchName = `releases/${workspace.branch}`;
+    const workspaceName = workspace.workspace;
+
+    const workspacePath = `workspaces/${workspaceName}`;
+    const pluginsYamlContent = workspace.plugins.map((plugin) => plugin.directory.replace(workspacePath + '/', '')).join(':\n');
+
+    const workspaceLink = `/${pluginsRepoOwner}/${pluginsRepo}/tree/${workspaceCommit}/workspaces/${workspaceName}`;
+
+    // checking existing content on the target branch
+    let needsUpdate = false;
+    try {
+      const checkExistingResponse = await githubClient.repos.getContent({
+        owner,
+        repo,
+        mediaType: {
+          format: 'text'        
+        }, 
+        path: `${workspacePath}/plugins-repo-ref`,
+        ref: targetBranchName,
+      })
+
+      if (checkExistingResponse.status === 200) {
+        console.log('workspace already exists on the target branch');
+        const data = checkExistingResponse.data;
+        if ('content' in data && data.content !== undefined) {
+          const content = Buffer.from(data.content, 'base64').toString();
+          if (content.trim() === workspaceCommit.trim()) {
+            console.log('workspace already added with the same commit');
+            await core.summary
+              .addHeading('Workspace skipped')
+              .addRaw('Workspace ')
+              .addLink(workspaceName, workspaceLink)
+              .addRaw(` already exists on branch ${targetBranchName} with the same commit ${workspaceCommit.substring(0,7)}`)
+              .write()
+            return;
+          }
+        }
+        needsUpdate = true;
+      }
+    } catch(e) {
+      if (e instanceof Object && 'status' in e && e.status === 404) {
+        console.log(`workspace ${workspaceName} not found on branch ${targetBranchName}`)
+      } else {
+        throw e;
+      }
+    }
+
+    // Checking pull request existence
+    try {
+      const prCheckResponse = await githubClient.git.getRef({
+        owner,
+        repo,
+        ref: `heads/${prBranchName}`
+      })
+
+      if (prCheckResponse.status === 200) {
+        console.log('pull request branch already exists. Do not try to create it again.')
+        await core.summary
+          .addHeading('Workspace skipped')
+          .addRaw(`Pull request branch ${prBranchName} already exists.`, true)
+          .write();
+        return;
+      }
+    } catch(e) {
+      if (e instanceof Object && 'status' in e && e.status === 404) {
+        console.log(`pull request branch ${prBranchName} doesn't already exist.`)
+      } else {
+        throw e;
+      }
+    }
+
+    // getting latest commit sha and treeSha of the target branch
+    const response = await githubClient.repos.listCommits({
+      owner,
+      repo,
+      sha: targetBranchName,
+      per_page: 1,
+    })
+
+    const latestCommitSha = response.data[0].sha;
+    const treeSha = response.data[0].commit.tree.sha;
+
+    const treeResponse = await githubClient.git.createTree({
+      owner,
+      repo,
+      base_tree: treeSha,
+      tree: [
+        { path: `${workspacePath}/plugins-list.yaml`, mode: '100644', content: pluginsYamlContent },
+        { path: `${workspacePath}/plugins-repo-ref`, mode: '100644', content: workspaceCommit }
+      ]
+    })
+    const newTreeSha = treeResponse.data.sha
+
+    const needsUpdateMessage = needsUpdate ? 'Update' : 'Add';
+    const message = `${needsUpdateMessage} \`${workspaceName}\` workspace to commit \`${workspaceCommit.substring(0,7)}\` for backstage \`${workspace.backstageVersion}\` on branch \`${targetBranchName}\``
+
+    console.log('creating commit')
+    const commitResponse = await githubClient.git.createCommit({
+      owner,
+      repo,
+      message,
+      tree: newTreeSha,
+      parents: [latestCommitSha],
+    })
+    const newCommitSha = commitResponse.data.sha
+
+    // Creating branch
+    await githubClient.git.createRef({
+      owner,
+      repo,
+      sha: newCommitSha,
+      ref: `refs/heads/${prBranchName}`
+    })
+
+    // Creating pull request
+    const prResponse = await githubClient.pulls.create({
+      owner: owner,
+      repo: repo,
+      head: prBranchName,
+      base: targetBranchName,
+      title: message,
+      body: `${needsUpdateMessage} [${workspaceName}](${workspaceLink}) workspace at commit ${pluginsRepoOwner}/${pluginsRepo}@${workspaceCommit} for backstage \`${workspace.backstageVersion}\` on branch \`${targetBranchName}\`.
+
+  This PR was created automatically.
+  You might need to complete it with additional dynamic plugin export information, like:
+  - the associated \`app-config.dynamic.yaml\` file for frontend plugins,
+  - optionally the \`scalprum-config.json\` file for frontend plugins,
+  - optionally some overlay source files for backend or frontend plugins.
+  `,
+    });
+
+    console.log(`Pull request created: ${prResponse.data.html_url}`);
+
+    await core.summary
+    .addHeading('Workspace PR created')
+    .addLink('Pull request', prResponse.data.html_url)
+    .addRaw(` on branch ${targetBranchName}`)
+    .addRaw(' created for workspace ')
+    .addLink(workspaceName, workspaceLink)
+    .addRaw(` at commit ${workspaceCommit.substring(0,7)} for backstage ${workspace.backstageVersion}`)
+    .write();
+  } catch (error) {
+    // Fail the workflow run if an error occurs
+    if (error instanceof Error) core.setFailed(error.message);
+  }
+}
\ No newline at end of file
diff --git a/.github/workflows/update-plugins-repo-refs.yaml b/.github/workflows/update-plugins-repo-refs.yaml
new file mode 100644
index 0000000..6645b86
--- /dev/null
+++ b/.github/workflows/update-plugins-repo-refs.yaml
@@ -0,0 +1,196 @@
+name: Update plugins repository references
+on:
+  workflow_dispatch:
+
+  schedule:
+    - cron: '0 12 * * *'    
+
+concurrency:
+  group: ${{ github.workflow }}
+  cancel-in-progress: true
+
+jobs:
+  prepare:
+    runs-on: ubuntu-latest
+
+    name: Prepare 
+    outputs:
+      workspace-keys: ${{ steps.gather-workspaces.outputs.workspace-keys }}
+
+    steps:
+      - name: Use node.js 20.x
+        uses: actions/setup-node@60edb5dd545a775178f52524783378180af0d1f8 # v4.0.2
+        with:
+          node-version: 20.x
+          registry-url: https://registry.npmjs.org/ # Needed for auth
+
+      - uses: actions/checkout@b4ffde65f46336ab88eb53be808477a3936bae11 # v4.1.1
+
+      - name: Get published community plugins
+        id: get-published-community-plugins
+        shell: bash
+        run: |
+          npm install semver -g
+          backstageVersions=$(cat branches.json | jq -r 'to_entries | map(.value)[]')
+          plugins=$(
+            comma=""
+            echo '['
+            for package in $(npm search --searchlimit=1000 --json --no-description @backstage-community | jq -r '.[].name' | sort)
+            do
+              if [[ "${package}" == *"-node" ]] || [[ "${package}" == *"-common" ]] || [[ "${package}" == *"-react" ]] 
+              then
+                echo "Skipping published package ${package}: not a plugin" >&2
+                continue
+              fi
+              if [[ "$(npm view --json ${package} | jq -r '.backstage.role')" != *"-plugin"* ]]
+              then
+                echo "Skipping published package ${package}: not a plugin" >&2
+                continue
+              fi
+              echo "Fetching published versions of plugin ${package}" >&2
+              for version in $(npm view --json ${package} versions | jq -r 'if type == "string" then . else .[] end')
+              do
+                pluginInfo=$(npm view --json ${package}@${version} | jq '. | {name, version, directory: .repository.directory, gitHead }')
+                workspace=$(echo ${pluginInfo} | jq -r '.directory' | sed -e 's:workspaces/\([^/]*\)/plugins/.*:\1:')
+                gitHead=$(echo ${pluginInfo} | jq -r '.gitHead')
+                backstageVersion=$(curl -s https://raw.githubusercontent.com/backstage/community-plugins/${gitHead}/workspaces/${workspace}/backstage.json | jq -r '.version')
+
+                branch=""
+                for supportedBackstageVersion in ${backstageVersions}
+                do
+                  if [[ "${supportedBackstageVersion}" == "$(semver -r ~${backstageVersion} ${supportedBackstageVersion})" ]]
+                  then
+                    branch=$(cat branches.json | jq -r "to_entries | map( select(.value == \"${supportedBackstageVersion}\") | .key )[]")
+                    break
+                  fi
+                done
+
+                if [[ "${branch}" == "" ]]
+                then
+                  echo "Skipping published plugin ${package}@${version}, since the underlying Backstage version ${backstageVersion} is not used by RHDH" >&2
+                  continue
+                fi
+
+                addedFields="{\"workspace\":\"$workspace\", \"backstageVersion\": \"$backstageVersion\", \"branch\": \"$branch\"}"
+                pluginInfo=$(echo "${pluginInfo}" | jq ".+= $addedFields")
+                echo -n "${comma} ${pluginInfo}"
+                comma=','
+              done
+            done
+            echo ']'
+          )
+
+          echo "Plugins to analyze:"
+          echo "$plugins"
+          echo "$plugins" | jq -c > published-plugins.json
+
+      - name: Gather Workspaces
+        id: gather-workspaces
+        shell: bash
+        run: |
+            plugins=$(cat published-plugins.json)
+            workspaces=$(echo ${plugins} | jq 'group_by(.branch + "__" + .workspace) | map({ (.[0].branch + "__" + .[0].workspace): {"workspace": .[0].workspace, "branch": .[0].branch, "backstageVersion": .[0].backstageVersion, "plugins": (. | group_by(.name) | map(. | sort_by(.version) | last ) )} }) | add')
+  
+            echo "Workspaces:"
+            echo "$workspaces"
+  
+            echo "$workspaces" | jq -c > workspaces.json
+            echo "workspace-keys=$(echo $workspaces | jq -c keys)" >> $GITHUB_OUTPUT
+
+      - name: Upload workspaces json file
+        uses: actions/upload-artifact@v4
+        with:
+          name: workspaces
+          path: workspaces.json
+              
+  export:
+    name: Export
+
+    needs: prepare
+    runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        workspace: ${{ fromJSON(needs.prepare.outputs.workspace-keys) }}
+
+    steps:
+
+      - uses: actions/checkout@b4ffde65f46336ab88eb53be808477a3936bae11 # v4.1.1
+
+      - name: Download workspaces json file
+        uses: actions/download-artifact@v4
+        with:
+          name: workspaces
+
+      - name: Get workspace JSON
+        id: get-workspace-json
+        shell: bash
+        run: |
+          workspace="$(cat workspaces.json | jq '.["${{ matrix.workspace }}"]')"
+          echo "Workspace:"
+          echo "${workspace}"
+
+          echo workspace=$(echo "${workspace}" | jq -c) >> $GITHUB_OUTPUT
+
+      - name: Get workspace Commit ID
+        id: get-workspace-commit-id
+        shell: bash
+        run: |
+          workspace='${{ steps.get-workspace-json.outputs.workspace }}'
+          commits=$(echo "$workspace" | jq -r '[ .plugins[] | .gitHead ] | unique | .[]')
+          pluginDirectories=$(echo '${{ steps.get-workspace-json.outputs.workspace }}' | jq -r '.plugins[] | .directory')
+          if [[ $(echo ${commits} | wc -w) == 1 ]]
+          then
+            workspaceCommit="${commits}"
+          else
+            workspaceCommit=""
+            for commit in ${commits}
+            do
+              for pluginDirectory in ${pluginDirectories}
+              do
+                packageJson=$(curl -s https://raw.githubusercontent.com/backstage/community-plugins/${commit}/${pluginDirectory}/package.json)
+                version=$(echo "${packageJson}" | jq -r '.version')
+                workspaceVersion=$(echo "${workspace}" | jq -r ".plugins[] | select(.directory == \"${pluginDirectory}\") | .version")
+                pluginName=$(echo "${workspace}" | jq -r ".plugins[] | select(.directory == \"${pluginDirectory}\") | .name")
+                if [[ "${version}" != "${workspaceVersion}" ]]
+                then
+                  echo "Skipping commit ${commit}: plugin ${pluginName} version not the latest version: ${version} != ${workspaceVersion}"
+                  continue 2
+                fi
+              done
+              if [[ "${workspaceCommit}" != "" ]]
+              then
+                echo "Cannot decide between workspace commits: ${commit} and ${workspaceCommit}"
+                break 2
+              fi
+              workspaceCommit="${commit}"
+            done
+          fi
+          echo "Workspace commit: ${workspaceCommit}"
+          echo "workspace-commit=${workspaceCommit}" >> $GITHUB_OUTPUT
+          
+      - name: Create PR if necessary
+        id: create-pr-if-necessary
+        uses: actions/github-script@v7
+        with:
+          script: |
+            const owner = '${{ github.repository_owner }}';
+            const repo = '${{ github.repository }}'.replace(owner + '/', '');
+            const pluginsRepoOwner = 'backstage';
+            const pluginsRepo = 'community-plugins';
+            const prBranchName = 'workspaces/${{ matrix.workspace }}';
+            const workspaceCommit = '${{ steps.get-workspace-commit-id.outputs.workspace-commit }}';
+            const workspaceJson ='${{ steps.get-workspace-json.outputs.workspace }}';
+
+            const script = require('.github/workflows/create-pr-if-necessary.js');
+            await script({
+              github,
+              core,
+              owner,
+              repo,
+              pluginsRepoOwner,
+              pluginsRepo,
+              prBranchName,
+              workspaceCommit,
+              workspaceJson,
+            });
diff --git a/branches.json b/branches.json
new file mode 100644
index 0000000..b145728
--- /dev/null
+++ b/branches.json
@@ -0,0 +1,3 @@
+{
+  "1.2.x": "1.26.5"
+}