using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using UnityEngine;
using UnityEngine.UI;
using System.Runtime.InteropServices;

public class OpenCVUinty : MonoBehaviour
{
	[DllImport("UnityAndroidDemo")]
    private static extern IntPtr CreateUnityAndroidDemo();

    [DllImport("UnityAndroidDemo")]
    private static extern void DestroyUnityAndroidDemo(IntPtr obj);

    [DllImport("UnityAndroidDemo")]
    private static extern double Add(IntPtr obj, double x, double y);

    [DllImport("UnityAndroidDemo")]
    private static extern void Threshold(IntPtr obj, ref Color32[] img, int width, int height);

    private IntPtr UnityAndroidDemo = IntPtr.Zero;

	public int width = 640;
    public int height = 480;
    public int fps = 30;

    private WebCamTexture cam = null;
    public string cam_name = "Integrated Camera";
    private Color32[] cam_data = null;
	private Texture2D tex = null;

	private Text show_text = null;
    private RawImage background = null;

    // Start is called before the first frame update
    IEnumerator Start()
    {
	    yield return Application.RequestUserAuthorization(UserAuthorization.WebCam);

    	show_text = GameObject.FindGameObjectWithTag("ShowText").GetComponent<UnityEngine.UI.Text>();
    	background = GameObject.FindWithTag("CamBackground").GetComponent<RawImage>();

    	UnityAndroidDemo = CreateUnityAndroidDemo();

    	if (Application.HasUserAuthorization(UserAuthorization.WebCam))
    	{
	    	WebCamDevice[] devices = WebCamTexture.devices;

	        if (devices.Length == 0)
	        {
	            // Debug.Log("No camera detected!");
	            show_text.text += "No camera detected!\n";
	            yield break;
	        }

	        bool find_camera = false;

	        for (int i = 0; i < devices.Length; i++)
	        {
	            // Debug.Log("Found camera:" + devices[i].name);
	            show_text.text += ("Found camera:" + devices[i].name + "\n");
	            if (cam_name.Equals(devices[i].name)) {
	            	find_camera = true;
	            }
	        }

	        if (!find_camera)
	        {
				show_text.text += ("Unable to find camera: " + cam_name + "\n");
	        	show_text.text += ("Open the first camera" + devices[0].name + "\n");

	        	cam_name = devices[0].name;
	        }

	        cam = new WebCamTexture(cam_name, width, height, fps);

	        WebCamTexture.allowThreadedTextureCreation = true;
	        WebCamTexture.streamingTextureDiscardUnusedMips = true;

	        cam.Play();

	        show_text.text += (cam_name +" Running...\n");
    	}
    }

    void OnDestroy()
    {
    	if (UnityAndroidDemo != IntPtr.Zero)
    	{
    		DestroyUnityAndroidDemo(UnityAndroidDemo);
    		UnityAndroidDemo = IntPtr.Zero;
    	}
    }


    // Update is called once per frame
    void Update()
    {
    	if (cam_data == null)
    	{
    		cam_data = new Color32[cam.width * cam.height];
    	}

    	if (tex == null)
    	{
    		tex = new Texture2D(cam.width, cam.height);
    	}
    		        

    	if (cam != null && cam.isPlaying)
    	{
    		cam_data = cam.GetPixels32();

			Threshold(UnityAndroidDemo, ref cam_data, cam.width, cam.height);

    		tex.SetPixels32(cam_data);
			tex.Apply();

	        background.texture = tex;

    		show_text.text += "ProcessImage\n";
    	}

    }
}

using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using UnityEngine;
using UnityEngine.UI;
using System.Runtime.InteropServices;

public class Camera : MonoBehaviour
{
    [DllImport("Camera")]
    private static extern IntPtr CreateCamera(int width, int height, int fps);

    [DllImport("Camera")]
    private static extern void DestroyCamera(IntPtr obj);

    [DllImport("Camera")]
    private static extern bool GetImage(IntPtr obj, ref IntPtr data, ref int size);
    
    private int width_ = 640;
    private int height_ = 480;
    private int fps_ = 30;
    
    private IntPtr Camera_ = IntPtr.Zero;
    private IntPtr data_ = IntPtr.Zero;
    private int size_ = 0;
    private byte[] buffer_ = null;

    private RawImage background_ = null;
    private Texture2D tex_ = null;

    // Start is called before the first frame update
    void Start()
    {
    	background_ = GameObject.FindWithTag("BackgroundImage").GetComponent<RawImage>(); 

    	Camera_ = CreateCamera(width_, height_, fps_);
    }

    void OnDestroy()
    {
    	if (Camera_ != IntPtr.Zero)
    	{
    		DestroyCamera(Camera_);
    		Camera_ = IntPtr.Zero;
    	}
    }

    // Update is called once per frame
    void Update()
    {
    	if (Camera_ == IntPtr.Zero) return;

    	bool flag = GetImage(Camera_, ref data_, ref size_);

    	if (!flag || size_ <= 0) return;

    	if (buffer_ == null) {
    		buffer_ = new byte[size_];
    	}

    	if (tex_ == null) {
    		tex_ = new Texture2D(width_, height_, TextureFormat.RGB24, false, false);
    	}

		System.Runtime.InteropServices.Marshal.Copy(data_, buffer_, 0, size_);
		tex_.LoadRawTextureData(buffer_);
		tex_.Apply();

		background_.texture = tex_;

		// byte[] bytes = tex_.EncodeToPNG();
		// File.WriteAllBytes("Image.png", bytes);
    }
}

using System.Collections.Generic;
using UnityEngine;
using SocketIO;

public class TestSocketScript : MonoBehaviour
{
    // 在 Editor 里把 SocketIO 拖过来
    public SocketIOComponent sio;
    void Start()
    {
        if (sio == null)
            Debug.LogError("Drop a SocketIOComponent to Me!");
        // 声明 connect 事件和 server_sent 事件的回调函数
        sio.On("connect", OnConnect);
        sio.On("server_sent", OnReceive);
    }
    
    /// <summary>
    /// connect 事件的回调函数
    /// </summary>
    /// <param name="obj"></param>
    void OnConnect(SocketIOEvent obj)
    {
        Debug.Log("Connection Open");
        OnReceive(obj);
    }
    
    /// <summary>
    /// 接收到 server_sent 事件的回调函数
    /// </summary>
    /// <param name="obj">SocketIOEvent</param>
    void OnReceive(SocketIOEvent obj)
    {
        // 1. 接收并输出 Server 传递过来的数字
        JSONObject jsonObject = obj.data;
        string rcv_nbr = jsonObject.GetField("nbr").str;
        Debug.Log("Recieved From Server : " + rcv_nbr);
        // 2. 将数字 +1 并返回给 Server
        try
        {
            int int_nbr = int.Parse(rcv_nbr);
            SendToServer(int_nbr + 1);
        }
        catch
        {
        }
    }
    
    /// <summary>
    /// 将数字发给 Server
    /// </summary>
    /// <param name="_nbr">发送的数字</param>
    void SendToServer(int _nbr)
    {
        Dictionary<string, string> data = new Dictionary<string, string>();
        data["nbr"] = _nbr.ToString();
        sio.Emit("client_sent", new JSONObject(data));
    }
}