WIP create session

Author: blaix

src/Route/Session.gren

@@ -8,6 +8,7 @@ import Db
 import Email exposing (Email)
 import HttpServer.Response as Response exposing (Response)
 import Json.Decode
+import Session exposing (Session)
 import Task exposing (Task)
 import User exposing (User)
 
@@ -20,6 +21,7 @@ type Error
 create : Db.Connection -> Response -> Bytes -> Task Never Response
 create db response requestBody =
     findOrCreateUser db requestBody
+        |> Task.andThen (createSession db)
         |> Task.andThen (\_ -> success response)
         |> Task.onError (\e -> failed response e)
 
@@ -35,6 +37,12 @@ findOrCreateUser db requestBody =
                 |> Task.mapError DbError
 
 
+createSession : Db.Connection -> User -> Task Error Session
+createSession db user =
+    Session.create db user
+        |> Task.mapError DbError
+
+
 success : Response -> Task x Response
 success response =
     Task.succeed response

src/Session.gren

@@ -0,0 +1,18 @@
+module Session exposing
+    ( Session
+    , create
+    )
+
+
+import Db
+import Task exposing (Task)
+import User exposing (User)
+
+
+type Session =
+    Session
+
+
+create : Db.Connection -> User -> Task Db.Error Session
+create db user =
+    Debug.todo "test-drive Session.create"

src/Test/E2E/Helper.gren

@@ -1,15 +1,18 @@
 module Test.E2E.Helper exposing
     ( expectBadStatus
+    , expectJson
     , initDb
     , get
     , post
     , postWithJson
     )
 
 
+import Bytes exposing (Bytes)
 import Db
 import Expect exposing (Expectation)
 import HttpClient exposing (Response)
+import Json.Decode
 import Json.Encode
 import Task exposing (Task)
 
@@ -41,11 +44,11 @@ post httpPerm path =
         |> HttpClient.send httpPerm
 
 
-postWithJson : HttpClient.Permission -> String -> Json.Encode.Value -> Task HttpClient.Error (HttpClient.Response {})
+postWithJson : HttpClient.Permission -> String -> Json.Encode.Value -> Task HttpClient.Error (HttpClient.Response Bytes)
 postWithJson httpPerm path json =
     url path
         |> HttpClient.post
-        |> HttpClient.expectAnything
+        |> HttpClient.expectBytes
         |> HttpClient.withJsonBody json
         |> HttpClient.send httpPerm
 
@@ -59,3 +62,18 @@ expectBadStatus status error =
             Expect.fail <|
                 "Expected HttpClient.BadStatus, Got: " ++
                 (Debug.toString error)
+
+
+expectJson : Json.Decode.Decoder a -> a -> Bytes -> Expectation
+expectJson decoder expected bytes =
+    when Bytes.toString bytes is
+        Nothing ->
+            Expect.fail "Failed to decode bytes"
+
+        Just json ->
+            when Json.Decode.decodeString decoder json is
+                Ok value ->
+                    Expect.equal expected value
+
+                Err error ->
+                    Expect.fail (Json.Decode.errorToString error)

src/Test/E2E/Route/Session.gren

@@ -1,16 +1,18 @@
 module Test.E2E.Route.Session exposing (tests)
 
 
+import Bytes
 import Db
 import Db.Encode
 import Db.Decode
 import Email
 import Expect
 import HttpClient
+import Json.Decode
 import Json.Encode
 import Task exposing (Task)
 import Test.Runner.Effectful exposing (Test, await, awaitError, concat, describe, test)
-import Test.E2E.Helper exposing (initDb, get, post, postWithJson, expectBadStatus)
+import Test.E2E.Helper exposing (initDb, get, post, postWithJson, expectBadStatus, expectJson)
 import User exposing (User)
 
 
@@ -62,10 +64,29 @@ tests httpPerm =
                 [ test "Responds successfully" <| \_ ->
                     Expect.equal 200 response.statusCode
 
-                , await "Getting created user from db" (getUser goodEmail) <| \user ->
-                    test "returns the created user" <| \_ ->
-                        Email.toString user.email
-                            |> Expect.equal goodEmail
+                , await "Getting session info from db" 
+                    (Db.getOne db
+                        { query = 
+                            """
+                            select fetch_session_token from session
+                            inner join user on (user.id = session.user_id)
+                            where user.email = :email
+                            order by session.created desc
+                            limit 1
+                            """
+                        , parameters =
+                            [ Db.Encode.string "email" goodEmail ]
+                        , decoder =
+                            Db.Decode.string "fetch_session_token"
+                        }
+                    )
+                    (\expectedToken ->
+                        test "responds with fetch session token" <| \_ ->
+                            response.data
+                                |> expectJson
+                                    (Json.Decode.field "fetch_session_token" Json.Decode.string)
+                                    expectedToken
+                    )
                 ]
         ]
     ]