スポンサーリンク

2015年8月15日

[Rails Tutorial for Phoenix]Following users

Goal

ユーザ間のフォロー機能を実装する。

Wait a minute

長くお付き合い頂きましたが、本章で最後となります。
本章の内容はフォロー機能の実装となります。
このチュートリアルにおける最後の山場です。
最後のひと踏ん張り頑張っていきましょう。

Index

Following users
|> Preparation
|> Relationship data model
|> User and Relationship of association
|> Validation
|> Utility Methods
|> Following / Followers User List
|> Follow / Unfollow Button
|> Relationship Controller
|> Following user microposts
|> Before the end

Preparation

作業前にブランチを切ります。

Example:

>cd path/to/sample_app
>git checkout -b following_users

Relationship data model

モデルを作成しますので、いつものようにデータモデルの提示をします。
リレーションシップのデータモデルは以下になります。
  • リレーションシップのデータモデル
    • モデル名: Relationship
    • テーブル名: relationships
    • 生成カラム(カラム名:型): follower_id:integer, followed_id:integer
    • 自動生成カラム(カラム名:型): id:integer, inserted_at:timestamp, updated_at:timestamp
    • インデックス(対象カラム名): follower_id, followed_id, follower_idとfollowed_idでの複合インデックス(ユニーク)
データモデルを把握したところで、早速実装に取り掛かりましょう。
モデルとマイグレーションファイルの生成をします。

Example:

>mix phoenix.gen.model Relationship relationships follower_id:integer followed_id:integer
マイグレーションファイルを編集します。

File: priv/repo/[timestamp]_create_relationship.exs

defmodule SampleApp.Repo.Migrations.CreateRelationship do
  use Ecto.Migration
  @disable_ddl_transaction true

  def change do
    create table(:relationships) do
      add :follower_id, :integer
      add :followed_id, :integer

      timestamps
    end

    create index(:relationships, [:follower_id], concurrently: true)
    create index(:relationships, [:followed_id], concurrently: true)
    create index(:relationships, [:follower_id, :followed_id], unique: true, concurrently: true)
  end
end
複合インデックスでユニークを指定している理由ですが、
フォローしているのに、再度フォローができたらおかしいですね。
それを防止するためにユニークを指定しています。
マイグレーションを実行します。

Example:

>mix ecto.migrate

User and Relationship of association

UserモデルとRelationshipモデルの多対多の関連付けを行います。
この項目は、中々ややこしいので多少冗長になっても説明を多めにします。
大目に見て下さい(笑)
構築したい関連は以下のような形になります。

Example:

+----+       +------------+       +----+
|User| 1---n |Relationship| n---1 |User|
+----+       +------------+       +----+
テーブルの例として形にしてみると、このような形にしたいわけです。 
users table
+----+-------+
| id | name  |
+----+-------+
| 1  | user1 |
+----+-------+
| 2  | user2 |
+----+-------+

relationships table
+-------------+-------------+
| followed_id | follower_id |
+-------------+-------------+
| 1           | 2           |
+-------------+-------------+
| 2           | 1           |
+-------------+-------------+
user1とuser2が相互フォローしている状態になります。
まず、自分がフォローしているユーザの関連付けを行います。
“自分 -> 他ユーザ”を表現するための関連付けです。
Userモデルのスキーマへ以下を追加する。

File: web/models/user.ex

defmodule SampleApp.User do
  ...

  schema "users" do
    ...

    has_many :followed_users, SampleApp.Relationship, foreign_key: :follower_id
    has_many :relationships, through: [:followed_users, :followed_user]

    timestamps
  end

  ...
end
今まで使ったことがない、throughと言うオプションが出てきました。
これは、多対多を構築する時によく使うものです。
2つのモデルの間に3つ目のモデルを介在させるためのものです。
今回の場合で言えば、自分は複数のフォローをしている。
また、自分をフォローしているユーザも複数のフォローを持っている。
なので、2つのモデルはどちらもUserモデルです。
そして、3つ目のモデルがRelationshipモデルになります。
では、3つ目のモデルであるRelationshipモデルでの関連付けをしましょう。
マイクロポストの関連付けを作成した時と同じですね。

File: web/models/relationship.ex

defmodule SampleApp.Relationship do
  ...

  schema "relationships" do
    belongs_to :followed_user, SampleApp.User, foreign_key: :follower_id
    field :followed_id, :integer

    timestamps
  end

  ...
