Instrument build script

Author: mwunderl

Buildfile

@@ -1 +1 @@
-01build: gradle build
+01build: ./bin/build.sh

bin/build.sh

@@ -0,0 +1,9 @@
+SEGMENT=$(python bin/xray_start.py)
+GRADLE_OUTPUT=$(gradle build); GRADLE_RETURN=$? 
+if (( GRADLE_RETURN != 0 )); then 
+  echo "Grade failed with exit status $GRADLE_RETURN" >&2 
+  echo "and output: $GRADLE_OUTPUT" >&2
+  python bin/xray_error.py "$SEGMENT" "$GRADLE_OUTPUT"
+  exit 1
+fi
+python bin/xray_success.py "$SEGMENT"

bin/xray_error.py

@@ -0,0 +1,22 @@
+import time
+import json
+import socket
+import sys
+
+SEGMENT_DOC = json.loads(sys.argv[1])
+ERROR = { "error": sys.argv[2] }
+del SEGMENT_DOC["in_progress"]
+END_TIME = time.time()
+SEGMENT_DOC["end_time"] = END_TIME
+SEGMENT_DOC["error"] = True
+SEGMENT_DOC["annotations"] = ERROR
+
+HEADER=json.dumps({"format": "json", "version": 1})
+TRACE_DATA = HEADER + "\n" + json.dumps(SEGMENT_DOC)
+
+UDP_IP= "127.0.0.1"
+UDP_PORT=2000
+sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+sock.sendto(TRACE_DATA, (UDP_IP, UDP_PORT))
+
+print json.dumps(SEGMENT_DOC)

bin/xray_start.py

@@ -0,0 +1,20 @@
+import time
+import json
+import socket
+import os
+import binascii
+
+START_TIME = time.time()
+HEX=hex(int(START_TIME))[2:]
+TRACE_ID="1-" + HEX + "-" + binascii.b2a_hex(os.urandom(12))
+SEGMENT_ID=binascii.b2a_hex(os.urandom(8))
+SEGMENT_DOC=json.dumps({"trace_id": TRACE_ID, "id": SEGMENT_ID, "start_time": START_TIME, "in_progress": True, "name": "Scorekeep-build"})
+HEADER=json.dumps({"format": "json", "version": 1})
+TRACE_DATA = HEADER + "\n" + SEGMENT_DOC
+
+UDP_IP= "127.0.0.1"
+UDP_PORT=2000
+sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+sock.sendto(TRACE_DATA, (UDP_IP, UDP_PORT))
+
+print SEGMENT_DOC

bin/xray_success.py

@@ -0,0 +1,18 @@
+import time
+import json
+import socket
+import sys
+
+SEGMENT_DOC = json.loads(sys.argv[1])
+del SEGMENT_DOC["in_progress"]
+END_TIME = time.time()
+SEGMENT_DOC["end_time"] = END_TIME
+HEADER=json.dumps({"format": "json", "version": 1})
+TRACE_DATA = HEADER + "\n" + json.dumps(SEGMENT_DOC)
+
+UDP_IP= "127.0.0.1"
+UDP_PORT=2000
+sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+sock.sendto(TRACE_DATA, (UDP_IP, UDP_PORT))
+
+print json.dumps(SEGMENT_DOC)