Initial Sonos support

Author: forki

RELEASE_NOTES.md

@@ -1,5 +1,8 @@
 # Release Notes
 
+## 1.5.0 - 2019-08-20
+* Sonos support
+
 ## 1.4.22 - 2019-08-20
 * Update deps
 * Use --self-contained for Firmware

src/Client/Client.fs

@@ -238,7 +238,7 @@ let tagsTable (model : Model) (dispatch : Msg -> unit) =
                         tr [ Id tag.Token ] [
                             yield td [ Title tag.Token ] [ str tag.Object ]
                             match tag.Action with
-                            | TagAction.PlayMusik urls -> 
+                            | TagAction.PlayMusik urls ->
                                 for url in urls do
                                     yield td [ ] [ a [Href url ] [str tag.Description ] ]
                             | TagAction.PlayYoutube url -> yield td [ ] [ a [Href url ] [str tag.Description ] ]

src/PiServer/PiServer.fs

@@ -223,6 +223,8 @@ let update (msg:Msg) (model:Model) =
 
     | ExecuteAction action ->
         match action with
+        | TagActionForBox.Ignore ->
+            model, Cmd.none
         | TagActionForBox.UnknownTag ->
             log.Warn "Unknown Tag"
             model, Cmd.none

src/Server/AzureTable.fs

@@ -124,6 +124,7 @@ let storageConnectionString =
 let connection = CloudStorageAccount.Parse storageConnectionString
 
 let tagsTable = getTable "tags" connection
+let usersTable = getTable "users" connection
 let positionsTable = getTable "positions" connection
 let linksTable = getTable "links" connection
 let requestsTable = getTable "requests" connection
@@ -150,6 +151,13 @@ let mapTag (entity: DynamicTableEntity) : Tag =
         | Error msg -> failwith msg
         | Ok action -> action }
 