end
続いて、自分をフォローしているフォロワーを表現する関連付けを行います。

File: web/models/user.ex

defmodule SampleApp.User do
  ...

  schema "users" do
    ...

    has_many :followers, SampleApp.Relationship, foreign_key: :followed_id
    has_many :reverse_relationships, through: [:followers, :follower]

    timestamps
  end

  ...
end
Relationshipモデルにも関連を追加して下さい。

File: web/models/relationship.ex

defmodule SampleApp.Relationship do
  ...

  schema "relationships" do
    ...
    belongs_to :follower, SampleApp.User, foreign_key: :followed_id

    timestamps
  end

  ...
end
面白いのは、外部キーを変えているだけだと言うことです。
内部でテーブルを反転させて利用しています。そのため、少しややこしいと思います。
しかし、わざわざ反転したテーブルを用意することなく、
これだけで、フォローとフォロワーへの関連付けが実現できています。
このようにすれば、テーブルを反転させた利用ができます。

Validation

Relationshipモデルへ検証を追加します。

File: web/models/relationship.ex

defmodule SampleApp.Relationship do
  ...

  def changeset(model, params \\ :empty) do
    model
    |> cast(params, @required_fields, @optional_fields)
    |> validate_presence(:followed_user)
    |> validate_presence(:follower)
  end

  ...
end

Utility Methods

フォローしたり、フォローを解除を補助するための関数を用意します。
以下の3つの関数を追加します。
  • フォローするための関数
  • フォローしているか確認するための関数
  • フォローを解除するための関数

File: web/models/relationship.ex

defmodule SampleApp.Relationship do
  ...

  def follow!(signed_id, follow_user_id) do
    changeset = SampleApp.Relationship.changeset(
      %SampleApp.Relationship{}, %{follower_id: signed_id, followed_id: follow_user_id})

    if changeset.valid? do
      SampleApp.Repo.insert!(changeset)
    end
  end

  def following?(signed_id, follow_user_id) do
    relationship = SampleApp.Repo.all(
      from(r in SampleApp.Relationship,
        where: r.follower_id == ^signed_id and r.followed_id == ^follow_user_id, limit: 1))

    !Enum.empty?(relationship)
  end

  def unfollow!(signed_id, follow_user_id) do
    [relationship] = SampleApp.Repo.all(
      from(r in SampleApp.Relationship,
        where: r.follower_id == ^signed_id and r.followed_id == ^follow_user_id, limit: 1))

    SampleApp.Repo.delete!(relationship)
  end
end

Following / Followers User List

フォローしているユーザの一覧とフォロワーユーザの一覧を表示できるようにしましょう。

File: web/router.ex

scope "/", SampleApp do
  ...

  get "user/:id/following", UserController, :following
  get "user/:id/followers", UserController, :followers
end
ユーザデータの取得時にpreloadを追加します。

File: web/controllers/user_controller.ex

defmodule SampleApp.UserController do
  ...

  def show(conn, %{"id" => id} = params) do
    select_page = params["select_page"]

    user = Repo.get(SampleApp.User, id) |> Repo.preload(:relationships) |> Repo.preload(:reverse_relationships)
    page = SampleApp.Micropost.paginate(user.id, select_page)
    changeset = SampleApp.Micropost.new(user.id)

    ...
  end

  ...
end
フォロー数、フォロワー数を表示し、一覧へのリンクとします。

File: web/templates/user/show.html.eex

<h2>User profile</h2>

<div class="row">
  <aside class="col-md-4">
    <section>
      <%= render SampleApp.SharedView, "user_info.html", conn: @conn, user: @user %>
    </section>
    <section>
      <%= render SampleApp.SharedView, "stats.html", conn: @conn, user: @user %>
    </section>

    ...
  </aside>

  ...

</div>
フォロー、フォロワー数の表示とリンクのテンプレートを作成します。

File: web/templates/shared/stats.html.eex

<div class="stats">
  <a href="<%= user_path(@conn, :following, @user) %>">
    <strong id="following" class="stat">
      (<%= Enum.count(@user.followed_users) %>)
    </strong>
    following
  </a>
  <a href="<%= user_path(@conn, :followers, @user) %>">
    <strong id="followers" class="stat">
      (<%= Enum.count(@user.followers) %>)
    </strong>
    followers
  </a>
