anchor.diff:              error ->
                   #{error => <<"Ports are not supported yet">>}
           end,
  -    epl_json:encode(#{id => list_to_binary(NodeId), info => Info}, <<"epl_st">>);
  +    epl_json:encode(#{id => list_to_binary(NodeId), info => Info}, <<"node-info">>);
   node_info(NodeId) when is_binary(NodeId) ->
       node_info(binary_to_list(NodeId)).
   
  
positive.code: unsubscribe() ->
      gen_server:cast(?MODULE, {unsubscribe, self()}).
  
  encode(Data) ->
      epl_json:encode(Data, <<"epl_st">>).
  
  node_info(NodeId) when is_list(NodeId) ->
      Info =
          case node_id_to_pid(NodeId) of
  
negative.code: -export([start_link/0,
           subscribe/0,
           unsubscribe/0,
           node_info/1]).
  
  %% gen_server callbacks
  