-
-
Notifications
You must be signed in to change notification settings - Fork 399
Expand file tree
/
Copy pathmain.go
More file actions
102 lines (90 loc) · 2.04 KB
/
main.go
File metadata and controls
102 lines (90 loc) · 2.04 KB
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
// Copyright (c) 2017, Daniel Martí <mvdan@mvdan.cc>
// See LICENSE for licensing information
// gosh is a proof of concept shell built on top of [interp].
package main
import (
"context"
"errors"
"flag"
"fmt"
"io"
"os"
"os/signal"
"strings"
"syscall"
"golang.org/x/term"
"mvdan.cc/sh/v3/interp"
"mvdan.cc/sh/v3/syntax"
)
var command = flag.String("c", "", "command to be executed")
func main() {
flag.Parse()
err := runAll()
var es interp.ExitStatus
if errors.As(err, &es) {
os.Exit(int(es))
}
if err != nil {
fmt.Fprintln(os.Stderr, err)
os.Exit(1)
}
}
func runAll() error {
ctx, _ := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
r, err := interp.New(interp.Interactive(true), interp.StdIO(os.Stdin, os.Stdout, os.Stderr))
if err != nil {
return err
}
if *command != "" {
return run(ctx, r, strings.NewReader(*command), "")
}
if flag.NArg() == 0 {
if term.IsTerminal(int(os.Stdin.Fd())) {
return runInteractive(ctx, r, os.Stdin, os.Stdout, os.Stderr)
}
return run(ctx, r, os.Stdin, "")
}
for _, path := range flag.Args() {
if err := runPath(ctx, r, path); err != nil {
return err
}
}
return nil
}
func run(ctx context.Context, r *interp.Runner, reader io.Reader, name string) error {
prog, err := syntax.NewParser().Parse(reader, name)
if err != nil {
return err
}
r.Reset()
return r.Run(ctx, prog)
}
func runPath(ctx context.Context, r *interp.Runner, path string) error {
f, err := os.Open(path)
if err != nil {
return err
}
defer f.Close()
return run(ctx, r, f, path)
}
func runInteractive(ctx context.Context, r *interp.Runner, stdin io.Reader, stdout, stderr io.Writer) error {
parser := syntax.NewParser()
fmt.Fprintf(stdout, "$ ")
for stmts, err := range parser.InteractiveSeq(stdin) {
if err != nil {
return err // stop at the first error
}
if parser.Incomplete() {
fmt.Fprintf(stdout, "> ")
continue
}
for _, stmt := range stmts {
err := r.Run(ctx, stmt)
if r.Exited() {
return err
}
}
fmt.Fprintf(stdout, "$ ")
}
return nil
}