# Requires sh, curl/wget & coreutils

# GET requests using wget / curl
msg_get() {
  wget -qO- "http://$HOST/api/v2/$*"
}
msg_get() {
  curl "http://$HOST/api/v2/$*"
}

# POST requests using wget/curl (stdin stored to a file)
msg_post() {
  FILE="$(mktemp)"
  cat > "$FILE"
  wget -qO- --post-file "$FILE" "http://$HOST/api/v2/$*"
  rm "$FILE"
}
msg_post() {
  curl -d@- "http://$HOST/api/v2/$*"
}

# POST request using wget/curl (send a file)
msg_post_file() {
  wget -qO- --post-file "$1" http://$HOST/api/v2/$2
}
msg_post_file() {
  curl --data-binary "@$1" http://$HOST/api/v2/$2
}

# --- Examples ---

# PowerGoblin server
export HOST=localhost:8080

# GET examples

msg_get cmd/startSession
msg_get session/latest/meter
msg_get session/latest/measurement/start

# POST examples

export DATA='{ "triggerType":"Run", "unit":"SUT", "message":"foo", "type":"trigger" }'

echo $DATA | msg_post session/latest/trigger
echo foobar | msg_post session/latest/measurement/rename
msg_post_file collectd.zip session/latest/import/collectd

# Requires Python 3+, python-requests, python-simplejson

import requests
import json

class GoblinClient:
  def __init__(self, host):
    self.host = "http://" + host + "/api/v2/"

  def get(self, url):
    return requests.get(self.host + url)

  def post_json(self, url, json):
    return requests.post(self.host + url, json = json)

  def post_text(self, url, text):
    h = {'Content-Type': 'text/plain'}
    return requests.post(self.host + url, data = text, headers=h)

  def post_file(self, url, file):
    with open(file, 'rb') as p:
      h = {'content-type': 'application/x-zip'}
      return requests.post(self.host + url, data=p, verify=False, headers=h)

  def interpret(self, result):
    return json.loads(result.content)["result"]

# --- Examples ---

# PowerGoblin server
c = GoblinClient("localhost:8080")

# GET examples

c.get("cmd/startSession")
meters = c.get("session/latest/meter")
print(c.interpret(meters))

c.get("session/latest/measurement/start")

# POST examples

data = { "triggerType":"Run", "unit":"SUT", "message":"foo", "type":"trigger" }

c.post_json("session/latest/trigger", json = data)
c.post_text("session/latest/measurement/rename", text = "foobar")
c.post_file("session/latest/import/collectd", "collectd.zip")

// Requires Java 21+

import java.io.IOException;
import java.nio.file.*;
import java.net.*;
import java.net.http.*;
import java.util.zip.*;

record GoblinClient(String host) {
  private HttpResponse<String> run(HttpRequest.Builder b) throws Exception {
    try (var client = HttpClient.newHttpClient()) {
      return client.send(
          b.build(),
          HttpResponse.BodyHandlers.ofString()
      );
    }
  }

  private HttpRequest.Builder api(String api) {
      return HttpRequest.newBuilder(URI.create("http://"+host+"/api/v2/"+api));
  }

  HttpResponse<String> get(String api) throws Exception {
    return run(api(api));
  }

  HttpResponse<String> post(String api, String msg) throws Exception {
    return run(api(api).POST(HttpRequest.BodyPublishers.ofString(msg)));
  }

  HttpResponse<String> post(String api, Path path) throws Exception {
    return run(api(api).POST(HttpRequest.BodyPublishers.ofFile(path)));
  }
}

// --- Examples ---

void main() {
  var c = new GoblinClient("localhost:8080");

  // GET examples

  c.get("cmd/startSession");
  c.get("session/latest/meter");
  c.get("session/latest/measurement/start");

  // POST examples

  var data = """
    { "triggerType": "Run", "unit": "SUT", "message": "foo", "type": "trigger" }
  """;
  
  c.post("session/latest/trigger", data);
  c.post("session/latest/rename", "foobar");
  c.post("session/latest/import/collectd", Path.of("collectd.zip"));
}

const request = require('request');

const host = "localhost:8080";

function get(api) {
  request(
    "http://" + host + "/api/v2/" + api,
    (e, r, body) => {
      if (!e && r.statusCode == 200)
        console.log(body);
    }
  );
}

