mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-29 01:33:10 -06:00
Test
This commit is contained in:
parent
0889ceeac2
commit
bdc30e57a5
|
|
@ -97,3 +97,6 @@ type OutputPresenceData struct {
|
||||||
LastActiveAgo int64 `json:"last_active_ago,omitempty"`
|
LastActiveAgo int64 `json:"last_active_ago,omitempty"`
|
||||||
StreamPos types2.StreamPosition `json:"stream_pos"`
|
StreamPos types2.StreamPosition `json:"stream_pos"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type FederationPresenceData struct {
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -502,6 +502,13 @@ func (t *txnReq) processEDUs(ctx context.Context) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
case gomatrixserverlib.MPresence:
|
||||||
|
payload := eduserverAPI.FederationPresenceData{}
|
||||||
|
util.GetLogger(ctx).Debug("%s", e.Content)
|
||||||
|
if err := json.Unmarshal(e.Content, &payload); err != nil {
|
||||||
|
util.GetLogger(ctx).WithError(err).Error("Failed to unmarshal presence event")
|
||||||
|
continue
|
||||||
|
}
|
||||||
default:
|
default:
|
||||||
util.GetLogger(ctx).WithField("type", e.Type).Debug("Unhandled EDU")
|
util.GetLogger(ctx).WithField("type", e.Type).Debug("Unhandled EDU")
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue