Private pusher channel

client/src/elm/App/Model.elm

@@ -11,6 +11,7 @@ import App.PageType exposing (Page(..))
 import Config.Model
 import Date exposing (Date)
 import Pages.Login.Model exposing (emptyModel, Model)
+import Pusher.Model
 import RemoteData exposing (RemoteData(..), WebData)
 import ItemManager.Model exposing (emptyModel, Model)
 import Time exposing (Time)
@@ -21,11 +22,13 @@ type Msg
     = HandleOfflineEvent (Result String Bool)
     | Logout
     | MsgItemManager ItemManager.Model.Msg
+    | MsgPusher Pusher.Model.Msg
     | PageLogin Pages.Login.Model.Msg
     | SetActivePage Page
     | SetCurrentDate Date
     | Tick Time
     | ToggleSideBar
+    | NoOp
 
 
 type alias Model =
@@ -36,6 +39,7 @@ type alias Model =
     , offline : Bool
     , pageLogin : Pages.Login.Model.Model
     , pageItem : ItemManager.Model.Model
+    , pusher : Pusher.Model.Model
     , sidebarOpen : Bool
     , user : WebData User
     }
@@ -61,6 +65,7 @@ emptyModel =
     , offline = False
     , pageLogin = Pages.Login.Model.emptyModel
     , pageItem = ItemManager.Model.emptyModel
+    , pusher = Pusher.Model.emptyModel
     , sidebarOpen = False
     , user = NotAsked
     }

client/src/elm/App/PageType.elm

@@ -1,6 +1,6 @@
 module App.PageType exposing (Page(..))
 
