Changeset 19564

Timestamp:

07/19/19 19:25:26 (5 years ago)

Author:

tbretz

Message:

Make an entry in the Alert DB if a broken GCN package is received (broken means different formatting than what we expect)

File:

• trunk/FACT++/src/gcn.cc (modified) (12 diffs)

trunk/FACT++/src/gcn.cc

@@ -1 +1 @@
 #include <functional>
 #include <boost/algorithm/string/join.hpp>
+
+#include "Database.h"
 
 #include "Dim.h"
@@ -41 +43 @@
     bool fDebugRx;
 
+    string fUri;
+
     uint32_t     fRxSize;
     vector<char> fRxData;
@@ -79 +83 @@
     {
         if (root.isNull())
-            return -1;
+            return -255;
 
         const string role = root.attribute("role", "").toStdString();
@@ -93 +97 @@
                 const QDomElement time = root.firstChildElement("TimeStamp");
                 if (orig.isNull() || time.isNull())
-                    return -1;
+                    return -254;
 
                 fLastKeepAlive = Time(time.text().toStdString());
@@ -126 +130 @@
             //const QDomElement ref  = root.firstChildElement("Reference");
             if (who.isNull() || what.isNull() || when.isNull())
-                return -1;
+                return -253;
 
             const auto ptype = GetType(what);
@@ -149 +153 @@
 
             const auto &id = ptype->first;
+
+            if (id==0)
+            {
+                Warn("Packet ID = 0");
+                return -252;
+            }
 
             // Gravitational wave event
@@ -187 +197 @@
             {
                 Warn("Missing elements: "+boost::algorithm::join(missing, ", "));
-                return -1;
+                return -id;
             }
 
@@ -468 +478 @@
             Out() << fRxData.data() << '\n';
             Out() << "------------------------------------------------------" << endl;
-            PostClose(false);
+            PostClose(true);
             return;
         }
@@ -482 +492 @@
             Out() << fRxData.data() << '\n';
             Out() << "------------------------------------------------------" << endl;
-            PostClose(false);
+            //PostClose(false);
+
+            try
+            {
+                auto db = Database(fUri);
+
+                // Make an entry in the alter databse to issue a call
+                const string query =
+                    "INSERT FlareTriggers SET\n"
+                    " fTriggerInserted=Now(),\n"
+                    " fNight="+to_string(Time().NightAsInt())+",\n"
+                    " fRunID="+to_string(-rc)+",\n"
+                    " fTriggerType=8";
+
+                auto q = db.query(query);
+                q.execute();
+                if (!q.info().empty())
+                    Info(q.info());
+            }
+            catch (const mysqlpp::ConnectionFailed &e)
+            {
+                Error(e.what());
+            }
+
             return;
         }
@@ -525 +558 @@
         fDebugRx = b;
         Connection::SetVerbose(b);
+    }
+
+    void SetURI(const string &uri)
+    {
+        fUri = uri;
     }
 
@@ -680 +718 @@
         fGCN.SetEndPoints(conf.Vec<string>("addr"));
 
+        fGCN.SetURI(conf.Get<string>("schedule-database"));
+
         return -1;
     }
@@ -701 +741 @@
         ("addr,a",        vars<string>(),  "Network addresses of GCN server")
         ("quiet,q",       po_bool(true),  "Disable printing contents of all received messages (except dynamic data) in clear text.")
+        ("schedule-database", var<string>(), "Database link as in\n\tuser:password@server[:port]/database[?compress=0|1].")
         ;