fix: better types

README.md

@@ -23,7 +23,9 @@ plugins:
 ```sh
 λ → sls schedule
 Serverless: Starting serverless-offline-schedule in standalone process. Press CTRL + C to stop.
-Serverless: Scheduling [my-function] with [*/1 * * * *]
+Serverless: Scheduling [schedule-function] cron: [*/1 * * * *] input: {"scheduler":"1-minute"}
+...
+Serverless: Succesfully invoked scheduled function: [my-function]
 ```
 
 #### Part of serverless-offline
@@ -33,5 +35,7 @@ Serverless: Scheduling [my-function] with [*/1 * * * *]
 ```sh
 λ → sls offline
 ...
-Serverless: Scheduling [my-function] with [*/1 * * * *]
+Serverless: Scheduling [schedule-function] cron: [*/1 * * * *] input: {"scheduler":"1-minute"}
+...
+Serverless: Succesfully invoked scheduled function: [my-function]
 ```

src/scheduler.ts

@@ -12,6 +12,12 @@ type SchedulerConfig = {
   functionProvider: FunctionProvider;
 };
 
+type FunctionConfiguration = {
+  input: object;
+  functionName: string;
+  cron: string;
+};
+
 class OfflineScheduler {
   private log: (message: string) => void;
   private functionProvider: FunctionProvider;
@@ -32,20 +38,20 @@ class OfflineScheduler {
 
     configurations.forEach(functionConfiguration => {
       const { functionName, cron, input } = functionConfiguration;
-      this.log(`Scheduling [${functionName}] with [${cron}]`);
+      this.log(`Scheduling [${functionName}] cron: [${cron}] input: ${JSON.stringify(input)}`);
 
       schedule.scheduleJob(cron, () => {
         const func = slsInvokeFunction(functionName, input);
         if (func === undefined) {
           this.log(`Unable to find source for function [${functionName}]`);
           return;
         }
-        this.log(`Succesfully run scheduled function: [${functionName}]`);
+        this.log(`Succesfully invoked scheduled function: [${functionName}]`);
       });
     });
   };
 
-  private getFunctionConfigurations = () => {
+  private getFunctionConfigurations = (): FunctionConfiguration[] => {
     const functions = this.functionProvider();
 
     const scheduleConfigurations = Object.keys(functions).map(functionName => {
@@ -57,7 +63,7 @@ class OfflineScheduler {
         return {
           functionName,
           cron: convertExpressionToCron(event['schedule'].rate),
-          input: event['schedule'].input,
+          input: event['schedule'].input || {},
         };
       });
     });

tests/scheduler.spec.ts

@@ -64,7 +64,9 @@ describe('OfflineScheduler', () => {
     });
 
     scheduler.scheduleEvents();
-    expect(log).toBeCalledWith('Scheduling [schedule-function] with [*/1 * * * *]');
+    expect(log).toBeCalledWith(
+      'Scheduling [schedule-function] cron: [*/1 * * * *] input: {"scheduler":"1-minute"}'
+    );
     expect(scheduleJob).toBeCalledTimes(1);
   });
 
@@ -81,7 +83,10 @@ describe('OfflineScheduler', () => {
       1,
       'Starting serverless-offline-schedule in standalone process. Press CTRL + C to stop.'
     );
-    expect(log).nthCalledWith(2, 'Scheduling [schedule-function] with [*/1 * * * *]');
+    expect(log).nthCalledWith(
+      2,
+      'Scheduling [schedule-function] cron: [*/1 * * * *] input: {"scheduler":"1-minute"}'
+    );
     expect(scheduleJob).toBeCalledTimes(1);
   });
 });

typings/Serverless.d.ts

@@ -35,7 +35,7 @@ declare namespace Serverless {
     extraServicePath?: string;
   }
 
-  type Event = { [type: string]: { rate: string; input: object } };
+  type Event = { [type: string]: { rate: string; input?: object } };
 
   interface Function {
     handler: string;