898d8d94c8
- Fix display of CJK wide characters
- Fix horizontal offset of header lines
- Add support for keys with ALT modifier, shift-tab, page-up and down
- Fix util.ExecCommand to properly parse command-line arguments
- Fix redraw on resize
- Implement Pause/Resume for execute action
- Remove runtime check of GOOS
- Change exit status to 2 when tcell failed to start
- TBD: Travis CI build for tcell renderer
- Pending. tcell cannot reliably ingest keys from tmux send-keys
79 lines
1.5 KiB
Go
79 lines
1.5 KiB
Go
package fzf
|
|
|
|
import (
|
|
"bufio"
|
|
"io"
|
|
"os"
|
|
|
|
"github.com/junegunn/fzf/src/util"
|
|
)
|
|
|
|
// Reader reads from command or standard input
|
|
type Reader struct {
|
|
pusher func([]byte) bool
|
|
eventBox *util.EventBox
|
|
delimNil bool
|
|
}
|
|
|
|
// ReadSource reads data from the default command or from standard input
|
|
func (r *Reader) ReadSource() {
|
|
if util.IsTty() {
|
|
cmd := os.Getenv("FZF_DEFAULT_COMMAND")
|
|
if len(cmd) == 0 {
|
|
cmd = defaultCommand
|
|
}
|
|
r.readFromCommand(cmd)
|
|
} else {
|
|
r.readFromStdin()
|
|
}
|
|
r.eventBox.Set(EvtReadFin, nil)
|
|
}
|
|
|
|
func (r *Reader) feed(src io.Reader) {
|
|
delim := byte('\n')
|
|
if r.delimNil {
|
|
delim = '\000'
|
|
}
|
|
reader := bufio.NewReaderSize(src, readerBufferSize)
|
|
for {
|
|
// ReadBytes returns err != nil if and only if the returned data does not
|
|
// end in delim.
|
|
bytea, err := reader.ReadBytes(delim)
|
|
byteaLen := len(bytea)
|
|
if len(bytea) > 0 {
|
|
if err == nil {
|
|
// get rid of carriage return if under Windows:
|
|
if util.IsWindows() && byteaLen >= 2 && bytea[byteaLen-2] == byte('\r') {
|
|
bytea = bytea[:byteaLen-2]
|
|
} else {
|
|
bytea = bytea[:byteaLen-1]
|
|
}
|
|
}
|
|
if r.pusher(bytea) {
|
|
r.eventBox.Set(EvtReadNew, nil)
|
|
}
|
|
}
|
|
if err != nil {
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
func (r *Reader) readFromStdin() {
|
|
r.feed(os.Stdin)
|
|
}
|
|
|
|
func (r *Reader) readFromCommand(cmd string) {
|
|
listCommand := util.ExecCommand(cmd)
|
|
out, err := listCommand.StdoutPipe()
|
|
if err != nil {
|
|
return
|
|
}
|
|
err = listCommand.Start()
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer listCommand.Wait()
|
|
r.feed(out)
|
|
}
|