fixing replaytplesforrule

rete/internal/mem/mhandleservice.go

@@ -101,3 +101,11 @@ func (hc *handleServiceImpl) GetHandleWithTuple(nw types.Network, tuple model.Tu
 	}
 	return h
 }
+
+func (hc *handleServiceImpl) GetAllHandles() map[string]types.ReteHandle {
+	all := make(map[string]types.ReteHandle)
+	for k, v := range hc.allHandles {
+		all[k] = v
+	}
+	return all
+}

rete/internal/redis/redis_test.go

@@ -146,10 +146,6 @@ func (n *testNetwork) GetTupleStore() model.TupleStore {
 	return nil
 }
 
-func (n *testNetwork) GetAssertedTupleByStringKey(key string) model.Tuple {
-	return nil
-}
-
 func (n *testNetwork) ReplayTuplesForRule(ruleName string, rs model.RuleSession) (err error) {
 	return nil
 }

rete/internal/redis/rhandleservice.go

@@ -210,3 +210,7 @@ func (hc *handleServiceImpl) GetHandleWithTuple(nw types.Network, tuple model.Tu
 	h := newReteHandleImpl(nw, hc.RedisHdl, tuple, key, status, id)
 	return h
 }
+
+func (hc *handleServiceImpl) GetAllHandles() map[string]types.ReteHandle {
+	return nil
+}

rete/internal/types/types.go

@@ -20,7 +20,6 @@ type Network interface {
 	GetHandleService() HandleService
 	GetJtRefService() JtRefsService
 	GetTupleStore() model.TupleStore
-	GetAssertedTupleByStringKey(key string) model.Tuple
 }
 
 type ConflictRes interface {
@@ -114,6 +113,7 @@ type HandleService interface {
 	GetHandleWithTuple(nw Network, tuple model.Tuple) ReteHandle
 	GetOrCreateLockedHandle(nw Network, tuple model.Tuple) (ReteHandle, bool)
 	GetLockedHandle(nw Network, tuple model.Tuple) (handle ReteHandle, locked, dne bool)
+	GetAllHandles() map[string]ReteHandle
 }
 
 type IdGen interface {

rete/network.go

@@ -173,11 +173,6 @@ func (nw *reteNetworkImpl) AddRule(rule model.Rule) (err error) {
 	return nil
 }
 
-func (nw *reteNetworkImpl) ReplayTuplesForRule(ruleName string, rs model.RuleSession) error {
-	// TO DO
-	return nil
-}
-
 func (nw *reteNetworkImpl) setClassNodeAndLinkJoinTables(nodesOfRule *list.List,
 	classNodeLinksOfRule *list.List) {
 }
@@ -219,8 +214,6 @@ func (nw *reteNetworkImpl) RemoveRule(ruleName string) model.Rule {
 			}
 		}
 	}
-	rstr := nw.String()
-	fmt.Printf(rstr)
 	return rule
 }
 
@@ -875,7 +868,17 @@ func (nw *reteNetworkImpl) GetPrefix() string {
 	return nw.prefix
 }
 
-func (nw *reteNetworkImpl) GetAssertedTupleByStringKey(key string) model.Tuple {
-	// TO DO
+func (nw *reteNetworkImpl) ReplayTuplesForRule(ruleName string, rs model.RuleSession) error {
+	if rule, exists := nw.allRules[ruleName]; !exists {
+		return fmt.Errorf("Rule not found [%s]", ruleName)
+	} else {
+		for _, h := range nw.handleService.GetAllHandles() {
+			tt := h.GetTuple()
+			if ContainedByFirst(rule.GetIdentifiers(), []model.TupleType{tt.GetTupleType()}) {
+				//assert it but only for this rule.
+				nw.assert(nil, rs, h.GetTuple(), nil, common.ADD, ruleName)
+			}
+		}
+	}
 	return nil
 }