goog.provide('shadow.remote.runtime.shared');
shadow.remote.runtime.shared.init_state = (function shadow$remote$runtime$shared$init_state(client_info){
return new cljs.core.PersistentArrayMap(null, 5, [new cljs.core.Keyword(null,"extensions","extensions",-1103629196),cljs.core.PersistentArrayMap.EMPTY,new cljs.core.Keyword(null,"ops","ops",1237330063),cljs.core.PersistentArrayMap.EMPTY,new cljs.core.Keyword(null,"client-info","client-info",1958982504),client_info,new cljs.core.Keyword(null,"call-id-seq","call-id-seq",-1679248218),(0),new cljs.core.Keyword(null,"call-handlers","call-handlers",386605551),cljs.core.PersistentArrayMap.EMPTY], null);
});
shadow.remote.runtime.shared.now = (function shadow$remote$runtime$shared$now(){
return Date.now();
});
shadow.remote.runtime.shared.get_client_id = (function shadow$remote$runtime$shared$get_client_id(p__19818){
var map__19820 = p__19818;
var map__19820__$1 = cljs.core.__destructure_map(map__19820);
var runtime = map__19820__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19820__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
var or__5002__auto__ = new cljs.core.Keyword(null,"client-id","client-id",-464622140).cljs$core$IFn$_invoke$arity$1(cljs.core.deref(state_ref));
if(cljs.core.truth_(or__5002__auto__)){
return or__5002__auto__;
} else {
throw cljs.core.ex_info.cljs$core$IFn$_invoke$arity$2("runtime has no assigned runtime-id",new cljs.core.PersistentArrayMap(null, 1, [new cljs.core.Keyword(null,"runtime","runtime",-1331573996),runtime], null));
}
});
shadow.remote.runtime.shared.relay_msg = (function shadow$remote$runtime$shared$relay_msg(runtime,msg){
var self_id_20070 = shadow.remote.runtime.shared.get_client_id(runtime);
if(cljs.core.not_EQ_.cljs$core$IFn$_invoke$arity$2(new cljs.core.Keyword(null,"to","to",192099007).cljs$core$IFn$_invoke$arity$1(msg),self_id_20070)){
shadow.remote.runtime.api.relay_msg(runtime,msg);
} else {
Promise.resolve((1)).then((function (){
var G__19823 = runtime;
var G__19824 = cljs.core.assoc.cljs$core$IFn$_invoke$arity$3(msg,new cljs.core.Keyword(null,"from","from",1815293044),self_id_20070);
return (shadow.remote.runtime.shared.process.cljs$core$IFn$_invoke$arity$2 ? shadow.remote.runtime.shared.process.cljs$core$IFn$_invoke$arity$2(G__19823,G__19824) : shadow.remote.runtime.shared.process.call(null, G__19823,G__19824));
}));
}

return msg;
});
shadow.remote.runtime.shared.reply = (function shadow$remote$runtime$shared$reply(runtime,p__19829,res){
var map__19830 = p__19829;
var map__19830__$1 = cljs.core.__destructure_map(map__19830);
var call_id = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19830__$1,new cljs.core.Keyword(null,"call-id","call-id",1043012968));
var from = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19830__$1,new cljs.core.Keyword(null,"from","from",1815293044));
var res__$1 = (function (){var G__19833 = res;
var G__19833__$1 = (cljs.core.truth_(call_id)?cljs.core.assoc.cljs$core$IFn$_invoke$arity$3(G__19833,new cljs.core.Keyword(null,"call-id","call-id",1043012968),call_id):G__19833);
if(cljs.core.truth_(from)){
return cljs.core.assoc.cljs$core$IFn$_invoke$arity$3(G__19833__$1,new cljs.core.Keyword(null,"to","to",192099007),from);
} else {
return G__19833__$1;
}
})();
return shadow.remote.runtime.api.relay_msg(runtime,res__$1);
});
shadow.remote.runtime.shared.call = (function shadow$remote$runtime$shared$call(var_args){
var G__19839 = arguments.length;
switch (G__19839) {
case 3:
return shadow.remote.runtime.shared.call.cljs$core$IFn$_invoke$arity$3((arguments[(0)]),(arguments[(1)]),(arguments[(2)]));

break;
case 4:
return shadow.remote.runtime.shared.call.cljs$core$IFn$_invoke$arity$4((arguments[(0)]),(arguments[(1)]),(arguments[(2)]),(arguments[(3)]));

break;
default:
throw (new Error(["Invalid arity: ",cljs.core.str.cljs$core$IFn$_invoke$arity$1(arguments.length)].join('')));

}
});

