add nonce to pricing-table.js

After the engine url got moved to /subscriptions, the tests had to be adapted.

The subscribe controller does not return products anymore after moving to the stripe pricing table, so the respective tests were removed.

.discourse-compatibility

@@ -1,7 +1,3 @@
-< 3.5.0.beta5-dev: 7309c937dddb1933ac66aa2d3e13d071060d30ff
-< 3.5.0.beta1-dev: b4f7be4274ada9400238f8692e705669034c1709
-< 3.4.0.beta2-dev: 692f410ab59e329d0aaf537cd772698f83c32a8a
-< 3.4.0.beta1-dev: bb96d77056a9ef842e01e46fd980320d427073ad
 < 3.3.0.beta1-dev: 0dcf17de59bdf82c0233bb630dad0ce407d1ae76
 3.1.999: c4f8220a5572ef9a42a9a71500e001d0df206c43
 2.9.0.beta9: 39b7253c082270e33839f4b0821fbf75abfdd826

.eslintrc.cjs

@@ -0,0 +1 @@
+module.exports = require("@discourse/lint-configs/eslint");

.npmrc

@@ -1,2 +0,0 @@
-engine-strict = true
-auto-install-peers = false

Gemfile.lock

@@ -7,95 +7,71 @@ GIT
 GEM
   remote: https://rubygems.org/
   specs:
-    activesupport (8.0.2)
+    activesupport (7.1.3.2)
       base64
-      benchmark (>= 0.3)
       bigdecimal
-      concurrent-ruby (~> 1.0, >= 1.3.1)
+      concurrent-ruby (~> 1.0, >= 1.0.2)
       connection_pool (>= 2.2.5)
       drb
       i18n (>= 1.6, < 2)
-      logger (>= 1.4.2)
       minitest (>= 5.1)
-      securerandom (>= 0.3)
-      tzinfo (~> 2.0, >= 2.0.5)
-      uri (>= 0.13.1)
-    ast (2.4.3)
-    base64 (0.3.0)
-    benchmark (0.4.1)
-    bigdecimal (3.2.0)
-    concurrent-ruby (1.3.5)
-    connection_pool (2.5.3)
-    drb (2.2.3)
-    i18n (1.14.7)
+      mutex_m
+      tzinfo (~> 2.0)
+    ast (2.4.2)
+    base64 (0.2.0)
+    bigdecimal (3.1.6)
+    concurrent-ruby (1.2.3)
+    connection_pool (2.4.1)
+    drb (2.2.1)
+    i18n (1.14.3)
       concurrent-ruby (~> 1.0)
-    json (2.12.2)
-    language_server-protocol (3.17.0.5)
-    lint_roller (1.1.0)
-    logger (1.7.0)
-    minitest (5.25.5)
-    parallel (1.27.0)
-    parser (3.3.8.0)
+      racc (~> 1.7)
+    json (2.7.1)
+    language_server-protocol (3.17.0.3)
+    minitest (5.22.2)
+    mutex_m (0.2.0)
+    parallel (1.24.0)
+    parser (3.3.0.5)
       ast (~> 2.4.1)
       racc
     prettier_print (1.2.1)
-    prism (1.4.0)
-    racc (1.8.1)
-    rack (3.1.16)
+    racc (1.7.3)
     rainbow (3.1.1)
-    regexp_parser (2.10.0)
-    rubocop (1.75.8)
+    regexp_parser (2.9.0)
+    rexml (3.2.6)
+    rubocop (1.62.0)
       json (~> 2.3)
-      language_server-protocol (~> 3.17.0.2)
-      lint_roller (~> 1.1.0)
+      language_server-protocol (>= 3.17.0)
       parallel (~> 1.10)
       parser (>= 3.3.0.2)
       rainbow (>= 2.2.2, < 4.0)
-      regexp_parser (>= 2.9.3, < 3.0)
-      rubocop-ast (>= 1.44.0, < 2.0)
+      regexp_parser (>= 1.8, < 3.0)
+      rexml (>= 3.2.5, < 4.0)
+      rubocop-ast (>= 1.31.1, < 2.0)
       ruby-progressbar (~> 1.7)
-      unicode-display_width (>= 2.4.0, < 4.0)
-    rubocop-ast (1.44.1)
-      parser (>= 3.3.7.2)
-      prism (~> 1.4)
-    rubocop-capybara (2.22.1)
-      lint_roller (~> 1.1)
-      rubocop (~> 1.72, >= 1.72.1)
-    rubocop-discourse (3.12.1)
+      unicode-display_width (>= 2.4.0, < 3.0)
+    rubocop-ast (1.31.1)
+      parser (>= 3.3.0.4)
+    rubocop-capybara (2.20.0)
+      rubocop (~> 1.41)
+    rubocop-discourse (3.7.1)
       activesupport (>= 6.1)
-      lint_roller (>= 1.1.0)
-      rubocop (>= 1.73.2)
-      rubocop-capybara (>= 2.22.0)
-      rubocop-factory_bot (>= 2.27.0)
-      rubocop-rails (>= 2.30.3)
-      rubocop-rspec (>= 3.0.1)
-      rubocop-rspec_rails (>= 2.31.0)
-    rubocop-factory_bot (2.27.1)
-      lint_roller (~> 1.1)
-      rubocop (~> 1.72, >= 1.72.1)
-    rubocop-rails (2.32.0)
-      activesupport (>= 4.2.0)
-      lint_roller (~> 1.1)
-      rack (>= 1.1)
-      rubocop (>= 1.75.0, < 2.0)
-      rubocop-ast (>= 1.44.0, < 2.0)
-    rubocop-rspec (3.6.0)
-      lint_roller (~> 1.1)
-      rubocop (~> 1.72, >= 1.72.1)
-    rubocop-rspec_rails (2.31.0)
-      lint_roller (~> 1.1)
-      rubocop (~> 1.72, >= 1.72.1)
-      rubocop-rspec (~> 3.5)
+      rubocop (>= 1.59.0)
+      rubocop-capybara (>= 2.0.0)
+      rubocop-factory_bot (>= 2.0.0)
+      rubocop-rspec (>= 2.25.0)
+    rubocop-factory_bot (2.25.1)
+      rubocop (~> 1.41)
+    rubocop-rspec (2.27.1)
+      rubocop (~> 1.40)
+      rubocop-capybara (~> 2.17)
+      rubocop-factory_bot (~> 2.22)
     ruby-progressbar (1.13.0)
