Method SendSignal

backend/store/signal.go:16–27

SendSignal sends a notification to the bytebase_signal channel.

(ctx context.Context, signalType storepb.Signal_Type, projectID string, uid int64)

// SendSignal sends a notification to the bytebase_signal channel.
func (s *Store) SendSignal(ctx context.Context, signalType storepb.Signal_Type, projectID string, uid int64) error {
	payload, err := protojson.Marshal(&storepb.Signal{
		Type:    signalType,
		Uid:     uid,
		Project: projectID,
	})
	if err != nil {
		return errors.Wrap(err, "failed to marshal signal payload")
	}
	_, err = s.GetDB().ExecContext(ctx, "SELECT pg_notify($1, $2)", SignalChannel, string(payload))
	return errors.Wrap(err, "failed to send signal")
}