--wip-- [skip ci]

Author: JoranVanBelle

src/Kafka/Internal/RdKafka.chs

@@ -1215,24 +1215,6 @@ rdKafkaCreateTopic kafkaPtr topic opts queue = do
     withForeignPtrsArrayLen topics $ \tLen tPtr -> do
       {#call rd_kafka_CreateTopics#} kPtr tPtr (fromIntegral tLen) oPtr qPtr
 
-rdKafkaEventCreateTopicsResult :: RdKafkaEventTPtr -> IO (Maybe RdKafkaTopicResultTPtr)
-rdKafkaEventCreateTopicsResult evtPtr =
-  withForeignPtr evtPtr $ \evtPtr' -> do
-    res <- {#call rd_kafka_event_CreateTopics_result#} (castPtr evtPtr')
-    if (res == nullPtr)
-      then pure Nothing
-      else Just <$> newForeignPtr_ (castPtr res)
-
-rdKafkaCreateTopicsResultTopics :: RdKafkaTopicResultTPtr
-                                -> IO [Either (String, RdKafkaRespErrT, String) String]
-rdKafkaCreateTopicsResultTopics tRes =
-  withForeignPtr tRes $ \tRes' ->
-    alloca $ \sPtr -> do
-      res <- {#call rd_kafka_CreateTopics_result_topics#} (castPtr tRes') sPtr
-      size <- peekIntConv sPtr
-      array <- peekArray size res
-      traverse unpackRdKafkaTopicResult array
-
 --- Delete topic
 foreign import ccall unsafe "rdkafka.h &rd_kafka_DeleteTopic_destroy"
     rdKafkaDeleteTopicDestroy :: FinalizerPtr RdKafkaDeleteTopicT
@@ -1251,25 +1233,6 @@ newRdKafkaDeleteTopic topicNameStr =
       then return $ Left $ "Something went wrong while deleting topic " ++ topicNameStr
       else Right <$> newForeignPtr rdKafkaDeleteTopicDestroy res
 
-rdKafkaEventDeleteTopicResult :: RdKafkaEventTPtr
-                                -> IO (Maybe RdKafkaDeleteTopicResultTPtr)
-rdKafkaEventDeleteTopicResult eventPtr =
-  withForeignPtr eventPtr $ \eventPtr' -> do
-    res <- {#call rd_kafka_event_DeleteTopics_result#} (castPtr eventPtr')
-    if (res == nullPtr)
-      then pure Nothing
-      else Just <$> newForeignPtr_ (castPtr res)
-
-rdKafkaDeleteTopicResultTopic :: RdKafkaDeleteTopicResultTPtr
-                                -> IO [Either (String, RdKafkaRespErrT, String) String]
-rdKafkaDeleteTopicResultTopic topicResult =
-  withForeignPtr topicResult $ \topicResult' ->
-    alloca $ \sPtr -> do
-      res <- {#call rd_kafka_DeleteTopics_result_topics#} (castPtr topicResult') sPtr
-      size <- peekIntConv sPtr
-      arr <- peekArray size res
-      traverse unpackRdKafkaTopicResult arr
-
 rdKafkaDeleteTopics :: RdKafkaTPtr
                     -> [RdKafkaDeleteTopicTPtr]
                     -> RdKafkaAdminOptionsTPtr
@@ -1280,17 +1243,6 @@ rdKafkaDeleteTopics kafkaPtr topics opts queue = do
     withForeignPtrsArrayLen topics $ \tLen tPtr -> do
       {#call rd_kafka_DeleteTopics#} kPtr tPtr (fromIntegral tLen) oPtr qPtr
 
-unpackRdKafkaTopicResult :: Ptr RdKafkaTopicResultT
-                         -> IO (Either (String, RdKafkaRespErrT, String) String)
-unpackRdKafkaTopicResult resPtr = do
-  name <- {#call rd_kafka_topic_result_name#} resPtr >>= peekCString
-  err <- {#call rd_kafka_topic_result_error#} resPtr
-  case cIntToEnum err of
-    respErr -> do
-      errMsg <- {#call rd_kafka_topic_result_error_string#} resPtr >>= peekCString
-      pure $ Left (name, respErr, errMsg)
-    RdKafkaRespErrNoError -> pure $ Right name
-
 -- Marshall / Unmarshall
 enumToCInt :: Enum a => a -> CInt
 enumToCInt = fromIntegral . fromEnum

tests-it/Kafka/IntegrationSpec.hs

@@ -178,15 +178,15 @@ spec = do
         let topicName = addRandomChars "admin.topic.created." 5
 
         topicsMVar <- runIO newEmptyMVar
-{-         specWithAdmin "Create topic" $ do
+        
+        specWithAdmin "Create topic" $ do
 
           it "should create a new topic" $ \(admin :: KAdmin) -> do
               tName <- topicName
               let newTopic = mkNewTopic (TopicName ( T.pack(tName) ))
               result <- createTopic admin newTopic
               result `shouldSatisfy` isRight
 
- -}
         specWithConsumer "Read all topics" consumerProps $ do
 
           it "should return all the topics" $ \(consumer :: KafkaConsumer) -> do
@@ -214,7 +214,6 @@ spec = do
 
           it "should delete all the topics currently existing" $ \(admin ::KAdmin) -> do
             topics <- takeMVar topicsMVar
-            putStrLn "Will now delete the topics"
             forM_ topics $ \topic -> do
               result <- deleteTopic admin topic
               result `shouldSatisfy` isRight