Packages

ca

5.10.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
1 Dependency
Dependants
Files
Activity
ca lib services cmc.ex
Raw

lib/services/cmc.ex 

defmodule CA.CMC do

    @moduledoc "CA/CMC TLS server."

    require CA



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

    def start(), do: :erlang.spawn(fn -> listen(1839) 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 '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} = :'EnrollmentMessageSyntax-2009'.decode(:'PKIData', data)

                  {:PKIData, _controlSequence, _reqSequence, cmsSequence, _otherMsgSequence} = dec

                  :io.format 'PKIData:~n~p~n', [dec]

                  __MODULE__.message(socket, cmsSequence)

                  loop(socket)

             {:error, :closed} -> :exit

        end

    end

end