would using dual benthos streams and a a complex bloblang processor work or would it be better to have a custom processor that handles this? Can you program a processor your self? my alarm processor can be found at my github to use as a base.