Skip to content
This repository has been archived by the owner on Oct 24, 2022. It is now read-only.

Commit

Permalink
Remove dialyze annotations and update deps
Browse files Browse the repository at this point in the history
  • Loading branch information
suvash committed May 23, 2018
1 parent 76d65c2 commit b9dce2a
Show file tree
Hide file tree
Showing 5 changed files with 17 additions and 69 deletions.
10 changes: 3 additions & 7 deletions Dockerfile
Original file line number Diff line number Diff line change
@@ -1,15 +1,11 @@
FROM elixir:1.6-alpine
ENV DEBIAN_FRONTEND="noninteractive"
FROM elixir:1.6.5-alpine

RUN mkdir -p /usr/src/app
WORKDIR /usr/src/app

COPY mix.exs mix.lock /usr/src/app/
COPY config /usr/src/app/config
RUN mix local.hex --force \
&& mix local.rebar --force \
&& mix deps.get \
&& mix deps.compile

RUN mix do local.hex --force, local.rebar --force, deps.get, deps.compile

COPY . /usr/src/app
CMD ["elixir"]
9 changes: 0 additions & 9 deletions lib/hulaaki/encoder.ex
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,6 @@ defmodule Hulaaki.Encoder do
Provides functions for encoding Message structs to bytes(binary)
"""

@type dup :: 0 | 1
@type qos :: 0 | 1 | 2
@type retain :: 0 | 1
@type packet_value :: 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12 | 13 | 14

@doc """
Encodes the fixed header (as specified in MQTT spec) for a given Message struct
"""
Expand Down Expand Up @@ -151,14 +146,12 @@ defmodule Hulaaki.Encoder do
message_id_length + topics_length
end

@spec encode_fixed_header_first_byte(packet_value, dup, qos, retain) :: binary
defp encode_fixed_header_first_byte(packet_value, dup, qos, retain)
when packet_value > 0 and packet_value < 15 and (dup == 0 or dup == 1) and
(qos == 0 or qos == 1 or qos == 2) and (retain == 0 or retain == 1) do
<<packet_value::size(4), dup::size(1), qos::size(2), retain::size(1)>>
end

@spec encode_fixed_header_second_byte(number) :: binary
defp encode_fixed_header_second_byte(remaining_length)
when remaining_length >= 0 and remaining_length <= 268_435_455 do
encode_fixed_header_remaining_length(remaining_length)
Expand All @@ -168,14 +161,12 @@ defmodule Hulaaki.Encoder do
Encodes remaining length using a variable length
encoding scheme specified in MQTT 3.1.1 spec section 2.2.3
"""
@spec encode_fixed_header_remaining_length(number) :: binary
def encode_fixed_header_remaining_length(0), do: <<0>>

def encode_fixed_header_remaining_length(number) when number > 0 do
encode_fixed_header_remaining_length(number, <<>>)
end

@spec encode_fixed_header_remaining_length(number, binary) :: binary
defp encode_fixed_header_remaining_length(number, accumulator) do
divisor = 128
dividend = div(number, divisor)
Expand Down
38 changes: 0 additions & 38 deletions lib/hulaaki/message.ex
Original file line number Diff line number Diff line change
Expand Up @@ -21,18 +21,6 @@ defmodule Hulaaki.Message do
* `keep_alive` : An integer representing the keep alive value in seconds.
"""

@type t :: %__MODULE__{
client_id: String.t(),
username: String.t(),
password: String.t(),
will_topic: String.t(),
will_message: String.t(),
will_qos: 0 | 1 | 2,
will_retain: 0 | 1,
clean_session: 0 | 1,
keep_alive: integer,
type: atom
}
defstruct [
:client_id,
:username,
Expand Down Expand Up @@ -89,7 +77,6 @@ defmodule Hulaaki.Message do
* `return_code` : An integer of value either 0,1,2,3,4,5 representing the return code.
"""

@type t :: %__MODULE__{session_present: 0 | 1, return_code: 1 | 2 | 3 | 4 | 5, type: atom}
defstruct [:session_present, :return_code, type: :CONNACK]
end

