update
This commit is contained in:
@@ -614,7 +614,8 @@ export class QueryRouter {
|
|||||||
}
|
}
|
||||||
/**
|
/**
|
||||||
* 等待程序运行, 获取到message的数据,就执行
|
* 等待程序运行, 获取到message的数据,就执行
|
||||||
*
|
* params 是预设参数,默认path为main
|
||||||
|
*
|
||||||
* emitter = process
|
* emitter = process
|
||||||
* -- .exit
|
* -- .exit
|
||||||
* -- .on
|
* -- .on
|
||||||
|
|||||||
@@ -2,7 +2,7 @@ export type ListenProcessOptions = {
|
|||||||
app?: any; // 传入的应用实例
|
app?: any; // 传入的应用实例
|
||||||
emitter?: any; // 可选的事件发射器
|
emitter?: any; // 可选的事件发射器
|
||||||
params?: any; // 可选的参数
|
params?: any; // 可选的参数
|
||||||
timeout?: number; // 可选的超时时间 (单位: 毫秒)
|
timeout?: number; // 可选的超时时间 (单位: 毫秒) 默认 10 分钟
|
||||||
};
|
};
|
||||||
export const listenProcess = async ({ app, emitter, params, timeout = 10 * 60 * 60 * 1000 }: ListenProcessOptions) => {
|
export const listenProcess = async ({ app, emitter, params, timeout = 10 * 60 * 60 * 1000 }: ListenProcessOptions) => {
|
||||||
const process = emitter || globalThis.process;
|
const process = emitter || globalThis.process;
|
||||||
@@ -27,9 +27,10 @@ export const listenProcess = async ({ app, emitter, params, timeout = 10 * 60 *
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const { path = 'main', ...rest } = await getParams()
|
const { path = 'main', payload = {}, ...rest
|
||||||
|
} = await getParams()
|
||||||
// 执行主要逻辑
|
// 执行主要逻辑
|
||||||
const result = await app.queryRoute({ path, ...rest, ...params })
|
const result = await app.queryRoute({ path, ...params, ...rest, payload: { ...params.payload, ...payload } })
|
||||||
// 发送结果回主进程
|
// 发送结果回主进程
|
||||||
const response = {
|
const response = {
|
||||||
success: true,
|
success: true,
|
||||||
|
|||||||
Reference in New Issue
Block a user