Merge pull request #73 from mgatny/filestore

Implement FileStore

Author: cbusbey

Makefile

@@ -1,7 +1,7 @@
 all: vet test
 
 get:
-	go get github.com/golang/lint/golint
+	go get -t -d ./...
 
 GEN_MESSAGES = go run _gen/generate-messages/main.go
 GEN_COMPONENTS = go run _gen/generate-components/main.go
@@ -20,15 +20,16 @@ vet:
 	go vet ./...
 
 lint:
+	go get github.com/golang/lint/golint
 	golint .
 
-test:
+test: get
 	go test -v -cover . ./datadictionary
 
-_build_all:
+_build_all: get
 	go build -v ./...
 
-build_accept:
+build_accept: get
 	cd _test; go build -o echo_server
 
 build: _build_all build_accept

config/configuration.go

@@ -15,4 +15,5 @@ const (
 	ResetOnLogon            string = "ResetOnLogon"
 	HeartBtInt              string = "HeartBtInt"
 	FileLogPath             string = "FileLogPath"
+	FileStorePath           string = "FileStorePath"
 )

config/doc.go

@@ -118,5 +118,9 @@ Socket port for listening to incoming connections, Only used with for acceptors.
 FileLogPath
 
 Directory to store logs.	Value must be valid directory for storing files, application must have write access.
+
+FileStorePath
+
+Directory to store sequence number and message files.  Only used with FileStoreFactory.
 */
 package config

field_map.go

@@ -103,6 +103,24 @@ func (m FieldMap) GetField(tag Tag, parser FieldValueReader) MessageRejectError
 	return nil
 }
 
+// GetInt is a GetField wrapper for int fields
+func (m FieldMap) GetInt(tag Tag) (int, MessageRejectError) {
+	var val FIXInt
+	if err := m.GetField(tag, &val); err != nil {
+		return 0, err
+	}
+	return int(val), nil
+}
+
+// GetString is a GetField wrapper for string fields
+func (m FieldMap) GetString(tag Tag) (string, MessageRejectError) {
+	var val FIXString
+	if err := m.GetField(tag, &val); err != nil {
+		return "", err
+	}
+	return string(val), nil
+}
+
 func (m FieldMap) GetGroup(parser *RepeatingGroup) MessageRejectError {
 	tagValues, ok := m.tagLookup[parser.Tag]
 	if !ok {

file_log.go

@@ -2,11 +2,11 @@ package quickfix
 
 import (
 	"fmt"
-	"github.com/quickfixgo/quickfix/config"
 	"log"
 	"os"
 	"path"
-	"strings"
+
+	"github.com/quickfixgo/quickfix/config"
 )
 
 type fileLog struct {
@@ -96,10 +96,6 @@ func (f fileLogFactory) CreateSessionLog(sessionID SessionID) (Log, error) {
 		return nil, fmt.Errorf("logger not defined for %v", sessionID)
 	}
 
-	prefixParts := []string{sessionID.BeginString, sessionID.SenderCompID, sessionID.TargetCompID}
-	if len(sessionID.Qualifier) > 0 {
-		prefixParts = append(prefixParts, sessionID.Qualifier)
-	}
-
-	return newFileLog(strings.Join(prefixParts, "-"), logPath)
+	prefix := sessionIDFilenamePrefix(sessionID)
+	return newFileLog(prefix, logPath)
 }