SpookTubeEX/Uploader.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using HarmonyLib;
using Steamworks;
using WebSocketSharp;

namespace SpookedTube;


class SpookedUploader
{
    WebSocket ws;
    public void Upload(IPlayableVideo cameraRecording, int views, CommentUI[] comments, Action onUpload)
    {
        if (cameraRecording.TryGetVideoPath(out string path))
        {
            if (!File.Exists(path))
            {
                Modal.ShowError("Path Nonexistent", $"Can't find {path}");
                return;
            }

            ws = new WebSocket(Plugin.URL.Value);

            string viewableUrl = "";
            string uuid = "";

            ws.OnMessage += (sender, evt) =>
            {
                ws.Send(evt.Data);

                if (evt.Data.StartsWith("url:")) viewableUrl = evt.Data.Substring(4);
                if (evt.Data.StartsWith("uuid:"))
                {
                    uuid = evt.Data.Substring(5);

                    // Begin Upload
                    byte[] byteArray = File.ReadAllBytes(path);

                    int offset = 0;
                    const int chunkSize = 512000;

                    while (byteArray.Length > offset * chunkSize)
                    {
                        byte[] buffer = byteArray.Skip(offset * chunkSize).Take(chunkSize).ToArray();
                        offset += 1;

                        ws.Send($"Bytes: {buffer.Length}");

                        List<byte> msgList = new List<byte>();

                        msgList.AddRange(new byte[1] { 36 });
                        msgList.AddRange(buffer);

                        ws.Send(msgList.ToArray());
                    }
                }

                if (evt.Data.StartsWith("fin"))
                {
                    ws.Close();
                    System.Diagnostics.Process.Start($"https://{viewableUrl}/#{uuid}");
                    // Modal.ShowError("Upload Complete", $"Video uploaded to {viewableUrl}! ({uuid})");
                    onUpload();
                }
            };

            ws.OnError += (sender, evt) =>
            {
                UnityEngine.Debug.LogError(evt.Message);
            };

            ws.OnOpen += (sender, evt) =>
            {
                UnityEngine.Debug.Log(SteamUser.GetSteamID().m_SteamID.ToString());
                ws.Send(SteamUser.GetSteamID().m_SteamID.ToString());
            };

            ws.Connect();
        }
    }
}