include/msg: Add modules for foundry IPC message handling

This commit adds modules providing a convenient interface to
generate and parse any of the message types that are used for
IPC between foundry components.

diff --git a/include/msg/artifact.sh b/include/msg/artifact.sh
new file mode 100644 (file)
index 0000000..a737c74
--- /dev/null
+++ b/include/msg/artifact.sh
@@ -0,0 +1,50 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_artifact_new() {
+       local uri="$1"
+       local checksum="$2"
+
+       local artifact
+
+       if ! artifact=$(json_object "uri"      "$uri" \
+                                   "checksum" "$checksum"); then
+               return 1
+       fi
+
+       echo "$artifact"
+       return 0
+}
+
+foundry_msg_artifact_get_uri() {
+       local artifact="$1"
+
+       local uri
+
+       if ! uri=$(jq -e -r ".uri" <<< "$artifact"); then
+               return 1
+       fi
+
+       echo "$uri"
+       return 0
+}
+
+foundry_msg_artifact_get_checksum() {
+       local artifact="$1"
+
+       local checksum
+
+       if ! checksum=$(jq -e -e ".checksum" <<< "$artifact"); then
+               return 1
+       fi
+
+       echo "$checksum"
+       return 0
+}

diff --git a/include/msg/build.sh b/include/msg/build.sh
new file mode 100644 (file)
index 0000000..a724ebb
--- /dev/null
+++ b/include/msg/build.sh
@@ -0,0 +1,152 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json" "foundry/msg/artifact"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_build_new() {
+       local tid="$1"
+       local repository="$2"
+       local branch="$3"
+       local commit="$4"
+       local result="$5"
+       local -n __foundry_msg_build_new_logs="$6"
+       local -n __foundry_msg_build_new_artifacts="$7"
+
+       local artifact_array
+       local log_array
+       local json
+
+       if ! artifact_array=$(json_array "${__foundry_msg_build_new_artifacts[@]}"); then
+               return 1
+       fi
+
+       if ! log_array=$(json_array "${__foundry_msg_build_new_logs[@]}"); then
+               return 1
+       fi
+
+       if ! json=$(json_object "tid"        "$tid"           \
+                               "repository" "$repository"    \
+                               "branch"     "$branch"        \
+                               "commit"     "$commit"        \
+                               "result"     "$result"        \
+                               "logs"       "$log_array"     \
+                               "artifacts"  "$artifact_array"); then
+               return 1
+       fi
+
+       echo "$json"
+       return 0
+}
+
+foundry_msg_build_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$msg" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_build_get_repository() {
+       local msg="$1"
+
+        local repository
+
+       if ! repository=$(json_object_get "$msg" "repository"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_build_get_branch() {
+       local msg="$1"
+
+       local branch
+
+       if ! branch=$(json_object_get "$msg" "branch"); then
+               return 1
+       fi
+
+       echo "$branch"
+       return 0
+}
+
+foundry_msg_build_get_commit() {
+       local msg="$1"
+
+       local commit
+
+       if ! commit=$(json_object_get "$msg" "commit"); then
+               return 1
+       fi
+
+       echo "$commit"
+       return 0
+}
+
+foundry_msg_build_get_result() {
+       local msg="$1"
+
+       local result
+
+       if ! result=$(json_object_get "$msg" "result"); then
+               return 1
+       fi
+
+       echo "$result"
+       return 0
+}
+
+foundry_msg_build_get_logs() {
+       local msg="$1"
+
+       local logs
+
+       if ! logs=$(json_object_get "$msg" "logs[]"); then
+               return 1
+       fi
+
+       echo "$logs"
+       return 0
+}
+
+foundry_msg_build_get_artifacts() {
+       local msg="$1"
+
+       local query
+       local raw_artifacts
+       local artifacts
+       local checksum
+       local uri
+
+       query='artifacts[] | "\(.checksum) \(.uri)"'
+       artifacts=()
+
+       if ! raw_artifacts=$(json_object_get "$msg" "$query"); then
+               return 1
+       fi
+
+       while read -r checksum uri; do
+               local artifact
+
+               if ! artifact=$(foundry_msg_artifact_new "$uri" "$checksum"); then
+                       return 1
+               fi
+
+               artifacts+=("$artifact")
+       done <<< "$raw_artifacts"
+
+       array_to_lines "${artifacts[@]}"
+       return 0
+}

diff --git a/include/msg/buildrequest.sh b/include/msg/buildrequest.sh
new file mode 100644 (file)
index 0000000..a75e92a
--- /dev/null
+++ b/include/msg/buildrequest.sh
@@ -0,0 +1,80 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_buildrequest_new() {
+       local tid="$1"
+       local repository="$2"
+       local branch="$3"
+       local commit="$4"
+
+       local json
+
+       if ! json=$(json_object "tid" "$tid"               \
+                               "repository" "$repository" \
+                               "branch"     "$branch"     \
+                               "commit"     "$commit"); then
+               return 1
+       fi
+
+       echo "$json"
+       return 0
+}
+
+foundry_msg_buildrequest_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$msg" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_buildrequest_get_repository() {
+       local msg="$1"
+
+       local repository
+
+       if ! repository=$(json_object_get "$msg" "repository"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_buildrequest_get_branch() {
+       local msg="$1"
+
+       local branch
+
+       if ! branch=$(json_object_get "$msg" "branch"); then
+               return 1
+       fi
+
+       echo "$branch"
+       return 0
+}
+
+foundry_msg_buildrequest_get_commit() {
+       local msg="$1"
+
+       local commit
+
+       if ! commit=$(json_object_get "$msg" "commit"); then
+               return 1
+       fi
+
+       echo "$commit"
+       return 0
+}

diff --git a/include/msg/commit.sh b/include/msg/commit.sh
new file mode 100644 (file)
index 0000000..d3b23b8
--- /dev/null
+++ b/include/msg/commit.sh
@@ -0,0 +1,79 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_commit_new() {
+       local repository="$1"
+       local branch="$2"
+       local commit="$3"
+
+       local msg
+
+       if ! msg=$(json_object "repository" "$repository" \
+                              "commit"     "$commit"     \
+                              "branch"     "$branch"); then
+               return 1
+       fi
+
+       echo "$msg"
+       return 0
+}
+
+_foundry_msg_commit_get_field() {
+       local msg="$1"
+       local field="$2"
+
+       local value
+
+       if ! value=$(echo "$msg" | jq -e -r ".$field"); then
+               return 1
+       fi
+
+       echo "$value"
+       return 0
+}
+
+foundry_msg_commit_get_repository() {
+       local msg="$1"
+
+       local repository
+
+       if ! repository=$(_foundry_msg_commit_get_field "$msg" "repository"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_commit_get_branch() {
+       local msg="$1"
+
+       local branch
+
+       if ! branch=$(_foundry_msg_commit_get_field "$msg" "branch"); then
+               return 1
+       fi
+
+       echo "$branch"
+       return 0
+}
+
+foundry_msg_commit_get_commit() {
+       local msg="$1"
+
+       local commit
+
+       if ! commit=$(_foundry_msg_commit_get_field "$msg" "commit"); then
+               return 1
+       fi
+
+       echo "$commit"
+       return 0
+}

diff --git a/include/msg/dist.sh b/include/msg/dist.sh
new file mode 100644 (file)
index 0000000..1988599
--- /dev/null
+++ b/include/msg/dist.sh
@@ -0,0 +1,111 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json" "foundry/msg/artifact"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_dist_new() {
+       local tid="$1"
+       local repository="$2"
+       local artifact_data=("${@:3}")
+
+       local msg
+       local artifacts
+       local artifact_array
+       local i
+
+       if (( ${#artifact_data} & 1 != 0 )); then
+               return 1
+       fi
+
+       artifacts=()
+
+       for (( i = 0; i + 1 < ${#artifact_data[@]}; i += 2 )); do
+               local artifact
+               local uri
+               local checksum
+
+               uri="${artifact_data[$i]}"
+               checksum="${artifact_data[$((i + 1))]}"
+
+               if ! artifact=$(foundry_msg_artifact_new "$uri" \
+                                                        "$checksum"); then
+                       return 1
+               fi
+
+               artifacts+=("$artifact")
+       done
+
+       if ! artifact_array=$(json_array "${artifacts[@]}"); then
+               return 1
+       fi
+
+        if ! msg=$(json_object "tid"        "$tid"           \
+                              "repository" "$repository"    \
+                              "artifacts"  "$artifact_array"); then
+               return 1
+       fi
+
+       echo "$msg"
+       return 0
+}
+
+foundry_msg_dist_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$msg" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_dist_get_repository() {
+       local msg="$1"
+
+       local repository
+
+       if ! repository=$(json_object_get "$msg" "repository"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_dist_get_artifacts() {
+       local msg="$1"
+
+       local query
+       local raw_artifacts
+       local artifacts
+       local checksum
+       local uri
+
+       query='artifacts[] | "\(.checksum) \(.uri)"'
+       artifacts=()
+
+       if ! raw_artifacts=$(json_object_get "$msg" "$query"); then
+               return 1
+       fi
+
+       while read -r checksum uri; do
+               local artifact
+
+               if ! artifact=$(foundry_msg_artifact_new "$uri" "$checksum"); then
+                       return 1
+               fi
+
+               artifacts+=("$artifact")
+       done <<< "$raw_artifacts"
+
+       array_to_lines "${artifacts[@]}"
+       return 0
+}

diff --git a/include/msg/distrequest.sh b/include/msg/distrequest.sh
new file mode 100644 (file)
index 0000000..7f9f53e
--- /dev/null
+++ b/include/msg/distrequest.sh
@@ -0,0 +1,91 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_distrequest_new() {
+       local tid="$1"
+       local artifact_data=("${@:2}")
+
+       local artifacts_array
+       local artifacts
+       local distrequest
+       local i
+
+       if ! (( $# & 1 )); then
+               # Invalid number of arguments
+               return 1
+       fi
+
+       artifacts=()
+
+       for (( i = 0; (i + 1) < $#; i += 2 )); do
+               local artifact
+
+               if ! artifact=$(foundry_msg_artifact_new "${artifact_data[$i]}" \
+                                                        "${artifact_data[$((i+1))]}"); then
+                       continue
+               fi
+
+               artifacts+=("$artifact")
+       done
+
+       if ! artifacts_array=$(json_array "${artifacts[@]}"); then
+               return 1
+       fi
+
+       if ! distrequest=$(json_object "tid"       "$tid"            \
+                                      "artifacts" "$artifacts_array"); then
+               return 1
+       fi
+
+       echo "$distrequest"
+       return 0
+}
+
+foundry_msg_distrequest_get_tid() {
+       local distrequest="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$distrequest" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_distrequest_get_artifacts() {
+       local distrequest="$1"
+
+       local raw_artifacts
+       local artifacts
+       local artifact
+       local checksum
+       local uri
+
+       if ! raw_artifacts=$(json_object_get "$distrequest" 'artifacts[] | "\(.checksum) \(.uri)"'); then
+               return 1
+       fi
+
+       while read -r checksum uri; do
+               if ! artifact=$(json_object "uri" "$uri" \
+                                           "checksum" "$checksum"); then
+                       return 1
+               fi
+
+               artifacts+=("$artifact")
+       done <<< "$raw_artifacts"
+
+       for artifact in "${artifacts[@]}"; do
+               echo "$artifact"
+       done
+
+       return 0
+}

diff --git a/include/msg/merge.sh b/include/msg/merge.sh
new file mode 100644 (file)
index 0000000..3c3ae9f
--- /dev/null
+++ b/include/msg/merge.sh
@@ -0,0 +1,110 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_merge_new() {
+       local tid="$1"
+       local repository="$2"
+       local srcbranch="$3"
+       local dstbranch="$4"
+       local status="$5"
+       local log="$6"
+
+       local json
+
+       if ! json=$(json_object "tid"        "$tid"        \
+                               "repository" "$repository" \
+                               "srcbranch"  "$srcbranch"  \
+                               "dstbranch"  "$dstbranch"  \
+                               "status"     "$status"     \
+                               "log"        "$log"); then
+               return 1
+       fi
+
+       echo "$json"
+       return 0
+}
+
+foundry_msg_merge_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$msg" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_merge_get_repository() {
+       local msg="$1"
+
+       local repository
+
+       if ! repository=$(json_object_get "$msg" "repository"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_merge_get_source_branch() {
+       local msg="$1"
+
+       local srcbranch
+
+       if ! srcbranch=$(json_object_get "$msg" "source_branch"); then
+               return 1
+       fi
+
+       echo "$srcbranch"
+       return 0
+}
+
+foundry_msg_merge_get_destination_branch() {
+       local msg="$1"
+
+       local dstbranch
+
+       if ! dstbranch=$(json_object_get "$msg" "destination_branch"); then
+               return 1
+       fi
+
+       echo "$dstbranch"
+       return 0
+}
+
+foundry_msg_merge_get_status() {
+       local msg="$1"
+
+       local status
+
+       if ! status=$(json_object_get "$msg" "status"); then
+               return 1
+       fi
+
+       echo "$status"
+       return 0
+}
+
+foundry_msg_merge_get_log() {
+       local msg="$1"
+
+       local log
+
+       if ! log=$(json_object_get "$msg" "log"); then
+               return 1
+       fi
+
+       echo "$log"
+       return 0
+}

diff --git a/include/msg/mergerequest.sh b/include/msg/mergerequest.sh
new file mode 100644 (file)
index 0000000..b95a5fa
--- /dev/null
+++ b/include/msg/mergerequest.sh
@@ -0,0 +1,79 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_mergerequest_new() {
+       local tid="$1"
+       local repository="$2"
+       local srcbranch="$3"
+       local dstbranch="$4"
+
+       local json
+
+       if ! json=$(json_object "tid" "$tid"                     \
+                               "repository" "$repository"       \
+                               "source_branch" "$srcbranch"     \
+                               "destination_branch" "$dstbranch"); then
+               return 1
+       fi
+
+       echo "$json"
+       return 0
+}
+
+foundry_msg_mergerequest_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$msg" "tid"); then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_mergerequest_get_repository() {
+       local msg="$1"
+
+       local repository
+
+       if ! repository=$(json_object_get "$msg" "repository"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_mergerequest_get_source_branch() {
+       local msg="$1"
+
+       local srcbranch
+
+       if ! srcbranch=$(json_object_get "$msg" "source_branch"); then
+               return 1
+       fi
+
+       echo "$srcbranch"
+       return 0
+}
+
+foundry_msg_mergerequest_get_destination_branch() {
+       local msg="$1"
+
+       local dstbranch
+
+       if ! dstbranch=$(json_object_get "$msg" "destination_branch"); then
+               return 1
+       fi
+
+       echo "$dstbranch"
+       return 0
+}

diff --git a/include/msg/sign.sh b/include/msg/sign.sh
new file mode 100644 (file)
index 0000000..eff9e35
--- /dev/null
+++ b/include/msg/sign.sh
@@ -0,0 +1,111 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json" "foundry/msg/artifact"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_sign_new() {
+       local tid="$1"
+       local key="$2"
+       local artifact_data=("${@:3}")
+
+       local msg
+       local artifacts
+       local artifact_array
+       local i
+
+       if (( ${#artifact_data} & 1 != 0 )); then
+               return 1
+       fi
+
+       artifacts=()
+
+       for (( i = 0; i + 1 < ${#artifact_data[@]}; i += 2 )); do
+               local artifact
+               local uri
+               local checksum
+
+               uri="${artifact_data[$i]}"
+               checksum="${artifact_data[$((i + 1))]}"
+
+               if ! artifact=$(foundry_msg_artifact_new "$uri" \
+                                                        "$checksum"); then
+                       return 1
+               fi
+
+               artifacts+=("$artifact")
+       done
+
+       if ! artifact_array=$(json_array "${artifacts[@]}"); then
+               return 1
+       fi
+
+        if ! msg=$(json_object "tid"       "$tid"           \
+                              "key"       "$key"           \
+                              "artifacts" "$artifact_array"); then
+               return 1
+       fi
+
+       echo "$msg"
+       return 0
+}
+
+foundry_msg_sign_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$msg" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_sign_get_key() {
+       local msg="$1"
+
+       local key
+
+       if ! key=$(json_object_get "$msg" "key"); then
+               return 1
+       fi
+
+       echo "$key"
+       return 0
+}
+
+foundry_msg_sign_get_artifacts() {
+       local msg="$1"
+
+       local query
+       local raw_artifacts
+       local artifacts
+       local checksum
+       local uri
+
+       query='artifacts[] | "\(.checksum) \(.uri)"'
+       artifacts=()
+
+       if ! raw_artifacts=$(json_object_get "$msg" "$query"); then
+               return 1
+       fi
+
+       while read -r checksum uri; do
+               local artifact
+
+               if ! artifact=$(foundry_msg_artifact_new "$uri" "$checksum"); then
+                       return 1
+               fi
+
+               artifacts+=("$artifact")
+       done <<< "$raw_artifacts"
+
+       array_to_lines "${artifacts[@]}"
+       return 0
+}

diff --git a/include/msg/signrequest.sh b/include/msg/signrequest.sh
new file mode 100644 (file)
index 0000000..b11e101
--- /dev/null
+++ b/include/msg/signrequest.sh
@@ -0,0 +1,92 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json" "foundry/msg/artifact"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_signrequest_new() {
+       local tid="$1"
+       local artifact_data=("${@:2}")
+
+       local artifacts_array
+       local artifacts
+       local signrequest
+       local i
+
+       if ! (( $# & 1 )); then
+               # Invalid number of arguments
+               return 1
+       fi
+
+       artifacts=()
+
+       for (( i = 0; (i + 1) < $#; i += 2 )); do
+               local artifact
+
+               if ! artifact=$(foundry_msg_artifact_new "${artifact_data[$i]}" \
+                                                        "${artifact_data[$((i+1))]}"); then
+                       continue
+               fi
+
+               artifacts+=("$artifact")
+       done
+
+       if ! artifacts_array=$(json_array "${artifacts[@]}"); then
+               return 1
+       fi
+
+       if ! signrequest=$(json_object "tid"       "$tid"            \
+                                      "artifacts" "$artifacts_array"); then
+               return 1
+       fi
+
+       echo "$signrequest"
+       return 0
+}
+
+foundry_msg_signrequest_get_tid() {
+       local signrequest="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$signrequest" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_signrequest_get_artifacts() {
+       local signrequest="$1"
+
+       local query
+       local raw_artifacts
+       local artifacts
+       local checksum
+       local uri
+
+       query='artifacts[] | "\(.checksum) \(.uri)"'
+       artifacts=()
+
+       if ! raw_artifacts=$(json_object_get "$signrequest" "$query"); then
+               return 1
+       fi
+
+       while read -r checksum uri; do
+               local artifact
+
+               if ! artifact=$(foundry_msg_artifact_new "$uri" "$checksum"); then
+                       return 1
+               fi
+
+               artifacts+=("$artifact")
+       done <<< "$raw_artifacts"
+
+       array_to_lines "${artifacts[@]}"
+       return 0
+}

diff --git a/include/msg/test.sh b/include/msg/test.sh
new file mode 100644 (file)
index 0000000..8aa16e3
--- /dev/null
+++ b/include/msg/test.sh
@@ -0,0 +1,115 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_test_new() {
+       local tid="$1"
+       local repository="$2"
+       local branch="$3"
+       local commit="$4"
+       local result="$5"
+       local logs=("${@:6}")
+
+       local logs_array
+       local msg
+
+       if ! logs_array=$(json_array "${logs[@]}"); then
+               return 1
+       fi
+
+       if ! msg=$(json_object "tid"        "$tid"        \
+                              "repository" "$repository" \
+                              "branch"     "$branch"     \
+                              "commit"     "$commit"     \
+                              "result"     "$result"     \
+                              "logs"       "$logs_array"); then
+               return 1
+       fi
+
+       echo "$msg"
+       return 0
+}
+
+foundry_msg_test_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(json_object_get "$msg" "tid"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+foundry_msg_test_get_repository() {
+       local msg="$1"
+
+       local repository
+
+       if ! repository=$(json_object_get "$msg" "repository"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_test_get_branch() {
+       local msg="$1"
+
+       local branch
+
+       if ! branch=$(json_object_get "$msg" "branch"); then
+               return 1
+       fi
+
+       echo "$branch"
+       return 0
+}
+
+foundry_msg_test_get_commit() {
+       local msg="$1"
+
+       local commit
+
+       if ! commit=$(json_object_get "$msg" "commit"); then
+               return 1
+       fi
+
+       echo "$commit"
+       return 0
+}
+
+foundry_msg_test_get_result() {
+       local msg="$1"
+
+       local result
+
+       if ! result=$(json_object_get "$msg" "result"); then
+               return 1
+       fi
+
+       echo "$result"
+       return 0
+}
+
+foundry_msg_test_get_logs() {
+       local msg="$1"
+
+       local logs
+
+       if ! logs=$(json_object_get "$msg" "logs[]"); then
+               return 1
+       fi
+
+       echo "$logs"
+       return 0
+}

diff --git a/include/msg/testrequest.sh b/include/msg/testrequest.sh
new file mode 100644 (file)
index 0000000..ab9324c
--- /dev/null
+++ b/include/msg/testrequest.sh
@@ -0,0 +1,81 @@
+#!/bin/bash
+
+__init() {
+       if ! include "json"; then
+               return 1
+       fi
+
+       return 0
+}
+
+foundry_msg_testrequest_new() {
+       local tid="$1"
+       local repository="$2"
+       local branch="$3"
+       local commit="$4"
+
+       local json
+
+       if ! json=$(json_object "tid" "$tid"               \
+                               "repository" "$repository" \
+                               "branch" "$branch"         \
+                               "commit" "$commit"); then
+               return 1
+       fi
+
+       echo "$json"
+       return 0
+}
+
+foundry_msg_testrequest_get_tid() {
+       local msg="$1"
+
+       local tid
+
+       if ! tid=$(jq -e -r ".tid" <<< "$msg"); then
+               return 1
+       fi
+
+       echo "$tid"
+       return 0
+}
+
+
+foundry_msg_testrequest_get_repository() {
+       local msg="$1"
+
+       local repository
+
+       if ! repository=$(jq -e -r ".repository" <<< "$msg"); then
+               return 1
+       fi
+
+       echo "$repository"
+       return 0
+}
+
+foundry_msg_testrequest_get_branch() {
+       local msg="$1"
+
+       local branch
+
+       if ! branch=$(jq -e -r ".branch" <<< "$msg"); then
+               return 1
+       fi
+
+       echo "$branch"
+       return 0
+}
+
+foundry_msg_testrequest_get_commit() {
+       local msg="$1"
+
+       local commit
+
+       if ! commit=$(jq -e -r ".commit" <<< "$msg"); then
+               return 1
+       fi
+
+       echo "$commit"
+       return 0
+}