2021-10-31 23:18:30 +00:00
|
|
|
package caddy_test
|
|
|
|
|
|
|
|
import (
|
2023-08-16 15:52:29 +00:00
|
|
|
"bytes"
|
2022-06-03 15:18:07 +00:00
|
|
|
"fmt"
|
2021-10-31 23:18:30 +00:00
|
|
|
"net/http"
|
2023-08-16 15:52:29 +00:00
|
|
|
"strings"
|
2022-06-03 15:18:07 +00:00
|
|
|
"sync"
|
2021-10-31 23:18:30 +00:00
|
|
|
"testing"
|
|
|
|
|
2024-10-08 21:23:53 +00:00
|
|
|
"github.com/dunglas/frankenphp"
|
|
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
|
|
"github.com/prometheus/client_golang/prometheus/testutil"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
|
2021-10-31 23:18:30 +00:00
|
|
|
"github.com/caddyserver/caddy/v2/caddytest"
|
|
|
|
)
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
var testPort = "9080"
|
|
|
|
|
2021-10-31 23:18:30 +00:00
|
|
|
func TestPHP(t *testing.T) {
|
2022-06-03 15:18:07 +00:00
|
|
|
var wg sync.WaitGroup
|
2021-10-31 23:18:30 +00:00
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
2022-06-03 15:18:07 +00:00
|
|
|
{
|
2023-08-04 15:38:28 +00:00
|
|
|
skip_install_trust
|
2022-10-04 12:36:03 +00:00
|
|
|
admin localhost:2999
|
2024-09-26 07:53:37 +00:00
|
|
|
http_port `+testPort+`
|
2022-10-04 12:36:03 +00:00
|
|
|
https_port 9443
|
2023-08-04 15:38:28 +00:00
|
|
|
|
|
|
|
frankenphp
|
2022-06-03 15:18:07 +00:00
|
|
|
}
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
localhost:`+testPort+` {
|
2023-08-04 15:38:28 +00:00
|
|
|
route {
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
}
|
|
|
|
}
|
2021-10-31 23:18:30 +00:00
|
|
|
}
|
2022-06-03 15:18:07 +00:00
|
|
|
`, "caddyfile")
|
2021-10-31 23:18:30 +00:00
|
|
|
|
2022-06-03 15:18:07 +00:00
|
|
|
for i := 0; i < 100; i++ {
|
2023-08-04 15:38:28 +00:00
|
|
|
wg.Add(1)
|
|
|
|
|
2022-06-03 15:18:07 +00:00
|
|
|
go func(i int) {
|
2024-09-26 07:53:37 +00:00
|
|
|
tester.AssertGetResponse(fmt.Sprintf("http://localhost:"+testPort+"/index.php?i=%d", i), http.StatusOK, fmt.Sprintf("I am by birth a Genevese (%d)", i))
|
2022-06-03 15:18:07 +00:00
|
|
|
wg.Done()
|
|
|
|
}(i)
|
|
|
|
}
|
|
|
|
wg.Wait()
|
2021-10-31 23:18:30 +00:00
|
|
|
}
|
2023-08-16 15:52:29 +00:00
|
|
|
|
|
|
|
func TestLargeRequest(t *testing.T) {
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
2024-09-26 07:53:37 +00:00
|
|
|
http_port `+testPort+`
|
2023-08-16 15:52:29 +00:00
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp
|
|
|
|
}
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
localhost:`+testPort+` {
|
2023-08-16 15:52:29 +00:00
|
|
|
route {
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
|
|
|
tester.AssertPostResponseBody(
|
2024-09-26 07:53:37 +00:00
|
|
|
"http://localhost:"+testPort+"/large-request.php",
|
2023-08-16 15:52:29 +00:00
|
|
|
[]string{},
|
|
|
|
bytes.NewBufferString(strings.Repeat("f", 1_048_576)),
|
|
|
|
http.StatusOK,
|
|
|
|
"Request body size: 1048576 (unknown)",
|
|
|
|
)
|
|
|
|
}
|
2023-09-15 10:59:43 +00:00
|
|
|
|
|
|
|
func TestWorker(t *testing.T) {
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
2024-09-26 07:53:37 +00:00
|
|
|
http_port `+testPort+`
|
2023-09-15 10:59:43 +00:00
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp {
|
|
|
|
worker ../testdata/index.php 2
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
localhost:`+testPort+` {
|
2023-09-15 10:59:43 +00:00
|
|
|
route {
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
|
|
|
for i := 0; i < 100; i++ {
|
|
|
|
wg.Add(1)
|
|
|
|
|
|
|
|
go func(i int) {
|
2024-09-26 07:53:37 +00:00
|
|
|
tester.AssertGetResponse(fmt.Sprintf("http://localhost:"+testPort+"/index.php?i=%d", i), http.StatusOK, fmt.Sprintf("I am by birth a Genevese (%d)", i))
|
2023-09-15 10:59:43 +00:00
|
|
|
wg.Done()
|
|
|
|
}(i)
|
|
|
|
}
|
|
|
|
wg.Wait()
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestEnv(t *testing.T) {
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
2024-09-26 07:53:37 +00:00
|
|
|
http_port `+testPort+`
|
2023-09-15 10:59:43 +00:00
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp {
|
|
|
|
worker {
|
2024-06-23 07:42:06 +00:00
|
|
|
file ../testdata/worker-env.php
|
2023-09-15 10:59:43 +00:00
|
|
|
num 1
|
|
|
|
env FOO bar
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
localhost:`+testPort+` {
|
2023-09-15 10:59:43 +00:00
|
|
|
route {
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
env FOO baz
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort+"/worker-env.php", http.StatusOK, "bazbar")
|
2024-06-23 07:42:06 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func TestJsonEnv(t *testing.T) {
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
"admin": {
|
|
|
|
"listen": "localhost:2999"
|
|
|
|
},
|
|
|
|
"apps": {
|
|
|
|
"frankenphp": {
|
|
|
|
"workers": [
|
|
|
|
{
|
|
|
|
"env": {
|
|
|
|
"FOO": "bar"
|
|
|
|
},
|
|
|
|
"file_name": "../testdata/worker-env.php",
|
|
|
|
"num": 1
|
|
|
|
}
|
|
|
|
]
|
|
|
|
},
|
|
|
|
"http": {
|
2024-09-26 07:53:37 +00:00
|
|
|
"http_port": `+testPort+`,
|
2024-06-23 07:42:06 +00:00
|
|
|
"https_port": 9443,
|
|
|
|
"servers": {
|
|
|
|
"srv0": {
|
|
|
|
"listen": [
|
2024-09-26 07:53:37 +00:00
|
|
|
":`+testPort+`"
|
2024-06-23 07:42:06 +00:00
|
|
|
],
|
|
|
|
"routes": [
|
|
|
|
{
|
|
|
|
"handle": [
|
|
|
|
{
|
|
|
|
"handler": "subroute",
|
|
|
|
"routes": [
|
|
|
|
{
|
|
|
|
"handle": [
|
|
|
|
{
|
|
|
|
"handler": "subroute",
|
|
|
|
"routes": [
|
|
|
|
{
|
|
|
|
"handle": [
|
|
|
|
{
|
|
|
|
"env": {
|
|
|
|
"FOO": "baz"
|
|
|
|
},
|
|
|
|
"handler": "php",
|
|
|
|
"root": "../testdata"
|
|
|
|
}
|
|
|
|
]
|
|
|
|
}
|
|
|
|
]
|
|
|
|
}
|
|
|
|
]
|
|
|
|
}
|
|
|
|
]
|
|
|
|
}
|
|
|
|
],
|
|
|
|
"match": [
|
|
|
|
{
|
|
|
|
"host": [
|
|
|
|
"localhost"
|
|
|
|
]
|
|
|
|
}
|
|
|
|
],
|
|
|
|
"terminal": true
|
|
|
|
}
|
|
|
|
]
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
"pki": {
|
|
|
|
"certificate_authorities": {
|
|
|
|
"local": {
|
|
|
|
"install_trust": false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "json")
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort+"/worker-env.php", http.StatusOK, "bazbar")
|
2023-09-15 10:59:43 +00:00
|
|
|
}
|
2023-10-03 13:44:55 +00:00
|
|
|
|
2024-09-04 18:57:17 +00:00
|
|
|
func TestCustomCaddyVariablesInEnv(t *testing.T) {
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
2024-09-26 07:53:37 +00:00
|
|
|
http_port `+testPort+`
|
2024-09-04 18:57:17 +00:00
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp {
|
|
|
|
worker {
|
|
|
|
file ../testdata/worker-env.php
|
|
|
|
num 1
|
|
|
|
env FOO world
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
localhost:`+testPort+` {
|
2024-09-04 18:57:17 +00:00
|
|
|
route {
|
|
|
|
map 1 {my_customvar} {
|
|
|
|
default "hello "
|
|
|
|
}
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
env FOO {my_customvar}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort+"/worker-env.php", http.StatusOK, "hello world")
|
2024-09-04 18:57:17 +00:00
|
|
|
}
|
|
|
|
|
2023-10-03 13:44:55 +00:00
|
|
|
func TestPHPServerDirective(t *testing.T) {
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
2024-09-26 07:53:37 +00:00
|
|
|
http_port `+testPort+`
|
2023-10-03 13:44:55 +00:00
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp
|
|
|
|
}
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
localhost:`+testPort+` {
|
2023-10-03 13:44:55 +00:00
|
|
|
root * ../testdata
|
|
|
|
php_server
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort, http.StatusOK, "I am by birth a Genevese (i not set)")
|
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort+"/hello.txt", http.StatusOK, "Hello")
|
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort+"/not-found.txt", http.StatusOK, "I am by birth a Genevese (i not set)")
|
2023-10-03 13:44:55 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func TestPHPServerDirectiveDisableFileServer(t *testing.T) {
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
2024-09-26 07:53:37 +00:00
|
|
|
http_port `+testPort+`
|
2023-10-03 13:44:55 +00:00
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp
|
|
|
|
order php_server before respond
|
|
|
|
}
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
localhost:`+testPort+` {
|
2023-10-03 13:44:55 +00:00
|
|
|
root * ../testdata
|
|
|
|
php_server {
|
|
|
|
file_server off
|
|
|
|
}
|
|
|
|
respond "Not found" 404
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
2024-09-26 07:53:37 +00:00
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort, http.StatusOK, "I am by birth a Genevese (i not set)")
|
|
|
|
tester.AssertGetResponse("http://localhost:"+testPort+"/hello.txt", http.StatusNotFound, "Not found")
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestMetrics(t *testing.T) {
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
|
|
|
http_port `+testPort+`
|
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp
|
|
|
|
}
|
|
|
|
|
|
|
|
localhost:`+testPort+` {
|
|
|
|
route {
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
|
|
|
// Make some requests
|
|
|
|
for i := 0; i < 10; i++ {
|
|
|
|
wg.Add(1)
|
|
|
|
go func(i int) {
|
|
|
|
tester.AssertGetResponse(fmt.Sprintf("http://localhost:"+testPort+"/index.php?i=%d", i), http.StatusOK, fmt.Sprintf("I am by birth a Genevese (%d)", i))
|
|
|
|
wg.Done()
|
|
|
|
}(i)
|
|
|
|
}
|
|
|
|
wg.Wait()
|
|
|
|
|
|
|
|
// Fetch metrics
|
|
|
|
resp, err := http.Get("http://localhost:2999/metrics")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to fetch metrics: %v", err)
|
|
|
|
}
|
|
|
|
defer resp.Body.Close()
|
|
|
|
|
|
|
|
// Read and parse metrics
|
|
|
|
metrics := new(bytes.Buffer)
|
|
|
|
_, err = metrics.ReadFrom(resp.Body)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to read metrics: %v", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
cpus := fmt.Sprintf("%d", frankenphp.MaxThreads)
|
|
|
|
|
|
|
|
// Check metrics
|
|
|
|
expectedMetrics := `
|
|
|
|
# HELP frankenphp_total_threads Total number of PHP threads
|
|
|
|
# TYPE frankenphp_total_threads counter
|
|
|
|
frankenphp_total_threads ` + cpus + `
|
|
|
|
|
|
|
|
# HELP frankenphp_busy_threads Number of busy PHP threads
|
|
|
|
# TYPE frankenphp_busy_threads gauge
|
|
|
|
frankenphp_busy_threads 0
|
|
|
|
`
|
|
|
|
|
|
|
|
require.NoError(t, testutil.GatherAndCompare(prometheus.DefaultGatherer, strings.NewReader(expectedMetrics), "frankenphp_total_threads", "frankenphp_busy_threads"))
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestWorkerMetrics(t *testing.T) {
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
|
|
|
http_port `+testPort+`
|
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp {
|
|
|
|
worker ../testdata/index.php 2
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
localhost:`+testPort+` {
|
|
|
|
route {
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
|
|
|
// Make some requests
|
|
|
|
for i := 0; i < 10; i++ {
|
|
|
|
wg.Add(1)
|
|
|
|
go func(i int) {
|
|
|
|
tester.AssertGetResponse(fmt.Sprintf("http://localhost:"+testPort+"/index.php?i=%d", i), http.StatusOK, fmt.Sprintf("I am by birth a Genevese (%d)", i))
|
|
|
|
wg.Done()
|
|
|
|
}(i)
|
|
|
|
}
|
|
|
|
wg.Wait()
|
|
|
|
|
|
|
|
// Fetch metrics
|
|
|
|
resp, err := http.Get("http://localhost:2999/metrics")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to fetch metrics: %v", err)
|
|
|
|
}
|
|
|
|
defer resp.Body.Close()
|
|
|
|
|
|
|
|
// Read and parse metrics
|
|
|
|
metrics := new(bytes.Buffer)
|
|
|
|
_, err = metrics.ReadFrom(resp.Body)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to read metrics: %v", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
cpus := fmt.Sprintf("%d", frankenphp.MaxThreads)
|
|
|
|
|
|
|
|
// Check metrics
|
|
|
|
expectedMetrics := `
|
|
|
|
# HELP frankenphp_total_threads Total number of PHP threads
|
|
|
|
# TYPE frankenphp_total_threads counter
|
|
|
|
frankenphp_total_threads ` + cpus + `
|
|
|
|
|
|
|
|
# HELP frankenphp_busy_threads Number of busy PHP threads
|
|
|
|
# TYPE frankenphp_busy_threads gauge
|
|
|
|
frankenphp_busy_threads 2
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_busy_workers Number of busy PHP workers for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_busy_workers gauge
|
|
|
|
frankenphp_testdata_index_php_busy_workers 0
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_total_workers Total number of PHP workers for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_total_workers gauge
|
|
|
|
frankenphp_testdata_index_php_total_workers 2
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_worker_request_count
|
|
|
|
# TYPE frankenphp_testdata_index_php_worker_request_count counter
|
|
|
|
frankenphp_testdata_index_php_worker_request_count 10
|
2024-10-03 19:53:12 +00:00
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_ready_workers Running workers that have successfully called frankenphp_handle_request at least once
|
|
|
|
# TYPE frankenphp_testdata_index_php_ready_workers gauge
|
|
|
|
frankenphp_testdata_index_php_ready_workers 2
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_worker_crashes Number of PHP worker crashes for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_worker_crashes counter
|
|
|
|
frankenphp_testdata_index_php_worker_crashes 0
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_worker_restarts Number of PHP worker restarts for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_worker_restarts counter
|
|
|
|
frankenphp_testdata_index_php_worker_restarts 0
|
2024-09-26 07:53:37 +00:00
|
|
|
`
|
|
|
|
|
|
|
|
require.NoError(t,
|
|
|
|
testutil.GatherAndCompare(
|
|
|
|
prometheus.DefaultGatherer,
|
|
|
|
strings.NewReader(expectedMetrics),
|
|
|
|
"frankenphp_total_threads",
|
|
|
|
"frankenphp_busy_threads",
|
|
|
|
"frankenphp_testdata_index_php_busy_workers",
|
|
|
|
"frankenphp_testdata_index_php_total_workers",
|
|
|
|
"frankenphp_testdata_index_php_worker_request_count",
|
2024-10-03 19:53:12 +00:00
|
|
|
"frankenphp_testdata_index_php_worker_crashes",
|
|
|
|
"frankenphp_testdata_index_php_worker_restarts",
|
|
|
|
"frankenphp_testdata_index_php_ready_workers",
|
2024-09-26 07:53:37 +00:00
|
|
|
))
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestAutoWorkerConfig(t *testing.T) {
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
tester := caddytest.NewTester(t)
|
|
|
|
tester.InitServer(`
|
|
|
|
{
|
|
|
|
skip_install_trust
|
|
|
|
admin localhost:2999
|
|
|
|
http_port `+testPort+`
|
|
|
|
https_port 9443
|
|
|
|
|
|
|
|
frankenphp {
|
|
|
|
worker ../testdata/index.php
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
localhost:`+testPort+` {
|
|
|
|
route {
|
|
|
|
php {
|
|
|
|
root ../testdata
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
`, "caddyfile")
|
|
|
|
|
|
|
|
// Make some requests
|
|
|
|
for i := 0; i < 10; i++ {
|
|
|
|
wg.Add(1)
|
|
|
|
go func(i int) {
|
|
|
|
tester.AssertGetResponse(fmt.Sprintf("http://localhost:"+testPort+"/index.php?i=%d", i), http.StatusOK, fmt.Sprintf("I am by birth a Genevese (%d)", i))
|
|
|
|
wg.Done()
|
|
|
|
}(i)
|
|
|
|
}
|
|
|
|
wg.Wait()
|
|
|
|
|
|
|
|
// Fetch metrics
|
|
|
|
resp, err := http.Get("http://localhost:2999/metrics")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to fetch metrics: %v", err)
|
|
|
|
}
|
|
|
|
defer resp.Body.Close()
|
|
|
|
|
|
|
|
// Read and parse metrics
|
|
|
|
metrics := new(bytes.Buffer)
|
|
|
|
_, err = metrics.ReadFrom(resp.Body)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to read metrics: %v", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
cpus := fmt.Sprintf("%d", frankenphp.MaxThreads)
|
|
|
|
workers := fmt.Sprintf("%d", frankenphp.MaxThreads-1)
|
|
|
|
|
|
|
|
// Check metrics
|
|
|
|
expectedMetrics := `
|
|
|
|
# HELP frankenphp_total_threads Total number of PHP threads
|
|
|
|
# TYPE frankenphp_total_threads counter
|
|
|
|
frankenphp_total_threads ` + cpus + `
|
|
|
|
|
|
|
|
# HELP frankenphp_busy_threads Number of busy PHP threads
|
|
|
|
# TYPE frankenphp_busy_threads gauge
|
|
|
|
frankenphp_busy_threads ` + workers + `
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_busy_workers Number of busy PHP workers for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_busy_workers gauge
|
|
|
|
frankenphp_testdata_index_php_busy_workers 0
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_total_workers Total number of PHP workers for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_total_workers gauge
|
|
|
|
frankenphp_testdata_index_php_total_workers ` + workers + `
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_worker_request_count
|
|
|
|
# TYPE frankenphp_testdata_index_php_worker_request_count counter
|
|
|
|
frankenphp_testdata_index_php_worker_request_count 10
|
2024-10-03 19:53:12 +00:00
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_ready_workers Running workers that have successfully called frankenphp_handle_request at least once
|
|
|
|
# TYPE frankenphp_testdata_index_php_ready_workers gauge
|
|
|
|
frankenphp_testdata_index_php_ready_workers ` + workers + `
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_worker_crashes Number of PHP worker crashes for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_worker_crashes counter
|
|
|
|
frankenphp_testdata_index_php_worker_crashes 0
|
|
|
|
|
|
|
|
# HELP frankenphp_testdata_index_php_worker_restarts Number of PHP worker restarts for this worker
|
|
|
|
# TYPE frankenphp_testdata_index_php_worker_restarts counter
|
|
|
|
frankenphp_testdata_index_php_worker_restarts 0
|
2024-09-26 07:53:37 +00:00
|
|
|
`
|
|
|
|
|
|
|
|
require.NoError(t,
|
|
|
|
testutil.GatherAndCompare(
|
|
|
|
prometheus.DefaultGatherer,
|
|
|
|
strings.NewReader(expectedMetrics),
|
|
|
|
"frankenphp_total_threads",
|
|
|
|
"frankenphp_busy_threads",
|
|
|
|
"frankenphp_testdata_index_php_busy_workers",
|
|
|
|
"frankenphp_testdata_index_php_total_workers",
|
|
|
|
"frankenphp_testdata_index_php_worker_request_count",
|
2024-10-03 19:53:12 +00:00
|
|
|
"frankenphp_testdata_index_php_worker_crashes",
|
|
|
|
"frankenphp_testdata_index_php_worker_restarts",
|
|
|
|
"frankenphp_testdata_index_php_ready_workers",
|
2024-09-26 07:53:37 +00:00
|
|
|
))
|
2023-10-03 13:44:55 +00:00
|
|
|
}
|