# Requires curl/wget & coreutils

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

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

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

# --- Example ---

# PowerGoblin server
export HOST=localhost:8080

# GET examples

echo|pg_post session
pg_get session/latest/meter
echo Measurement|pg_post session/latest/trigger
echo name|pg_post session/latest/measurement
echo Run|pg_post session/latest/trigger
echo RunStop|pg_post session/latest/trigger
echo MeasurementStop|pg_post session/latest/trigger
pg_post_file collectd.zip session/latest/import/collectd

# Requires 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"]

# --- Example ---

c = GoblinClient("localhost:8080")

c.post_text("session", "")
meters = c.get("session/latest/meter")
print(c.interpret(meters))

c.post_text("session/latest/trigger", text = "Measurement")
c.post_text("session/latest/measurement", json = "name")
c.post_text("session/latest/trigger", json = "Run")
c.post_text("session/latest/trigger", json = "RunStop")
c.post_text("session/latest/trigger", text = "MeasurementStop")
c.post_file("session/latest/import/collectd", "collectd.zip")

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)));
  }
}

// --- Example ---

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

  c.post("session", "");
  c.get("session/latest/meter");

  c.post("session/latest/trigger", "Measurement");
  c.post("session/latest/measurement", "name");
  c.post("session/latest/trigger", "Run");
  c.post("session/latest/trigger", "RunStop");
  c.post("session/latest/trigger", "MeasurementStop");
  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)
    }
  );
}

// --- Example ---

post("session", "")
get("session/latest/meter")

post("session/latest/trigger", "Measurement")
post("session/latest/measurement", "name")
post("session/latest/trigger", "Run")
post("session/latest/trigger", "RunStop")
post("session/latest/trigger", "MeasurementStop")
post_json("session/latest/rename", "foobar");

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)))
}

// --- Example ---

var c = GoblinClient("localhost:8080")

c.post("session", "")
c.get("session/latest/meter")

c.post("session/latest/trigger", "Measurement")
c.post("session/latest/measurement", "name")
c.post("session/latest/trigger", "Run")
c.post("session/latest/trigger", "RunStop")
c.post("session/latest/trigger", "MeasurementStop")
c.post("session/latest/import/collectd", Path.of("collectd.zip"))

# Requires coreutils & gnu-netcat or busybox

GoblinClient() {
  export HOST=$1
  export PORT=$2
}

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

# --- Example ---

GoblinClient 127.0.0.1 9000

send SESSION latest METER
send SESSION latest MEASUREMENT START algo1
send SESSION latest SYNC $(date +%s%N)
send SESSION latest RUN START
send SESSION latest RUN STOP
send SESSION latest MEASUREMENT STOP
send SESSION latest CLOSE

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("127.0.0.1", 9000)

c.send("SESSION latest METER")
c.send("SESSION latest SYNC " + milli_time())
c.send("SESSION latest MEASUREMENT START algo1")
c.send("SESSION latest RUN START")
c.send("SESSION latest RUN STOP")
c.send("SESSION latest MEASUREMENT STOP")
c.send("SESSION latest CLOSE")

import java.io.PrintWriter;

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

// --- Example ---

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

  c.send("SESSION latest METER");
    c.send("SESSION latest SYNC " + System.currentTimeMillis());
  c.send("SESSION latest MEASUREMENT START algo1");
  c.send("SESSION latest RUN START");
  c.send("SESSION latest RUN STOP");
  c.send("SESSION latest MEASUREMENT STOP");
  c.send("SESSION latest CLOSE");
}

var net = require('net');

const GoblinClient = (host, port) => ({
    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();
        });
    }
});

// --- Example ---

var c = GoblinClient("127.0.0.1", 9000);

c.send("SESSION latest METER");
c.send("SESSION latest SYNC " + Date.now());
c.send("SESSION latest MEASUREMENT START algo1");
c.send("SESSION latest RUN START");
c.send("SESSION latest RUN STOP");
c.send("SESSION latest MEASUREMENT STOP");
c.send("SESSION latest CLOSE");

class GoblinClient(val host: String, val port: Int) {
  fun send(msg: String) =
    java.net.Socket(host, port).use {
      java.io.PrintWriter(it.outputStream).use {
        it.println(msg)
      }
  }
}

// --- Example ---

val c = GoblinClient("127.0.0.1", 9000)

c.send("SESSION latest METER")
c.send("SESSION latest SYNC " + System.currentTimeMillis())
c.send("SESSION latest MEASUREMENT START algo1")
c.send("SESSION latest RUN START")
c.send("SESSION latest RUN STOP")
c.send("SESSION latest MEASUREMENT STOP")
c.send("SESSION latest CLOSE")