blob: 0dc4d6c11b64aa8ddd3d2e05450cd890fd34e423 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
// Copyright (C) 2024 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only
import * as net from 'net';
import { IsWindows, createLogger } from 'qt-lib';
const logger = createLogger('designer-server');
export class DesignerServer {
private readonly server: net.Server;
private client: net.Socket | undefined;
private readonly port: number;
private static readonly newLine = IsWindows ? '\r\n' : '\n';
constructor(port = 0) {
this.port = port;
this.server = net.createServer((socket) => {
socket.pipe(socket);
});
this.client = undefined;
this.start();
logger.info('Designer server is created');
}
public start() {
this.server
.listen(this.port, () => {
logger.info(`Designer server is listening on ${this.port}`);
})
.on('connection', (socket) => {
this.onConnection(socket);
})
.on('error', (err) => {
logger.error(err.message);
throw err;
});
}
private onConnection(socket: net.Socket) {
logger.info('Designer server is connected:' + socket.remoteAddress);
this.client = socket;
}
public stop() {
logger.verbose('Designer server is stopping');
this.server.close();
}
public closeClient() {
if (this.client) {
this.client.destroy();
this.client = undefined;
}
}
public dispose() {
this.stop();
}
public getPort(): number | undefined {
if (this.server.address()) {
return (this.server.address() as net.AddressInfo).port;
}
return undefined;
}
public isClientConnected() {
return this.client !== undefined && !this.client.destroyed;
}
public sendFile(filePath: string) {
if (!this.client) {
const message = 'No client connected';
logger.error(message);
throw new Error(message);
}
logger.info('Sending file:' + filePath);
this.client.write(filePath.toString() + DesignerServer.newLine);
}
}
|
