add link to T&Cs

.discourse-compatibility

@@ -1,7 +0,0 @@
-< 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

.github/workflows/discourse-plugin.yml

@@ -1,11 +0,0 @@
-name: Discourse Plugin
-
-on:
-  push:
-    branches:
-      - main
-  pull_request:
-
-jobs:
-  ci:
-    uses: discourse/.github/.github/workflows/discourse-plugin.yml@v1

.gitignore

@@ -1,2 +1,4 @@
-node_modules
-/gems
+.DS_Store
+gems
+log
+.byebug_history

.npmrc

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

.prettierrc.cjs

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

.rubocop.yml

@@ -1,8 +0,0 @@
-inherit_gem:
-  rubocop-discourse: stree-compat.yml
-AllCops:
-  Exclude:
-    - "gems/**/*"
-    - "vendor/bundle/**/*"
-Discourse/NoAddReferenceOrAliasesActiveRecordMigration:
-  Enabled: false

.ruby-version

@@ -0,0 +1 @@
+2.3.3

.streerc

@@ -1,2 +0,0 @@
---print-width=100
---plugins=plugin/trailing_comma

.template-lintrc.cjs

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

.travis.yml

@@ -0,0 +1,42 @@
+language: ruby
+
+env:
+  global:
+    - DISCOURSE_HOSTNAME=www.example.com
+
+dist: trusty
+
+cache: bundler --path $TRAVIS_BUILD_DIR/discourse/vendor
+
+addons:
+  postgresql: 9.5
+  apt:
+    packages:
+    - gifsicle
+    - jpegoptim
+    - optipng
+    - jhead
+
+rvm:
+  - 2.3.3
+
+services:
+  - redis-server
+
+before_install:
+  - git clone https://github.com/discourse/discourse.git discourse
+  - cd discourse
+
+install:
+  - touch config/stripe.yml
+  - git clone $TRAVIS_BUILD_DIR plugins/discourse-donations --depth 50 --branch $TRAVIS_BRANCH
+
+before_script:
+  - gem install bundler
+  - bundle install
+  - bundle exec rake db:create db:migrate
+
+script:
+  - "bundle exec rake plugin:spec[discourse-donations]"
+  - "MODULE='Acceptance: Discourse Donations' bundle exec rake qunit:test[20000]"
+  - "MODULE='component:stripe-card' bundle exec rake qunit:test[20000]"

Gemfile

@@ -1,9 +0,0 @@
-# frozen_string_literal: true
-
-source "https://rubygems.org"
-
-group :development do
-  gem "translations-manager", git: "https://github.com/discourse/translations-manager.git"
-  gem "rubocop-discourse"
-  gem "syntax_tree"
-end

Gemfile.lock

@@ -1,109 +0,0 @@
-GIT
-  remote: https://github.com/discourse/translations-manager.git
-  revision: a8b225f7fabd3250ba88a4a2eff797693df51192
-  specs:
-    translations-manager (0.6)
-
-GEM
-  remote: https://rubygems.org/
-  specs:
-    activesupport (8.0.2)
-      base64
-      benchmark (>= 0.3)
-      bigdecimal
-      concurrent-ruby (~> 1.0, >= 1.3.1)
-      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)
-      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)
-      ast (~> 2.4.1)
-      racc
-    prettier_print (1.2.1)
-    prism (1.4.0)
-    racc (1.8.1)
-    rack (3.1.16)
-    rainbow (3.1.1)
-    regexp_parser (2.10.0)
-    rubocop (1.75.8)
-      json (~> 2.3)
-      language_server-protocol (~> 3.17.0.2)
-      lint_roller (~> 1.1.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)
-      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)
-      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)
-    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)
-
-PLATFORMS
-  ruby
-
-DEPENDENCIES
-  rubocop-discourse
-  syntax_tree
-  translations-manager!
-
-BUNDLED WITH
-   2.6.9

README.md

@@ -1,8 +1,60 @@
-# Discourse Subscriptions Plugin
+# Discourse Donations
 
