anchor.diff:      {title, Title}
     ],
     Reply = [{init, true}, {options, Config}, {data, History}],
  -  {ok, Reply, #ws_state{pulses=PulseTokens, last_utc = LastUTCs}}.
  +  {ok, Reply, State#ws_state{pulses=PulseTokens, last_utc = LastUTCs}}.
   
   
   
  
positive.code:   Ref = erlang:send_after(?WS_TIMEOUT, self(), ping),
    {ok, Req, State#ws_state{timer = Ref}};  
  
  websocket_handle({text, Text}, Req, #ws_state{db=DB, auth=Auth}=State) ->
    Json = jsx:decode(Text),
    Embed = proplists:get_value(<<"embed">>, Json),
    {ok, Title, Queries} = resolve_embed(Embed, Auth, []),
    case pulse_data(Title, Queries, DB) of
      {ok, InitBody, NewState} ->
        {reply, {text, jsx:encode(InitBody)}, Req, NewState};
      _ ->
  
negative.code: 
  
  
  pulse_data(Title, Queries, #ws_state{db = DB} = State) ->
    {History, PulseTokens, LastUTCs1} = lists:unzip3(
    [begin
      {Name, QueryRealtime, QueryHistory} = make_queries(Query),
  