CREATE OR REPLACE FUNCTION get_last_message(
  _stream_name varchar
)
RETURNS SETOF message
AS $$
DECLARE
  command text;
BEGIN
  command := '
    SELECT
      id::varchar,
      stream_name::varchar,
      type::varchar,
      position::bigint,
      global_position::bigint,
      data::varchar,
      metadata::varchar,
      time::timestamp
    FROM
      messages
    WHERE
      stream_name = $1
    ORDER BY
      position DESC
    LIMIT
      1';

  -- RAISE NOTICE '%', command;

  RETURN QUERY EXECUTE command USING _stream_name;
END;
$$ LANGUAGE plpgsql
VOLATILE;