Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This adds a Room integration package for PowerSync.
This works by making the PowerSync SDK run queries against the connection pool managed for Room databases, which ensures that we have no conflict due to multiple write connections. One unfortunate downside is that the driver APIs exposed by Room are async-only. Using
runBlocking
to turn them synchronous is inefficient, but also blocked by Room (if we request a connection from a pool, we can only use it from a single coroutine). It looks like we may be able to use something like this as a workaround though. This PR works around that by introducing asynchronous transaction callbacks, but that will require more work to finalize.This uses the new update hooks implemented in the core extension to query for updates after each transaction from the PowerSync SDK, these updates are automatically forwarded to Room (so a sync from PowerSync automatically updates
Flow
s in Room).Because we can't install a general update listener on Room databases, the other direction is more complicated. The best approach I could come up with here is to create a Room flow listening on all tables explicitly, and then call
powersync_update_hook('get')
to forward these writes to PowerSync.