Add scheduled airtable update

totallymoney · Jun 12, 2020 · 2c40dd1 · 2c40dd1
1 parent 7085cc9
commit 2c40dd1
Show file tree

Hide file tree

Showing 6 changed files with 20 additions and 0 deletions.
diff --git a/paket.dependencies b/paket.dependencies
@@ -5,6 +5,7 @@ nuget FSharp.Core
 nuget FSharp.Data
 nuget Amazon.Lambda.APIGatewayEvents
 nuget Amazon.Lambda.Core
+nuget Amazon.Lambda.CloudWatchLogsEvents
 nuget Amazon.Lambda.Serialization.SystemTextJson
 nuget AWSSDK.Core
 nuget AWSSDK.DynamoDBv2

diff --git a/paket.lock b/paket.lock
@@ -2,6 +2,7 @@ RESTRICTION: == netcoreapp3.1
 NUGET
   remote: https://api.nuget.org/v3/index.json
     Amazon.Lambda.APIGatewayEvents (2.1)
+    Amazon.Lambda.CloudWatchLogsEvents (2.0)
     Amazon.Lambda.Core (1.1)
     Amazon.Lambda.Serialization.SystemTextJson (2.0.1)
       Amazon.Lambda.Core (>= 1.1)

diff --git a/serverless.yml b/serverless.yml
@@ -72,6 +72,13 @@ functions:
           path: "/updateFromAirtable"
           cors: true
 
+  scheduledAirtableUpdate:
+    handler: BigHack.Fumble.Api::BigHack.Fumble.Api.LambdaFunctions::scheduledAirtableUpdate
+    events:
+      - cloudwatchEvent:
+          name: bighack-fumble-api-${self:provider.stage}-airtable-update
+          schedule: rate(1 minutes)
+
 resources:
   Resources:
     CardsDynamoDBTable:

diff --git a/src/BigHack.Fumble.Api.fsproj b/src/BigHack.Fumble.Api.fsproj
@@ -3,6 +3,7 @@
   <PropertyGroup>
     <TargetFramework>netcoreapp3.1</TargetFramework>
     <GenerateRuntimeConfigurationFiles>true</GenerateRuntimeConfigurationFiles>
+    <AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
   </PropertyGroup>
   <ItemGroup>
     <Compile Include="TypeExtensions.fs" />

diff --git a/src/LambdaFunctions.fs b/src/LambdaFunctions.fs
@@ -3,6 +3,7 @@ module BigHack.Fumble.Api.LambdaFunctions
 open Amazon.Lambda.Core
 open Amazon.Lambda.APIGatewayEvents
 open Amazon.Lambda.Serialization.SystemTextJson
+open Amazon.Lambda.CloudWatchLogsEvents
 
 open BigHack.Fumble.Api
 open BigHack.Fumble.Api.TypeExtensions
@@ -34,3 +35,11 @@ let updateFromAirtable (gatewayRequest : APIGatewayProxyRequest)
                          "UpdateCards"
                          (fun ctx () -> Workflow.updateFromAirtable ctx)
                          ResponseDto.mapEmptyResultToDto
+
+[<LambdaSerializer(typeof<DefaultLambdaJsonSerializer>)>]
+let scheduledAirtableUpdate (cloudwatchEvent : CloudWatchLogsEvent)
+                            (lambdaContext : ILambdaContext) =
+    Ok ()
+    |> handleAsyncEvent lambdaContext
+                        "ScheduledAirtableUpdate"
+                        (fun ctx () -> Workflow.updateFromAirtable ctx)
diff --git a/src/paket.references b/src/paket.references
@@ -1,6 +1,7 @@
 FSharp.Core
 FSharp.Data
 Amazon.Lambda.APIGatewayEvents
+Amazon.Lambda.CloudWatchLogsEvents
 Amazon.Lambda.Core
 Amazon.Lambda.Serialization.SystemTextJson
 AWSSDK.Core