155 lines
3.0 KiB
CUE
155 lines
3.0 KiB
CUE
package http
|
|
|
|
import (
|
|
"encoding/json"
|
|
"strconv"
|
|
|
|
"alpha.dagger.io/alpine"
|
|
"alpha.dagger.io/dagger"
|
|
"alpha.dagger.io/dagger/op"
|
|
"alpha.dagger.io/os"
|
|
)
|
|
|
|
#Get: #Do & {method: "GET"}
|
|
#Post: #Do & {method: "POST"}
|
|
#Put: #Do & {method: "PUT"}
|
|
#Delete: #Do & {method: "DELETE"}
|
|
#Do: {
|
|
url: string
|
|
method: "GET" | "POST" | "PUT" | "DELETE" | "PATH" | "HEAD"
|
|
|
|
request: {
|
|
body: string | *""
|
|
header: [string]: string | [...string]
|
|
token: dagger.#Secret | *null
|
|
}
|
|
|
|
ctr: os.#Container & {
|
|
image: alpine.#Image & {
|
|
package: curl: true
|
|
package: bash: "=5.1.0-r0"
|
|
package: jq: "~=1.6"
|
|
}
|
|
shell: path: "/bin/bash"
|
|
always: true
|
|
|
|
env: {
|
|
METHOD: method
|
|
HEADERS: json.Marshal(request.header)
|
|
BODY: request.body
|
|
URL: url
|
|
}
|
|
if request.token != null {
|
|
secret: "/token": request.token
|
|
}
|
|
command: #"""
|
|
curlArgs=(
|
|
"$URL"
|
|
-L --fail --silent --show-error
|
|
--write-out "%{http_code}"
|
|
-X "$METHOD"
|
|
-o /response
|
|
)
|
|
|
|
[ -n "$BODY" ] && curlArgs+=("-d" "'$BODY'")
|
|
|
|
headers="$(echo $HEADERS | jq -r 'to_entries | map(.key + ": " + (.value | tostring) + "\n") | add')"
|
|
while read h; do
|
|
curlArgs+=("-H" "'$h'")
|
|
done <<< "$headers"
|
|
if [ -e /token ]; then
|
|
curlArgs+=("-H" "Authorization: bearer $(cat /token)")
|
|
fi
|
|
|
|
curl "${curlArgs[@]}" > /status
|
|
"""#
|
|
}
|
|
|
|
statusCode: {
|
|
os.#File & {
|
|
from: ctr
|
|
path: "/status"
|
|
}
|
|
}.contents @dagger(output)
|
|
|
|
body: {
|
|
os.#File & {
|
|
from: ctr
|
|
path: "/response"
|
|
}
|
|
}.contents @dagger(output)
|
|
|
|
// Force os.#File exec before Atoi
|
|
response: {
|
|
"body": body
|
|
"statusCode": strconv.Atoi(statusCode)
|
|
}
|
|
}
|
|
|
|
// URL listener
|
|
// Creates a dependency on URL
|
|
#Wait: {
|
|
// URL to listen
|
|
url: string
|
|
|
|
// Waiting time between checks (sec.)
|
|
interval: int | *30
|
|
|
|
// Max amount of retries
|
|
retries: int | *3
|
|
|
|
// Max initialization time (sec.)
|
|
startPeriod: int | *0
|
|
|
|
// Time until timeout (sec.)
|
|
timeout: int | *30
|
|
|
|
#up: [
|
|
op.#Load & {
|
|
from: alpine.#Image & {
|
|
package: bash: "=~5.1"
|
|
package: curl: true
|
|
}
|
|
},
|
|
op.#Exec & {
|
|
args: ["/bin/bash", "-c",
|
|
#"""
|
|
# (f: str -> int)
|
|
nb_retries=$(($NB_RETRIES+0))
|
|
starting_period=$(($START_PERIOD+0))
|
|
|
|
status="0"
|
|
SECONDS=0
|
|
# START_PERIOD implementation
|
|
while [ $SECONDS -lt $starting_period ]; do
|
|
status="$(curl --connect-timeout 1 -s -o /dev/null -w ''%{http_code}'' $HEALTH_URL)"
|
|
if [ "$status" == "200" ]; then
|
|
exit 0;
|
|
fi
|
|
sleep 1;
|
|
done
|
|
|
|
# TIMEOUT, INTERVAL, INTERVAL implementation
|
|
for ((i=0;i<NB_RETRIES;i++)); do
|
|
status="$(curl --connect-timeout $TIMEOUT -s -o /dev/null -w ''%{http_code}'' $HEALTH_URL)"
|
|
if [ "$status" == "200" ]; then
|
|
exit 0;
|
|
fi
|
|
sleep "$INTERVAL";
|
|
done
|
|
|
|
exit 1;
|
|
"""#,
|
|
]
|
|
always: true
|
|
env: {
|
|
HEALTH_URL: url
|
|
INTERVAL: "\(interval)"
|
|
NB_RETRIES: "\(retries)"
|
|
START_PERIOD: "\(startPeriod)"
|
|
TIMEOUT: "\(timeout)"
|
|
}
|
|
},
|
|
]
|
|
}
|