( ctx context.Context, userID, roomID, eventID, receiptType string, timestamp gomatrixserverlib.Timestamp, )
| 42 | } |
| 43 | |
| 44 | func (p *SyncAPIProducer) SendReceipt( |
| 45 | ctx context.Context, |
| 46 | userID, roomID, eventID, receiptType string, timestamp gomatrixserverlib.Timestamp, |
| 47 | ) error { |
| 48 | m := &nats.Msg{ |
| 49 | Subject: p.TopicReceiptEvent, |
| 50 | Header: nats.Header{}, |
| 51 | } |
| 52 | m.Header.Set(jetstream.UserID, userID) |
| 53 | m.Header.Set(jetstream.RoomID, roomID) |
| 54 | m.Header.Set(jetstream.EventID, eventID) |
| 55 | m.Header.Set("type", receiptType) |
| 56 | m.Header.Set("timestamp", fmt.Sprintf("%d", timestamp)) |
| 57 | |
| 58 | log.WithFields(log.Fields{}).Tracef("Producing to topic '%s'", p.TopicReceiptEvent) |
| 59 | _, err := p.JetStream.PublishMsg(m, nats.Context(ctx)) |
| 60 | return err |
| 61 | } |
| 62 | |
| 63 | func (p *SyncAPIProducer) SendToDevice( |
| 64 | ctx context.Context, sender, userID, deviceID, eventType string, |
no test coverage detected