From f9f898b1171df310f03ef53ec12ca1140ebb8808 Mon Sep 17 00:00:00 2001
From: Dobrica Pavlinusic <dpavlin@rot13.org>
Date: Tue, 4 Jul 2023 13:48:44 +0200
Subject: [PATCH] read from /home/nodelogs/

---
 parse-node-logs.pl | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/parse-node-logs.pl b/parse-node-logs.pl
index 1e1b6e9..1007c43 100755
--- a/parse-node-logs.pl
+++ b/parse-node-logs.pl
@@ -8,11 +8,18 @@ use DBD::Pg;
 use Data::Dump qw(dump);
 use autodie;
 
+my $path = '/home/nodelogs/c405f97667784094bca5cfa52af0bcf1/';
+
+# select _id,json->'received',time,to_timestamp((json->>'received')::int8/1000) - interval '1 hour' from nodelog ;
+
 my $dbh = DBI->connect("dbi:Pg:dbname=eg5120", "dpavlin", "", { RaiseError => 1 });
 $dbh->do( qq{ truncate table nodelog } ); # FIXME
 my $sth = $dbh->prepare(qq{insert into nodelog (time,json) values (?,?)});
 
-foreach my $filename ( sort(glob('node-logs/node-red-out__2023-07-*')), 'node-logs/node-red-out.log' ) {
+foreach my $filename (
+		sort(glob("$path/node-red-out__2023-07-*")),
+		"$path/node-red-out.log"
+	) {
 	warn "# $filename";
 	open(my $log, '<', $filename);
 	my $in_json = 0;
@@ -48,3 +55,4 @@ foreach my $filename ( sort(glob('node-logs/node-red-out__2023-07-*')), 'node-lo
 
 	}
 }
+
-- 
2.20.1