Compare commits
4 Commits
1fa830f286
...
721f80d0f2
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
721f80d0f2 | ||
| 6339f0c2e5 | |||
| 656052dc74 | |||
| 6c5873da6f |
@ -81,7 +81,8 @@ func (arp *ATRequestParser) GetInput(rq any) ([]byte, error) {
|
|||||||
return nil, fmt.Errorf("no input found")
|
return nil, fmt.Errorf("no input found")
|
||||||
}
|
}
|
||||||
|
|
||||||
return []byte(parts[len(parts)-1]), nil
|
trimmedInput := strings.TrimSpace(parts[len(parts)-1])
|
||||||
|
return []byte(trimmedInput), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func parseQueryParams(query string) map[string]string {
|
func parseQueryParams(query string) map[string]string {
|
||||||
|
|||||||
@ -204,6 +204,7 @@ func(s *SshRunner) GetEngine(sessionId string) (engine.Engine, func(), error) {
|
|||||||
|
|
||||||
// adapted example from crypto/ssh package, NewServerConn doc
|
// adapted example from crypto/ssh package, NewServerConn doc
|
||||||
func(s *SshRunner) Run(ctx context.Context, keyStore *SshKeyStore) {
|
func(s *SshRunner) Run(ctx context.Context, keyStore *SshKeyStore) {
|
||||||
|
s.Ctx = ctx
|
||||||
running := true
|
running := true
|
||||||
|
|
||||||
// TODO: waitgroup should probably not be global
|
// TODO: waitgroup should probably not be global
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user