             feed_id: feed.id,
           }
 
-          Repo.transaction fn ->
+          {:ok, saved_item} = Repo.transaction fn ->
             existing = Repo.one(from i in Item, where: i.guid == ^item.guid and i.user_id == ^item.user_id and i.feed_id == ^item.feed_id)
 
             if existing != nil do

          item = %{item | orig_feed_title: data["origin"]["title"]}
          Repo.insert!(Item.changeset(%Item{}, item))
        end
      end
    end)
  end

        end)
      end

      {:ok, saved_item} = Repo.transaction fn ->
        feed_url = data["origin"]["streamId"] |> String.slice(5..-1)
        feed = Feed |> Repo.filter(conn) |> Ecto.Query.where([f], f.url == ^feed_url) |> Repo.one
        if feed != nil do