function post_json(api, data) {
  request.post(
    {
      url: "http://" + host + "/api/v2/" + api,
      json: data,
    },
    (e, r, body) => {
      if (!e && r.statusCode == 200)
        console.log(body)
    }
  );
}

// GET examples

get("cmd/startSession");
get("session/latest/meter");
get("session/latest/measurement/start");

// POST examples

var data = { "triggerType" : "Run", "unit" : "SUT", "message": "foo", "type": "trigger" };

post_json("session/latest/trigger", data);
post_json("session/latest/rename", "foobar");

// Requires Java 21+

import java.nio.file.*
import java.net.*
import java.net.http.*
import java.util.zip.*

class GoblinClient(val host: String) {
  private fun run(b: HttpRequest.Builder) =
    HttpClient.newHttpClient().use {
      it.send(
        b.build(),
        HttpResponse.BodyHandlers.ofString()
      )
    }

  private fun api(api: String) =
    HttpRequest.newBuilder(URI.create("http://$host/api/v2/$api"))

  fun get(api: String) = run(api(api))

  fun post(api: String, msg: String) =
    run(api(api).POST(HttpRequest.BodyPublishers.ofString(msg)))

  fun post(api: String, path: Path) =
    run(api(api).POST(HttpRequest.BodyPublishers.ofFile(path)))
}

// --- Examples ---

var c = GoblinClient("localhost:8080")

// GET examples

c.get("cmd/startSession")
c.get("session/latest/meter")
c.get("session/latest/measurement/start")

// POST examples

var data = """
  { "triggerType": "Run", "unit": "SUT", "message": "foo", "type": "trigger" }
"""

c.post("session/latest/trigger", data)
c.post("session/latest/rename", "foobar")
c.post("session/latest/import/collectd", Path.of("collectd.zip"))

# Requires sh, coreutils & gnu-netcat or busybox

msg() {
  echo $* | nc $HOST $PORT
}

# --- Examples ---

# PowerGoblin server
export HOST=localhost
export PORT=9000

msg SESSION METERS
msg MEASUREMENT START starting
msg SESSION SYNC $(date +%s%N)
msg TRIGGER Run,SUT,start
msg SESSION RENAME foobar

# Requires Python 3+

import socket
import time

class GoblinClient:
  def __init__(self, host, port):
    self.host = host
    self.port = port

  def send(self, msg):
    self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    self.socket.connect((self.host, self.port))
    self.socket.sendall(bytes(msg, "utf-8"))
    self.socket.close()

def milli_time():
  return str(round(time.time() * 1000))

# --- Examples ---

c = GoblinClient("localhost", 9000)

c.send("SESSION METERS")
c.send("MEASUREMENT START starting")
c.send("SESSION SYNC " + milli_time())
c.send("TRIGGER Run,SUT,start")
c.send("SESSION RENAME foobar")

// requires Java 21+
import java.net.*;
import java.io.*;

public record GoblinClient(String host, int port) {
  void send(String msg) throws Exception {
    try (
      var s = new Socket(host, port);
      var w = new PrintWriter(s.getOutputStream())
    ) {
      w.println(msg);
    }
  }
}

// --- Examples ---

void main() {
  var c = new GoblinClient("localhost", 9000);

  c.send("SESSION METERS");
  c.send("MEASUREMENT START starting");
  c.send("SESSION SYNC " + System.currentTimeMillis());
  c.send("TRIGGER Run,SUT,start");
  c.send("SESSION RENAME foobar");
}

var net = require('net');

const host = "127.0.0.1";
const port = 9000;

function send(msg) {
  var client = new net.Socket();
  client.connect(port, host, function() {
    client.write(msg);
  });

  client.on('data', function(data) {
    console.log("RESULT: "+data);
    client.destroy();
  });
}

send("SESSION METERS");
send("MEASUREMENT START starting");
send("SESSION SYNC " + System.currentTimeMillis());
send("TRIGGER Run,SUT,start");
send("SESSION RENAME foobar");

// requires Java 21+
import java.net.*
import java.io.*

class GoblinClient(val host: String, val port: int) {
  fun send(msg: String) {
      Socket(host, port).use {
          PrintWriter(it.outputStream).use {
              it.println(msg)
          }
  }
}

// --- Examples ---

var c = GoblinClient("localhost", 9000)

c.send("SESSION METERS")
c.send("MEASUREMENT START starting")
c.send("SESSION SYNC " + System.currentTimeMillis())
c.send("TRIGGER Run,SUT,start")
c.send("SESSION RENAME foobar")