use kubectl, fix 2

.gitignore

@@ -6,5 +6,6 @@ cube/pubsubc.a
 test
 .bash_history
 .vscode
-
+.dccache
+sink/.dccache
 

.gitlab-ci.yml

@@ -1,36 +1,55 @@
 stages:
-    - check
     - build
     - deploy
 
-include:
-    - project: dockerized/commons
-      ref: master
-      file: gitlab-ci-template.yml
+variables:
+        IMAGE_NAME: $CI_REGISTRY/$CI_PROJECT_PATH
+        HUB_IMAGE_NAME: wollud1969/sinkserver
 
-deploy:
+build:
     image: registry.hottis.de/dockerized/docker-bash:latest
-    stage: deploy
+    stage: build
     tags:
         - hottis
         - linux
         - docker
-    only:
-        - tags
-    variables:
-        GIT_STRATEGY: none
-        CONTAINER_NAME: sink
-    script:
-        - docker stop $CONTAINER_NAME || echo "container not running, never mind"
-        - docker rm $CONTAINER_NAME || echo "container not existing, never mind"
-        - docker run 
-          -d 
-          --network docker-server 
-          --ip 172.16.10.42 
-          -v sink_config:/etc/sink 
-          --name $CONTAINER_NAME 
-          --restart always 
-          $IMAGE_NAME:$CI_COMMIT_TAG
-    environment:
-        name: production
+    script: 
+        - docker build --build-arg="VERSION=${CI_COMMIT_SHORT_SHA}-${CI_COMMIT_TAG}" --tag $IMAGE_NAME:${CI_COMMIT_SHORT_SHA} .
+        - docker login -u gitlab-ci-token -p $CI_JOB_TOKEN $CI_REGISTRY;
+        - docker push $IMAGE_NAME:${CI_COMMIT_SHORT_SHA}
+        - if [ "$CI_COMMIT_TAG" != "" ]; then
+            docker tag $IMAGE_NAME:${CI_COMMIT_SHORT_SHA} $IMAGE_NAME:${CI_COMMIT_TAG};
+            docker push $IMAGE_NAME:${CI_COMMIT_TAG};
+          fi
+        - docker login -u $DOCKER_HUB_LOGIN -p $DOCKER_HUB_PASSWORD
+        - docker tag $IMAGE_NAME:${CI_COMMIT_SHORT_SHA} ${HUB_IMAGE_NAME}:${CI_COMMIT_SHORT_SHA}
+        - docker push ${HUB_IMAGE_NAME}:${CI_COMMIT_SHORT_SHA}
+
+
+# deploy:
+#    image: registry.hottis.de/dockerized/docker-bash:latest
+#    stage: deploy
+#    tags:
+#        - hottis
+#        - linux
+#        - docker
+#    only:
+#        - tags
+#    variables:
+#        GIT_STRATEGY: none
+#        CONTAINER_NAME: sink
+#    script:
+#        - docker stop $CONTAINER_NAME || echo "container not running, never mind"
+#        - docker rm $CONTAINER_NAME || echo "container not existing, never mind"
+#        - docker run 
+#          -d 
+#          --network docker-server 
+#          --ip 172.16.10.42 
+#          -v sink_config:/etc/sink 
+#          --name $CONTAINER_NAME 
+#          --restart always 
+#          $IMAGE_NAME:$CI_COMMIT_TAG
+#    environment:
+#        name: production
+
 

.woodpecker.yml

@@ -0,0 +1,25 @@
+steps:
+  build:
+    image: plugins/kaniko
+    settings:
+      repo: gitea.hottis.de/${CI_REPO}
+      registry: https://gitea.hottis.de/v2/
+      tags: latest,${CI_COMMIT_SHA},${CI_COMMIT_TAG}
+      username: 
+        from_secret: system_container_registry_username
+      password: 
+        from_secret: system_container_registry_password
+      dockerfile: Dockerfile
+
+  deploy:
+    image: portainer/kubectl-shell:latest
+    secrets:
+      - source: kube_config
+        target: KUBE_CONFIG_CONTENT
+    commands:
+      - printf "$KUBE_CONFIG_CONTENT" > ~/kubeconfig
+      - KUBECONFIG=~/kubeconfig
+      - kubectl get nodes
+    when:
+      - event: tag
+

