     redis_key = "user:#{user.id}:followed_users_id_cache"
     Redis.command(["SADD", redis_key, following_user.id])
 
+    on_exit fn ->
+      Redis.command(["DEL", redis_key])
+    end
+
+    {:ok, conn: auth_conn(conn, user), unauth_conn: conn, user: user}
+  end
+
+  test "GET /v2/following/posts/recent", %{conn: conn} do
     response = get(conn, following_post_path(conn, :index))
     assert response.status == 200
   end

    Stream.Client.Test.reset

    user = Factory.insert(:user)
    {:ok, conn: auth_conn(conn, user), unauth_conn: conn, user: user}
  end

  test "GET /v2/following/posts/recent", %{conn: conn, user: user} do
    following_user = Factory.insert(:user)
    post = Factory.insert(:post, author: following_user)
    roshi_items = [

    assert response.status == 401
  end

  @tag :json_schema
  test "GET /v2/following/posts/recent - json schema", %{conn: conn} do
    conn = get(conn, following_post_path(conn, :index))
    assert :ok = validate_json("post", json_response(conn, 200))
  end

end
