MetzNet
/
graphvent
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added PolicyMap

graph-rework-2
noah metz 2023-07-24 18:04:16 -06:00
parent 3fa550ab29
commit cf35d8a86d
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
node.go
Unescape Escape View File

@ -70,9 +70,9 @@ type Node interface {
} }
type SimpleNode struct { type SimpleNode struct {
id NodeID Id NodeID
state_mutex sync.RWMutex state_mutex sync.RWMutex
policies map[NodeID]Policy PolicyMap map[NodeID]Policy
} }
func (node *SimpleNode) NodeHandle() *SimpleNode { func (node *SimpleNode) NodeHandle() *SimpleNode {
@ -81,8 +81,8 @@ func (node *SimpleNode) NodeHandle() *SimpleNode {
func NewSimpleNode(id NodeID) SimpleNode { func NewSimpleNode(id NodeID) SimpleNode {
return SimpleNode{ return SimpleNode{
id: id, Id: id,
policies: map[NodeID]Policy{}, PolicyMap: map[NodeID]Policy{},
} }
} }
@ -91,12 +91,12 @@ type SimpleNodeJSON struct {
} }
func (node *SimpleNode) Process(context *StateContext, signal GraphSignal) error { func (node *SimpleNode) Process(context *StateContext, signal GraphSignal) error {
context.Graph.Log.Logf("signal", "SIMPLE_NODE_SIGNAL: %s - %s", node.id, signal) context.Graph.Log.Logf("signal", "SIMPLE_NODE_SIGNAL: %s - %s", node.Id, signal)
return nil return nil
} }
func (node *SimpleNode) ID() NodeID { func (node *SimpleNode) ID() NodeID {
return node.id return node.Id
} }
func (node *SimpleNode) Type() NodeType { func (node *SimpleNode) Type() NodeType {
@ -125,9 +125,9 @@ func (node *SimpleNode) UnlockState(write bool) {
} }
func NewSimpleNodeJSON(node *SimpleNode) SimpleNodeJSON { func NewSimpleNodeJSON(node *SimpleNode) SimpleNodeJSON {
policy_ids := make([]string, len(node.policies)) policy_ids := make([]string, len(node.PolicyMap))
i := 0 i := 0
for id, _ := range(node.policies) { for id, _ := range(node.PolicyMap) {
policy_ids[i] = id.String() policy_ids[i] = id.String()
i += 1 i += 1
} }
@ -153,7 +153,7 @@ func RestoreSimpleNode(ctx *Context, node *SimpleNode, j SimpleNodeJSON, nodes N
if ok == false { if ok == false {
return fmt.Errorf("%s is not a Policy", policy_id) return fmt.Errorf("%s is not a Policy", policy_id)
} }
node.policies[policy_id] = policy node.PolicyMap[policy_id] = policy
} }
return nil return nil
@ -178,9 +178,9 @@ func LoadSimpleNode(ctx *Context, id NodeID, data []byte, nodes NodeMap)(Node, e
} }
func (node *SimpleNode) Policies() []Policy { func (node *SimpleNode) Policies() []Policy {
ret := make([]Policy, len(node.policies)) ret := make([]Policy, len(node.PolicyMap))
i := 0 i := 0
for _, policy := range(node.policies) { for _, policy := range(node.PolicyMap) {
ret[i] = policy ret[i] = policy
i += 1 i += 1
} }
@ -227,7 +227,7 @@ func AttachPolicies(ctx *Context, node Node, policies ...Policy) error {
context := NewWriteContext(ctx) context := NewWriteContext(ctx)
return UpdateStates(context, node, NewLockInfo(node, []string{"policies"}), func(context *StateContext) error { return UpdateStates(context, node, NewLockInfo(node, []string{"policies"}), func(context *StateContext) error {
for _, policy := range(policies) { for _, policy := range(policies) {
node.NodeHandle().policies[policy.ID()] = policy node.NodeHandle().PolicyMap[policy.ID()] = policy
} }
return nil return nil
}) })