# feed.yaml
nabinno/sports/feed_group_name:
  tags:
    - ski
  links:
    - http://rss.example.com/ski_feed.rss
    - http://rss.example.com/snowboard_feed.rss
    - http://ski-status.example.com/rss

# feed_excluded_link.yaml
- anti-ski.example.com
- awesome-snowboard.example.com

# feed_excluded_title.yaml
- queer
- two-planker
- beaver-tail

# feed_corrected_link.yaml
amazon.com:
  - ref
  - ie

# feed_redirected_link.yaml
ski-status.example.com:
  - Floki.find(fst, ".post__body a")

Supervisor.start_link(
  [
    :hackney_pool.child_spec(:hatena_bookmark_pool, timeout: 15_000, max_connections: 100),
    # @todo 当該ワーカーで暖気処理を行っていないので `one_for_one` にした場合、再起動時にほかに影響する
    supervisor(Cachex, [:feed, []]),
    supervisor(Keshikimi2Feed.Registry, [prefix]),

    # フィード読込処理 (PubSub)
    supervisor(Keshikimi2Feed.Subscriber, [prefix]),
    worker(Keshikimi2Feed.Worker, [prefix]),
    worker(Keshikimi2Feed.Publisher, [[prefix: prefix, poll_interval: 3_000]]),

    # ブクマ処理
    worker(Keshikimi2.HatenaBookmark.AddEntry, [
      [prefix: prefix, poll_interval: 3_000]
    ])
  ],
  strategy: :one_for_all,
  name: name(prefix)
)

Cachex.keys!(:feed)
|> Enum.reject(fn key ->
  key in [
    "excluded_links",
    "excluded_titles",
    "corrected_links",
    "redirected_links",
    "feed_group",
    "archived_links"
  ]
end)
|> Task.async_stream(
  fn item_link ->
    with {:ok, [item_title, feed_tags]} <- Cachex.get(:feed, item_link),
         :ok <- validate_all(item_link, item_title),
         corrected_link <- correct_all(item_link),
         {:ok, payload} <-
           FormData.create(
             %{
               url: corrected_link,
               comment: feed_tags |> Enum.map_join(fn tag -> "[#{tag}]" end),
               rks: System.get_env("HATENA_BOOKMARK_RKS"),
               private: 0,
               keep_original_url: 1,
               with_status_op: 1,
               from: "inplace",
               post_twitter: 0,
               post_evernote: 0
             },
             :url_encoded,
             get: false
           ) do
      do_add_entries_to_hb(payload)
      Logger.info("add entry: #{item_link}")
    end

    archive_link(item_link)
  end,
  timeout: 15_000
)
|> Stream.run()