fixed raw data struct so that encoding/json can prase into it

1 files changed, 10 insertions, 10 deletions

diff --git a/cleaner.go b/cleaner.go
index f7f697e..8d5985f 100644
--- a/cleaner.go
+++ b/cleaner.go
@@ -151,8 +151,8 @@ func clean(rDat []RawData, cfg *Config) (cDat []cleanedData, err error) {
 	// collect all ips so we can query for their ip blocks
 	ips := make(map[string]struct{})
 	for _, rd := range rDat {
-		ips[rd.IpSrc] = struct{}{}
-		ips[rd.IpDst] = struct{}{}
+		ips[rd.Ip_src] = struct{}{}
+		ips[rd.Ip_dst] = struct{}{}
 	}
 
 	var iplist []string
@@ -173,14 +173,14 @@ func clean(rDat []RawData, cfg *Config) (cDat []cleanedData, err error) {
 		}
 		cDat = append(cDat,
 			cleanedData{
-				ipbSrc:     pairs[rd.IpSrc],
-				ipbDst:     pairs[rd.IpDst],
-				asSrc:      rd.AsSrc,
-				asDst:      rd.AsDst,
-				portSrc:    rd.PortSrc,
-				portDst:    rd.PortDst,
-				occurences: 1,
-				volume:     rd.PktLenDist,
+				ipbSrc:     pairs[rd.Ip_src],
+				ipbDst:     pairs[rd.Ip_dst],
+				asSrc:      rd.As_src,
+				asDst:      rd.As_dst,
+				portSrc:    rd.Port_src,
+				portDst:    rd.Port_dst,
+				occurences: rd.Packets,
+				volume:     rd.Pkt_len_distrib,
 				time:       tim,
 			})
 	}