(shadow.remote.runtime.shared.call.cljs$core$IFn$_invoke$arity$3 = (function (runtime,msg,handlers){
return shadow.remote.runtime.shared.call.cljs$core$IFn$_invoke$arity$4(runtime,msg,handlers,(0));
}));

(shadow.remote.runtime.shared.call.cljs$core$IFn$_invoke$arity$4 = (function (p__19844,msg,handlers,timeout_after_ms){
var map__19846 = p__19844;
var map__19846__$1 = cljs.core.__destructure_map(map__19846);
var runtime = map__19846__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19846__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
if(cljs.core.map_QMARK_(msg)){
} else {
throw (new Error("Assert failed: (map? msg)"));
}

if(cljs.core.map_QMARK_(handlers)){
} else {
throw (new Error("Assert failed: (map? handlers)"));
}

if(cljs.core.nat_int_QMARK_(timeout_after_ms)){
} else {
throw (new Error("Assert failed: (nat-int? timeout-after-ms)"));
}

var call_id = new cljs.core.Keyword(null,"call-id-seq","call-id-seq",-1679248218).cljs$core$IFn$_invoke$arity$1(cljs.core.deref(state_ref));
cljs.core.swap_BANG_.cljs$core$IFn$_invoke$arity$4(state_ref,cljs.core.update,new cljs.core.Keyword(null,"call-id-seq","call-id-seq",-1679248218),cljs.core.inc);

cljs.core.swap_BANG_.cljs$core$IFn$_invoke$arity$4(state_ref,cljs.core.assoc_in,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"call-handlers","call-handlers",386605551),call_id], null),new cljs.core.PersistentArrayMap(null, 4, [new cljs.core.Keyword(null,"handlers","handlers",79528781),handlers,new cljs.core.Keyword(null,"called-at","called-at",607081160),shadow.remote.runtime.shared.now(),new cljs.core.Keyword(null,"msg","msg",-1386103444),msg,new cljs.core.Keyword(null,"timeout","timeout",-318625318),timeout_after_ms], null));

return shadow.remote.runtime.api.relay_msg(runtime,cljs.core.assoc.cljs$core$IFn$_invoke$arity$3(msg,new cljs.core.Keyword(null,"call-id","call-id",1043012968),call_id));
}));

(shadow.remote.runtime.shared.call.cljs$lang$maxFixedArity = 4);

shadow.remote.runtime.shared.trigger_BANG_ = (function shadow$remote$runtime$shared$trigger_BANG_(var_args){
var args__5732__auto__ = [];
var len__5726__auto___20114 = arguments.length;
var i__5727__auto___20117 = (0);
while(true){
if((i__5727__auto___20117 < len__5726__auto___20114)){
args__5732__auto__.push((arguments[i__5727__auto___20117]));

var G__20118 = (i__5727__auto___20117 + (1));
i__5727__auto___20117 = G__20118;
continue;
} else {
}
break;
}

var argseq__5733__auto__ = ((((2) < args__5732__auto__.length))?(new cljs.core.IndexedSeq(args__5732__auto__.slice((2)),(0),null)):null);
return shadow.remote.runtime.shared.trigger_BANG_.cljs$core$IFn$_invoke$arity$variadic((arguments[(0)]),(arguments[(1)]),argseq__5733__auto__);
});

