sim1222/SyslogPro
1
0
Fork 0
mirror of https://github.com/misskey-dev/SyslogPro.git synced 2025-04-29 02:37:18 +09:00
Code Issues Packages Projects Releases Wiki Activity

improve types

Browse Source
This commit is contained in:
nkzawa 2019-12-14 01:14:57 +09:00
parent 6d14bee012
commit 50093e8a34
2 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
index.ts
View File

@ -306,12 +306,12 @@ export class Syslog extends EventEmitter {
* @returns {Promise} - The Syslog formatted string sent * @returns {Promise} - The Syslog formatted string sent
* @throws {Error} - Network Error * @throws {Error} - Network Error
*/ */
async udpMessage(msg) { async udpMessage(msg: string) {
if (!this.udpSocketPromise) { if (!this.udpSocketPromise) {
this.udpSocketPromise = this.udpConnect(); this.udpSocketPromise = this.udpConnect();
} }
const socket = await this.udpSocketPromise; const socket = await this.udpSocketPromise;
return new Promise((resolve, reject) => { return new Promise<string>((resolve, reject) => {
// @ts-ignore // @ts-ignore
socket.send(msg, (err) => { socket.send(msg, (err) => {
if (err) { if (err) {
@ -357,12 +357,12 @@ export class Syslog extends EventEmitter {
* @throws {Error} - Timeout error for TCP and TLS connections * @throws {Error} - Timeout error for TCP and TLS connections
* @throws {Error} - Network Error * @throws {Error} - Network Error
*/ */
async tcpMessage(msg) { async tcpMessage(msg: string) {
if (!this.tcpSocketPromise) { if (!this.tcpSocketPromise) {
this.tcpSocketPromise = this.tcpConnect(); this.tcpSocketPromise = this.tcpConnect();
} }
const socket = await this.tcpSocketPromise; const socket = await this.tcpSocketPromise;
return new Promise((resolve, reject) => { return new Promise<string>((resolve, reject) => {
const removeListeners = () => { const removeListeners = () => {
socket.off('error', onceError); socket.off('error', onceError);
socket.off('timeout', onceTimeout); socket.off('timeout', onceTimeout);
@ -435,12 +435,12 @@ export class Syslog extends EventEmitter {
* @throws {Error} - Timeout error for TCP and TLS connections * @throws {Error} - Timeout error for TCP and TLS connections
* @throws {Error} - Network Error * @throws {Error} - Network Error
*/ */
async tlsMessage(msg) { async tlsMessage(msg: string) {
if (!this.tlsSocketPromise) { if (!this.tlsSocketPromise) {
this.tlsSocketPromise = this.tlsConnect(); this.tlsSocketPromise = this.tlsConnect();
} }
const socket = await this.tlsSocketPromise; const socket = await this.tlsSocketPromise;
return new Promise((resolve, reject) => { return new Promise<string>((resolve, reject) => {
const removeListeners = () => { const removeListeners = () => {
socket.off('error', onceError); socket.off('error', onceError);
socket.off('timeout', onceTimeout); socket.off('timeout', onceTimeout);
@ -545,7 +545,7 @@ export class Syslog extends EventEmitter {
* @throws {Error} - Timeout error for TCP and TLS connections * @throws {Error} - Timeout error for TCP and TLS connections
* @throws {Error} - Network Error * @throws {Error} - Network Error
*/ */
async send(msg) { async send(msg: string) {
if (typeof msg !== 'string') { if (typeof msg !== 'string') {
throw new Error('TYPE ERROR: Syslog message must be a string'); throw new Error('TYPE ERROR: Syslog message must be a string');
} }
@ -571,7 +571,7 @@ export class Syslog extends EventEmitter {
this.tcpSocketPromise = null; this.tcpSocketPromise = null;
return; return;
} }
return new Promise((resolve) => { return new Promise<void>((resolve) => {
socket.end(resolve); socket.end(resolve);
}); });
} }
@ -584,7 +584,7 @@ export class Syslog extends EventEmitter {
this.tlsSocketPromise = null; this.tlsSocketPromise = null;
return; return;
} }
return new Promise((resolve) => { return new Promise<void>((resolve) => {
socket.end(resolve); socket.end(resolve);
}); });
} }
@ -597,7 +597,7 @@ export class Syslog extends EventEmitter {
this.udpSocketPromise = null; this.udpSocketPromise = null;
return; return;
} }
return new Promise((resolve) => { return new Promise<void>((resolve) => {
socket.close(resolve); socket.close(resolve);
}); });
} }

2
package-lock.json generated
View File

@ -1,6 +1,6 @@
{ {
"name": "@zeit/syslog-pro", "name": "@zeit/syslog-pro",
"version": "0.2.2", "version": "0.2.6",
"lockfileVersion": 1, "lockfileVersion": 1,
"requires": true, "requires": true,
"dependencies": { "dependencies": {