aboutsummaryrefslogtreecommitdiff
path: root/plugin/dnstap/dnstapio/dnstap_encoder_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugin/dnstap/dnstapio/dnstap_encoder_test.go')
-rw-r--r--plugin/dnstap/dnstapio/dnstap_encoder_test.go53
1 files changed, 0 insertions, 53 deletions
diff --git a/plugin/dnstap/dnstapio/dnstap_encoder_test.go b/plugin/dnstap/dnstapio/dnstap_encoder_test.go
deleted file mode 100644
index a7fe23d2b..000000000
--- a/plugin/dnstap/dnstapio/dnstap_encoder_test.go
+++ /dev/null
@@ -1,53 +0,0 @@
-package dnstapio
-
-import (
- "bytes"
- "testing"
-
- tap "github.com/dnstap/golang-dnstap"
- fs "github.com/farsightsec/golang-framestream"
- "github.com/golang/protobuf/proto"
-)
-
-func dnstapMsg() *tap.Dnstap {
- t := tap.Dnstap_MESSAGE
- mt := tap.Message_CLIENT_RESPONSE
- msg := &tap.Message{Type: &mt}
- return &tap.Dnstap{Type: &t, Message: msg}
-}
-
-func TestEncoderCompatibility(t *testing.T) {
- opts := &fs.EncoderOptions{
- ContentType: []byte("protobuf:dnstap.DnstapTest"),
- Bidirectional: false,
- }
- msg := dnstapMsg()
-
- //framestream encoder
- fsW := new(bytes.Buffer)
- fsEnc, err := fs.NewEncoder(fsW, opts)
- if err != nil {
- t.Fatal(err)
- }
- data, err := proto.Marshal(msg)
- if err != nil {
- t.Fatal(err)
- }
- fsEnc.Write(data)
- fsEnc.Close()
-
- //dnstap encoder
- dnstapW := new(bytes.Buffer)
- dnstapEnc := newDnstapEncoder(opts)
- if err := dnstapEnc.resetWriter(dnstapW); err != nil {
- t.Fatal(err)
- }
- dnstapEnc.writeMsg(msg)
- dnstapEnc.flushBuffer()
- dnstapEnc.close()
-
- //compare results
- if !bytes.Equal(fsW.Bytes(), dnstapW.Bytes()) {
- t.Fatal("DnstapEncoder is not compatible with framestream Encoder")
- }
-}