aboutsummaryrefslogtreecommitdiff
path: root/syncapi
diff options
context:
space:
mode:
Diffstat (limited to 'syncapi')
-rw-r--r--syncapi/storage/postgres/syncserver.go2
-rw-r--r--syncapi/storage/sqlite3/syncserver.go2
2 files changed, 2 insertions, 2 deletions
diff --git a/syncapi/storage/postgres/syncserver.go b/syncapi/storage/postgres/syncserver.go
index 36e8de67..e7f2c944 100644
--- a/syncapi/storage/postgres/syncserver.go
+++ b/syncapi/storage/postgres/syncserver.go
@@ -80,7 +80,7 @@ func NewDatabase(dbProperties *config.DatabaseOptions) (*SyncServerDatasource, e
}
d.Database = shared.Database{
DB: d.db,
- Writer: sqlutil.NewDummyWriter(),
+ Writer: d.writer,
Invites: invites,
AccountData: accountData,
OutputEvents: events,
diff --git a/syncapi/storage/sqlite3/syncserver.go b/syncapi/storage/sqlite3/syncserver.go
index 81197bb7..f68bf737 100644
--- a/syncapi/storage/sqlite3/syncserver.go
+++ b/syncapi/storage/sqlite3/syncserver.go
@@ -93,7 +93,7 @@ func (d *SyncServerDatasource) prepare() (err error) {
}
d.Database = shared.Database{
DB: d.db,
- Writer: sqlutil.NewExclusiveWriter(),
+ Writer: d.writer,
Invites: invites,
AccountData: accountData,
OutputEvents: events,