From 3c4d63149c4816a6ddc1b285a2a04f7670340aef Mon Sep 17 00:00:00 2001
From: saneery <anatolyniky@gmail.com>
Date: Tue, 7 May 2019 13:06:44 +0300
Subject: [PATCH] mark pools as deleted if they don't exist in the list

---
 .../chain/import/runner/staking_pools.ex      | 29 +++++++++++++++++++
 .../lib/indexer/fetcher/staking_pools.ex      |  1 +
 2 files changed, 30 insertions(+)

diff --git a/apps/explorer/lib/explorer/chain/import/runner/staking_pools.ex b/apps/explorer/lib/explorer/chain/import/runner/staking_pools.ex
index aaf5d7242e..f0e62b7e89 100644
--- a/apps/explorer/lib/explorer/chain/import/runner/staking_pools.ex
+++ b/apps/explorer/lib/explorer/chain/import/runner/staking_pools.ex
@@ -41,6 +41,9 @@ defmodule Explorer.Chain.Import.Runner.StakingPools do
       |> Map.put(:timestamps, timestamps)
 
     multi
+    |> Multi.run(:mark_as_deleted, fn repo, _ ->
+      mark_as_deleted(repo, changes_list, insert_options)
+    end)
     |> Multi.run(:insert_staking_pools, fn repo, _ ->
       insert(repo, changes_list, insert_options)
     end)
@@ -49,6 +52,32 @@ defmodule Explorer.Chain.Import.Runner.StakingPools do
   @impl Import.Runner
   def timeout, do: @timeout
 
+  defp mark_as_deleted(repo, changes_list, %{timeout: timeout}) when is_list(changes_list) do
+    addresses = Enum.map(changes_list, & &1.address_hash)
+
+    query =
+      from(
+        address_name in Address.Name,
+        where:
+          address_name.address_hash not in ^addresses and
+            fragment("(metadata->>'is_pool')::boolean = true"),
+        update: [
+          set: [
+            metadata: fragment("metadata || '{\"deleted\": true}'::jsonb")
+          ]
+        ]
+      )
+
+    try do
+      {_, result} = repo.update_all(query, [], timeout: timeout)
+
+      {:ok, result}
+    rescue
+      postgrex_error in Postgrex.Error ->
+        {:error, %{exception: postgrex_error}}
+    end
+  end
+
   @spec insert(Repo.t(), [map()], %{
           optional(:on_conflict) => Import.Runner.on_conflict(),
           required(:timeout) => timeout,
diff --git a/apps/indexer/lib/indexer/fetcher/staking_pools.ex b/apps/indexer/lib/indexer/fetcher/staking_pools.ex
index 68794d9ee4..fe4ab84c28 100644
--- a/apps/indexer/lib/indexer/fetcher/staking_pools.ex
+++ b/apps/indexer/lib/indexer/fetcher/staking_pools.ex
@@ -125,6 +125,7 @@ defmodule Indexer.Fetcher.StakingPools do
       pool
       |> Map.delete(:staking_address)
       |> Map.put(:mining_address, mining_address)
+      |> Map.put(:is_pool, true)
 
     %{
       name: "anonymous",