File tree Expand file tree Collapse file tree 6 files changed +15
-16
lines changed
Expand file tree Collapse file tree 6 files changed +15
-16
lines changed Original file line number Diff line number Diff line change 22node_modules /
33node_modules_mac /
44node_modules_cont /
5- package-lock.json
65
76# Build outputs
87dist /
Original file line number Diff line number Diff line change @@ -50,7 +50,7 @@ export class BoltService {
5050
5151 // Cache storage
5252 private inventoryCache : CacheEntry < Node [ ] > | null = null ;
53- private factsCache : Map < string , CacheEntry < Facts > > = new Map ( ) ;
53+ private factsCache = new Map < string , CacheEntry < Facts > > ( ) ;
5454
5555 constructor (
5656 boltProjectPath : string ,
Original file line number Diff line number Diff line change @@ -93,9 +93,9 @@ export function createCommandsRouter(
9393 try {
9494 // Set up streaming callback if expert mode is enabled and streaming manager is available
9595 const streamingCallback = expertMode && streamingManager ? {
96- onCommand : ( cmd : string ) => streamingManager . emitCommand ( executionId , cmd ) ,
97- onStdout : ( chunk : string ) => streamingManager . emitStdout ( executionId , chunk ) ,
98- onStderr : ( chunk : string ) => streamingManager . emitStderr ( executionId , chunk ) ,
96+ onCommand : ( cmd : string ) => { streamingManager . emitCommand ( executionId , cmd ) ; } ,
97+ onStdout : ( chunk : string ) => { streamingManager . emitStdout ( executionId , chunk ) ; } ,
98+ onStderr : ( chunk : string ) => { streamingManager . emitStderr ( executionId , chunk ) ; } ,
9999 } : undefined ;
100100
101101 const result = await boltService . runCommand ( nodeId , command , streamingCallback ) ;
Original file line number Diff line number Diff line change 11import { Router , type Request , type Response } from "express" ;
22import { z } from "zod" ;
3- import { BoltService } from "../bolt/BoltService" ;
4- import { ExecutionRepository } from "../database/ExecutionRepository" ;
3+ import type { BoltService } from "../bolt/BoltService" ;
4+ import type { ExecutionRepository } from "../database/ExecutionRepository" ;
55import { asyncHandler } from "./asyncHandler" ;
66
77/**
@@ -111,9 +111,9 @@ export function createPackagesRouter(
111111 try {
112112 // Set up streaming callback if expert mode is enabled and streaming manager is available
113113 const streamingCallback = expertMode && streamingManager ? {
114- onCommand : ( cmd : string ) => streamingManager . emitCommand ( executionId , cmd ) ,
115- onStdout : ( chunk : string ) => streamingManager . emitStdout ( executionId , chunk ) ,
116- onStderr : ( chunk : string ) => streamingManager . emitStderr ( executionId , chunk ) ,
114+ onCommand : ( cmd : string ) => { streamingManager . emitCommand ( executionId , cmd ) ; } ,
115+ onStdout : ( chunk : string ) => { streamingManager . emitStdout ( executionId , chunk ) ; } ,
116+ onStderr : ( chunk : string ) => { streamingManager . emitStderr ( executionId , chunk ) ; } ,
117117 } : undefined ;
118118
119119 // Execute package installation task with parameter mapping
Original file line number Diff line number Diff line change @@ -86,9 +86,9 @@ export function createPuppetRouter(
8686 try {
8787 // Set up streaming callback if expert mode is enabled and streaming manager is available
8888 const streamingCallback = expertMode && streamingManager ? {
89- onCommand : ( cmd : string ) => streamingManager . emitCommand ( executionId , cmd ) ,
90- onStdout : ( chunk : string ) => streamingManager . emitStdout ( executionId , chunk ) ,
91- onStderr : ( chunk : string ) => streamingManager . emitStderr ( executionId , chunk ) ,
89+ onCommand : ( cmd : string ) => { streamingManager . emitCommand ( executionId , cmd ) ; } ,
90+ onStdout : ( chunk : string ) => { streamingManager . emitStdout ( executionId , chunk ) ; } ,
91+ onStderr : ( chunk : string ) => { streamingManager . emitStderr ( executionId , chunk ) ; } ,
9292 } : undefined ;
9393
9494 const result = await boltService . runPuppetAgent ( nodeId , config , streamingCallback ) ;
Original file line number Diff line number Diff line change @@ -40,9 +40,9 @@ export class ExecutionQueueFullError extends Error {
4040export class ExecutionQueue {
4141 private readonly limit : number ;
4242 private readonly maxQueueSize : number ;
43- private runningExecutions : Set < string > = new Set ( ) ;
44- private queuedExecutions : Map < string , QueuedExecution > = new Map ( ) ;
45- private waitingPromises : Map < string , { resolve : ( ) => void ; reject : ( error : Error ) => void } > = new Map ( ) ;
43+ private runningExecutions = new Set < string > ( ) ;
44+ private queuedExecutions = new Map < string , QueuedExecution > ( ) ;
45+ private waitingPromises = new Map < string , { resolve : ( ) => void ; reject : ( error : Error ) => void } > ( ) ;
4646
4747 constructor ( limit = 5 , maxQueueSize = 50 ) {
4848 this . limit = limit ;
You can’t perform that action at this time.
0 commit comments