Function postDirectMessage

backend/plugin/webhook/teams/teams.go:162–215

(webhookCtx webhook.Context)

}

func postDirectMessage(webhookCtx webhook.Context) bool {
	teams := getTeamsConfig(webhookCtx.IMSetting)
	if teams == nil {
		return false
	}

	p := newProvider(teams.TenantId, teams.ClientId, teams.ClientSecret)
	ctx := context.Background()

	sent := map[string]bool{}

	if err := common.Retry(ctx, func() error {
		var errs error

		var emails []string
		for _, u := range webhookCtx.MentionEndUsers {
			if sent[u.Email] {
				continue
			}
			emails = append(emails, u.Email)
		}

		idByEmail, err := p.getIDByEmail(ctx, emails)
		if err != nil {
			return errors.Wrapf(err, "failed to get id by email")
		}

		for _, u := range webhookCtx.MentionEndUsers {
			if sent[u.Email] {
				continue
			}
			id, ok := idByEmail[u.Email]
			if !ok {
				continue
			}

			err := p.sendMessage(ctx, id, getAdaptiveCard(webhookCtx))
			if err != nil {
				slog.Error("Teams failed to send message",
					slog.String("email", u.Email),
					log.BBError(err))
				err = errors.Wrapf(err, "failed to send message to %s", u.Email)
				multierr.AppendInto(&errs, err)
			}
			sent[u.Email] = true
		}
		return errs
	}); err != nil {
		slog.Warn("failed to send direct message to Teams user", log.BBError(err))
		return false
	}

	return true
}

func postMessage(context webhook.Context) error {
	factList := []WebhookSectionFact{}