From 902bb1cc2a0a8644e160f303be1a2e0ad354bfd5 Mon Sep 17 00:00:00 2001
From: Luke Shumaker <lukeshu@lukeshu.com>
Date: Wed, 15 Nov 2017 15:38:05 -0500
Subject: initial commit

---
 read.go | 65 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 65 insertions(+)
 create mode 100644 read.go

(limited to 'read.go')

diff --git a/read.go b/read.go
new file mode 100644
index 0000000..cfe35c4
--- /dev/null
+++ b/read.go
@@ -0,0 +1,65 @@
+package libfastimport
+
+type UnsupportedCommand string
+
+func (e UnsupportedCommand) Error() string {
+	return "Unsupported command: "+string(e)
+}
+
+type Parser struct {
+	fir *FIReader
+
+	cmd chan Cmd
+}
+
+func (p *Parser) GetCmd() (Cmd, error) {
+	for p.cmd == nil {
+		slice, err := p.fir.ReadSlice()
+		if err != nil {
+			return nil, err
+		}
+		err = p.putSlice(slice)
+		if err != nil {
+			return nil, err
+		}
+	}
+	return p.cmd, nil
+}
+
+func (p *Parser) putSlice(slice []byte) error {
+}
+
+func utSlice(fir *FIReader) (Cmd, error) {
+	slice, err := fir.PeekSlice()
+	if err != nil {
+		return nil, err
+	}
+	if len(slice) < 1 {
+		return nil, UnsupportedCommand(slice)
+	}
+	switch slice[0] {
+	case '#': // comment
+	case 'b': // blob
+	case 'c':
+		if len(slice) < 2 {
+			return nil, UnsupportedCommand(slice)
+		}
+		switch slice[1] {
+		case 'o': // commit
+		case 'h': // checkpoint
+		case 'a': // cat-blob
+		default:
+			return nil, UnsupportedCommand(slice)
+		}
+	case 'd': // done
+	case 'f': // feature
+	case 'g': // get-mark
+	case 'l': // ls
+	case 'o': // option
+	case 'p': // progress
+	case 'r': // reset
+	case 't': // tag
+	default:
+		return nil, UnsupportedCommand(slice)
+	}
+}
-- 
cgit v1.2.3