2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 Nokia
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
9 // http://www.apache.org/licenses/LICENSE-2.0
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
23 "github.com/pkg/errors"
28 SendRmrMessage = "send"
29 ReceiveRmrMessage = "receive"
33 type JsonCommand struct {
44 WaitForRmrMessageType string
48 var Configuration = make(map[string]*JsonCommand)
49 // Rmr Message Id -> Command
50 var WaitedForRmrMessageType = make(map[int]*JsonCommand)
52 func JsonCommandDecoder(data []byte, processor func (*JsonCommand) error ) error {
53 dec := json.NewDecoder(bytes.NewReader(data))
55 if err := dec.Decode(&cmd); err != nil && err != io.EOF {
56 return errors.New(err.Error())
58 if err := processor (&cmd); err != nil {
64 func JsonCommandsDecoder(data []byte, processor func (*JsonCommand) error ) error {
65 dec := json.NewDecoder(bytes.NewReader(data))
67 var commands []JsonCommand
68 if err := dec.Decode(&commands); err == io.EOF {
70 } else if err != nil {
71 return errors.New(err.Error())
73 for i, cmd := range commands {
74 if err := processor(&cmd); err != nil {
75 return errors.New(fmt.Sprintf("processing error at #%d, %s",i,err))