/
class_child_process.ahk
141 lines (137 loc) · 6.24 KB
/
class_child_process.ahk
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
/************************************************************************
* @author thqby
* @date 2022/03/06
* @version 1.0.1
***********************************************************************/
class child_process {
pid := 0, hProcess := 0, onData := 0, onClose := 0
stdin := 0, stdout := 0, stderr := 0, output := [], error := [], laststdoutindex := 0
/**
* create a child process, then capture the stdout/stderr outputs.
* @param command The name of the module to be executed or the command line to be executed.
* @param args List of string arguments.
* @param sync Get the output by synchronous blocking method, `stdin` will be closed after `CreateProcess`.
* @param options The object or map with optional property.
*
* `cwd` = '', Current working directory of the child process.
*
* `input` = '', The value which will be passed as stdin to the child process.(only sync mode)
*
* `encoding` = 'cp0' or ['cp0','cp0','cp0'], The encoding(s) of stdin/stdout/stderr.
*
* `hide` = true, hide the subprocess window that would normally be created on Windows systems.
*
* `flags` = DllCall('GetPriorityClass', 'ptr', -1, 'uint'), The flags that control the priority class and the creation of the process.
*
* `onData`, The callback function that is called when stdout/stderr receives data. Close the pipe when the callback returns true.
*
* `onClose` The callback function that is called when stdout/stderr is closed.
*/
__New(command, args := unset, sync := false, options := 0) {
handles := [], handles.DefineProp('__Delete', { call: closehandles })
hide := true, flags := DllCall('GetPriorityClass', 'ptr', -1, 'uint')
encoding := encoding_in := encoding_out := encoding_err := 'cp0'
input := cwd := params := '', onData := onClose := 0
if options
for k, v in (options is Object ? options.OwnProps() : options)
try %k% := v
flags |= hide ? 0x08000000 : 0, this.onData := onData, this.onClose := onClose
if encoding is Array {
for i, v in ['in', 'out', 'err']
encoding.Has(i) ? encoding_%v% := encoding[i] : 0
} else encoding_in := encoding_out := encoding_err := encoding
if IsSet(args) {
if args is Array {
for v in args
params .= ' ' escapeparam(v)
} else params := args
} else if SubStr(command, 1, 1) = '"' || !FileExist(command)
params := command, command := ''
x64 := (A_PtrSize = 8), STARTUPINFO := Buffer(x64 ? 104 : 68, 0), PROCESS_INFORMATION := Buffer(x64 ? 24 : 16)
NumPut('uint', x64 ? 104 : 68, STARTUPINFO), NumPut('uint', 0x100, STARTUPINFO, x64 ? 60 : 44)
sp := NumPut('ptr', (handles.Push(t := this.Pipe('stdin', encoding_in)), t), sp := (x64 ? 80 : 56) + STARTUPINFO.Ptr)
sp := NumPut('ptr', (handles.Push(t := this.Pipe('stdout', encoding_out)), t), sp)
sp := NumPut('ptr', (handles.Push(t := this.Pipe('stderr', encoding_err)), t), sp)
if !DllCall('CreateProcess', 'ptr', command ? StrPtr(command) : 0, 'ptr', params ? StrPtr(params) : 0, 'ptr', 0, 'int', 0,
'int', true, 'int', flags, 'int', 0, 'ptr', cwd ? StrPtr(cwd) : 0, 'ptr', STARTUPINFO, 'ptr', PROCESS_INFORMATION)
throw OSError(A_LastError)
handles.Push(NumGet(PROCESS_INFORMATION, A_PtrSize, 'ptr')), handles := 0
this.hProcess := NumGet(PROCESS_INFORMATION, 'ptr'), this.pid := NumGet(PROCESS_INFORMATION, 2 * A_PtrSize, 'uint')
this.output.DefineProp('toString', { call: toString }), this.error.DefineProp('toString', { call: toString })
if sync {
this.stdin := input ? (this.stdin.Write(input), '') : ''
while this()
continue
} else SetTimer(this, 20, 10000)
closehandles(obj) {
for h in obj
DllCall('CloseHandle', 'ptr', h)
}
escapeparam(s) {
s := StrReplace(s, '"', '\"', , &c)
return c || RegExMatch(s, '\s') ? '"' s '"' : s
}
toString(arr, begin := 0) { ; zero-based index
static mIndex_offset := 6 * A_PtrSize + 16
for v in (s := '', begin > 0 ? (NumPut('uint', begin - 1, ObjPtr(enum := arr.__Enum(1)), mIndex_offset), enum) : arr)
s .= '`n' v
return SubStr(s, 2)
}
}
__Delete() {
if this.hProcess
DllCall('CloseHandle', 'ptr', this.hProcess), this.hProcess := 0
}
; create anonymous pipe
Pipe(name, codepage) {
static mFlags_offset := 4 * A_PtrSize + 8, USEHANDLE := 0x10000000
if !DllCall('CreatePipe', "ptr*", &hPipeR := 0, "ptr*", &hPipeW := 0, 'ptr', 0, 'uint', 0)
throw OSError(A_LastError)
if name = 'stdin' {
this.stdin := file := FileOpen(hPipeW, 'h', codepage), ptr := hPipeR
file.DefineProp('Flush', { call: (s) => s.Read(0) })
} else {
this.%name% := file := FileOpen(hPipeR, 'h`n', codepage), ptr := hPipeW
DllCall('SetNamedPipeHandleState', 'ptr', hPipeR, 'uint*', 1, 'ptr', 0, 'ptr', 0) ; PIPE_NOWAIT
}
p := ObjPtr(file), file.ptr := file.Handle
NumPut('uint', NumGet(p, mFlags_offset, 'uint') & ~USEHANDLE, p, mFlags_offset) ; remove USEHANDLE flag, auto close handle
DllCall('SetHandleInformation', 'ptr', ptr, 'int', 1, 'int', 1)
return ptr
}
Clear() => this.output.Length := this.error.Length := this.laststdoutindex := 0
GetLastStdout() => this.output.toString((t := this.laststdoutindex, this.laststdoutindex := this.output.Length, t))
; wait process exit
Wait(timeout := -1) => DllCall('WaitForSingleObject', 'ptr', this.hProcess, 'uint', timeout)
; terminate process
Terminate() {
if this.hProcess
DllCall('TerminateProcess', 'ptr', this.hProcess)
}
ExitCode => (DllCall('GetExitCodeProcess', 'ptr', this.hProcess, 'uint*', &code := 0), code)
; get stdout/stderr output
Call() {
static outs := ['stdout', 'stderr']
for k in (peek := 0, outs) {
if !(f := this.%k%)
continue
out := k = 'stdout' ? this.output : this.error
if DllCall('PeekNamedPipe', 'ptr', f, 'ptr', 0, 'int', 0, 'ptr', 0, 'ptr', 0, 'ptr', 0) && (t := '', ++peek) {
while f {
if t := t f.Read() {
arr := StrSplit(t, '`n'), t := f.AtEOF ? '' : arr.Pop()
for line in arr
try if (out.Push(line), line) && this.onData(k, line) && (--peek, !f := this.%k% := 0) {
try this.onClose(k)
break 2
}
} else if f.AtEOF
break
else Sleep(5)
}
} else try this.%k% := f := 0, this.onClose(k)
}
; terminates the timer when the object is not referenced
return peek && (this.onData || this.onClose || NumGet(ObjPtr(this), A_PtrSize, 'uint') > 2) ? peek : (SetTimer(this, 0), 0)
}
}