use LogP6::Wrapper;
use LogP6::Wrapper::SyncAbstract;
use LogP6::LogGetter;
use LogP6::Exceptions;

#| Wrapper for synchronize a logger each X seconds itself.
class LogP6::Wrapper::SyncTime is LogP6::Wrapper::SyncAbstract {
	#| How often a logger have to be updated
	has Int:D $.seconds is required;

	method sync($context) {
		$context.date-clean();
		my $last = self.get-sync-obj;
		without $last {
			$last = DateTime.now;
			self.put-sync-obj($last);
			self.update-aggr;
		}
		my $now = $context.date;
		if $now - $last > $!seconds {
			self.update-aggr;
			self.put-sync-obj($now);
		}
		CATCH { default { logp6-error($_) } }
	}
}

#| Wrapper logic for synchronize a logger each X seconds.
class LogP6::Wrapper::SyncTime::Wrapper
		is LogP6::Wrapper::SyncAbstract::Wrapper {
	#| How often a logger have to be updated
	has Int:D $.seconds is required;
	#| Method for retrieving the new logger
	has &.get-logger-pure;

	method wrap(LogP6::Wrapper::SyncTime::Wrapper:D:
		LogP6::Logger:D $logger --> LogP6::Logger:D
	) {
		return LogP6::Wrapper::SyncTime.new(
			:$!seconds, :aggr($logger),
			:get-fresh-logger(&!get-logger-pure // &get-pure)
		)
	}
}