mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-13 09:53:10 -06:00
parent
86d96c63ca
commit
ecaa9a000e
|
|
@ -74,19 +74,19 @@ func (s *filterStatements) prepare(db *sql.DB) (err error) {
|
||||||
func (s *filterStatements) selectFilter(
|
func (s *filterStatements) selectFilter(
|
||||||
ctx context.Context, localpart string, filterID string,
|
ctx context.Context, localpart string, filterID string,
|
||||||
) (*gomatrix.Filter, error) {
|
) (*gomatrix.Filter, error) {
|
||||||
// Retrieve canonical JSON
|
// Retrieve filter from database (stored as canonical JSON)
|
||||||
var filterData []byte
|
var filterData []byte
|
||||||
err := s.selectFilterStmt.QueryRowContext(ctx, localpart, filterID).Scan(&filterData)
|
err := s.selectFilterStmt.QueryRowContext(ctx, localpart, filterID).Scan(&filterData)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Parse filter JSON
|
// Unmarshall JSON into Filter struct
|
||||||
var filter gomatrix.Filter
|
var filter gomatrix.Filter
|
||||||
if err = json.Unmarshal(filterData, &filter); err != nil {
|
if err = json.Unmarshal(filterData, &filter); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
return &filter, err
|
return &filter, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *filterStatements) insertFilter(
|
func (s *filterStatements) insertFilter(
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue