| 25 | } |
| 26 | |
| 27 | async def setup(self): |
| 28 | self.url = self.config.get("url", "") |
| 29 | self.source = self.config.get("source", "bbot") |
| 30 | self.index = self.config.get("index", "main") |
| 31 | self.timeout = self.config.get("timeout", 10) |
| 32 | self.headers = {} |
| 33 | |
| 34 | hectoken = self.config.get("hectoken", "") |
| 35 | if hectoken: |
| 36 | self.headers["Authorization"] = f"Splunk {hectoken}" |
| 37 | if not self.url: |
| 38 | return False, "Must set URL" |
| 39 | if not self.source: |
| 40 | self.warning("Please provide a source") |
| 41 | return True |
| 42 | |
| 43 | async def handle_event(self, event): |
| 44 | while 1: |