Skip to content

Commit 063395d

Browse files
authored
(feat): Sync Streams (#35)
* Adding data classes and fields related to sync streams. Added controller logic to StreamingSyncImplementation. * Scaffold for ConnectionManager. * Finished first stab at sync streams. * Fixes/polish. * Added finalizer. Cleaned up some property getters. * Polish. * Fixed issue with skipping Storage Adapter cleanup failing sequential tests. * Virtualised some Remote methods, also changed remote to be supplied via a factory. Scaffolding A MockRemote test. * Added a fix for closing a live stream. * Finished PoC for mocked sync service tests. Added missing StreamingSyncRequest field. * wip * Ported SyncStreamsTests. Minor fixes/polish. * Disabled parralelization across tests. * Deep equal test implementation. * Added DeepEquals utility, using for comparison in SyncStatus. * Using StreamPriority struct instead of enum. TTL is now specified via TimeSpan. * Removing pointless json attribute. * Fixed dapper typing issue. * Changelog entry. * Made SyncStatus on DB public. * Added SyncTests to test some more sync issues. Fixed dapper issue. * Changed PowerSyncDatabase public members to public get, protected set. * Moved performance tests to a separate test package.
1 parent 35cea75 commit 063395d

27 files changed

Lines changed: 2505 additions & 185 deletions

PowerSync/PowerSync.Common/CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
# PowerSync.Common Changelog
22

33
## 0.0.8-alpha.1
4+
- Add support for [sync streams](https://docs.powersync.com/sync/streams/overview).
45
- Return an `IDisposable` from `PowerSync.Watch`, allowing for easier cancellation of watched queries.
56
- Replaced the old JSON-based method of extracting type information from queries with using Dapper internally for queries, improving memory usage and execution time for querying.
67
- Added non-generic overloads for `GetAll()`, `GetOptional()`, `Get()`, `Watch()` which return `dynamic`:

PowerSync/PowerSync.Common/Client/Connection/PowerSyncCredentials.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
namespace PowerSync.Common.Client.Connection;
2+
23
public class PowerSyncCredentials(string endpoint, string token, DateTime? expiresAt = null)
34
{
45
public string Endpoint { get; set; } = endpoint;

0 commit comments

Comments
 (0)