NewDatabase creates a new sync server database nolint: gocyclo
(base *base.BaseDendrite, dbProperties *config.DatabaseOptions)
| 36 | // NewDatabase creates a new sync server database |
| 37 | // nolint: gocyclo |
| 38 | func NewDatabase(base *base.BaseDendrite, dbProperties *config.DatabaseOptions) (*SyncServerDatasource, error) { |
| 39 | var d SyncServerDatasource |
| 40 | var err error |
| 41 | if d.db, d.writer, err = base.DatabaseConnection(dbProperties, sqlutil.NewExclusiveWriter()); err != nil { |
| 42 | return nil, err |
| 43 | } |
| 44 | if err = d.prepare(); err != nil { |
| 45 | return nil, err |
| 46 | } |
| 47 | return &d, nil |
| 48 | } |
| 49 | |
| 50 | func (d *SyncServerDatasource) prepare() (err error) { |
| 51 | if err = d.streamID.Prepare(d.db); err != nil { |
nothing calls this directly
no test coverage detected