chore: wip

Author: chrisbbreuer

storage/framework/core/path/src/index.ts

@@ -366,6 +366,10 @@ export function scriptsPath(path?: string) {
   return frameworkPath(`scripts/${path || ''}`)
 }
 
+export function schedulePath() {
+  return appPath(`Schedule.ts`)
+}
+
 export function schedulerPath(path?: string) {
   return corePath(`scheduler/${path || ''}`)
 }
@@ -523,6 +527,7 @@ export const path = {
   signalsPath,
   slugPath,
   scriptsPath,
+  schedulePath,
   securityPath,
   serverPath,
   serverlessPath,

storage/framework/core/queue/src/index.ts

@@ -8,14 +8,16 @@ export class Job {
   rate: JobOptions['rate']
   tries: JobOptions['tries']
   backoff: JobOptions['backoff']
+  enabled: JobOptions['enabled']
 
-  constructor({ name, description, handle, rate, tries, backoff, action }: JobOptions) {
+  constructor({ name, description, handle, rate, tries, backoff, action, enabled }: JobOptions) {
     this.name = name
     this.description = description
     this.handle = handle
     this.rate = rate
     this.action = action
     this.tries = tries
     this.backoff = backoff
+    this.enabled = enabled
   }
 }

storage/framework/core/scheduler/src/schedule.ts

@@ -23,6 +23,11 @@ export class Schedule {
     return this
   }
 
+  everyTwoMinutes() {
+    this.cronPattern = '*/2 * * * * *'
+    return this
+  }
+
   everyFiveMinutes() {
     this.cronPattern = '*/5 * * * *'
     return this

storage/framework/core/utils/src/index.ts

@@ -16,6 +16,7 @@ export * from './math'
 export * from './p'
 export * from './promise'
 export * from './regex'
+export * from './retry'
 export * from './sleep'
 export * from './throttle'
 export * from './vendors'

storage/framework/core/utils/src/retry.ts

@@ -0,0 +1,33 @@
+export function retry(fn, options) {
+  const { retries = 3, initialDelay = 1000, backoffFactor = 2, jitter = true } = options
+
+  return new Promise((resolve, reject) => {
+    let attemptCount = 0
+    const attempt = async () => {
+      try {
+        resolve(await fn())
+      }
+      catch (err) {
+        if (attemptCount >= retries) {
+          reject(err)
+        }
+        else {
+          const delay = calculateDelay(attemptCount, initialDelay, backoffFactor, jitter)
+          setTimeout(() => attempt(), delay)
+          attemptCount++
+        }
+      }
+    }
+    attempt()
+  })
+}
+
+function calculateDelay(attemptCount, initialDelay, backoffFactor, jitter) {
+  let delay = initialDelay * backoffFactor ** attemptCount
+  if (jitter) {
+    const random = Math.random() // Generates a number between 0 and 1
+    const jitterValue = delay * 0.3 // Jitter will be up to 30% of the delay
+    delay = delay + jitterValue * (random - 0.5) * 2 // Adjust delay randomly within ±30%
+  }
+  return delay
+}