1.3.0 (#14)

* swift-docc-plugin 1.3.0

* async-http-client 1.19.0

* replaced deprecated .createNew with the new .singleton

* Adding _find capability. (#13)

* docs

* tabs

* renames

* added test for find method with body

* docs added

* findError added

* tests renamed

* added test for find method with generic type

* docs

* README updated

* updated dependencies

* docs updated

* try Swift 5.7.1

* Update build-ubuntu.yml

* Swift 5.7.3

* Revert "Swift 5.7.3"

This reverts commit ab8f67a.

---------

Co-authored-by: Gregório Gevartosky Torrezan <[email protected]>

Author: makoni

.github/workflows/build-ubuntu.yml

@@ -11,7 +11,7 @@ jobs:
     name: Build on Ubuntu with Swift ${{matrix.swift}}
     strategy:
       matrix:
-        swift: [5.8.1, 5.7.3, 5.6.3]
+        swift: [5.9, 5.8.1, 5.7.3]
     runs-on: ubuntu-latest
     container: 
       image: swift:${{matrix.swift}}

Package.resolved

@@ -1,4 +1,4 @@
-// swift-tools-version:5.6
+// swift-tools-version:5.7.1
 // The swift-tools-version declares the minimum version of Swift required to build this package.
 
 import PackageDescription

Package.swift

@@ -129,6 +129,13 @@ print(dbs)
 // prints: ["_global_changes", "_replicator", "_users", "yourDBname"]
 ```
 
+Find documents in DB by selector:
+```swift
+let selector = ["selector": ["name": "Sam"]]
+let docs: [ExpectedDoc] = try await couchDBClient.find(in: "databaseName", selector: selector)
+print(docs)
+```
+
 ### Using with Vapor
 Here's a simple [tutorial](https://spaceinbox.me/docs/couchdbclient/tutorials/couchdbclient/vaportutorial) for Vapor.
 

README.md

@@ -17,6 +17,7 @@ Currently CouchDBClient supports:
 - Get databases list.
 - Get document by id or documents using view.
 - Insert/update documents.
+- Find documents by selector.
 - Delete documents.
 - CouchDB authorization.
 

Sources/CouchDBClient/CouchDBClient.docc/CouchDBClient.md

@@ -27,5 +27,7 @@ A CouchDB client class with methods using Swift Concurrency.
 - ``insert(dbName:doc:dateEncodingStrategy:eventLoopGroup:)``
 - ``update(dbName:doc:dateEncodingStrategy:eventLoopGroup:)``
 - ``update(dbName:uri:body:eventLoopGroup:)``
+- ``find(in:body:eventLoopGroup:)``
+- ``find(in:selector:dateDecodingStrategy:eventLoopGroup:)``
 - ``delete(fromDb:doc:eventLoopGroup:)``
 - ``delete(fromDb:uri:rev:eventLoopGroup:)``

Sources/CouchDBClient/CouchDBClient.docc/Extensions/Client.md

@@ -22,6 +22,8 @@ public enum CouchDBClientError: Error {
 	case insertError(error: CouchDBError)
 	/// Update request wasn't successful.
 	case updateError(error: CouchDBError)
+	/// Find request wasn't successful.
+	case findError(error: CouchDBError)
 	/// Uknown response from CouchDB.
 	case unknownResponse
 	/// Wrong username or password.
@@ -41,6 +43,8 @@ extension CouchDBClientError: LocalizedError {
 			return "Insert request wasn't successful: \(error.localizedDescription)"
 		case .updateError(let error):
 			return "Update request wasn't successful: \(error.localizedDescription)"
+		case .findError(let error):
+			return "Find request wasn't successful: \(error.localizedDescription)"
 		case .unknownResponse:
 			return "Uknown response from CouchDB."
 		case .unauthorized:
@@ -478,6 +482,96 @@ public class CouchDBClient {
 			throw parsingError
 		}
 	}
+    
+    /// Find data in DB by selector.
+    ///
+    /// Example:
+    ///
+    /// ```swift
+    /// // find documents in DB by selector
+	/// let selector = ["selector": ["name": "Sam"]]
+    /// let docs: [ExpectedDoc] = try await couchDBClient.find(in: testsDB, selector: selector)
+    /// ```
+    ///
+    /// - Parameters:
+    ///   - in dbName: DB name.
+    ///   - selector: Codable representation of json selector query.
+    ///   - eventLoopGroup: NIO's EventLoopGroup object. New will be created if nil value provided.
+    /// - Returns: Array of documents [T].
+	public func find<T: Codable & CouchDBRepresentable>(in dbName: String, selector: Codable, dateDecodingStrategy: JSONDecoder.DateDecodingStrategy = .secondsSince1970, eventLoopGroup: EventLoopGroup? = nil) async throws -> [T] {
+		let encoder = JSONEncoder()
+		let selectorData = try encoder.encode(selector)
+
+		let findResponse = try await find(
+			in: dbName,
+			body: .data(selectorData),
+			eventLoopGroup: eventLoopGroup
+		)
+
+		guard var body = findResponse.body, let bytes = body.readBytes(length: body.readableBytes) else {
+			throw CouchDBClientError.unknownResponse
+		}
+
+		let data = Data(bytes)
+		let decoder = JSONDecoder()
+		decoder.dateDecodingStrategy = dateDecodingStrategy
+
+		do {
+			let doc = try decoder.decode(CouchDBFindResponse<T>.self, from: data)
+			return doc.docs
+		} catch let parsingError {
+			if let couchdbError = try? decoder.decode(CouchDBError.self, from: data) {
+				throw CouchDBClientError.findError(error: couchdbError)
+			}
+			throw parsingError
+		}
+	}
+	
+	/// Find data in DB by selector.
+	///
+	/// Example:
+	/// ```swift
+	/// let selector = ["selector": ["name": "Greg"]]
+	/// let bodyData = try JSONEncoder().encode(selector)
+	/// var findResponse = try await couchDBClient.find(in: testsDB, body: .data(bodyData))
+	///
+	/// let bytes = findResponse.body!.readBytes(length: findResponse.body!.readableBytes)!
+	/// let docs = try JSONDecoder().decode(CouchDBFindResponse<ExpectedDoc>.self, from: Data(bytes)).docs
+	/// ```
+	/// - Parameters:
+	///   - dbName: DB name.
+	///   - body: Request body data.
+	///   - eventLoopGroup: NIO's EventLoopGroup object. New will be created if nil value provided.
+	/// - Returns: Request response.
+	public func find(in dbName: String, body: HTTPClient.Body, eventLoopGroup: EventLoopGroup? = nil) async throws -> HTTPClient.Response {
+		try await authIfNeed(eventLoopGroup: eventLoopGroup)
+
+		let httpClient: HTTPClient
+		if let eventLoopGroup = eventLoopGroup {
+			httpClient = HTTPClient(eventLoopGroupProvider: .shared(eventLoopGroup))
+		} else {
+			httpClient = HTTPClient(eventLoopGroupProvider: .singleton)
+		}
+
+		defer {
+			DispatchQueue.main.async {
+				try? httpClient.syncShutdown()
+			}
+		}
+
+		let url = buildUrl(path: "/" + dbName + "/_find", query: [])
+		var request = try buildRequest(fromUrl: url, withMethod: .POST)
+		request.body = body
+		let response = try await httpClient
+			.execute(request: request, deadline: .now() + .seconds(requestsTimeout))
+			.get()
+
+		if response.status == .unauthorized {
+			throw CouchDBClientError.unauthorized
+		}
+
+		return response
+	}
 
 	/// Update data in DB.
 	///

Sources/CouchDBClient/CouchDBClient.swift

@@ -0,0 +1,13 @@
+//
+//  CouchDBFindResponse.swift
+//  
+//
+//  Created by Gregorio Gevartosky Torrezan on 2023-11-15.
+//
+
+import Foundation
+
+public struct CouchDBFindResponse<T: Codable & CouchDBRepresentable>: Codable {
+    var docs: [T]
+    var bookmark: String?
+}