Skip to content
This repository has been archived by the owner on Mar 28, 2024. It is now read-only.

Commit

Permalink
fix(nano-server): compatible with new logger api
Browse files Browse the repository at this point in the history
  • Loading branch information
AliMD committed Oct 23, 2023
1 parent 49d1a28 commit ecace8b
Showing 1 changed file with 9 additions and 12 deletions.
21 changes: 9 additions & 12 deletions packages/nano-server/src/nano-server.ts
Original file line number Diff line number Diff line change
@@ -1,10 +1,9 @@
import {createServer} from 'node:http';

import {createLogger, globalAlwatr} from '@alwatr/logger';
import {createLogger, definePackage, type AlwatrLogger} from '@alwatr/logger';
import {isNumber} from '@alwatr/math';

import type {NanoServerConfig, ConnectionConfig} from './type.js';
import type {AlwatrLogger} from '@alwatr/logger';
import type {
AlwatrServiceResponse,
AlwatrServiceResponseFailed,
Expand Down Expand Up @@ -36,10 +35,8 @@ export type {
AlwatrServiceResponseSuccessWithMeta,
};

globalAlwatr.registeredList.push({
name: '@alwatr/nano-server',
version: _ALWATR_VERSION_,
});
definePackage('nano-server', '1.x');


export class AlwatrNanoServer {
protected _config: NanoServerConfig;
Expand Down Expand Up @@ -162,7 +159,7 @@ export class AlwatrNanoServer {
if (this.middlewareList[method] == null) this.middlewareList[method] = {};

if (typeof this.middlewareList[method][route] === 'function') {
this._logger.accident('route', 'route_already_exists', 'Route already exists', {
this._logger.accident('route', 'route_already_exists', {
method,
route,
});
Expand Down Expand Up @@ -209,7 +206,7 @@ export class AlwatrNanoServer {
buffer = Buffer.from(JSON.stringify(content), 'utf8');
}
catch (err) {
this._logger.accident('responseData', 'data_stringify_failed', 'JSON.stringify(data) failed!', err);
this._logger.accident('responseData', 'data_stringify_failed', err);
return this.reply(
serverResponse,
content.ok === false
Expand Down Expand Up @@ -247,7 +244,7 @@ export class AlwatrNanoServer {

protected _errorListener(err: NodeJS.ErrnoException): void {
if (err.code === 'EADDRINUSE') {
this._logger.incident?.('server.onError', 'address_in_use', 'Address in use, retrying...', err);
this._logger.incident?.('server.onError', 'address_in_use', err);
setTimeout(() => {
this.httpServer.close();
this.httpServer.listen(this._config.port, this._config.host, () => {
Expand All @@ -261,7 +258,7 @@ export class AlwatrNanoServer {
}

protected _clientErrorListener(err: NodeJS.ErrnoException, socket: Duplex): void {
this._logger.accident('server.clientError', 'http_server_catch_client_error', 'HTTP server catch a client error', {
this._logger.accident('server.clientError', 'http_server_catch_client_error', {
errCode: err.code,
errMessage: err.message,
});
Expand Down Expand Up @@ -300,12 +297,12 @@ export class AlwatrNanoServer {
this._logger.logMethod?.('handleRequest');

if (incomingMessage.url == null) {
this._logger.accident('handleRequest', 'http_server_url_undefined', 'incomingMessage.url is undefined');
this._logger.accident('handleRequest', 'http_server_url_undefined');
return;
}

if (incomingMessage.method == null) {
this._logger.accident('handleRequest', 'http_server_method_undefined', 'incomingMessage.method is undefined');
this._logger.accident('handleRequest', 'http_server_method_undefined');
return;
}

Expand Down

0 comments on commit ecace8b

Please sign in to comment.