add suave server HTTP endpoint

Author: tamizhvendan

fsharp/HopacSeries/Part3/ApiGateway.fsx

@@ -9,10 +9,15 @@ open FSharp.Data
 #r "packages/FSharp.Data/lib/net45/FSharp.Data.dll"
 #r "packages/Http.fs/lib/net461/HttpFs.dll"
 #r "packages/System.Net.Http/lib/net46/System.Net.Http.dll"
+#r "packages/Suave/lib/net40/Suave.dll"
 
 open Hopac
 open FSharp.Data
 open HttpFs.Client
+open Suave
+open Suave.Successful
+open Suave.Filters
+open System.Threading
 
 type UserTypeProvider = JsonProvider<"https://api.github.com/users/tamizhvendan">
 type User = UserTypeProvider.Root
@@ -144,6 +149,8 @@ type UserDto = {
       "avatarUrl", JsonValue.String u.AvatarUrl
       "topThreeRepos", topThreeRepos
     |]
+  static member ToJsonString(u : UserDto) =
+    UserDto.ToJson(u).ToString()
 
 let repoDto (repo : Repo) languages = {
   Name = repo.Name
@@ -171,9 +178,45 @@ let getUserDto username = job {
   }
 }
 
-#time "on"
-getUserDto "haf"
-|> Job.map (UserDto.ToJson)  
-|> Job.map (fun x -> x.ToString())
-|> run
-#time "off"
+
+open Suave.Operators
+
+let getUserApi username ctx = async {
+  let! userDtoResponse =
+    getUserDto username
+    |> Job.catch
+    |> Job.toAsync
+  match userDtoResponse with
+  | Choice1Of2 userDto ->
+    let res =
+      userDto
+      |> UserDto.ToJsonString
+      |> OK
+      >=> Writers.setMimeType "application/json; charset=utf-8"
+    return! res ctx
+  | Choice2Of2 ex ->
+    printfn "%A" ex
+    return! ServerErrors.INTERNAL_ERROR "something went wrong" ctx
+}
+
+let app = pathScan "/api/profile/%s" getUserApi
+
+let startServer () =
+  let cts = new CancellationTokenSource()
+  let listening, server = 
+    startWebServerAsync defaultConfig app
+  Async.Start(server, cts.Token) |> ignore
+  Async.RunSynchronously listening |> ignore
+  cts
+
+let stopServer (cts : CancellationTokenSource) =
+  cts.Cancel true
+  cts.Dispose()
+
+
+// #time "on"
+// getUserDto "haf"
+// |> Job.map (UserDto.ToJson)  
+// |> Job.map (fun x -> x.ToString())
+// |> run
+// #time "off"

fsharp/HopacSeries/Part3/paket.dependencies

@@ -3,4 +3,5 @@ framework: net461
 nuget FSharp.Data
 nuget Hopac
 nuget Http.Fs
+nuget Suave
 nuget System.Net.Http

fsharp/HopacSeries/Part3/paket.lock

@@ -8,6 +8,8 @@ NUGET
     Http.fs (5.0.1)
       FSharp.Core (>= 4.1.18)
       Hopac (>= 0.3.23)
+    Suave (2.2.1)
+      FSharp.Core (>= 4.0.0.1)
     System.Net.Http (4.3.3)
       System.Security.Cryptography.X509Certificates (>= 4.3)
     System.Security.Cryptography.Algorithms (4.3.1)