(shadow.remote.runtime.shared.trigger_BANG_.cljs$core$IFn$_invoke$arity$variadic = (function (p__19860,ev,args){
var map__19861 = p__19860;
var map__19861__$1 = cljs.core.__destructure_map(map__19861);
var runtime = map__19861__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19861__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
var seq__19864 = cljs.core.seq(cljs.core.vals(new cljs.core.Keyword(null,"extensions","extensions",-1103629196).cljs$core$IFn$_invoke$arity$1(cljs.core.deref(state_ref))));
var chunk__19867 = null;
var count__19868 = (0);
var i__19869 = (0);
while(true){
if((i__19869 < count__19868)){
var ext = chunk__19867.cljs$core$IIndexed$_nth$arity$2(null, i__19869);
var ev_fn = cljs.core.get.cljs$core$IFn$_invoke$arity$2(ext,ev);
if(cljs.core.truth_(ev_fn)){
cljs.core.apply.cljs$core$IFn$_invoke$arity$2(ev_fn,args);


var G__20138 = seq__19864;
var G__20139 = chunk__19867;
var G__20140 = count__19868;
var G__20141 = (i__19869 + (1));
seq__19864 = G__20138;
chunk__19867 = G__20139;
count__19868 = G__20140;
i__19869 = G__20141;
continue;
} else {
var G__20144 = seq__19864;
var G__20145 = chunk__19867;
var G__20146 = count__19868;
var G__20147 = (i__19869 + (1));
seq__19864 = G__20144;
chunk__19867 = G__20145;
count__19868 = G__20146;
i__19869 = G__20147;
continue;
}
} else {
var temp__5804__auto__ = cljs.core.seq(seq__19864);
if(temp__5804__auto__){
var seq__19864__$1 = temp__5804__auto__;
if(cljs.core.chunked_seq_QMARK_(seq__19864__$1)){
var c__5525__auto__ = cljs.core.chunk_first(seq__19864__$1);
var G__20153 = cljs.core.chunk_rest(seq__19864__$1);
var G__20154 = c__5525__auto__;
var G__20155 = cljs.core.count(c__5525__auto__);
var G__20156 = (0);
seq__19864 = G__20153;
chunk__19867 = G__20154;
count__19868 = G__20155;
i__19869 = G__20156;
continue;
} else {
var ext = cljs.core.first(seq__19864__$1);
var ev_fn = cljs.core.get.cljs$core$IFn$_invoke$arity$2(ext,ev);
if(cljs.core.truth_(ev_fn)){
cljs.core.apply.cljs$core$IFn$_invoke$arity$2(ev_fn,args);


var G__20159 = cljs.core.next(seq__19864__$1);
var G__20160 = null;
var G__20161 = (0);
var G__20162 = (0);
seq__19864 = G__20159;
chunk__19867 = G__20160;
count__19868 = G__20161;
i__19869 = G__20162;
continue;
} else {
var G__20165 = cljs.core.next(seq__19864__$1);
var G__20166 = null;
var G__20167 = (0);
var G__20168 = (0);
seq__19864 = G__20165;
chunk__19867 = G__20166;
count__19868 = G__20167;
i__19869 = G__20168;
continue;
}
}
} else {
return null;
}
}
break;
}
}));

(shadow.remote.runtime.shared.trigger_BANG_.cljs$lang$maxFixedArity = (2));

/** @this {Function} */
(shadow.remote.runtime.shared.trigger_BANG_.cljs$lang$applyTo = (function (seq19855){
var G__19856 = cljs.core.first(seq19855);
var seq19855__$1 = cljs.core.next(seq19855);
var G__19857 = cljs.core.first(seq19855__$1);
var seq19855__$2 = cljs.core.next(seq19855__$1);
var self__5711__auto__ = this;
return self__5711__auto__.cljs$core$IFn$_invoke$arity$variadic(G__19856,G__19857,seq19855__$2);
}));

shadow.remote.runtime.shared.welcome = (function shadow$remote$runtime$shared$welcome(p__19888,p__19889){
var map__19890 = p__19888;
var map__19890__$1 = cljs.core.__destructure_map(map__19890);
var runtime = map__19890__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19890__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
var map__19891 = p__19889;
var map__19891__$1 = cljs.core.__destructure_map(map__19891);
var msg = map__19891__$1;
var client_id = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19891__$1,new cljs.core.Keyword(null,"client-id","client-id",-464622140));
cljs.core.swap_BANG_.cljs$core$IFn$_invoke$arity$variadic(state_ref,cljs.core.assoc,new cljs.core.Keyword(null,"client-id","client-id",-464622140),client_id,cljs.core.prim_seq.cljs$core$IFn$_invoke$arity$2([new cljs.core.Keyword(null,"welcome","welcome",-578152123),true], 0));

var map__19893 = cljs.core.deref(state_ref);
var map__19893__$1 = cljs.core.__destructure_map(map__19893);
var client_info = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19893__$1,new cljs.core.Keyword(null,"client-info","client-info",1958982504));
var extensions = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19893__$1,new cljs.core.Keyword(null,"extensions","extensions",-1103629196));
shadow.remote.runtime.shared.relay_msg(runtime,new cljs.core.PersistentArrayMap(null, 2, [new cljs.core.Keyword(null,"op","op",-1882987955),new cljs.core.Keyword(null,"hello","hello",-245025397),new cljs.core.Keyword(null,"client-info","client-info",1958982504),client_info], null));

