jcstein/latency-monitor.sh

## latency-monitor.sh
#!/usr/bin/env bash
# Bash-only Celestia blob submit load tester.
# Usage: COUNT=100 NS=0x676d DATA=0x676d CMD="celestia blob submit" ./celestia_blob_bench.sh

set -euo pipefail

COUNT=${COUNT:-20}
CMD=${CMD:-"celestia blob submit"}
NS=${NS:-"0x676d"}
DATA=${DATA:-"0x676d"}

printf "Running %s submissions: %s %s %s\n" "$COUNT" "$CMD" "$NS" "$DATA"

ok=0
fail=0
times=()

has_jq=1
if ! command -v jq >/dev/null 2>&1; then
  has_jq=0
  echo "Note: jq not found; height/commitment parsing skipped." >&2
fi

for i in $(seq 1 "$COUNT"); do
  start_ns=$(date +%s%N)
  out=$($CMD "$NS" "$DATA" 2>&1) || rc=$?
  end_ns=$(date +%s%N)
  dur_ms=$(( (end_ns - start_ns) / 1000000 ))

  rc=${rc:-0}
  if [ "$rc" -eq 0 ]; then
    ok=$((ok + 1))
    times+=("$dur_ms")
    if [ "$has_jq" -eq 1 ]; then
      height=$(echo "$out" | jq -r '(.result.height // .height // "-")')
      commitment=$(echo "$out" | jq -r '(.result.commitments[0] // .commitments[0] // "-")')
    else
      height="-"
      commitment="-"
    fi
    printf "[%03d] ok   %7.2f ms | height=%s | commitment=%s\n" "$i" "$dur_ms" "$height" "$commitment"
  else
    fail=$((fail + 1))
    printf "[%03d] fail %7.2f ms | rc=%s | %s\n" "$i" "$dur_ms" "$rc" "$out"
  fi
  unset rc
done

if [ "${#times[@]}" -gt 0 ]; then
  sum=0
  min=${times[0]}
  max=${times[0]}
  for t in "${times[@]}"; do
    sum=$((sum + t))
    (( t < min )) && min=$t
    (( t > max )) && max=$t
  done
  avg=$(printf "%s\n" "${times[@]}" | awk '{s+=$1; c++} END {if(c>0) printf "%.2f", s/c; else print "0"}')
  printf "\nSummary: total=%s ok=%s fail=%s\n" "$COUNT" "$ok" "$fail"
  printf "Durations (ms): avg=%s min=%s max=%s\n" "$avg" "$min" "$max"
else
  printf "\nSummary: total=%s ok=%s fail=%s (no successes to compute stats)\n" "$COUNT" "$ok" "$fail"
fi
	#!/usr/bin/env bash
	# Bash-only Celestia blob submit load tester.
	# Usage: COUNT=100 NS=0x676d DATA=0x676d CMD="celestia blob submit" ./celestia_blob_bench.sh

	set -euo pipefail

	COUNT=${COUNT:-20}
	CMD=${CMD:-"celestia blob submit"}
	NS=${NS:-"0x676d"}
	DATA=${DATA:-"0x676d"}

	printf "Running %s submissions: %s %s %s\n" "$COUNT" "$CMD" "$NS" "$DATA"

	ok=0
	fail=0
	times=()

	has_jq=1
	if ! command -v jq >/dev/null 2>&1; then
	has_jq=0
	echo "Note: jq not found; height/commitment parsing skipped." >&2
	fi

	for i in $(seq 1 "$COUNT"); do
	start_ns=$(date +%s%N)
	out=$($CMD "$NS" "$DATA" 2>&1) \|\| rc=$?
	end_ns=$(date +%s%N)
	dur_ms=$(( (end_ns - start_ns) / 1000000 ))

	rc=${rc:-0}
	if [ "$rc" -eq 0 ]; then
	ok=$((ok + 1))
	times+=("$dur_ms")
	if [ "$has_jq" -eq 1 ]; then
	height=$(echo "$out" \| jq -r '(.result.height // .height // "-")')
	commitment=$(echo "$out" \| jq -r '(.result.commitments[0] // .commitments[0] // "-")')
	else
	height="-"
	commitment="-"
	fi
	printf "[%03d] ok %7.2f ms \| height=%s \| commitment=%s\n" "$i" "$dur_ms" "$height" "$commitment"
	else
	fail=$((fail + 1))
	printf "[%03d] fail %7.2f ms \| rc=%s \| %s\n" "$i" "$dur_ms" "$rc" "$out"
	fi
	unset rc
	done

	if [ "${#times[@]}" -gt 0 ]; then
	sum=0
	min=${times[0]}
	max=${times[0]}
	for t in "${times[@]}"; do
	sum=$((sum + t))
	(( t < min )) && min=$t
	(( t > max )) && max=$t
	done
	avg=$(printf "%s\n" "${times[@]}" \| awk '{s+=$1; c++} END {if(c>0) printf "%.2f", s/c; else print "0"}')
	printf "\nSummary: total=%s ok=%s fail=%s\n" "$COUNT" "$ok" "$fail"
	printf "Durations (ms): avg=%s min=%s max=%s\n" "$avg" "$min" "$max"
	else
	printf "\nSummary: total=%s ok=%s fail=%s (no successes to compute stats)\n" "$COUNT" "$ok" "$fail"
	fi
No results found