Packages

slack

0.0.3
0.23.5 0.23.4 0.23.3 0.23.2 0.23.1 0.23.0 0.22.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.3 0.9.2 0.9.1 0.9.0 0.8.0 0.7.1 0.7.0 0.6.0 0.5.0 0.4.2 0.4.1 0.4.0 0.3.0 0.2.0 0.1.0 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

A Slack Real Time Messaging API client.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
2 Dependencies
Dependants
Files
Activity
slack lib slack socket.ex
Raw

lib/slack/socket.ex 

defmodule Slack.Socket do

  @behaviour :websocket_client_handler

  @moduledoc false



  def init(bootstrap = %{module: module, initial_state: initial_state}, socket) do

    slack_state = Slack.State.new(socket, bootstrap.rtm_response)

    {:ok, module_state} = module.init(initial_state, slack_state)



    state = %{

      module: module,

      module_state: module_state,

      slack_state: initial_state

    }



    {:ok, state}

  end



  def websocket_handle({:text, message}, _connection, state) do

    json = JSX.decode!(message, [{:labels, :atom}])



    if Map.has_key?(json, :type) do

      {:ok, new_state} = send_handler_message(json, state)



      state = Map.put(state, :handler_state, new_state)

    end



    {:ok, state}

  end



  def websocket_handle({:ping, data}, _connection, state) do

    {:reply, {:pong, data}, state}

  end



  def websocket_info(:start, _connection, state) do

    {:ok, state}

  end



  def websocket_terminate(_reason, _connection, _state) do

    :ok

  end



  defp send_handler_message(json, state) do

    state.module.handle_message(

      {:type, json.type, json},

      state.slack_state,

      state.module_state

    )

  end

end