+
+sub wind_average
+{
+ my ($sindir, $cosdir, $wind);
+ my $count;
+
+ foreach my $r (@_) {
+ $wind += $r->{w};
+ $sindir += sin(d2r($r->{d})) * $r->{w};
+ $cosdir += cos(d2r($r->{d})) * $r->{w};
+ ++$count;
+ }
+
+ my $avhdg = r2d(atan2($sindir, $cosdir));
+ $avhdg += 360 if $avhdg < 0;
+ return {w => nearest(0.1,$wind / $count), d => nearest(0.1,$avhdg)};
+}
+
+# radians to degrees
+sub r2d
+{
+ my $n = shift;
+ return ($n / pi) * 180;
+}
+
+# degrees to radians
+sub d2r
+{
+ my $n = shift;
+ return ($n / 180) * pi;
+}
+
+sub calc_rain
+{
+ my $rain = shift;
+
+ $ld->{rain24} ||= [];
+
+ my $Rain_1h = nearest(0.1, $rain >= $ld->{last_rain_hour} ? $rain - $ld->{last_rain_hour} : $rain); # this is the rate for this hour, so far
+ my $rm = nearest(0.1, $rain >= $ld->{last_rain_min} ? $rain - $ld->{last_rain_min} : $rain);
+ my $Rain_1m = nearest(0.1, $rm);
+ push @{$ld->{rain24}}, $Rain_1m;
+ $ld->{rain_24} += $rm;
+ while (@{$ld->{rain24}} > 24*60) {
+ $ld->{rain_24} -= shift @{$ld->{rain24}};
+ }
+ my $Rain_24h = nearest(0.1, $ld->{rain_24});
+ return ($Rain_1m, $Rain_1h, $Rain_24h);
+}
+
+sub read_ld
+{
+ unless ($dataf) {
+ $dataf = IO::File->new("+>> $datafn") or die "cannot open $datafn $!";
+ $dataf->autoflush(1);
+ }
+
+ seek $dataf, 0, 0;
+ my $s = <$dataf>;
+ chomp $s;
+ dbg "read loop data: $s" if isdbg 'json';
+ $ld = $json->decode($s) if length $s;
+
+ # sort out rain stats
+ my $c;
+ if ($ld->{rain24} && ($c = @{$ld->{rain24}}) < 24*60) {
+ my $diff = 24*60 - $c;
+ unshift @{$ld->{rain24}}, 0 for 0 .. $diff;
+ }
+ my $rain;
+
+ if ($ld->{rain24}) {
+ $rain += $_ for @{$ld->{rain24}};
+ }
+
+ $ld->{rain_24} = nearest(0.1, $rain);
+ delete $ld->{hour};
+ delete $ld->{min};
+}
+
+sub write_ld
+{
+ unless ($dataf) {
+ $dataf = IO::File->new("+>> $datafn") or die "cannot open $datafn $!";
+ $dataf->autoflush(1);
+ }
+
+ seek $dataf, 0, 0;
+ truncate $dataf, 0;
+ $ld->{ts} = time;
+ my $s = $json->encode($ld);
+ dbg "write loop data: $s" if isdbg 'json';
+ print $dataf "$s\n";
+}
+
+sub cycle_loop_data_files
+{
+ $dataf->close if $dataf;
+ undef $dataf;
+
+ rename "$datafn.oooo", "$datafn.ooooo";
+ rename "$datafn.ooo", "$datafn.oooo";
+ rename "$datafn.oo", "$datafn.ooo";
+ rename "$datafn.o", "$datafn.oo";
+ copy $datafn, "$datafn.o";
+}
+
+sub send_history
+{
+ my $c = shift;
+ my $lg = shift;
+ my $tnow = shift;
+ my $dayno = shift;
+ if ($lg->open($dayno, 'r+')) {
+ while (my $l = $lg->read) {
+ next unless $l =~ /,"h":/;
+ my ($t) = $l =~ /"t":(\d+)/;
+ if ($t && $t >= $tnow-86400) {
+ $c->send($l);
+# dbg "sending: $l";
+ }
+ }
+ $lg->close;
+ }
+}