| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- extends Node
- var peer = WebRTCPeerConnection.new()
- var wsclient
- var username
- # Create negotiated data channel
- var channel = peer.create_data_channel("position", {"negotiated": true, "id": 1})
- func _ready():
- # Connect all functions
- peer.connect("ice_candidate_created", self, "_on_ice_candidate")
- peer.connect("session_description_created", self, "_on_session")
- # Register to the local signaling server (see below for the implementation)
- wsclient = find_node("WSClient")
- wsclient.connect("ws_login_in", self, "on_login_in")
- wsclient.connect("ws_candidate_in", self, "on_candidate_in")
- wsclient.connect("ws_session_in", self, "on_session_in")
- wsclient.login()
- peer.create_offer()
- breakpoint
- func _on_ice_candidate(mid, index, sdp):
- # Send the ICE candidate to the other peer via signaling server
- var data = {"mtype": "candidate", "payload": {"mid": mid, "index": index, "sdp": sdp}}
- emit_signal("ws_out", data)
- func _on_session(type, sdp):
- # Send the session to other peer via signaling server
- var data = {"mtype": "session", "payload": {"type": type, "sdp": sdp}}
- emit_signal("ws_out", data)
-
- # Set generated description as local
- peer.set_local_description(type, sdp)
-
- func _process(delta):
- # Always poll the connection frequently
- peer.poll()
- if channel.get_ready_state() == WebRTCDataChannel.STATE_OPEN:
- while channel.get_available_packet_count() > 0:
- print(get_path(), " received: ", channel.get_packet().get_string_from_utf8())
- func send_message(message):
- channel.put_packet(message.to_utf8())
-
- func on_session_in(type, sdp):
- peer.set_remote_description(type, sdp)
- func on_candidate_in(mid, index, sdp):
- peer.add_ice_candidate(mid, index, sdp)
- func on_ws_login_in(msg):
- print(msg)
|