-    securerandom (0.4.1)
     syntax_tree (6.2.0)
       prettier_print (>= 1.2.0)
     tzinfo (2.0.6)
       concurrent-ruby (~> 1.0)
-    unicode-display_width (3.1.4)
-      unicode-emoji (~> 4.0, >= 4.0.4)
-    unicode-emoji (4.0.4)
-    uri (1.0.3)
+    unicode-display_width (2.5.0)
 
 PLATFORMS
   ruby
@@ -106,4 +82,4 @@ DEPENDENCIES
   translations-manager!
 
 BUNDLED WITH
-   2.6.9
+   2.5.4

README.md

@@ -1,8 +1,5 @@
 # Discourse Subscriptions Plugin
 
-> [!IMPORTANT]
-> This plugin has now been bundled into Discourse core. See: https://meta.discourse.org/t/bundling-more-popular-plugins-with-discourse-core/373574
-
 Discourse Subscriptions allows site owners to sell recurring and one-time purchase subscriptions that grant access to a group on a Discourse instance.
 
 For more information, please see: https://meta.discourse.org/t/discourse-subscriptions-plugin/140818

app/controllers/discourse_subscriptions/admin/subscriptions_controller.rb

@@ -53,7 +53,7 @@ module DiscourseSubscriptions
         params.require(:id)
         begin
           refund_subscription(params[:id]) if params[:refund]
-          subscription = ::Stripe::Subscription.cancel(params[:id])
+          subscription = ::Stripe::Subscription.delete(params[:id])
 
           customer =
             Customer.find_by(
@@ -61,8 +61,11 @@ module DiscourseSubscriptions
               customer_id: subscription[:customer],
             )
 
+          Subscription.delete_by(external_id: params[:id])
+
           if customer
             user = ::User.find(customer.user_id)
+            customer.delete
             group = plan_group(subscription[:plan])
             group.remove(user) if group
           end
@@ -80,7 +83,6 @@ module DiscourseSubscriptions
           expand: ["data.plan.product"],
           limit: PAGE_LIMIT,
           starting_after: start,
-          status: "all",
         )
       end
 

app/controllers/discourse_subscriptions/hooks_controller.rb

@@ -9,7 +9,6 @@ module DiscourseSubscriptions
 
     layout false
 
-    before_action :set_api_key
     skip_before_action :check_xhr
     skip_before_action :redirect_to_login_if_required
     skip_before_action :verify_authenticity_token, only: [:create]
@@ -28,121 +27,48 @@ module DiscourseSubscriptions
       end
 
       case event[:type]
-      when "checkout.session.completed"
-        checkout_session = event[:data][:object]
-
-        if SiteSetting.discourse_subscriptions_enable_verbose_logging
-          Rails.logger.warn("checkout.session.completed data: #{checkout_session}")
-        end
-        email = checkout_session[:customer_email]
-
-        return head 200 if checkout_session[:status] != "complete"
-        return render_json_error "email not found" if !email
-
-        if checkout_session[:customer].nil?
-          customer = ::Stripe::Customer.create({ email: email })
-          customer_id = customer[:id]
-        else
-          customer_id = checkout_session[:customer]
-        end
-
-        if SiteSetting.discourse_subscriptions_enable_verbose_logging
-          Rails.logger.warn("Looking up user with email: #{email}")
-        end
-
-        user = ::User.find_by_username_or_email(email)
-
-        return render_json_error "user not found" if !user
-
-        discourse_customer = Customer.create(user_id: user.id, customer_id: customer_id)
-
-        subscription = checkout_session[:subscription]
-
-        if subscription.present?
-          Subscription.create(customer_id: discourse_customer.id, external_id: subscription)
-        end
-
-        line_items =
-          ::Stripe::Checkout::Session.list_line_items(checkout_session[:id], { limit: 1 })
-        item = line_items[:data].first
-
-        group = plan_group(item[:price])
-        group.add(user) unless group.nil?
-
-        if SiteSetting.discourse_subscriptions_enable_verbose_logging
-          Rails.logger.warn("Line item with group name meta data: #{item[:price]}")
-          if group.nil?
-            Rails.logger.warn("Group not found or not listed in metadata!")
-          else
-            Rails.logger.warn("Group: #{group.name}")
-          end
-        end
-
-        discourse_customer.product_id = item[:price][:product]
-        discourse_customer.save!
-
-        if !subscription.nil?
-          ::Stripe::Subscription.update(
-            subscription,
-            { metadata: { user_id: user.id, username: user.username } },
-          )
-        end
       when "customer.subscription.created"
       when "customer.subscription.updated"
-        subscription = event[:data][:object]
-        status = subscription[:status]
-        return head 200 if !%w[complete active].include?(status)
-
-        customer = find_active_customer(subscription[:customer], subscription[:plan][:product])
+        customer =
+          Customer.find_by(
+            customer_id: event[:data][:object][:customer],
+            product_id: event[:data][:object][:plan][:product],
+          )
 
         return render_json_error "customer not found" if !customer
-
-        update_status(customer.id, subscription[:id], status)
+        return head 200 if event[:data][:object][:status] != "complete"
 
         user = ::User.find_by(id: customer.user_id)
         return render_json_error "user not found" if !user
 
-        if group = plan_group(subscription[:plan])
+        if group = plan_group(event[:data][:object][:plan])
           group.add(user)
         end
       when "customer.subscription.deleted"
-        subscription = event[:data][:object]
-
-        customer = find_active_customer(subscription[:customer], subscription[:plan][:product])
+        customer =
+          Customer.find_by(
+            customer_id: event[:data][:object][:customer],
+            product_id: event[:data][:object][:plan][:product],
+          )
 
         return render_json_error "customer not found" if !customer
 
-        update_status(customer.id, subscription[:id], subscription[:status])
+        Subscription.find_by(
+          customer_id: customer.id,
+          external_id: event[:data][:object][:id],
+        )&.destroy!
 
         user = ::User.find(customer.user_id)
         return render_json_error "user not found" if !user
 
-        if group = plan_group(subscription[:plan])
+        if group = plan_group(event[:data][:object][:plan])
           group.remove(user)
         end
+
+        customer.destroy!
       end
 
       head 200
     end
-
-    private
-
-    def update_status(customer_id, subscription_id, status)
-      discourse_subscription =
-        Subscription.find_by(customer_id: customer_id, external_id: subscription_id)
-      discourse_subscription.update(status: status) if discourse_subscription
-    end
-
-    def find_active_customer(customer_id, product_id)
-      Customer
-        .joins(:subscriptions)
-        .where(customer_id: customer_id, product_id: product_id)
-        .where(
-          Subscription.arel_table[:status].eq(nil).or(
-            Subscription.arel_table[:status].not_eq("canceled"),
-          ),
-        )
-        .first
-    end
   end
 end

app/controllers/discourse_subscriptions/pricingtable_controller.rb

@@ -1,11 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  class PricingtableController < ::ApplicationController
-    requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-    def index
-      head 200
-    end
-  end
-end

app/controllers/discourse_subscriptions/subscribe_controller.rb

@@ -11,20 +11,7 @@ module DiscourseSubscriptions
     requires_login except: %i[index contributors show]
 
     def index
-      begin
-        product_ids = Product.all.pluck(:external_id)
-        products = []
-
-        if product_ids.present? && is_stripe_configured?
-          response = ::Stripe::Product.list({ ids: product_ids, active: true })
-
-          products = response[:data].map { |p| serialize_product(p) }
-        end
-
-        render_json_dump products
-      rescue ::Stripe::InvalidRequestError => e
-        render_json_error e.message
-      end
+      head 200
     end
 
     def contributors
@@ -85,19 +72,14 @@ module DiscourseSubscriptions
 
           promo_code_id = promo_code[:id] if promo_code
 
-          subscription_params = {
-            customer: customer[:id],
-            items: [{ price: params[:plan] }],
-            metadata: metadata_user,
-            trial_period_days: trial_days,
-            promotion_code: promo_code_id,
-          }
-
-          if SiteSetting.discourse_subscriptions_enable_automatic_tax
-            subscription_params[:automatic_tax] = { enabled: true }
-          end
-
-          transaction = ::Stripe::Subscription.create(subscription_params)
+          transaction =
+            ::Stripe::Subscription.create(
+              customer: customer[:id],
+              items: [{ price: params[:plan] }],
+              metadata: metadata_user,
+              trial_period_days: trial_days,
+              promotion_code: promo_code_id,
+            )
 
           payment_intent = retrieve_payment_intent(transaction[:latest_invoice]) if transaction[
             :status
@@ -105,28 +87,16 @@ module DiscourseSubscriptions
         else
           coupon_id = promo_code[:coupon][:id] if promo_code && promo_code[:coupon] &&
             promo_code[:coupon][:id]
-
-          invoice_params = { customer: customer[:id] }
-          if SiteSetting.discourse_subscriptions_enable_automatic_tax
-            invoice_params[:automatic_tax] = { enabled: true }
-          end
-          invoice = ::Stripe::Invoice.create(invoice_params)
-
           invoice_item =
             ::Stripe::InvoiceItem.create(
               customer: customer[:id],
               price: params[:plan],
               discounts: [{ coupon: coupon_id }],
-              invoice: invoice[:id],
             )
+          invoice = ::Stripe::Invoice.create(customer: customer[:id])
           transaction = ::Stripe::Invoice.finalize_invoice(invoice[:id])
           payment_intent = retrieve_payment_intent(transaction[:id]) if transaction[:status] ==
             "open"
-          if payment_intent.nil?
-            return(
-              render_json_error I18n.t("js.discourse_subscriptions.subscribe.transaction_error")
-            )
-          end
           transaction = ::Stripe::Invoice.pay(invoice[:id]) if payment_intent[:status] ==
             "successful"
         end
@@ -167,11 +137,7 @@ module DiscourseSubscriptions
         )
 
       if transaction[:object] == "subscription"
-        Subscription.create(
-          customer_id: customer.id,
-          external_id: transaction[:id],
-          status: transaction[:status],
-        )
+        Subscription.create(customer_id: customer.id, external_id: transaction[:id])
       end
     end
 
@@ -190,17 +156,7 @@ module DiscourseSubscriptions
     def current_user_products
       return [] if current_user.nil?
 
-      Customer
-        .joins(:subscriptions)
-        .where(user_id: current_user.id)
-        .where(
-          Subscription.arel_table[:status].eq(nil).or(
-            Subscription.arel_table[:status].not_eq("canceled"),
-          ),
-        )
-        .select(:product_id)
-        .distinct
-        .pluck(:product_id)
+      Customer.select(:product_id).where(user_id: current_user.id).map { |c| c.product_id }.compact
     end
 
     def serialize_plans(plans)

app/controllers/discourse_subscriptions/user/payments_controller.rb

@@ -27,31 +27,10 @@ module DiscourseSubscriptions
               payments = ::Stripe::PaymentIntent.list(customer: customer_id)
               payments_from_invoices =
                 payments[:data].select { |payment| invoice_ids.include?(payment[:invoice]) }
-
-              if SiteSetting.discourse_subscriptions_enable_verbose_logging
-                Rails.logger.warn("Payments from invoices: #{payments_from_invoices}")
-              end
-
-              # Pricing table one-off purchases do not have invoices
-              payments_without_invoices =
-                payments[:data].select { |payment| payment[:invoice].nil? }
-
-              if SiteSetting.discourse_subscriptions_enable_verbose_logging
-                Rails.logger.warn("Payments without invoices: #{payments_without_invoices}")
-              end
-
-              data = data | payments_from_invoices | payments_without_invoices
+              data = data | payments_from_invoices
             end
           end
 
-          if SiteSetting.discourse_subscriptions_pricing_table_enabled && current_user.email
-            related_guest_payments = fetch_guest_payments(current_user.email)
-            if SiteSetting.discourse_subscriptions_enable_verbose_logging
-              Rails.logger.warn("Related guest payments: #{related_guest_payments}")
-            end
-            data = data | related_guest_payments
-          end
-
           data = data.sort_by { |pmt| pmt[:created] }.reverse
 
           render_json_dump data
@@ -63,13 +42,12 @@ module DiscourseSubscriptions
       private
 
       def parse_invoices(all_invoices, product_ids)
