Commit Graph

146 Commits

Author SHA1 Message Date
Nathan Harris d9d61bafe4 Minor comment fixes 2019-05-01 21:52:27 -07:00
Nathan Harris 0131fe43ba Update Readme and Tweak Redis.makeConnection(...)
Motivation:

The goal of the `Redis.makeConnection` factory method is to provide end users with a quick way to jump in and get started with Redis in Swift.

Right now, users have to provide an `EventLoopGroup` instance, when a reasonable default is available for us to define.

Modifications:

- Add: `MultiThreadedEventLoopGroup` for 1 thread as a default argument to the `using:` label in `Redis.makeConnection`
- Remove: The `with:` label for the password in `Redis.makeConnection`
- Change: The project README to reflect the current state of the project

Results:

Users should be able to create `RedisConnections` by just defining an IP Address & Port to connect to - and possibly a password.

In addition, the README should now properly direct users on how to use the latest version of the library.
2019-05-01 18:59:59 -07:00
Nathan Harris c7a606d8a6 Add Copyright Notices, Acknowledgements, and Contributors List 2019-05-01 16:24:05 -07:00
Nathan Harris 066a5c3dea Resolve RedisPipeline Proposal Discussion Topic
Motivation:

During the discussion thread of the NIORedis SSWG proposal, there were concerns expressed over the implementation
of `RedisPipeline` that covered the following areas:

1. Clashes with SwiftNIO concepts such as "Pipeline"
2. Misleading users on library behavior with using a Pipeline vs. a single `RedisConnection`
3. The implementation was "too clever" in that it allowed users to easily find themselves in "Undefined Behavior"
   due to lack of enough type safety in the API

However, the value in being able to control how frequently "flush" happens on a socket was discussed and considered
high - so something still needs to be in place to force flushes by users.

It was decided to leave the implementation of batching commands and their responses to library users, perhaps in
higher level frameworks while the library will provide said mechanism for controlling writing and flushing of commands.

Modifications:

- Add: `sendCommandsImmediately` bool property to `RedisConnection` to handle choice of flushing after each command
- Remove: `RedisPipeline`

Results:

Users should now have a more clear understanding on what type of control they have over the timing of when commands
are actually sent over the wire, with the greater emphasis placed on `RedisConnection`.
2019-05-01 15:26:00 -07:00
Nathan Harris 477668e667 Simplify RESP Parsing and Redis Channel Handlers
Motivation:

As it stands, the parsing / encoding implementations for RESP was directly tied to the NIO Channel Handlers.

Unit tests were sloppily spread across multiple files and it made it difficult to explicitly separate out
the Channel Handler behavior from the RESP specification implementation.

Modifications:

- Add: `RESPTranslator` enum helper object with static methods that only handles RESP parsing / encoding
- Rename: `RESPEncoder` to `RedisMessageEncoder`
- Rename: `RESPDecoder` to `RedisByteDecoder`

Results:

It should be easier to understand what type is intended to be used as part of a NIO channel pipeline while
still having a direct way of parsing / encoding between Swift types and the RESP specification.

Unit tests should be more maintainable as well.
2019-04-30 22:54:31 -07:00
Nathan Harris e446a834cd Namespace global static factory methods under Redis
Motivation:

The two provided factory methods for creating `RedisConnection` and `ClientBootstrap` were not readily discoverable or appropriately expressible.

Modifications:

- Add: `Redis` top-level namespace enum
- Move & Rename: `RedisConnection.connect` factory method to `Redis.makeConnection`
- Move & Rename: `ClientBootstrap.makeRedisDefault` factory method to `Redis.makeDefaultClientBootstrap`
- Rename: `EventLoopFuture` extension file to just `SwiftNIO` to have all framework extensions in a single file

Results:

Using NIORedis should be more discoverable and straight forward on how to create a connection with `Redis.makeConnection(...)` over `RedisConnection.connect(...)`
2019-04-30 21:01:35 -07:00
Nathan Harris 46e96bd9cb Standardize Error Handling
Motivation:

`RedisError` was being used in many places in an ad-hoc fashion that made it unclear as to what source of errors it exactly represents.

In addition, it doesn't follow community conventions of handling known "classes" of errors with enums rather than static struct instances.

Results:

All errors that are generated and thrown within the library are specified as either `RESPDecoder.Error` or `NIORedisError`.

`RedisError` is simplified to represent an error message sent by a Redis instance that conforms to `LocalizedError`.
2019-04-30 16:18:21 -07:00
Nathan Harris 76ceb6370c Fix incorrect default logger label in RedisConnection static factory method 2019-04-24 10:34:29 -07:00
Nathan Harris 864c4bcff6 Refactor RedisClient state to use enum instead of booleans
Motivation:

When later adding support for pub/sub, and potentially batching commands, a state is going to need to be defined and multiple booleans will create a large matrix that will be error prone.

Results:

Rather than using `Atomic<Bool>`, a `Lock` and `ConnectionState` enum are used to determine if a connection is open.
2019-04-24 10:33:55 -07:00
Nathan Harris d93511b8d0 Rework RESPValue to use ByteBuffers for .simpleString and .bulkString
Motivation:

Throughout the process of creating and using RESPValue, many unnecessary allocations happened translating ByteBuffers into [Int8] raw byte arrays.

Results:

RESPValue has a more conherent underlying data structure and computed properties, while decoding RESP is more straight forward and performant

Resolves #31
2019-04-09 16:29:24 -07:00
Nathan Harris 4cfc326c4d Update to latest SwiftLog names 2019-04-09 11:42:52 -07:00
Nathan Harris 3c53d4404b Replace Foundation.Data with [UInt8] type everywhere
Motivation:

`Foundation.Data` is known to be more expensive than is necessary for this low level of a library, and has some quirks with its usage.

Results:

This library now works with byte arrays (`[UInt8]`) directly, and all references to `Foundation` now explicitly import the exact types they need.
2019-04-01 09:23:45 -07:00
Nathan Harris 51dd32dabd Add a warning log in RedisConnection deinit 2019-03-28 22:03:17 -07:00
Nathan Harris 2b7b2130ca Remove authorize convenience command method
Motivation:

As this command is embedded in the creation of a `RedisConnection` and you authorize an entire connection to a Redis instance - this command serves no purpose and could make it easier for users to shoot themselves in the foot.

Results:

`authorize(with:)` convenience method is removed, and the `RedisConnection.connect` method now sends a raw command
2019-03-27 23:07:01 -07:00
Nathan Harris db4a156d05 Remove RedisDriver
Motivation:

`RedisDriver` has one of the weakest use cases for existence, as its entire purpose can be solved with a static function on `RedisConnection`.

Result:

`RedisDriver` no longer is a thing, and a simpler process of creating a `RedisConnection` is available through the static method `connect(to:with:on:logger:)`.

Also, the `ClientBootstrap.makeForRedis(using:)` method has been cleaned up and renamed to `ClientBootstrap.makeRedisDefault(using:)`.
2019-03-27 22:56:40 -07:00
Nathan Harris c4ea8f9e49 Simplify RedisPipeline
Motivation:

`RedisPipeline` has a weak use case as a protocol, as it is more than likely 98% of use cases will end up using the `NIORedisPipeline` implementation.

Result:

`RedisPipeline` is more direct in its intended usage, with comment blocks being more clear.
2019-03-27 22:44:46 -07:00
Nathan Harris 9f049eb4b5 Simplify RedisCommandExecutor and RedisConnection
Motivation:

`RedisCommandExecutor` was a complex and "wordy" name that was not 100% clear as to how it relates to other types.

`RedisConnection` also has not had a strong use case shown for it to exists as a separate protocol - using up a great name for the "out of the box" implementation.

Result:

`RedisClient` instead of `RedisCommandExecutor` is more clear as to what it is, in Redis terminology, a communication client.

`RedisConnection` as a concrete class provides an identifiable basic block for making connections to Redis.

`RedisConnection` also saw some fixes to `close()` while having some names and comment blocks tweaked for updated naming.
2019-03-27 22:36:52 -07:00
Nathan Harris f4e646c1aa Audit convenience commands
Motivation:

Performance, clarity, and uniformity with code documentation, Swift API, and data types.
2019-03-25 13:37:40 -07:00
Nathan Harris bcc7f71186 Add convenience command methods for Sorted Set with unit tests 2019-03-23 22:29:38 -07:00
Nathan Harris 050ad64eaa Add list convenience commands with unit tests 2019-03-21 19:41:29 -07:00
Nathan Harris 21fc0a4031 Make extension properties on RESPValue to all be public 2019-03-21 19:41:08 -07:00
Nathan Harris 39feecb4cb Add hash convenience commands with unit tests 2019-03-21 16:00:19 -07:00
Nathan Harris 17f77363ae Fix scan method and add unit test 2019-03-21 14:07:15 -07:00
Nathan Harris d7b029fe29 Add scan convenience method and refactor sscan to use new generic internal implementation for scan 2019-03-20 22:18:34 -07:00
Nathan Harris 4c7fe40419 Add mset, msetnx, mget, incr, incrby, incrbyfloat, decr, and decrby convenience methods with unit tests 2019-03-20 14:13:11 -07:00
Nathan Harris 55fbbcc1f5 Reorganize code into related extensions 2019-03-20 13:22:40 -07:00
Nathan Harris 5a35a918ae Add extension to EventLoopFuture for RESPValueConvertible Values for easier mapping 2019-03-20 12:43:08 -07:00
Nathan Harris 73d5930f34 Add initial swift-log support for most paths
Closes #14
2019-03-18 22:04:47 -07:00
Nathan Harris 6b30127f6b Refactor RedisConnection and RedisPipeline into protocols.
Motivation:

The goal of this commit is to make it easier for library users to implement their own types for creating connections and pipelines without losing all of the convenience command extensions.

This also splits executing commands from the concept of a "connection" to make it more swifty in `RedisPipeline`.
2019-03-18 19:48:36 -07:00
Nathan Harris 6825451963 Improve RedisConnection.close() to send a QUIT command to Redis before closing the channel from the client 2019-03-18 19:19:46 -07:00
Nathan Harris 9f505be4d2 Add echo, ping, and swapdb command extensions with unit tests 2019-03-18 18:59:12 -07:00
Nathan Harris 618481fe1e Add RESPValueConvertible conformance to Optional 2019-03-18 18:57:59 -07:00
Nathan Harris 5c32b97a0c Remove DispatchRedis 2019-03-17 14:06:21 -07:00
Nathan Harris 00bf027330 Add all Set commands with unit tests
This contributes to #10
2019-03-12 23:14:44 -07:00
Nathan Harris 571d7bce02 Housekeeping of code
- Move: `String.convertedToData()` to `NIORedisTests` as a test utility
- Change: URLs in code comments to be Markdown links
- Change: Code comments to be more correct
2019-03-12 14:42:11 -07:00
Nathan Harris 9c5db400b2 Update RESPEncoder to write to ByteBuffer directly
This is to remove the need of allocations with Foundation.Data before writing to the buffer.

We should see an estimated ~10% performance boost to encoding values.
2019-03-12 14:31:42 -07:00
Nathan Harris b4fc9f3ae5 Update to latest SwiftNIO 2019-03-11 21:41:13 -07:00
tanner0101 5a831fad05 nio 2 ctx fixes 2019-02-28 22:05:42 -05:00
Nathan Harris 4d9afa5ba0 Update to latest NIO2 changes 2019-02-12 22:45:25 -08:00
Nathan Harris deac19553f resolve SR-9876 bug with different joined "implementation" 2019-02-11 16:15:19 -08:00
Nathan Harris 51e18f7149 remove unnecessary indirect label on RESPValue.array case 2019-02-11 16:14:34 -08:00
Nathan Harris dd58fb2cfe Split NIO ChannelHandler conformances into separate files from RESP Encoder/Decoder 2019-02-11 12:33:22 -08:00
Nathan Harris 5bdb92967b Rename RESPConvertible file to RESPValueConvertible to match type definition 2019-02-11 12:28:09 -08:00
Nathan Harris 7b9a349213 Rename RedisCommandContext.promise to responsePromise 2019-02-08 17:14:21 -08:00
Nathan Harris fff2486450 Update RESPConvertible to match proposal.
- Rename: `RESPConvertible` to `RESPValueConvertible`
- Change: `RESPValueConvertible.convertFromRESP(_:)` to be a non-throwing failable initializer
- Rename: `RESPValueConvertible.convertToRESP()` to non-throwing `convertedToRESPValue()`
2019-02-08 16:52:48 -08:00
Nathan Harris e168b6c65e update to latest NIO2 2019-02-06 16:13:51 -08:00
Nathan Harris e25db7dcfd Make public factory method for "standard" NIORedis ClientBootstrap 2019-01-17 16:10:59 -08:00
Nathan Harris 1e160b0680 Make RedisDriver.eventLoopGroup public 2019-01-17 13:24:46 -08:00
Nathan Harris d8cd550931 Fix initializers not being public 2019-01-17 12:22:11 -08:00
Nathan Harris 7609a8455f Cleanup interactions with isRunning and isClosed properties 2019-01-10 11:33:47 -08:00