right, stdin

bzip.go

@@ -1,21 +0,0 @@
-package main
-
-import (
-	"compress/bzip2"
-	"io"
-)
-
-// bzipCloser wraps an io.ReadCloser in a bzip reader, while allowing a caller
-// to close the underlying source
-type bzipCloser struct {
-	reader io.Reader
-	source io.ReadCloser
-}
-
-func newBzipCloser(r io.ReadCloser) io.ReadCloser {
-	return &bzipCloser{reader: bzip2.NewReader(r), source: r}
-}
-
-func (b *bzipCloser) Read(p []byte) (int, error) { return b.reader.Read(p) }
-
-func (b *bzipCloser) Close() error { return b.source.Close() }

main.go

@@ -1,11 +1,11 @@
 package main
 
 import (
+	"compress/bzip2"
 	"flag"
 	"fmt"
 	"io"
 	"os"
-	"path/filepath"
 	"strings"
 )
 
@@ -16,14 +16,6 @@ func ensureNewline(t string) string {
 	return t + "\n"
 }
 
-func usage(t string, args ...interface{}) {
-	t = ensureNewline(t) + "\n"
-	fmt.Fprintf(os.Stderr, t, args...)
-	fmt.Fprintln(os.Stderr, "Usage:")
-	fmt.Fprintln(os.Stderr, "\thyperstone replay-id")
-	os.Exit(1)
-}
-
 func bail(status int, t string, args ...interface{}) {
 	var out io.Writer
 	if status == 0 {
@@ -36,29 +28,39 @@ func bail(status int, t string, args ...interface{}) {
 	os.Exit(status)
 }
 
-func openReplayFile(path string) (io.ReadCloser, error) {
+type options struct {
-	fi, err := os.Open(path)
+	b bool   // bzip compression flag
-	if err != nil {
+	v bool   // verbose flag
-		return nil, fmt.Errorf("unable to open replay file: %v", err)
+	f string // input file
+}
+
+func (o options) input() (io.Reader, error) {
+	var r io.Reader
+	if o.f == "--" {
+		r = os.Stdin
+	} else {
+		fi, err := os.Open(o.f)
+		if err != nil {
+			return nil, fmt.Errorf("unable to open file %s: %v", o.f, err)
+		}
+		r = fi
 	}
 
-	switch filepath.Ext(path) {
+	if o.b {
-	case ".bz2":
+		r = bzip2.NewReader(r)
-		return newBzipCloser(fi), nil
-	default:
-		return fi, nil
 	}
-	return nil, io.EOF
+	return r, nil
 }
 
 func main() {
+	var opts options
+	flag.BoolVar(&opts.b, "b", false, "input is expected to be bzip-compressed")
+	flag.BoolVar(&opts.v, "v", false, "verbose mode")
+	flag.StringVar(&opts.f, "f", "--", "input file to be used. -- means stdin")
 	flag.Parse()
-	if flag.NArg() != 1 {
+
-		usage("please supply the path to a valid replay file")
+	_, err := opts.input()
-	}
-	f, err := openReplayFile(flag.Arg(0))
 	if err != nil {
-		bail(1, "unable to open replay file: %v", err)
+		bail(1, "input error: %v", err)
 	}
-	defer f.Close()
 }