Dockerfile

@@ -1,4 +1,4 @@
-FROM alpine:3.13 AS builder
+FROM alpine:3.18.3 AS builder
 
 ARG VERSION="dockerized"
 
@@ -7,26 +7,30 @@ COPY sink/ /tmp/sink
 RUN \
   apk update && \
   apk add alpine-sdk && \
-  apk add libconfig-dev && \
   apk add postgresql-dev && \
   cd /tmp/sink && \
   make VERSION=${VERSION}
 
 
-FROM alpine:3.13
+FROM alpine:3.18.3
+
+ENV PGHOST=""
+ENV PGDATABASE="mainscnt"
+ENV PGUSER="sink"
+ENV PGPASSWORD=""
+ENV PGSSLMODE="require"
+ENV LOWER_BOUND="44000"
+ENV UPPER_BOUND="56000"
 
 COPY --from=builder /tmp/sink/build/sink20169 /usr/local/bin/
 
 RUN \
-  apk add --no-cache libpq && \
-  apk add --no-cache libconfig && \
-  mkdir /etc/sink
+  apk add --no-cache libpq 
 
 EXPOSE 20169/udp
+USER nobody
 
-VOLUME /etc/sink
-
-CMD [ "/usr/local/bin/sink20169", "-f", "/etc/sink/sink20169.cfg", "-n", "nobody", "-v" ]
+CMD [ "/usr/local/bin/sink20169", "-v", "-d" ]
 
   
 

deployment/deploy.yml

@@ -0,0 +1,50 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: sinkserver
+  namespace: mainscnt
+  labels:
+    app: sinkserver
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: sinkserver
+  template:
+    metadata:
+      labels:
+        app: sinkserver
+    spec:
+      containers:
+        - name: sinkserver
+          image: wollud1969/sinkserver:e5f9d3e3
+          ports:
+            - containerPort: 20169
+              protocol: UDP
+          env:
+            - name: PGHOST
+              valueFrom: 
+                configMapKeyRef:
+                  name: sinkserver-config
+                  key: dbhost
+            - name: PGPASSWORD
+              valueFrom:
+                secretKeyRef:
+                  name: sinkserver-secret
+                  key: dbpass
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: sinkserver
+  namespace: mainscnt
+  labels:
+    app: sinkserver
+spec:
+  type: LoadBalancer
+  selector:
+    app: sinkserver
+  ports:
+    - protocol: UDP
+      port: 20169
+      targetPort: 20169

readme.md

