5: JupiterPerpsAlarm should be able to alarm on price 0

4: Change datatype of severity field and parsing
4: Add new AlarmSeverity enum
2026-06-19 12:28:06 +02:00 · 2026-06-19 12:28:06 +02:00 · 2026-06-19 11:55:29 +02:00 · 2026-06-19 11:00:59 +02:00 · 2026-06-19 10:57:55 +02:00 · 2026-06-19 10:41:18 +02:00
16 changed files with 92 additions and 184 deletions
@@ -1,4 +1,4 @@
 # Asset   Direction   Target    TRIGGER   SEVERITY   NOTE
 #############################################################
-SOL       BELOW       70.0      ONETIME   2          "ALARM: Risiko for Perps Solana long LIKVIDERING!"
-SOL       BELOW       71.4      ONETIME   2          "ALARM: Risiko for Solana Raydium LÅN LIKVIDERING!"
+SOL       BELOW       170.0      ONETIME   CRITICAL  "EMERGENCY: Risiko for Perps Solana long LIKVIDERING!"
+#SOL       BELOW       71.4      ONETIME   CRITICAL   "CRITICAL: Risiko for Solana Raydium LÅN LIKVIDERING!"
@@ -1,59 +0,0 @@
-#!/usr/bin/env bash
-set -euo pipefail
-
-JREVERSION=25.0.2-0
-
-export VERSION=$(git describe --tags --exact-match 2>/dev/null \
-  || git symbolic-ref --short -q HEAD \
-  || git rev-parse --short HEAD)
-
-GITHASH=$(git rev-parse --short=8 HEAD)
-
-echo "Preparing Docker image for '${VERSION}'..."
-
-mkdir -p build/docker/{conf,libs}
-
-cp src/main/docker/run.sh build/docker/run.sh
-cp libs/*.jar build/docker/libs/
-cp conf/* build/docker/conf/
-
-sed \
-    -e "s|_VERSION_|${VERSION}|g" \
-    -e "s|_JREVERSION_|${JREVERSION}|g" \
-    src/main/docker/Dockerfile_template \
-    > build/docker/Dockerfile
-
-GROUP=r35157
-NAME=nenjimhub
-
-BASETAG=dockerreg.r35157.com/${GROUP}/${NAME}
-
-HASHTAG=${BASETAG}:${GITHASH}_amd64
-VERSIONTAG=${BASETAG}:${VERSION}_amd64
-LATESTTAG=${BASETAG}:latest_amd64
-
-echo "Building ${HASHTAG}..."
-
-docker buildx build \
-    --load \
-    -t ${HASHTAG} \
-    build/docker
-
-docker tag ${HASHTAG} ${VERSIONTAG}
-docker tag ${HASHTAG} ${LATESTTAG}
-
-sed \
-    -e "s|_HASHTAG_|${HASHTAG}|g" \
-    -e "s|_VERSIONTAG_|${VERSIONTAG}|g" \
-    -e "s|_LATESTTAG_|${LATESTTAG}|g" \
-    src/main/docker/publish_template.sh \
-    > build/docker/publish.sh
-
-chmod 755 build/docker/publish.sh
-
-echo ""
-echo "Docker image ready:"
-echo "  ${HASHTAG}"
-echo "  ${VERSIONTAG}"
-echo "  ${LATESTTAG}"
-
@@ -5,10 +5,5 @@ export VERSION=$(git describe --tags --exact-match 2>/dev/null \
  || git symbolic-ref --short -q HEAD \
  || git rev-parse --short HEAD)

-./docker.sh
-
 echo "Publishing artifact to local Maven repo ($VERSION)..."
 ./gradlew -Pversion=$VERSION publishToMavenLocal
-
-echo "Publishing docker container to public 'dockerreg.r35157.com' ($VERSION)..."
-./build/docker/publish.sh
@@ -1 +0,0 @@
-src/main/docker/run.sh
@@ -0,0 +1,18 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+shopt -s nullglob
+
+jars=(libs/*.jar)
+if (( ${#jars[@]} == 0 )); then
+  echo "ERROR: No JARs found in libs/" >&2
+  exit 1
+fi
+
+CLASSPATH=$(IFS=:; echo "${jars[*]}")
+
+exec java \
+  --enable-preview \
+  -Dlog4j.configurationFile=conf/log4j2.xml \
+  -cp "$CLASSPATH" \
+  com.r35157.nenjim.hubd.impl.ref.Main
@@ -1,43 +0,0 @@
-FROM dockerreg.r35157.com/r35157/jre:_JREVERSION__amd64
-
-LABEL maintainer="Minimons <minimons@r35157.com>"
-
-# Setup environment
-ENV APP_HOME=/usr/local/software/nenjimhub
-WORKDIR /usr/local/software
-USER root
-
-RUN mkdir nenjimhub-_VERSION_ \
-    && ln -s nenjimhub-_VERSION_ nenjimhub
-WORKDIR nenjimhub
-RUN mkdir libs
-
-# These dirs are expected to be overshadowed by host mounts
-RUN mkdir conf logs && chown user:user logs
-
-# Set timezone
-ENV TZ=Europe/Copenhagen
-RUN apt-get update
-RUN apt-get install -y tzdata \
-    && ln -snf /usr/share/zoneinfo/$TZ /etc/localtime \
-    && echo $TZ > /etc/timezone \
-    && dpkg-reconfigure -f noninteractive tzdata
-
-# Clean-up
-RUN apt-get autoremove -y \
-    && apt-get clean \
-    && rm -rf /var/lib/apt/lists/*
-
-# Install application and configuration (Do this as late as possible to be able to reuse layers between builds)
-COPY run.sh .
-COPY conf/* conf/
-COPY libs/*.jar libs/
-
-RUN chown root:root -R conf
-RUN chmod 755 ./run.sh \
-    && chmod -R a+rX /usr/local/software/nenjimhub-_VERSION_
-
-USER user:user
-
-CMD ["./run.sh"]
-
@@ -1,9 +0,0 @@
-#!/usr/bin/env bash
-set -euo pipefail
-
-echo "Publishing '_HASHTAG_', '_VERSIONTAG_' and '_LATESTTAG_'..."
-docker push _HASHTAG_
-docker push _VERSIONTAG_
-docker push _LATESTTAG_
-
-echo "Publishing completed!"
@@ -1,18 +0,0 @@
-#!/usr/bin/env bash
-set -euo pipefail
-
-shopt -s nullglob
-
-jars=(libs/*.jar)
-if (( ${#jars[@]} == 0 )); then
-  echo "ERROR: No JARs found in libs/" >&2
-  exit 1
-fi
-
-CLASSPATH=$(IFS=:; echo "${jars[*]}")
-
-exec java \
-  --enable-preview \
-  -Dlog4j.configurationFile=conf/log4j2.xml \
-  -cp "$CLASSPATH" \
-  com.r35157.nenjim.hubd.impl.ref.Main
@@ -1,19 +0,0 @@
-version: '3.9'
-
-services:
-  nenjimhub:
-    hostname: nenjimhub
-    image: dockerreg.r35157.com/r35157/nenjimhub:latest
-    deploy:
-      replicas: 1
-      resources:
-        limits:
-          memory: 128m
-      restart_policy:
-        condition: any
-        delay: 5s
-        max_attempts: 3
-        window: 120s
-    volumes:
-      - /home/op/nenjimhub/conf:/usr/local/software/nenjimhub/conf
-      - /home/op/nenjimhub/logs:/usr/local/software/nenjimhub/logs
@@ -1,3 +0,0 @@
-#!/bin/bash
-
-docker stack deploy --compose-file /home/op/stack.yml stack --detach=true
@@ -0,0 +1,9 @@
+package com.r35157.jupiterperpsalarm;
+
+public enum AlarmSeverity {
+    EMERGENCY,  // Repeated wake-up alarm
+    CRITICAL,   // One-shot wake-up alarm
+    WARN,       // Audible warning respecting quiet hours
+    INFO,       // Low-priority visible notification
+    SILENT      // No user interruption
+}
@@ -1,5 +1,7 @@
 package com.r35157.jupiterperpsalarm.impl.ref;

+import com.r35157.jupiterperpsalarm.AlarmSeverity;
+
 import java.io.IOException;
 import java.math.BigDecimal;
 import java.nio.file.Files;
@@ -44,15 +46,21 @@ public final class AlarmConfigurationParser {
        JupiterPerpsAsset asset = JupiterPerpsAsset.valueOf(
                cursor.nextToken("asset").toUpperCase(Locale.ROOT)
        );
+
        PriceDirection direction = PriceDirection.valueOf(
                cursor.nextToken("direction").toUpperCase(Locale.ROOT)
        );

        BigDecimal target = new BigDecimal(cursor.nextToken("target"));
+
        AlarmTrigger trigger = AlarmTrigger.valueOf(
                cursor.nextToken("trigger").toUpperCase(Locale.ROOT)
        );
-        int severity = Integer.parseInt(cursor.nextToken("severity"));
+
+        AlarmSeverity severity = AlarmSeverity.valueOf(
+                cursor.nextToken("severity").toUpperCase()
+        );
+
        String note = cursor.nextQuotedString("note");

        cursor.skipWhitespace();
@@ -16,10 +16,9 @@ public final class JupiterPerpsAlarmImpl {
        try {
            config = Config.parse(args, System.getenv());
        } catch (IllegalArgumentException exception) {
-            System.err.println(exception.getMessage());
            printUsage();
-            System.exit(2);
-            return;
+            String errMsg = "Could not parse configuration for JupiterPerpsAlarm: " + exception.getMessage() + "!";
+            throw new IllegalStateException(errMsg, exception);
        }

        if (config.selfTest()) {
@@ -32,9 +31,8 @@ public final class JupiterPerpsAlarmImpl {
        try {
            definitions = AlarmConfigurationParser.parse(config.alarmConfiguration());
        } catch (Exception exception) {
-            System.err.println("Could not load alarm configuration: " + exception.getMessage());
-            System.exit(2);
-            return;
+            String errMsg = "Could not load alarm configuration: " + exception.getMessage() + "!";
+            throw new IllegalStateException(errMsg, exception);
        }

        List<AlarmAction> actions = new ArrayList<>();
@@ -91,7 +89,7 @@ public final class JupiterPerpsAlarmImpl {
                    asset.oracleAccount()
            );
            assetDefinitions.forEach(definition -> System.out.printf(
-                    "    %s %s USD, %s, severity=%d%n",
+                    "    %s %s USD, %s, severity=%s%n",
                    definition.direction(),
                    definition.target().toPlainString(),
                    definition.trigger(),
@@ -1,5 +1,7 @@
 package com.r35157.jupiterperpsalarm.impl.ref;

+import com.r35157.jupiterperpsalarm.AlarmSeverity;
+
 import java.math.BigDecimal;
 import java.util.Objects;

@@ -8,7 +10,7 @@ public record PriceAlarmDefinition(
        PriceDirection direction,
        BigDecimal target,
        AlarmTrigger trigger,
-        int severity,
+        AlarmSeverity severity,
        String note
 ) {
    public PriceAlarmDefinition {
@@ -18,11 +20,9 @@ public record PriceAlarmDefinition(
        Objects.requireNonNull(trigger, "trigger");
        Objects.requireNonNull(note, "note");

+        // TODO: https://git.r35157.com/r35157/com_r35157_nenjim-hubd-impl_ref/issues/5
        if (target.signum() <= 0) {
            throw new IllegalArgumentException("Target price must be positive");
        }
-        if (severity < 0) {
-            throw new IllegalArgumentException("Severity must be zero or positive");
-        }
    }
 }
@@ -1,5 +1,7 @@
 package com.r35157.jupiterperpsalarm.impl.ref;

+import com.r35157.jupiterperpsalarm.AlarmSeverity;
+
 import java.math.BigDecimal;
 import java.time.Instant;
 import java.util.ArrayList;
@@ -17,14 +19,14 @@ public final class SelfTest {

    private static void configurationParserTest() {
        PriceAlarmDefinition alarm = AlarmConfigurationParser.parseLine(
-                "SOL ABOVE 75.7 ONETIME 2 \"ALARM: Risiko for likvidering!\""
+                "SOL ABOVE 75.7 ONETIME CRITICAL \"ALARM: Risiko for likvidering!\""
        );

        require(alarm.asset() == JupiterPerpsAsset.SOL, "Asset parsing failed");
        require(alarm.direction() == PriceDirection.ABOVE, "Direction parsing failed");
        require(alarm.target().compareTo(new BigDecimal("75.7")) == 0, "Target parsing failed");
        require(alarm.trigger() == AlarmTrigger.ONETIME, "Trigger parsing failed");
-        require(alarm.severity() == 2, "Severity parsing failed");
+        require(alarm.severity() == AlarmSeverity.CRITICAL, "Severity parsing failed");
        require(alarm.note().equals("ALARM: Risiko for likvidering!"), "Note parsing failed");
    }

@@ -89,7 +91,7 @@ public final class SelfTest {
                direction,
                new BigDecimal(target),
                trigger,
-                2,
+                AlarmSeverity.CRITICAL,
                "ignored for now"
        );
    }
@@ -14,8 +14,11 @@ import java.nio.file.Files;
 import java.nio.file.Path;

 public class Main {
+
+    // TODO: Consider if we really need a Main class or we just need to move the main method to NenjimHubImpl?
    static void main(String[] args) throws Exception {
-        NenjimHub nenjimHub = new NenjimHubImpl();
+        NenjimHubImpl nenjimHub = new NenjimHubImpl();
+        nenjimHub.awaitShutdown();

        /*        try {
            log.info("Auto-starting 2 Nenjim application(s)...");
@@ -1,5 +1,6 @@
 package com.r35157.nenjim.hubd.impl.ref;

+import com.r35157.jupiterperpsalarm.impl.ref.JupiterPerpsAlarmImpl;
 import com.r35157.nenjim.hubd.NenjimHub;
 import com.r35157.nenjim.hubd.journal.Journal;
 import crypto.r35157.nenjim.NenjimProcess;
@@ -8,6 +9,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

 import java.util.HashMap;
+import java.util.concurrent.CountDownLatch;

 public class NenjimHubImpl implements NenjimHub {
    public NenjimHubImpl() throws Exception {
@@ -38,19 +40,24 @@ public class NenjimHubImpl implements NenjimHub {
    }

    private void startAutoRunProcesses() throws Exception {
-        String[] processesToAutoStart = {
+        startJupiterPerpsAlarm();   // TODO: Hardcoded/hacky way to auto-start but good enough for now.

-                "crypto.r35157.nenjim.NenjimHubSocketAdminAdapter",
-                "crypto.r35157.nenjim.NenjimHubRestAdminAdapter",
-                "crypto.r35157.nenjim.NenjimHubRPCAdminAdapter",
-                "crypto.r35157.nenjim.SuwimoHub",
-                "crypto.r35157.nenjim.SodaTaskManager",
-                "crypto.r35157.assetaz.hub.AssetAZHub"
+        // TODO: Old but more correct way to auto start plugins - but it is currently broken.
+        /*
+        String[] processesToAutoStart = {
+                //"com.r35157.jupiterperpsalarm.impl.ref.JupiterPerpsAlarmImpl"
+                //"crypto.r35157.nenjim.NenjimHubSocketAdminAdapter",
+                //"crypto.r35157.nenjim.NenjimHubRestAdminAdapter",
+                //"crypto.r35157.nenjim.NenjimHubRPCAdminAdapter",
+                //"crypto.r35157.nenjim.SuwimoHub",
+                //"crypto.r35157.nenjim.SodaTaskManager",
+                //"crypto.r35157.assetaz.hub.AssetAZHub"
        };

        for (String processInterfaceName : processesToAutoStart) {
            startProcess(processInterfaceName);
        }
+        */
    }

    @Override
