Packages

pixie

0.2.0
0.3.9 0.3.8 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.3 0.2.2 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.3 0.0.2 0.0.1

Bayeux compatible server written in Elixir.

HexDocs

Current section

Files

Jump to
Readme
22 Versions
10 Dependencies
Dependants
Files
Activity
pixie lib pixie backends redis client_subscriptions.ex
Raw

lib/pixie/backends/redis/client_subscriptions.ex 

defmodule Pixie.Backend.Redis.ClientSubscriptions do

  import Pixie.Backend.Redis.Connection



  @moduledoc false



  def get client_id do

    {:ok, subs} = query ["SMEMBERS", key(client_id)]

    subs

  end



  def subscribed? client_id, channel_name do

    case query ["SISMEMBER", key(client_id), channel_name] do

      {:ok, "1"} -> true

      {:ok, "0"} -> false

    end

  end



  def subscribe client_id, channel_name do

    {ok, _} = query ["SADD", key(client_id), channel_name]

    ok

  end



  def unsubscribe client_id, channel_name do

    {ok, _} = query ["SREM", key(client_id), channel_name]

    ok

  end



  defp key client_id do

    cluster_namespace("client_subscriptions:#{client_id}")

  end

end