Expand All @@ -116,15 +103,6 @@ defmodule Hulaaki.Message do
* `retain` : An integer of value either 0,1 representing the retain bit.
"""

@type t :: %__MODULE__{
id: non_neg_integer,
topic: String.t(),
message: String.t(),
dup: 0 | 1,
qos: 0 | 1 | 2,
retain: 0 | 1,
type: atom
}
defstruct [:id, :topic, :message, :dup, :qos, :retain, type: :PUBLISH]
end

Expand Down Expand Up @@ -168,7 +146,6 @@ defmodule Hulaaki.Message do
* `packet_id` : An integer of value upto 65535 (2 bytes) representing packet identifier
"""

@type t :: %__MODULE__{id: non_neg_integer, type: atom}
defstruct [:id, type: :PUBACK]
end

Expand All @@ -188,7 +165,6 @@ defmodule Hulaaki.Message do
* `packet_id` : An integer of value upto 65535 (2 bytes) representing packet identifier
"""

@type t :: %__MODULE__{id: non_neg_integer, type: atom}
defstruct [:id, type: :PUBREC]
end

Expand All @@ -208,7 +184,6 @@ defmodule Hulaaki.Message do
* `packet_id` : An integer of value upto 65535 (2 bytes) representing packet identifier
"""

@type t :: %__MODULE__{id: non_neg_integer, type: atom}
defstruct [:id, type: :PUBREL]
end

Expand All @@ -228,7 +203,6 @@ defmodule Hulaaki.Message do
* `packet_id` : An integer of value upto 65535 (2 bytes) representing packet identifier
"""

@type t :: %__MODULE__{id: non_neg_integer, type: atom}
defstruct [:id, type: :PUBCOMP]
end

Expand All @@ -250,12 +224,6 @@ defmodule Hulaaki.Message do
* `requested_qoses` : A list of integer of value 0,1,2 representing qoses.
"""

@type t :: %__MODULE__{
id: non_neg_integer,
topics: list(String.t()),
requested_qoses: list(0 | 1 | 2),
type: atom
}
defstruct [:id, :topics, :requested_qoses, type: :SUBSCRIBE]
end

Expand All @@ -281,7 +249,6 @@ defmodule Hulaaki.Message do
* `granted_qoses` : A list of integer of value 0,1,2,128 representing qoses.
"""

@type t :: %__MODULE__{id: non_neg_integer, granted_qoses: list(0 | 1 | 2 | 128), type: atom}
defstruct [:id, :granted_qoses, type: :SUBACK]
end

Expand All @@ -306,7 +273,6 @@ defmodule Hulaaki.Message do
* `topics` : A list of string(binary) representing various topics.
"""

@type t :: %__MODULE__{id: non_neg_integer, topics: list(String.t()), type: atom}
defstruct [:id, :topics, type: :UNSUBSCRIBE]
end

Expand All @@ -328,7 +294,6 @@ defmodule Hulaaki.Message do
* `packet_id` : An integer of value upto 65535 (2 bytes) representing packet identifier
"""

@type t :: %__MODULE__{id: non_neg_integer, type: atom}
defstruct [:id, type: :UNSUBACK]
end

Expand All @@ -345,7 +310,6 @@ defmodule Hulaaki.Message do
Struct for Hulaaki PingReq
"""

@type t :: %__MODULE__{type: atom}
defstruct type: :PINGREQ
end

Expand All @@ -361,7 +325,6 @@ defmodule Hulaaki.Message do
Struct for Hulaaki PingResp
"""

@type t :: %__MODULE__{type: atom}
defstruct type: :PINGRESP
end

Expand All @@ -377,7 +340,6 @@ defmodule Hulaaki.Message do
Struct for Hulaaki Disconnect
"""

@type t :: %__MODULE__{type: atom}
defstruct type: :DISCONNECT
end

Expand Down
9 changes: 4 additions & 5 deletions mix.exs
Original file line number Diff line number Diff line change
Expand Up @@ -25,11 +25,10 @@ defmodule Hulaaki.Mixfile do

