kamituel.s-tlbx-probe.utils — kamituel/s-tlbx-probe 0.2.8

correlate-sender-with-receivers cljs

(correlate-sender-with-receivers messages)

Each message should be observed by the probe (at least) twice - once when it is being sent by the originating component (it's :type is then :firehose/cmp-put) and once when it is being received by the destination component (:type = :firehose/cmp-recv).

When routing in the switchboard is configured so that multiple destination components are going to receive the same message, there might be multiple observations at the destination components.

When routing in the switchboard is invalid, there will be a sent message, but no received one.

Thus the relationship between a sent message and received ones is 1-* (one-to-many), with 1-1 being the most common case, but 1-0 and 1-2+ being also possible.

Messages sent and received can be matched using :corr-id (assigned by systems-toolbox).

correlated? cljs

(correlated? msg-1 msg-2)

diff-state-snapshots cljs

(diff-state-snapshots s1 s2)

fix-message-order cljs

(fix-message-order messages)

Messages that originate in distributed systems (i.e. on the frontend ran in a browser and a backend ran on a remote server) could be delivered via the firehose out of order. This function restores that order based on an observation that all messages related to one event are using the same :tag, and that for messages with the given tag, first message will have one element in :cmp-seq, second - two, etc.

merge-correlated cljs

(merge-correlated msg-1 msg-2)

number->str cljs

(number->str n decimal-places)

Converts a number to a string with a given number of decimal places. I.e. for three decimal places: 3 -> 3.000 3.1 -> 3.100 3.123 -> 3.123 3.1238 -> 3.123

prepare-logs cljs

(prepare-logs all-snapshots snapshots-diffs messages)

raw-msg->map cljs

(raw-msg->map reference-timestamp msg)

Converts message as received from the toolbox's firehose to the simple map.

raw-state-snapshot->map cljs

(raw-state-snapshot->map reference-timestamp state-snapshot)

received? cljs

(received? msg)

relative-timestamp-str cljs

(relative-timestamp-str reference-timestamp firehose-msg)

same-tag? cljs

(same-tag? msg-1 msg-2)

sanitize-message cljs

(sanitize-message msg)

sanitize-snapshot-diff cljs

(sanitize-snapshot-diff snapshot-diff)

sanitize-state-snapshot cljs

(sanitize-state-snapshot state-snapshot)

sanitize-value cljs

(sanitize-value v)

save-file cljs

(save-file filename contents-str)

save-logs cljs

(save-logs & args)

sent? cljs

(sent? msg)

uuid-pattern cljs

valid-uuid? cljs

(valid-uuid? uuid)

ClojureScript doesn't ensure that #uuid is a valid UUID.