@@ -176,15 +176,17 @@ mkReplicaCount n
176emptyBody :: L.ByteString
176emptyBody :: L.ByteString
177emptyBody = L.pack ""
177emptyBody = L.pack ""
179−dispatch :: MonadBH m => Method -> Text -> Maybe L.ByteString
179+dispatch :: MonadBH m
182+ -> Maybe L.ByteString
180− -> m Reply
183+ -> m Reply
181dispatch dMethod url body = do
184dispatch dMethod url body = do
182 initReq <- liftIO $ parseUrl' url
185 initReq <- liftIO $ parseUrl' url
183 reqHook <- bhRequestHook <$> getBHEnv
186 reqHook <- bhRequestHook <$> getBHEnv
184 let reqBody = RequestBodyLBS $ fromMaybe emptyBody body
187 let reqBody = RequestBodyLBS $ fromMaybe emptyBody body
185− req <- liftIO $ reqHook $ initReq { method = dMethod
188+ req <- liftIO $ reqHook $ setRequestIgnoreStatus $ initReq { method = dMethod
186− , requestBody = reqBody
189+ , requestBody = reqBody }
187− , checkStatus = \_ _ _ -> Nothing}
188 mgr <- bhManager <$> getBHEnv
190 mgr <- bhManager <$> getBHEnv
189 liftIO $ httpLbs req mgr
191 liftIO $ httpLbs req mgr
@@ -828,7 +830,7 @@ pageSearch :: From -- ^ The result offset
828pageSearch resultOffset pageSize search = search { from = resultOffset, size = pageSize }
830pageSearch resultOffset pageSize search = search { from = resultOffset, size = pageSize }
830parseUrl' :: MonadThrow m => Text -> m Request
832parseUrl' :: MonadThrow m => Text -> m Request
831−parseUrl' t = parseUrl (URI.escapeURIString URI.isAllowedInURI (T.unpack t))
833+parseUrl' t = parseRequest (URI.escapeURIString URI.isAllowedInURI (T.unpack t))
833-- | Was there an optimistic concurrency control conflict when
835-- | Was there an optimistic concurrency control conflict when
834-- indexing a document?
836-- indexing a document?