| Koren Lev | 19ca78f | 2018-11-21 18:46:54 +0200 | [diff] [blame^] | 1 | package main |
| 2 | |
| 3 | import ( |
| 4 | "bytes" |
| 5 | "encoding/json" |
| 6 | "fmt" |
| 7 | "git.fd.io/govpp.git/examples/bin_api/vpe" |
| 8 | ) |
| 9 | |
| 10 | type jsonVppDetails struct { |
| 11 | Program string `json:"program"` |
| 12 | Version string `json:"version"` |
| 13 | BuildDate string `json:"build_date"` |
| 14 | BuildDirectory string `json:"build_directory"` |
| 15 | } |
| 16 | |
| 17 | type jsonVppInterface struct { |
| 18 | Index uint32 `json:"if_index"` |
| 19 | Name string `json:"if_name"` |
| 20 | Tag string `json:"if_tag"` |
| 21 | MacAddress string `json:"if_mac"` |
| 22 | AdminState uint8 `json:"if_admin_state"` |
| 23 | LinkState uint8 `json:"if_link_state"` |
| 24 | LinkMTU uint16 `json:"if_link_mtu"` |
| 25 | SubDot1ad uint8 `json:"if_sub_dot1ad"` |
| 26 | SubID uint32 `json:"if_sub_id"` |
| 27 | |
| 28 | TxBytes uint64 `json:"if_tx_bytes"` |
| 29 | TxPackets uint64 `json:"if_tx_packets"` |
| 30 | TxErrors uint64 `json:"if_tx_errors"` |
| 31 | RxBytes uint64 `json:"if_rx_bytes"` |
| 32 | RxPackets uint64 `json:"if_rx_packets"` |
| 33 | RxErrors uint64 `json:"if_rx_errors"` |
| 34 | Drops uint64 `json:"if_drops"` |
| 35 | Punts uint64 `json:"if_punts"` |
| 36 | } |
| 37 | |
| 38 | type jsonVppPayload struct { |
| 39 | *jsonVppDetails `json:"vpp_details"` |
| 40 | Interfaces []*jsonVppInterface `json:"interfaces"` |
| 41 | } |
| 42 | |
| 43 | func bytesToString(b []byte) string { |
| 44 | return string(bytes.Split(b, []byte{0})[0]) |
| 45 | } |
| 46 | |
| 47 | func toJSONVppDetails(svReply *vpe.ShowVersionReply) *jsonVppDetails { |
| 48 | return &jsonVppDetails{ |
| 49 | Program: bytesToString(svReply.Program), |
| 50 | Version: bytesToString(svReply.Version), |
| 51 | BuildDate: bytesToString(svReply.BuildDate), |
| 52 | BuildDirectory: bytesToString(svReply.BuildDirectory), |
| 53 | } |
| 54 | } |
| 55 | |
| 56 | func toJSONVppInterface(vppIf *vppInterface) *jsonVppInterface { |
| 57 | return &jsonVppInterface{ |
| 58 | Index: vppIf.SwIfIndex, |
| 59 | Name: bytesToString(vppIf.InterfaceName), |
| 60 | Tag: bytesToString(vppIf.Tag), |
| 61 | MacAddress: parseMacAddress(vppIf.L2Address, vppIf.L2AddressLength), |
| 62 | AdminState: vppIf.AdminUpDown, |
| 63 | LinkState: vppIf.LinkUpDown, |
| 64 | LinkMTU: vppIf.LinkMtu, |
| 65 | SubDot1ad: vppIf.SubDot1ad, |
| 66 | SubID: vppIf.SubID, |
| 67 | TxBytes: vppIf.Stats.TxBytes, |
| 68 | TxPackets: vppIf.Stats.TxPackets, |
| 69 | TxErrors: vppIf.Stats.TxErrors, |
| 70 | RxBytes: vppIf.Stats.RxBytes, |
| 71 | RxPackets: vppIf.Stats.RxPackets, |
| 72 | RxErrors: vppIf.Stats.RxErrors, |
| 73 | Drops: vppIf.Stats.Drops, |
| 74 | Punts: vppIf.Stats.Punts, |
| 75 | } |
| 76 | } |
| 77 | |
| 78 | func toJSONVppPayload(svReply *vpe.ShowVersionReply, vppIfs []*vppInterface) *jsonVppPayload { |
| 79 | p := &jsonVppPayload{jsonVppDetails: toJSONVppDetails(svReply), Interfaces: make([]*jsonVppInterface, len(vppIfs))} |
| 80 | for index, vppIf := range vppIfs { |
| 81 | p.Interfaces[index] = toJSONVppInterface(vppIf) |
| 82 | } |
| 83 | return p |
| 84 | } |
| 85 | |
| 86 | func dumpToJSONString(v *vppConnector) (string, error) { |
| 87 | payload := toJSONVppPayload(&v.VppDetails, v.Interfaces) |
| 88 | jsonBytes, err := json.Marshal(payload) |
| 89 | if err != nil { |
| 90 | return "", fmt.Errorf("failed to dump to json: %v", err) |
| 91 | } |
| 92 | return string(jsonBytes), nil |
| 93 | } |