Runtime

const http = require('http');
const fs = require('fs');
const path = require('path');

const port = Number(process.env.MYRAX_PLUGIN_PORT);
const dataDir = process.env.MYRAX_PLUGIN_DATA;
const statePath = path.join(dataDir, 'state.json');

function readState() {
  try { return JSON.parse(fs.readFileSync(statePath, 'utf8')); }
  catch { return {}; }
}

function writeState(state) {
  fs.mkdirSync(dataDir, { recursive: true });
  fs.writeFileSync(statePath, JSON.stringify(state), { mode: 0o600 });
}

const server = http.createServer((req, res) => {
  if (req.method === 'GET' && req.url === '/health') {
    res.writeHead(200, { 'content-type': 'application/json' });
    return res.end('{"ok":true}');
  }
  if (req.method === 'GET' && req.url === '/api/state') {
    res.writeHead(200, { 'content-type': 'application/json' });
    return res.end(JSON.stringify(readState()));
  }
  res.writeHead(404, { 'content-type': 'application/json' });
  res.end('{"error":"not found"}');
});

server.listen(port, '127.0.0.1', () => {
  console.log(`listening on ${port}`); // goes to the plugin log
});

process.on('SIGINT', () => server.close(() => process.exit(0)));

package main

import (
	"context"
	"encoding/json"
	"log"
	"net/http"
	"os"
	"os/signal"
	"path/filepath"
)

func main() {
	port := os.Getenv("MYRAX_PLUGIN_PORT")
	dataDir := os.Getenv("MYRAX_PLUGIN_DATA")
	statePath := filepath.Join(dataDir, "state.json")

	mux := http.NewServeMux()
	mux.HandleFunc("GET /health", func(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Content-Type", "application/json")
		w.Write([]byte(`{"ok":true}`))
	})
	mux.HandleFunc("GET /api/state", func(w http.ResponseWriter, r *http.Request) {
		state := map[string]any{}
		if raw, err := os.ReadFile(statePath); err == nil {
			json.Unmarshal(raw, &state)
		}
		w.Header().Set("Content-Type", "application/json")
		json.NewEncoder(w).Encode(state)
	})

	server := &http.Server{Addr: "127.0.0.1:" + port, Handler: mux}

	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
	defer stop()
	go func() {
		<-ctx.Done()
		server.Shutdown(context.Background())
	}()

	log.Printf("listening on %s", port) // goes to the plugin log
	server.ListenAndServe()
}