-{-| Prevent circula dependency.
+{-| Prevent circular dependency.
 -}
 
 

client/src/elm/App/Test.elm

@@ -44,7 +44,11 @@ getPageAsAuthenticated : Page -> Page
 getPageAsAuthenticated page =
     let
         dummyUser =
-            { id = 100, name = "Foo", avatarUrl = "https://example.com" }
+            { id = 100
+            , name = "Foo"
+            , avatarUrl = "https://example.com"
+            , pusherChannel = "general"
+            }
 
         model =
             { emptyModel | user = Success dummyUser }

client/src/elm/App/Update.elm

@@ -5,14 +5,13 @@ import App.PageType exposing (Page(..))
 import Config
 import Date
 import Dict
-import Http
 import ItemManager.Model
 import ItemManager.Update
 import Json.Decode exposing (bool, decodeValue)
 import Json.Encode exposing (Value)
 import Pages.Login.Update
 import Pusher.Model
-import Pusher.Utils exposing (getClusterName)
+import Pusher.Update
 import RemoteData exposing (RemoteData(..), WebData)
 import Task
 import Time exposing (minute)
@@ -30,12 +29,7 @@ init flags =
                 Just config ->
                     let
                         defaultCmds =
-                            [ pusherKey
-                                ( config.pusherKey.key
-                                , getClusterName config.pusherKey.cluster
-                                , Pusher.Model.eventNames
-                                )
-                            , Task.perform SetCurrentDate Date.now
+                            [ Task.perform SetCurrentDate Date.now
                             ]
 
                         ( cmds, activePage_ ) =
@@ -87,13 +81,20 @@ update msg model =
                 model ! []
 
             Logout ->
-                ( { emptyModel
-                    | accessToken = ""
-                    , activePage = Login
-                    , config = model.config
-                  }
-                , accessTokenPort ""
-                )
+                let
+                    ( _, pusherLogout ) =
+                        update (MsgPusher Pusher.Model.Logout) model
+                in
+                    ( { emptyModel
+                        | accessToken = ""
+                        , activePage = Login
+                        , config = model.config
+                      }
+                    , Cmd.batch
+                        [ accessTokenPort ""
+                        , pusherLogout
+                        ]
+                    )
 
             MsgItemManager subMsg ->
                 case model.user of
@@ -124,6 +125,15 @@ update msg model =
                         -- If we don't have a user, we have nothing to do.
                         model ! []
 
+            MsgPusher subMsg ->
+                let
+                    ( val, cmd ) =
+                        Pusher.Update.update backendUrl subMsg model.pusher
+                in
+                    ( { model | pusher = val }
+                    , Cmd.map MsgPusher cmd
+                    )
+
             PageLogin msg ->
                 let
                     ( val, cmds, ( webDataUser, accessToken ) ) =
@@ -166,6 +176,7 @@ update msg model =
                         [ Cmd.map PageLogin cmds
                         , accessTokenPort accessToken
                         , setActivePageCmds
+                        , pusherLogin model webDataUser accessToken
                         ]
                     )
 
@@ -205,6 +216,9 @@ update msg model =
             ToggleSideBar ->
                 { model | sidebarOpen = not model.sidebarOpen } ! []
 
+            NoOp ->
+                model ! []
+
 
 {-| Determine is a page can be accessed by a user (anonymous or authenticated),
 and if not return a access denied page.
@@ -240,6 +254,7 @@ subscriptions model =
         [ Sub.map MsgItemManager <| ItemManager.Update.subscriptions model.pageItem model.activePage
         , Time.every minute Tick
         , offline (decodeValue bool >> HandleOfflineEvent)
+        , Sub.map MsgPusher <| Pusher.Update.subscription
         ]
 
 
@@ -248,11 +263,35 @@ subscriptions model =
 port accessTokenPort : String -> Cmd msg
 
 
-{-| Send Pusher key and cluster to JS.
--}
-port pusherKey : ( String, String, List String ) -> Cmd msg
-
-
 {-| Get a singal if internet connection is lost.
 -}
 port offline : (Value -> msg) -> Sub msg
+
+
+pusherLogin : Model -> WebData User -> String -> Cmd Msg
+pusherLogin model webDataUser accessToken =
+    let
+        pusherLoginMsg pusherKey pusherChannel =
+            MsgPusher <|
+                Pusher.Model.Login
+                    pusherKey
+                    pusherChannel
+                    (Pusher.Model.AccessToken accessToken)
+
+        msg =
+            case webDataUser of
+                Success user ->
+                    case model.config of
+                        Success config ->
+                            pusherLoginMsg config.pusherKey user.pusherChannel
+
+                        _ ->
+                            NoOp
+
+                _ ->
+                    NoOp
+
+        ( _, pusherLogin ) =
+            update msg model
+    in
+        pusherLogin

client/src/elm/Item/Decoder.elm

@@ -15,6 +15,7 @@ decodeItem =
     decode Item
         |> required "label" string
         |> optionalAt [ "image", "styles", "large" ] string "http://placehold.it/350x150"
+        |> optional "private_note" (nullable string) Nothing
 
 
 decodeItemsDict : Decoder ItemsDict

client/src/elm/Item/Model.elm

@@ -15,6 +15,7 @@ type alias ItemId =
 type alias Item =
     { name : String
     , image : String
+    , privateNote : Maybe String
     }
 
 

client/src/elm/Pages/Item/View.elm

@@ -10,23 +10,33 @@ import User.Model exposing (User)
 
 view : Date -> User -> ItemId -> Item -> Html Msg
 view currentDate currentUser itemId item =
-    div []
-        [ div
-            [ class "ui secondary pointing fluid menu" ]
-            [ h2
-                [ class "ui header" ]
-                [ text item.name ]
-            , div
-                [ class "right menu" ]
-                [ a
-                    [ class "ui active item" ]
-                    [ text "Overview" ]
+    let
+        privateNote =
+            case item.privateNote of
+                Just note ->
+                    div [] [ text note ]
+
+                _ ->
+                    text ""
+    in
+        div []
+            [ div
+                [ class "ui secondary pointing fluid menu" ]
+                [ h2
+                    [ class "ui header" ]
+                    [ text item.name ]
+                , div
+                    [ class "right menu" ]
+                    [ a
+                        [ class "ui active item" ]
+                        [ text "Overview" ]
+                    ]
                 ]
+            , div []
+                [ img [ src item.image, alt item.name ] []
+                ]
+            , div
+                [ class "ui divider" ]
+                []
+            , privateNote
             ]
-        , div []
-            [ img [ src item.image, alt item.name ] []
-            ]
-        , div
-            [ class "ui divider" ]
-            []
-        ]

client/src/elm/Pages/Login/Decoder.elm

@@ -3,13 +3,6 @@ module Pages.Login.Decoder exposing (..)
 import Base64 exposing (encode)
 import Json.Decode as Decode
 import Pages.Login.Model exposing (AccessToken)
-import User.Decoder as UserDecoder exposing (decodeUser)
-import User.Model exposing (User)
-
-
-decodeUser : Decode.Decoder User
-decodeUser =
-    Decode.at [ "data", "0" ] <| UserDecoder.decodeUser
 
 
 decodeAccessToken : Decode.Decoder AccessToken

client/src/elm/Pages/Login/Update.elm

@@ -7,6 +7,7 @@ import User.Model exposing (..)
 import Pages.Login.Model as Login exposing (..)
 import Pages.Login.Decoder exposing (..)
 import RemoteData exposing (RemoteData(..), WebData)
+import User.Decoder exposing (decodeUser)
 import Utils.WebData exposing (sendWithHandler)
 
 

client/src/elm/Pusher/Model.elm

@@ -3,6 +3,19 @@ module Pusher.Model exposing (..)
 import Item.Model exposing (Item, ItemId)
 
 
+type alias Model =
+    { connectionStatus : ConnectionStatus
+    , errors : List PusherError
+    }
+
+
+emptyModel : Model
+emptyModel =
+    { connectionStatus = Initialized
+    , errors = []
+    }
+
+
 type Cluster
     = ApSouthEast1
     | EuWest1
@@ -25,8 +38,48 @@ type PusherEventData
     = ItemUpdate Item
 
 
+type AccessToken
+    = AccessToken String
+
+
+type alias PusherChannel =
+    String
+
+
+type alias PusherConfig =
+    { key : String
+    , cluster : String
+    , authEndpoint : String
+    , channel : String
+    , eventNames : List String
+    }
+
+
+type ConnectionStatus
+    = Initialized
+    | Connecting (Maybe Int)
+    | Connected
+    | Unavailable (Maybe Int)
+    | Failed
+    | Disconnected
+    | Other String
+
+
+type alias PusherError =
+    { code : Maybe Int
+    , message : Maybe String
+    }
+
+
 {-| Return the event names that should be added via JS.
 -}
 eventNames : List String
 eventNames =
     [ "item__update" ]
+
+
+type Msg
+    = HandleError PusherError
+    | HandleStateChange String
+    | Login PusherAppKey PusherChannel AccessToken
+    | Logout

client/src/elm/Pusher/Test.elm

@@ -32,6 +32,7 @@ decodeTest =
                         , data =
                             { name = "new-item"
                             , image = "http://placehold.it/350x150"
+                            , privateNote = Nothing
                             }
                                 |> ItemUpdate
                         }