From 3d8b50f1e837c5f6f5335908c7bbf8925f08e7c7 Mon Sep 17 00:00:00 2001 From: breakfixrepeat <1808307+breakfixrepeat@users.noreply.github.com> Date: Mon, 9 May 2022 21:24:53 +0100 Subject: [PATCH 1/2] Update replay generator --- splunk_eventgen/lib/plugins/generator/replay.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/splunk_eventgen/lib/plugins/generator/replay.py b/splunk_eventgen/lib/plugins/generator/replay.py index e4a773cc..125c884d 100644 --- a/splunk_eventgen/lib/plugins/generator/replay.py +++ b/splunk_eventgen/lib/plugins/generator/replay.py @@ -173,9 +173,12 @@ def gen(self, count, earliest, latest, samplename=None): rpevent, self.backfill_time, earliest, latest ) previous_event = current_event - previous_event_timediff = rpevent["timediff"] + previous_event_timediff = line_list[index + 1]["timediff"] self._out.bulksend([current_event]) continue + else: + previous_event = rpevent + previous_event_timediff = rpevent["timediff"] try: time.sleep(previous_event_timediff.total_seconds()) except ValueError: @@ -186,8 +189,6 @@ def gen(self, count, earliest, latest, samplename=None): logger.error("Event: {0}".format(rpevent)) pass current_time = datetime.datetime.now() - previous_event = rpevent - previous_event_timediff = rpevent["timediff"] send_event = self.set_time_and_tokens( rpevent, current_time, earliest, latest ) From 2e89735a5878f99ddb0270a210d1ce516a9b564b Mon Sep 17 00:00:00 2001 From: "@infosux" <1808307+breakfixrepeat@users.noreply.github.com> Date: Sat, 4 Feb 2023 00:54:44 +0000 Subject: [PATCH 2/2] Update splunk_eventgen/lib/plugins/generator/replay.py Co-authored-by: 0xr2po <117746006+0xr2po@users.noreply.github.com> --- splunk_eventgen/lib/plugins/generator/replay.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/splunk_eventgen/lib/plugins/generator/replay.py b/splunk_eventgen/lib/plugins/generator/replay.py index 125c884d..f131dab7 100644 --- a/splunk_eventgen/lib/plugins/generator/replay.py +++ b/splunk_eventgen/lib/plugins/generator/replay.py @@ -173,7 +173,10 @@ def gen(self, count, earliest, latest, samplename=None): rpevent, self.backfill_time, earliest, latest ) previous_event = current_event - previous_event_timediff = line_list[index + 1]["timediff"] + if len(line_list) != 1: + previous_event_timediff = line_list[index + 1]["timediff"] + else: + previous_event_timediff = rpevent["timediff"] self._out.bulksend([current_event]) continue else: