Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion Package.swift
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,9 @@ var package = Package(
),
.target(
name: "ValkeySearch",
dependencies: ["Valkey"],
dependencies: [
"Valkey"
],
swiftSettings: defaultSwiftSettings
),
.target(
Expand Down
82 changes: 82 additions & 0 deletions Sources/Valkey/RESP/RESPRenderableHelpers.swift
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
//
import NIOCore

/// Render token if boolean is true
@usableFromInline
package struct RESPPureToken: RESPRenderable {
@usableFromInline
Expand All @@ -29,6 +30,7 @@ package struct RESPPureToken: RESPRenderable {
}
}

/// Render token and value if value is not nil
@usableFromInline
package struct RESPWithToken<Value: RESPRenderable>: RESPRenderable {
@usableFromInline
Expand Down Expand Up @@ -57,6 +59,7 @@ package struct RESPWithToken<Value: RESPRenderable>: RESPRenderable {
}
}

/// Render array with token preceding each item
@usableFromInline
package struct RESPArrayWithToken<Element: RESPRenderable>: RESPRenderable {
@usableFromInline
Expand All @@ -82,6 +85,7 @@ package struct RESPArrayWithToken<Element: RESPRenderable>: RESPRenderable {
}
}

/// Render array item count and then array
@usableFromInline
package struct RESPArrayWithCount<Element: RESPRenderable>: RESPRenderable {
@usableFromInline
Expand All @@ -101,3 +105,81 @@ package struct RESPArrayWithCount<Element: RESPRenderable>: RESPRenderable {
self.array.encode(into: &commandEncoder)
}
}

/// Render number of resp parameters array generates and then array
@usableFromInline
package struct RESPArrayWithParameterCount<Element: RESPRenderable>: RESPRenderable {
@usableFromInline
let array: [Element]

@inlinable
package init(_ array: [Element]) {
self.array = array
}
@inlinable
package var respEntries: Int {
self.array.respEntries + 1
}
@inlinable
package func encode(into commandEncoder: inout ValkeyCommandEncoder) {
self.array.respEntries.encode(into: &commandEncoder)
self.array.encode(into: &commandEncoder)
}
}

/// Render token, count of items in array and array, but only if array is non-empty
@usableFromInline
package struct RESPArrayWithTokenAndCount<Element: RESPRenderable>: RESPRenderable {
@usableFromInline
let array: [Element]
@usableFromInline
let token: String

@inlinable
package init(_ token: String, _ array: [Element]) {
self.token = token
self.array = array
}

@inlinable
package var respEntries: Int {
guard self.array.count > 0 else { return 0 }
return self.array.respEntries + 2
}
@inlinable
package func encode(into commandEncoder: inout ValkeyCommandEncoder) {
guard self.array.count > 0 else { return }
self.token.encode(into: &commandEncoder)
self.array.count.encode(into: &commandEncoder)
self.array.encode(into: &commandEncoder)
}
}

/// Render token, count of parameters generated by array and array, but only if array is non-empty
@usableFromInline
package struct RESPArrayWithTokenAndParameterCount<Element: RESPRenderable>: RESPRenderable {
@usableFromInline
let array: [Element]
@usableFromInline
let token: String

@inlinable
package init(_ token: String, _ array: [Element]) {
self.token = token
self.array = array
}
@inlinable
package var respEntries: Int {
let respEntries = self.array.respEntries
guard respEntries > 0 else { return 0 }
return respEntries + 2
}
@inlinable
package func encode(into commandEncoder: inout ValkeyCommandEncoder) {
let respEntries = self.array.respEntries
guard respEntries > 0 else { return }
self.token.encode(into: &commandEncoder)
respEntries.encode(into: &commandEncoder)
self.array.encode(into: &commandEncoder)
}
}
Loading
Loading