From fa5866ee33d0a9ef8188e0be368b712b363fc370 Mon Sep 17 00:00:00 2001
From: Markus Zolliker <markus.zolliker@psi.ch>
Date: Tue, 20 May 2025 10:12:34 +0200
Subject: [PATCH] change arguments for starting feeder

+ add relative path for servicemanager
---
 feeder.py   | 20 +++++++++-----------
 seinflux.py |  2 +-
 2 files changed, 10 insertions(+), 12 deletions(-)

diff --git a/feeder.py b/feeder.py
index c10974f..d183e3f 100644
--- a/feeder.py
+++ b/feeder.py
@@ -1,21 +1,21 @@
-import sys
+import sys, os
 import socket
 from streams import EventStream
 from nicoscache import NicosStream
 from secop import ScanStream, ScanReply, TrySecopConnect, send_fake_udp
 from seinflux import SEHistory
-from servicemanager import FrappyManager
+from ..servicemanager import FrappyManager
 
 
 USAGE = """
 Usage:
     start server
 
-        python feeder.py [<db instance>]
+        python feeder.py -d [<db instance>]
 
     add a SECoP connection:
 
-        python feeder.py + uri [device] [instrument]
+        python feeder.py uri [device] [instrument]
 """
 
 
@@ -57,12 +57,10 @@ def main(dbname=None):
         db.disconnect()
 
 
-if len(sys.argv) == 2:
-    main(sys.argv[1])
-elif len(sys.argv) > 2:
-    if sys.argv[1] == '+':
-        send_fake_udp(*sys.argv[2:])
+if len(sys.argv) >= 3:
+    if sys.argv[1] == '-d':
+        main(*sys.argv[2:])
     else:
-        print(USAGE)
+        send_fake_udp(*sys.argv[1:])
 else:
-    main()
+    print(USAGE)
diff --git a/seinflux.py b/seinflux.py
index 478f631..d950812 100644
--- a/seinflux.py
+++ b/seinflux.py
@@ -291,7 +291,7 @@ class SEHistory(InfluxDBWrapper):
         by_stream = {}  # dict <stream> of [<ts>, <flag>, <instrument>, <device>]
         for key, table in inperiod.items():
             nextrow = nextrows.get(key)
-            if nextrow and not nextrow[1]:
+            if nextrow and not nextrow[0][1]:
                 table.extend(nextrow)
             stream, instrument, device = [table.tags.get(k, '') for k in ('stream', 'instrument', 'device')]
             elist = by_stream.setdefault(stream, [])