#!/bin/sh

ifile=./sample.d/tmp.file.ipc
istrm=./sample.d/tmp.strm.ipc

gencsv(){
	echo timestamp,severity,status,body
	echo 2025-10-21T01:41:32.012345Z,INFO,200,apt update done
	echo 2025-10-20T01:41:32.012345Z,WARN,500,apt update failure
	echo 2025-10-19T01:41:32.012345Z,WARN,500,apt update failure
}

geninput(){
	echo generating input file...

	mkdir -p ./sample.d

	gencsv |
		csv2arrow2ipc |
		cat > "${ifile}"

	arrow-file-to-stream "${ifile}" > "${istrm}"
}

test -f "${istrm}" || geninput

cat "${istrm}" | ./arrow-ipc-stream-count | arrow-cat

which rs-arrow-ipc-stream-cat | fgrep -q rs-arrow-ipc-stream-cat &&
	cat "${istrm}" |
		./arrow-ipc-stream-count |
		rs-arrow-ipc-stream-cat