anchor.diff:              ok;
           {ok, {{_, Code, _}, _, Body}} ->
               {error, {Code, Body}}
  -    end.
  -send_to_output(TriggerId, {Value, Timestamp, StreamId, Input, [_|Rest]}) ->
  -    case httpc:request(post, {URI, [],"application/json", Message}, [], []) of
  -        {ok,{{_, 200, _}, _, _}} ->
  -            ok;
  -        {ok, {{_, Code, _}, _, Body}} ->
  -            {error, {Code, Body}}
  -    end.
  +    end,
  +    send_to_output(TriggerId, {Value, Timestamp, StreamId, [Input|Inputs], Rest}).
  +send_to_output(TriggerId, {Value, Timestamp, StreamId, [Input|Inputs], [_|Rest]}) ->
  +    erlang:display("Invalid output!"),
  +    send_to_output(TriggerId, {Value, Timestamp, StreamId, [Input|Inputs], Rest}).
                 
   
   handle_command({add,{Input,User}},[]) ->
  
positive.code: 
  
  
  
  
  
  
  %% @doc
  %% Function: apply_function()/3
  %% Purpose: Applies the specified predefined function
  
negative.code:             {error, {Code, Body}};
          {ok, Response} ->
              ok
      end,
      send_to_output(TriggerId, {Value, Timestamp, StreamId, [Input|Inputs], Rest});
  send_to_output(TriggerId, {Value, Timestamp, StreamId, [Input|Inputs], [{uri,URI}|Rest]}) ->
      Message = lib_json:set_attrs([{trigger, "{}"},
          {"trigger.value", Value},
          {"trigger.timestamp", Timestamp},
          {"trigger.stream_id", StreamId},
  