Method createUnsubMagicTokens

admin/server/reports.go:763–822

(ctx context.Context, projectID, reportName, ownerID, ownerEmail string, emails []string)

}

func (s *Server) createUnsubMagicTokens(ctx context.Context, projectID, reportName, ownerID, ownerEmail string, emails []string) (map[string]string, error) {
	var createdByUserID *string
	if ownerID != "" {
		createdByUserID = &ownerID
	}
	ttl := 3 * 30 * 24 * time.Hour // approx 3 months
	mgcOpts := &admin.IssueMagicAuthTokenOptions{
		ProjectID:       projectID,
		CreatedByUserID: createdByUserID,
		Internal:        true,
		TTL:             &ttl,
	}

	// issue magic tokens
	cctx, tx, err := s.admin.DB.NewTx(ctx, false)
	if err != nil {
		return nil, fmt.Errorf("failed to start transaction: %w", err)
	}
	defer func() { _ = tx.Rollback() }()

	emailTokens := make(map[string]string)
	for _, email := range emails {
		if ownerEmail != "" && strings.EqualFold(ownerEmail, email) {
			// skip creating unsubscribe token for owner email
			continue
		}
		// set user attrs as per the email
		mgcOpts.Attributes = map[string]interface{}{
			"name":   "",
			"email":  email,
			"domain": email[strings.LastIndex(email, "@")+1:],
			"groups": []string{},
			"admin":  false,
		}

		tkn, err := s.admin.IssueMagicAuthToken(cctx, mgcOpts)
		if err != nil {
			return nil, fmt.Errorf("failed to issue magic auth token for email %s: %w", email, err)
		}

		emailTokens[email] = tkn.Token().String()

		_, err = s.admin.DB.InsertNotificationToken(cctx, &database.InsertNotificationTokenOptions{
			ResourceKind:     runtime.ResourceKindReport,
			ResourceName:     reportName,
			RecipientEmail:   email,
			MagicAuthTokenID: tkn.Token().ID.String(),
		})
		if err != nil {
			return nil, fmt.Errorf("failed to insert report token for email %s: %w", email, err)
		}
	}

	err = tx.Commit()
	if err != nil {
		return nil, fmt.Errorf("failed to commit transaction: %w", err)
	}