contextualizer.clj

(defn annotate-event
  "Applies the context and id field to the provided source event."
  [source-event id context]
  (merge source-event {:id id :context context}))

(defn contextualize
  "Parses a source event for identifiers that are representative of contexts (interactions, queues, resources, etc) and
  annotates + replicates the event based on these contexts."
  [source-event]
  (let [{:keys [resource-id queue-id interaction-id]} source-event
        replicated-events (cond-> []
                            resource-id (conj (annotate-event source-event resource-id :resource))
                            queue-id (conj (annotate-event source-event resource-id :queue))
                            interaction-id (conj (annotate-event source-event resource-id :interaction)))]
    (delegate-contextualized-events replicated-events)))