using System;
using System.Drawing;
using DirectShowLib;
using MediaFoundation;

public class MediaCapture
{
    private DsDevice _videoDevice;
    private IMFSourceReader _videoReader;
    private IMFSinkWriter _videoWriter;

    public void InitializeCamera()
    {
        // 獲取默認(rèn)攝像頭
        _videoDevice = DsDevice.GetDevicesByClass(DsClass.VideoInputDevice).FirstOrDefault();
        if (_videoDevice == null) throw new Exception("未檢測到攝像頭");

        // 初始化 MediaFoundation 編碼器
        MFStartup(MF_VERSION);
        _videoReader = new MFSourceReader();
        _videoReader.SetDevice(_videoDevice.MonikerString);
        
        // 配置編碼參數(shù)（H.264 + AAC）
        var videoMediaType = MFMediaType.CreateVideo(MediaTypeGuids.H264);
        videoMediaType.SetUINT32(MF_MT_FRAME_RATE, 30);
        videoMediaType.SetUINT32(MF_MT_FRAME_SIZE_WIDTH, 640);
        videoMediaType.SetUINT32(MF_MT_FRAME_SIZE_HEIGHT, 480);
        _videoWriter = new MFSinkWriter();
        _videoWriter.AddStream(videoMediaType);
    }

    public Bitmap CaptureFrame()
    {
        // 從攝像頭讀取一幀
        _videoReader.GetCurrentBuffer(out _videoReader.BufferCount, out _videoReader.Buffer);
        return (Bitmap)_videoReader.Buffer.ToImage();
    }
}

using System.Net;
using System.Net.Sockets;
using System.Text;

public class SignalServer
{
    private UdpClient _udpServer;
    private IPEndPoint _endPoint;

    public SignalServer(int port)
    {
        _udpServer = new UdpClient(port);
        _endPoint = new IPEndPoint(IPAddress.Any, 0);
    }

    public async Task ListenForRequests()
    {
        while (true)
        {
            var result = await _udpServer.ReceiveAsync();
            string message = Encoding.UTF8.GetString(result.Buffer);
            
            // 解析信令消息（如視頻請求、ICE 候選）
            HandleSignalingMessage(result.Buffer, result.RemoteEndPoint);
        }
    }

    private void HandleSignalingMessage(byte[] data, IPEndPoint remoteEP)
    {
        // 示例：處理視頻請求
        var request = JsonSerializer.Deserialize<VideoRequest>(Encoding.UTF8.GetString(data));
        if (request.Type == "video_invite")
        {
            // 回復(fù) SDP 描述和 ICE 候選
            var response = new VideoResponse { Type = "video_offer", Sdp = GenerateSdp() };
            _udpServer.Send(Encoding.UTF8.GetBytes(JsonSerializer.Serialize(response)), response.Length, remoteEP);
        }
    }
}

public class IceNegotiator
{
    private List<IceCandidate> _localCandidates = new();
    private UdpClient _iceSocket;

    public void StartIceCandidateDiscovery()
    {
        // 生成本地 ICE 候選（STUN/TURN 服務(wù)器可選）
        _localCandidates.Add(new IceCandidate { Candidate = "candidate:1", SdpMid = "0" });
        
        // 發(fā)送候選到對端
        SendCandidateToPeer(_localCandidates[0]);
    }

    private void SendCandidateToPeer(IceCandidate candidate)
    {
        var msg = new { Type = "ice_candidate", Candidate = candidate };
        byte[] data = Encoding.UTF8.GetBytes(JsonSerializer.Serialize(msg));
        _iceSocket.Send(data, data.Length, _peerEndPoint);
    }
}

public class RtpStreamer
{
    private UdpClient _rtpSocket;
    private int _sequenceNumber = 0;
    private DateTime _startTime;

    public void SendPacket(byte[] payload, int payloadType)
    {
        // RTP 頭部封裝
        byte[] header = new byte[12]
        {
            (byte)(0x80 | payloadType), // 版本2 + 無填充 + 無擴(kuò)展 + CSRC計數(shù)0
            (byte)_sequenceNumber,
            (byte)(_sequenceNumber >> 8),
            (byte)(_timestamp >> 24),
            (byte)(_timestamp >> 16),
            (byte)(_timestamp >> 8),
            (byte)_timestamp,
            (byte)(_ssrc >> 24),
            (byte)(_ssrc >> 16),
            (byte)(_ssrc >> 8),
            (byte)_ssrc
        };

        _rtpSocket.Send(header.Concat(payload).ToArray(), _rtpSocket.Client.LocalEndPoint);
    }
}

{
  "StunServer": "stun:stun.l.google.com:19302",
  "TurnServer": "turn:your-turn-server:3478",
  "VideoCodec": "H264",
  "AudioCodec": "AAC"
}