@@ -32,3 +32,4 @@ Measurement is visualized at https://grafana.mainscnt.eu.
 The projects of the three current variants are at [RPi](https://home.hottis.de/gitlab/wolutator/mains-frequency-counter-rpi), [STM32](https://home.hottis.de/gitlab/wolutator/mains-frequency-counter-stm32) and [ESP32](https://home.hottis.de/gitlab/wolutator/mains-frequency-counter-esp32).
 
 
+

schema/create.sql

@@ -0,0 +1,30 @@
+create sequence device_s;
+
+CREATE TABLE device_t (
+    id integer DEFAULT nextval('device_s') NOT NULL,
+    deviceid character varying(64) NOT NULL,
+    sharedsecret character varying(31) NOT NULL,
+    location character varying(128) NOT NULL,
+    active boolean DEFAULT false NOT NULL,
+    contact character varying(128),
+    flaky boolean DEFAULT false NOT NULL,
+    CONSTRAINT device_t_sharedsecret_check CHECK ((char_length((sharedsecret)::text) = 31))
+);
+
+ALTER TABLE ONLY device_t
+    ADD CONSTRAINT device_t_deviceid_key UNIQUE (deviceid);
+
+ALTER TABLE ONLY device_t
+    ADD CONSTRAINT device_t_pkey PRIMARY KEY (id);
+
+CREATE TABLE mainsfrequency (
+    "time" timestamp without time zone NOT NULL,
+    host text,
+    location text,
+    freq double precision,
+    valid smallint DEFAULT 1 NOT NULL
+);
+
+select create_hypertable('mainsfrequency', 'time');
+
+

sink/Makefile

@@ -9,10 +9,10 @@ VERSION ?= $(shell git rev-parse --short=8 HEAD)
 UNAME_S := $(shell uname -s)
 
 CC = gcc
-CFLAGS = $(shell pkg-config --cflags libpq libconfig) -I. \
+CFLAGS = $(shell pkg-config --cflags libpq) -I. \
          -Wall -Werror -std=c99 \
 		 -D$(UNAME_S)=1 -DVERSION="\"$(VERSION)\""
-LDFLAGS = $(shell pkg-config --libs libpq libconfig)
+LDFLAGS = $(shell pkg-config --libs libpq)
 TARGET = sink20169
 
 all: $(BUILD_DIR)/$(TARGET)

sink/sink20169.c

@@ -17,14 +17,12 @@
 #include <string.h>
 #include <getopt.h>
 #include <pwd.h>
-#include <libconfig.h>
 #include <libpq-fe.h>
 #include <sinkStruct.h>
 #include <logging.h>
 #include <sha256.h>
 
 
-const char DEFAULT_CONFIG_FILENAME[] = "./sink20169.cfg";
 
 typedef struct {
     const char *deviceId;
@@ -34,20 +32,12 @@ typedef struct {
     PGresult *deviceResult;
 } t_device;
 
-typedef struct {
-    config_t cfg;
-    uint16_t numOfDevices;
-    t_device *devices;    
-} t_configHandle;
-
 #define NUM_OF_STMT_PARAMS 4
 
 typedef struct {
-    t_configHandle *configHandle;
     int receiveSockFd;
     int32_t lowerBound;
     int32_t upperBound;
-    const char *postgresqlConnInfo;
     PGconn *conn;
     t_device foundDevice;
 } t_commonHandle;
@@ -61,7 +51,7 @@ int openDatabaseConnection(t_commonHandle *handle) {
     
     if (! handle->conn) {
         logmsg(LOG_DEBUG, "Opening connection to database");
-        handle->conn = PQconnectdb(handle->postgresqlConnInfo);
+        handle->conn = PQconnectdb("");
     } else if (PQstatus(handle->conn) != CONNECTION_OK) {
         logmsg(LOG_DEBUG, "Resetting connection to database");
         PQreset(handle->conn);
@@ -75,22 +65,6 @@ int openDatabaseConnection(t_commonHandle *handle) {
     return res;
 }
 
-int initConfig(const char *configFilename, t_configHandle *configHandle) {
-    config_init(&(configHandle->cfg));
-    if (! config_read_file(&(configHandle->cfg), configFilename)) {
-        logmsg(LOG_ERR, "failed to read config file: %s:%d - %s\n",
-            config_error_file(&(configHandle->cfg)), config_error_line(&(configHandle->cfg)),
-            config_error_text(&(configHandle->cfg)));
-        config_destroy(&(configHandle->cfg));
-        return -1;
-    }
-
-    return 0;
-}
-
-void deinitConfig(t_configHandle *configHandle) {
-    config_destroy(&(configHandle->cfg));
-}
 
 // When you got a result here, remember to free it using freeDevice
 int findDevice(t_commonHandle *handle, char *deviceId) {
@@ -154,9 +128,7 @@ void freeDevice(t_commonHandle *handle) {
     }
 }
 
-int initReceiver(t_configHandle *configHandle, t_commonHandle *handle) {
-    handle->configHandle = configHandle;
-
+int initReceiver(t_commonHandle *handle) {
     struct sockaddr_in servaddr;
 
     handle->receiveSockFd = socket(AF_INET, SOCK_DGRAM, 0);
@@ -166,11 +138,6 @@ int initReceiver(t_configHandle *configHandle, t_commonHandle *handle) {
     }
 
     int receivePort = 20169;
-    config_lookup_int(&(configHandle->cfg), "receivePort", &receivePort);
-    if (receivePort < 1 || receivePort > 65535) {
-        logmsg(LOG_ERR, "illegal receive port configured");
-        return -2;
-    }
 
     memset(&servaddr, 0, sizeof(servaddr));
     servaddr.sin_family = AF_INET;
@@ -231,22 +198,13 @@ int receiveAndVerifyMinuteBuffer(t_commonHandle *handle, t_minuteBuffer *buf) {
 }
 
 
-int initForwarder(t_configHandle *configHandle, t_commonHandle *handle) {
-    handle->configHandle = configHandle;
-
-    handle->postgresqlConnInfo = NULL;
-    config_lookup_string(&(configHandle->cfg), "postgresqlConnInfo", &(handle->postgresqlConnInfo));
-    if (! handle->postgresqlConnInfo) {
-        logmsg(LOG_ERR, "no postgresql connInfo configured");
-        return -1;
-    }
-
+int initForwarder(t_commonHandle *handle) {
     handle->conn = NULL;
 
-    handle->lowerBound = 45000;
-    config_lookup_int(&(configHandle->cfg), "lowerBound", &(handle->lowerBound));
-    handle->upperBound = 55000;
-    config_lookup_int(&(configHandle->cfg), "upperBound", &(handle->upperBound));
+    char *lowerBoundStr = getenv("LOWER_BOUND");
+    handle->lowerBound = lowerBoundStr ? strtol(lowerBoundStr, NULL, 10) : 45000;
+    char *upperBoundStr = getenv("UPPER_BOUND");
+    handle->upperBound = upperBoundStr ? strtol(upperBoundStr, NULL, 10) : 55000;
     logmsg(LOG_INFO, "lowerBound: %u, upperBound: %u", handle->lowerBound, handle->upperBound);
 
     return 0;
@@ -357,21 +315,16 @@ void usage() {
 }
 
 int main(int argc, char **argv) {
-    t_configHandle configHandle;
     t_commonHandle commonHandle;
     commonHandle.foundDevice.deviceResult = NULL;
 
 
-    const char *configFilename = DEFAULT_CONFIG_FILENAME;
     const char *dropPrivilegesToUser = NULL;
     bool doFork = false;
 
     int c;
-    while ((c = getopt(argc, argv, "f:vds:hn:b")) != -1) {
+    while ((c = getopt(argc, argv, "vds:hn:b")) != -1) {
         switch (c) {
-            case 'f':
-                configFilename = strdup(optarg);
-                break;
             case 'v':
                 verbose = true;
                 break;
@@ -410,11 +363,6 @@ int main(int argc, char **argv) {
 
     logmsg(LOG_INFO, "Version: " VERSION);
 
-    if (0 != initConfig(configFilename, &configHandle)) {
-        logmsg(LOG_ERR, "error when reading configuration");
-        exit(3);
-    }
-    
     if (doFork) {
         int pid = fork();
         if (pid == -1) {
@@ -427,12 +375,12 @@ int main(int argc, char **argv) {
         }
     }
 
-    if (0 != initReceiver(&configHandle, &commonHandle)) {
+    if (0 != initReceiver(&commonHandle)) {
         logmsg(LOG_ERR, "error when initializing receiver");
         exit(5);
     }
 
-    if (0 != initForwarder(&configHandle, &commonHandle)) {
+    if (0 != initForwarder(&commonHandle)) {
         logmsg(LOG_ERR, "error when initializing forwarder");
         exit(6);
     }
@@ -458,5 +406,4 @@ int main(int argc, char **argv) {
 
     deinitForwarder(&commonHandle);
     deinitReceiver(&commonHandle);
-    deinitConfig(&configHandle);
 }

sink/sink20169.cfg

@@ -1,7 +0,0 @@
-postgresqlConnInfo = "host=172.16.3.32 dbname=mainscnt user=sink password=test123";
-
-lowerBound = 45000;
-upperBound = 55000;
-
-receivePort = 20169;
-