add paging

src/delete.ts

@@ -1,47 +1,134 @@
 import {Input} from './input'
-import {Observable, of, throwError} from 'rxjs'
+import {EMPTY, Observable, of, throwError} from 'rxjs'
 import {deletePackageVersions, getOldestVersions} from './version'
-import {concatMap, map} from 'rxjs/operators'
+import {concatMap, map, expand, tap} from 'rxjs/operators'
 
-export function getVersionIds(input: Input): Observable<string[]> {
+export interface VersionInfo {
+  id: string
+  version: string
+}
+
+export interface QueryInfo {
+  versions: VersionInfo[]
+  cursor: string
+  paginate: boolean
+  totalCount: number
+}
+
+let totalCount: number
+
+export function getVersionIds(
+  owner: string,
+  repo: string,
+  packageName: string,
+  numVersions: number,
+  ignoreVersions: RegExp,
+  cursor: string,
+  token: string
+): Observable<VersionInfo[]> {
+  return getOldestVersions(
+    owner,
+    repo,
+    packageName,
+    numVersions,
+    ignoreVersions,
+    cursor,
+    token
+  ).pipe(
+    expand(value =>
+      value.paginate
+        ? getOldestVersions(
+            owner,
+            repo,
+            packageName,
+            numVersions,
+            ignoreVersions,
+            value.cursor,
+            token
+          )
+        : EMPTY
+    ),
+    tap(value => (totalCount = value.totalCount)),
+    map(value => value.versions),
+    tap(value =>
+      value.map(info =>
+        console.log(`id0: ${info.id}, version: ${info.version}`)
+      )
+    )
+  )
+}
+
+export function finalIds(input: Input): Observable<string[]> {
   if (input.packageVersionIds.length > 0) {
     return of(input.packageVersionIds)
   }
-
   if (input.hasOldestVersionQueryInfo()) {
-    return getOldestVersions(
-      input.owner,
-      input.repo,
-      input.packageName,
-      input.numOldVersionsToDelete + input.minVersionsToKeep,
-      input.token
-    ).pipe(
-      map(versionInfo => {
-        const numberVersionsToDelete =
-          versionInfo.length - input.minVersionsToKeep
-
-        if (input.minVersionsToKeep > 0) {
-          return numberVersionsToDelete <= 0
-            ? []
-            : versionInfo
-                .filter(info => !input.ignoreVersions.test(info.version))
-                .map(info => info.id)
-                .slice(0, -input.minVersionsToKeep)
-        } else {
-          return numberVersionsToDelete <= 0
-            ? []
-            : versionInfo
-                .filter(info => !input.ignoreVersions.test(info.version))
-                .map(info => info.id)
-                .slice(0, numberVersionsToDelete)
-        }
-      })
-    )
+    if (input.minVersionsToKeep < 0) {
+      console.log(`in numOldVersionsToDelete`)
+      return getVersionIds(
+        input.owner,
+        input.repo,
+        input.packageName,
+        input.numOldVersionsToDelete,
+        input.ignoreVersions,
+        '',
+        input.token
+      ).pipe(
+        map(value => {
+          const temp = input.numOldVersionsToDelete
+          input.numOldVersionsToDelete =
+            input.numOldVersionsToDelete - value.length <= 0
+              ? 0
+              : input.numOldVersionsToDelete - value.length
+          console.log(
+            `temp: ${temp} numVersions: ${input.numOldVersionsToDelete} ignore-versions: ${input.ignoreVersions}`
+          )
+          return value
+            .filter(info => !input.ignoreVersions.test(info.version))
+            .map(info => info.id)
+            .slice(0, temp)
+        })
+      )
+    } else {
+      console.log(`in min versions to keep`)
+      return getVersionIds(
+        input.owner,
+        input.repo,
+        input.packageName,
+        100,
+        input.ignoreVersions,
+        '',
+        input.token
+      ).pipe(
+        map(value => {
+          console.log(`point 1`)
+          const toDelete =
+            totalCount -
+            value.filter(info => !input.ignoreVersions.test(info.version))
+              .length -
+            input.minVersionsToKeep
+          console.log(
+            `toDelete: ${toDelete} numVersions: ${input.numOldVersionsToDelete} total count: ${totalCount}`
+          )
+          if (toDelete > input.numOldVersionsToDelete) {
+            //here input.numOldVersionsToDelete will never have user value hence using it to keep track of deleted versions
+            input.numOldVersionsToDelete =
+              input.numOldVersionsToDelete + value.length
+            return toDelete - input.numOldVersionsToDelete >= 0
+              ? value
+                  .filter(info => !input.ignoreVersions.test(info.version))
+                  .map(info => info.id)
+              : value
+                  .filter(info => !input.ignoreVersions.test(info.version))
+                  .map(info => info.id)
+                  .slice(0, toDelete - input.numOldVersionsToDelete)
+          } else return []
+        })
+      )
+    }
   }
 
-  return throwError(
-    "Could not get packageVersionIds. Explicitly specify using the 'package-version-ids' input or provide the 'package-name' and 'num-old-versions-to-delete' inputs to dynamically retrieve oldest versions"
-  )
+  return throwError(`no package id found`)
 }
 
 export function deleteVersions(input: Input): Observable<boolean> {
@@ -50,17 +137,17 @@ export function deleteVersions(input: Input): Observable<boolean> {
   }
 
   if (!input.checkInput()) {
-    return throwError('Invalid input combination')
+    return throwError('Invlaid input combination')
   }
 
-  if (input.numOldVersionsToDelete <= 0) {
+  if (input.numOldVersionsToDelete <= 0 && input.minVersionsToKeep < 0) {
     console.log(
       'Number of old versions to delete input is 0 or less, no versions will be deleted'
     )
     return of(true)
   }
 
-  return getVersionIds(input).pipe(
+  return finalIds(input).pipe(
     concatMap(ids => deletePackageVersions(ids, input.token))
   )
 }