update: enable manually handle cross resolving context

src/core/kernel.ts

@@ -28,6 +28,7 @@ export class Kernel<
 			requestId: string;
 			resolve: (value: unknown) => void;
 			reject: (error: Error | string) => void;
+			resolveCallback?: Middleware;
 		}
 	> = {};
 	private channelsMap: Record<ChannelId, ChannelContext<EventType>> =
@@ -247,7 +248,11 @@ export class Kernel<
 		await execute(request, middlewares);
 	}
 
-	createCrossResolvingRequest(requestId: string, timeout: number = 1000) {
+	createCrossResolvingRequest(
+		requestId: string,
+		timeout: number = 1000,
+		resolveCallback?: Middleware,
+	) {
 		const resolveId = crypto.randomUUID();
 
 		const resolve = async <T>() => {
@@ -269,6 +274,7 @@ export class Kernel<
 						clearTimeout(timerId);
 						delete this.crossResolvingContext[resolveId];
 					},
+					resolveCallback,
 				};
 			}) as T;
 		};
@@ -311,7 +317,7 @@ export class Kernel<
 		clearInterval(this.timer as never);
 	}
 
-	handleCrossResolvingMiddleware: Middleware = (request, respond) => {
+	handleCrossResolvingMiddleware: Middleware = async (request, respond) => {
 		const { resolveId } = request;
 		if (!resolveId) {
 			respond({ error: 'Can not find resolveId in request' });
@@ -322,9 +328,13 @@ export class Kernel<
 		if (!resolvingContext) {
 			respond({ error: 'Can not find context for cross-resolving' });
 		} else {
-			const { resolve } = resolvingContext;
-			resolve(request);
-			respond({ message: 'ok' });
+			const { resolve, resolveCallback } = resolvingContext;
+			if (!resolveCallback) {
+				resolve(request);
+				respond({ message: 'ok' });
+			} else {
+				await resolveCallback(request, respond, resolve);
+			}
 		}
 	};