Method sendDirectMessage

backend/plugin/webhook/wecom/wecom.go:152–196

sendDirectMessage sends direct message to users. returns `true` if successfully sends messages to all users.

(webhookCtx webhook.Context)

// sendDirectMessage sends direct message to users.
// returns `true` if successfully sends messages to all users.
func (*Receiver) sendDirectMessage(webhookCtx webhook.Context) bool {
	wecom := getWecomConfig(webhookCtx.IMSetting)
	if wecom == nil {
		return false
	}
	p, err := newProvider(wecom.GetCorpId(), wecom.GetAgentId(), wecom.GetSecret())
	if err != nil {
		slog.Error("failed to get wecom provider", log.BBError(err))
	}

	ctx := context.Background()

	fn := func() error {
		var errs error
		var users []string

		for _, u := range webhookCtx.MentionEndUsers {
			userID, err := p.getUserIDByEmail(ctx, u.Email)
			if err != nil {
				err = errors.Wrapf(err, "failed to get user id by email %v", u.Email)
				multierr.AppendInto(&errs, err)
				continue
			}
			users = append(users, userID)
		}
		if len(users) == 0 {
			err := errors.Errorf("wecom dm: got 0 user id, errs: %v", errs)
			return backoff.Permanent(err)
		}

		if err := p.sendMessage(ctx, users, getMessageCard(webhookCtx)); err != nil {
			err = errors.Wrapf(err, "failed to send message")
			multierr.AppendInto(&errs, err)
		}

		return errs
	}

	if err := common.Retry(ctx, fn); err != nil {
		slog.Warn("failed to send direct message to wecom users", log.BBError(err))
		return false
	}

	return true
}