+let mapUser (entity: DynamicTableEntity) : User =
+    { UserID = entity.RowKey
+      SonosID = getStringProperty "SonosID" entity
+      SpeakerType =
+        match Decode.fromString SpeakerType.Decoder (getStringProperty "SpeakerType" entity) with
+        | Error msg -> failwith msg
+        | Ok action -> action }
 
 let mapRequest (entity: DynamicTableEntity) : Request =
     { UserID = entity.PartitionKey
@@ -232,6 +240,16 @@ let getTag (userID:string) token = task {
         if isNull result then return None else return Some(mapTag result)
 }
 
+let getUser (userID:string) = task {
+    let query = TableOperation.Retrieve("users", userID)
+    let! r = usersTable.ExecuteAsync(query)
+    if r.HttpStatusCode <> 200 then
+        return None
+    else
+        let result = r.Result :?> DynamicTableEntity
+        if isNull result then return None else return Some(mapUser result)
+}
+
 let getPlayListPosition (userID:string) token = task {
     let query = TableOperation.Retrieve(userID, token)
     let! r = positionsTable.ExecuteAsync(query)

src/Server/Server.fs

@@ -53,7 +53,7 @@ let uploadMusik (stream:Stream) = task {
 let mapBlobMusikTag (tag:Tag) = task {
     match tag.Action with
     | TagAction.PlayBlobMusik mediaIDs ->
-        let list = System.Collections.Generic.List<_>() 
+        let list = System.Collections.Generic.List<_>()
         for mediaID in mediaIDs do
             let! sas = getSASMediaLink(mediaID.ToString())
             list.Add sas
@@ -109,7 +109,7 @@ let uploadEndpoint (userID:string) =
                 let file = form.Files.[0]
                 use stream = file.OpenReadStream()
                 let! tagAction = uploadMusik stream
-                let tag : Tag = { 
+                let tag : Tag = {
                     Token = System.Guid.NewGuid().ToString()
                     Action = tagAction
                     Description = ""
@@ -130,14 +130,14 @@ let previousFileEndpoint (userID,token) =
         plug (fun next ctx -> task {
             let! _ = AzureTable.saveRequest userID token
             let! tag = AzureTable.getTag userID token
-            let! position = AzureTable.getPlayListPosition userID token 
+            let! position = AzureTable.getPlayListPosition userID token
             let position = position |> Option.map (fun p -> p.Position + 1) |> Option.defaultValue 0
             let! _ = AzureTable.savePlayListPosition userID token position
             let! tag =
                 match tag with
                 | Some t -> mapBlobMusikTag t
-                | _ -> 
-                    let t = { 
+                | _ ->
+                    let t = {
                         Token = token
                         UserID = userID
                         Action = TagAction.UnknownTag
@@ -147,7 +147,7 @@ let previousFileEndpoint (userID,token) =
                     task { return t }
 
             let! tag = mapYoutube tag
-            let tag : TagForBox = { 
+            let tag : TagForBox = {
                 Token = tag.Token
                 Object = tag.Object
                 Description = tag.Description
@@ -158,40 +158,145 @@ let previousFileEndpoint (userID,token) =
         })
     }
 
+let accessToken = "0df1e468-cd6f-4038-9734-9bcf4777925b"
+let group = "RINCON_347E5CF009E001400:3169659583"
+
+open System.Net
+open Microsoft.Extensions.Logging
+
+let post (log:ILogger) (url:string) headers (data:string) = task {
+    let req = HttpWebRequest.Create(url) :?> HttpWebRequest
+    req.ProtocolVersion <- HttpVersion.Version10
+    req.Method <- "POST"
+
+    for (name:string),(value:string) in headers do
+        req.Headers.Add(name,value) |> ignore
+
+    let postBytes = System.Text.Encoding.UTF8.GetBytes(data)
+    req.ContentType <- "application/json; charset=utf-8"
+    req.ContentLength <- int64 postBytes.Length
+
+    try
+        // Write data to the request
+        use reqStream = req.GetRequestStream()
+        do! reqStream.WriteAsync(postBytes, 0, postBytes.Length)
+        reqStream.Close()
+
+        use resp = req.GetResponse()
+        use stream = resp.GetResponseStream()
+        use reader = new StreamReader(stream)
+        let! html = reader.ReadToEndAsync()
+        return html
+    with
+    | :? WebException as exn when not (isNull exn.Response) ->
+        use errorResponse = exn.Response :?> HttpWebResponse
+        use reader = new StreamReader(errorResponse.GetResponseStream())
+        let error = reader.ReadToEnd()
+        log.LogError(sprintf "Request to %s failed with: %s %s" url exn.Message error)
+        return! raise exn
+}
+
+type Session =
+    { ID : string }
+
+    static member Decoder =
+        Decode.object (fun get ->
+            { ID = get.Required.Field "sessionId" Decode.string }
+        )
+
+let createOrJoinSession (log:ILogger) accessToken group = task {
+    let headers = ["Bearer " , accessToken]
+    let url = sprintf "https://api.ws.sonos.com/control/api/v1/groups/%s/playbackSession/joinOrCreate" group
+    let body = """{
+    "appId": "com.Forkmann.AudioHub",
+    "appContext": "1a2b3c24b",
+    "customData": "playlistid:12345"
+}"""
+
+    let! result = post log url headers body
+
+    match Decode.fromString Session.Decoder result with
+    | Error msg -> return failwith msg
+    | Ok session -> return session
+}
+
+
+let playStream (log:ILogger) accessToken (session:Session) (tag:Tag) = task {
+    let headers = ["Bearer " , accessToken]
+    let url = sprintf "https://api.ws.sonos.com/control/api/v1/playbackSessions/%s/playbackSession/loadStreamUrl" session.ID
+
+    match tag.Action with
+    | TagAction.PlayMusik stream ->
+        let body = sprintf """{
+      "streamUrl": "%s",
+      "playOnCompletion": true,
+      "stationMetadata": {
+        "name": "%s"
+      },
+      "itemId" : "%s"
+    }"""                stream.[0] (tag.Object + " - " + tag.Description) tag.Token
+
+
+        let! _result = post log url headers body
+        ()
+    | _ -> ()
+}
+
 let nextFileEndpoint (userID,token) =
     pipeline {
         set_header "Content-Type" "application/json"
         plug (fun next ctx -> task {
             let! _ = AzureTable.saveRequest userID token
-            let! tag = AzureTable.getTag userID token
-            
-            let! position = AzureTable.getPlayListPosition userID token 
-            let position = position |> Option.map (fun p -> p.Position - 1) |> Option.defaultValue 0
-            
-            let! tag =
-                match tag with
-                | Some t -> mapBlobMusikTag t
-                | _ -> 
-                    let t = { 
-                        Token = token
-                        UserID = userID
-                        Action = TagAction.UnknownTag
-                        LastVerified = DateTimeOffset.MinValue
-                        Description = ""
-                        Object = "" }
-                    task { return t }
-
-            let! tag = mapYoutube tag
-            let tag : TagForBox = { 
-                Token = tag.Token
-                Object = tag.Object
-                Description = tag.Description
-                Action = TagActionForBox.GetFromTagAction(tag.Action,position) } 
-            
-            let! _ = AzureTable.savePlayListPosition userID token position
-            
-            let txt = TagForBox.Encoder tag |> Encode.toString 0
-            return! setBodyFromString txt next ctx
+            match! AzureTable.getUser userID with
+            | None ->
+                return! Response.notFound ctx userID
+            | Some user ->
+                let! tag = AzureTable.getTag userID token
+
+                let! position = AzureTable.getPlayListPosition userID token
+                let position = position |> Option.map (fun p -> p.Position - 1) |> Option.defaultValue 0
+
+                let! tag =
+                    match tag with
+                    | Some t -> mapBlobMusikTag t
+                    | _ ->
+                        let t = {
+                            Token = token
+                            UserID = userID
+                            Action = TagAction.UnknownTag
+                            LastVerified = DateTimeOffset.MinValue
+                            Description = ""
+                            Object = "" }
+                        task { return t }
+
+                let! tag = mapYoutube tag
+                let! _ = AzureTable.savePlayListPosition userID token position
+
+                match user.SpeakerType with
+                | SpeakerType.Local ->
+                    let! tag = mapYoutube tag
+                    let tag : TagForBox = {
+                        Token = tag.Token
+                        Object = tag.Object
+                        Description = tag.Description
+                        Action = TagActionForBox.GetFromTagAction(tag.Action,position) }
+
+
+                    let txt = TagForBox.Encoder tag |> Encode.toString 0
+                    return! setBodyFromString txt next ctx
+                | SpeakerType.Sonos ->
+                    let logger = ctx.GetLogger "NextFile"
+                    let! session = createOrJoinSession logger accessToken group
+                    do! playStream logger accessToken session tag
+
+                    let tag : TagForBox = {
+                        Token = tag.Token
+                        Object = tag.Object
+                        Description = tag.Description
+                        Action = TagActionForBox.Ignore }
+
+                    let txt = TagForBox.Encoder tag |> Encode.toString 0
+                    return! setBodyFromString txt next ctx
         })
     }
 

src/Shared/Shared.fs

@@ -72,21 +72,22 @@ type TagAction =
 [<RequireQualifiedAccess>]
 type TagActionForBox =
 | UnknownTag
+| Ignore
 | StopMusik
 | PlayMusik of string
 
     static member GetFromTagAction(action:TagAction,position) =
         match action with
         | TagAction.StopMusik -> TagActionForBox.StopMusik
         | TagAction.UnknownTag -> TagActionForBox.UnknownTag
-        | TagAction.PlayMusik urls -> 
+        | TagAction.PlayMusik urls ->
             if Array.isEmpty urls then
                 TagActionForBox.StopMusik
             else
                 let pos = Math.Abs(position % urls.Length)
                 TagActionForBox.PlayMusik urls.[pos]
         | _ -> failwithf "Can't convert %A" action
-        
+
     static member Encoder (action : TagActionForBox) =
         match action with
         | TagActionForBox.UnknownTag ->
@@ -97,6 +98,10 @@ type TagActionForBox =
             Encode.object [
                 "StopMusik", Encode.nil
             ]
+        | TagActionForBox.Ignore ->
+            Encode.object [
+                "Ignore", Encode.nil
+            ]
         | TagActionForBox.PlayMusik url ->
             Encode.object [
                 "PlayMusik", Encode.string url
@@ -106,6 +111,7 @@ type TagActionForBox =
         Decode.oneOf [
             Decode.field "UnknownTag" (Decode.succeed TagActionForBox.UnknownTag)
             Decode.field "StopMusik" (Decode.succeed TagActionForBox.StopMusik)
+            Decode.field "Ignore" (Decode.succeed TagActionForBox.Ignore)
             Decode.field "PlayMusik" Decode.string |> Decode.map TagActionForBox.PlayMusik
         ]
 
@@ -138,12 +144,52 @@ type Tag =
               Object = get.Required.Field "Object" Decode.string
               Description = get.Required.Field "Description" Decode.string
               UserID = get.Required.Field "UserID" Decode.string
-              LastVerified = 
-                    get.Optional.Field "LastVerified" Decode.datetimeOffset 
+              LastVerified =
+                    get.Optional.Field "LastVerified" Decode.datetimeOffset
                     |> Option.defaultValue DateTimeOffset.MinValue
               Action = get.Required.Field "Action" TagAction.Decoder }
         )
 
+[<RequireQualifiedAccess>]
+type SpeakerType =
+| Local
+| Sonos
+
+    static member Encoder (action : SpeakerType) =
+        match action with
+        | Local ->
+            Encode.object [
+                "Local", Encode.nil
+            ]
+        | Sonos ->
+            Encode.object [
+                "Sonos", Encode.nil
+            ]
+
+    static member Decoder =
+        Decode.oneOf [
+            Decode.field "Local" (Decode.succeed SpeakerType.Local)
+            Decode.field "Sonos" (Decode.succeed SpeakerType.Sonos)
+        ]
+
+type User =
+    { UserID : string
+      SpeakerType : SpeakerType
+      SonosID : string }
+
+    static member Encoder (user : User) =
+        Encode.object [
+            "UserID", Encode.string user.UserID
+            "SpeakerType", SpeakerType.Encoder user.SpeakerType
+            "SonosID", Encode.string user.SonosID
+        ]
+    static member Decoder =
+        Decode.object (fun get ->
+            { UserID = get.Required.Field "UserID" Decode.string
+              SpeakerType = get.Required.Field "SpeakerType" SpeakerType.Decoder
+              SonosID = get.Required.Field "SonosID" Decode.string }
+        )
+
 type Request =
     { Token : string
       Timestamp : DateTimeOffset