@spec provider_handler(non_neg_integer()) :: atom()

Get the current provider handler based on the config

@spec provider_worker(non_neg_integer()) :: atom()

Get the current provider worker based on the organization | Config | Defaultconfig

@spec publish_data({:ok, any()} | any(), atom(), non_neg_integer()) :: any()

Unified function to publish data on the graphql subscription endpoint. This is still looking for a place to actually reside. This is a good next stop for now

For now the data types are Message and all join Tag tables