问无法在两个Python脚本之间完全建立ICE连接

EN

import asyncio
import json
import requests
import time

from aiortc import (
    MediaStreamTrack,
    RTCConfiguration,
    RTCIceServer,
    RTCPeerConnection,
    RTCSessionDescription,
)
from aiortc.contrib.media import MediaPlayer, MediaRelay
from loguru import logger

relay = MediaRelay()


class VideoTransformTrack(MediaStreamTrack):
    """
    A video stream track that transforms frames from an another track.
    """

    kind = "video"

    def __init__(self, track):
        if track.kind != "video":
            raise Exception("Unsupported kind: %s" % (track.kind))

        super().__init__()  # don't forget this!
        logger.info("track kind: %s" % track.kind)
        self.track = track

    async def recv(self):

        logger.info("Attempt to receive frame ...")

        frame = await self.track.recv()

        logger.info("Received frame: %s" % (frame))


async def run():
    # config = RTCConfiguration(
    #     iceServers=[
    #         RTCIceServer(
    #             urls=[
    #                 "stun:stun.l.google.com:19302",
    #                 "stun:stun1.l.google.com:19302",
    #                 "stun:stun2.l.google.com:19302",
    #                 "stun:stun3.l.google.com:19302",
    #                 "stun:stun4.l.google.com:19302",
    #             ]
    #         ),
    #     ]
    # )

    pc = RTCPeerConnection()

    pc.addTransceiver("video", direction="recvonly")

    @pc.on("track")
    def on_track(track):
        """
        Track has been received from client.
        """

        logger.info("Track %s received" % track)

        pc.addTrack(
            VideoTransformTrack(
                relay.subscribe(track),
            )
        )

        @track.on("ended")
        async def on_ended():
            logger.info("Track ended: %s" % track)

    offer = await pc.createOffer()
    await pc.setLocalDescription(offer)

    while True:
        logger.info("icegatheringstate: %s" % pc.iceGatheringState)
        if pc.iceGatheringState == "complete":
            break

    offer2 = pc.localDescription

    data = {
        "sdp": offer2.sdp,
        "type": offer2.type,
    }

    response = requests.post(
        "http://localhost:8080/offer",
        headers={"Content-Type": "application/json"},
        json=data,
    )

    response_data = response.json()

    await pc.setRemoteDescription(
        RTCSessionDescription(sdp=response_data["sdp"], type=response_data["type"])
    )

    while True:
        time.sleep(2)
        logger.info("pc.iceGatheringState: %s" % pc.iceGatheringState)
        logger.info("pc.connectionState : %s" % pc.connectionState)


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(run())

var config = {
    sdpSemantics: 'unified-plan'
};

pc = new RTCPeerConnection(config);

negotiate();

function negotiate() {
    pc.addTransceiver('video', {direction: 'recvonly'});
    pc.addTransceiver('audio', {direction: 'recvonly'});
    return pc.createOffer().then(function(offer) {
        return pc.setLocalDescription(offer);
    }).then(function() {
        // wait for ICE gathering to complete
        return new Promise(function(resolve) {
            if (pc.iceGatheringState === 'complete') {
                resolve();
            } else {
                function checkState() {
                    if (pc.iceGatheringState === 'complete') {
                        pc.removeEventListener('icegatheringstatechange', checkState);
                        resolve();
                    }
                }
                pc.addEventListener('icegatheringstatechange', checkState);
            }
        });
    }).then(function() {
        var offer = pc.localDescription;
        return fetch('/offer', {
            body: JSON.stringify({
                sdp: offer.sdp,
                type: offer.type,
            }),
            headers: {
                'Content-Type': 'application/json'
            },
            method: 'POST'
        });
    }).then(function(response) {
        return response.json();
    }).then(function(answer) {
        return pc.setRemoteDescription(answer);
    }).catch(function(e) {
        alert(e);
    });
}