| ===> Failed to fetch and copy dep: {git,"git://github.com/DeadZen/goldrush.git", | |
| {tag,"879c69874a"}} |
A new socket behaviour has been introduced to handle socket authentication in a single place, wire up default channel assigns, and disconnect a user's multiplex connection as needed.
First things first, create a UserSocket module in web/channels/user_socket.ex and move all your channel routes from web/route.ex to the user socket: (replace MyApp with your application module)
0.14.x - web/router.ex:
defmodule MyApp.Router do
...
| config :hackney, | |
| mod_metrics: MyApp.Util.HackneyLibratoMetrics |
| defmodule MyApp.Util.HackneyLibratoMetrics do | |
| require Logger | |
| def new(_, _) do | |
| :ok | |
| end | |
| def delete(_name) do | |
| :ok | |
| end |
| defmodule MyApp.Repo do | |
| use Ecto.Repo, otp_app: :my_app | |
| def log(entry) do | |
| Logger.info(fn -> | |
| [log_time("measure#database.query", entry.query_time, true), log_time("measure#database.queue", entry.queue_time, false)] | |
| end) | |
| super(entry) | |
| end |
| results = try do | |
| Task.await(search_task, @timeout) | |
| catch | |
| :exit, {:timeout, {Task, :await, [_, @timeout]}} -> [] | |
| end |
Then add
worker(Redis, []),to your supervision tree
| defmodule MyApp.CommentView do | |
| use MyApp.Web, :view | |
| @attributes ~W(id name inserted_at) | |
| def render("show.json", %{data: comments}) when is_list(comments) do | |
| for comment <- comments do | |
| render("show.json", data: comment) | |
| end | |
| end | |
| defmodule MyApp.MyModelController do | |
| use MyApp.Web, :controller | |
| plug :action | |
| def show(conn, params) do | |
| render conn, "show.json", data: Repo.get!(MyModel, params[:id]) | |
| end | |
| end |
| def render("show.json", %{data: data}) do | |
| %{ | |
| id: data.id, | |
| name: data.name, | |
| title: String.capitalize!(data.name) | |
| } | |
| end |