package send
import (
"brainbaking.com/go-jamming/app/mf"
"brainbaking.com/go-jamming/common"
"brainbaking.com/go-jamming/db"
"brainbaking.com/go-jamming/mocks"
"brainbaking.com/go-jamming/rest"
"fmt"
"github.com/stretchr/testify/assert"
"net/http"
"net/url"
"sync"
"testing"
)
var conf = &common.Config{
ConString: ":memory:",
AllowedWebmentionSources: []string{
"domain",
},
}
func TestSendSingleDoesNotSendIfRelPathNotFound(t *testing.T) {
var postedSomething bool
snder := Sender{
Conf: conf,
RestClient: &mocks.RestClientMock{
GetBodyFunc: mocks.RelPathGetBodyFunc("../../../mocks/"),
PostFormFunc: func(endpt string, formValues url.Values) error {
postedSomething = true
return nil
},
},
}
snder.SendSingle("brainbaking.com", "unknown-file")
assert.False(t, postedSomething)
}
func TestSendSingleSendsMentionsBasedOnRelativeDomain(t *testing.T) {
passedFormValues := url.Values{}
var endpoint string
snder := Sender{
Conf: conf,
RestClient: &mocks.RestClientMock{
GetBodyFunc: mocks.RelPathGetBodyFunc("../../../mocks/"),
PostFormFunc: func(endpt string, formValues url.Values) error {
passedFormValues = formValues
endpoint = endpt
return nil
},
},
}
snder.SendSingle("brainbaking.com", "single-send-test.html")
assert.Equal(t, "http://aaronpk.example/webmention-endpoint-body", endpoint)
assert.Equal(t, "https://brainbaking.com/single-send-test.html", passedFormValues.Get("source"))
assert.Equal(t, "https://brainbaking.com/link-discover-test-single.html", passedFormValues.Get("target"))
}
func TestSendMentionAsWebmention(t *testing.T) {
passedFormValues := url.Values{}
snder := Sender{
RestClient: &mocks.RestClientMock{
PostFormFunc: func(endpoint string, formValues url.Values) error {
passedFormValues = formValues
return nil
},
},
}
sendMentionAsWebmention(&snder, mf.Mention{
Source: "mysource",
Target: "mytarget",
}, "someendpoint")
assert.Equal(t, "mysource", passedFormValues.Get("source"))
assert.Equal(t, "mytarget", passedFormValues.Get("target"))
}
// Stress test for opening HTTP connections en masse.
// Works great for up to 1000 runs. 10k hits: "http: Accept error: accept tcp [::]:6666: accept: too many open files in system; retrying in 10ms"
// Crashed even GoLand and the open Spotify client...
// The rate limiter fixes this, and in reality, we never send out 10k links anyway.
func TestSendMentionIntegrationStressTest(t *testing.T) {
snder := Sender{
Conf: conf,
RestClient: &rest.HttpClient{},
}
runs := 100
responses := make(chan bool, runs)
mux := http.NewServeMux()
mux.HandleFunc("/pingback", func(writer http.ResponseWriter, request *http.Request) {
writer.WriteHeader(200)
writer.Write([]byte("pingbacked stuff."))
responses <- true
})
mux.HandleFunc("/target", func(writer http.ResponseWriter, request *http.Request) {
target := `
sup!
`
writer.WriteHeader(200)
writer.Write([]byte(target))
})
srv := &http.Server{Addr: ":6666", Handler: mux}
defer srv.Close()
go func() {
fmt.Println("Serving stub at 6666...")
srv.ListenAndServe()
fmt.Println("Stub stopped?")
}()
fmt.Println("Bootstrapping runs...")
for i := 0; i < runs; i++ {
snder.sendMention(mf.Mention{
Source: "http://localhost:6666/source",
Target: "http://localhost:6666/target",
})
}
fmt.Println("Asserting...")
for i := 0; i < runs; i++ {
pingbacked := <-responses
assert.True(t, pingbacked)
}
}
func TestSendIntegrationTestCanSendBothWebmentionsAndPingbacks(t *testing.T) {
posted := map[string]interface{}{}
var lock = sync.Mutex{}
snder := Sender{
Conf: conf,
Repo: db.NewMentionRepo(conf),
RestClient: &mocks.RestClientMock{
GetBodyFunc: mocks.RelPathGetBodyFunc("./../../../mocks/"),
PostFunc: func(url string, contentType string, body string) error {
lock.Lock()
defer lock.Unlock()
posted[url] = body
return nil
},
PostFormFunc: func(endpoint string, formValues url.Values) error {
lock.Lock()
defer lock.Unlock()
posted[endpoint] = formValues
return nil
},
},
}
snder.Send("brainbaking.com")
assert.Equal(t, 3, len(posted))
wmPost1 := posted["http://aaronpk.example/webmention-endpoint-header"].(url.Values)
assert.Equal(t, "https://brainbaking.com/notes/2021/03/16h17m07s14/", wmPost1.Get("source"))
assert.Equal(t, "https://brainbaking.com/link-discover-test-multiple.html", wmPost1.Get("target"))
wmPost2 := posted["http://aaronpk.example/pingback-endpoint-body"].(string)
expectedPost2 := `
pingback.ping
https://brainbaking.com/notes/2021/03/16h17m07s14/
https://brainbaking.com/pingback-discover-test-single.html
`
assert.Equal(t, expectedPost2, wmPost2)
wmPost3 := posted["http://aaronpk.example/webmention-endpoint-body"].(url.Values)
assert.Equal(t, "https://brainbaking.com/notes/2021/03/16h17m07s14/", wmPost3.Get("source"))
assert.Equal(t, "https://brainbaking.com/link-discover-test-single.html", wmPost3.Get("target"))
}