benchmarks_test.go

package aicra_test

import (
	"context"
	"net/http"
	"net/http/httptest"
	"strings"
	"testing"

	"github.com/xdrm-io/aicra"
	"github.com/xdrm-io/aicra/validator"
)

const staticConfig = `[
	{
		"method": "GET",
		"path": "/users/123",
		"scope": [],
		"info": "info",
		"in": {},
		"out": {}
	}
]`
const staticOutConfig = `[
	{
		"method": "GET",
		"path": "/users/123",
		"scope": [],
		"info": "info",
		"in": {},
		"out": {
			"id": {"info":"info","name":"ID","type":"int"}
		}
	}
]`
const uriConfig = `[
	{
		"method": "GET",
		"path": "/users/{id}",
		"scope": [],
		"info": "info",
		"in": {
			"{id}": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	}
]`
const getConfig = `[
	{
		"method": "GET",
		"path": "/users",
		"scope": [],
		"info": "info",
		"in": {
			"GET@id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	}
]`
const formConfig = `[
	{
		"method": "GET",
		"path": "/users",
		"scope": [],
		"info": "info",
		"in": {
			"id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	}
]`
const staticMultiConfig = `[
	{
		"method": "GET",
		"path": "/users/123",
		"scope": [],
		"info": "info",
		"in": {},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/users/123",
		"scope": [],
		"info": "info",
		"in": {},
		"out": {}
	},
	{
		"method": "GET",
		"path": "/users/456",
		"scope": [],
		"info": "info",
		"in": {},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/users/456",
		"scope": [],
		"info": "info",
		"in": {},
		"out": {}
	}
]`
const uriMultiConfig = `[
	{
		"method": "GET",
		"path": "/users/{id}",
		"scope": [],
		"info": "info",
		"in": {
			"{id}": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/users/{id}",
		"scope": [],
		"info": "info",
		"in": {
			"{id}": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "GET",
		"path": "/articles/{id}",
		"scope": [],
		"info": "info",
		"in": {
			"{id}": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/articles/{id}",
		"scope": [],
		"info": "info",
		"in": {
			"{id}": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	}
]`
const getMultiConfig = `[
	{
		"method": "GET",
		"path": "/users",
		"scope": [],
		"info": "info",
		"in": {
			"GET@id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/users",
		"scope": [],
		"info": "info",
		"in": {
			"GET@id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "GET",
		"path": "/articles",
		"scope": [],
		"info": "info",
		"in": {
			"GET@id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/articles",
		"scope": [],
		"info": "info",
		"in": {
			"GET@id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	}
]`
const formMultiConfig = `[
	{
		"method": "GET",
		"path": "/users",
		"scope": [],
		"info": "info",
		"in": {
			"id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/users",
		"scope": [],
		"info": "info",
		"in": {
			"id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "GET",
		"path": "/articles",
		"scope": [],
		"info": "info",
		"in": {
			"id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	},
	{
		"method": "POST",
		"path": "/articles",
		"scope": [],
		"info": "info",
		"in": {
			"id": {"info":"info","name":"ID","type":"int"}
		},
		"out": {}
	}
]`

func noOpHandler(context.Context, struct{}) (*struct{}, error) {
	return nil, nil
}
func noOpIntHandler(context.Context, struct{ ID int }) (*struct{}, error) {
	return nil, nil
}
func outHandler(context.Context, struct{}) (*struct{ ID int }, error) {
	return &struct{ ID int }{ID: 123}, nil
}
func outIntHandler(context.Context, struct{ ID int }) (*struct{}, error) {
	return nil, nil
}

func Benchmark1StaticRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(staticConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}
	err = aicra.Bind(builder, "GET", "/users/123", noOpHandler)
	if err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users/123", nil)
	res := httptest.NewRecorder()
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}
func Benchmark1StaticOutRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Output("int", int(0)); err != nil {
		b.Fatalf("cannot set output type: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(staticOutConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}
	err = aicra.Bind(builder, "GET", "/users/123", outHandler)
	if err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users/123", nil)
	res := httptest.NewRecorder()
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}

func Benchmark1OverNStaticRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(staticMultiConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}

	routes := [][2]string{
		{"GET", "/users/123"},
		{"POST", "/users/123"},
		{"GET", "/users/456"},
		{"POST", "/users/456"},
	}
	for _, route := range routes {
		if err := aicra.Bind(builder, route[0], route[1], noOpHandler); err != nil {
			b.Fatalf("cannot bind: %s", err)
		}

	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users/123", nil)
	res := httptest.NewRecorder()
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}

func Benchmark1UriRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(uriConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}
	err = aicra.Bind(builder, "GET", "/users/{id}", noOpIntHandler)
	if err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users/123", nil)
	res := httptest.NewRecorder()
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}

