WIP: protobuf state

examples/payment/cc_enc_context_with_mapping.go

@@ -6,6 +6,7 @@ import (
 	"github.com/s7techlab/cckit/extensions/encryption"
 	"github.com/s7techlab/cckit/router"
 	p "github.com/s7techlab/cckit/router/param"
+	"github.com/s7techlab/cckit/state"
 	m "github.com/s7techlab/cckit/state/mapping"
 )
 
@@ -45,14 +46,16 @@ func invokePaymentCreateWithDefaultContext(c router.Context) (interface{}, error
 
 func queryPaymentsWithDefaultContext(c router.Context) (interface{}, error) {
 
-	paymentType := c.ParamString(`type`)
-	namespace, err := c.State().(m.MappedState).MappingNamespace(&schema.Payment{})
-	if err != nil {
-		return nil, err
-	}
+	//paymentType := c.ParamString(`type`)
+	//namespace, err := c.State().(m.MappedState).MappingNamespace(&schema.Payment{})
+	//if err != nil {
+	//	return nil, err
+	//}
+	//return c.State().List(namespace.Append(state.Key { paymentType }), &schema.Payment{})
 
-	// State use encryption setting from context
-	return c.State().List(namespace.Add(paymentType), &schema.Payment{})
+	// some sugar to previous
+
+	return c.State().(m.MappedState).ListWith(&schema.Payment{}, state.Key{c.ParamString(`type`)})
 }
 
 func queryPaymentWithDefaultContext(c router.Context) (interface{}, error) {

examples/payment/mapping.go

@@ -9,5 +9,4 @@ var (
 	// State mappings
 	StateMappings = m.StateMappings{}.
 		Add(&schema.Payment{}, m.StatePKeyFromAttrs(`Type`, `Id`)) //key will be <'Payment',Type, Id>
-
 )

state/mapping/state.go

@@ -9,7 +9,10 @@ import (
 type (
 	MappedState interface {
 		state.State
+		// MappingNamespace returns mapping for schema
 		MappingNamespace(schema interface{}) (state.Key, error)
+		// ListWith extends schema namespace with key
+		ListWith(schema interface{}, key state.Key) (result []interface{}, err error)
 	}
 
 	StateImpl struct {
@@ -93,6 +96,14 @@ func (s *StateImpl) List(namespace interface{}, target ...interface{}) (result [
 	return s.state.List(namespace, target...)
 }
 
+func (s *StateImpl) ListWith(schema interface{}, key state.Key) (result []interface{}, err error) {
+	namespace, err := s.MappingNamespace(schema)
+	if err != nil {
+		return nil, err
+	}
+	return s.state.List(namespace.Append(key), schema)
+}
+
 func (s *StateImpl) Delete(entry interface{}) (err error) {
 	if entry, err = s.mapIfMappingExists(entry); err != nil {
 		return err

state/state.go

@@ -63,8 +63,8 @@ type State interface {
 	UseStatePutTransformer(ToBytesTransformer) State
 }
 
-func (k Key) Add(part string) Key {
-	return append(k, part)
+func (k Key) Append(key Key) Key {
+	return append(k, key...)
 }
 
 type StateImpl struct {