X-Git-Url: https://git.xandkar.net/?p=khatus.git;a=blobdiff_plain;f=src%2Fawk%2Flib%2Fmsg.awk;fp=src%2Fawk%2Flib%2Fmsg_out.awk;h=fba25e7884af648ca5318c924e13352d1811a57c;hp=24393c664b1075a1eca7fa0141e4e819e2bf32fe;hb=81336934f5dcb1895c050d71805ec37e56c400ad;hpb=0f81c6a873640359583d44a791e706de2d44ea1e

diff --git a/src/awk/lib/msg_out.awk b/src/awk/lib/msg.awk
similarity index 61%
rename from src/awk/lib/msg_out.awk
rename to src/awk/lib/msg.awk
index 24393c6..fba25e7 100644
--- a/src/awk/lib/msg_out.awk
+++ b/src/awk/lib/msg.awk
@@ -6,6 +6,39 @@ BEGIN {
     Kfs = FS2
 }
 
+function msg_parse(msg, line,    status, fields, type) {
+    split(line, fields, FS1)
+    msg["node"]   = fields[1]
+    msg["module"] = fields[2]
+    type          = fields[3]
+    msg["type"]   = type
+
+    status = 1
+    if (type == "data") {
+        msg["key"] = fields[4]
+        msg["val"] = str_tail(str_join(fields, 1, 4, FS1) FS1, line)
+    } else if (type == "error") {
+        msg["line"] = str_tail(str_join(fields, 1, 3, FS1) FS1, line)
+    } else if (type == "alert") {
+        msg["priority"] = fields[4]
+        msg["subject"]  = fields[5]
+        msg["body"]     = str_tail(str_join(fields, 1, 5, FS1) FS1, line)
+    } else if (type == "log") {
+        msg["location"] = fields[4]
+        msg["level"]    = fields[5]
+        msg["msg"]      = str_tail(str_join(fields, 1, 5, FS1) FS1, line)
+    } else if (type == "status_bar") {
+        msg["status_bar"] = str_tail(str_join(fields, 1, 3, FS1) FS1, line)
+    } else {
+        msg_out_log_error(\
+            "msg_parse",
+            "Unexpected msg type: " type " in given input line: " line \
+        )
+        status = 0
+    }
+    return status
+}
+
 # -----------------------------------------------------------------------------
 # alert
 # -----------------------------------------------------------------------------