Function postDirectMessage

backend/plugin/webhook/slack/slack.go:253–295

(webhookCtx webhook.Context)

}

func postDirectMessage(webhookCtx webhook.Context) bool {
	ctx := context.Background()
	t := getSlackToken(webhookCtx.IMSetting)
	if t == "" {
		slog.Warn("failed to found valid slack im token", slog.String("event", webhookCtx.EventType))
		return false
	}
	p := newProvider(t)
	sent := map[string]bool{}
	if err := common.Retry(ctx, func() error {
		var errs error
		for _, u := range webhookCtx.MentionEndUsers {
			if sent[u.Email] {
				continue
			}
			err := func() error {
				userID, err := p.lookupByEmail(ctx, u.Email)
				if err != nil {
					return errors.Wrapf(err, "failed to lookup user")
				}
				if userID == "" {
					return errors.Errorf("failed to find user id for %v", u.Email)
				}
				channelID, err := p.openConversation(ctx, userID)
				if err != nil {
					return errors.Wrapf(err, "failed to open conversation")
				}
				if err := p.chatPostMessage(ctx, channelID, webhookCtx); err != nil {
					return errors.Wrapf(err, "failed to post message")
				}
				sent[u.Email] = true
				return nil
			}()
			multierr.AppendInto(&errs, errors.Wrapf(err, "failed to send message to user %v", u.Email))
		}
		return errs
	}); err != nil {
		slog.Warn("failed to send direct message to slack user", log.BBError(err), slog.String("event", webhookCtx.EventType))
		return false
	}

	return true
}