-> [!IMPORTANT]
-> This plugin has now been bundled into Discourse core. See: https://meta.discourse.org/t/bundling-more-popular-plugins-with-discourse-core/373574
+[![Build Status](https://travis-ci.org/choiceaustralia/discourse-donations.svg?branch=master)](https://travis-ci.org/choiceaustralia/discourse-donations)
 
-Discourse Subscriptions allows site owners to sell recurring and one-time purchase subscriptions that grant access to a group on a Discourse instance.
+Accept donations in Discourse! Integrates with [Stripe](https://stripe.com).
 
-For more information, please see: https://meta.discourse.org/t/discourse-subscriptions-plugin/140818
+## Installation
+
+* Be sure your site is enforcing https.
+* Follow the install instructions here: https://meta.discourse.org/t/install-a-plugin/19157
+* Add your Stripe public and private keys in settings and set the currency to your local value.
+* Add the following script to your page header in a custom theme component: `<script src="https://js.stripe.com/v3/"></script>`
+* Enable the plugin and wait for people to donate money.
+
+## Creating new user accounts
+
+**This is an experimental feature.** A user can create a new account if they makes a successful donation. Enable this in settings. When a user is not logged in, they will be asked to enter details for a new user account. This feature doesn't support mandatory custom user fields yet.
+
+## Test Suite
+
+* To run the rails specs, install the plugin and run `bundle exec rake plugin:spec[discourse-donations]` in the discourse root directory.
+* To run qunit tests: `MODULE='Acceptance: Discourse Donations' bundle exec rake qunit:test[20000]`.
+* To run Component tests: `MODULE='component:stripe-card' bundle exec rake qunit:test[20000]`.
+
+**Note:**
+
+* If you're using a zsh shell, then you probably get this error: `zsh: no matches found ...` and you'll need to escape the square brackets with backslashes.
+
+## TODO
+
+* Test card fails
+* Handle custom fields
+* Acceptance test in RSpec not qunit.
+
+## Tested Credit Card Numbers
+
+These numbers can be used in test mode to simulate a transaction. For more information see the [Stripe docs](https://stripe.com/docs/testing).
+
+Card numbers in **bold** have beed tested.
+
+* **4000 0000 0000 0077**	Charge succeeds and funds will be added directly to your available balance (bypassing your pending balance).
+* **4000 0000 0000 0093**	Charge succeeds and domestic pricing is used (other test cards use international pricing). This card is only significant in countries with split pricing.
+* **4000 0000 0000 0010**	The address_line1_check and address_zip_check verifications fail. If your account is blocking payments that fail postal code validation, the charge is declined.
+* **4000 0000 0000 0028**	Charge succeeds but the address_line1_check verification fails.
+* **4000 0000 0000 0036**	The address_zip_check verification fails. If your account is blocking payments that fail postal code validation, the charge is declined.
+* **4000 0000 0000 0044**	Charge succeeds but the address_zip_check and address_line1_check verifications are both unavailable.
+* **4000 0000 0000 0101** If a CVC number is provided, the cvc_check fails. If your account is blocking payments that fail CVC code validation, the charge is declined.
+* **4000 0000 0000 0341**	Attaching this card to a Customer object succeeds, but attempts to charge the customer fail.
+* **4000 0000 0000 9235**	Charge succeeds with a risk_level of elevated and placed into review.
+* **4000 0000 0000 0002**	Charge is declined with a card_declined code.
+* **4100 0000 0000 0019**	Charge is declined with a card_declined code and a fraudulent reason.
+* **4000 0000 0000 0127**	Charge is declined with an incorrect_cvc code.
+* **4000 0000 0000 0069**	Charge is declined with an expired_card code.
+* **4000 0000 0000 0119**	Charge is declined with a processing_error code.
+* 4242 4242 4242 4241	Charge is declined with an incorrect_number code as the card number fails the Luhn check.
+
+## Warranty
+
+This software comes with no warranty of any kind.
+>>>>>>> master

app/controllers/concerns/group.rb

@@ -1,11 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module Group
-    extend ActiveSupport::Concern
-
-    def plan_group(plan)
-      ::Group.find_by_name(plan[:metadata][:group_name])
-    end
-  end
-end

app/controllers/concerns/stripe.rb

@@ -1,16 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module Stripe
-    extend ActiveSupport::Concern
-
-    def set_api_key
-      ::Stripe.api_key = SiteSetting.discourse_subscriptions_secret_key
-    end
-
-    def is_stripe_configured?
-      SiteSetting.discourse_subscriptions_public_key.present? &&
-        SiteSetting.discourse_subscriptions_secret_key.present?
-    end
-  end
-end

app/controllers/discourse_donations/charges_controller.rb

@@ -0,0 +1,99 @@
+require_dependency 'discourse'
+
+module DiscourseDonations
+  class ChargesController < ActionController::Base
+    include CurrentUser
+
+    skip_before_filter :verify_authenticity_token, only: [:create]
+
+    def create
+      params.permit(:name, :username, :email, :password, :stripeToken, :amount, :plan, :create_account)
+
+      output = { 'messages' => [], 'rewards' => [] }
+
+      if create_account
+        if !email.present? || !params[:username].present?
+          output['messages'] << I18n.t('login.missing_user_field')
+        end
+        if params[:password] && params[:password].length > User.max_password_length
+          output['messages'] << I18n.t('login.password_too_long')
+        end
+        if params[:username] && ::User.reserved_username?(params[:username])
+          output['messages'] << I18n.t('login.reserved_username')
+        end
+      end
+
+      if output['messages'].present?
+        render(:json => output.merge(success: false)) and return
+      end
+
+      payment = DiscourseDonations::Stripe.new(secret_key, stripe_options)
+
+      begin
+        if params['amount'].present?
+          charge = payment.subscribe(email, params.merge(plan: params[:amount]))
+        else
+          charge = payment.subscribe(email, params)
+        end
+      rescue ::Stripe::CardError => e
+        err = e.json_body[:error]
+
+        output['messages'] << "There was an error (#{err[:type]})."
+        #output['messages'] << "Error code: #{err[:code]}" if err[:code]
+        #output['messages'] << "Decline code: #{err[:decline_code]}" if err[:decline_code]
+        output['messages'] << "Message: #{err[:message]}" if err[:message]
+
+        render(:json => output) and return
+      end
+
+      if charge['paid'] == true || charge['status'] == 'active'
+        output['success'] = true
+
+        output['messages'] << I18n.t('donations.payment.success')
+
+        output['rewards'] << { type: :group, name: group_name } if group_name
+        output['rewards'] << { type: :badge, name: badge_name } if badge_name
+
+        if create_account && email.present?
+          args = params.slice(:email, :username, :password, :name).merge(rewards: output['rewards'])
+          Jobs.enqueue(:donation_user, args)
+        end
+      end
+
+      render :json => output
+    end
+
+    private
+
+    def create_account
+      params[:create_account] == 'true' && SiteSetting.discourse_donations_enable_create_accounts
+    end
+
+    def reward?(payment)
+      payment.present? && payment.successful?
+    end
+
+    def group_name
+      SiteSetting.discourse_donations_reward_group_name
+    end
+
+    def badge_name
+      SiteSetting.discourse_donations_reward_badge_name
+    end
+
+    def secret_key
+      SiteSetting.discourse_donations_secret_key
+    end
+
+    def stripe_options
+      {
+        description: SiteSetting.discourse_donations_description,
+        currency: SiteSetting.discourse_donations_currency
+      }
+    end
+
+    def email
+      params[:email] || current_user.try(:email)
+    end
+  end
+end

app/controllers/discourse_donations/payments_controller.rb

@@ -0,0 +1,11 @@
+module DiscourseDonations
+  class PaymentsController < ApplicationController
+    def index
+      render json: {}
+    end
+
+    def show
+      render json: {}
+    end
+  end
+end

app/controllers/discourse_subscriptions/admin/coupons_controller.rb

@@ -1,71 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module Admin
-    class CouponsController < ::Admin::AdminController
-      include DiscourseSubscriptions::Stripe
-      include DiscourseSubscriptions::Group
-
-      requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-      before_action :set_api_key
-
-      def index
-        begin
-          promo_codes = ::Stripe::PromotionCode.list({ limit: 100 })[:data]
-          promo_codes = promo_codes.select { |code| code[:coupon][:valid] == true }
-          render_json_dump promo_codes
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def create
-        params.require(%i[promo discount_type discount active])
-        begin
-          coupon_params = { duration: "forever" }
-
-          case params[:discount_type]
-          when "amount"
-            coupon_params[:amount_off] = params[:discount].to_i * 100
-            coupon_params[:currency] = SiteSetting.discourse_subscriptions_currency
-          when "percent"
-            coupon_params[:percent_off] = params[:discount]
-          end
-
-          coupon = ::Stripe::Coupon.create(coupon_params)
-
-          promo_code =
-            ::Stripe::PromotionCode.create(
-              { coupon: coupon[:id], code: params[:promo] },
-            ) if coupon.present?
-
-          render_json_dump promo_code
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def update
-        params.require(%i[id active])
-        begin
-          promo_code = ::Stripe::PromotionCode.update(params[:id], { active: params[:active] })
-
-          render_json_dump promo_code
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def destroy
-        params.require(:coupon_id)
-        begin
-          coupon = ::Stripe::Coupon.delete(params[:coupon_id])
-          render_json_dump coupon
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-    end
-  end
-end

app/controllers/discourse_subscriptions/admin/plans_controller.rb

@@ -1,98 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module Admin
-    class PlansController < ::Admin::AdminController
-      include DiscourseSubscriptions::Stripe
-
-      requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-      before_action :set_api_key
-
-      def index
-        begin
-          plans = ::Stripe::Price.list(product_params)
-
-          render_json_dump plans.data
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def create
-        begin
-          price_object = {
-            nickname: params[:nickname],
-            unit_amount: params[:amount],
-            product: params[:product],
-            currency: params[:currency],
-            active: params[:active],
-            metadata: {
-              group_name: params[:metadata][:group_name],
-              trial_period_days: params[:trial_period_days],
-            },
-          }
-
-          price_object[:recurring] = { interval: params[:interval] } if params[:type] == "recurring"
-
-          plan = ::Stripe::Price.create(price_object)
-
-          render_json_dump plan
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def show
-        begin
-          plan = ::Stripe::Price.retrieve(params[:id])
-
-          if plan[:metadata] && plan[:metadata][:trial_period_days]
-            trial_days = plan[:metadata][:trial_period_days]
-          elsif plan[:recurring] && plan[:recurring][:trial_period_days]
-            trial_days = plan[:recurring][:trial_period_days]
-          end
-
-          interval = nil
-          interval = plan[:recurring][:interval] if plan[:recurring] && plan[:recurring][:interval]
-
-          serialized =
-            plan.to_h.merge(
-              trial_period_days: trial_days,
-              currency: plan[:currency].upcase,
-              interval: interval,
-            )
-
-          render_json_dump serialized
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def update
-        begin
-          plan =
-            ::Stripe::Price.update(
-              params[:id],
-              nickname: params[:nickname],
-              active: params[:active],
-              metadata: {
-                group_name: params[:metadata][:group_name],
-                trial_period_days: params[:trial_period_days],
-              },
-            )
-
-          render_json_dump plan
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      private
-
-      def product_params
-        { product: params[:product_id] } if params[:product_id]
-      end
-    end
-  end
-end

app/controllers/discourse_subscriptions/admin/products_controller.rb

@@ -1,95 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module Admin
-    class ProductsController < ::Admin::AdminController
-      include DiscourseSubscriptions::Stripe
-
-      requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-      before_action :set_api_key
-
-      def index
-        begin
-          product_ids = Product.all.pluck(:external_id)
-          products = []
-
-          if product_ids.present? && is_stripe_configured?
-            products = ::Stripe::Product.list({ ids: product_ids, limit: 100 })
-            products = products[:data]
-          elsif !is_stripe_configured?
-            products = nil
-          end
-
-          render_json_dump products
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def create
-        begin
-          create_params = product_params.merge!(type: "service")
-
-          create_params.except!(:statement_descriptor) if params[:statement_descriptor].blank?
-
-          product = ::Stripe::Product.create(create_params)
-
-          Product.create(external_id: product[:id])
-
-          render_json_dump product
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def show
-        begin
-          product = ::Stripe::Product.retrieve(params[:id])
-
-          render_json_dump product
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def update
-        begin
-          product = ::Stripe::Product.update(params[:id], product_params)
-
-          render_json_dump product
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def destroy
-        begin
-          product = ::Stripe::Product.delete(params[:id])
-
-          Product.delete_by(external_id: params[:id])
-
-          render_json_dump product
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      private
-
-      def product_params
-        params.permit!
-
-        {
-          name: params[:name],
-          active: params[:active],
-          statement_descriptor: params[:statement_descriptor],
-          metadata: {
-            description: params.dig(:metadata, :description),
-            repurchaseable: params.dig(:metadata, :repurchaseable),
-          },
-        }
-      end
-    end
-  end
-end

app/controllers/discourse_subscriptions/admin/subscriptions_controller.rb

@@ -1,103 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module Admin
-    class SubscriptionsController < ::Admin::AdminController
-      requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-      include DiscourseSubscriptions::Stripe
-      include DiscourseSubscriptions::Group
-      before_action :set_api_key
-
-      PAGE_LIMIT = 10
-
-      def index
-        begin
-          subscription_ids = Subscription.all.pluck(:external_id)
-          subscriptions = {
-            has_more: false,
-            data: [],
-            length: 0,
-            last_record: params[:last_record],
-          }
-
-          if subscription_ids.present? && is_stripe_configured?
-            while subscriptions[:length] < PAGE_LIMIT
-              current_set = get_subscriptions(subscriptions[:last_record])
-
-              until valid_subscriptions =
-                      find_valid_subscriptions(current_set[:data], subscription_ids)
-                current_set = get_subscriptions(current_set[:data].last)
-                break if current_set[:has_more] == false
-              end
-
-              subscriptions[:data] = subscriptions[:data].concat(valid_subscriptions.to_a)
-              subscriptions[:last_record] = current_set[:data].last[:id] if current_set[
-                :data
-              ].present?
-              subscriptions[:length] = subscriptions[:data].length
-              subscriptions[:has_more] = current_set[:has_more]
-              break if subscriptions[:has_more] == false
-            end
-          elsif !is_stripe_configured?
-            subscriptions = nil
-          end
-
-          render_json_dump subscriptions
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def destroy
-        params.require(:id)
-        begin
-          refund_subscription(params[:id]) if params[:refund]
-          subscription = ::Stripe::Subscription.cancel(params[:id])
-
-          customer =
-            Customer.find_by(
-              product_id: subscription[:plan][:product],
-              customer_id: subscription[:customer],
-            )
-
-          if customer
-            user = ::User.find(customer.user_id)
-            group = plan_group(subscription[:plan])
-            group.remove(user) if group
-          end
-
-          render_json_dump subscription
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      private
-
-      def get_subscriptions(start)
-        ::Stripe::Subscription.list(
-          expand: ["data.plan.product"],
-          limit: PAGE_LIMIT,
-          starting_after: start,
-          status: "all",
-        )
-      end
-
-      def find_valid_subscriptions(data, ids)
-        valid = data.select { |sub| ids.include?(sub[:id]) }
-        valid.empty? ? nil : valid
-      end
-
-      # this will only refund the most recent subscription payment
-      def refund_subscription(subscription_id)
-        subscription = ::Stripe::Subscription.retrieve(subscription_id)
-        invoice = ::Stripe::Invoice.retrieve(subscription[:latest_invoice]) if subscription[
-          :latest_invoice
-        ]
-        payment_intent = invoice[:payment_intent] if invoice[:payment_intent]
-        refund = ::Stripe::Refund.create({ payment_intent: payment_intent })
-      end
-    end
-  end
-end

app/controllers/discourse_subscriptions/admin_controller.rb

@@ -1,25 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  class AdminController < ::Admin::AdminController
-    requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-    def index
-      head 200
-    end
-
-    def refresh_campaign
-      Jobs.enqueue(:manually_update_campaign_data)
-      render json: success_json
-    end
-
-    def create_campaign
-      begin
-        DiscourseSubscriptions::Campaign.new.create_campaign
-        render json: success_json
-      rescue => e
-        render_json_error e.message
-      end
-    end
-  end
-end

app/controllers/discourse_subscriptions/hooks_controller.rb

@@ -1,148 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  class HooksController < ::ApplicationController
-    include DiscourseSubscriptions::Group
-    include DiscourseSubscriptions::Stripe
-
-    requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-    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]
-
-    def create
-      begin
-        payload = request.body.read
-        sig_header = request.env["HTTP_STRIPE_SIGNATURE"]
-        webhook_secret = SiteSetting.discourse_subscriptions_webhook_secret
-
-        event = ::Stripe::Webhook.construct_event(payload, sig_header, webhook_secret)
-      rescue JSON::ParserError => e
-        return render_json_error e.message
-      rescue ::Stripe::SignatureVerificationError => e
-        return render_json_error e.message
-      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])
-
-        return render_json_error "customer not found" if !customer
-
-        update_status(customer.id, subscription[:id], status)
-
-        user = ::User.find_by(id: customer.user_id)
-        return render_json_error "user not found" if !user
-
-        if group = plan_group(subscription[:plan])
-          group.add(user)
-        end
-      when "customer.subscription.deleted"
-        subscription = event[:data][:object]
-
-        customer = find_active_customer(subscription[:customer], subscription[:plan][:product])
-
-        return render_json_error "customer not found" if !customer
-
-        update_status(customer.id, subscription[:id], subscription[:status])
-
-        user = ::User.find(customer.user_id)
-        return render_json_error "user not found" if !user
-
-        if group = plan_group(subscription[:plan])
-          group.remove(user)
-        end
-      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

@@ -1,267 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  class SubscribeController < ::ApplicationController
-    include DiscourseSubscriptions::Stripe
-    include DiscourseSubscriptions::Group
-
-    requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-    before_action :set_api_key
-    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
-    end
-
-    def contributors
-      return unless SiteSetting.discourse_subscriptions_campaign_show_contributors
-      contributor_ids = Set.new
-
-      campaign_product = SiteSetting.discourse_subscriptions_campaign_product
-      if campaign_product.present?
-        contributor_ids.merge(Customer.where(product_id: campaign_product).last(5).pluck(:user_id))
-      else
-        contributor_ids.merge(Customer.last(5).pluck(:user_id))
-      end
-
-      contributors = ::User.where(id: contributor_ids)
-
-      render_serialized(contributors, UserSerializer)
-    end
-
-    def show
-      params.require(:id)
-      begin
-        product = ::Stripe::Product.retrieve(params[:id])
-        plans = ::Stripe::Price.list(active: true, product: params[:id])
-
-        response = { product: serialize_product(product), plans: serialize_plans(plans) }
-
-        render_json_dump response
-      rescue ::Stripe::InvalidRequestError => e
-        render_json_error e.message
-      end
-    end
-
-    def create
-      params.require(%i[source plan])
-      begin
-        customer =
-          find_or_create_customer(
-            params[:source],
-            params[:cardholder_name],
-            params[:cardholder_address],
-          )
-        plan = ::Stripe::Price.retrieve(params[:plan])
-
-        if params[:promo].present?
-          promo_code = ::Stripe::PromotionCode.list({ code: params[:promo] })
-          promo_code = promo_code[:data][0] # we assume promo codes have a unique name
-
-          if promo_code.blank?
-            return render_json_error I18n.t("js.discourse_subscriptions.subscribe.invalid_coupon")
-          end
-        end
-
-        recurring_plan = plan[:type] == "recurring"
-
-        if recurring_plan
-          trial_days = plan[:metadata][:trial_period_days] if plan[:metadata] &&
-            plan[:metadata][:trial_period_days]
-
-          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)
-
-          payment_intent = retrieve_payment_intent(transaction[:latest_invoice]) if transaction[
-            :status
-          ] == "incomplete"
-        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],
-            )
-          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
-
-        finalize_transaction(transaction, plan) if transaction_ok(transaction)
-
-        transaction = transaction.to_h.merge(transaction, payment_intent: payment_intent)
-
-        render_json_dump transaction
-      rescue ::Stripe::InvalidRequestError => e
-        render_json_error e.message
-      end
-    end
-
-    def finalize
-      params.require(%i[plan transaction])
-      begin
-        price = ::Stripe::Price.retrieve(params[:plan])
-        transaction = retrieve_transaction(params[:transaction])
-        finalize_transaction(transaction, price) if transaction_ok(transaction)
-
-        render_json_dump params[:transaction]
-      rescue ::Stripe::InvalidRequestError => e
-        render_json_error e.message
-      end
-    end
-
-    def finalize_transaction(transaction, plan)
-      group = plan_group(plan)
-
-      group.add(current_user) if group
-
-      customer =
-        Customer.create(
-          user_id: current_user.id,
-          customer_id: transaction[:customer],
-          product_id: plan[:product],
-        )
-
-      if transaction[:object] == "subscription"
-        Subscription.create(
-          customer_id: customer.id,
-          external_id: transaction[:id],
-          status: transaction[:status],
-        )
-      end
-    end
-
-    private
-
-    def serialize_product(product)
-      {
-        id: product[:id],
-        name: product[:name],
-        description: PrettyText.cook(product[:metadata][:description]),
-        subscribed: current_user_products.include?(product[:id]),
-        repurchaseable: product[:metadata][:repurchaseable],
-      }
-    end
-
-    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)
-    end
-
-    def serialize_plans(plans)
-      plans[:data]
-        .map { |plan| plan.to_h.slice(:id, :unit_amount, :currency, :type, :recurring) }
-        .sort_by { |plan| plan[:amount] }
-    end
-
-    def find_or_create_customer(source, cardholder_name = nil, cardholder_address = nil)
-      customer = Customer.find_by_user_id(current_user.id)
-      cardholder_address =
-        (
-          if cardholder_address.present?
-            {
-              line1: cardholder_address[:line1],
-              city: cardholder_address[:city],
-              state: cardholder_address[:state],
-              country: cardholder_address[:country],
-              postal_code: cardholder_address[:postalCode],
-            }
-          else
-            nil
-          end
-        )
-
-      if customer.present?
-        ::Stripe::Customer.retrieve(customer.customer_id)
-      else
-        ::Stripe::Customer.create(
-          email: current_user.email,
-          source: source,
-          name: cardholder_name,
-          address: cardholder_address,
-        )
-      end
-    end
-
-    def retrieve_payment_intent(invoice_id)
-      invoice = ::Stripe::Invoice.retrieve(invoice_id)
-      ::Stripe::PaymentIntent.retrieve(invoice[:payment_intent])
-    end
-
-    def retrieve_transaction(transaction)
-      begin
-        case transaction
-        when /^sub_/
-          ::Stripe::Subscription.retrieve(transaction)
-        when /^in_/
-          ::Stripe::Invoice.retrieve(transaction)
-        end
-      rescue ::Stripe::InvalidRequestError => e
-        e.message
-      end
-    end
-
-    def metadata_user
-      { user_id: current_user.id, username: current_user.username_lower }
-    end
-
-    def transaction_ok(transaction)
-      %w[active trialing paid].include?(transaction[:status])
-    end
-  end
-end

