Packages

ca

7.1.2
7.6.2 7.4.14 7.1.4 7.1.3 7.1.2 7.1.1 6.1.1 5.11.22 5.11.15 5.11.13 5.11.5 5.11.1 5.10.4 5.10.3 5.10.2 5.10.1 4.8.2 4.7.26 4.7.14 4.7.13 4.7.12 4.7.2 4.7.1 4.6.1 4.6.0 2.7.14 1.11.0 1.10.0 1.2.1 1.2.0 1.1.1 1.1.0 0.10.0 0.9.0 0.8.2 0.8.1 0.8.0 0.1.0

CA CXC 138 21 Certificate Authority

HexDocs

Current section

Files

Jump to
Readme
38 Versions
6 Dependencies
Dependants
Files
Activity
ca lib services ocsp.ex
Raw

lib/services/ocsp.ex 

defmodule CA.OCSP do

  @moduledoc "CA/OCSP TCP server."

  require CA



  def code(),  do: :binary.encode_hex(:crypto.strong_rand_bytes(8))



  def start_link(port: port), do: {:ok, :erlang.spawn_link(fn -> listen(port) end)}

  def child_spec(opt) do

      %{

        id: OCSP,

        start: {CA.OCSP, :start_link, [opt]},

        type: :supervisor,

        restart: :permanent,

        shutdown: 500

      }

  end



    def listen(port) do

        {:ok, socket} = :gen_tcp.listen(port,

          [:binary, {:packet, 0}, {:active, false}, {:reuseaddr, true}])

        accept(socket)

    end



    def accept(socket) do

        {:ok, fd} = :gen_tcp.accept(socket)

        :erlang.spawn(fn -> __MODULE__.loop(fd) end)

        accept(socket)

    end



    def message(_socket, cms) do

        :logger.info ~c"Unknown message request ~p", [cms]

    end



    def answer(socket, res) do

        :gen_tcp.send(socket, res)

    end



    def loop(socket) do

        case :gen_tcp.recv(socket, 0) do

             {:ok, data} ->

                  {:ok, dec} = :'OCSP'.decode(:OCSPRequest, data)

                  :io.format ~c"OCSPRequest:~n~p~n", [dec]

                  __MODULE__.message(socket, dec)

                  __MODULE__.loop(socket)

             {:error, _} -> :exit

        end

    end

end