-        all_invoices[:data].select do |invoice|
-          invoice_lines = invoice[:lines][:data][0] if invoice[:lines] && invoice[:lines][:data]
-          if invoice_lines
+        invoices_with_products =
+          all_invoices[:data].select do |invoice|
+            invoice_lines = invoice[:lines][:data][0] if invoice[:lines] && invoice[:lines][:data]
             invoice_product_id = parse_invoice_lines(invoice_lines)
             product_ids.include?(invoice_product_id)
           end
-        end
       end
 
       def parse_invoice_lines(invoice_lines)
@@ -79,40 +57,6 @@ module DiscourseSubscriptions
           invoice_lines[:plan][:product]
         invoice_product_id
       end
-
-      def fetch_guest_payments(email)
-        guest_payments = []
-        starting_after = nil
-
-        begin
-          loop do
-            # Fetch charges in batches of 100, using pagination with starting_after
-            charges =
-              ::Stripe::Charge.list(
-                limit: 100,
-                starting_after: starting_after,
-                expand: ["data.payment_intent"],
-              )
-
-            charges[:data].each do |charge|
-              # Check if the charge is associated with the given email and has no customer ID
-              if charge[:billing_details][:email] == email && charge[:customer].nil?
-                guest_payments << charge
-              end
-            end
-
-            # Check if there are more charges to fetch
-            break if charges[:data].count < 100
-
-            # Set starting_after to the last charge's ID for the next batch
-            starting_after = charges[:data].last[:id]
-          end
-        rescue ::Stripe::StripeError => e
-          render_json_error e.message
-        end
-
-        guest_payments
-      end
     end
   end
 end

app/controllers/discourse_subscriptions/user/subscriptions_controller.rb

@@ -15,7 +15,6 @@ module DiscourseSubscriptions
         begin
           customer = Customer.where(user_id: current_user.id)
           customer_ids = customer.map { |c| c.id } if customer
