mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-07 15:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Review comments

Browse source
This commit is contained in:
Mark Haines 2017-02-07 13:39:52 +00:00
parent edce400ef4
commit 77e3ff58c2
2 changed files with 25 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/github.com/matrix-org/dendrite/roomserver/input/events.go
View file

@ -11,6 +11,7 @@ type RoomEventDatabase interface {
} }
func processRoomEvent(db RoomEventDatabase, input api.InputRoomEvent) error { func processRoomEvent(db RoomEventDatabase, input api.InputRoomEvent) error {
// Parse and validate the event JSON
event, err := gomatrixserverlib.NewEventFromUntrustedJSON(input.Event) event, err := gomatrixserverlib.NewEventFromUntrustedJSON(input.Event)
if err != nil { if err != nil {
return err return err
@ -20,11 +21,26 @@ func processRoomEvent(db RoomEventDatabase, input api.InputRoomEvent) error {
return err return err
} }
// TODO:
// * Check that the event passes authentication checks.
if input.Kind == api.KindOutlier { if input.Kind == api.KindOutlier {
// For outlier events we only need to store the event JSON. // For outliers we can stop after we've stored the event itself as it
// doesn't have any associated state to store and we don't need to
// notify anyone it.
return nil return nil
} }
// TODO: Handle the other kinds of input. // TODO:
// * Calcuate the state at the event if necessary.
// * Store the state at the event.
// * Update the extremities of the event graph for the room
// * Caculate the new current state for the room if the forward extremities have changed.
// * Work out the delta between the new current state and the previous current state.
// * Work out the visibility of the event.
// * Write a message to the output logs containing:
// - The event itself
// - The visiblity of the event, i.e. who is allowed to see the event.
// - The changes to the current state of the room.
panic("Not implemented") panic("Not implemented")
} }

11
src/github.com/matrix-org/dendrite/roomserver/storage/storage.go
View file

@ -62,10 +62,13 @@ func (d *Database) StoreEvent(event gomatrixserverlib.Event) error {
} }
} }
eventID := event.EventID() if eventNID, err = d.statements.insertEvent(
referenceSHA256 := event.EventReference().EventSHA256 roomNID,
eventTypeNID,
if eventNID, err = d.statements.insertEvent(roomNID, eventTypeNID, eventStateKeyNID, eventID, referenceSHA256); err != nil { eventStateKeyNID,
event.EventID(),
event.EventReference().EventSHA256,
); err != nil {
return err return err
} }