Packages

fifo_utils

0.1.17
0.1.53 0.1.52 0.1.51 0.1.50 0.1.49 0.1.48 0.1.47 0.1.46 0.1.45 0.1.44 0.1.43 0.1.42 0.1.41 0.1.40 0.1.39 0.1.38 0.1.37 0.1.35 0.1.34 0.1.33 0.1.32 0.1.31 0.1.30 0.1.29 0.1.28 0.1.27 0.1.26 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.7

FiFo utility library

Current section

Files

Jump to
Readme
43 Versions
1 Dependency
Dependants
Files
Activity
fifo_utils src fifo_cmd.erl
Raw

src/fifo_cmd.erl 

-module(fifo_cmd).



-export([run/1, run/2, run_json/1, run_json/2]).



run_json(Cmd) ->

    run_json(Cmd, []).



run_json(Cmd, Args) ->

    case run(Cmd, Args) of

        {ok, Data} ->

            {ok, jsx:decode(Data)};

        Error ->

            Error

    end.



run(Cmd) ->

    run(Cmd, []).



run(Cmd, Args) ->

    Port = open_port({spawn_executable, Cmd},

                     [use_stdio, binary, {line, 2048}, {args, mk_args(Args)},

                      stderr_to_stdout, exit_status]),

    wait_for_port(Port).



wait_for_port(Port) ->

    wait_for_port(Port, <<>>).



wait_for_port(Port, Reply) ->

    wait_for_port(Port, Reply, infinity).



wait_for_port(Port, Reply, Timeout) ->

    receive

        {Port, {data, {eol, Data}}} ->

            wait_for_port(Port, <<Reply/binary, Data/binary>>);

        {Port, {data, Data}} ->

            wait_for_port(Port, <<Reply/binary, Data/binary>>);

        {Port,{exit_status, 0}} ->

            {ok, Reply};

        {Port,{exit_status, S}} ->

            {error, S, Reply}

    after

        Timeout ->

            port_close(Port),

            {error, timeout, Reply}

    end.





mk_args([]) ->

    [];

mk_args([{K, V} | R]) ->

    [ mk_val(K), mk_val(V) | mk_args(R)];

mk_args([K | R]) ->

    [ mk_val(K) | mk_args(R)].



mk_val(I) when is_integer(I) ->

    integer_to_list(I);

mk_val(A) when is_atom(A) ->

    [$- | atom_to_list(A)];

mk_val(L) when is_list(L)->

    L;

mk_val(B) when is_binary(B) ->

    binary_to_list(B).