app/controllers/discourse_subscriptions/user/payments_controller.rb

@@ -1,118 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module User
-    class PaymentsController < ::ApplicationController
-      include DiscourseSubscriptions::Stripe
-
-      requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-      before_action :set_api_key
-      requires_login
-
-      def index
-        begin
-          customer = Customer.where(user_id: current_user.id)
-          customer_ids = customer.map { |c| c.customer_id } if customer
-          product_ids = Product.all.pluck(:external_id)
-
-          data = []
-
-          if customer_ids.present? && product_ids.present?
-            customer_ids.each do |customer_id|
-              # lots of matching because the Stripe API doesn't make it easy to match products => payments except from invoices
-              all_invoices = ::Stripe::Invoice.list(customer: customer_id)
-              invoices_with_products = parse_invoices(all_invoices, product_ids)
-              invoice_ids = invoices_with_products.map { |invoice| invoice[:id] }
-              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
-            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
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      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
-            invoice_product_id = parse_invoice_lines(invoice_lines)
-            product_ids.include?(invoice_product_id)
-          end
-        end
-      end
-
-      def parse_invoice_lines(invoice_lines)
-        invoice_product_id = invoice_lines[:price][:product] if invoice_lines[:price] &&
-          invoice_lines[:price][:product]
-        invoice_product_id = invoice_lines[:plan][:product] if invoice_lines[:plan] &&
-          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

