PlaintDB Serves - another milestone reached
Tags: rust, pliantdb, database
Published: 2021-04-14 17:53:14

---
title: PlaintDB Serves - another milestone reached
published: true
date: 2021-04-14 17:53:00 UTC
tags: rust,pliantdb,databases
canonical_url: https://ecton.dev/pliantdb-serves/
---

It's been a productive couple of weeks since I [introduced PliantDB](https://ecton.dev/introducing-pliantdb/). I merged the [pull request enabling client/server communications](https://github.com/khonsulabs/pliantdb/pull/28). The journey took a little longer than I had anticipated, but that's for a few reasons. Ultimately, I want to stress something: You can be extremely productive in Rust.

{% youtube XE0lH0tlbBs?t=27m27s %}

If you want to just learn about how PliantDB's engine works, [my previous post](https://ecton.dev/introducing-pliantdb/) goes into more detail. Or, you can listen to my talk at last Saturday's Rust Game Dev Meetup, embedded above. Today, I'm going to talk more about the process of developing.

## My journey from Rust-noob to when I began PliantDB

My Rust journey began a few years ago when I haphazardly threw together a small tool to wait for AWS CloudFormation stacks to reach a "complete" state. The official AWS CLI application allows you to wait for a single state, such as "UPDATE_COMPLETE," but not for one of many states (or any state matching a COMPLETE-like status). So, I wrote a simple tool using [rusoto](https://lib.rs/rusoto). I liked the idea of Rust, but it didn't click for me yet. Stubborn me didn't actually read the book.

Fast forward to when I'm daydreaming about quitting my day job to pursue game development. At that point, I firmly believed in the idea of why Rust was a big deal, but I still hadn't done anything beyond that simple tool. When I quit my job in November 2019, I had only started trying to dive into Rust full time.

PliantDB's initial commit was on [Friday, March 19](https://github.com/khonsulabs/pliantdb/commit/43bd3a25b61fc7841c9554422d7bb46ad4362e59). I know I began writing code that morning because I kicked off the day by having a conversation with one of my former business partners: "You'll never guess what I'm seriously thinking of doing after we end our call."

When I told him, "I'm going to write my own CouchDB-like database," he protested in the fashion he always would as we debated ideas back when we ran our business together. Within a few minutes, I had sold him on the idea, which gave me the last boost of confidence I needed to embark on what most developers would consider a foolish endeavor.

## Tackling async compatibility issues

I settled on [sled](https://sled.rs) after evaluating the landscape of available BTree-like data storage layers. It's a complex project, but it's well-tested and is fairly widespread in use. From the initial moments of designing this architecture, I was thinking of how to fit it within sled to utilize its transactions to ensure ACID compliance.

This fundamental decision wasn't without downsides. The primary of which is that sled isn't "compatible" with async/await in Rust. What I mean is that if you're trying to integrate it within an app that uses tokio, for example, you either need to operate sled within its own thread pool outside of tokio, or you need to use blocking wrappers such as spawn_blocking. These come with their own downsides, such as long-running blocking tasks requiring to worry about tasks on the currently blocked thread not executing.

For today, I've chosen to use my best guess as to the best type of blocking wrapper for each type of operation, but the long-term goal is utilizing a new async executor that [Daxpedda](https://github.com/daxpedda) is working on. It's compatible with tokio, but it already has a concept named `block_on_blocking,` which is an optimized version of blocking designed to more fairly block without needing to adopt a `'static` lifetime requirement due to using `spawn_blocking`. He's about to resume working on the executor, but he was responsible for the [QUIC-based networking stack](https://github.com/khonsulabs/fabruic/) PliantDB is using and is wrapping up a few last requests before moving on.

## Complexities of supporting a rich type system over a network

The second major battle was something I hadn't fully comprehended when I started: How do you deal with types in a safe way while only exchanging bytes between a client and server? In my head, I knew [serde](https://serde.rs) was going to be a big part of the solution, but I didn't quite realize the levels of indirection I was going to need.

Let's take a look at an example:

```rust
db
 .view::<ShapesByNumberOfSides>()
 .with_key(3)
 .query_with_docs()
 .await?
```

This code could be code running on a client talking to a remote database or using PliantDB locally in a form akin to SQLite. This is meant to be one of the selling points of PliantDB, but to make this work, it's rather tricky. Here's how it works:

[`db.view::<ShapesByNumberOfSides>()`](https://docs.rs/pliantdb/0.1.0-dev-2/pliantdb/core/connection/trait.Connection.html#method.view) returns a [View](https://docs.rs/pliantdb/0.1.0-dev-2/pliantdb/local/core/connection/struct.View.html), which acts as a [builder](https://doc.rust-lang.org/1.0.0/style/ownership/builders.html) for accessing a view. [`with_key(3)`](https://docs.rs/pliantdb/0.1.0-dev-2/pliantdb/local/core/connection/struct.View.html#method.with_key) sets the `key` field of the `View` to [`QueryKey::Matches(3_u32)`](https://docs.rs/pliantdb/0.1.0-dev-2/pliantdb/core/connection/enum.QueryKey.html). Finally, [`query_with_docs()`](https://docs.rs/pliantdb/0.1.0-dev-2/pliantdb/local/core/connection/struct.View.html#method.query_with_docs) simply calls [`Connection::query_with_docs()`](https://docs.rs/pliantdb/0.1.0-dev-2/pliantdb/core/connection/trait.Connection.html#tymethod.query_with_docs).

Let's look at it from the Client's perspective. Following it along the route to the server will show the complexities I had to navigate and the power of Rust each step along the way.

On the client, `db` is a `RemoteDatabase<Schema>`. This implements connection, and converts the parameters `Option<QueryKey<u32>>` and `AccessPolicy` into [`Request::Database`](https://docs.rs/pliantdb-local/0.1.0-dev-2/pliantdb_local/core/networking/enum.Request.html#variant.Database) `{ database: "dbname", request:` [`DatabaseRequest::Query`](https://docs.rs/pliantdb-local/0.1.0-dev-2/pliantdb_local/core/networking/enum.DatabaseRequest.html#variant.Query) `{ view: "view-name", key: Option<QueryKey<Vec<u8>>>, access_policy, with_docs: true } }`.

Once it has it in this enum, it can be sent via QUIC or WebSockets across the wire. It will receive that request on the server, but at the layer that it's receiving the request, the server doesn't have any generic types in its signatures. So, we must design a way to talk to our `Storage<Schema>` without the `<Schema>` part!

This is done using an internal trait [`OpenDatabase`](https://github.com/khonsulabs/pliantdb/blob/40eb7a16af42c6e768c2824bfafbf2c89f908f49/server/src/server.rs#L704), which the server implements for `Storage<Schema>`. This is the first layer, allowing the network code to [invoke `query_with_docs`](https://github.com/khonsulabs/pliantdb/blob/40eb7a16af42c6e768c2824bfafbf2c89f908f49/server/src/server.rs#L819) which takes the view's name rather than the type of the view. It then looks up an [abstracted version](https://docs.rs/pliantdb-core/0.1.0-dev-2/pliantdb_core/schema/view/trait.Serialized.html) of that view which automatically serializes and deserializes across its access points. These are the same conversion mechanisms that were used when initially creating the ViewEntries when indexing these views.

Finally, once the response is retrieved, the journey happens in reverse, going through [`Response::Database`](https://docs.rs/pliantdb-local/0.1.0-dev-2/pliantdb_local/core/networking/enum.Response.html#variant.Database)([`DatabaseResponse::ViewMappingsWithDocs()`](https://docs.rs/pliantdb-local/0.1.0-dev-2/pliantdb_local/core/networking/enum.DatabaseResponse.html#variant.ViewMappingsWithDocs)).

To me, it's incredible the lengths that you can go in Rust to allow transparent handling of native types in user-code. One of my initial goals of PlaintDB has been achieved: writing local and remote code using async/await without needing to care whether the data is local or not.

## Multi-tasking is challenging sometimes, even with Rust

Ultimately, the goal wasn't to provide a WebSocket implementation in the first pass of the server. I had a goal to present at the Game Dev Meetup this past Saturday, and I really wanted to have a working client/server, but Daxpedda and I were having troubles with some of our code. It was becoming tough to isolate whether the networking code was to blame or whether PlaintDB was to blame.

That's when I decided to add WebSockets. I was pretty confident I wanted them long-term anyways. Additionally, it was to give me a way to use a protocol I was familiar with and wasn't very complicated to verify the server's functionality. I found bugs with my code in PliantDB pretty quickly, but I was having two peculiar issues.

First, I was becoming more and more confident that the channel library Daxpedda and I fell in love with, [flume](https://lib.rs/flume), was misbehaving, but I couldn't seem to reproduce it outside of the massive PliantDB codebase. I finally called up Daxpedda on Discord and screen shared my debugging session, showing him how the tests succeeded if I retained a channel. If I allowed the sender to drop after successfully sending, sometimes the tests would fail. He agreed, something was odd. It took me a while, but I finally whittled it down to about 30 lines of code and [reported the issue](https://github.com/zesterer/flume/issues/78). In an amazingly quick fashion, the maintainer fixed the issue and released an update. And for the record, I still fully love and recommend this library if you're mixing async and non-async code using channels. It's a wonderful implementation.

The second issue was that every time I ran my unit test suite as a whole, I would sometimes succeed, but more often than not, after a random number of tests, all of the rest would fail. This ended up being my own stupidity. When I was writing the unit tests for the client, I thought to myself, "If I create one shared server, I can test the server differently by running each client test suite on a single server in its own database." I liked the idea, but I didn't think about the problem of achieving it.

> Pro-tip: `#[tokio::test]` creates a unique tokio runtime for each test

When spawning the server, I was spawning it in a runtime that would dutifully get destroyed once the test completed. Whatever other tests happened to finish before the server was destroyed would get green marks, and the rest would start getting connection refusals.

Of course, this manifested itself in fun ways to my code -- channels just disconnecting all of a sudden, and often I wouldn't have any errors displaying anywhere!

So, remember: when writing async tests, if you `spawn` into your async runtime, it will not last beyond the current unit test. In this case, I decided to move that style of test to an integration-style test, to keep the "unit" nature more accurate.

## Sharing Unit Tests

One of the neat results of using the same trait to implement the database interface for Client/Server/Local is that a common unit testing suite was able to be written and reused:

* [`pliantdb-core::test_util::define_connection_test_suite!`](https://github.com/khonsulabs/pliantdb/blob/40eb7a16af42c6e768c2824bfafbf2c89f908f49/core/src/test_util.rs#L284)
* [`pliantdb-local::tests`](https://github.com/khonsulabs/pliantdb/blob/40eb7a16af42c6e768c2824bfafbf2c89f908f49/local/src/tests.rs#L34)
* [`pliantdb-server::tests`](https://github.com/khonsulabs/pliantdb/blob/40eb7a16af42c6e768c2824bfafbf2c89f908f49/server/src/tests.rs#L38)
* [`pliantdb-client::tests::websockets`](https://github.com/khonsulabs/pliantdb/blob/40eb7a16af42c6e768c2824bfafbf2c89f908f49/client/src/tests.rs#L92)
* [`pliantdb-client::tests::pliant`](https://github.com/khonsulabs/pliantdb/blob/40eb7a16af42c6e768c2824bfafbf2c89f908f49/client/src/tests.rs#L136) (the QUIC-based connection tests)

This means that as more database functionality is added, it can be added to the common test suite and automatically tested across all layers of PliantDB. Once clustering support is added, the same suite will be tested there also.

## Being Productive

This morning, I decided I wanted to write an example for the PliantDB server. At the end of the day, I wasn't happy with the type of interaction-less result I could make with the current functionality, so [I added `reduce_grouped()`](https://github.com/khonsulabs/pliantdb/issues/22). I marveled with Daxpedda in Discords after looking at the diff: [19 files,+494,-90](https://github.com/khonsulabs/pliantdb/commit/c14c6d7bf1dfe4977a42a8f89c3275721c744114). It took me about an hour from the point of introducing my first compilation issue to getting it compiling. I added a couple of unit tests into the existing suite, and it all worked.

This is a regular occurrence with Rust and me. Yes, I can tell you about my experiences of having to debug multithreading issues. I can tell you they're just as painful as they are outside of Rust. However, the building blocks of the language itself encourage a design that helps eliminate so many types of runtime issues that you can encounter. You can still have errors in your logic, but I am finding that more often than not: when it compiles, it works.

Let's look at the stats of PliantDB as of tonight, using [tokei](https://github.com/XAMPPRocky/tokei):

```bash
===============================================================================
 Language            Files        Lines         Code     Comments       Blanks
===============================================================================
 Shell                   2           29           24            3            2
 TOML                    8          249          223            1           25
 YAML                    1            8            6            2            0
-------------------------------------------------------------------------------
 Markdown                1           77            0           49           28
 |- BASH                 1            1            1            0            0
 |- Rust                 1           54           40            3           11
 (Total)                            132           41           52           39
-------------------------------------------------------------------------------
 Rust                   61         7974         6699          221         1054
 |- Markdown            39          593            0          563           30
 (Total)                           8567         6699          784         1084
===============================================================================
 Total                  73         8337         6952          276         1109
===============================================================================
```

According to Tokei, I've written 6699 lines of Rust code in this project. The first day of work was Friday, March 19, which is around ~3.5 weeks for those stats.

I have a [pretty-well-tested](https://khonsulabs.github.io/pliantdb/coverage/) codebase that I'm almost ready to integrate into [Cosmic Verge](https://github.com/khonsulabs/cosmicverge). While I have plenty of work remaining on PliantDB, I'm excited at the prospect of replacing PostgreSQL and Redis in Cosmic Verge potentially next month.

## Interested in PliantDB's development?

I'm always happy to have more people to talk about Rust with. I'd love to hear from you [on Discord](https://discord.khonsulabs.com), [Twitter](https://twitter.com/ectonDev), or [GitHub Discussions](https://github.com/khonsulabs/pliantdb/discussions).

[pliantdb]: https://github.com/khonsulabs/pliantdb