-          stripe_customer_ids = customer.map { |c| c.customer_id }.uniq if customer
           subscription_ids =
             Subscription.where("customer_id in (?)", customer_ids).pluck(
               :external_id,
@@ -24,25 +23,18 @@ module DiscourseSubscriptions
           subscriptions = []
 
           if subscription_ids
-            prices = []
-            price_params = { limit: 100, expand: ["data.product"] }
-            loop do
-              response = ::Stripe::Price.list(price_params)
-              prices.concat(response[:data])
-              break unless response[:has_more]
-              price_params[:starting_after] = response[:data].last.id
-            end
-            all_subscriptions = []
+            plans = ::Stripe::Price.list(expand: ["data.product"], limit: 100)
 
-            stripe_customer_ids.each do |stripe_customer_id|
-              customer_subscriptions =
-                ::Stripe::Subscription.list(customer: stripe_customer_id, status: "all")
-              all_subscriptions.concat(customer_subscriptions[:data])
-            end
+            customers =
+              ::Stripe::Customer.list(email: current_user.email, expand: ["data.subscriptions"])
+
+            subscriptions =
+              customers[:data].map { |sub_customer| sub_customer[:subscriptions][:data] }.flatten(1)
+
+            subscriptions = subscriptions.select { |sub| subscription_ids.include?(sub[:id]) }
 
-            subscriptions = all_subscriptions.select { |sub| subscription_ids.include?(sub[:id]) }
             subscriptions.map! do |subscription|
-              plan = prices.find { |p| p[:id] == subscription[:items][:data][0][:price][:id] }
+              plan = plans[:data].find { |p| p[:id] == subscription[:items][:data][0][:price][:id] }
               subscription.to_h.except!(:plan)
               subscription.to_h.merge(plan: plan, product: plan[:product].to_h.slice(:id, :name))
             end

app/models/discourse_subscriptions/customer.rb

@@ -13,20 +13,3 @@ module DiscourseSubscriptions
     end
   end
 end
-
-# == Schema Information
-#
-# Table name: discourse_subscriptions_customers
-#
-#  id          :bigint           not null, primary key
-#  customer_id :string           not null
-#  product_id  :string
-#  user_id     :bigint
-#  created_at  :datetime         not null
-#  updated_at  :datetime         not null
-#
-# Indexes
-#
-#  index_discourse_subscriptions_customers_on_customer_id  (customer_id)
-#  index_discourse_subscriptions_customers_on_user_id      (user_id)
-#

app/models/discourse_subscriptions/product.rb

@@ -4,17 +4,3 @@ module DiscourseSubscriptions
   class Product < ActiveRecord::Base
   end
 end
-
-# == Schema Information
-#
-# Table name: discourse_subscriptions_products
-#
-#  id          :bigint           not null, primary key
-#  external_id :string           not null
-#  created_at  :datetime         not null
-#  updated_at  :datetime         not null
-#
-# Indexes
-#
-#  index_discourse_subscriptions_products_on_external_id  (external_id)
-#

app/models/discourse_subscriptions/subscription.rb

@@ -5,20 +5,3 @@ module DiscourseSubscriptions
     belongs_to :customer
   end
 end
-
-# == Schema Information
-#
-# Table name: discourse_subscriptions_subscriptions
-#
-#  id          :bigint           not null, primary key
-#  customer_id :bigint           not null
-#  external_id :string           not null
-#  created_at  :datetime         not null
-#  updated_at  :datetime         not null
-#  status      :string
-#
-# Indexes
-#
-#  index_discourse_subscriptions_subscriptions_on_customer_id  (customer_id)
-#  index_discourse_subscriptions_subscriptions_on_external_id  (external_id)
-#

app/serializers/discourse_subscriptions/payment_serializer.rb

@@ -53,14 +53,6 @@ module DiscourseSubscriptions
         "S$"
       when "zar"
         "R"
-      when "chf"
-        "CHF"
-      when "pln"
-        "zł"
-      when "czk"
-        "Kč"
-      when "sek"
-        "kr"
       else
         "$"
       end

app/services/discourse_subscriptions/campaign.rb

@@ -91,7 +91,7 @@ module DiscourseSubscriptions
         params = {
           full_name: I18n.t("js.discourse_subscriptions.campaign.supporters"),
           title: I18n.t("js.discourse_subscriptions.campaign.supporter"),
-          flair_icon: "circle-dollar-to-slot",
+          flair_icon: "donate",
         }
 
         group.update(params)
@@ -154,30 +154,26 @@ module DiscourseSubscriptions
           all_invoices =
             ::Stripe::Invoice.list(limit: 100, starting_after: current_set[:last_record])
 
-          if all_invoices[:data].present?
-            current_set[:last_record] = all_invoices[:data].last[:id]
-            current_set[:has_more] = all_invoices[:has_more]
+          current_set[:last_record] = all_invoices[:data].last[:id] if all_invoices[:data].present?
+          current_set[:has_more] = all_invoices[:has_more]
 
-            all_invoices[:data].each do |invoice|
-              customer_id = invoice[:customer]
-              next if invoice[:paid] != true
-              line_item = invoice[:lines][:data][0] if invoice[:lines] && invoice[:lines][:data] # Discourse only makes single-line item charges
-              # check if non-subscription and that the plan is active
-              if line_item && line_item[:plan] == nil && line_item[:price] &&
-                   line_item[:price][:recurring] == nil && line_item[:price][:active] == true
-                product_id = line_item[:price][:product]
-                if product_ids.include? product_id
-                  line_data = {
-                    customer_id: customer_id,
-                    product_id: product_id,
-                    price: line_item[:price][:unit_amount],
-                  }
-                  one_time_payments << line_data
-                end
+          all_invoices[:data].each do |invoice|
+            customer_id = invoice[:customer]
+            next if invoice[:paid] != true
+            line_item = invoice[:lines][:data][0] if invoice[:lines] && invoice[:lines][:data] # Discourse only makes single-line item charges
+            # check if non-subscription and that the plan is active
+            if line_item[:plan] == nil && line_item[:price] &&
+                 line_item[:price][:recurring] == nil && line_item[:price][:active] == true
+              product_id = line_item[:price][:product]
+              if product_ids.include? product_id
+                line_data = {
+                  customer_id: customer_id,
+                  product_id: product_id,
+                  price: line_item[:price][:unit_amount],
+                }
+                one_time_payments << line_data
               end
             end
-          else
-            current_set[:has_more] = false
           end
         end
       end

assets/javascripts/discourse/components/campaign-banner.hbs

@@ -0,0 +1,173 @@
+{{#if shouldShow}}
+  <div
+    class="campaign-banner"
+    style={{html-safe (concat "box-shadow: 5px 5px #" dropShadowColor)}}
+  >
+    <DButton @icon="times" @action={{this.dismissBanner}} class="close" />
+
+    <div class="campaign-banner-info" style={{html-safe this.bannerInfoStyle}}>
+      {{#if isGoalMet}}
+        <h2 class="campaign-banner-info-header">
+          {{i18n "discourse_subscriptions.campaign.success_title"}}
+        </h2>
+
+        <p class="campaign-banner-info-description">
+          {{i18n "discourse_subscriptions.campaign.success_body"}}
+        </p>
+      {{else}}
+        <h2 class="campaign-banner-info-header">
+          {{i18n "discourse_subscriptions.campaign.title"}}
+        </h2>
+
+        <p class="campaign-banner-info-description">
+          {{i18n "discourse_subscriptions.campaign.body"}}
+        </p>
+
+        {{#if product}}
+          <LinkTo
+            @route="subscribe.show"
+            @model={{product}}
+            @disabled={{product.subscribed}}
+            class="btn btn-primary campaign-banner-info-button"
+          >
+            {{d-icon "far-heart"}}
+            {{d-icon "heart" class="hover-heart"}}
+            {{i18n "discourse_subscriptions.campaign.button"}}
+          </LinkTo>
+        {{else}}
+          <LinkTo
+            @route="subscribe"
+            class="btn btn-primary campaign-banner-info-button"
+          >
+            {{d-icon "far-heart"}}
+            {{d-icon "heart" class="hover-heart"}}
+            {{i18n "discourse_subscriptions.campaign.button"}}
+          </LinkTo>
+        {{/if}}
+      {{/if}}
+    </div>
+
+    <div class="campaign-banner-progress">
+      {{#if isGoalMet}}
+        <div class="fireworks">
+          <div class="before"></div>
+          <div class="after"></div>
+        </div>
+
+        <div class="campaign-banner-progress-success"></div>
+
+        {{#if subscriberGoal}}
+          <p class="campaign-banner-progress-description">
+            {{html-safe
+              (i18n
+                "discourse_subscriptions.campaign.goal_comparison"
+                current=subscribers
+                goal=goalTarget
+              )
+            }}
+            {{i18n "discourse_subscriptions.campaign.subscribers"}}
+          </p>
+        {{else}}
+          <p class="campaign-banner-progress-description">
+            {{html-safe
+              (i18n
+                "discourse_subscriptions.campaign.goal_comparison"
+                current=(format-currency currency amountRaised)
+                goal=(format-currency currency goalTarget)
+              )
+            }}
+            {{i18n "discourse_subscriptions.campaign.raised"}}
+          </p>
+
+          {{#if showContributors}}
+            <ConditionalLoadingSpinner @condition={{loading}} @size="small">
+              <div class="campaign-banner-progress-users">
+                <p class="campaign-banner-progress-users-title">
+                  <strong>
+                    {{i18n
+                      "discourse_subscriptions.campaign.recent_contributors"
+                    }}
+                  </strong>
+                </p>
+
+                <div class="campaign-banner-progress-users-avatars">
+                  {{#each contributors as |contributor|}}
+                    {{avatar
+                      contributor
+                      avatarTemplatePath="avatar_template"
+                      usernamePath="username"
+                      namePath="name"
+                      imageSize="small"
+                    }}
+                  {{/each}}
+                </div>
+              </div>
+            </ConditionalLoadingSpinner>
+          {{/if}}
+        {{/if}}
+      {{else}}
+        {{#if subscriberGoal}}
+          <progress
+            class="campaign-banner-progress-bar"
+            value={{subscribers}}
+            max={{siteSettings.discourse_subscriptions_campaign_goal}}
+          ></progress>
+
+          <p class="campaign-banner-progress-description">
+            {{html-safe
+              (i18n
+                "discourse_subscriptions.campaign.goal_comparison"
+                current=subscribers
+                goal=goalTarget
+              )
+            }}
+            {{i18n "discourse_subscriptions.campaign.subscribers"}}
+          </p>
+        {{else}}
+          <progress
+            class="campaign-banner-progress-bar"
+            value={{amountRaised}}
+            max={{siteSettings.discourse_subscriptions_campaign_goal}}
+          ></progress>
+
+          <p class="campaign-banner-progress-description">
+            {{html-safe
+              (i18n
+                "discourse_subscriptions.campaign.goal_comparison"
+                current=(format-currency currency amountRaised)
+                goal=(format-currency currency goalTarget)
+              )
+            }}
+            {{i18n "discourse_subscriptions.campaign.raised"}}
+          </p>
+        {{/if}}
+
+        {{#if showContributors}}
+          <ConditionalLoadingSpinner @condition={{loading}} @size="small">
+            <div class="campaign-banner-progress-users">
+              <p class="campaign-banner-progress-users-title">
+                <strong>
+                  {{i18n
+                    "discourse_subscriptions.campaign.recent_contributors"
+                  }}
+                </strong>
+              </p>
+
+              <div class="campaign-banner-progress-users-avatars">
+                {{#each contributors as |contributor|}}
+                  {{avatar
+                    contributor
+                    avatarTemplatePath="avatar_template"
+                    usernamePath="username"
+                    namePath="name"
+                    imageSize="small"
+                  }}
+                {{/each}}
+              </div>
+            </div>
+          </ConditionalLoadingSpinner>
+        {{/if}}
+      {{/if}}
+    </div>
+  </div>
+{{/if}}

assets/javascripts/discourse/components/campaign-banner.js

@@ -0,0 +1,187 @@
+import Component from "@ember/component";
+import { action } from "@ember/object";
+import { equal } from "@ember/object/computed";
+import { later } from "@ember/runloop";
+import { inject as service } from "@ember/service";
+import { ajax } from "discourse/lib/ajax";
+import { setting } from "discourse/lib/computed";
+import discourseComputed, { observes } from "discourse-common/utils/decorators";
+
+const SIDEBAR_BODY_CLASS = "subscription-campaign-sidebar";
+
+export default Component.extend({
+  router: service(),
+  dismissed: false,
+  loading: false,
+  dropShadowColor: setting(
+    "discourse_subscriptions_campaign_banner_shadow_color"
+  ),
+  backgroundImageUrl: setting(
+    "discourse_subscriptions_campaign_banner_bg_image"
+  ),
+  isSidebar: equal(
+    "siteSettings.discourse_subscriptions_campaign_banner_location",
+    "Sidebar"
+  ),
+  subscribers: setting("discourse_subscriptions_campaign_subscribers"),
+  subscriberGoal: equal(
+    "siteSettings.discourse_subscriptions_campaign_type",
+    "Subscribers"
+  ),
+  currency: setting("discourse_subscriptions_currency"),
+  amountRaised: setting("discourse_subscriptions_campaign_amount_raised"),
+  goalTarget: setting("discourse_subscriptions_campaign_goal"),
+  product: setting("discourse_subscriptions_campaign_product"),
+  showContributors: setting(
+    "discourse_subscriptions_campaign_show_contributors"
+  ),
+  classNameBindings: ["isGoalMet:goal-met"],
+
+  init() {
+    this._super(...arguments);
+
+    this.set("contributors", []);
+
+    // add background-image url to stylesheet
+    if (this.backgroundImageUrl) {
+      const backgroundUrl = `url(${this.backgroundImageUrl}`.replace(/\\/g, "");
+      if (
+        document.documentElement.style.getPropertyValue(
+          "--campaign-background-image"
+        ) !== backgroundUrl
+      ) {
+        document.documentElement.style.setProperty(
+          "--campaign-background-image",
+          backgroundUrl
+        );
+      }
+    }
+
+    if (this.currentUser && this.showContributors) {
+      return ajax("/subscriptions/contributors", { method: "get" }).then(
+        (result) => {
+          this.setProperties({
+            contributors: result,
+            loading: false,
+          });
+        }
+      );
+    }
+  },
+
+  didInsertElement() {
+    this._super(...arguments);
+    if (this.isSidebar && this.shouldShow && !this.site.mobileView) {
+      document.body.classList.add(SIDEBAR_BODY_CLASS);
+    } else {
+      document.body.classList.remove(SIDEBAR_BODY_CLASS);
+    }
+
+    // makes sure to only play animation once, & not repeat on reload
+    if (this.isGoalMet) {
+      const successAnimationKey = this.keyValueStore.get(
+        "campaign_success_animation"
+      );
+
+      if (!successAnimationKey) {
+        later(() => {
+          this.keyValueStore.set({
+            key: "campaign_success_animation",
+            value: Date.now(),
+          });
+          document.body.classList.add("success-animation-off");
+        }, 7000);
+      } else {
+        document.body.classList.add("success-animation-off");
+      }
+    }
+  },
+
+  willDestroyElement() {
+    this._super(...arguments);
+    document.body.classList.remove(SIDEBAR_BODY_CLASS);
+  },
+
+  @discourseComputed("backgroundImageUrl")
+  bannerInfoStyle(backgroundImageUrl) {
+    if (!backgroundImageUrl) {
+      return "";
+    }
+
+    return `background-image: linear-gradient(
+        0deg,
+        rgba(var(--secondary-rgb), 0.75) 0%,
+        rgba(var(--secondary-rgb), 0.75) 100%),
+        var(--campaign-background-image);
+      background-size: cover;
+      background-repeat: no-repeat;`;
+  },
+
+  @discourseComputed(
+    "router.currentRouteName",
+    "currentUser",
+    "siteSettings.discourse_subscriptions_campaign_enabled",
+    "visible"
+  )
+  shouldShow(currentRoute, currentUser, enabled, visible) {
+    // do not show on admin or subscriptions pages
+    const showOnRoute =
+      currentRoute !== "discovery.s" &&
+      !currentRoute.split(".")[0].includes("admin") &&
+      currentRoute.split(".")[0] !== "subscribe";
+
+    if (!this.site.show_campaign_banner) {
+      return false;
+    }
+
+    // make sure not to render above main container when inside a topic
+    if (
+      this.connectorName === "above-main-container" &&
+      currentRoute.includes("topic")
+    ) {
+      return false;
+    }
+
+    return showOnRoute && currentUser && enabled && visible;
+  },
+
+  @observes("dismissed")
+  _updateBodyClasses() {
+    if (this.dismissed) {
+      document.body.classList.remove(SIDEBAR_BODY_CLASS);
+    }
+  },
+
+  @discourseComputed("dismissed")
+  visible(dismissed) {
+    const dismissedBannerKey = this.keyValueStore.get(
+      "dismissed_campaign_banner"
+    );
+    const threeMonths = 2628000000 * 3;
+
+    const bannerDismissedTime = new Date(dismissedBannerKey);
+    const now = Date.now();
+
+    return (
+      (!dismissedBannerKey || now - bannerDismissedTime > threeMonths) &&
+      !dismissed
+    );
+  },
+
+  @discourseComputed
+  isGoalMet() {
+    const currentVolume = this.subscriberGoal
+      ? this.subscribers
+      : this.amountRaised;
+    return currentVolume >= this.goalTarget;
+  },
+
+  @action
+  dismissBanner() {
+    this.set("dismissed", true);
+    this.keyValueStore.set({
+      key: "dismissed_campaign_banner",
+      value: Date.now(),
+    });
+  },
+});

assets/javascripts/discourse/components/create-coupon-form.gjs

@@ -1,92 +0,0 @@
-import Component, { Input } from "@ember/component";
-import { fn } from "@ember/helper";
-import { action } from "@ember/object";
-import DButton from "discourse/components/d-button";
-import discourseComputed from "discourse/lib/decorators";
-import { i18n } from "discourse-i18n";
-import ComboBox from "select-kit/components/combo-box";
-
-export default class CreateCouponForm extends Component {
-  discountType = "amount";
-  discount = null;
-  promoCode = null;
-  active = false;
-
-  @discourseComputed
-  discountTypes() {
-    return [
-      { id: "amount", name: "Amount" },
-      { id: "percent", name: "Percent" },
-    ];
-  }
-
-  @action
-  createNewCoupon() {
-    const createParams = {
-      promo: this.promoCode,
-      discount_type: this.discountType,
-      discount: this.discount,
-      active: this.active,
-    };
-
-    this.create(createParams);
-  }
-
-  @action
-  cancelCreate() {
-    this.cancel();
-  }
-
-  <template>
-    <div class="create-coupon-form">
-      <form class="form-horizontal">
-        <p>
-          <label for="promo_code">
-            {{i18n "discourse_subscriptions.admin.coupons.promo_code"}}
-          </label>
-          <Input @type="text" name="promo_code" @value={{this.promoCode}} />
-        </p>
-
-        <p>
-          <label for="amount">
-            {{i18n "discourse_subscriptions.admin.coupons.discount"}}
-          </label>
-          <ComboBox
-            @content={{this.discountTypes}}
-            @value={{this.discountType}}
-            @onChange={{fn (mut this.discountType)}}
-          />
-          <Input
-            class="discount-amount"
-            @type="text"
-            name="amount"
-            @value={{this.discount}}
-          />
-        </p>
-
-        <p>
-          <label for="active">
-            {{i18n "discourse_subscriptions.admin.coupons.active"}}
-          </label>
-          <Input @type="checkbox" name="active" @checked={{this.active}} />
-        </p>
-      </form>
-
-      <DButton
-        @action={{this.createNewCoupon}}
-        @label="discourse_subscriptions.admin.coupons.create"
-        @title="discourse_subscriptions.admin.coupons.create"
-        @icon="plus"
-        class="btn-primary btn btn-icon"
-      />
-
-      <DButton
-        @action={{this.cancelCreate}}
-        label="cancel"
-        @title="cancel"
-        @icon="xmark"
-        class="btn btn-icon"
-      />
-    </div>
-  </template>
-}

assets/javascripts/discourse/components/create-coupon-form.hbs

@@ -0,0 +1,50 @@
+<div class="create-coupon-form">
+  <form class="form-horizontal">
+    <p>
+      <label for="promo_code">
+        {{i18n "discourse_subscriptions.admin.coupons.promo_code"}}
+      </label>
+      <Input @type="text" name="promo_code" @value={{promoCode}} />
+    </p>
+
+    <p>
+      <label for="amount">
+        {{i18n "discourse_subscriptions.admin.coupons.discount"}}
+      </label>
+      <ComboBox
+        @content={{discountTypes}}
+        @value={{discountType}}
+        @onChange={{action (mut discountType)}}
+      />
+      <Input
+        class="discount-amount"
+        @type="text"
+        name="amount"
+        @value={{discount}}
+      />
+    </p>
+
+    <p>
+      <label for="active">
+        {{i18n "discourse_subscriptions.admin.coupons.active"}}
+      </label>
+      <Input @type="checkbox" name="active" @checked={{active}} />
+    </p>
+  </form>
+
+  <DButton
+    @action={{action "createNewCoupon"}}
+    @label="discourse_subscriptions.admin.coupons.create"
+    @title="discourse_subscriptions.admin.coupons.create"
+    @icon="plus"
+    class="btn-primary btn btn-icon"
+  />
+
+  <DButton
+    @action={{action "cancelCreate"}}
+    label="cancel"
+    @title="cancel"
+    @icon="times"
+    class="btn btn-icon"
+  />
+</div>

assets/javascripts/discourse/components/create-coupon-form.js

@@ -0,0 +1,32 @@
+import Component from "@ember/component";
+import discourseComputed from "discourse-common/utils/decorators";
+
+export default Component.extend({
+  @discourseComputed
+  discountTypes() {
+    return [
+      { id: "amount", name: "Amount" },
+      { id: "percent", name: "Percent" },
+    ];
+  },
+  discountType: "amount",
+  discount: null,
+  promoCode: null,
+  active: false,
+
+  actions: {
+    createNewCoupon() {
+      const createParams = {
+        promo: this.promoCode,
+        discount_type: this.discountType,
+        discount: this.discount,
+        active: this.active,
+      };
+
+      this.create(createParams);
+    },
+    cancelCreate() {
+      this.cancel();
+    },
+  },
+});

assets/javascripts/discourse/components/login-required.gjs

@@ -1,16 +0,0 @@
-import DButton from "discourse/components/d-button";
-import routeAction from "discourse/helpers/route-action";
-import { i18n } from "discourse-i18n";
-
-const LoginRequired = <template>
-  <h3>{{i18n "discourse_subscriptions.subscribe.unauthenticated"}}</h3>
-
-  <DButton
-    @label="log_in"
-    @action={{routeAction "showLogin"}}
-    @icon="user"
-    class="btn btn-primary login-required subscriptions"
-  />
-</template>;
-
-export default LoginRequired;

assets/javascripts/discourse/components/login-required.hbs

@@ -0,0 +1,8 @@
+<h3>{{i18n "discourse_subscriptions.subscribe.unauthenticated"}}</h3>
+
+<DButton
+  @label="log_in"
+  @action={{route-action "showLogin"}}
+  @icon="user"
+  class="btn btn-primary login-required subscriptions"
+/>

assets/javascripts/discourse/components/modal/admin-cancel-subscription.gjs

@@ -4,7 +4,7 @@ import { Input } from "@ember/component";
 import { fn, hash } from "@ember/helper";
 import DButton from "discourse/components/d-button";
 import DModal from "discourse/components/d-modal";
-import { i18n } from "discourse-i18n";
+import i18n from "discourse-common/helpers/i18n";
 
 export default class AdminCancelSubscription extends Component {
   @tracked refund;
@@ -25,13 +25,9 @@ export default class AdminCancelSubscription extends Component {
           @label="yes_value"
           @action={{fn
             @model.cancelSubscription
-            (hash
-              [email protected]
-              refund=this.refund
-              closeModal=@closeModal
-            )
+            (hash [email protected] refund=this.refund)
           }}
-          @icon="xmark"
+          @icon="times"
           @isLoading={{@model.subscription.loading}}
           class="btn-danger"
         />

assets/javascripts/discourse/components/payment-options.gjs

@@ -1,42 +0,0 @@
-import Component from "@ember/component";
-import { action } from "@ember/object";
-import discourseComputed from "discourse/lib/decorators";
-import { i18n } from "discourse-i18n";
-import PaymentPlan from "./payment-plan";
-
-export default class PaymentOptions extends Component {
-  @discourseComputed("plans")
-  orderedPlans(plans) {
-    if (plans) {
-      return plans.sort((a, b) => (a.unit_amount > b.unit_amount ? 1 : -1));
-    }
-  }
-
-  didInsertElement() {
-    super.didInsertElement(...arguments);
-    if (this.plans && this.plans.length === 1) {
-      this.set("selectedPlan", this.plans[0].id);
-    }
-  }
-
-  @action
-  clickPlan(plan) {
-    this.set("selectedPlan", plan.id);
-  }
-
-  <template>
-    <p>
-      {{i18n "discourse_subscriptions.plans.select"}}
-    </p>
-
-    <div class="subscribe-buttons">
-      {{#each this.orderedPlans as |plan|}}
-        <PaymentPlan
-          @plan={{plan}}
-          @selectedPlan={{this.selectedPlan}}
-          @clickPlan={{this.clickPlan}}
-        />
-      {{/each}}
-    </div>
-  </template>
-}

assets/javascripts/discourse/components/payment-options.hbs

@@ -0,0 +1,13 @@
+<p>
+  {{i18n "discourse_subscriptions.plans.select"}}
+</p>
+
+<div class="subscribe-buttons">
+  {{#each orderedPlans as |plan|}}
+    <PaymentPlan
+      @plan={{plan}}
+      @selectedPlan={{selectedPlan}}
+      @clickPlan={{action "clickPlan"}}
+    />
+  {{/each}}
+</div>

assets/javascripts/discourse/components/payment-options.js

@@ -0,0 +1,23 @@
+import Component from "@ember/component";
+import discourseComputed from "discourse-common/utils/decorators";
+
+export default Component.extend({
+  @discourseComputed("plans")
+  orderedPlans(plans) {
+    if (plans) {
+      return plans.sort((a, b) => (a.unit_amount > b.unit_amount ? 1 : -1));
+    }
+  },
+
+  didInsertElement() {
+    this._super(...arguments);
+    if (this.plans && this.plans.length === 1) {
+      this.set("selectedPlan", this.plans[0].id);
+    }
+  },
+  actions: {
+    clickPlan(plan) {
+      this.set("selectedPlan", plan.id);
+    },
+  },
+});

assets/javascripts/discourse/components/payment-plan.gjs

@@ -1,57 +0,0 @@
-import Component from "@ember/component";
-import { concat } from "@ember/helper";
-import { action } from "@ember/object";
-import { tagName } from "@ember-decorators/component";
-import DButton from "discourse/components/d-button";
-import concatClass from "discourse/helpers/concat-class";
-import discourseComputed from "discourse/lib/decorators";
-import { i18n } from "discourse-i18n";
-import formatCurrency from "../helpers/format-currency";
-
-const RECURRING = "recurring";
-
-@tagName("")
-export default class PaymentPlan extends Component {
-  @discourseComputed("selectedPlan")
-  selectedClass(planId) {
-    return planId === this.plan.id ? "btn-primary" : "";
-  }
-
-  @discourseComputed("plan.type")
-  recurringPlan(type) {
-    return type === RECURRING;
-  }
-
-  @action
-  planClick() {
-    this.clickPlan(this.plan);
-    return false;
-  }
-
-  <template>
-    <DButton
-      @action={{this.planClick}}
-      class={{concatClass
-        "btn-discourse-subscriptions-subscribe"
-        this.selectedClass
-      }}
-    >
-      <span class="interval">
-        {{#if this.recurringPlan}}
-          {{i18n
-            (concat
-              "discourse_subscriptions.plans.interval.adverb."
-              this.plan.recurring.interval
-            )
-          }}
-        {{else}}
-          {{i18n "discourse_subscriptions.one_time_payment"}}
-        {{/if}}
-      </span>
-
-      <span class="amount">
-        {{formatCurrency this.plan.currency this.plan.amountDollars}}
-      </span>
-    </DButton>
-  </template>
-}

assets/javascripts/discourse/components/payment-plan.hbs

@@ -0,0 +1,21 @@
+<DButton
+  @action={{action "planClick"}}
+  class={{concat-class "btn-discourse-subscriptions-subscribe" selectedClass}}
+>
+  <span class="interval">
+    {{#if this.recurringPlan}}
+      {{i18n
+        (concat
+          "discourse_subscriptions.plans.interval.adverb."
+          this.plan.recurring.interval
+        )
+      }}
+    {{else}}
+      {{i18n "discourse_subscriptions.one_time_payment"}}
+    {{/if}}
+  </span>
+
+  <span class="amount">
+    {{format-currency this.plan.currency this.plan.amountDollars}}
+  </span>
+</DButton>