@@ -90,7 +97,27 @@ public class NenjimHubImpl implements NenjimHub {
        System.out.println("NenjimHub command: 'noop'");
    }

+    public void awaitShutdown() throws InterruptedException {
+        shutdownLatch.await();
+    }
+
+    private void startJupiterPerpsAlarm() {
+        Thread thread = new Thread(() -> {
+            try {
+                JupiterPerpsAlarmImpl.main(new String[] {
+                        "--config=conf/alarms.conf"
+                });
+            } catch (Throwable throwable) {
+                throwable.printStackTrace();
+            }
+        }, "Nenjim Plugin - JupiterPerpsAlarm");
+
+        thread.setDaemon(false);
+        thread.start();
+    }
+
    private static final Logger log = LoggerFactory.getLogger(NenjimHubImpl.class);
+    private final CountDownLatch shutdownLatch = new CountDownLatch(1);

    private HashMap<Integer, NenjimProcess> processes;
    //private StructuredTaskScope.ShutdownOnFailure processesScope;
Author	SHA256	Message	Date
minimons	7d44edb186	5: JupiterPerpsAlarm should be able to alarm on price 0	2026-06-19 12:28:06 +02:00
minimons	c45fd72b4b	4: Change datatype of severity field and parsing	2026-06-19 12:28:06 +02:00
minimons	dc82a5f684	4: Add new AlarmSeverity enum	2026-06-19 11:55:29 +02:00
minimons	55cdec29f4	3: Remove docker files and build support	2026-06-19 11:00:59 +02:00
minimons	87e2b00c61	3: Move run.sh out of docker directory	2026-06-19 10:57:55 +02:00
minimons	ab67f93aa0	2: Autostart JupiterPerpsAlarmImpl from NenjimHub using a named platform thread.	2026-06-19 10:41:18 +02:00
minimons	75cd15a20c	2: Swap System.exit from JupiterPerpsAlarmImpl with thrown exceptions	2026-06-19 09:52:24 +02:00
minimons	992c2ca860	2: Disable old autostart plugins	2026-06-19 09:52:24 +02:00