chore: update c-questdb-client submodule (#87)

Author: jerrinot

c-questdb-client

@@ -5,10 +5,8 @@
 import threading
 import time
 
-
 NON_ESCAPED_NEW_LINE_RE = re.compile(rb'(?<!\\)\n')
 
-
 class Server:
     def __init__(self):
         self._sock = None
@@ -62,7 +60,8 @@ def __exit__(self, _ex_type, _ex_value, _ex_tb):
         self.close()
 
 class HttpServer:
-    def __init__(self):
+    def __init__(self, delay_seconds=0):
+        self.delay_seconds = delay_seconds
         self.requests = []
         self.responses = []
         self.headers = []
@@ -74,18 +73,19 @@ def __init__(self):
     def _serve(self):
         self._http_server.serve_forever()
         self._stop_event.set()
-    
-    def __enter__(self):
-        headers = self.headers
+
+    def create_handler(self):
+        delay_seconds = self.delay_seconds
         requests = self.requests
+        headers = self.headers
         responses = self.responses
 
         class IlpHttpHandler(hs.BaseHTTPRequestHandler):
             def do_POST(self):
+                time.sleep(delay_seconds)
+
                 try:
-                    headers.append({
-                        key: value
-                        for key, value in self.headers.items()})
+                    headers.append({key: value for key, value in self.headers.items()})
                     content_length = int(self.headers['Content-Length'])
                     body = self.rfile.read(content_length)
                     requests.append(body)
@@ -103,17 +103,18 @@ def do_POST(self):
                     if body:
                         self.wfile.write(body)
                 except BrokenPipeError:
-                    pass  # Client disconnected early, no biggie.
+                    pass
+
+        return IlpHttpHandler
 
+    def __enter__(self):
         self._stop_event = threading.Event()
-        self._http_server = hs.HTTPServer(
-            ('', 0),
-            IlpHttpHandler,
-            bind_and_activate=True)
+        handler_class = self.create_handler()
+        self._http_server = hs.HTTPServer(('', 0), handler_class, bind_and_activate=True)
         self._http_server_thread = threading.Thread(target=self._serve)
         self._http_server_thread.start()
         return self
-    
+
     def __exit__(self, _ex_type, _ex_value, _ex_tb):
         self._http_server.shutdown()
         self._http_server.server_close()

test/mock_server.py

@@ -1,6 +1,7 @@
 #!/usr/bin/env python3
 
 import sys
+
 sys.dont_write_bytecode = True
 import os
 import unittest
@@ -11,6 +12,7 @@
 import pathlib
 
 import patch_path
+
 PROJ_ROOT = patch_path.PROJ_ROOT
 sys.path.append(str(PROJ_ROOT / 'c-questdb-client' / 'system_test'))
 
@@ -882,7 +884,7 @@ def _do_test_auto_flush_interval2(self):
                 sender.row('t', columns={'x': 5}, at=qi.ServerTimestamp)
                 sender.row('t', columns={'x': 6}, at=qi.ServerTimestamp)
             return server.requests
-            
+
         def test_auto_flush_interval2(self):
             # This test is timing-sensitive,
             # so it has a tendency to go wrong in CI.
@@ -896,7 +898,7 @@ def test_auto_flush_interval2(self):
                         b't x=4i\nt x=5i\n',
                         b't x=6i\n'])
                     break
-            
+
             # If this fails, it failed 10 attempts.
             # Due to CI timing delays there may have been multiple flushes.
             self.assertEqual(len(requests), 3)
@@ -952,11 +954,14 @@ def test_http_err_retry(self):
                 self.assertEqual(server.requests[1], exp_payload)
 
         def test_http_request_min_throughput(self):
-            with HttpServer() as server, self.builder(
+            with HttpServer(delay_seconds=2) as server, self.builder(
                     'http',
                     'localhost',
                     server.port,
-                    request_timeout=0,
+                    request_timeout=1000,
+                    # request_timeout is sufficiently high since it's also used as a connect timeout and we want to
+                    # survive hiccups on CI. it should be lower than the server delay though to actually test the
+                    # effect of request_min_throughput.
                     request_min_throughput=1) as sender:
                 sender.row('tbl1', columns={'x': 42}, at=qi.ServerTimestamp)
                 sender.flush()
@@ -968,7 +973,7 @@ def test_http_request_min_throughput_timeout(self):
                     'localhost',
                     server.port,
                     auto_flush='off',
-                    request_timeout=0,
+                    request_timeout=1,
                     retry_timeout=0,
                     request_min_throughput=100000000) as sender:
                 sender.row('tbl1', columns={'x': 42}, at=qi.ServerTimestamp)