package svc // import "github.com/getwtxt/getwtxt/svc" import ( "net" "reflect" "strings" "testing" "github.com/getwtxt/registry" ) func Test_parseQueryOut(t *testing.T) { initTestConf() urls := "https://gbmor.dev/twtxt.txt" nick := "gbmor" out, _, err := registry.GetTwtxt(urls) if err != nil { t.Errorf("Couldn't set up test: %v\n", err) } statusmap, err := registry.ParseUserTwtxt(out, nick, urls) if err != nil { t.Errorf("Couldn't set up test: %v\n", err) } twtxtCache.AddUser(nick, urls, "", net.ParseIP("127.0.0.1"), statusmap) t.Run("Parsing Status Query", func(t *testing.T) { data, err := twtxtCache.QueryAllStatuses() if err != nil { t.Errorf("%v\n", err) } out := parseQueryOut(data) conv := strings.Split(string(out), "\n") if !reflect.DeepEqual(data, conv) { t.Errorf("Pre- and Post- parseQueryOut data are inequal:\n%#v\n%#v\n", data, conv) } }) } func Benchmark_parseQueryOut(b *testing.B) { initTestConf() urls := "https://gbmor.dev/twtxt.txt" nick := "gbmor" out, _, err := registry.GetTwtxt(urls) if err != nil { b.Errorf("Couldn't set up test: %v\n", err) } statusmap, err := registry.ParseUserTwtxt(out, nick, urls) if err != nil { b.Errorf("Couldn't set up test: %v\n", err) } twtxtCache.AddUser(nick, urls, "", net.ParseIP("127.0.0.1"), statusmap) data, err := twtxtCache.QueryAllStatuses() if err != nil { b.Errorf("%v\n", err) } b.ResetTimer() for i := 0; i < b.N; i++ { parseQueryOut(data) } } func Test_compositeStatusQuery(t *testing.T) { initTestConf() statuses, _, err := registry.GetTwtxt("https://gbmor.dev/twtxt.txt") if err != nil { t.Errorf("%v\n", err) } parsed, err := registry.ParseUserTwtxt(statuses, "gbmor", "https://gbmor.dev/twtxt.txt") if err != nil { t.Errorf("%v\n", err) } err = twtxtCache.AddUser("gbmor", "https://gbmor.dev/twtxt.txt", "1", net.ParseIP("127.0.0.1"), parsed) if err != nil { t.Errorf("%v\n", err) } t.Run("Composite Query Test", func(t *testing.T) { out1, err := twtxtCache.QueryInStatus("sqlite") if err != nil { t.Errorf("%v\n", err) } out2, err := twtxtCache.QueryInStatus("Sqlite") if err != nil { t.Errorf("%v\n", err) } out3, err := twtxtCache.QueryInStatus("SQLITE") if err != nil { t.Errorf("%v\n", err) } outro := make([]string, 0) outro = append(outro, out1...) outro = append(outro, out2...) outro = append(outro, out3...) out := dedupe(outro) data := compositeStatusQuery("sqlite", nil) if !reflect.DeepEqual(out, data) { t.Errorf("Returning different data.\nManual: %v\nCompositeQuery: %v\n", out, data) } }) } func Benchmark_compositeStatusQuery(b *testing.B) { initTestConf() statuses, _, _ := registry.GetTwtxt("https://gbmor.dev/twtxt.txt") parsed, _ := registry.ParseUserTwtxt(statuses, "gbmor", "https://gbmor.dev/twtxt.txt") _ = twtxtCache.AddUser("gbmor", "https://gbmor.dev/twtxt.txt", "1", net.ParseIP("127.0.0.1"), parsed) b.ResetTimer() for i := 0; i < b.N; i++ { compositeStatusQuery("sqlite", nil) } }