Poll Twitter using ExTwitter and the Streaming API

Author: Chris Rees

apps/zapdos/.gitignore

@@ -0,0 +1,20 @@
+# The directory Mix will write compiled artifacts to.
+/_build
+
+# If you run "mix test --cover", coverage assets end up here.
+/cover
+
+# The directory Mix downloads your dependencies sources to.
+/deps
+
+# Where 3rd-party dependencies like ExDoc output generated docs.
+/doc
+
+# Ignore .fetch files in case you like to edit your project deps locally.
+/.fetch
+
+# If the VM crashes, it generates a dump, let's ignore it too.
+erl_crash.dump
+
+# Also ignore archive artifacts (built via "mix archive.build").
+*.ez

apps/zapdos/README.md

@@ -0,0 +1,19 @@
+# Zapdos
+
+**TODO: Add description**
+
+## Installation
+
+If [available in Hex](https://hex.pm/docs/publish), the package can be installed
+by adding `zapdos` to your list of dependencies in `mix.exs`:
+
+```elixir
+def deps do
+  [{:zapdos, "~> 0.1.0"}]
+end
+```
+
+Documentation can be generated with [ExDoc](https://github.com/elixir-lang/ex_doc)
+and published on [HexDocs](https://hexdocs.pm). Once published, the docs can
+be found at [https://hexdocs.pm/zapdos](https://hexdocs.pm/zapdos).
+

apps/zapdos/config/config.exs

@@ -0,0 +1,37 @@
+# This file is responsible for configuring your application
+# and its dependencies with the aid of the Mix.Config module.
+use Mix.Config
+
+# This configuration is loaded before any dependency and is restricted
+# to this project. If another project depends on this project, this
+# file won't be loaded nor affect the parent project. For this reason,
+# if you want to provide default values for your application for
+# 3rd-party users, it should be done in your "mix.exs" file.
+
+# You can configure for your application as:
+#
+#     config :zapdos, key: :value
+#
+# And access this configuration in your application as:
+#
+#     Application.get_env(:zapdos, :key)
+#
+# Or configure a 3rd-party app:
+#
+#     config :logger, level: :info
+#
+
+# It is also possible to import configuration files, relative to this
+# directory. For example, you can emulate configuration per environment
+# by uncommenting the line below and defining dev.exs, test.exs and such.
+# Configuration from the imported file will override the ones defined
+# here (which is why it is important to import them last).
+#
+#     import_config "#{Mix.env}.exs"
+
+config :extwitter, :oauth, [
+   consumer_key: "",
+   consumer_secret: "",
+   access_token: "",
+   access_token_secret: ""
+]

apps/zapdos/lib/zapdos.ex

@@ -0,0 +1,15 @@
+defmodule Zapdos do
+  alias Zapdos.ColorParsing
+
+  @moduledoc """
+  Documentation for Zapdos.
+  """
+
+  def get_tweets(query) do
+    ExTwitter.stream_filter(track: query)
+    |> Stream.map(fn(tweet) -> tweet.text end)
+    |> Stream.map(fn(text) -> ColorParsing.get_color(text) |> ColorParsing.hex_to_number |> IO.puts end)
+    |> Enum.to_list
+  end
+
+end

apps/zapdos/lib/zapdos/application.ex

@@ -0,0 +1,20 @@
+defmodule Zapdos.Application do
+  # See http://elixir-lang.org/docs/stable/elixir/Application.html
+  # for more information on OTP Applications
+  @moduledoc false
+
+  use Application
+
+  def start(_type, _args) do
+    import Supervisor.Spec, warn: false
+
+    # Define workers and child supervisors to be supervised
+    children = [
+    ]
+
+    # See http://elixir-lang.org/docs/stable/elixir/Supervisor.html
+    # for other strategies and supported options
+    opts = [strategy: :one_for_one, name: Zapdos.Supervisor]
+    Supervisor.start_link(children, opts)
+  end
+end

apps/zapdos/lib/zapdos/color_parsing.ex

@@ -0,0 +1,15 @@
+defmodule Zapdos.ColorParsing do
+  def get_color("Color: #" <> <<raw_hex::bytes-size(6)>> <> _), do: raw_hex
+
+  def get_color(_), do: "FFFFFF"
+
+  def parse_rgb_hex(rgb_value) do
+    [r1, r2, g1, g2, b1, b2] = rgb_value |> String.codepoints |> Enum.take(-6)
+    {hex_to_number(r1 <> r2), hex_to_number(g1 <> g2), hex_to_number(b1 <> b2)}
+  end
+
+  def hex_to_number(hex_value) do
+    hex_value |> String.upcase |> Base.decode16! |> :binary.decode_unsigned
+  end
+end
+

apps/zapdos/lib/zapdos/pluck.ex

@@ -0,0 +1,25 @@
+defmodule Zapdos.Pluck do
+  use GenServer
+
+  def start_link do
+    GenServer.start_link(__MODULE__, %{})
+  end
+
+  def init(state) do
+    schedule_work() # Schedule work to be performed at some point
+    {:ok, state}
+  end
+
+  def handle_info(:work, state) do
+    # Do the work you desire here
+    Zapdos.get_tweets("#cmm_storm", 1)
+    |> IO.inspect
+
+    schedule_work() # Reschedule once more
+    {:noreply, state}
+  end
+
+  defp schedule_work() do
+    Process.send_after(self(), :work, 15 * 1000)
+  end
+end

apps/zapdos/mix.exs

@@ -0,0 +1,40 @@
+defmodule Zapdos.Mixfile do
+  use Mix.Project
+
+  def project do
+    [app: :zapdos,
+     version: "0.1.0",
+     build_path: "../../_build",
+     config_path: "../../config/config.exs",
+     deps_path: "../../deps",
+     lockfile: "../../mix.lock",
+     elixir: "~> 1.3",
+     build_embedded: Mix.env == :prod,
+     start_permanent: Mix.env == :prod,
+     deps: deps()]
+  end
+
+  # Configuration for the OTP application
+  #
+  # Type "mix help compile.app" for more information
+  def application do
+    # Specify extra applications you'll use from Erlang/Elixir
+    [extra_applications: [:logger],
+     mod: {Zapdos.Application, []}]
+  end
+
+  # Dependencies can be Hex packages:
+  #
+  #   {:my_dep, "~> 0.3.0"}
+  #
+  # Or git/path repositories:
+  #
+  #   {:my_dep, git: "https://github.com/elixir-lang/my_dep.git", tag: "0.1.0"}
+  #
+  # Type "mix help deps" for more examples and options
+  defp deps do
+    [
+      {:extwitter, "~> 0.8"},
+    ]
+  end
+end

apps/zapdos/test/test_helper.exs

@@ -0,0 +1 @@
+ExUnit.start()

apps/zapdos/test/zapdos_test.exs

@@ -0,0 +1,8 @@
+defmodule ZapdosTest do
+  use ExUnit.Case
+  doctest Zapdos
+
+  test "the truth" do
+    assert 1 + 1 == 2
+  end
+end

apps/zeus/lib/zeus.ex

@@ -18,6 +18,9 @@ defmodule Zeus do
     # for other strategies and supported options
     opts = [strategy: :one_for_one, name: Zeus.Supervisor]
     Supervisor.start_link(children, opts)
+
+    :timer.apply_interval(:timer.seconds(15), Zapdos, :get_tweet("#cmm_storm", 1))
+    |> IO.puts
   end
 
   # Tell Phoenix to update the endpoint configuration

apps/zeus/lib/zeus/color_parsing.ex

@@ -1,11 +1,3 @@
 defmodule Zeus.ColorParsing do
 
-  def parse_rgb_hex(rgb_value) do
-    [r1, r2, g1, g2, b1, b2] = rgb_value |> String.codepoints |> Enum.take(-6)
-    {hex_to_number(r1 <> r2), hex_to_number(g1 <> g2), hex_to_number(b1 <> b2)}
-  end
-
-  def hex_to_number(hex_value) do
-    hex_value |> String.upcase |> Base.decode16! |> :binary.decode_unsigned
-  end
 end

apps/zeus/mix.exs

@@ -39,7 +39,8 @@ defmodule Zeus.Mixfile do
      {:phoenix_live_reload, "~> 1.0", only: :dev},
      {:gettext, "~> 0.11"},
      {:cowboy, "~> 1.0"},
-     {:lightning, in_umbrella: true}]
+     {:lightning, in_umbrella: true},
+     {:zapdos, in_umbrella: true}]
   end
 
   def aliases do

mix.lock

@@ -2,6 +2,7 @@
   "cowlib": {:hex, :cowlib, "1.0.2", "9d769a1d062c9c3ac753096f868ca121e2730b9a377de23dec0f7e08b1df84ee", [:make], []},
   "distillery": {:hex, :distillery, "1.1.2", "4cf32ecc70ca7eecca9e52e111edf320bd78011050825863cd8bc7ffee686c5d", [:mix], []},
   "elixir_make": {:hex, :elixir_make, "0.3.0", "285147fa943806eee82f6680b7b446b5569bcf3ee8328fa0a7c200ffc44fbaba", [:mix], []},
+  "extwitter": {:hex, :extwitter, "0.8.2", "1b1b6842c6541ddfa468f1589b54c02a3b278b5ae74d6bed260655394d8cc7be", [:mix], [{:oauther, "~> 1.1", [hex: :oauther, optional: false]}, {:poison, "~> 2.0", [hex: :poison, optional: false]}]},
   "fs": {:hex, :fs, "0.9.2", "ed17036c26c3f70ac49781ed9220a50c36775c6ca2cf8182d123b6566e49ec59", [:rebar], []},
   "gettext": {:hex, :gettext, "0.13.1", "5e0daf4e7636d771c4c71ad5f3f53ba09a9ae5c250e1ab9c42ba9edccc476263", [:mix], []},
   "mime": {:hex, :mime, "1.0.1", "05c393850524767d13a53627df71beeebb016205eb43bfbd92d14d24ec7a1b51", [:mix], []},
@@ -14,6 +15,7 @@
   "nerves_toolchain_arm_unknown_linux_gnueabihf": {:hex, :nerves_toolchain_arm_unknown_linux_gnueabihf, "0.9.0", "5a1bca8c46776ad24c358ab58800ed470f91a3e294ac6eb8ffda0041954781e1", [:mix], [{:nerves, "~> 0.4.0", [hex: :nerves, optional: false]}, {:nerves_toolchain_ctng, "~> 0.8.0", [hex: :nerves_toolchain_ctng, optional: false]}]},
   "nerves_toolchain_ctng": {:hex, :nerves_toolchain_ctng, "0.8.0", "6dff7ed51e1711c5f4da3d559bc528a8265e3dd950dda95f4d6832aed9dbe320", [:mix], []},
   "nerves_wpa_supplicant": {:hex, :nerves_wpa_supplicant, "0.2.3", "2666b21bf0868f0d3b127930c3bacf59b178a0d015d308ae3985dcb7c1595870", [:make, :mix], [{:elixir_make, "~> 0.3", [hex: :elixir_make, optional: false]}]},
+  "oauther": {:hex, :oauther, "1.1.0", "c9a56e200507ce64e069f5273143db0cddd7904cd5d1fe46920388a48f22441b", [:mix], []},
   "phoenix": {:hex, :phoenix, "1.2.1", "6dc592249ab73c67575769765b66ad164ad25d83defa3492dc6ae269bd2a68ab", [:mix], [{:cowboy, "~> 1.0", [hex: :cowboy, optional: true]}, {:phoenix_pubsub, "~> 1.0", [hex: :phoenix_pubsub, optional: false]}, {:plug, "~> 1.1", [hex: :plug, optional: false]}, {:poison, "~> 1.5 or ~> 2.0", [hex: :poison, optional: false]}]},
   "phoenix_html": {:hex, :phoenix_html, "2.9.3", "1b5a2122cbf743aa242f54dced8a4f1cc778b8bd304f4b4c0043a6250c58e258", [:mix], [{:plug, "~> 1.0", [hex: :plug, optional: false]}]},
   "phoenix_live_reload": {:hex, :phoenix_live_reload, "1.0.8", "4333f9c74190f485a74866beff2f9304f069d53f047f5fbb0fb8d1ee4c495f73", [:mix], [{:fs, "~> 0.9.1", [hex: :fs, optional: false]}, {:phoenix, "~> 1.0 or ~> 1.2-rc", [hex: :phoenix, optional: false]}]},