func Benchmark1OverNUriRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(uriMultiConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}

	routes := [][2]string{
		{"GET", "/users/{id}"},
		{"POST", "/users/{id}"},
		{"GET", "/articles/{id}"},
		{"POST", "/articles/{id}"},
	}
	for _, route := range routes {
		if err := aicra.Bind(builder, route[0], route[1], noOpIntHandler); err != nil {
			b.Fatalf("cannot bind: %s", err)
		}

	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users/123", nil)
	res := httptest.NewRecorder()
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}

func Benchmark1GetRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(getConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}
	err = aicra.Bind(builder, "GET", "/users", noOpIntHandler)
	if err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users?id=123", nil)
	res := httptest.NewRecorder()
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}
func Benchmark1OverNGetRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(getMultiConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}

	routes := [][2]string{
		{"GET", "/users"},
		{"POST", "/users"},
		{"GET", "/articles"},
		{"POST", "/articles"},
	}
	for _, route := range routes {
		if err := aicra.Bind(builder, route[0], route[1], noOpIntHandler); err != nil {
			b.Fatalf("cannot bind: %s", err)
		}

	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users?id=123", nil)
	res := httptest.NewRecorder()
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}

func Benchmark1URLEncodedRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(formConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}
	err = aicra.Bind(builder, "GET", "/users", noOpIntHandler)
	if err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users", strings.NewReader("id=123"))
	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
	res := httptest.NewRecorder()

	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}
func Benchmark1OverNURLEncodedRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(formMultiConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}

	routes := [][2]string{
		{"GET", "/users"},
		{"POST", "/users"},
		{"GET", "/articles"},
		{"POST", "/articles"},
	}
	for _, route := range routes {
		if err := aicra.Bind(builder, route[0], route[1], noOpIntHandler); err != nil {
			b.Fatalf("cannot bind: %s", err)
		}

	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users", strings.NewReader("id=123"))
	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
	res := httptest.NewRecorder()

	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}

func Benchmark1JsonRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(formConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}
	err = aicra.Bind(builder, "GET", "/users", noOpIntHandler)
	if err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users", strings.NewReader(`{"id":123}`))
	req.Header.Add("Content-Type", "application/json")
	res := httptest.NewRecorder()

	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}
func Benchmark1OverNJsonRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(formMultiConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}

	routes := [][2]string{
		{"GET", "/users"},
		{"POST", "/users"},
		{"GET", "/articles"},
		{"POST", "/articles"},
	}
	for _, route := range routes {
		if err := aicra.Bind(builder, route[0], route[1], noOpIntHandler); err != nil {
			b.Fatalf("cannot bind: %s", err)
		}

	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users", strings.NewReader(`{"id":123}`))
	req.Header.Add("Content-Type", "application/json")
	res := httptest.NewRecorder()

	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}

func Benchmark1MultipartRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(formConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}
	err = aicra.Bind(builder, "GET", "/users", noOpIntHandler)
	if err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users", strings.NewReader(`--x
	Content-Disposition: form-data; name="id"

	123
	--x--`))
	req.Header.Add("Content-Type", "multipart/form-data; boundary=x")
	res := httptest.NewRecorder()

	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}
func Benchmark1OverNMultipartRouteMatch(b *testing.B) {
	builder := &aicra.Builder{}

	if err := builder.Input(validator.IntType{}); err != nil {
		b.Fatalf("cannot bind: %s", err)
	}
	err := builder.RespondWith(func(w http.ResponseWriter, data map[string]interface{}, err error) {})
	if err != nil {
		b.Fatalf("cannot set responder: %s", err)
	}
	err = builder.Setup(strings.NewReader(formMultiConfig))
	if err != nil {
		b.Fatalf("cannot setup: %s", err)
	}

	routes := [][2]string{
		{"GET", "/users"},
		{"POST", "/users"},
		{"GET", "/articles"},
		{"POST", "/articles"},
	}
	for _, route := range routes {
		if err := aicra.Bind(builder, route[0], route[1], noOpIntHandler); err != nil {
			b.Fatalf("cannot bind: %s", err)
		}

	}
	srv, err := builder.Build()
	if err != nil {
		b.Fatalf("cannot build: %s", err)
	}

	req, _ := http.NewRequest("GET", "/users", strings.NewReader(`--x
	Content-Disposition: form-data; name="id"

	123
	--x--`))
	req.Header.Add("Content-Type", "multipart/form-data; boundary=x")
	res := httptest.NewRecorder()

	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		srv.ServeHTTP(res, req)
	}
}