Private
Public Access
rootandClaude Fable 5.1
88be6723b2
Handlers take (props : dval, request : dval) for COMPONENT and TASK and (request : dval) otherwise; every parameter is optional and keeps its name, and request is bound in every handler body. name : capture type fills an omitted argument from the caller variable of that name. Exported (dval) dval functions carry an implicit request capture. Request builtins capture request; redirect writes request.out. The runtime builds one request value per request, passes request and props handles to handlers, applies request.out once after the top-level handler, and drops the pending-props slot, handler frames, per-handler refresh, and current_request(). Core ABI 38, unit ABI 39. Legacy request type checks and the removed-API migration table are gone from the compiler. Documentation, generated routes, tests, and the project home follow; the home page loses the demo and starter. Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
124 lines
4.1 KiB
Bash
Executable File
124 lines
4.1 KiB
Bash
Executable File
#!/usr/bin/env bash
|
|
set -euo pipefail
|
|
cd "$(dirname "$0")/.."
|
|
|
|
test_name="component-resolution-ttl-test-$$"
|
|
site_directory="${BEARER_TEST_SITE_DIRECTORY:-site}"
|
|
worker_count="${BEARER_TEST_WORKER_COUNT:-4}"
|
|
if [[ -r /etc/bearer/settings.cfg ]]; then
|
|
if [[ -z "${BEARER_TEST_SITE_DIRECTORY:-}" ]]; then
|
|
configured_site_directory=$(awk -F= '/^[[:space:]]*SITE_DIRECTORY[[:space:]]*=/ {gsub(/^[[:space:]]+|[[:space:]]+$/, "", $2); print $2; exit}' /etc/bearer/settings.cfg)
|
|
site_directory="${configured_site_directory:-$site_directory}"
|
|
fi
|
|
if [[ -z "${BEARER_TEST_WORKER_COUNT:-}" ]]; then
|
|
configured_worker_count=$(awk -F= '/^[[:space:]]*WORKER_COUNT[[:space:]]*=/ {gsub(/^[[:space:]]+|[[:space:]]+$/, "", $2); print $2; exit}' /etc/bearer/settings.cfg)
|
|
worker_count="${configured_worker_count:-$worker_count}"
|
|
fi
|
|
fi
|
|
http_host="${BEARER_TEST_HTTP_HOST:-bearer.openfu.com}"
|
|
source_dir="$site_directory/$test_name"
|
|
bin_directory="${BIN_DIRECTORY:-}"
|
|
if [[ -z "$bin_directory" && -r /etc/bearer/settings.cfg ]]; then
|
|
bin_directory=$(awk -F= '/^[[:space:]]*BIN_DIRECTORY[[:space:]]*=/ {gsub(/^[[:space:]]+|[[:space:]]+$/, "", $2); print $2; exit}' /etc/bearer/settings.cfg)
|
|
fi
|
|
bin_directory="${bin_directory:-/tmp/bearer/work}"
|
|
cache_dir=""
|
|
|
|
cleanup() {
|
|
rm -rf "$source_dir"
|
|
if [[ -n "$cache_dir" ]]; then
|
|
rm -rf "$cache_dir"
|
|
fi
|
|
}
|
|
trap cleanup EXIT
|
|
mkdir -p "$source_dir"
|
|
cache_dir="$(scripts/unit_cache_directory "$bin_directory")$(realpath "$source_dir")"
|
|
|
|
cat >"$source_dir/parent.capy" <<'EOF'
|
|
function RENDER(request : dval) {
|
|
var perf := runtime_perf()
|
|
print("parent:", string(perf.worker_pid), ":", component("chosen"))
|
|
}
|
|
EOF
|
|
printf '%s\n' 'function COMPONENT(request : dval) { print("a") }' >"$source_dir/a.capy"
|
|
printf '%s\n' 'function COMPONENT(request : dval) { print("b") }' >"$source_dir/b.capy"
|
|
ln -s a.capy "$source_dir/chosen.capy"
|
|
|
|
declare -A seen
|
|
collect_workers() {
|
|
local method="$1"
|
|
local marker="$2"
|
|
local path="${3:-parent.capy}"
|
|
local deadline=$((SECONDS + 30))
|
|
seen=()
|
|
while (( SECONDS < deadline && ${#seen[@]} < worker_count )); do
|
|
local response status body pid
|
|
response=$(curl -sS --max-time 10 -X "$method" -H "Host: $http_host" -w $'\n%{http_code}' "http://127.0.0.1/$test_name/$path")
|
|
status=${response##*$'\n'}
|
|
body=${response%$'\n'*}
|
|
if [[ "$status" == "503" ]]; then
|
|
sleep 0.1
|
|
continue
|
|
fi
|
|
if [[ "$status" != "200" || "$body" != parent:*":$marker" ]]; then
|
|
echo "component resolution TTL probe failed: method=$method status=$status expected=$marker body=$body" >&2
|
|
exit 1
|
|
fi
|
|
pid=${body#parent:}
|
|
pid=${pid%%:*}
|
|
seen["$pid"]=1
|
|
done
|
|
if (( ${#seen[@]} != worker_count )); then
|
|
echo "component resolution TTL probe reached ${#seen[@]}/$worker_count workers" >&2
|
|
exit 1
|
|
fi
|
|
}
|
|
|
|
collect_missing_workers() {
|
|
local deadline=$((SECONDS + 30))
|
|
seen=()
|
|
while (( SECONDS < deadline && ${#seen[@]} < worker_count )); do
|
|
local response status body pid
|
|
response=$(curl -sS --max-time 10 -H "Host: $http_host" -w $'\n%{http_code}' "http://127.0.0.1/$test_name/missing.capy")
|
|
status=${response##*$'\n'}
|
|
body=${response%$'\n'*}
|
|
if [[ "$status" == "503" ]]; then
|
|
sleep 0.1
|
|
continue
|
|
fi
|
|
if [[ "$status" != "500" || "$body" != parent:* ]]; then
|
|
echo "missing component TTL probe failed: status=$status body=$body" >&2
|
|
exit 1
|
|
fi
|
|
pid=${body#parent:}
|
|
pid=${pid%%:*}
|
|
seen["$pid"]=1
|
|
done
|
|
if (( ${#seen[@]} != worker_count )); then
|
|
echo "missing component TTL probe reached ${#seen[@]}/$worker_count workers" >&2
|
|
exit 1
|
|
fi
|
|
}
|
|
|
|
collect_workers GET a
|
|
sleep 10.2
|
|
collect_workers GET a
|
|
ln -sfn b.capy "$source_dir/chosen.capy"
|
|
# The site watch invalidates cached resolution on rename. TTL applies without inotify.
|
|
collect_workers GET b
|
|
collect_workers POST b
|
|
sleep 10.2
|
|
collect_workers GET b
|
|
|
|
cat >"$source_dir/missing.capy" <<'EOF'
|
|
function RENDER(request : dval) {
|
|
var perf := runtime_perf()
|
|
print("parent:", string(perf.worker_pid), ":", component("later"))
|
|
}
|
|
EOF
|
|
collect_missing_workers
|
|
printf '%s\n' 'function COMPONENT(request : dval) { print("created") }' >"$source_dir/later.capy"
|
|
collect_workers GET created missing.capy
|
|
|
|
echo "component resolution TTL passed"
|