@@ -1,98 +0,0 @@
-# frozen_string_literal: true
-
-module DiscourseSubscriptions
-  module User
-    class SubscriptionsController < ::ApplicationController
-      include DiscourseSubscriptions::Stripe
-      include DiscourseSubscriptions::Group
-
-      requires_plugin DiscourseSubscriptions::PLUGIN_NAME
-
-      before_action :set_api_key
-      requires_login
-
-      def index
-        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,
-            ) if customer_ids
-
-          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 = []
-
-            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
-
-            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] }
-              subscription.to_h.except!(:plan)
-              subscription.to_h.merge(plan: plan, product: plan[:product].to_h.slice(:id, :name))
-            end
-          end
-
-          render_json_dump subscriptions
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def destroy
-        # we cancel but don't remove until the end of the period
-        # full removal is done via webhooks
-        begin
-          subscription = ::Stripe::Subscription.update(params[:id], { cancel_at_period_end: true })
-
-          if subscription
-            render_json_dump subscription
-          else
-            render_json_error I18n.t("discourse_subscriptions.customer_not_found")
-          end
-        rescue ::Stripe::InvalidRequestError => e
-          render_json_error e.message
-        end
-      end
-
-      def update
-        params.require(:payment_method)
-
-        subscription = Subscription.where(external_id: params[:id]).first
-        begin
-          attach_method_to_customer(subscription.customer_id, params[:payment_method])
-          subscription =
-            ::Stripe::Subscription.update(
-              params[:id],
-              { default_payment_method: params[:payment_method] },
-            )
-          render json: success_json
-        rescue ::Stripe::InvalidRequestError
-          render_json_error I18n.t("discourse_subscriptions.card.invalid")
-        end
-      end
-
-      private
-
-      def attach_method_to_customer(customer_id, method)
-        customer = Customer.find(customer_id)
-        ::Stripe::PaymentMethod.attach(method, { customer: customer.customer_id })
-      end
-    end
-  end
-end

app/helpers/discourse_donations/application_helper.rb

@@ -0,0 +1,5 @@
+
+module DiscourseDonations
+  module ApplicationHelper
+  end
+end

app/jobs/jobs.rb

@@ -0,0 +1 @@
+load File.expand_path('../regular/donation_user.rb', __FILE__)

app/jobs/regular/donation_user.rb

@@ -0,0 +1,18 @@
+
+module Jobs
+  class DonationUser < ::Jobs::Base
+    def execute(args)
+      user = User.create!(args.slice(:username, :password, :name, :email))
+      return unless user.persisted?
+      Jobs.enqueue(
+        :critical_user_email,
+        type: :signup, user_id: user.id, email_token: user.email_tokens.first.token
+      )
+      rewards = DiscourseDonations::Rewards.new(user)
+      args[:rewards].to_a.each do |reward|
+        rewards.grant_badge(reward[:name]) if reward[:type] == 'badge'
+        rewards.add_to_group(reward[:name]) if reward[:type] == 'group'
+      end
+    end
+  end
+end