# Requires sh, curl/wget & coreutils

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

# GET requests using curl
msg_get() { 
  curl "http://$HOST/$*"
}

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

# POST requests using curl
msg_post() { 
  curl -d@- "http://$HOST/$*"
}

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

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

# --- Examples ---

# PowerGoblin server
export HOST=localhost:8080

# GET examples

msg_get api/v1/session/meters

msg_get api/v1/measurement/start/TestScenario1

# POST examples

export DATA='{ "triggerType":"Run", "unit":"SUT", "message":"foo", "type":"trigger" }'
echo $DATA | msg_post api/v1/trigger

echo foobar | msg_post api/v1/session/rename

msg_post_file collectd.zip api/v1/import/collectd

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

import requests                                                                                                                          
import json                                                                                                                          

class GoblinClient:
  def __init__(self, host):
    self.host = "http://" + host
 
  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

meters = c.get("api/v1/session/meters")
print(c.interpret(meters))

meters = c.get("api/v1/measurement/start/TestScenario1")

# POST examples

data = { "triggerType":"Run", "unit":"SUT", "message":"foo", "type":"trigger" }
c.post_json("api/v1/trigger", json = data)

c.post_text("api/v1/session/rename", text = "foobar")

c.post_file("api/v1/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));
  }
  
  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("api/v1/session/meters");
  
  c.get("api/v1/measurement/start/TestScenario1");

  // POST examples
            
  var data = "{ \"triggerType\":\"Run\", \"unit\":\"SUT\", \"message\":\"foo\", \"type\":\"trigger\" }";
  c.post("api/v1/trigger", data);

  c.post("api/v1/session/rename", "foobar");
  
  c.post("api/v1/import/collectd", Path.of("collectd.zip"));
}

const request = require('request');

const host = "localhost:8080";

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

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

// GET examples

get("api/v1/session/meters");

get("api/v1/measurement/start/TestScenario1");

// POST examples
  
var data = { "triggerType" : "Run", "unit" : "SUT", "message": "foo", "type": "trigger" };
post_json("api/v1/trigger", data);
  
post_json("api/v1/session/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")))
  
  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("api/v1/session/meters")

c.get("api/v1/measurement/start/TestScenario1")

// POST examples
        
var data = "{ \"triggerType\":\"Run\", \"unit\":\"SUT\", \"message\":\"foo\", \"type\":\"trigger\" }"
c.post("api/v1/trigger", data)

c.post("api/v1/session/rename", "foobar")

c.post("api/v1/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")