( ctx context.Context, txn *sql.Tx, roomID string, stateFilter *gomatrixserverlib.StateFilter, )
| 935 | } |
| 936 | |
| 937 | func (d *Database) currentStateStreamEventsForRoom( |
| 938 | ctx context.Context, txn *sql.Tx, roomID string, |
| 939 | stateFilter *gomatrixserverlib.StateFilter, |
| 940 | ) ([]types.StreamEvent, error) { |
| 941 | allState, err := d.CurrentRoomState.SelectCurrentState(ctx, txn, roomID, stateFilter, nil) |
| 942 | if err != nil { |
| 943 | return nil, err |
| 944 | } |
| 945 | s := make([]types.StreamEvent, len(allState)) |
| 946 | for i := 0; i < len(s); i++ { |
| 947 | s[i] = types.StreamEvent{HeaderedEvent: allState[i], StreamPosition: 0} |
| 948 | } |
| 949 | return s, nil |
| 950 | } |
| 951 | |
| 952 | func (d *Database) StoreNewSendForDeviceMessage( |
| 953 | ctx context.Context, userID, deviceID string, event gomatrixserverlib.SendToDeviceEvent, |
no test coverage detected