Cleanup error handling

wireapp · Oct 1, 2024 · da83c3f · da83c3f
1 parent f13a8b3
commit da83c3f
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/tools/db/find-undead/src/Work.hs b/tools/db/find-undead/src/Work.hs
@@ -39,9 +39,14 @@ import Wire.API.User (AccountStatus (..))
 
 runCommand :: Logger -> ClientState -> ES.BHEnv -> String -> IO ()
 runCommand l cas es indexStr = do
-  let index = fromRight (error "TODO: Index error helper function") $ ES.mkIndexName $ Text.pack indexStr
-      transform :: IO (Either ES.EsError a) -> IO a
-      transform = fmap (fromRight (error "TODO: Handle error"))
+  index <-
+    either (\err -> fail ("Invalid index name: " ++ indexStr ++ ". Error: " ++ show err)) pure $
+      ES.mkIndexName $
+        Text.pack indexStr
+  let transform :: IO (Either ES.EsError a) -> IO a
+      transform res =
+        res
+          >>= \r -> either (\err -> (fail ("ElasticSearch error: " ++ show err))) pure r
   runConduit $
     transPipe (transform <$> ES.runBH es) $
       getScrolled index