diff --git a/tap/tester/.gitignore b/tap/tester/.gitignore deleted file mode 100644 index 6028450ae..000000000 --- a/tap/tester/.gitignore +++ /dev/null @@ -1 +0,0 @@ -tester \ No newline at end of file diff --git a/tap/tester/README.md b/tap/tester/README.md deleted file mode 100644 index 3fc7e4c65..000000000 --- a/tap/tester/README.md +++ /dev/null @@ -1,12 +0,0 @@ - -This tester used to launch passive-tapper locally without Docker or Kuberenetes environment. - -Its good for testing purposes. - -# How to run - -From the `tap` folder run: -`./tester/launch.sh` - -The tester gets the same arguments the passive_tapper gets, run with `--help` to get a complete list of options. -`./tester/launch.sh --help` diff --git a/tap/tester/launch.sh b/tap/tester/launch.sh deleted file mode 100755 index 5abab4a93..000000000 --- a/tap/tester/launch.sh +++ /dev/null @@ -1,10 +0,0 @@ -#!/bin/bash - -set -e - -echo "Building extensions..." -pushd .. && ./devops/build_extensions.sh && popd - -go build -o tester tester/tester.go - -sudo ./tester/tester "$@" diff --git a/tap/tester/tester.go b/tap/tester/tester.go deleted file mode 100644 index 0ae1e9486..000000000 --- a/tap/tester/tester.go +++ /dev/null @@ -1,114 +0,0 @@ -package main - -import ( - "bufio" - "io/ioutil" - "os" - "path" - "plugin" - "sort" - "strings" - - "github.com/op/go-logging" - - "github.com/go-errors/errors" - "github.com/up9inc/mizu/shared/logger" - "github.com/up9inc/mizu/tap" - tapApi "github.com/up9inc/mizu/tap/api" -) - -func loadExtensions() ([]*tapApi.Extension, error) { - extensionsDir := "./extensions" - files, err := ioutil.ReadDir(extensionsDir) - - if err != nil { - return nil, errors.Wrap(err, 0) - } - - extensions := make([]*tapApi.Extension, 0) - for _, file := range files { - filename := file.Name() - - if !strings.HasSuffix(filename, ".so") { - continue - } - - logger.Log.Infof("Loading extension: %s", filename) - - extension := &tapApi.Extension{ - Path: path.Join(extensionsDir, filename), - } - - plug, err := plugin.Open(extension.Path) - - if err != nil { - return nil, errors.Wrap(err, 0) - } - - extension.Plug = plug - symDissector, err := plug.Lookup("Dissector") - - if err != nil { - return nil, errors.Wrap(err, 0) - } - - dissector, ok := symDissector.(tapApi.Dissector) - - if !ok { - return nil, errors.Errorf("Symbol Dissector type error: %v %T", file, symDissector) - } - - dissector.Register(extension) - extension.Dissector = dissector - extensions = append(extensions, extension) - } - - sort.Slice(extensions, func(i, j int) bool { - return extensions[i].Protocol.Priority < extensions[j].Protocol.Priority - }) - - for _, extension := range extensions { - logger.Log.Infof("Extension Properties: %+v", extension) - } - - return extensions, nil -} - -func internalRun() error { - logger.InitLoggerStderrOnly(logging.DEBUG) - - opts := tap.TapOpts{ - HostMode: false, - } - - outputItems := make(chan *tapApi.OutputChannelItem, 1000) - extenssions, err := loadExtensions() - - if err != nil { - return err - } - - tapOpts := tapApi.TrafficFilteringOptions{} - - tap.StartPassiveTapper(&opts, outputItems, extenssions, &tapOpts) - - logger.Log.Infof("Tapping, press enter to exit...") - reader := bufio.NewReader(os.Stdin) - reader.ReadLine() - return nil -} - -func main() { - err := internalRun() - - if err != nil { - switch err := err.(type) { - case *errors.Error: - logger.Log.Errorf("Error: %v", err.ErrorStack()) - default: - logger.Log.Errorf("Error: %v", err) - } - - os.Exit(1) - } -}