Corrects mongo pkg ref in test

quickfixgo · Nov 9, 2023 · d88cecc · d88cecc
1 parent f430d0a
commit d88cecc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/_test/test-server/main.go b/_test/test-server/main.go
@@ -16,6 +16,7 @@ import (
 	field "github.com/quickfixgo/quickfix/gen/field"
 	tag "github.com/quickfixgo/quickfix/gen/tag"
 	"github.com/quickfixgo/quickfix/store/file"
+	"github.com/quickfixgo/quickfix/store/mongo"
 )
 
 var router *quickfix.MessageRouter = quickfix.NewMessageRouter()
@@ -150,7 +151,7 @@ func main() {
 		appSettings.GlobalSettings().Set(config.MongoStoreReplicaSet, mongoReplicaSet)
 		appSettings.GlobalSettings().Set(config.DynamicSessions, "Y")
 
-		acceptor, err = quickfix.NewAcceptor(app, quickfix.NewMongoStoreFactory(appSettings), appSettings, fileLogFactory)
+		acceptor, err = quickfix.NewAcceptor(app, mongo.NewStoreFactory(appSettings), appSettings, fileLogFactory)
 	case "FILE":
 		fileStoreRootPath := path.Join(os.TempDir(), fmt.Sprintf("FileStoreTestSuite-%d", os.Getpid()))
 		fileStorePath := path.Join(fileStoreRootPath, fmt.Sprintf("%d", time.Now().UnixNano()))

diff --git a/store/file/filestore.go b/store/file/filestore.go
@@ -77,9 +77,7 @@ func (f fileStoreFactory) Create(sessionID quickfix.SessionID) (msgStore quickfi
 
 	dirname, err := sessionSettings.Setting(config.FileStorePath)
 	if err != nil {
-		if err != nil {
 			return nil, err
-		}
 	}
 	var fsync bool
 	if sessionSettings.HasSetting(config.FileStoreSync) {