Merge branch 'main' into feat/1220-in-window-tabs

Author: datlechin

CHANGELOG.md

@@ -27,6 +27,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Fixed
 
+- ClickHouse, BigQuery, CloudflareD1, LibSQL, Etcd, and DynamoDB: long-running queries no longer fail at 30 seconds when Settings > Query timeout is set higher. The HTTP transport now uses the configured query timeout plus a 30-second grace, so the server's `max_execution_time` (or equivalent) fires before the client gives up. Setting "No limit" raises the transport ceiling to 1 hour. (#1267)
+- AI Chat: DeepSeek V4 thinking content (`reasoning_content`) is now captured during streaming and passed back in subsequent turns, fixing 400 errors when using deepseek-v4-pro or deepseek-v4-flash.
+- MongoDB: the connection form now shows a Username field. It was hidden for databases where authentication is optional, so connections to auth-enabled servers saved with no credentials and every query failed with "requires authentication" even though the connection looked healthy.
+- SQL import dropped statements when the database executed them slower than the file was parsed, so a re-imported export could fail with errors like "relation does not exist". The parser now waits for each statement to be consumed before reading more. (#1264)
+- SQL import ignored the database dialect, so PostgreSQL dumps with dollar-quoted function bodies were split at semicolons inside the body. (#1264)
+- SQL export emitted `DROP TABLE` for views, materialized views, and foreign tables, so re-importing failed with "is not a table". It now emits `DROP VIEW`, `DROP MATERIALIZED VIEW`, or `DROP FOREIGN TABLE` to match the object. (#1264)
 - iOS: connections, groups, and tags no longer silently disappear after a TestFlight or App Store update. Persistence files are now stored with `.completeFileProtectionUntilFirstUserAuthentication` so they stay readable across background sync runs, load failures are no longer swallowed, and the sync engine refuses to overwrite local data when the load was not actually empty.
 
 ### Removed

Plugins/BigQueryDriverPlugin/BigQueryConnection.swift

@@ -284,6 +284,7 @@ internal final class BigQueryConnection: @unchecked Sendable {
     private var _currentJobId: String?
     private var _currentJobLocation: String?
     private var _queryTimeoutSeconds: Int = 300
+    private let _queryTimeout = HttpQueryTimeoutBox()
     private let location: String?
     private static let logger = Logger(subsystem: "com.TablePro", category: "BigQueryConnection")
     private static let baseUrl = "https://bigquery.googleapis.com/bigquery/v2"
@@ -294,6 +295,7 @@ internal final class BigQueryConnection: @unchecked Sendable {
 
     func setQueryTimeout(_ seconds: Int) {
         lock.withLock { _queryTimeoutSeconds = max(seconds, 30) }
+        _queryTimeout.set(serverTimeoutSeconds: seconds)
     }
 
     init(config: DriverConnectionConfig) {
@@ -306,8 +308,8 @@ internal final class BigQueryConnection: @unchecked Sendable {
         let authProvider = try createAuthProvider()
 
         let sessionConfig = URLSessionConfiguration.default
-        sessionConfig.timeoutIntervalForRequest = 60
-        sessionConfig.timeoutIntervalForResource = 300
+        sessionConfig.timeoutIntervalForRequest = HttpQueryTimeout.sessionBootstrapRequestTimeout
+        sessionConfig.timeoutIntervalForResource = HttpQueryTimeout.sessionResourceTimeout
         let urlSession = URLSession(configuration: sessionConfig)
 
         lock.withLock {
@@ -836,8 +838,10 @@ internal final class BigQueryConnection: @unchecked Sendable {
         _ request: URLRequest,
         session: URLSession
     ) async throws -> (Data, URLResponse) {
-        try await withCheckedThrowingContinuation { continuation in
-            let task = session.dataTask(with: request) { [weak self] data, response, error in
+        var timedRequest = request
+        timedRequest.timeoutInterval = _queryTimeout.requestTimeoutInterval
+        return try await withCheckedThrowingContinuation { continuation in
+            let task = session.dataTask(with: timedRequest) { [weak self] data, response, error in
                 self?.lock.withLock { self?._currentTask = nil }
                 if let error {
                     if (error as? URLError)?.code == .cancelled {

Plugins/BigQueryDriverPlugin/Info.plist

@@ -4,5 +4,7 @@
 <dict>
 	<key>TableProPluginKitVersion</key>
 	<integer>12</integer>
+	<key>TableProMinAppVersion</key>
+	<string>0.42.0</string>
 </dict>
 </plist>

Plugins/ClickHouseDriverPlugin/ClickHousePlugin.swift

@@ -145,6 +145,7 @@ final class ClickHousePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
     private var currentTask: URLSessionDataTask?
     private var _currentDatabase: String
     private var _lastQueryId: String?
+    private let _queryTimeout = HttpQueryTimeoutBox()
 
     private static let logger = Logger(subsystem: "com.TablePro", category: "ClickHousePluginDriver")
 
@@ -196,8 +197,8 @@ final class ClickHousePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
 
     func connect() async throws {
         let urlConfig = URLSessionConfiguration.default
-        urlConfig.timeoutIntervalForRequest = 30
-        urlConfig.timeoutIntervalForResource = 300
+        urlConfig.timeoutIntervalForRequest = HttpQueryTimeout.sessionBootstrapRequestTimeout
+        urlConfig.timeoutIntervalForResource = HttpQueryTimeout.sessionResourceTimeout
 
         lock.lock()
         if let delegate = ClickHouseTLSDelegate.make(for: config.ssl) {
@@ -732,6 +733,7 @@ final class ClickHousePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
     }
 
     func applyQueryTimeout(_ seconds: Int) async throws {
+        _queryTimeout.set(serverTimeoutSeconds: seconds)
         guard seconds > 0 else { return }
         _ = try await execute(query: "SET max_execution_time = \(seconds)")
     }
@@ -802,7 +804,8 @@ final class ClickHousePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
         }
         lock.unlock()
 
-        let request = try buildRequest(query: query, database: database, queryId: queryId)
+        var request = try buildRequest(query: query, database: database, queryId: queryId)
+        request.timeoutInterval = _queryTimeout.requestTimeoutInterval
         let isSelect = Self.isSelectLikeQuery(query)
 
         let (data, response) = try await withTaskCancellationHandler {
@@ -861,7 +864,8 @@ final class ClickHousePluginDriver: PluginDatabaseDriver, @unchecked Sendable {
         }
         lock.unlock()
 
-        let request = try buildRequest(query: query, database: database, queryId: queryId, params: params)
+        var request = try buildRequest(query: query, database: database, queryId: queryId, params: params)
+        request.timeoutInterval = _queryTimeout.requestTimeoutInterval
         let isSelect = Self.isSelectLikeQuery(query)
 
         let (data, response) = try await withTaskCancellationHandler {

Plugins/CloudflareD1DriverPlugin/CloudflareD1PluginDriver.swift

@@ -182,6 +182,13 @@ final class CloudflareD1PluginDriver: PluginDatabaseDriver, @unchecked Sendable
         lock.unlock()
     }
 
+    func applyQueryTimeout(_ seconds: Int) async throws {
+        lock.lock()
+        let client = httpClient
+        lock.unlock()
+        client?.setQueryTimeout(seconds)
+    }
+
     // MARK: - Streaming
 
     func streamRows(query: String) -> AsyncThrowingStream<PluginStreamElement, Error> {

Plugins/CloudflareD1DriverPlugin/D1HttpClient.swift

@@ -5,6 +5,7 @@
 
 import Foundation
 import os
+import TableProPluginKit
 
 // MARK: - API Response Types
 
@@ -136,6 +137,7 @@ final class D1HttpClient: @unchecked Sendable {
     private var _databaseId: String
     private var session: URLSession?
     private var currentTask: URLSessionDataTask?
+    private let queryTimeout = HttpQueryTimeoutBox()
 
     var databaseId: String {
         get {
@@ -156,10 +158,14 @@ final class D1HttpClient: @unchecked Sendable {
         self._databaseId = databaseId
     }
 
+    func setQueryTimeout(_ seconds: Int) {
+        queryTimeout.set(serverTimeoutSeconds: seconds)
+    }
+
     func createSession() {
         let config = URLSessionConfiguration.default
-        config.timeoutIntervalForRequest = 30
-        config.timeoutIntervalForResource = 300
+        config.timeoutIntervalForRequest = HttpQueryTimeout.sessionBootstrapRequestTimeout
+        config.timeoutIntervalForResource = HttpQueryTimeout.sessionResourceTimeout
 
         lock.lock()
         session = URLSession(configuration: config)
@@ -307,6 +313,7 @@ final class D1HttpClient: @unchecked Sendable {
 
         var request = URLRequest(url: url)
         request.httpMethod = method
+        request.timeoutInterval = queryTimeout.requestTimeoutInterval
         request.setValue("Bearer \(apiToken)", forHTTPHeaderField: "Authorization")
         request.setValue("application/json", forHTTPHeaderField: "Content-Type")
         request.httpBody = body

Plugins/CloudflareD1DriverPlugin/Info.plist

@@ -4,5 +4,7 @@
 <dict>
 	<key>TableProPluginKitVersion</key>
 	<integer>12</integer>
+	<key>TableProMinAppVersion</key>
+	<string>0.42.0</string>
 </dict>
 </plist>

Plugins/DynamoDBDriverPlugin/DynamoDBConnection.swift

@@ -261,6 +261,7 @@ internal final class DynamoDBConnection: @unchecked Sendable {
     private var _session: URLSession?
     private var _credentials: AWSCredentials?
     private var _currentTask: URLSessionDataTask?
+    private let _queryTimeout = HttpQueryTimeoutBox()
     private let region: String
     private let endpointUrl: String
     private static let logger = Logger(subsystem: "com.TablePro", category: "DynamoDBConnection")
@@ -270,6 +271,10 @@ internal final class DynamoDBConnection: @unchecked Sendable {
         lock.withLock { _session }
     }
 
+    func setQueryTimeout(_ seconds: Int) {
+        _queryTimeout.set(serverTimeoutSeconds: seconds)
+    }
+
     init(config: DriverConnectionConfig) {
         self.config = config
         self.region = config.additionalFields["awsRegion"] ?? "us-east-1"
@@ -298,8 +303,8 @@ internal final class DynamoDBConnection: @unchecked Sendable {
     func connect() async throws {
         let credentials = try resolveCredentials()
         let sessionConfig = URLSessionConfiguration.default
-        sessionConfig.timeoutIntervalForRequest = 30
-        sessionConfig.timeoutIntervalForResource = 60
+        sessionConfig.timeoutIntervalForRequest = HttpQueryTimeout.sessionBootstrapRequestTimeout
+        sessionConfig.timeoutIntervalForResource = HttpQueryTimeout.sessionResourceTimeout
         let urlSession = URLSession(configuration: sessionConfig)
 
         lock.withLock {
@@ -442,6 +447,7 @@ internal final class DynamoDBConnection: @unchecked Sendable {
         urlRequest.setValue(hostHeader, forHTTPHeaderField: "Host")
 
         signRequest(&urlRequest, body: bodyData, credentials: credentials)
+        urlRequest.timeoutInterval = _queryTimeout.requestTimeoutInterval
 
         let (data, response) = try await withCheckedThrowingContinuation {
             (continuation: CheckedContinuation<(Data, URLResponse), Error>) in

Plugins/DynamoDBDriverPlugin/DynamoDBPluginDriver.swift

@@ -197,7 +197,9 @@ internal final class DynamoDBPluginDriver: PluginDatabaseDriver, @unchecked Send
         connection?.cancelCurrentRequest()
     }
 
-    func applyQueryTimeout(_ seconds: Int) async throws {}
+    func applyQueryTimeout(_ seconds: Int) async throws {
+        connection?.setQueryTimeout(seconds)
+    }
 
     // MARK: - Schema Operations
 

Plugins/DynamoDBDriverPlugin/Info.plist

@@ -4,5 +4,7 @@
 <dict>
 	<key>TableProPluginKitVersion</key>
 	<integer>12</integer>
+	<key>TableProMinAppVersion</key>
+	<string>0.42.0</string>
 </dict>
 </plist>