return shadow.remote.runtime.shared.trigger_BANG_(runtime,new cljs.core.Keyword(null,"on-welcome","on-welcome",1895317125));
});
shadow.remote.runtime.shared.ping = (function shadow$remote$runtime$shared$ping(runtime,msg){
return shadow.remote.runtime.shared.reply(runtime,msg,new cljs.core.PersistentArrayMap(null, 1, [new cljs.core.Keyword(null,"op","op",-1882987955),new cljs.core.Keyword(null,"pong","pong",-172484958)], null));
});
shadow.remote.runtime.shared.request_supported_ops = (function shadow$remote$runtime$shared$request_supported_ops(p__19909,msg){
var map__19910 = p__19909;
var map__19910__$1 = cljs.core.__destructure_map(map__19910);
var runtime = map__19910__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19910__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
return shadow.remote.runtime.shared.reply(runtime,msg,new cljs.core.PersistentArrayMap(null, 2, [new cljs.core.Keyword(null,"op","op",-1882987955),new cljs.core.Keyword(null,"supported-ops","supported-ops",337914702),new cljs.core.Keyword(null,"ops","ops",1237330063),cljs.core.disj.cljs$core$IFn$_invoke$arity$variadic(cljs.core.set(cljs.core.keys(new cljs.core.Keyword(null,"ops","ops",1237330063).cljs$core$IFn$_invoke$arity$1(cljs.core.deref(state_ref)))),new cljs.core.Keyword(null,"welcome","welcome",-578152123),cljs.core.prim_seq.cljs$core$IFn$_invoke$arity$2([new cljs.core.Keyword(null,"unknown-relay-op","unknown-relay-op",170832753),new cljs.core.Keyword(null,"unknown-op","unknown-op",1900385996),new cljs.core.Keyword(null,"request-supported-ops","request-supported-ops",-1034994502),new cljs.core.Keyword(null,"tool-disconnect","tool-disconnect",189103996)], 0))], null));
});
shadow.remote.runtime.shared.unknown_relay_op = (function shadow$remote$runtime$shared$unknown_relay_op(msg){
return console.warn("unknown-relay-op",msg);
});
shadow.remote.runtime.shared.unknown_op = (function shadow$remote$runtime$shared$unknown_op(msg){
return console.warn("unknown-op",msg);
});
shadow.remote.runtime.shared.add_extension_STAR_ = (function shadow$remote$runtime$shared$add_extension_STAR_(p__19922,key,p__19923){
var map__19925 = p__19922;
var map__19925__$1 = cljs.core.__destructure_map(map__19925);
var state = map__19925__$1;
var extensions = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19925__$1,new cljs.core.Keyword(null,"extensions","extensions",-1103629196));
var map__19927 = p__19923;
var map__19927__$1 = cljs.core.__destructure_map(map__19927);
var spec = map__19927__$1;
var ops = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19927__$1,new cljs.core.Keyword(null,"ops","ops",1237330063));
var transit_write_handlers = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19927__$1,new cljs.core.Keyword(null,"transit-write-handlers","transit-write-handlers",1886308716));
if(cljs.core.contains_QMARK_(extensions,key)){
throw cljs.core.ex_info.cljs$core$IFn$_invoke$arity$2("extension already registered",new cljs.core.PersistentArrayMap(null, 2, [new cljs.core.Keyword(null,"key","key",-1516042587),key,new cljs.core.Keyword(null,"spec","spec",347520401),spec], null));
} else {
}

return cljs.core.reduce_kv((function (state__$1,op_kw,op_handler){
if(cljs.core.truth_(cljs.core.get_in.cljs$core$IFn$_invoke$arity$2(state__$1,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"ops","ops",1237330063),op_kw], null)))){
throw cljs.core.ex_info.cljs$core$IFn$_invoke$arity$2("op already registered",new cljs.core.PersistentArrayMap(null, 2, [new cljs.core.Keyword(null,"key","key",-1516042587),key,new cljs.core.Keyword(null,"op","op",-1882987955),op_kw], null));
} else {
}

return cljs.core.assoc_in(state__$1,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"ops","ops",1237330063),op_kw], null),op_handler);
}),cljs.core.assoc_in(state,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"extensions","extensions",-1103629196),key], null),spec),ops);
});
shadow.remote.runtime.shared.add_extension = (function shadow$remote$runtime$shared$add_extension(p__19935,key,spec){
var map__19936 = p__19935;
var map__19936__$1 = cljs.core.__destructure_map(map__19936);
var runtime = map__19936__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19936__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
cljs.core.swap_BANG_.cljs$core$IFn$_invoke$arity$4(state_ref,shadow.remote.runtime.shared.add_extension_STAR_,key,spec);

var temp__5808__auto___20253 = new cljs.core.Keyword(null,"on-welcome","on-welcome",1895317125).cljs$core$IFn$_invoke$arity$1(spec);
if((temp__5808__auto___20253 == null)){
} else {
var on_welcome_20255 = temp__5808__auto___20253;
if(cljs.core.truth_(new cljs.core.Keyword(null,"welcome","welcome",-578152123).cljs$core$IFn$_invoke$arity$1(cljs.core.deref(state_ref)))){
(on_welcome_20255.cljs$core$IFn$_invoke$arity$0 ? on_welcome_20255.cljs$core$IFn$_invoke$arity$0() : on_welcome_20255.call(null, ));
} else {
}
}

return runtime;
});
shadow.remote.runtime.shared.add_defaults = (function shadow$remote$runtime$shared$add_defaults(runtime){
return shadow.remote.runtime.shared.add_extension(runtime,new cljs.core.Keyword("shadow.remote.runtime.shared","defaults","shadow.remote.runtime.shared/defaults",-1821257543),new cljs.core.PersistentArrayMap(null, 1, [new cljs.core.Keyword(null,"ops","ops",1237330063),new cljs.core.PersistentArrayMap(null, 5, [new cljs.core.Keyword(null,"welcome","welcome",-578152123),(function (p1__19944_SHARP_){
return shadow.remote.runtime.shared.welcome(runtime,p1__19944_SHARP_);
}),new cljs.core.Keyword(null,"unknown-relay-op","unknown-relay-op",170832753),(function (p1__19945_SHARP_){
return shadow.remote.runtime.shared.unknown_relay_op(p1__19945_SHARP_);
}),new cljs.core.Keyword(null,"unknown-op","unknown-op",1900385996),(function (p1__19946_SHARP_){
return shadow.remote.runtime.shared.unknown_op(p1__19946_SHARP_);
}),new cljs.core.Keyword(null,"ping","ping",-1670114784),(function (p1__19948_SHARP_){
return shadow.remote.runtime.shared.ping(runtime,p1__19948_SHARP_);
}),new cljs.core.Keyword(null,"request-supported-ops","request-supported-ops",-1034994502),(function (p1__19949_SHARP_){
return shadow.remote.runtime.shared.request_supported_ops(runtime,p1__19949_SHARP_);
})], null)], null));
});
shadow.remote.runtime.shared.del_extension_STAR_ = (function shadow$remote$runtime$shared$del_extension_STAR_(state,key){
var ext = cljs.core.get_in.cljs$core$IFn$_invoke$arity$2(state,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"extensions","extensions",-1103629196),key], null));
if(cljs.core.not(ext)){
return state;
} else {
return cljs.core.reduce_kv((function (state__$1,op_kw,op_handler){
return cljs.core.update_in.cljs$core$IFn$_invoke$arity$4(state__$1,new cljs.core.PersistentVector(null, 1, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"ops","ops",1237330063)], null),cljs.core.dissoc,op_kw);
}),cljs.core.update.cljs$core$IFn$_invoke$arity$4(state,new cljs.core.Keyword(null,"extensions","extensions",-1103629196),cljs.core.dissoc,key),new cljs.core.Keyword(null,"ops","ops",1237330063).cljs$core$IFn$_invoke$arity$1(ext));
}
});
shadow.remote.runtime.shared.del_extension = (function shadow$remote$runtime$shared$del_extension(p__19965,key){
var map__19969 = p__19965;
var map__19969__$1 = cljs.core.__destructure_map(map__19969);
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19969__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
return cljs.core.swap_BANG_.cljs$core$IFn$_invoke$arity$3(state_ref,shadow.remote.runtime.shared.del_extension_STAR_,key);
});
shadow.remote.runtime.shared.unhandled_call_result = (function shadow$remote$runtime$shared$unhandled_call_result(call_config,msg){
return console.warn("unhandled call result",msg,call_config);
});
shadow.remote.runtime.shared.unhandled_client_not_found = (function shadow$remote$runtime$shared$unhandled_client_not_found(p__19976,msg){
var map__19978 = p__19976;
var map__19978__$1 = cljs.core.__destructure_map(map__19978);
var runtime = map__19978__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19978__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
return shadow.remote.runtime.shared.trigger_BANG_.cljs$core$IFn$_invoke$arity$variadic(runtime,new cljs.core.Keyword(null,"on-client-not-found","on-client-not-found",-642452849),cljs.core.prim_seq.cljs$core$IFn$_invoke$arity$2([msg], 0));
});
shadow.remote.runtime.shared.reply_unknown_op = (function shadow$remote$runtime$shared$reply_unknown_op(runtime,msg){
return shadow.remote.runtime.shared.reply(runtime,msg,new cljs.core.PersistentArrayMap(null, 2, [new cljs.core.Keyword(null,"op","op",-1882987955),new cljs.core.Keyword(null,"unknown-op","unknown-op",1900385996),new cljs.core.Keyword(null,"msg","msg",-1386103444),msg], null));
});
shadow.remote.runtime.shared.process = (function shadow$remote$runtime$shared$process(p__19988,p__19989){
var map__19991 = p__19988;
var map__19991__$1 = cljs.core.__destructure_map(map__19991);
var runtime = map__19991__$1;
var state_ref = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19991__$1,new cljs.core.Keyword(null,"state-ref","state-ref",2127874952));
var map__19992 = p__19989;
var map__19992__$1 = cljs.core.__destructure_map(map__19992);
var msg = map__19992__$1;
var op = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19992__$1,new cljs.core.Keyword(null,"op","op",-1882987955));
var call_id = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__19992__$1,new cljs.core.Keyword(null,"call-id","call-id",1043012968));
var state = cljs.core.deref(state_ref);
var op_handler = cljs.core.get_in.cljs$core$IFn$_invoke$arity$2(state,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"ops","ops",1237330063),op], null));
if(cljs.core.truth_(call_id)){
var cfg = cljs.core.get_in.cljs$core$IFn$_invoke$arity$2(state,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"call-handlers","call-handlers",386605551),call_id], null));
var call_handler = cljs.core.get_in.cljs$core$IFn$_invoke$arity$2(cfg,new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Keyword(null,"handlers","handlers",79528781),op], null));
if(cljs.core.truth_(call_handler)){
cljs.core.swap_BANG_.cljs$core$IFn$_invoke$arity$variadic(state_ref,cljs.core.update,new cljs.core.Keyword(null,"call-handlers","call-handlers",386605551),cljs.core.dissoc,cljs.core.prim_seq.cljs$core$IFn$_invoke$arity$2([call_id], 0));

return (call_handler.cljs$core$IFn$_invoke$arity$1 ? call_handler.cljs$core$IFn$_invoke$arity$1(msg) : call_handler.call(null, msg));
} else {
if(cljs.core.truth_(op_handler)){
return (op_handler.cljs$core$IFn$_invoke$arity$1 ? op_handler.cljs$core$IFn$_invoke$arity$1(msg) : op_handler.call(null, msg));
} else {
return shadow.remote.runtime.shared.unhandled_call_result(cfg,msg);

}
}
} else {
if(cljs.core.truth_(op_handler)){
return (op_handler.cljs$core$IFn$_invoke$arity$1 ? op_handler.cljs$core$IFn$_invoke$arity$1(msg) : op_handler.call(null, msg));
} else {
if(cljs.core._EQ_.cljs$core$IFn$_invoke$arity$2(new cljs.core.Keyword(null,"client-not-found","client-not-found",-1754042614),op)){
return shadow.remote.runtime.shared.unhandled_client_not_found(runtime,msg);
} else {
return shadow.remote.runtime.shared.reply_unknown_op(runtime,msg);

}
}
}
});
shadow.remote.runtime.shared.run_on_idle = (function shadow$remote$runtime$shared$run_on_idle(state_ref){
var seq__20011 = cljs.core.seq(cljs.core.vals(new cljs.core.Keyword(null,"extensions","extensions",-1103629196).cljs$core$IFn$_invoke$arity$1(cljs.core.deref(state_ref))));
var chunk__20013 = null;
var count__20014 = (0);
var i__20015 = (0);
while(true){
if((i__20015 < count__20014)){
var map__20031 = chunk__20013.cljs$core$IIndexed$_nth$arity$2(null, i__20015);
var map__20031__$1 = cljs.core.__destructure_map(map__20031);
var on_idle = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__20031__$1,new cljs.core.Keyword(null,"on-idle","on-idle",2044706602));
if(cljs.core.truth_(on_idle)){
(on_idle.cljs$core$IFn$_invoke$arity$0 ? on_idle.cljs$core$IFn$_invoke$arity$0() : on_idle.call(null, ));


var G__20298 = seq__20011;
var G__20299 = chunk__20013;
var G__20300 = count__20014;
var G__20301 = (i__20015 + (1));
seq__20011 = G__20298;
chunk__20013 = G__20299;
count__20014 = G__20300;
i__20015 = G__20301;
continue;
} else {
var G__20304 = seq__20011;
var G__20305 = chunk__20013;
var G__20306 = count__20014;
var G__20307 = (i__20015 + (1));
seq__20011 = G__20304;
chunk__20013 = G__20305;
count__20014 = G__20306;
i__20015 = G__20307;
continue;
}
} else {
var temp__5804__auto__ = cljs.core.seq(seq__20011);
if(temp__5804__auto__){
var seq__20011__$1 = temp__5804__auto__;
if(cljs.core.chunked_seq_QMARK_(seq__20011__$1)){
var c__5525__auto__ = cljs.core.chunk_first(seq__20011__$1);
var G__20312 = cljs.core.chunk_rest(seq__20011__$1);
var G__20313 = c__5525__auto__;
var G__20314 = cljs.core.count(c__5525__auto__);
var G__20315 = (0);
seq__20011 = G__20312;
chunk__20013 = G__20313;
count__20014 = G__20314;
i__20015 = G__20315;
continue;
} else {
var map__20037 = cljs.core.first(seq__20011__$1);
var map__20037__$1 = cljs.core.__destructure_map(map__20037);
var on_idle = cljs.core.get.cljs$core$IFn$_invoke$arity$2(map__20037__$1,new cljs.core.Keyword(null,"on-idle","on-idle",2044706602));
if(cljs.core.truth_(on_idle)){
(on_idle.cljs$core$IFn$_invoke$arity$0 ? on_idle.cljs$core$IFn$_invoke$arity$0() : on_idle.call(null, ));


var G__20322 = cljs.core.next(seq__20011__$1);
var G__20323 = null;
var G__20324 = (0);
var G__20325 = (0);
seq__20011 = G__20322;
chunk__20013 = G__20323;
count__20014 = G__20324;
i__20015 = G__20325;
continue;
} else {
var G__20326 = cljs.core.next(seq__20011__$1);
var G__20327 = null;
var G__20328 = (0);
var G__20329 = (0);
seq__20011 = G__20326;
chunk__20013 = G__20327;
count__20014 = G__20328;
i__20015 = G__20329;
continue;
}
}
} else {
return null;
}
}
break;
}
});

//# sourceMappingURL=shadow.remote.runtime.shared.js.map