Method SendPresence

clientapi/producers/syncapi.go:149–163

( // 发送出席消息（比如进入某个房间）
	ctx context.Context, userID string, presence types.Presence, statusMsg *string,
)

}

func (p *SyncAPIProducer) SendPresence( // 发送出席消息（比如进入某个房间）
	ctx context.Context, userID string, presence types.Presence, statusMsg *string,
) error {
	m := nats.NewMsg(p.TopicPresenceEvent)
	m.Header.Set(jetstream.UserID, userID)
	m.Header.Set("presence", presence.String())
	if statusMsg != nil {
		m.Header.Set("status_msg", *statusMsg)
	}

	m.Header.Set("last_active_ts", strconv.Itoa(int(gomatrixserverlib.AsTimestamp(time.Now()))))

	_, err := p.JetStream.PublishMsg(m, nats.Context(ctx))
	return err
}