From 558c26f49a4f502dfa37fa2d9c6ca4b4dff0a67f Mon Sep 17 00:00:00 2001
From: Luca Cinquini <cinquini@mt-509305.jpl.nasa.gov>
Date: Fri, 5 Jan 2024 11:11:09 -0700
Subject: [PATCH 1/2] Adding examples on how to use unity-py to interact with
 SPS

---
 examples/requirements.txt |  2 +
 examples/sps_job.py       | 96 +++++++++++++++++++++++++++++++++++++++
 examples/sps_process.py   | 31 +++++++++++++
 3 files changed, 129 insertions(+)
 create mode 100644 examples/requirements.txt
 create mode 100644 examples/sps_job.py
 create mode 100644 examples/sps_process.py

diff --git a/examples/requirements.txt b/examples/requirements.txt
new file mode 100644
index 0000000..e335bce
--- /dev/null
+++ b/examples/requirements.txt
@@ -0,0 +1,2 @@
+unity-sds-client
+requests
diff --git a/examples/sps_job.py b/examples/sps_job.py
new file mode 100644
index 0000000..118c16e
--- /dev/null
+++ b/examples/sps_job.py
@@ -0,0 +1,96 @@
+import requests
+import time
+
+from datetime import datetime
+
+from unity_sds_client.unity import Unity
+from unity_sds_client.unity_services import UnityServices
+from unity_sds_client.resources.job_status import JobStatus
+
+VENUE_ID = "unity-sips-test"
+PROCESS_ID = "chirp:develop"
+
+data = {
+  "mode": "async",
+  "response": "document",
+  "inputs": [
+    {
+      "id": "input_processing_labels",
+      "data": [
+        "gangl_test"
+      ]
+    },
+    {
+      "id": "input_cmr_collection_name",
+      "data": "C2011289787-GES_DISC"
+    },
+    {
+      "id": "input_cmr_search_start_time",
+      "data": "2016-08-30T00:10:00Z"
+    },
+    {
+      "id": "input_cmr_search_stop_time",
+      "data": "2016-08-31T01:10:00Z"
+    },
+    {
+      "id": "input_cmr_edl_user",
+      "data": "cmr_user"
+    },
+    {
+      "id": "input_cmr_edl_pass",
+      "data": "cmr_pass"
+    },
+    {
+      "id": "output_collection_id",
+      "data": "urn:nasa:unity:ssips:TEST1:CHRP_16_DAY_REBIN___1"
+    },
+    {
+      "id": "output_data_bucket",
+      "data": " ssips-test-ds-storage-reproc"
+    }, {
+      "id": "input_daac_collection_shortname",
+      "data": "CHIRP_L1B"
+    },
+    {
+      "id": "input_daac_collection_sns",
+      "data": "arn:://SNS-arn"
+    }
+  ],
+  "outputs": [
+    {
+      "id": "output",
+      "transmissionMode": "reference"
+    }
+  ]
+}
+
+unity = Unity()
+unity.set_venue_id(VENUE_ID)
+process_service = unity.client(UnityServices.PROCESS_SERVICE)
+
+# Submit a job for the given process
+process = process_service.get_process(PROCESS_ID)
+try:
+    job = process.execute(data)
+    print(job)
+    # If the job submission is successful, print a success message along with the returned JOB-ID
+    print("\nJob Submission Successful!\nJOB ID: {}\n".format(job.id))
+
+    # Monitor the job until completion
+    job_status = job.get_status()
+    while job_status == JobStatus.RUNNING:
+        print("Status for job \"{}\" ({}): {}".format(job.id,
+                                                      datetime.now().strftime("%H:%M:%S"), job_status.value))
+        time.sleep(5)
+        job_status = job.get_status()
+        print("\nStatus for job \"{}\" ({}): {}\n".format(job.id,
+                                                          datetime.now().strftime("%H:%M:%S"), job_status.value))
+
+    # Print the final status
+    print("\nFinal status for job \"{}\" ({}): {}\n".format(job.id,
+                                                            datetime.now().strftime("%H:%M:%S"), job_status.value))
+
+
+except requests.exceptions.HTTPError as e:
+    # An error has occurred, print the error message that was generated
+    print(e)
diff --git a/examples/sps_process.py b/examples/sps_process.py
new file mode 100644
index 0000000..09e46db
--- /dev/null
+++ b/examples/sps_process.py
@@ -0,0 +1,31 @@
+"""
+Example script that exercises SPS functionality related to Processes.
+The authentication credentials can be read from the environment variables:
+UNITY_USER
+UNITY_PASSWORD
+or can be injected interactively from the command line.
+"""
+from unity_sds_client.unity import Unity
+from unity_sds_client.unity_services import UnityServices
+
+VENUE_ID = "unity-sips-test"
+PROCESS_ID = "chirp:develop"
+
+unity = Unity()
+unity.set_venue_id(VENUE_ID)
+process_service = unity.client(UnityServices.PROCESS_SERVICE)
+print("WPS-T endpoint=%s" % process_service.endpoint)
+
+# List all deployed processes
+processes = process_service.get_processes()
+for process in processes:
+    print("Process ID: {}".format(process.id))
+    print("Process Title: {}".format(process.title))
+    print("Process Abstract: {}".format(process.abstract))
+    print("Process Version: {}".format(process.process_version))
+    print("")
+    print(process)
+
+# Query for a specific process
+process = process_service.get_process(PROCESS_ID)
+print(process)

From 86806dac602a08d7a00e517311962a93631dbeb7 Mon Sep 17 00:00:00 2001
From: Luca Cinquini <cinquini@mt-509305.jpl.nasa.gov>
Date: Fri, 5 Jan 2024 11:14:00 -0700
Subject: [PATCH 2/2] Updating the job examples

---
 examples/sps_job.py | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/examples/sps_job.py b/examples/sps_job.py
index 118c16e..b83abc7 100644
--- a/examples/sps_job.py
+++ b/examples/sps_job.py
@@ -1,3 +1,11 @@
+"""
+Example script that exercises SPS functionality related to Jobs.
+The authentication credentials can be read from the environment variables:
+UNITY_USER
+UNITY_PASSWORD
+or can be injected interactively from the command line.
+"""
+
 import requests
 import time