</div>
CSSの追加を行います。

File: priv/static/css/custom.css

/* following and followers */
.stats {
  overflow: auto;
}

.stats a {
  float: left;
  padding: 0 10px;
  border-left: 1px solid #eeeeee;
  color: gray;
}

.stats a:first-child {
  padding-left: 0;
  border: 0;
}

.stats a:hover {
  text-decoration: none;
  color: #3677a3;
}

.stats strong {
  display: block;
}
followingとfollowersのアクション関数を作成します。
以下、4つのことを行います。
  • 認可(プラグ)へのアクションの追加
  • フォロー一覧を表示するためのfollowingアクションの実装
  • フォロワー一覧を表示するためのfollowersアクションの実装
  • 取得したいユーザのIDをリストとして一覧にする関数の実装

File: web/controllers/user_controller.ex

defmodule SampleApp.UserController do
  use SampleApp.Web, :controller

  plug SampleApp.Plugs.SignedInUser when action in [:index, :show, :edit, :update, :delete, :following, :followers]

  ...

  def following(conn, params) do
    select_page = params["select_page"]
    id = params["id"]

    user = Repo.get(SampleApp.User, id) |> Repo.preload(:relationships) |> Repo.preload(:reverse_relationships)
    page = SampleApp.User.show_follow_paginate(
             select_page, list_map_to_value_list(user.followed_users, :followed_id))

    if page do
      page_list = if page.total_pages == 0, do: Range.new(1, 1), else: Range.new(1, page.total_pages)

      render(conn, "following.html",
             user: user,
             users: page.entries,
             current_page: page.page_number,
             total_pages: page.total_pages,
             page_list: page_list)
    else
      conn
      |> put_flash(:error, "Invalid page number!!")
      |> render("following.html", user: user, users: [])
    end
  end

  def followers(conn, params) do
    select_page = params["select_page"]
    id = params["id"]

    user = Repo.get(SampleApp.User, id) |> Repo.preload(:relationships) |> Repo.preload(:reverse_relationships)
    page = SampleApp.User.show_follow_paginate(
             select_page, list_map_to_value_list(user.followers, :follower_id))

    if page do
      page_list = if page.total_pages == 0, do: Range.new(1, 1), else: Range.new(1, page.total_pages)

      render(conn, "followers.html",
             user: user,
             users: page.entries,
             current_page: page.page_number,
             total_pages: page.total_pages,
             page_list: page_list)
    else
      conn
      |> put_flash(:error, "Invalid page number!!")
      |> render("followers.html", user: user, users: [])
    end
  end

  defp list_map_to_value_list(repo_result, key) do
    for map <- repo_result do Map.get(map, key) end
  end
end
フォロー、フォロワーのユーザ一覧をページネーションするための関数を追加します。

File: web/models/user.ex

defmodule SampleApp.User do
  ...

  def show_follow_paginate(select_page, ids_list) do
    SampleApp.Helpers.PaginationHelper.paginate(
      from(u in SampleApp.User, where: u.id in ^ids_list, order_by: [asc: :name]),
      select_page)
　　end
end
フォロー一覧を表示するためのテンプレートを作成します。

File: web/templates/user/following.html.eex

<h2>Followed users</h2>

<%= render "show_follow.html", action: user_path(@conn, :following, @user), conn: @conn,
                        user: @user,
                        users: @users,
                        current_page: @current_page,
                        total_pages: @total_pages,
                        page_list: @page_list %>
フォロワー一覧を表示するためのテンプレートを作成します。

File: web/templates/user/followers.html.eex

<h2>Follower users</h2>

<%= render "show_follow.html", action: user_path(@conn, :followers, @user), conn: @conn,
                        user: @user,
                        users: @users,
                        current_page: @current_page,
                        total_pages: @total_pages,
                        page_list: @page_list %>
フォロー、フォロワー一覧を表示するための共通テンプレートを作成します。

File: web/templates/user/show_follow.html.eex

