kintoneHack2020、エゴで「俺の嫁kintone」を開発した話　中編

version: "3"
services:
  https-portal:
    image: steveltn/https-portal:1
    ports:
      - "80:80"
      - "443:443"
    environment:
      STAGE: "production"
      DOMAINS: "ドメイン名 -> http://sockethook:xxxx"
      WEBSOCKET: "true"
  sockethook:
    image: bettse/sockethook
  curl:
    image: curlimages/curl
    entrypoint: ["/bin/sh", "-c", "while true; do curl -s -f -d '{\"type\": \"PING\"}'  -H 'Content-Type: application/json'  http://sockethook:xxxx; sleep 10; done"]

public class KintoneHack : MonoBehaviour
{
    // These need to be assigned in the editor
    [SerializeField] private Animator animator;
    [SerializeField] private AudioSource audioSource;

    private WebSocket webSocket;
    private SynchronizationContext context;
    private Dictionary<string, string> clipNames = new Dictionary<string, string> {
        {"RecordAdded", "Voice/record_add"}, 
        {"RecordSubmitted", "Voice/process_submit"},
        {"RecordApproved", "Voice/process_proceed"},
        {"RecordRejected", "Voice/process_reject"},
        {"CommentAdded", "Voice/comment"},
    };

    void TriggerTransition(object arg)
    {
        var trigger = arg as string;

        if (!clipNames.ContainsKey(trigger)) {
            Debug.LogWarning("Unknown trigger: " + trigger);
            return;
        }

        var clip = Resources.Load<AudioClip>(clipNames[trigger]);

        audioSource.PlayOneShot(clip);
        animator.SetTrigger(trigger);

        Invoke("TriggerProceed", clip.length);
    }

    void PlaySound(AudioClip clip)
    {
        audioSource.PlayOneShot(clip);
        Invoke("TriggerProceed", clip.length);
    }

    void TriggerProceed()
    {
        animator.SetTrigger("Proceed");
    }

    void HandleMessage(byte[] msg)
    {
        var json = JsonSerializer.Deserialize<dynamic>(msg);
        var eventType = json["data"]["type"];

        switch (eventType) {
            case "ADD_RECORD":
                Debug.Log("Triggering event RecordAdded");
                context.Post(TriggerTransition, "RecordAdded");
                break;
            case "UPDATE_STATUS":
                var recordStatus = json["data"]["record"]["ステータス"]["value"];

                switch (recordStatus) {
                    case "申請中":
                        Debug.Log("Triggering event RecordSubmitted");
                        context.Post(TriggerTransition, "RecordSubmitted");
                        break;
                    case "確認":
                        Debug.Log("Triggering event RecordApproved");
                        context.Post(TriggerTransition, "RecordApproved");
                        break;
                    case "差し戻し":
                        Debug.Log("Triggering event RecordRejected");
                        context.Post(TriggerTransition, "RecordRejected");
                        break;
                    default:
                        Debug.LogWarning("Unknown record status: " + recordStatus);
                        break;
                }
                break;
            case "ADD_RECORD_COMMENT":
                Debug.Log("Triggering event CommentAdded");
                context.Post(TriggerTransition, "CommentAdded");
                break;
            case "PING":
                // Debug.Log("Received ping");
                break;
            default:
                Debug.LogWarning("Unknown event type: " + eventType);
                break;
        }
    }

async Task ReceiveLoop()
    {
        var ws = new ClientWebSocket();
        ws.Options.KeepAliveInterval = TimeSpan.FromSeconds(1.0);
        
        var uri = new Uri("wss://xxx");

        try {
            await ws.ConnectAsync(uri, CancellationToken.None);
        } catch (WebSocketException e) {
            Debug.LogWarning("Failed to open connection: " + e.Message);
            PlayDisconnected();
            return;
        }

        Debug.Log("Connected to the sockethook server");
        PlayConnected();

        while (true) {          
            var buf = new ArraySegment<byte>(new byte[1024]);
            var ms = new MemoryStream();
            WebSocketReceiveResult result = null;

            do {
                var token = new CancellationTokenSource(15000).Token;

                try {
                    result = await ws.ReceiveAsync(buf, token);
                } catch (OperationCanceledException) {
                    Debug.LogWarning("Connection to the sockethook server timed out");
                    PlayDisconnected();
                    return;
                }

                if (result.MessageType == WebSocketMessageType.Close) {
                    Debug.LogWarning("Disconnected from the sockethook server");
                    PlayDisconnected();
                    return;
                }

                ms.Write(buf.Array, buf.Offset, result.Count);

                // Debug.Log("Received " + result.Count + " bytes from the sockethook server");

            } while(!result.EndOfMessage);

            HandleMessage(ms.ToArray());
        }
    }

    async void WebSocketWorker()
    {
        while (true) {
            await ReceiveLoop();
            Debug.LogWarning("Waiting 5 seconds to reconnect...");
            await Task.Delay(5000);
        }
    }