me/e4mc
1
1
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Wiki Activity

New Ingress server!

Browse source
This commit is contained in:
Skye 2023-04-09 21:48:23 +09:00
parent ec252a9ffe
commit ff0831c89d
Signed by: me
GPG key ID: 0104BC05F41B77B8
3 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
client/src/main.rs
View file

@ -39,7 +39,7 @@ async fn main() -> anyhow::Result<()> {
let args = Args::parse(); let args = Args::parse();
let server = args let server = args
.server .server
.unwrap_or("wss://e4mc.skyevg.systems".to_string()); .unwrap_or("wss://ingress.e4mc.link".to_string());
let (ws_conn, _) = connect_async(server).await?; let (ws_conn, _) = connect_async(server).await?;
let (send, recv) = ws_conn.split(); let (send, recv) = ws_conn.split();
let (sender, receiver) = tokio::sync::mpsc::unbounded_channel(); let (sender, receiver) = tokio::sync::mpsc::unbounded_channel();

2
node/client.ts
View file

@ -1,7 +1,7 @@
import WebSocket from 'ws'; import WebSocket from 'ws';
import net from 'net'; import net from 'net';
const DEFAULT_REMOTE_SERVER = 'wss://e4mc.skyevg.systems'; const DEFAULT_REMOTE_SERVER = 'wss://ingress.e4mc.link';
const DEFAULT_TCP_ADDRESS = 'localhost'; const DEFAULT_TCP_ADDRESS = 'localhost';
const DEFAULT_TCP_PORT = 25565; const DEFAULT_TCP_PORT = 25565;

2
quilt/src/main/java/vg/skye/e4mc_quilt/E4mcRelayHandler.kt
View file

@ -27,7 +27,7 @@ data class DomainAssignedMessage(val DomainAssigned: String)
data class ChannelOpenMessage(val ChannelOpen: List<Any>) data class ChannelOpenMessage(val ChannelOpen: List<Any>)
data class ChannelClosedMessage(val ChannelClosed: Number) data class ChannelClosedMessage(val ChannelClosed: Number)
class E4mcRelayHandler: WebSocketClient(URI("wss://e4mc.skyevg.systems")) { class E4mcRelayHandler: WebSocketClient(URI("wss://ingress.e4mc.link")) {
private val gson = Gson() private val gson = Gson()
private val childChannels = mutableMapOf<Int, LocalChannel>() private val childChannels = mutableMapOf<Int, LocalChannel>()
private val messageQueue = mutableMapOf<Int, ArrayBlockingQueue<ByteBuffer>>() private val messageQueue = mutableMapOf<Int, ArrayBlockingQueue<ByteBuffer>>()