<div class="row">
  <aside class="col-md-4">
    <section>
      <%= render SampleApp.SharedView, "user_info.html", conn: @conn, user: @user %>
    </section>
    <section>
      <%= render SampleApp.SharedView, "stats.html", conn: @conn, user: @user %>
      <%= if @users do %>
        <div class="user_avatars">
          <%= for follow_user <- @users do %>
            <a href="<%= user_path(@conn, :show, follow_user) %>">
              <img src="<%= get_gravatar_url(follow_user) %>" class="gravatar">
            </a>
          <% end %>
        </div>
      <% end %>
    </section>
  </aside>

  <div class="col-md-8">
    <h3>Users</h3>
    <%= if @users do %>
      <ul class="users">
        <%= for follow_user <- @users do %>
          <%= render "user.html", conn: @conn, user: follow_user %>
        <% end %>
      </ul>

      <%= render SampleApp.PaginationView, "pagination.html",
               action: @action,
               current_page: @current_page,
               page_list: @page_list,
               total_pages: @total_pages %>
    <% end %>
  </div>
</div>

Follow / Unfollow Button

フォローとアンフォローのボタンを表示させます。

File: web/router.ex

scope "/", SampleApp do
  ...

  resources "/relationship", RelationshipController, only: [:create, :delete]
end
Relationshipビューのformテンプレートを呼び出します。

File: web/templates/user/show.html.eex

<h2>User profile</h2>

<div class="row">
  ...

  <div class="col-md-8">
    <%= render SampleApp.RelationshipView, "form.html", conn: @conn, user: @user %>

    ...
  </div>
</div>
リレーションシップのテンプレートを格納するためのディレクトリを作成します。
relationshipと言う名前で作成して下さい。

Directory: web/templates/relationship

フォローボタンを表示するためのテンプレートを作成します。

File: web/templates/relationship/form.html.eex

<%= unless current_user?(@conn, @user) do %>
  <div id="follow_form">
  <%= if following?(@conn, @user.id) do %>
    <%= form_tag(relationship_path(@conn, :delete, current_user(@conn)), method: :delete) %>
      <input type="hidden" name="unfollow_id" value="<%= @user.id %>">
      <%= submit "Unfollow", class: "btn btn-default" %>
    </form>
  <% else %>
    <%= form_tag(relationship_path(@conn, :create), method: :post) %>
      <input type="hidden" name="id" value="<%= current_user(@conn).id %>">
      <input type="hidden" name="follow_id" value="<%= @user.id %>">
      <%= submit "Follow", class: "btn btn-primary" %>
    </form>
  <% end %>
  </div>
<% end %>
Relationshipビューを作成します。

File: web/views/relationship_view.ex

defmodule SampleApp.RelationshipView do
  use SampleApp.Web, :view

  def following?(conn, follow_user_id) do
    SampleApp.Relationship.following?(conn.assigns[:current_user].id, follow_user_id)
  end
end

Relationship Controller

フォローする、フォロー解除を画面から行えるようにします。
Relationshipコントローラの作成をします。

File: web/controllers/relationship_controller.ex

defmodule SampleApp.RelationshipController do
  use SampleApp.Web, :controller

  plug SampleApp.Plugs.SignedInUser

  def create(conn, params) do
    SampleApp.Relationship.follow!(params["id"], params["follow_id"])

    conn
    |> put_flash(:info, "Follow successfully!!")
    |> redirect(to: user_path(conn, :show, params["follow_id"]))
  end

  def delete(conn, params) do
    SampleApp.Relationship.unfollow!(params["id"], params["unfollow_id"])

    conn
    |> put_flash(:info, "Unfollow successfully!!")
    |> redirect(to: user_path(conn, :show, params["unfollow_id"]))
  end
end

Following user microposts

フォローしているユーザのマイクロポストをユーザのマイクロポスト一覧に表示させます。
Micropostモデルにページネーション関数を追加します。

File: web/models/micropost.ex

defmodule SampleApp.Micropost do
  ...

  def paginate(user_id, select_page, following_ids) do
    SampleApp.Helpers.PaginationHelper.paginate(
      from(m in SampleApp.Micropost,
        where: m.user_id in ^following_ids or m.user_id == ^user_id,
          order_by: [desc: m.inserted_at]),
      select_page)
  end
end
Userコントローラのshowアクションで、
Micropostモデルのページネーション関数を利用するように修正します。

File: web/controllers/user_controller.ex

