lytedev/godot-webrtc-mplayer-testing
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

It works over the internet across clients

Browse source
This commit is contained in:
Daniel Flanagan 2021-12-06 15:55:16 -06:00
parent 1417401ccd
commit 7d76876f99
Signed by: lytedev
GPG key ID: 5B2020A0F9921EF4
4 changed files with 22 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
multiplayer_client.gd
View file

@ -4,7 +4,7 @@ extends Node
This module sets up WebRTC peer connections.
"""
var multiplayer_url = "ws://webrtc-signaller.deno.dev"
var multiplayer_url = "wss://webrtc-signaller.deno.dev:443"
# var multiplayer_url = "ws://localhost:8888"
# var multiplayer_url = "ws://echo.websocket.org"
var webrtc_ice_servers = [

6
project.godot
View file

@ -20,7 +20,11 @@ Global="*res://global.gd"
[gdnative]
singletons=[ ]
singletons=[ "res://webrtc/webrtc.tres" ]
[network]
ssl/certificates="res://ca-certificates.crt"
[physics]

15
server.ts
View file

@ -15,7 +15,7 @@ interface DataMessage {
}
type ServerDataObject = Record<string, string | number | symbol | null>;
type ServerData = ServerDataObject | string;
type ServerData = ServerDataObject[] | ServerDataObject | string;
type Message = string | DataMessage;
const broadcast = (message: Message) =>
@ -185,12 +185,13 @@ class Lobby {
peerId: client.peerId,
}),
);
this.clients.forEach((c) =>
client.send(buildMessage("peer_joined", {
id: c.id,
name: c.name,
peerId: c.peerId,
}))
client.send(
buildMessage(
"peer_joined",
Array.from(this.clients.values()).map(
({ id, name, peerId }) => ({ id, name, peerId }),
),
),
);
this.clients.set(client.id, client);
}

14
signaller_client.gd
View file

@ -30,9 +30,14 @@ func _ready():
var _result = ws.connect("data_received", self, "_parse_msg")
_result = ws.connect("connection_established", self, "_connected")
_result = ws.connect("connection_closed", self, "_closed")
_result = ws.connect("connection_error", self, "_closed")
_result = ws.connect("connection_error", self, "_closed", [false])
_result = ws.connect("connection_failed", self, "_closed", [false])
_result = ws.connect("connection_succeeded", self, "_succ")
_result = ws.connect("server_close_request", self, "_close_request")
func _succ():
print("WebSocket Connection Succeeded")
func close():
ws.disconnect_from_host()
@ -60,11 +65,8 @@ func _connected(protocol = ""):
func _process(_delta: float):
var status: int = ws.get_connection_status()
ws.poll()
if status == WebSocketClient.CONNECTION_CONNECTED || status == WebSocketClient.CONNECTION_CONNECTING:
print("I'm polling! %s" % status)
else:
print("Not polling! %s" % status)
if status in [WebSocketClient.CONNECTION_CONNECTED, WebSocketClient.CONNECTION_CONNECTING]:
ws.poll()
func join_lobby(id: String):
return _send("lobby_join:%s" % id)