HoloLensのUnity 3DアプリでFirebase Streaming Rest APIを動かすメモ

using UnityEngine;
using System.Collections;
using System.Text;
using UnityEngine.Networking;
using MiniJSON;
using System.Collections.Generic;

#if UNITY_UWP
using System.Threading;
using System.Net.Http;
using System.IO;
using System;
using System.Net.Http.Headers;
using System.Threading.Tasks;
#endif

public class SphereCommands : MonoBehaviour
{

#if UNITY_UWP
    CancellationTokenSource cancellationTokenSource;
    HttpResponseMessage httpResponse;
    StreamReader contentStreamReader;
    Stream contentStream;
    Task taskFirebase;
#endif
    // Use this for initialization
    void Start()
    {
#if UNITY_UWP
        // 起動した際にFirebaseのFirebase Streaming Rest APIにつなぎに行きます。
        GetAndProcessFirebaseHttpResponse();
#endif
    }

    // Called by GazeGestureManager when the user performs a Select gesture
    void OnSelect()
    {
        Debug.Log("OnSelect");
    }

    // Called by SpeechManager when the user says the "Reset world" command
    void OnReset()
    {

    }

    // Called by SpeechManager when the user says the "Drop sphere" command
    void OnDrop()
    {
        // Just do the same logic as a Select gesture.
        OnSelect();
    }


#if UNITY_UWP

    public void GetAndProcessFirebaseHttpResponse()
    {
        // while 無限ループで待つと開放されずUnity描画が止まるのでTask化
        taskFirebase = new Task(async () =>
        {

            cancellationTokenSource = new CancellationTokenSource();

            // まず text/event-stream なHTTPリクエストを成立させる
            httpResponse = ListenAsync().Result;

            using (httpResponse)
            {
                using (contentStream = httpResponse.Content.ReadAsStreamAsync().Result)
                {
                    // StreamReaderでストリームデータを待つ
                    using (contentStreamReader = new StreamReader(contentStream))
                    {
                        // whileループで待つ
                        while (true)
                        {

                            if (cancellationTokenSource.IsCancellationRequested)
                            {
                                httpResponse.RequestMessage.Dispose();
                            }

                            cancellationTokenSource.Token.ThrowIfCancellationRequested();

                            // StreamReaderからストリームデータ取得
                            string read = await contentStreamReader.ReadLineAsync();

                            // データ判定
                            if (string.IsNullOrWhiteSpace(read))
                            {
                                // 通常は空のデータがくるので無視
                                // Debug.Log("IsNullOrWhiteSpace");
                            }
                            else
                            {
                                Debug.LogFormat("read : {0}", read);
                                
                                // ストリームデータから
                                string type = read.Split(new[] { ':' }, 2, StringSplitOptions.RemoveEmptyEntries)[0];

                                if (type == "data")
                                {
                                    Debug.Log("type : data");

                                    if (read == "data: null")
                                    {
                                        // 長く変化がないと cancel が来るので除外
                                    } else {
                                        // データがある場合

                                        // data: 以下をデータとして取り出す
                                        string dataStr = read.Split(new[] { ':' }, 2, StringSplitOptions.RemoveEmptyEntries)[1];

                                        // JSONデータ化
                                        Dictionary<string, object> json = Json.Deserialize(dataStr) as Dictionary<string, object>;
                                        Debug.LogFormat("dataStr : {0}", dataStr);

                                        UnityEngine.WSA.Application.InvokeOnAppThread(() => {

                                            RecieveMessage(json);

                                        }, true);
                                    }

                                    
                                }
                                // イベントが発生した
                                if (type == "event")
                                {
                                    Debug.Log("eventType : event");
                                }
                            }

                            // await Task.Delay(100);
                        }


                    }
                }
            }

        });

        taskFirebase.Start();
    }
    
    private async Task<HttpResponseMessage> ListenAsync()
    {
        // Create HTTP Client which will allow auto redirect as required by Firebase
        HttpClientHandler httpClientHandler = new HttpClientHandler();
        httpClientHandler.AllowAutoRedirect = true;

        // 自分のFirebaseのURL入れる
        // この場合は childpath /sample を取得
        var _firebasePath = "https://          .firebaseio.com/sample.json";

        HttpClient httpClient = new HttpClient(httpClientHandler, true);
        httpClient.BaseAddress = new Uri(_firebasePath);
        httpClient.Timeout = TimeSpan.FromSeconds(60);

        string requestUrl = _firebasePath;
        Uri requestUri = new Uri(requestUrl);

        HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, requestUri);
        request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("text/event-stream"));

        // HttpResponseMessage response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead);
        HttpResponseMessage response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead).ConfigureAwait(false);
        response.EnsureSuccessStatusCode();

        return response;
    }


    private void RecieveMessage(Dictionary<string, object> json)
    {
        Debug.Log("RecieveMessage");

        // Firebaseから来た内容
        // 例： {"path":"/","data":"ddddd"}
        Debug.LogFormat("json : {0}", json["data"]);  // ddddd
    }

   
#endif
}

        // 自分のFirebaseのURL入れる
        // この場合は childpath /sample を取得
        var _firebasePath = "https://          .firebaseio.com/sample.json";