defmodule SampleApp.UserController do
  ...

  def show(conn, %{"id" => id} = params) do
    select_page = params["select_page"]

    user = Repo.get(SampleApp.User, id) |> Repo.preload(:relationships) |> Repo.preload(:reverse_relationships)
    page = SampleApp.Micropost.paginate(
             user.id, select_page, list_map_to_value_list(user.followed_users, :followed_id))
    changeset = SampleApp.Micropost.new(user.id)

    if page do
      render(conn, "show.html",
             user: user,
             posts: page.entries,
             current_page: page.page_number,
             total_pages: page.total_pages,
             page_list: Range.new(1, page.total_pages),
             changeset: changeset)
    else
      conn
      |> put_flash(:error, "Invalid page number!!")
      |> render("show.html", user: user, posts: [])
    end
  end
end
完成！！

Before the end

ソースコードをマージします。

Example:

>git add .
>git commit -am "Finish following_users."
>git checkout master
>git merge following_users

Speaking to oneself

祝！チュートリアル終了！！
ここまでお付き合い頂きありがとうございました。
本チュートリアルを通して何か得るものはあったでしょうか？
少しでも皆様の技量向上に貢献できたのであれば、これほど嬉しいことはありません！
喜びに水を差すようで申し訳ないのですが、
このチュートリアルでやった内容は全て基礎です。
なので、応用的を習得するために今後の努力を怠らないようにして下さい。
それでは、お疲れ様でした。m(_ _)m

Bibliography

​
ラベル: , ,

人気の投稿

  • [Elixir]Proxy環境下でElixirを無理やり動かす！
    Proxy環境下でElixirを動かすまでにやったこと 社内の環境だとProxyがあるためうまく動かないことはわかっていた。 時間ができたので、突貫でElixirの仮環境を作成しました。 突貫で作業したので、内容に不備があるかもしれません。 もし問題が発生しましたら、...
  • Rubyのエンコーディングについて
    タイトル：Rubyのエンコーディングについて 目的：Rubyのエンコーディングについての備忘録を作成すること 以下の環境により実施 OS：Windows8.1 Ruby：v2.2.2 x64 ディレクトリ構造： 作業ディレクトリ |-encoding-test....
  • [Elixir]Timexを使って日時のフォーマット変換を行う
    Goal TimexのDateFormatを使う。 Dev-Environment OS: Windows8.1 Erlang: Eshell V6.4, OTP-Version 17.5 Elixir: v1.0.4 Timex: v0.19.5 Con...
  • [Elixir+Phoenix]Ectoでpreloadする対象にorder_byしたい
    Goal Ectoでpreloadする対象にorder_byを行う。 Dev-Environment OS: Windows8.1 Erlang: Eshell V7.1, OTP-Version 18.1 Elixir: v1.1.1 Phoenix Frame...
  • Sinatraで掲示板を作ってみた！！
    タイトル：Sinatraで掲示板を作ってみた！！ 目的：Sinatraを使って掲示板を作成してみる。 実施環境： OS：Windows8.1 Ruby：v2.2.2 Sinatra：v1.4.6 Haml：v4.0.6 ディレクトリ構造： 作業ディレクトリ ...
  • [Elixir+Phoenix]Phoenixでもページネーションがしたい！！(その2)
    Goal Github - drewolson/scrivener を動作検証する。 Dev-Environment OS: Windows8.1 Erlang: Eshell V6.4, OTP-Version 17.5 Elixir: v1.0.4 Phoen...
  • [Elixir]Streamの使い方を習得する
    Goal Streamの使い方を習得する。 Dev-Environment OS: Windows8.1 Erlang: Eshell V6.4, OTP-Version 17.5 Elixir: v1.0.5 Wait a minute 今回はStr...
  • Markdown Hereをインストールしたのでテスト
    目的 私が利用頻度の高そうなものを練習がてら記述する。 始める前に Markdown Here： Chromeの拡張機能 目次 ヘッダー 協調と打消し線 リスト リンク 画像 コードとシンタックスのハイライト テーブル ブロック ...
  • Using gen_udp module in elixir
    Goal gen_udpの簡単なサンプルを実装する Dev-Environment OS: Windows8.1 Erlang: Eshell V7.3, OTP-Version 18.3 Elixir: v1.2.3 Using gen_udp ...
  • [Elixir]GenServerの基本を習得する
    Goal GenServerの基本を習得する。 Dev-Environment OS: Windows8.1 Erlang: Eshell V6.4, OTP-Version 17.5 Elixir: v1.0.5 Wait a minute プロセス...