fixed: consumer decode response service error
diff --git a/packages/dubbo/src/server/server.ts b/packages/dubbo/src/server/server.ts
index a6e049b..ac3f32c 100644
--- a/packages/dubbo/src/server/server.ts
+++ b/packages/dubbo/src/server/server.ts
@@ -49,14 +49,20 @@
private readonly _middlewares: Array<Middleware<ResponseContext>>;
constructor(props: IDubboServerProps) {
- log('init dubbo-server with: %O', props);
-
const {port, services} = props;
this._port = port || 20880;
this._registry = props.registry;
this._middlewares = [];
this._services = services || [];
this._serviceMap = new Map();
+
+ // debug log
+ log(`init service with port: %d`, this._port);
+ for (let service of this._services) {
+ const methods = Object.keys(service.methods);
+ const s = {...service, methods};
+ log('registry services %j', s);
+ }
}
public static from(props: IDubboServerProps) {
@@ -65,10 +71,10 @@
start = () => {
// TODO 完善promise机制
- log('start dubbo-server with port %d', this._port);
this._server = net
.createServer(this._handleSocketRequest)
.listen(this._port, () => {
+ log('start dubbo-server with port %d', this._port);
this._registerServices();
});
};
@@ -151,7 +157,7 @@
},
];
- log('middleware->', middlewares);
+ log('middleware stack =>', middlewares);
const fn = compose(middlewares);
try {
