Skip to content

Commit 97d7f06

Browse files
committed
🐛 Close udp socket after request is done
1 parent 46311b1 commit 97d7f06

File tree

5 files changed

+15
-3
lines changed

5 files changed

+15
-3
lines changed

package-lock.json

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "steam-server-query",
3-
"version": "1.1.0",
3+
"version": "1.1.1",
44
"description": "Module which implements the Master Server Query Protocol and Game Server Queries.",
55
"main": "lib/index.js",
66
"types": "lib/index.d.ts",

src/gameServer/gameServer.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,8 @@ class GameServerQuery {
8484
}
8585
}
8686

87+
this._promiseSocket.closeSocket();
88+
8789
const parsedInfoBuffer = this._parseInfoBuffer(resultBuffer);
8890
return parsedInfoBuffer as InfoResponse;
8991
}
@@ -105,6 +107,8 @@ class GameServerQuery {
105107
throw new Error(err);
106108
}
107109

110+
this._promiseSocket.closeSocket();
111+
108112
const parsedPlayerBuffer = this._parsePlayerBuffer(resultBuffer);
109113
return parsedPlayerBuffer;
110114
}
@@ -126,6 +130,8 @@ class GameServerQuery {
126130
throw new Error(err);
127131
}
128132

133+
this._promiseSocket.closeSocket();
134+
129135
const parsedRulesBuffer = this._parseRulesBuffer(resultBuffer);
130136
return parsedRulesBuffer;
131137
}

src/masterServer/masterServer.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,8 @@ class MasterServerQuery {
5757
}
5858
} while (this._seedId !== ZERO_IP);
5959

60+
this._promiseSocket.closeSocket();
61+
6062
// remove ZERO_IP from end of host list
6163
this._hosts.pop();
6264
return this._hosts;

src/promiseSocket.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,10 @@ export class PromiseSocket {
3535
});
3636
}
3737

38+
public closeSocket() {
39+
this._socket.close();
40+
}
41+
3842
private _socketSend(buffer: Buffer, host: string, port: number, timeout: number): Promise<Buffer> {
3943
return new Promise((resolve, reject) => {
4044
this._socket.send(buffer, port, host, (err) => {

0 commit comments

Comments
 (0)