blob: c709ed1a8575e9fa9df496ae6749c771b33e164d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
(ns chameleon.aai-processor
(:require [chameleon.txform :refer :all]
[chameleon.route :refer :all]
[cheshire.core :refer :all]))
(defn from-gallifrey
"Transforms Gallifrey response payloads into a format consumable by AAI-centric clients"
[body]
(->> body
(map (fn [[k v]] [(clojure.string/split k #"\.") v]))
((fn [x] (reduce #(assoc-in %1 (first %2) (second %2) ) {} x)))))
(defn from-spike
"Transforms Spike-based event payloads to a format accepted by Gallifrey for vertices and relationships"
[gallifrey-host payload]
(let [txpayload (map-keywords (parse-string payload))
operation (:operation txpayload)
entity-type (if (contains? txpayload :vertex)
:vertex
:relationship)
entity (map-keywords (entity-type txpayload))
key (:key entity)
properties (assoc (:properties entity) :type (:type entity))]
(assert-gallifrey gallifrey-host "aai" (if (= entity-type :vertex)
{:meta {:key key :operation operation} :body (generate-string properties)}
{:meta {:key key :operation operation} :body (generate-string (conj properties (flatten-entry entity :source) (flatten-entry entity :target)))}))))
|
