diff --git a/.DS_Store b/.DS_Store
new file mode 100644
index 0000000..bff3f9d
Binary files /dev/null and b/.DS_Store differ
diff --git a/.gitattributes b/.gitattributes
new file mode 100644
index 0000000..31eeee0
--- /dev/null
+++ b/.gitattributes
@@ -0,0 +1,7 @@
+# See https://git-scm.com/docs/gitattributes for more about git attribute files.
+
+# Mark the database schema as having been generated.
+db/schema.rb linguist-generated
+
+# Mark any vendored files as having been vendored.
+vendor/* linguist-vendored
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..12439e5
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,33 @@
+# See https://help.github.com/articles/ignoring-files for more about ignoring files.
+#
+# If you find yourself ignoring temporary files generated by your text editor
+# or operating system, you probably want to add a global ignore instead:
+# git config --global core.excludesfile '~/.gitignore_global'
+
+# Ignore bundler config.
+/.bundle
+
+# Ignore the default SQLite database.
+/db/*.sqlite3
+/db/*.sqlite3-*
+
+# Ignore all logfiles and tempfiles.
+/log/*
+/tmp/*
+!/log/.keep
+!/tmp/.keep
+
+# Ignore pidfiles, but keep the directory.
+/tmp/pids/*
+!/tmp/pids/
+!/tmp/pids/.keep
+
+# Ignore uploaded files in development.
+/storage/*
+!/storage/.keep
+/tmp/storage/*
+!/tmp/storage/
+!/tmp/storage/.keep
+
+# Ignore master key for decrypting credentials and more.
+/config/master.key
diff --git a/.idea/.gitignore b/.idea/.gitignore
new file mode 100644
index 0000000..13566b8
--- /dev/null
+++ b/.idea/.gitignore
@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml
diff --git a/.idea/dataSources.xml b/.idea/dataSources.xml
new file mode 100644
index 0000000..18a44da
--- /dev/null
+++ b/.idea/dataSources.xml
@@ -0,0 +1,14 @@
+
+
+
+
+ sqlite.xerial
+ true
+ true
+ $PROJECT_DIR$/config/database.yml
+ org.sqlite.JDBC
+ jdbc:sqlite:$PROJECT_DIR$/db/development.sqlite3
+ $ProjectFileDir$
+
+
+
\ No newline at end of file
diff --git a/.idea/misc.xml b/.idea/misc.xml
new file mode 100644
index 0000000..057b4eb
--- /dev/null
+++ b/.idea/misc.xml
@@ -0,0 +1,4 @@
+
+
+
+
\ No newline at end of file
diff --git a/.idea/modules.xml b/.idea/modules.xml
new file mode 100644
index 0000000..6295ae9
--- /dev/null
+++ b/.idea/modules.xml
@@ -0,0 +1,8 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/sequra.iml b/.idea/sequra.iml
new file mode 100644
index 0000000..306eb39
--- /dev/null
+++ b/.idea/sequra.iml
@@ -0,0 +1,144 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/vcs.xml b/.idea/vcs.xml
new file mode 100644
index 0000000..35eb1dd
--- /dev/null
+++ b/.idea/vcs.xml
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.rspec b/.rspec
new file mode 100644
index 0000000..c99d2e7
--- /dev/null
+++ b/.rspec
@@ -0,0 +1 @@
+--require spec_helper
diff --git a/.ruby-version b/.ruby-version
new file mode 100644
index 0000000..72b3400
--- /dev/null
+++ b/.ruby-version
@@ -0,0 +1 @@
+ruby-3.2.1
diff --git a/Gemfile b/Gemfile
new file mode 100644
index 0000000..a0f4e12
--- /dev/null
+++ b/Gemfile
@@ -0,0 +1,71 @@
+# frozen_string_literal: true
+
+source 'https://rubygems.org'
+git_source(:github) { |repo| "https://github.com/#{repo}.git" }
+
+ruby '3.2.1'
+
+# Bundle edge Rails instead: gem "rails", github: "rails/rails", branch: "main"
+gem 'rails', '~> 7.0.5'
+
+# Use sqlite3 as the database for Active Record
+gem 'sqlite3', '~> 1.4'
+
+# Use the Puma web server [https://github.com/puma/puma]
+gem 'puma', '~> 5.0'
+
+# Build JSON APIs with ease [https://github.com/rails/jbuilder]
+# gem "jbuilder"
+
+# Use Redis adapter to run Action Cable in production
+# gem "redis", "~> 4.0"
+
+# Use Kredis to get higher-level data types in Redis [https://github.com/rails/kredis]
+# gem "kredis"
+
+# Use Active Model has_secure_password [https://guides.rubyonrails.org/active_model_basics.html#securepassword]
+# gem "bcrypt", "~> 3.1.7"
+
+# Windows does not include zoneinfo files, so bundle the tzinfo-data gem
+gem 'tzinfo-data', platforms: %i[mingw mswin x64_mingw jruby]
+
+# Reduces boot times through caching; required in config/boot.rb
+gem 'bootsnap', require: false
+
+# Use Active Storage variants [https://guides.rubyonrails.org/active_storage_overview.html#transforming-images]
+# gem "image_processing", "~> 1.2"
+
+# Use Rack CORS for handling Cross-Origin Resource Sharing (CORS), making cross-origin AJAX possible
+# gem "rack-cors"
+
+# bulk import ( used for importing data from the csv )
+gem 'activerecord-import'
+
+# used to deal with money and prevent rouding issues
+gem 'money-rails'
+
+# to be used with sidekiq
+gem 'redis'
+
+# to run workers in the background
+gem 'sidekiq'
+gem 'sidekiq-scheduler'
+
+group :development, :test do
+ gem 'pry-byebug'
+ gem 'pry-rails'
+ gem 'rspec-rails'
+ gem 'factory_bot_rails'
+ gem 'faker' # To easily generate random data.
+ # See https://guides.rubyonrails.org/debugging_rails_applications.html#debugging-with-the-debug-gem
+ gem 'debug', platforms: %i[mri mingw x64_mingw]
+end
+
+group :test do
+ gem 'shoulda-matchers'
+end
+
+group :development do
+ # Speed up commands on slow machines / big apps [https://github.com/rails/spring]
+ # gem "spring"
+end
diff --git a/Gemfile.lock b/Gemfile.lock
new file mode 100644
index 0000000..2da28f1
--- /dev/null
+++ b/Gemfile.lock
@@ -0,0 +1,257 @@
+GEM
+ remote: https://rubygems.org/
+ specs:
+ actioncable (7.0.7.2)
+ actionpack (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ nio4r (~> 2.0)
+ websocket-driver (>= 0.6.1)
+ actionmailbox (7.0.7.2)
+ actionpack (= 7.0.7.2)
+ activejob (= 7.0.7.2)
+ activerecord (= 7.0.7.2)
+ activestorage (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ mail (>= 2.7.1)
+ net-imap
+ net-pop
+ net-smtp
+ actionmailer (7.0.7.2)
+ actionpack (= 7.0.7.2)
+ actionview (= 7.0.7.2)
+ activejob (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ mail (~> 2.5, >= 2.5.4)
+ net-imap
+ net-pop
+ net-smtp
+ rails-dom-testing (~> 2.0)
+ actionpack (7.0.7.2)
+ actionview (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ rack (~> 2.0, >= 2.2.4)
+ rack-test (>= 0.6.3)
+ rails-dom-testing (~> 2.0)
+ rails-html-sanitizer (~> 1.0, >= 1.2.0)
+ actiontext (7.0.7.2)
+ actionpack (= 7.0.7.2)
+ activerecord (= 7.0.7.2)
+ activestorage (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ globalid (>= 0.6.0)
+ nokogiri (>= 1.8.5)
+ actionview (7.0.7.2)
+ activesupport (= 7.0.7.2)
+ builder (~> 3.1)
+ erubi (~> 1.4)
+ rails-dom-testing (~> 2.0)
+ rails-html-sanitizer (~> 1.1, >= 1.2.0)
+ activejob (7.0.7.2)
+ activesupport (= 7.0.7.2)
+ globalid (>= 0.3.6)
+ activemodel (7.0.7.2)
+ activesupport (= 7.0.7.2)
+ activerecord (7.0.7.2)
+ activemodel (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ activerecord-import (1.5.0)
+ activerecord (>= 4.2)
+ activestorage (7.0.7.2)
+ actionpack (= 7.0.7.2)
+ activejob (= 7.0.7.2)
+ activerecord (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ marcel (~> 1.0)
+ mini_mime (>= 1.1.0)
+ activesupport (7.0.7.2)
+ concurrent-ruby (~> 1.0, >= 1.0.2)
+ i18n (>= 1.6, < 2)
+ minitest (>= 5.1)
+ tzinfo (~> 2.0)
+ bootsnap (1.16.0)
+ msgpack (~> 1.2)
+ builder (3.2.4)
+ byebug (11.1.3)
+ coderay (1.1.3)
+ concurrent-ruby (1.2.2)
+ connection_pool (2.4.1)
+ crass (1.0.6)
+ date (3.3.3)
+ debug (1.8.0)
+ irb (>= 1.5.0)
+ reline (>= 0.3.1)
+ diff-lcs (1.5.0)
+ erubi (1.12.0)
+ et-orbi (1.2.7)
+ tzinfo
+ factory_bot (6.2.1)
+ activesupport (>= 5.0.0)
+ factory_bot_rails (6.2.0)
+ factory_bot (~> 6.2.0)
+ railties (>= 5.0.0)
+ faker (3.2.1)
+ i18n (>= 1.8.11, < 2)
+ fugit (1.8.1)
+ et-orbi (~> 1, >= 1.2.7)
+ raabro (~> 1.4)
+ globalid (1.1.0)
+ activesupport (>= 5.0)
+ groupdate (6.3.0)
+ activesupport (>= 6.1)
+ i18n (1.14.1)
+ concurrent-ruby (~> 1.0)
+ io-console (0.6.0)
+ irb (1.7.4)
+ reline (>= 0.3.6)
+ loofah (2.21.3)
+ crass (~> 1.0.2)
+ nokogiri (>= 1.12.0)
+ mail (2.8.1)
+ mini_mime (>= 0.1.1)
+ net-imap
+ net-pop
+ net-smtp
+ marcel (1.0.2)
+ method_source (1.0.0)
+ mini_mime (1.1.5)
+ minitest (5.19.0)
+ monetize (1.12.0)
+ money (~> 6.12)
+ money (6.16.0)
+ i18n (>= 0.6.4, <= 2)
+ money-rails (1.15.0)
+ activesupport (>= 3.0)
+ monetize (~> 1.9)
+ money (~> 6.13)
+ railties (>= 3.0)
+ msgpack (1.7.2)
+ net-imap (0.3.7)
+ date
+ net-protocol
+ net-pop (0.1.2)
+ net-protocol
+ net-protocol (0.2.1)
+ timeout
+ net-smtp (0.3.3)
+ net-protocol
+ nio4r (2.5.9)
+ nokogiri (1.15.4-arm64-darwin)
+ racc (~> 1.4)
+ pry (0.14.2)
+ coderay (~> 1.1)
+ method_source (~> 1.0)
+ pry-byebug (3.10.1)
+ byebug (~> 11.0)
+ pry (>= 0.13, < 0.15)
+ pry-rails (0.3.9)
+ pry (>= 0.10.4)
+ puma (5.6.7)
+ nio4r (~> 2.0)
+ raabro (1.4.0)
+ racc (1.7.1)
+ rack (2.2.8)
+ rack-test (2.1.0)
+ rack (>= 1.3)
+ rails (7.0.7.2)
+ actioncable (= 7.0.7.2)
+ actionmailbox (= 7.0.7.2)
+ actionmailer (= 7.0.7.2)
+ actionpack (= 7.0.7.2)
+ actiontext (= 7.0.7.2)
+ actionview (= 7.0.7.2)
+ activejob (= 7.0.7.2)
+ activemodel (= 7.0.7.2)
+ activerecord (= 7.0.7.2)
+ activestorage (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ bundler (>= 1.15.0)
+ railties (= 7.0.7.2)
+ rails-dom-testing (2.2.0)
+ activesupport (>= 5.0.0)
+ minitest
+ nokogiri (>= 1.6)
+ rails-html-sanitizer (1.6.0)
+ loofah (~> 2.21)
+ nokogiri (~> 1.14)
+ railties (7.0.7.2)
+ actionpack (= 7.0.7.2)
+ activesupport (= 7.0.7.2)
+ method_source
+ rake (>= 12.2)
+ thor (~> 1.0)
+ zeitwerk (~> 2.5)
+ rake (13.0.6)
+ redis (4.8.1)
+ redis-client (0.16.0)
+ connection_pool
+ reline (0.3.8)
+ io-console (~> 0.5)
+ rspec-core (3.12.2)
+ rspec-support (~> 3.12.0)
+ rspec-expectations (3.12.3)
+ diff-lcs (>= 1.2.0, < 2.0)
+ rspec-support (~> 3.12.0)
+ rspec-mocks (3.12.6)
+ diff-lcs (>= 1.2.0, < 2.0)
+ rspec-support (~> 3.12.0)
+ rspec-rails (6.0.3)
+ actionpack (>= 6.1)
+ activesupport (>= 6.1)
+ railties (>= 6.1)
+ rspec-core (~> 3.12)
+ rspec-expectations (~> 3.12)
+ rspec-mocks (~> 3.12)
+ rspec-support (~> 3.12)
+ rspec-support (3.12.1)
+ rufus-scheduler (3.9.1)
+ fugit (~> 1.1, >= 1.1.6)
+ shoulda-matchers (5.3.0)
+ activesupport (>= 5.2.0)
+ sidekiq (7.1.2)
+ concurrent-ruby (< 2)
+ connection_pool (>= 2.3.0)
+ rack (>= 2.2.4)
+ redis-client (>= 0.14.0)
+ sidekiq-scheduler (5.0.3)
+ rufus-scheduler (~> 3.2)
+ sidekiq (>= 6, < 8)
+ tilt (>= 1.4.0)
+ sqlite3 (1.6.4-arm64-darwin)
+ thor (1.2.2)
+ tilt (2.2.0)
+ timeout (0.4.0)
+ tzinfo (2.0.6)
+ concurrent-ruby (~> 1.0)
+ websocket-driver (0.7.6)
+ websocket-extensions (>= 0.1.0)
+ websocket-extensions (0.1.5)
+ zeitwerk (2.6.11)
+
+PLATFORMS
+ arm64-darwin-22
+
+DEPENDENCIES
+ activerecord-import
+ bootsnap
+ debug
+ factory_bot_rails
+ faker
+ groupdate
+ money-rails
+ pry-byebug
+ pry-rails
+ puma (~> 5.0)
+ rails (~> 7.0.5)
+ redis
+ rspec-rails
+ shoulda-matchers
+ sidekiq
+ sidekiq-scheduler
+ sqlite3 (~> 1.4)
+ tzinfo-data
+
+RUBY VERSION
+ ruby 3.2.1p31
+
+BUNDLED WITH
+ 2.4.8
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..48326ab
--- /dev/null
+++ b/README.md
@@ -0,0 +1,185 @@
+# seQura Disbursements System
+
+This application is designed to automate the calculation of merchants’ disbursements payouts and seQura commissions. It includes processes to handle large datasets efficiently and ensures accurate financial operations.
+
+### Disbursement Summary Table
+
+| Year | Number of disbursements | Amount disbursed to merchants | Amount of order fees | Number of monthly fees charged (From minimum monthly fee) | Amount of monthly fee charged (From minimum monthly fee) |
+|------|-------------------------|-------------------------------|----------------------|------------------------------------------------------|----------------------------------------------------------|
+| 2022 | 1450 | 14.518.175,80 € | 124.490,81 € | 18 | 233,43 € |
+| 2023 | 1186 | 15.308.971,43 € | 131.264,29 € | 185 | 3.868,55 € |
+
+
+## Setup:
+
+### 1. Rails and Database:
+- Used a Rails application
+- Integrated the `money-rails` gem for better money handling.
+- All the values are stored in cents so we dont have rounding issues
+
+### 2. Models:
+- **Merchant**:
+- **Order**:
+- **Disbursement**:
+
+### 3. Importing Data from CSV:
+- Created Rake tasks to import merchants and orders from CSV files.
+- Sanitizes emails during import.
+- Optimized import strategies for large datasets.
+
+### 4. Background Processing with Sidekiq:
+- Integrated `sidekiq` for asynchronous job processing.
+- Daily disbursements processed using Sidekiq workers.
+- Scheduled tasks using `sidekiq-scheduler`.
+
+## Usage:
+
+### 1. CSV Import:
+
+**Import Merchants**:
+ ```bash
+ rake import:merchants
+ ```
+
+**Import Orders**:
+ ```bash
+ rake import:orders
+ ```
+
+### 2. Sidekiq:
+- Start Sidekiq:
+ ```bash
+ bundle exec sidekiq
+ ```
+- `DisbursementWorker` runs daily at 7:00 UTC to process disbursements for eligible merchants.
+
+## Features:
+
+### 1. Disbursements Calculation:
+- All orders are disbursed precisely once.
+- Unique alphanumerical reference for each disbursement.
+- Order-based commission calculation.
+- Checks for `minimum_monthly_fee` on the first disbursement of each month.
+
+### 2. Efficiency:
+- Data import that doesn't load the entire CSV into memory.
+- Cached merchant references during order imports.
+- Optimized for large datasets using batch processing.
+- when dealing with calculations used the sum from the database to
+better performance tried to instantiate only the needed parts
+
+### 3. Sanitization:
+- Email sanitization during CSV import for data integrity.
+- During the order import check if the Merchant exits added references in the
+database and index to minimize data corruption
+
+## Future Enhancements:
+
+1. On the services that import data if a batch has bad data on it we discard the whole batch this can be imporved
+2. Integrate error handling and notifications for failed jobs in Sidekiq.
+3. Improve reporting capabilities for orders, amounts, and fees included in disbursements.
+4. Add more coverage to the more complex part ( the worker )
+
+---
+
+## DisbursementWorker
+
+The `DisbursementWorker` class is a utility designed to process disbursements for merchants. It calculates and processes disbursements for all registered merchants, taking into consideration the specific frequency (daily or weekly) at which each merchant prefers to receive their payments.
+
+### Technical Choices & Assumptions:
+
+1. **Sidekiq Integration**: the decision to use Sidekiq for this worker because it provides a robust background job processing capability. This ensures that our disbursement process doesn't block other operations, especially if the number of merchants or orders is large.
+
+2. **Batch Processing with `Merchant.find_each`**: Instead of loading all merchants into memory, used the `find_each` method to retrieve them in batches. This makes the memory footprint predictable regardless of the total number of merchants.
+
+3. **Date Iteration based on Disbursement Frequency**: The worker considers the disbursement frequency of each merchant (daily or weekly) to process the disbursements accordingly. This is achieved through the `date_iterator_for` method.
+
+4. **Deferred Fee Calculation**: Fees are calculated based on the total amount disbursed. Different slabs of fees exist based on the disbursement amount, ensuring a fair fee structure.
+
+5. **Monthly Minimum Fee**: If the fee from transactions is less than the minimum monthly fee, a correction is applied. This ensures the merchant always pays the minimum monthly fee.
+
+6. **Atomicity in Disbursement Creation**: The disbursement record creation and linking to orders is done atomically. This ensures that we don't end up with orders linked to a failed disbursement record.
+
+### Tradeoffs:
+
+- **Performance vs Freshness**: Instead of processing disbursements in real-time, went with a batch-based approach which might have a delay but ensures optimal performance.
+
+- **Complexity**: To handle various scenarios like monthly fees, different fee slabs, and varying disbursement frequencies, the worker has a fair bit of complexity. However, it's organized into smaller methods for clarity.
+
+### Left Aside due to Time Constraints:
+
+1. **Error Handling**: While the basic structure is in place, more comprehensive error handling and reporting mechanisms need to be integrated. This would ensure that any issues during the disbursement process are quickly identified and addressed.
+
+2. **Performance Optimizations**: Although the current setup works efficiently for a moderate number of merchants and orders, specific optimizations can be done, especially in SQL queries and iterations, when the data size grows significantly.
+
+3. **Testing**: Comprehensive unit tests for this worker would be essential. While some basic tests might exist, ensuring full coverage, especially around edge cases, would be the next step.
+
+### How to Resolve/Improve:
+
+1. **Parallel Processing**: If the number of merchants grows, we could split the job into multiple smaller jobs that can run in parallel, ensuring faster processing.
+
+2. **Distributed Locking**: To ensure that two workers don't process the same merchant's disbursements simultaneously, we could introduce distributed locking mechanisms.
+
+3. **Introduce a Retry Mechanism**: If for any reason a disbursement for a merchant fails, having a retry mechanism with exponential backoff could be beneficial.
+
+4. **Monitoring and Alerting**: Integrate the worker with monitoring tools to get insights into its performance, failures, and ensure timely alerts in case of issues.
+
+### Usage:
+
+To trigger the disbursement process:
+
+```ruby
+DisbursementWorker.perform_async
+```
+
+Ensure you have Sidekiq running and integrated with your application.
+
+### Dependencies:
+
+- `Sidekiq`: For background job processing.
+
+
+## Description of `MerchantImporterService`
+
+The `MerchantImporterService` is a service class responsible for importing merchant data from a provided CSV file into the system. The class serves as a pipeline for extracting, transforming, and loading (ETL) the merchant data.
+
+**Key Components and Processes:**
+
+1. **Initialization**: Upon instantiation, it requires a file path to the CSV to be imported and sets up a logger.
+
+2. **Parsing**: It uses Ruby's CSV library to parse the file. Each row from the CSV file is read and transformed into a hash of attributes suitable for creating a Merchant record.
+
+3. **Transformation**: During this phase:
+ - Email addresses are sanitized by removing any character that doesn't match a predefined regular expression.
+ - The currency is set to a default value ('EUR').
+ - The minimum monthly fee is converted from float to an integer (multiplied by 100, presumably to handle cents).
+
+4. **Loading**: Merchants are inserted in batches (defined by `BATCH_SIZE`) to optimize the database writes.
+
+5. **Logging**: Any errors during the import process, or during the bulk insert, are logged. Successful imports are also logged.
+
+6. **Transactions**: The bulk insert process is wrapped in a database transaction to ensure data integrity. If one insert fails, all inserts in that batch will be rolled back.
+
+## Possible Improvements:
+
+1. **Validation**:
+ - Currently, the service assumes that the provided data is mostly correct. It might be beneficial to add validations for essential fields (e.g., checking if the `email` is in a valid format or if `reference` is unique).
+ - Use ActiveRecord validations for merchant attributes and handle validation errors.
+
+2. **Error Handling**:
+ - Instead of just logging errors, the service could also return these errors so that they can be presented to the user or be processed further.
+ - Specific error messages for different types of errors, like malformed CSV, missing required columns, or invalid data.
+
+3. **Configurability**:
+ - Allow for configurable batch sizes or default currencies instead of hardcoding them. This can be useful if you need to adjust based on performance metrics or different use cases.
+
+4. **Extensibility**:
+ - The service is specific to importing merchants. An abstracted version could be created to handle different types of CSV imports, making the system more extensible.
+ - Allow for custom transformations or additional steps in the ETL process if required in the future.
+
+5. **Feedback**:
+ - Provide feedback on the number of successful imports vs. failed ones.
+ - Allow for a dry-run mode where the import is simulated but no data is actually saved. This lets users check the potential output before committing.
+
+6. **Integration with External Systems**:
+ - If the data comes from or goes to external systems, consider adding integrations or notifications to inform these systems about the import status.
diff --git a/Rakefile b/Rakefile
new file mode 100644
index 0000000..9a5ea73
--- /dev/null
+++ b/Rakefile
@@ -0,0 +1,6 @@
+# Add your own tasks in files placed in lib/tasks ending in .rake,
+# for example lib/tasks/capistrano.rake, and they will automatically be available to Rake.
+
+require_relative "config/application"
+
+Rails.application.load_tasks
diff --git a/app/channels/application_cable/channel.rb b/app/channels/application_cable/channel.rb
new file mode 100644
index 0000000..d672697
--- /dev/null
+++ b/app/channels/application_cable/channel.rb
@@ -0,0 +1,4 @@
+module ApplicationCable
+ class Channel < ActionCable::Channel::Base
+ end
+end
diff --git a/app/channels/application_cable/connection.rb b/app/channels/application_cable/connection.rb
new file mode 100644
index 0000000..0ff5442
--- /dev/null
+++ b/app/channels/application_cable/connection.rb
@@ -0,0 +1,4 @@
+module ApplicationCable
+ class Connection < ActionCable::Connection::Base
+ end
+end
diff --git a/app/controllers/application_controller.rb b/app/controllers/application_controller.rb
new file mode 100644
index 0000000..4ac8823
--- /dev/null
+++ b/app/controllers/application_controller.rb
@@ -0,0 +1,2 @@
+class ApplicationController < ActionController::API
+end
diff --git a/app/controllers/concerns/.keep b/app/controllers/concerns/.keep
new file mode 100644
index 0000000..e69de29
diff --git a/app/jobs/application_job.rb b/app/jobs/application_job.rb
new file mode 100644
index 0000000..d394c3d
--- /dev/null
+++ b/app/jobs/application_job.rb
@@ -0,0 +1,7 @@
+class ApplicationJob < ActiveJob::Base
+ # Automatically retry jobs that encountered a deadlock
+ # retry_on ActiveRecord::Deadlocked
+
+ # Most jobs are safe to ignore if the underlying records are no longer available
+ # discard_on ActiveJob::DeserializationError
+end
diff --git a/app/mailers/application_mailer.rb b/app/mailers/application_mailer.rb
new file mode 100644
index 0000000..3c34c81
--- /dev/null
+++ b/app/mailers/application_mailer.rb
@@ -0,0 +1,4 @@
+class ApplicationMailer < ActionMailer::Base
+ default from: "from@example.com"
+ layout "mailer"
+end
diff --git a/app/models/application_record.rb b/app/models/application_record.rb
new file mode 100644
index 0000000..08dc537
--- /dev/null
+++ b/app/models/application_record.rb
@@ -0,0 +1,5 @@
+# frozen_string_literal: true
+
+class ApplicationRecord < ActiveRecord::Base
+ primary_abstract_class
+end
diff --git a/app/models/concerns/.keep b/app/models/concerns/.keep
new file mode 100644
index 0000000..e69de29
diff --git a/app/models/disbursement.rb b/app/models/disbursement.rb
new file mode 100644
index 0000000..507561b
--- /dev/null
+++ b/app/models/disbursement.rb
@@ -0,0 +1,30 @@
+# frozen_string_literal: true
+
+# This is the Disbursement model representing disbursements made to merchants.
+class Disbursement < ApplicationRecord
+ # Each disbursement is associated with one merchant.
+ belongs_to :merchant
+
+ # A disbursement can be associated with many orders.
+ has_many :orders
+
+ # Validations to ensure that the required attributes are present.
+ validates :amount_cents, :fee_cents, :disbursed_on, :reference, presence: true
+
+ # Ensures that the reference of each disbursement is unique.
+ validates :reference, uniqueness: true
+
+ # Before saving a new disbursement to the database,
+ # this callback ensures a unique reference is generated.
+ before_validation :generate_unique_reference, on: :create
+
+ private
+
+ # This method is used to generate a unique reference for the disbursement.
+ # It consists of the merchant's ID, the disbursement date, and a random hex value.
+ # The `||=` ensures that it only sets the reference if it's currently nil,
+ # to avoid overwriting an existing reference.
+ def generate_unique_reference
+ self.reference ||= "#{merchant.id}-#{disbursed_on}-#{SecureRandom.hex(4)}"
+ end
+end
diff --git a/app/models/merchant.rb b/app/models/merchant.rb
new file mode 100644
index 0000000..4b14b81
--- /dev/null
+++ b/app/models/merchant.rb
@@ -0,0 +1,35 @@
+# frozen_string_literal: true
+
+# This is the Merchant model representing merchants using the system.
+class Merchant < ApplicationRecord
+ # Constants
+
+ # Define constants for disbursement frequencies to avoid magic strings and maintain consistency.
+ DAILY = 'DAILY'
+ WEEKLY = 'WEEKLY'
+
+ # A list of allowed disbursement frequencies.
+ DISBURSEMENT_FREQUENCIES = [DAILY, WEEKLY].freeze
+
+ # Validations
+
+ # Ensures that each merchant has a unique reference.
+ validates :reference, presence: true, uniqueness: true
+
+ # Ensures that email is present and matches a standard email format.
+ validates :email, presence: true, format: { with: URI::MailTo::EMAIL_REGEXP }
+
+ # Validates that the disbursement frequency is either 'DAILY' or 'WEEKLY'.
+ validates :disbursement_frequency, presence: true, inclusion: { in: DISBURSEMENT_FREQUENCIES }
+
+ # Associations
+
+ # A merchant can have many orders.
+ has_many :orders
+
+ # A merchant can have many disbursements.
+ has_many :disbursements
+
+ # Configuration for the Money gem, setting up the money attribute with the relevant currency.
+ monetize :minimum_monthly_fee_cents, with_model_currency: :currency
+end
diff --git a/app/models/order.rb b/app/models/order.rb
new file mode 100644
index 0000000..eac4fd3
--- /dev/null
+++ b/app/models/order.rb
@@ -0,0 +1,7 @@
+# frozen_string_literal: true
+
+# This is the Order model representing individual orders made through the system.
+class Order < ApplicationRecord
+ # Each order belongs to a merchant, establishing a many-to-one relationship.
+ belongs_to :merchant
+end
diff --git a/app/services/merchant_importer_service.rb b/app/services/merchant_importer_service.rb
new file mode 100644
index 0000000..a6939ff
--- /dev/null
+++ b/app/services/merchant_importer_service.rb
@@ -0,0 +1,85 @@
+# frozen_string_literal: true
+
+require 'csv'
+
+# The MerchantImporterService is responsible for importing merchant data from a CSV file.
+class MerchantImporterService
+ # Constants for defining the batch size for bulk insert,
+ # default currency for merchants, and CSV parsing configurations.
+ BATCH_SIZE = 1000
+ DEFAULT_CURRENCY = 'EUR'
+ CSV_CONFIGS = {
+ headers: true,
+ col_sep: ';'
+ }.freeze
+
+ # Regular expression for sanitizing email addresses.
+ EMAIL_REGEX = /[^a-zA-Z0-9_.@-]/i
+
+ # Initializes a new instance of the service with a given CSV file path.
+ def initialize(file_path)
+ @file_path = file_path
+ @logger = Rails.logger
+ end
+
+ # Primary method that processes and imports merchants from the given CSV file.
+ def perform
+ # Ensures the file exists, else logs an error.
+ return @logger.error("File #{@file_path} does not exist.") unless File.exist?(@file_path)
+
+ # Array to store merchants data temporarily for batch insertion.
+ merchants_batch = []
+
+ begin
+ # Iterates over the CSV file row-by-row.
+ CSV.foreach(@file_path, **CSV_CONFIGS) do |row|
+ # Converts each CSV row to merchant attributes and appends to the batch.
+ merchants_batch << build_merchant_data(row)
+
+ # Checks if the batch reaches its size limit, and if so, performs the insertion.
+ if merchants_batch.size >= BATCH_SIZE
+ bulk_insert_merchants(merchants_batch)
+ merchants_batch.clear
+ end
+ end
+
+ # Handles any remaining merchants that didn't meet the batch size.
+ bulk_insert_merchants(merchants_batch) unless merchants_batch.empty?
+
+ # Logs successful import.
+ @logger.info("Successfully imported merchants from #{@file_path}")
+ rescue StandardError => e
+ # Logs any exception that might occur during the process.
+ @logger.error("Error while importing merchants: #{e.message}")
+ end
+ end
+
+ private
+
+ # Constructs merchant attributes from a CSV row.
+ def build_merchant_data(row)
+ {
+ reference: row['reference'],
+ email: sanitize_email(row['email']),
+ live_on: Date.parse(row['live_on']),
+ disbursement_frequency: row['disbursement_frequency'],
+ minimum_monthly_fee_cents: (row['minimum_monthly_fee'].to_f * 100).to_i, # Converts fee to cents.
+ currency: DEFAULT_CURRENCY
+ }
+ end
+
+ # Cleans up the email string by removing unwanted characters.
+ def sanitize_email(email)
+ email.gsub(EMAIL_REGEX, '').downcase
+ end
+
+ # Performs bulk insertion of merchants in a transaction to ensure atomicity.
+ def bulk_insert_merchants(merchants)
+ ActiveRecord::Base.transaction do
+ Merchant.insert_all(merchants)
+ end
+ rescue StandardError => e
+ # Logs an error in case of a failed insertion.
+ @logger.error("Error while performing bulk insert: #{e.message}")
+ end
+end
diff --git a/app/services/order_importer_service.rb b/app/services/order_importer_service.rb
new file mode 100644
index 0000000..d8d356c
--- /dev/null
+++ b/app/services/order_importer_service.rb
@@ -0,0 +1,84 @@
+# frozen_string_literal: true
+
+# app/services/order_importer_service.rb
+class OrderImporterService
+ # Required to read CSV files.
+ require 'csv'
+
+ # Constants to represent the batch size and configurations for reading the CSV.
+ BATCH_SIZE = 10_000
+ CSV_CONFIGS = {
+ headers: true,
+ col_sep: ';'
+ }.freeze
+
+ # Initializes the OrderImporterService with a given file path.
+ #
+ # @param file_path [String] The path to the CSV file to be imported.
+ def initialize(file_path)
+ @file_path = file_path
+ @logger = Rails.logger
+ end
+
+ # The primary method that orchestrates the CSV reading and order importing.
+ def perform
+ # Create a mapping of merchant references to their respective IDs for quick lookup.
+ merchant_ids_by_reference = fetch_merchant_ids_by_reference
+
+ # Temporary storage for orders that will be imported in batches.
+ orders_to_import = []
+
+ # Use a transaction to ensure data integrity.
+ ActiveRecord::Base.transaction do
+ # Iterate over each row in the CSV file.
+ CSV.foreach(@file_path, **CSV_CONFIGS) do |row|
+ # Build an order instance for the current CSV row.
+ order = build_order(row, merchant_ids_by_reference)
+ orders_to_import << order if order
+
+ # If the current batch reaches the defined size, import the batch and clear the temporary storage.
+ bulk_insert_orders(orders_to_import) if orders_to_import.size >= BATCH_SIZE
+ end
+
+ # After iterating through the CSV, import any remaining orders.
+ bulk_insert_orders(orders_to_import) unless orders_to_import.empty?
+ end
+ rescue StandardError => e
+ # Log any errors that arise during the process.
+ @logger.error("Error while importing orders: #{e.message}")
+ end
+
+ private
+
+ # Fetch a mapping of merchant references to their IDs.
+ #
+ # @return [Hash] A hash where keys are merchant references and values are their respective IDs.
+ def fetch_merchant_ids_by_reference
+ Merchant.pluck(:reference, :id).to_h
+ end
+
+ # Constructs an order instance based on a CSV row.
+ #
+ # @param row [CSV::Row] The current CSV row being processed.
+ # @param merchant_ids_by_reference [Hash] A mapping of merchant references to their IDs.
+ # @return [Order, nil] An order instance if a valid merchant reference is found, otherwise nil.
+ def build_order(row, merchant_ids_by_reference)
+ merchant_id = merchant_ids_by_reference[row['merchant_reference']]
+ return unless merchant_id
+
+ order_amount_in_cents = (row['amount'].to_f * 100).to_i
+ Order.new(
+ merchant_id:,
+ amount: order_amount_in_cents,
+ created_at: Date.parse(row['created_at'])
+ )
+ end
+
+ # Performs the actual bulk insertion of orders into the database.
+ #
+ # @param orders [Array] An array of order instances to be imported.
+ def bulk_insert_orders(orders)
+ Order.import orders
+ orders.clear
+ end
+end
diff --git a/app/views/layouts/mailer.html.erb b/app/views/layouts/mailer.html.erb
new file mode 100644
index 0000000..cbd34d2
--- /dev/null
+++ b/app/views/layouts/mailer.html.erb
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+
+ <%= yield %>
+
+
diff --git a/app/views/layouts/mailer.text.erb b/app/views/layouts/mailer.text.erb
new file mode 100644
index 0000000..37f0bdd
--- /dev/null
+++ b/app/views/layouts/mailer.text.erb
@@ -0,0 +1 @@
+<%= yield %>
diff --git a/app/workers/disbursement_worker.rb b/app/workers/disbursement_worker.rb
new file mode 100644
index 0000000..d0dba94
--- /dev/null
+++ b/app/workers/disbursement_worker.rb
@@ -0,0 +1,187 @@
+class DisbursementWorker
+ include Sidekiq::Worker
+
+ def perform
+ Merchant.find_each do |merchant|
+ process_disbursements_for(merchant)
+ end
+ end
+
+ private
+
+ # Initiates the disbursement process for a given merchant.
+ #
+ # @param merchant [Merchant] The merchant for whom disbursements are being processed.
+ def process_disbursements_for(merchant)
+ oldest_order_date = oldest_unprocessed_order_date_for(merchant)
+ return unless oldest_order_date
+
+ date_iterator_for(merchant.disbursement_frequency, oldest_order_date) do |start_date, end_date|
+ disburse_for_date_range(merchant, start_date, end_date)
+ end
+ end
+
+ # Processes disbursements for orders within a specific date range.
+ #
+ # @param merchant [Merchant] The merchant for whom disbursements are being processed.
+ # @param start_date [Date] The beginning of the date range.
+ # @param end_date [Date] The end of the date range.
+ def disburse_for_date_range(merchant, start_date, end_date)
+ orders = fetch_unprocessed_orders_for(merchant, start_date, end_date)
+ total_amount_cents = orders.sum(:amount)
+ monthly_fee_cents = calculate_monthly_fee_for(merchant, start_date)
+
+ if amount_or_fee_to_disburse?(total_amount_cents, monthly_fee_cents)
+ create_and_link_disbursement(merchant, orders, total_amount_cents, end_date, monthly_fee_cents)
+ end
+ end
+
+ # Calculates the monthly fee for a merchant based on their transactions.
+ #
+ # @param merchant [Merchant] The merchant for which the monthly fee is calculated.
+ # @param date [Date] The reference date for calculating the monthly fee.
+ # @return [Integer] The amount to be charged as the monthly fee in cents.
+ def calculate_monthly_fee_for(merchant, date)
+ return 0 unless eligible_for_monthly_fee?(merchant.disbursement_frequency, date)
+
+ last_month_fee = total_fees_for_month(merchant, date.last_month)
+ [merchant.minimum_monthly_fee_cents - last_month_fee, 0].max
+ end
+
+ # Calculates the total fees accrued by a merchant for a specific month based on their disbursements.
+ #
+ # This method fetches all the disbursements for the merchant within the given month's range and sums up the fee_cents from each disbursement.
+ #
+ # @param merchant [Merchant] The merchant for whom the fees need to be calculated.
+ # @param date [Date] Any date within the month for which total fees are being calculated.
+ # The method will use this date to determine the beginning and end of the month.
+ # @return [Integer] The total fee in cents for the specified month.
+ def total_fees_for_month(merchant, date)
+ date_range = date.beginning_of_month..date.end_of_month
+ merchant.disbursements.where(disbursed_on: date_range).sum(:fee_cents)
+ end
+
+
+ # Determines if a merchant is eligible for a monthly fee based on their disbursement frequency and a given date.
+ #
+ # A merchant with a 'DAILY' disbursement frequency is eligible on the first day of the month,
+ # while a merchant with a 'WEEKLY' disbursement frequency is eligible during the first seven days of the month.
+ #
+ # @param disbursement_frequency [String] The merchant's disbursement frequency ('DAILY' or 'WEEKLY').
+ # @param date [Date] The date to check eligibility against.
+ # @return [Boolean] True if the merchant is eligible for a monthly fee, otherwise false.
+ def eligible_for_monthly_fee?(disbursement_frequency, date)
+ (disbursement_frequency == 'DAILY' && date.day == 1) ||
+ (disbursement_frequency == 'WEEKLY' && date.day <= 7)
+ end
+
+
+ # Fetches unprocessed orders for a merchant within a given date range.
+ #
+ # @param merchant [Merchant] The relevant merchant.
+ # @param start_date [Date] The beginning of the date range.
+ # @param end_date [Date] The end of the date range.
+ # @return [ActiveRecord::Relation] A collection of orders.
+ def fetch_unprocessed_orders_for(merchant, start_date, end_date)
+ merchant.orders.where(disbursement_id: nil, created_at: start_date..end_date)
+ end
+
+ # Creates a disbursement and links it with the relevant orders.
+ #
+ # @param merchant [Merchant] The relevant merchant.
+ # @param orders [ActiveRecord::Relation] A collection of orders.
+ # @param amount_cents [Integer] The total amount in cents.
+ # @param disbursed_on [Date] The date the disbursement is being made.
+ # @param monthly_fee [Integer] The monthly fee in cents.
+ def create_and_link_disbursement(merchant, orders, amount_cents, disbursed_on, monthly_fee)
+ fee_cents = calculate_disbursement_fee(amount_cents).cents
+ disbursement = create_disbursement(merchant, amount_cents, fee_cents, disbursed_on, monthly_fee)
+ orders.update_all(disbursement_id: disbursement.id)
+ end
+
+ # Iterates through dates based on a specified disbursement frequency.
+ #
+ # @param frequency [String] The disbursement frequency ("DAILY" or "WEEKLY").
+ # @param start_date [Date] The starting date.
+ def date_iterator_for(frequency, start_date)
+ case frequency
+ when 'DAILY'
+ daily_iterator(start_date) { |s_date, e_date| yield s_date, e_date }
+ when 'WEEKLY'
+ weekly_iterator(start_date) { |s_date, e_date| yield s_date, e_date }
+ end
+ end
+
+ # Iterates through each day from the start date until yesterday.
+ #
+ # @param start_date [Date] The starting date.
+ def daily_iterator(start_date)
+ (start_date..Date.yesterday).each do |date|
+ yield date.beginning_of_day, date.end_of_day
+ end
+ end
+
+ # Iterates through each week starting from the given date until the current week's start.
+ #
+ # @param start_date [Date] The starting date.
+ def weekly_iterator(start_date)
+ current_week_start = Date.today.beginning_of_week
+ while start_date < current_week_start
+ yield start_date, start_date.end_of_week.end_of_day
+ start_date += 7.days
+ end
+ end
+
+ # Fee calculation methods
+
+ # Calculates the disbursement fee for a given amount.
+ #
+ # @param amount_cents [Integer] The amount in cents for which the fee is being calculated.
+ # @return [Money] The calculated fee.
+ def calculate_disbursement_fee(amount_cents)
+ percentage = case amount_cents
+ when 0...5000 then 0.01
+ when 5000...30000 then 0.0095
+ else 0.0085
+ end
+
+ Money.new((amount_cents * percentage).ceil)
+ end
+
+ # Utility methods
+
+ # Determines the oldest order date for a merchant that hasn't been processed.
+ #
+ # @param merchant [Merchant] The relevant merchant.
+ # @return [Date, nil] The oldest unprocessed order date or nil if no orders found.
+ def oldest_unprocessed_order_date_for(merchant)
+ merchant.orders.where(disbursement_id: nil).order(:created_at).first&.created_at&.to_date
+ end
+
+ # Checks if there's an amount or fee to be disbursed.
+ #
+ # @param amount_cents [Integer] The amount in cents.
+ # @param monthly_fee_cents [Integer] The monthly fee in cents.
+ # @return [Boolean] True if there's an amount or fee to disburse, otherwise false.
+ def amount_or_fee_to_disburse?(amount_cents, monthly_fee_cents)
+ amount_cents.positive? || monthly_fee_cents.positive?
+ end
+
+ # Creates a disbursement record.
+ #
+ # @param merchant [Merchant] The relevant merchant.
+ # @param amount_cents [Integer] The disbursement amount in cents.
+ # @param fee_cents [Integer] The fee in cents.
+ # @param disbursed_on [Date] The date the disbursement is being made.
+ # @param monthly_fee [Integer] The monthly fee in cents.
+ # @return [Disbursement] The created disbursement record.
+ def create_disbursement(merchant, amount_cents, fee_cents, disbursed_on, monthly_fee)
+ Disbursement.create!(
+ merchant: merchant,
+ amount_cents: amount_cents - fee_cents,
+ fee_cents: fee_cents,
+ monthly_fee_cents: monthly_fee,
+ disbursed_on: disbursed_on
+ )
+ end
+end
diff --git a/bin/bundle b/bin/bundle
new file mode 100755
index 0000000..42c7fd7
--- /dev/null
+++ b/bin/bundle
@@ -0,0 +1,109 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+#
+# This file was generated by Bundler.
+#
+# The application 'bundle' is installed as part of a gem, and
+# this file is here to facilitate running it.
+#
+
+require "rubygems"
+
+m = Module.new do
+ module_function
+
+ def invoked_as_script?
+ File.expand_path($0) == File.expand_path(__FILE__)
+ end
+
+ def env_var_version
+ ENV["BUNDLER_VERSION"]
+ end
+
+ def cli_arg_version
+ return unless invoked_as_script? # don't want to hijack other binstubs
+ return unless "update".start_with?(ARGV.first || " ") # must be running `bundle update`
+ bundler_version = nil
+ update_index = nil
+ ARGV.each_with_index do |a, i|
+ if update_index && update_index.succ == i && a =~ Gem::Version::ANCHORED_VERSION_PATTERN
+ bundler_version = a
+ end
+ next unless a =~ /\A--bundler(?:[= ](#{Gem::Version::VERSION_PATTERN}))?\z/
+ bundler_version = $1
+ update_index = i
+ end
+ bundler_version
+ end
+
+ def gemfile
+ gemfile = ENV["BUNDLE_GEMFILE"]
+ return gemfile if gemfile && !gemfile.empty?
+
+ File.expand_path("../Gemfile", __dir__)
+ end
+
+ def lockfile
+ lockfile =
+ case File.basename(gemfile)
+ when "gems.rb" then gemfile.sub(/\.rb$/, ".locked")
+ else "#{gemfile}.lock"
+ end
+ File.expand_path(lockfile)
+ end
+
+ def lockfile_version
+ return unless File.file?(lockfile)
+ lockfile_contents = File.read(lockfile)
+ return unless lockfile_contents =~ /\n\nBUNDLED WITH\n\s{2,}(#{Gem::Version::VERSION_PATTERN})\n/
+ Regexp.last_match(1)
+ end
+
+ def bundler_requirement
+ @bundler_requirement ||=
+ env_var_version ||
+ cli_arg_version ||
+ bundler_requirement_for(lockfile_version)
+ end
+
+ def bundler_requirement_for(version)
+ return "#{Gem::Requirement.default}.a" unless version
+
+ bundler_gem_version = Gem::Version.new(version)
+
+ bundler_gem_version.approximate_recommendation
+ end
+
+ def load_bundler!
+ ENV["BUNDLE_GEMFILE"] ||= gemfile
+
+ activate_bundler
+ end
+
+ def activate_bundler
+ gem_error = activation_error_handling do
+ gem "bundler", bundler_requirement
+ end
+ return if gem_error.nil?
+ require_error = activation_error_handling do
+ require "bundler/version"
+ end
+ return if require_error.nil? && Gem::Requirement.new(bundler_requirement).satisfied_by?(Gem::Version.new(Bundler::VERSION))
+ warn "Activating bundler (#{bundler_requirement}) failed:\n#{gem_error.message}\n\nTo install the version of bundler this project requires, run `gem install bundler -v '#{bundler_requirement}'`"
+ exit 42
+ end
+
+ def activation_error_handling
+ yield
+ nil
+ rescue StandardError, LoadError => e
+ e
+ end
+end
+
+m.load_bundler!
+
+if m.invoked_as_script?
+ load Gem.bin_path("bundler", "bundle")
+end
diff --git a/bin/rails b/bin/rails
new file mode 100755
index 0000000..efc0377
--- /dev/null
+++ b/bin/rails
@@ -0,0 +1,4 @@
+#!/usr/bin/env ruby
+APP_PATH = File.expand_path("../config/application", __dir__)
+require_relative "../config/boot"
+require "rails/commands"
diff --git a/bin/rake b/bin/rake
new file mode 100755
index 0000000..4fbf10b
--- /dev/null
+++ b/bin/rake
@@ -0,0 +1,4 @@
+#!/usr/bin/env ruby
+require_relative "../config/boot"
+require "rake"
+Rake.application.run
diff --git a/bin/setup b/bin/setup
new file mode 100755
index 0000000..ec47b79
--- /dev/null
+++ b/bin/setup
@@ -0,0 +1,33 @@
+#!/usr/bin/env ruby
+require "fileutils"
+
+# path to your application root.
+APP_ROOT = File.expand_path("..", __dir__)
+
+def system!(*args)
+ system(*args) || abort("\n== Command #{args} failed ==")
+end
+
+FileUtils.chdir APP_ROOT do
+ # This script is a way to set up or update your development environment automatically.
+ # This script is idempotent, so that you can run it at any time and get an expectable outcome.
+ # Add necessary setup steps to this file.
+
+ puts "== Installing dependencies =="
+ system! "gem install bundler --conservative"
+ system("bundle check") || system!("bundle install")
+
+ # puts "\n== Copying sample files =="
+ # unless File.exist?("config/database.yml")
+ # FileUtils.cp "config/database.yml.sample", "config/database.yml"
+ # end
+
+ puts "\n== Preparing database =="
+ system! "bin/rails db:prepare"
+
+ puts "\n== Removing old logs and tempfiles =="
+ system! "bin/rails log:clear tmp:clear"
+
+ puts "\n== Restarting application server =="
+ system! "bin/rails restart"
+end
diff --git a/config.ru b/config.ru
new file mode 100644
index 0000000..4a3c09a
--- /dev/null
+++ b/config.ru
@@ -0,0 +1,6 @@
+# This file is used by Rack-based servers to start the application.
+
+require_relative "config/environment"
+
+run Rails.application
+Rails.application.load_server
diff --git a/config/application.rb b/config/application.rb
new file mode 100644
index 0000000..1309a0a
--- /dev/null
+++ b/config/application.rb
@@ -0,0 +1,35 @@
+require_relative "boot"
+
+require "rails/all"
+
+# Require the gems listed in Gemfile, including any gems
+# you've limited to :test, :development, or :production.
+Bundler.require(*Rails.groups)
+
+module Sequra
+ class Application < Rails::Application
+ # Initialize configuration defaults for originally generated Rails version.
+ config.load_defaults 7.0
+
+ # Configuration for the application, engines, and railties goes here.
+ #
+ # These settings can be overridden in specific environments using the files
+ # in config/environments, which are processed later.
+ #
+ # config.time_zone = "Central Time (US & Canada)"
+ # config.eager_load_paths << Rails.root.join("extras")
+
+ # Only loads a smaller set of middleware suitable for API only apps.
+ # Middleware like session, flash, cookies can be added back manually.
+ # Skip views, helpers and assets when generating a new resource.
+ config.api_only = true
+
+ config.active_job.queue_adapter = :sidekiq
+
+ # This also configures session_options for use below
+ config.session_store :cookie_store, key: '_interslice_session'
+ # Required for all session management (regardless of session_store)
+ config.middleware.use ActionDispatch::Cookies
+ config.middleware.use config.session_store, config.session_options
+ end
+end
diff --git a/config/boot.rb b/config/boot.rb
new file mode 100644
index 0000000..988a5dd
--- /dev/null
+++ b/config/boot.rb
@@ -0,0 +1,4 @@
+ENV["BUNDLE_GEMFILE"] ||= File.expand_path("../Gemfile", __dir__)
+
+require "bundler/setup" # Set up gems listed in the Gemfile.
+require "bootsnap/setup" # Speed up boot time by caching expensive operations.
diff --git a/config/cable.yml b/config/cable.yml
new file mode 100644
index 0000000..91a528f
--- /dev/null
+++ b/config/cable.yml
@@ -0,0 +1,10 @@
+development:
+ adapter: async
+
+test:
+ adapter: test
+
+production:
+ adapter: redis
+ url: <%= ENV.fetch("REDIS_URL") { "redis://localhost:6379/1" } %>
+ channel_prefix: sequra_production
diff --git a/config/credentials.yml.enc b/config/credentials.yml.enc
new file mode 100644
index 0000000..eef109c
--- /dev/null
+++ b/config/credentials.yml.enc
@@ -0,0 +1 @@
+vr0hCH74H5a0s0h41/cL7CVimNHEmirzxI4Jk0/fDNDs3OZeKEDFQNwH8bUUdjJFQsFTF1pSR4t2Dq6di614aylmq00IPzrP/zLJW2w4hANPy1Qyf2WOBw/Bdza7+TiueS/Xf09xPoDmy/NzRkOv7EXm4L4wciNq5x4JeS/1kZ5ST4PTL+b6coK17s+oHYhStgFMwssB9eCYkT5Na6hUwwPpXas+RCpBGg/TnoYQ3ONp+AJUWOe3Aqe5rlYiwcxuUVDWCHZ8OjM9h3xsLSY2OFDDChexMNIqKgKvH+l8oiKlawbyJhFaxxtvJD4kKshDo9wP7iR9ICzKynsuq9/EtaRYzRrnzLzzhOSq3wOXEmfENsHHf78UGza5K9PQNxOEP0lhBKaAyHEnlfcz8tuFkfjUWGSrjaAq6IS2--luWx+aV6CeuB5O3E--qqK2nw/YhRESPbVayt7T3w==
\ No newline at end of file
diff --git a/config/database.yml b/config/database.yml
new file mode 100644
index 0000000..fcba57f
--- /dev/null
+++ b/config/database.yml
@@ -0,0 +1,25 @@
+# SQLite. Versions 3.8.0 and up are supported.
+# gem install sqlite3
+#
+# Ensure the SQLite 3 gem is defined in your Gemfile
+# gem "sqlite3"
+#
+default: &default
+ adapter: sqlite3
+ pool: <%= ENV.fetch("RAILS_MAX_THREADS") { 5 } %>
+ timeout: 5000
+
+development:
+ <<: *default
+ database: db/development.sqlite3
+
+# Warning: The database defined as "test" will be erased and
+# re-generated from your development database when you run "rake".
+# Do not set this db to the same as development or production.
+test:
+ <<: *default
+ database: db/test.sqlite3
+
+production:
+ <<: *default
+ database: db/production.sqlite3
diff --git a/config/environment.rb b/config/environment.rb
new file mode 100644
index 0000000..cac5315
--- /dev/null
+++ b/config/environment.rb
@@ -0,0 +1,5 @@
+# Load the Rails application.
+require_relative "application"
+
+# Initialize the Rails application.
+Rails.application.initialize!
diff --git a/config/environments/development.rb b/config/environments/development.rb
new file mode 100644
index 0000000..3d6b073
--- /dev/null
+++ b/config/environments/development.rb
@@ -0,0 +1,65 @@
+require "active_support/core_ext/integer/time"
+
+Rails.application.configure do
+ # Settings specified here will take precedence over those in config/application.rb.
+
+ # In the development environment your application's code is reloaded any time
+ # it changes. This slows down response time but is perfect for development
+ # since you don't have to restart the web server when you make code changes.
+ config.cache_classes = false
+
+ # Do not eager load code on boot.
+ config.eager_load = false
+
+ # Show full error reports.
+ config.consider_all_requests_local = true
+
+ # Enable server timing
+ config.server_timing = true
+
+ # Enable/disable caching. By default caching is disabled.
+ # Run rails dev:cache to toggle caching.
+ if Rails.root.join("tmp/caching-dev.txt").exist?
+ config.cache_store = :memory_store
+ config.public_file_server.headers = {
+ "Cache-Control" => "public, max-age=#{2.days.to_i}"
+ }
+ else
+ config.action_controller.perform_caching = false
+
+ config.cache_store = :null_store
+ end
+
+ # Store uploaded files on the local file system (see config/storage.yml for options).
+ config.active_storage.service = :local
+
+ # Don't care if the mailer can't send.
+ config.action_mailer.raise_delivery_errors = false
+
+ config.action_mailer.perform_caching = false
+
+ # Print deprecation notices to the Rails logger.
+ config.active_support.deprecation = :log
+
+ # Raise exceptions for disallowed deprecations.
+ config.active_support.disallowed_deprecation = :raise
+
+ # Tell Active Support which deprecation messages to disallow.
+ config.active_support.disallowed_deprecation_warnings = []
+
+ # Raise an error on page load if there are pending migrations.
+ config.active_record.migration_error = :page_load
+
+ # Highlight code that triggered database queries in logs.
+ config.active_record.verbose_query_logs = true
+
+
+ # Raises error for missing translations.
+ # config.i18n.raise_on_missing_translations = true
+
+ # Annotate rendered view with file names.
+ # config.action_view.annotate_rendered_view_with_filenames = true
+
+ # Uncomment if you wish to allow Action Cable access from any origin.
+ # config.action_cable.disable_request_forgery_protection = true
+end
diff --git a/config/environments/production.rb b/config/environments/production.rb
new file mode 100644
index 0000000..390f876
--- /dev/null
+++ b/config/environments/production.rb
@@ -0,0 +1,86 @@
+require "active_support/core_ext/integer/time"
+
+Rails.application.configure do
+ # Settings specified here will take precedence over those in config/application.rb.
+
+ # Code is not reloaded between requests.
+ config.cache_classes = true
+
+ # Eager load code on boot. This eager loads most of Rails and
+ # your application in memory, allowing both threaded web servers
+ # and those relying on copy on write to perform better.
+ # Rake tasks automatically ignore this option for performance.
+ config.eager_load = true
+
+ # Full error reports are disabled and caching is turned on.
+ config.consider_all_requests_local = false
+
+ # Ensures that a master key has been made available in either ENV["RAILS_MASTER_KEY"]
+ # or in config/master.key. This key is used to decrypt credentials (and other encrypted files).
+ # config.require_master_key = true
+
+ # Disable serving static files from the `/public` folder by default since
+ # Apache or NGINX already handles this.
+ config.public_file_server.enabled = ENV["RAILS_SERVE_STATIC_FILES"].present?
+
+ # Enable serving of images, stylesheets, and JavaScripts from an asset server.
+ # config.asset_host = "http://assets.example.com"
+
+ # Specifies the header that your server uses for sending files.
+ # config.action_dispatch.x_sendfile_header = "X-Sendfile" # for Apache
+ # config.action_dispatch.x_sendfile_header = "X-Accel-Redirect" # for NGINX
+
+ # Store uploaded files on the local file system (see config/storage.yml for options).
+ config.active_storage.service = :local
+
+ # Mount Action Cable outside main process or domain.
+ # config.action_cable.mount_path = nil
+ # config.action_cable.url = "wss://example.com/cable"
+ # config.action_cable.allowed_request_origins = [ "http://example.com", /http:\/\/example.*/ ]
+
+ # Force all access to the app over SSL, use Strict-Transport-Security, and use secure cookies.
+ # config.force_ssl = true
+
+ # Include generic and useful information about system operation, but avoid logging too much
+ # information to avoid inadvertent exposure of personally identifiable information (PII).
+ config.log_level = :info
+
+ # Prepend all log lines with the following tags.
+ config.log_tags = [ :request_id ]
+
+ # Use a different cache store in production.
+ # config.cache_store = :mem_cache_store
+
+ # Use a real queuing backend for Active Job (and separate queues per environment).
+ # config.active_job.queue_adapter = :resque
+ # config.active_job.queue_name_prefix = "sequra_production"
+
+ config.action_mailer.perform_caching = false
+
+ # Ignore bad email addresses and do not raise email delivery errors.
+ # Set this to true and configure the email server for immediate delivery to raise delivery errors.
+ # config.action_mailer.raise_delivery_errors = false
+
+ # Enable locale fallbacks for I18n (makes lookups for any locale fall back to
+ # the I18n.default_locale when a translation cannot be found).
+ config.i18n.fallbacks = true
+
+ # Don't log any deprecations.
+ config.active_support.report_deprecations = false
+
+ # Use default logging formatter so that PID and timestamp are not suppressed.
+ config.log_formatter = ::Logger::Formatter.new
+
+ # Use a different logger for distributed setups.
+ # require "syslog/logger"
+ # config.logger = ActiveSupport::TaggedLogging.new(Syslog::Logger.new "app-name")
+
+ if ENV["RAILS_LOG_TO_STDOUT"].present?
+ logger = ActiveSupport::Logger.new(STDOUT)
+ logger.formatter = config.log_formatter
+ config.logger = ActiveSupport::TaggedLogging.new(logger)
+ end
+
+ # Do not dump schema after migrations.
+ config.active_record.dump_schema_after_migration = false
+end
diff --git a/config/environments/test.rb b/config/environments/test.rb
new file mode 100644
index 0000000..6ea4d1e
--- /dev/null
+++ b/config/environments/test.rb
@@ -0,0 +1,60 @@
+require "active_support/core_ext/integer/time"
+
+# The test environment is used exclusively to run your application's
+# test suite. You never need to work with it otherwise. Remember that
+# your test database is "scratch space" for the test suite and is wiped
+# and recreated between test runs. Don't rely on the data there!
+
+Rails.application.configure do
+ # Settings specified here will take precedence over those in config/application.rb.
+
+ # Turn false under Spring and add config.action_view.cache_template_loading = true.
+ config.cache_classes = true
+
+ # Eager loading loads your whole application. When running a single test locally,
+ # this probably isn't necessary. It's a good idea to do in a continuous integration
+ # system, or in some way before deploying your code.
+ config.eager_load = ENV["CI"].present?
+
+ # Configure public file server for tests with Cache-Control for performance.
+ config.public_file_server.enabled = true
+ config.public_file_server.headers = {
+ "Cache-Control" => "public, max-age=#{1.hour.to_i}"
+ }
+
+ # Show full error reports and disable caching.
+ config.consider_all_requests_local = true
+ config.action_controller.perform_caching = false
+ config.cache_store = :null_store
+
+ # Raise exceptions instead of rendering exception templates.
+ config.action_dispatch.show_exceptions = false
+
+ # Disable request forgery protection in test environment.
+ config.action_controller.allow_forgery_protection = false
+
+ # Store uploaded files on the local file system in a temporary directory.
+ config.active_storage.service = :test
+
+ config.action_mailer.perform_caching = false
+
+ # Tell Action Mailer not to deliver emails to the real world.
+ # The :test delivery method accumulates sent emails in the
+ # ActionMailer::Base.deliveries array.
+ config.action_mailer.delivery_method = :test
+
+ # Print deprecation notices to the stderr.
+ config.active_support.deprecation = :stderr
+
+ # Raise exceptions for disallowed deprecations.
+ config.active_support.disallowed_deprecation = :raise
+
+ # Tell Active Support which deprecation messages to disallow.
+ config.active_support.disallowed_deprecation_warnings = []
+
+ # Raises error for missing translations.
+ # config.i18n.raise_on_missing_translations = true
+
+ # Annotate rendered view with file names.
+ # config.action_view.annotate_rendered_view_with_filenames = true
+end
diff --git a/config/initializers/cors.rb b/config/initializers/cors.rb
new file mode 100644
index 0000000..e5a82f1
--- /dev/null
+++ b/config/initializers/cors.rb
@@ -0,0 +1,16 @@
+# Be sure to restart your server when you modify this file.
+
+# Avoid CORS issues when API is called from the frontend app.
+# Handle Cross-Origin Resource Sharing (CORS) in order to accept cross-origin AJAX requests.
+
+# Read more: https://github.com/cyu/rack-cors
+
+# Rails.application.config.middleware.insert_before 0, Rack::Cors do
+# allow do
+# origins "example.com"
+#
+# resource "*",
+# headers: :any,
+# methods: [:get, :post, :put, :patch, :delete, :options, :head]
+# end
+# end
diff --git a/config/initializers/filter_parameter_logging.rb b/config/initializers/filter_parameter_logging.rb
new file mode 100644
index 0000000..adc6568
--- /dev/null
+++ b/config/initializers/filter_parameter_logging.rb
@@ -0,0 +1,8 @@
+# Be sure to restart your server when you modify this file.
+
+# Configure parameters to be filtered from the log file. Use this to limit dissemination of
+# sensitive information. See the ActiveSupport::ParameterFilter documentation for supported
+# notations and behaviors.
+Rails.application.config.filter_parameters += [
+ :passw, :secret, :token, :_key, :crypt, :salt, :certificate, :otp, :ssn
+]
diff --git a/config/initializers/inflections.rb b/config/initializers/inflections.rb
new file mode 100644
index 0000000..3860f65
--- /dev/null
+++ b/config/initializers/inflections.rb
@@ -0,0 +1,16 @@
+# Be sure to restart your server when you modify this file.
+
+# Add new inflection rules using the following format. Inflections
+# are locale specific, and you may define rules for as many different
+# locales as you wish. All of these examples are active by default:
+# ActiveSupport::Inflector.inflections(:en) do |inflect|
+# inflect.plural /^(ox)$/i, "\\1en"
+# inflect.singular /^(ox)en/i, "\\1"
+# inflect.irregular "person", "people"
+# inflect.uncountable %w( fish sheep )
+# end
+
+# These inflection rules are supported but not enabled by default:
+# ActiveSupport::Inflector.inflections(:en) do |inflect|
+# inflect.acronym "RESTful"
+# end
diff --git a/config/initializers/money.rb b/config/initializers/money.rb
new file mode 100644
index 0000000..d027dca
--- /dev/null
+++ b/config/initializers/money.rb
@@ -0,0 +1,116 @@
+# encoding : utf-8
+
+MoneyRails.configure do |config|
+
+ # To set the default currency
+ #
+ # config.default_currency = :usd
+ config.default_currency = :eur
+
+ # Set default bank object
+ #
+ # Example:
+ # config.default_bank = EuCentralBank.new
+
+ # Add exchange rates to current money bank object.
+ # (The conversion rate refers to one direction only)
+ #
+ # Example:
+ # config.add_rate "USD", "CAD", 1.24515
+ # config.add_rate "CAD", "USD", 0.803115
+
+ # To handle the inclusion of validations for monetized fields
+ # The default value is true
+ #
+ # config.include_validations = true
+
+ # Default ActiveRecord migration configuration values for columns:
+ #
+ # config.amount_column = { prefix: '', # column name prefix
+ # postfix: '_cents', # column name postfix
+ # column_name: nil, # full column name (overrides prefix, postfix and accessor name)
+ # type: :integer, # column type
+ # present: true, # column will be created
+ # null: false, # other options will be treated as column options
+ # default: 0
+ # }
+ #
+ # config.currency_column = { prefix: '',
+ # postfix: '_currency',
+ # column_name: nil,
+ # type: :string,
+ # present: true,
+ # null: false,
+ # default: 'USD'
+ # }
+
+ # Register a custom currency
+ #
+ # Example:
+ # config.register_currency = {
+ # priority: 1,
+ # iso_code: "EU4",
+ # name: "Euro with subunit of 4 digits",
+ # symbol: "€",
+ # symbol_first: true,
+ # subunit: "Subcent",
+ # subunit_to_unit: 10000,
+ # thousands_separator: ".",
+ # decimal_mark: ","
+ # }
+
+ # Specify a rounding mode
+ # Any one of:
+ #
+ # BigDecimal::ROUND_UP,
+ # BigDecimal::ROUND_DOWN,
+ # BigDecimal::ROUND_HALF_UP,
+ # BigDecimal::ROUND_HALF_DOWN,
+ # BigDecimal::ROUND_HALF_EVEN,
+ # BigDecimal::ROUND_CEILING,
+ # BigDecimal::ROUND_FLOOR
+ #
+ # set to BigDecimal::ROUND_HALF_EVEN by default
+ #
+ config.rounding_mode = BigDecimal::ROUND_HALF_EVEN
+
+ # Set default money format globally.
+ # Default value is nil meaning "ignore this option".
+ # Example:
+ #
+ # config.default_format = {
+ # no_cents_if_whole: nil,
+ # symbol: nil,
+ # sign_before_symbol: nil
+ # }
+
+ # If you would like to use I18n localization (formatting depends on the
+ # locale):
+ config.locale_backend = :i18n
+ #
+ # Example (using default localization from rails-i18n):
+ #
+ # I18n.locale = :en
+ # Money.new(10_000_00, 'USD').format # => $10,000.00
+ # I18n.locale = :es
+ # Money.new(10_000_00, 'USD').format # => $10.000,00
+ #
+ # For the legacy behaviour of "per currency" localization (formatting depends
+ # only on currency):
+ # config.locale_backend = :currency
+ #
+ # Example:
+ # Money.new(10_000_00, 'USD').format # => $10,000.00
+ # Money.new(10_000_00, 'EUR').format # => €10.000,00
+ #
+ # In case you don't need localization and would like to use default values
+ # (can be redefined using config.default_format):
+ # config.locale_backend = nil
+
+ # Set default raise_error_on_money_parsing option
+ # It will be raise error if assigned different currency
+ # The default value is false
+ #
+ # Example:
+ # config.raise_error_on_money_parsing = false
+end
diff --git a/config/initializers/sidekiq.rb b/config/initializers/sidekiq.rb
new file mode 100644
index 0000000..ed75d5d
--- /dev/null
+++ b/config/initializers/sidekiq.rb
@@ -0,0 +1,18 @@
+require 'sidekiq'
+require 'sidekiq-scheduler'
+
+Sidekiq.configure_server do |config|
+ config.redis = { url: 'redis://localhost:6379/0' }
+end
+
+Sidekiq.configure_server do |config|
+ config.on(:startup) do
+ Sidekiq.schedule = YAML.load_file(File.expand_path('../../sidekiq_schedule.yml', __FILE__))
+ Sidekiq::Scheduler.reload_schedule!
+ end
+end
+
+
+Sidekiq.configure_client do |config|
+ config.redis = { url: 'redis://localhost:6379/0' }
+end
diff --git a/config/locales/en.yml b/config/locales/en.yml
new file mode 100644
index 0000000..8ca56fc
--- /dev/null
+++ b/config/locales/en.yml
@@ -0,0 +1,33 @@
+# Files in the config/locales directory are used for internationalization
+# and are automatically loaded by Rails. If you want to use locales other
+# than English, add the necessary files in this directory.
+#
+# To use the locales, use `I18n.t`:
+#
+# I18n.t "hello"
+#
+# In views, this is aliased to just `t`:
+#
+# <%= t("hello") %>
+#
+# To use a different locale, set it with `I18n.locale`:
+#
+# I18n.locale = :es
+#
+# This would use the information in config/locales/es.yml.
+#
+# The following keys must be escaped otherwise they will not be retrieved by
+# the default I18n backend:
+#
+# true, false, on, off, yes, no
+#
+# Instead, surround them with single quotes.
+#
+# en:
+# "true": "foo"
+#
+# To learn more, please read the Rails Internationalization guide
+# available at https://guides.rubyonrails.org/i18n.html.
+
+en:
+ hello: "Hello world"
diff --git a/config/puma.rb b/config/puma.rb
new file mode 100644
index 0000000..daaf036
--- /dev/null
+++ b/config/puma.rb
@@ -0,0 +1,43 @@
+# Puma can serve each request in a thread from an internal thread pool.
+# The `threads` method setting takes two numbers: a minimum and maximum.
+# Any libraries that use thread pools should be configured to match
+# the maximum value specified for Puma. Default is set to 5 threads for minimum
+# and maximum; this matches the default thread size of Active Record.
+#
+max_threads_count = ENV.fetch("RAILS_MAX_THREADS") { 5 }
+min_threads_count = ENV.fetch("RAILS_MIN_THREADS") { max_threads_count }
+threads min_threads_count, max_threads_count
+
+# Specifies the `worker_timeout` threshold that Puma will use to wait before
+# terminating a worker in development environments.
+#
+worker_timeout 3600 if ENV.fetch("RAILS_ENV", "development") == "development"
+
+# Specifies the `port` that Puma will listen on to receive requests; default is 3000.
+#
+port ENV.fetch("PORT") { 3000 }
+
+# Specifies the `environment` that Puma will run in.
+#
+environment ENV.fetch("RAILS_ENV") { "development" }
+
+# Specifies the `pidfile` that Puma will use.
+pidfile ENV.fetch("PIDFILE") { "tmp/pids/server.pid" }
+
+# Specifies the number of `workers` to boot in clustered mode.
+# Workers are forked web server processes. If using threads and workers together
+# the concurrency of the application would be max `threads` * `workers`.
+# Workers do not work on JRuby or Windows (both of which do not support
+# processes).
+#
+# workers ENV.fetch("WEB_CONCURRENCY") { 2 }
+
+# Use the `preload_app!` method when specifying a `workers` number.
+# This directive tells Puma to first boot the application and load code
+# before forking the application. This takes advantage of Copy On Write
+# process behavior so workers use less memory.
+#
+# preload_app!
+
+# Allow puma to be restarted by `bin/rails restart` command.
+plugin :tmp_restart
diff --git a/config/routes.rb b/config/routes.rb
new file mode 100644
index 0000000..6fc4664
--- /dev/null
+++ b/config/routes.rb
@@ -0,0 +1,9 @@
+Rails.application.routes.draw do
+ # Define your application routes per the DSL in https://guides.rubyonrails.org/routing.html
+
+ # Defines the root path route ("/")
+ # root "articles#index"
+
+ require 'sidekiq/web'
+ mount Sidekiq::Web => '/sidekiq'
+end
diff --git a/config/sidekiq.yml b/config/sidekiq.yml
new file mode 100644
index 0000000..8b097bd
--- /dev/null
+++ b/config/sidekiq.yml
@@ -0,0 +1,4 @@
+---
+:concurrency: 5
+:queues:
+ - default
diff --git a/config/sidekiq_schedule.yml b/config/sidekiq_schedule.yml
new file mode 100644
index 0000000..e67ae8d
--- /dev/null
+++ b/config/sidekiq_schedule.yml
@@ -0,0 +1,3 @@
+DisbursementWorker:
+ cron: '0 7 * * *' # Every day at 7 am
+ class: 'DisbursementWorker'
diff --git a/config/storage.yml b/config/storage.yml
new file mode 100644
index 0000000..4942ab6
--- /dev/null
+++ b/config/storage.yml
@@ -0,0 +1,34 @@
+test:
+ service: Disk
+ root: <%= Rails.root.join("tmp/storage") %>
+
+local:
+ service: Disk
+ root: <%= Rails.root.join("storage") %>
+
+# Use bin/rails credentials:edit to set the AWS secrets (as aws:access_key_id|secret_access_key)
+# amazon:
+# service: S3
+# access_key_id: <%= Rails.application.credentials.dig(:aws, :access_key_id) %>
+# secret_access_key: <%= Rails.application.credentials.dig(:aws, :secret_access_key) %>
+# region: us-east-1
+# bucket: your_own_bucket-<%= Rails.env %>
+
+# Remember not to checkin your GCS keyfile to a repository
+# google:
+# service: GCS
+# project: your_project
+# credentials: <%= Rails.root.join("path/to/gcs.keyfile") %>
+# bucket: your_own_bucket-<%= Rails.env %>
+
+# Use bin/rails credentials:edit to set the Azure Storage secret (as azure_storage:storage_access_key)
+# microsoft:
+# service: AzureStorage
+# storage_account_name: your_account_name
+# storage_access_key: <%= Rails.application.credentials.dig(:azure_storage, :storage_access_key) %>
+# container: your_container_name-<%= Rails.env %>
+
+# mirror:
+# service: Mirror
+# primary: local
+# mirrors: [ amazon, google, microsoft ]
diff --git a/db/migrate/20230826212849_create_merchants.rb b/db/migrate/20230826212849_create_merchants.rb
new file mode 100644
index 0000000..0d24229
--- /dev/null
+++ b/db/migrate/20230826212849_create_merchants.rb
@@ -0,0 +1,18 @@
+# frozen_string_literal: true
+
+class CreateMerchants < ActiveRecord::Migration[7.0]
+ def change
+ create_table :merchants do |t|
+ t.string :reference, null: false, unique: true
+ t.string :email, null: false, unique: true
+ t.date :live_on
+ t.string :disbursement_frequency
+ t.integer :minimum_monthly_fee_cents
+ t.string :currency
+
+ t.timestamps
+ end
+ add_index :merchants, :reference, unique: true
+ add_index :merchants, :email, unique: true
+ end
+end
diff --git a/db/migrate/20230826222229_create_orders.rb b/db/migrate/20230826222229_create_orders.rb
new file mode 100644
index 0000000..a920d9b
--- /dev/null
+++ b/db/migrate/20230826222229_create_orders.rb
@@ -0,0 +1,12 @@
+# frozen_string_literal: true
+
+class CreateOrders < ActiveRecord::Migration[7.0]
+ def change
+ create_table :orders do |t|
+ t.references :merchant, null: false, foreign_key: true
+ t.integer :amount
+ t.references :disbursement, foreign_key: true
+ t.timestamps
+ end
+ end
+end
diff --git a/db/migrate/20230827165927_create_disbursements.rb b/db/migrate/20230827165927_create_disbursements.rb
new file mode 100644
index 0000000..644a459
--- /dev/null
+++ b/db/migrate/20230827165927_create_disbursements.rb
@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+class CreateDisbursements <