- First working output descriptor checking

Author: Alan Christie

src/groovy/Log.groovy

@@ -0,0 +1,43 @@
+// Number of warnings generated
+def warningCount = 7
+
+/**
+ * Print a simple separator (a bar) to stdout.
+ * Used to visually separate generated output into logical blocks.
+ */
+static separate() {
+
+    // To look 'pretty' this should align with the field width
+    // used in the info() function
+    println "+----------------+"
+
+}
+
+/**
+ * Print an 'info' message prefixed with `->` string. You can specify a
+ * tag and a message which is printed as "-> <tag> : <msg>"
+ */
+static info(String tag, String msg) {
+
+    println ":" + sprintf('%16s: %s', tag, msg)
+
+}
+
+/**
+ * Print a warning message (and counts it).
+ */
+static warning(String msg) {
+
+    println "WARNING: $msg"
+    Log.warningCount += 1
+
+}
+
+/**
+ * Print an error message.
+ */
+static err(String msg) {
+
+    println "ERROR: $msg"
+
+}

src/groovy/MediaChecker.groovy

@@ -0,0 +1,76 @@
+#!/usr/bin/env groovy
+
+/**
+ * Copyright (c) 2018 Informatics Matters Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * The MediaTypes class. A class to provide validation of files produced
+ * by an executing pipeline.
+ */
+class MediaChecker {
+
+    final static String mediaTypesFile = 'MediaTypes.txt'
+
+    // A map of media type and expected file extension(s).
+    // This is populated by the constructor, which reads the content
+    // of 'mediaTypesFile'.
+    def mediaTypesLookup = null
+
+    /**
+     * Default constructor.
+     * Reads media types config file.
+     */
+    MediaChecker() {
+
+        mediaTypesLookup = new ConfigSlurper().parse(new File(mediaTypesFile).toURI().toURL())
+
+    }
+
+    /**
+     * Checks that a pipeline's expected files exist.
+     *
+     * @param serviceDescriptor The test service descriptor
+     * @param path The test path (where the pipeline's files are to be found)
+     * @return True on success, False otherwise.
+     */
+    boolean check(serviceDescriptor, File path) {
+
+        boolean retVal = true
+
+        // Check output descriptors for expected output file names...
+        // Do all, regardless of individual failure.
+        def opDescriptors = serviceDescriptor.serviceConfig.outputDescriptors
+        opDescriptors.each { desc ->
+
+            // Expected extension...
+            // (use the media type to lookup it up)
+            // And construct full path to the expected file...
+            String opExt = mediaTypesLookup.media_type[desc.mediaType]
+            String opName = desc.name + opExt
+            String opPath = path.toString() + File.separator + opName
+            if (!new File(opPath).exists()) {
+                Log.err("The pipeline's 'outputDescriptor'" +
+                        " expected '$opName' but the file wasn't found")
+                retVal = false
+            }
+
+        }
+
+        return retVal
+
+    }
+
+}

src/groovy/MediaTypes.txt

@@ -0,0 +1,18 @@
+// Input/Output Descriptor dictionary for use with the PipelineTester.
+// This is a map of input/output descriptor `mediaType` identifiers,
+// with expected filename extension(s).
+//
+// Read by MediaChecker.groovy
+
+media_type = [
+
+    // Please keep the keys in alphabetical order...
+
+    'application/x-squonk-dataset-molecule+json': '.data.gz',
+    'application/x-squonk-dataset-basic+json': '.data.gz',
+
+    'image/gif': '.gif',
+    'image/jpeg': '.jpg',
+    'image/png': '.png',
+
+]

src/groovy/PipelineTester.groovy

@@ -31,7 +31,7 @@
 
 // Version
 // Update with every change/release
-String version = '2.0.0'
+String version = '2.1.0'
 
 println "+----------------+"
 println "| PipelineTester | v$version"