diff --git a/federationsender/internal/perform.go b/federationsender/internal/perform.go index 9d7c28fca..1a3eb9225 100644 --- a/federationsender/internal/perform.go +++ b/federationsender/internal/perform.go @@ -578,4 +578,4 @@ func (r *FederationSenderInternalAPI) PerformBroadcastEDU( } return nil -} \ No newline at end of file +} diff --git a/federationsender/storage/postgres/storage.go b/federationsender/storage/postgres/storage.go index e63c11bf3..8884e35b2 100644 --- a/federationsender/storage/postgres/storage.go +++ b/federationsender/storage/postgres/storage.go @@ -72,15 +72,15 @@ func NewDatabase(dbProperties *config.DatabaseOptions) (*Database, error) { return nil, err } d.Database = shared.Database{ - DB: d.db, - Writer: d.writer, - FederationSenderJoinedHosts: joinedHosts, - FederationSenderQueuePDUs: queuePDUs, - FederationSenderQueueEDUs: queueEDUs, - FederationSenderQueueJSON: queueJSON, - FederationSenderRooms: rooms, - FederationSenderBlacklist: blacklist, - FederationSenderInboundPeeks: inboundPeeks, + DB: d.db, + Writer: d.writer, + FederationSenderJoinedHosts: joinedHosts, + FederationSenderQueuePDUs: queuePDUs, + FederationSenderQueueEDUs: queueEDUs, + FederationSenderQueueJSON: queueJSON, + FederationSenderRooms: rooms, + FederationSenderBlacklist: blacklist, + FederationSenderInboundPeeks: inboundPeeks, FederationSenderOutboundPeeks: outboundPeeks, } if err = d.PartitionOffsetStatements.Prepare(d.db, d.writer, "federationsender"); err != nil {