MCPcopy Create free account
hub / github.com/daodst/chat / NewDatabase

Function NewDatabase

syncapi/storage/postgres/syncserver.go:38–119  ·  view source on GitHub ↗

NewDatabase creates a new sync server database

(base *base.BaseDendrite, dbProperties *config.DatabaseOptions)

Source from the content-addressed store, hash-verified

36
37// NewDatabase creates a new sync server database
38func 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.NewDummyWriter()); err != nil {
42 return nil, err
43 }
44 accountData, err := NewPostgresAccountDataTable(d.db)
45 if err != nil {
46 return nil, err
47 }
48 events, err := NewPostgresEventsTable(d.db)
49 if err != nil {
50 return nil, err
51 }
52 currState, err := NewPostgresCurrentRoomStateTable(d.db)
53 if err != nil {
54 return nil, err
55 }
56 invites, err := NewPostgresInvitesTable(d.db)
57 if err != nil {
58 return nil, err
59 }
60 peeks, err := NewPostgresPeeksTable(d.db)
61 if err != nil {
62 return nil, err
63 }
64 topology, err := NewPostgresTopologyTable(d.db)
65 if err != nil {
66 return nil, err
67 }
68 backwardExtremities, err := NewPostgresBackwardsExtremitiesTable(d.db)
69 if err != nil {
70 return nil, err
71 }
72 sendToDevice, err := NewPostgresSendToDeviceTable(d.db)
73 if err != nil {
74 return nil, err
75 }
76 filter, err := NewPostgresFilterTable(d.db)
77 if err != nil {
78 return nil, err
79 }
80 receipts, err := NewPostgresReceiptsTable(d.db)
81 if err != nil {
82 return nil, err
83 }
84 memberships, err := NewPostgresMembershipsTable(d.db)
85 if err != nil {
86 return nil, err
87 }
88 notificationData, err := NewPostgresNotificationDataTable(d.db)
89 if err != nil {
90 return nil, err
91 }
92 ignores, err := NewPostgresIgnoresTable(d.db)
93 if err != nil {
94 return nil, err
95 }

Callers

nothing calls this directly

Tested by

no test coverage detected