Merge pull request #6 from longbridgeapp/feat/nust-store

[CORE-0000] support db store

Author: level2player

nuts_store.go

@@ -24,13 +24,19 @@ func NewNutsDbStoreFactory(settings *Settings, db *nutsdb.DB) MessageStoreFactor
 }
 
 func (f nutsDbStoreFactory) Create(sessionID SessionID) (msgStore MessageStore, err error) {
-	_, ok := f.settings.SessionSettings()[sessionID]
+	sessionSettings, ok := f.settings.SessionSettings()[sessionID]
 	if !ok {
 		return nil, errors.Errorf("unknown session: %v", sessionID)
 	}
+	bucket, err := sessionSettings.Setting("Bucket")
+	if err != nil {
+		return nil, err
+	}
+
 	store := &nutsDbStore{
-		db:    f.db,
-		cache: &memoryStore{},
+		db:     f.db,
+		cache:  &memoryStore{},
+		bucket: bucket,
 	}
 	if err = store.cache.Reset(); err != nil {
 		err = errors.Wrap(err, "cache reset")

nuts_store_test.go

@@ -19,6 +19,7 @@ func TestSetup(t *testing.T) {
 TimeStampPrecision=MICROS
 
 [SESSION]
+Bucket=lb_hk
 BeginString=%s
 SenderCompID=%s
 TargetCompID=%s`, sessionID.BeginString, sessionID.SenderCompID, sessionID.TargetCompID)))