REQ に対しての処理の外側

実際に求められたデータを流す部分はバックグラウンドで実行する。何故ならばある REQ リクエストが求められている間にも他のリクエストが来て、それを処理しなくてはならなくなることもあるからだ。これを in.sh として別に作るが、取り敢えずは out.sh を書き続ける。

bash in.sh "$second_element" "third_element" &
inner=$!

と "&" を付ければバックグラウンド(別プロセス)で同時進行できる。しかしそのプロセスのID(PID)を保持しておかないと CLOSE が来ても kill できない。なので $! でそれを取得して変数 inner に入れている。それを REQ の次の要素、セッションID と結びつけて保つことにする。これには連想配列を使う。なので while の上で

declare -A req_rec=()

と連想配列を宣言しておく。req_rec は REQ のレコードくらいの意味でつけた。この配列に

session_id=$(tr -d '"' <<< $second_element) # REQ のセッションID
req_rec[$session_id]=$inner # 連想配列にセッションIDをキーにPIDを収める

と、REQ に応じる in.sh のプロセスIDをセッションIDとセットで追加する。
in.sh の内容は後で記す。取り敢えず REQ に対する out.sh の処理は

elif [ "$first_element" = '"REQ"' ]; then

	bash in.sh "$second_element" "$third_element" &
	inner=$! # in.sh のプロセスID を inner に保持

	session_id=$(tr -d '"' <<< $second_element) # REQ のセッションID
	req_rec[$session_id]=$inner # 連想配列にセッションIDをキーにPIDを収める

とする。

CLOSE に対する処理

CLOSE が来たらセッションIDとセットになっているプロセスIDを kill し、req_rec 配列から削除すればよい。

elif [ "$first_element" = '"CLOSE"' ]; then

	session_id=$(tr -d '"' <<< $second_element) # CLOSE するのセッションID
	kill $( echo ${req_rec[$session_id]} ) # プロセスIDを kill し
	unset req_rec[$session_id] # req_rec から削除

out.sh の全文を以下に記すが、最初に trap 'kill $(jobs -p)' EXIT と書いておく。kill 漏れがあった場合でも out.sh を止めたとき全てのプロセスを kill するためだ。

out.sh

#!/bin/bash


trap 'kill $(jobs -p)' EXIT

declare -A req_rec=()

while read -r line; do
	first_element=$(echo $line | jq -c .[0])
	second_element=$(echo $line | jq -c .[1])
	third_element=$(echo $line | jq -c .[2:][])

	if [ "$first_element" = '"EVENT"' ]; then
	## 記録・保存
		id=$(echo $second_element | jq '.id' | tr -d '"')
		pubkey=$(echo $second_element | jq '.pubkey' | tr -d '"')
		kind=$(echo $second_element | jq '.kind')
		created_at=$(echo $second_element | jq '.created_at')

		tags=( $(echo $second_element | jq -c .tags[][1] | tr -d '"' |
								while read -r tag; do
								echo "$tag"
								done) ) # 配列化
		tag1=${tags[0]}
		tag2=${tags[1]}
		tag3=${tags[2]}
		tag4=${tags[3]}

		sqlite3 test.db "insert into forRelay (created_at, id, author, kind, tag1, tag2, tag3, tag4) values ('$created_at', '$id', '$pubkey', '$kind', '$tag1', '$tag2','$tag3','$tag4');" # シングルクォート大事
		echo $second_element > ./jsons/$created_at
		echo "[\"OK\",\"$id\",true,\"\"]"
	## 記録・保存 ここまで

	elif [ "$first_element" = '"REQ"' ]; then

		bash in.sh "$second_element" "$third_element" &
		inner=$! # in.sh のプロセスID を inner に保持

		session_id=$(tr -d '"' <<< $second_element) # REQ のセッションID
		req_rec[$session_id]=$inner # 連想配列にセッションIDをキーにPIDを収める


	elif [ "$first_element" = '"CLOSE"' ]; then

		session_id=$(tr -d '"' <<< $second_element) # CLOSE するのセッションID
		kill $( echo ${req_rec[$session_id]} ) # プロセスIDを kill し
		unset req_rec[$session_id] # req_rec から削除

	else echo "[NOTICE]" # これで誤魔化す
	fi
done

参考