netshovel

commit

dd6e485

parent

ac599bb

author

Neale Pickett

date

2020-06-30 18:28:21 -0600 MDT

go fmt

 1@@ -2,13 +2,13 @@ package main
 2 
 3 import (
 4 	"fmt"
 5+	"github.com/dirtbags/netshovel"
 6+	"github.com/google/gopacket"
 7+	"github.com/google/gopacket/tcpassembly"
 8 	"io"
 9 	"log"
10 	"strings"
11 	"sync"
12-	"github.com/google/gopacket"
13-	"github.com/google/gopacket/tcpassembly"
14-	"github.com/dirtbags/netshovel"
15 )
16 
17 var wg sync.WaitGroup
18@@ -45,16 +45,15 @@ func (stream SimpleStream) Display(pkt SimplePacket) {
19 
20 	fmt.Fprintf(out, "Simple %v:%v → %v:%v\n",
21 		stream.Net.Src().String(), stream.Transport.Src().String(),
22-    stream.Net.Dst().String(), stream.Transport.Dst().String(),
23-  )
24-  out.WriteString(pkt.Describe())
25-  fmt.Println(out.String())
26+		stream.Net.Dst().String(), stream.Transport.Dst().String(),
27+	)
28+	out.WriteString(pkt.Describe())
29+	fmt.Println(out.String())
30 }
31 
32 func (stream SimpleStream) Decode(wg *sync.WaitGroup) {
33 	for {
34 		pkt := NewSimplePacket()
35-		
36 
37 		utterance, err := stream.Read(-1)
38 		if err != nil {
39@@ -63,7 +62,7 @@ func (stream SimpleStream) Decode(wg *sync.WaitGroup) {
40 			}
41 			break
42 		}
43-		
44+
45 		pkt.Payload = utterance.Data
46 		pkt.When = utterance.When
47 		stream.Display(pkt)