Skip to content

Commit c035e08

Browse files
committed
fix: enhance inbound filtering logic in StartAllNodesByProfileQueueProcessor
- Updated the inbounds filtering to include unsecure protocols in addition to active node inbound tags.
1 parent cffb9fe commit c035e08

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

src/queue/start-all-nodes-by-profile/start-all-nodes-by-profile.processor.ts

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -145,8 +145,10 @@ export class StartAllNodesByProfileQueueProcessor extends WorkerHost {
145145
const response = await this.axios.startXray(
146146
{
147147
...config.response,
148-
inbounds: config.response.inbounds.filter((inbound) =>
149-
activeNodeInboundsTags.has(inbound.tag),
148+
inbounds: config.response.inbounds.filter(
149+
(inbound) =>
150+
activeNodeInboundsTags.has(inbound.tag) ||
151+
this.isUnsecureInbound(inbound.protocol),
150152
),
151153
} as unknown as Record<string, unknown>,
152154
node.address,
@@ -207,4 +209,8 @@ export class StartAllNodesByProfileQueueProcessor extends WorkerHost {
207209
await this.startAllNodesQueueService.queue.resume();
208210
}
209211
}
212+
213+
private isUnsecureInbound(protocol: string): boolean {
214+
return ['dokodemo-door', 'http', 'mixed', 'wireguard'].includes(protocol);
215+
}
210216
}

0 commit comments

Comments
 (0)