configure ci processing

index.ts

@@ -2,7 +2,11 @@ import * as Commander from 'commander'
 import * as Actions from '@actions/core'
 import * as Os from 'node:os'
 import * as Fs from 'node:fs'
+import PLimit from 'p-limit'
 import { RequestNpmPackageMetaData } from './sources/npm-api.js'
+import { HistoryManager } from './sources/github.js'
+import { PurgeRequestManager } from './sources/requests.js'
+import { FileManager } from './sources/file.js'
 
 Actions.info(`Running on ${Os.cpus()[0].model} with ${Os.cpus().length} threads/vCPUs.`)
 
@@ -37,3 +41,19 @@ const Options = Program.opts() as {
 	repo: string
 }
 
+const CurrrentTags = (await RequestNpmPackageMetaData(Options.package))['dist-tags']
+Fs.writeFileSync('/tmp/dist-tag.json', JSON.stringify(CurrrentTags))
+const OlderTags = await new HistoryManager({ Repo: Options.repo, GitHubToken: Options.ghToken, WorkflowRef: Options.workflowRef }).RequestHistory()
+
+const PLimitInstance = PLimit(Os.cpus().length)
+const PLimitJobs: Promise<void>[] = []
+for (const TargetTag of Options.distTag.split(' ')) {
+	PLimitJobs.push(PLimitInstance(async () => {
+		const ChangedFiles = await new FileManager(Options.repo, { A: CurrrentTags[TargetTag], B: OlderTags === null ? undefined : OlderTags[TargetTag] }, `${Options.ciWorkspacePath}/${TargetTag}`).Union()
+		const PurgeRequestManagerInstance = new PurgeRequestManager(Options.repo)
+		PurgeRequestManagerInstance.AddURLs(ChangedFiles, TargetTag)
+		PurgeRequestManagerInstance.Start()
+	}))
+}
+
+await Promise.all(PLimitJobs)

package.json

@@ -23,6 +23,7 @@
     "es-toolkit": "^1.17.0",
     "got": "^14.4.2",
     "luxon": "^3.5.0",
+    "p-limit": "^6.1.0",
     "tar": "^7.4.3",
     "tsx": "^4.19.0",
     "typescript": "^5.5.4",

sources/github.ts

@@ -8,7 +8,7 @@ export type IHistoryManagerDataJSON = Record<string, string>
 export class HistoryManager {
   private GitHubInstance: InstanceType<typeof GitHub.Octokit> = null
 
-  constructor(private readonly Config: { Repo: string, GitHubToken: string, WorkflowRef: string, DistTags: string }) {
+  constructor(private readonly Config: { Repo: string, GitHubToken: string, WorkflowRef: string }) {
     this.GitHubInstance = new GitHub.Octokit({ auth: this.Config.GitHubToken })
   }
 
@@ -36,7 +36,7 @@ export class HistoryManager {
     return GHResponseRuns.data.total_count > 0
   }
 
-  private async RequestHistory() {
+  async RequestHistory() {
     if (!await this.CheckWorkflowRunExist()) {
       return null
     }