defp deps do
[
{:inch_ex, "~> 0.5.6", only: :docs},
{:earmark, "~> 1.2.4", only: [:dev, :docs]},
{:ex_doc, "~> 0.18.2", only: [:dev, :docs]},
{:dialyze, "~> 0.2.1", only: :test},
{:excoveralls, "~> 0.8.1", only: [:dev, :test]}
{:inch_ex, "~> 0.5", only: :docs},
{:earmark, "~> 1.2", only: [:dev, :docs]},
{:ex_doc, "~> 0.18", only: [:dev, :docs]},
{:excoveralls, "~> 0.8", only: [:dev, :test]}
]
end

Expand Down
20 changes: 10 additions & 10 deletions mix.lock
Original file line number Diff line number Diff line change
@@ -1,17 +1,17 @@
%{
"certifi": {:hex, :certifi, "2.0.0", "a0c0e475107135f76b8c1d5bc7efb33cd3815cb3cf3dea7aefdd174dabead064", [:rebar3], [], "hexpm"},
"dialyze": {:hex, :dialyze, "0.2.1", "9fb71767f96649020d769db7cbd7290059daff23707d6e851e206b1fdfa92f9d", [:mix], []},
"earmark": {:hex, :earmark, "1.2.4", "99b637c62a4d65a20a9fb674b8cffb8baa771c04605a80c911c4418c69b75439", [:mix], [], "hexpm"},
"ex_doc": {:hex, :ex_doc, "0.18.2", "993e0a95e9fbb790ac54ea58e700b45b299bd48bc44b4ae0404f28161f37a83e", [:mix], [{:earmark, "~> 1.1", [hex: :earmark, repo: "hexpm", optional: false]}], "hexpm"},
"excoveralls": {:hex, :excoveralls, "0.8.1", "0bbf67f22c7dbf7503981d21a5eef5db8bbc3cb86e70d3798e8c802c74fa5e27", [:mix], [{:exjsx, ">= 3.0.0", [hex: :exjsx, repo: "hexpm", optional: false]}, {:hackney, ">= 0.12.0", [hex: :hackney, repo: "hexpm", optional: false]}], "hexpm"},
"certifi": {:hex, :certifi, "2.3.1", "d0f424232390bf47d82da8478022301c561cf6445b5b5fb6a84d49a9e76d2639", [:rebar3], [{:parse_trans, "3.2.0", [hex: :parse_trans, repo: "hexpm", optional: false]}], "hexpm"},
"earmark": {:hex, :earmark, "1.2.5", "4d21980d5d2862a2e13ec3c49ad9ad783ffc7ca5769cf6ff891a4553fbaae761", [:mix], [], "hexpm"},
"ex_doc": {:hex, :ex_doc, "0.18.3", "f4b0e4a2ec6f333dccf761838a4b253d75e11f714b85ae271c9ae361367897b7", [:mix], [{:earmark, "~> 1.1", [hex: :earmark, repo: "hexpm", optional: false]}], "hexpm"},
"excoveralls": {:hex, :excoveralls, "0.8.2", "b941a08a1842d7aa629e0bbc969186a4cefdd035bad9fe15d43aaaaaeb8fae36", [:mix], [{:exjsx, ">= 3.0.0", [hex: :exjsx, repo: "hexpm", optional: false]}, {:hackney, ">= 0.12.0", [hex: :hackney, repo: "hexpm", optional: false]}], "hexpm"},
"exjsx": {:hex, :exjsx, "4.0.0", "60548841e0212df401e38e63c0078ec57b33e7ea49b032c796ccad8cde794b5c", [:mix], [{:jsx, "~> 2.8.0", [hex: :jsx, repo: "hexpm", optional: false]}], "hexpm"},
"hackney": {:hex, :hackney, "1.11.0", "4951ee019df102492dabba66a09e305f61919a8a183a7860236c0fde586134b6", [:rebar3], [{:certifi, "2.0.0", [hex: :certifi, repo: "hexpm", optional: false]}, {:idna, "5.1.0", [hex: :idna, repo: "hexpm", optional: false]}, {:metrics, "1.0.1", [hex: :metrics, repo: "hexpm", optional: false]}, {:mimerl, "1.0.2", [hex: :mimerl, repo: "hexpm", optional: false]}, {:ssl_verify_fun, "1.1.1", [hex: :ssl_verify_fun, repo: "hexpm", optional: false]}], "hexpm"},
"idna": {:hex, :idna, "5.1.0", "d72b4effeb324ad5da3cab1767cb16b17939004e789d8c0ad5b70f3cea20c89a", [:rebar3], [{:unicode_util_compat, "0.3.1", [hex: :unicode_util_compat, repo: "hexpm", optional: false]}], "hexpm"},
"hackney": {:hex, :hackney, "1.12.1", "8bf2d0e11e722e533903fe126e14d6e7e94d9b7983ced595b75f532e04b7fdc7", [:rebar3], [{:certifi, "2.3.1", [hex: :certifi, repo: "hexpm", optional: false]}, {:idna, "5.1.1", [hex: :idna, repo: "hexpm", optional: false]}, {:metrics, "1.0.1", [hex: :metrics, repo: "hexpm", optional: false]}, {:mimerl, "1.0.2", [hex: :mimerl, repo: "hexpm", optional: false]}, {:ssl_verify_fun, "1.1.1", [hex: :ssl_verify_fun, repo: "hexpm", optional: false]}], "hexpm"},
"idna": {:hex, :idna, "5.1.1", "cbc3b2fa1645113267cc59c760bafa64b2ea0334635ef06dbac8801e42f7279c", [:rebar3], [{:unicode_util_compat, "0.3.1", [hex: :unicode_util_compat, repo: "hexpm", optional: false]}], "hexpm"},
"inch_ex": {:hex, :inch_ex, "0.5.6", "418357418a553baa6d04eccd1b44171936817db61f4c0840112b420b8e378e67", [:mix], [{:poison, "~> 1.5 or ~> 2.0 or ~> 3.0", [hex: :poison, repo: "hexpm", optional: false]}], "hexpm"},
"jsx": {:hex, :jsx, "2.8.3", "a05252d381885240744d955fbe3cf810504eb2567164824e19303ea59eef62cf", [:mix, :rebar3], [], "hexpm"},
"metrics": {:hex, :metrics, "1.0.1", "25f094dea2cda98213cecc3aeff09e940299d950904393b2a29d191c346a8486", [:rebar3], []},
"mimerl": {:hex, :mimerl, "1.0.2", "993f9b0e084083405ed8252b99460c4f0563e41729ab42d9074fd5e52439be88", [:rebar3], []},
"metrics": {:hex, :metrics, "1.0.1", "25f094dea2cda98213cecc3aeff09e940299d950904393b2a29d191c346a8486", [:rebar3], [], "hexpm"},
"mimerl": {:hex, :mimerl, "1.0.2", "993f9b0e084083405ed8252b99460c4f0563e41729ab42d9074fd5e52439be88", [:rebar3], [], "hexpm"},
"parse_trans": {:hex, :parse_trans, "3.2.0", "2adfa4daf80c14dc36f522cf190eb5c4ee3e28008fc6394397c16f62a26258c2", [:rebar3], [], "hexpm"},
"poison": {:hex, :poison, "3.1.0", "d9eb636610e096f86f25d9a46f35a9facac35609a7591b3be3326e99a0484665", [:mix], [], "hexpm"},
"ssl_verify_fun": {:hex, :ssl_verify_fun, "1.1.1", "28a4d65b7f59893bc2c7de786dec1e1555bd742d336043fe644ae956c3497fbe", [:make, :rebar], [], "hexpm"},
"unicode_util_compat": {:hex, :unicode_util_compat, "0.3.1", "a1f612a7b512638634a603c8f401892afbf99b8ce93a45041f8aaca99cadb85e", [], [], "hexpm"},
"unicode_util_compat": {:hex, :unicode_util_compat, "0.3.1", "a1f612a7b512638634a603c8f401892afbf99b8ce93a45041f8aaca99cadb85e", [:rebar3], [], "hexpm"},
}

0 comments on commit b9dce2a

Please sign in to comment.