#!/usr/bin/env bash

set -u

instances=1 if [ ! -z ${INSTANCES+x} ]; then

instances=$INSTANCES

fi

uuid=$(echo $(uuidgen) | tr '[:upper:]' '[:lower:]') stream_name=“testStream-$uuid” if [ ! -z ${STREAM_NAME+x} ]; then

stream_name=$STREAM_NAME

fi

echo echo “Writing $instances Messages to Stream $stream_name” echo “= = =” echo

default_name=message_store

if [ -z ${DATABASE_USER+x} ]; then

echo "(DATABASE_USER is not set)"
user=$default_name

else

user=$DATABASE_USER

fi echo “Database user is: $user”

if [ -z ${DATABASE_NAME+x} ]; then

echo "(DATABASE_NAME is not set)"
database=$default_name

else

database=$DATABASE_NAME

fi echo “Database name is: $database” echo

for (( i=1; i<=instances; i++ )); do

uuid=$(echo $(uuidgen) | tr '[:upper:]' '[:lower:]')

echo "Instance: $i, Message ID: $uuid"

psql $database -U $user -c "SELECT write_message('$uuid'::varchar, '$stream_name'::varchar, 'SomeType'::varchar, '{\"attribute\": \"some value\"}'::jsonb, '{\"metaAttribute\": \"some meta value\"}'::jsonb);" > /dev/null

done

echo psql $database -U $user -P pager=off -x -c “SELECT * FROM messages WHERE stream_name = '$stream_name';”

echo