A => .dockerignore +16 -0
@@ 1,16 @@
+.git
+tmp
+!tmp/pids
+log
+public/assets
+public/packs
+.bundle
+
+db/*.sqlite3
+db/*.sqlite3-*
+
+storage
+config/master.key
+config/credentials/*.key
+
+node_modules
A => .gitattributes +7 -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
A => .gitignore +36 -0
@@ 1,36 @@
+# 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
+.gems/*
+
+# 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
+
+/public/assets
+
+# Ignore master key for decrypting credentials and more.
+/config/master.key
A => .rubocop.yml +168 -0
@@ 1,168 @@
+AllCops:
+ TargetRubyVersion: 2.5
+ NewCops: enable
+ Exclude:
+ - db/**/*
+ - lib/tasks/fly.rake
+ - bin/rails
+ - bin/rake
+ - bin/importmap
+ - bin/bundle
+ - bin/setup
+ - config/boot.rb
+ - config.ru
+
+Style/RescueModifier:
+ Enabled: false
+
+Metrics/ClassLength:
+ CountAsOne:
+ - heredoc
+ Exclude:
+ - test/*
+
+Metrics/MethodLength:
+ Max: 50
+ Exclude:
+ - test/*
+
+Metrics/BlockLength:
+ ExcludedMethods:
+ - route
+ - "on"
+ - with_shopify_session
+ Exclude:
+ - test/*
+ - config/**/*
+
+Metrics/AbcSize:
+ Max: 80
+ Exclude:
+ - test/*
+
+Metrics/CyclomaticComplexity:
+ Max: 15
+
+Metrics/PerceivedComplexity:
+ Max: 15
+
+Metrics/ParameterLists:
+ Max: 6
+
+Style/OptionalBooleanParameter:
+ Enabled: false
+
+Naming/MethodParameterName:
+ AllowNamesEndingInNumbers: false
+ AllowedNames:
+ - io
+ - m
+ - e
+ - q
+ - s
+ - k
+ - v
+ - ex
+ - tx
+ - id
+ - iq
+ - db
+ - to
+
+Layout/IndentationStyle:
+ Enabled: false
+ EnforcedStyle: tabs
+ IndentationWidth: 2
+
+Layout/IndentationWidth:
+ Width: 1 # one tab
+
+Layout/LineLength:
+ Max: 120
+ Exclude:
+ - Gemfile
+
+Layout/EndAlignment:
+ EnforcedStyleAlignWith: start_of_line
+
+Layout/SpaceAroundEqualsInParameterDefault:
+ EnforcedStyle: no_space
+
+Layout/AccessModifierIndentation:
+ EnforcedStyle: outdent
+
+Layout/FirstParameterIndentation:
+ EnforcedStyle: consistent
+
+Layout/MultilineMethodCallIndentation:
+ EnforcedStyle: indented
+
+Style/AccessModifierDeclarations:
+ Enabled: false
+
+Style/ArrayCoercion:
+ Enabled: false
+
+Style/StringLiterals:
+ EnforcedStyle: double_quotes
+
+Style/NumericLiterals:
+ Enabled: false
+
+Style/SymbolArray:
+ EnforcedStyle: brackets
+
+Style/WordArray:
+ EnforcedStyle: brackets
+
+Style/Documentation:
+ Enabled: false
+
+Style/DoubleNegation:
+ EnforcedStyle: allowed_in_returns
+ Enabled: false
+
+Style/PerlBackrefs:
+ Enabled: false
+
+Style/SpecialGlobalVars:
+ EnforcedStyle: use_perl_names
+
+Style/RegexpLiteral:
+ EnforcedStyle: slashes
+ AllowInnerSlashes: true
+
+Lint/OutOfRangeRegexpRef:
+ Enabled: false
+
+Lint/MissingSuper:
+ Enabled: false
+
+Style/BlockDelimiters:
+ EnforcedStyle: semantic
+ AllowBracesOnProceduralOneLiners: true
+ ProceduralMethods:
+ - execute_command
+ - new
+
+Style/MultilineBlockChain:
+ Enabled: false
+
+Layout/FirstArgumentIndentation:
+ EnforcedStyle: consistent
+
+Layout/FirstArrayElementIndentation:
+ EnforcedStyle: consistent
+
+Style/FormatString:
+ EnforcedStyle: percent
+
+Style/FormatStringToken:
+ EnforcedStyle: unannotated
+
+Style/FrozenStringLiteralComment:
+ Exclude:
+ - forms/**/*.rb
+
+Naming/AccessorMethodName:
+ Enabled: false
A => .ruby-version +1 -0
A => COPYING +661 -0
@@ 1,661 @@
+ GNU AFFERO GENERAL PUBLIC LICENSE
+ Version 3, 19 November 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc. <http://fsf.org/>
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+ Preamble
+
+ The GNU Affero General Public License is a free, copyleft license for
+software and other kinds of works, specifically designed to ensure
+cooperation with the community in the case of network server software.
+
+ The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works. By contrast,
+our General Public Licenses are intended to guarantee your freedom to
+share and change all versions of a program--to make sure it remains free
+software for all its users.
+
+ When we speak of free software, we are referring to freedom, not
+price. Our General Public Licenses are designed to make sure that you
+have the freedom to distribute copies of free software (and charge for
+them if you wish), that you receive source code or can get it if you
+want it, that you can change the software or use pieces of it in new
+free programs, and that you know you can do these things.
+
+ Developers that use our General Public Licenses protect your rights
+with two steps: (1) assert copyright on the software, and (2) offer
+you this License which gives you legal permission to copy, distribute
+and/or modify the software.
+
+ A secondary benefit of defending all users' freedom is that
+improvements made in alternate versions of the program, if they
+receive widespread use, become available for other developers to
+incorporate. Many developers of free software are heartened and
+encouraged by the resulting cooperation. However, in the case of
+software used on network servers, this result may fail to come about.
+The GNU General Public License permits making a modified version and
+letting the public access it on a server without ever releasing its
+source code to the public.
+
+ The GNU Affero General Public License is designed specifically to
+ensure that, in such cases, the modified source code becomes available
+to the community. It requires the operator of a network server to
+provide the source code of the modified version running there to the
+users of that server. Therefore, public use of a modified version, on
+a publicly accessible server, gives the public access to the source
+code of the modified version.
+
+ An older license, called the Affero General Public License and
+published by Affero, was designed to accomplish similar goals. This is
+a different license, not a version of the Affero GPL, but Affero has
+released a new version of the Affero GPL which permits relicensing under
+this license.
+
+ The precise terms and conditions for copying, distribution and
+modification follow.
+
+ TERMS AND CONDITIONS
+
+ 0. Definitions.
+
+ "This License" refers to version 3 of the GNU Affero General Public License.
+
+ "Copyright" also means copyright-like laws that apply to other kinds of
+works, such as semiconductor masks.
+
+ "The Program" refers to any copyrightable work licensed under this
+License. Each licensee is addressed as "you". "Licensees" and
+"recipients" may be individuals or organizations.
+
+ To "modify" a work means to copy from or adapt all or part of the work
+in a fashion requiring copyright permission, other than the making of an
+exact copy. The resulting work is called a "modified version" of the
+earlier work or a work "based on" the earlier work.
+
+ A "covered work" means either the unmodified Program or a work based
+on the Program.
+
+ To "propagate" a work means to do anything with it that, without
+permission, would make you directly or secondarily liable for
+infringement under applicable copyright law, except executing it on a
+computer or modifying a private copy. Propagation includes copying,
+distribution (with or without modification), making available to the
+public, and in some countries other activities as well.
+
+ To "convey" a work means any kind of propagation that enables other
+parties to make or receive copies. Mere interaction with a user through
+a computer network, with no transfer of a copy, is not conveying.
+
+ An interactive user interface displays "Appropriate Legal Notices"
+to the extent that it includes a convenient and prominently visible
+feature that (1) displays an appropriate copyright notice, and (2)
+tells the user that there is no warranty for the work (except to the
+extent that warranties are provided), that licensees may convey the
+work under this License, and how to view a copy of this License. If
+the interface presents a list of user commands or options, such as a
+menu, a prominent item in the list meets this criterion.
+
+ 1. Source Code.
+
+ The "source code" for a work means the preferred form of the work
+for making modifications to it. "Object code" means any non-source
+form of a work.
+
+ A "Standard Interface" means an interface that either is an official
+standard defined by a recognized standards body, or, in the case of
+interfaces specified for a particular programming language, one that
+is widely used among developers working in that language.
+
+ The "System Libraries" of an executable work include anything, other
+than the work as a whole, that (a) is included in the normal form of
+packaging a Major Component, but which is not part of that Major
+Component, and (b) serves only to enable use of the work with that
+Major Component, or to implement a Standard Interface for which an
+implementation is available to the public in source code form. A
+"Major Component", in this context, means a major essential component
+(kernel, window system, and so on) of the specific operating system
+(if any) on which the executable work runs, or a compiler used to
+produce the work, or an object code interpreter used to run it.
+
+ The "Corresponding Source" for a work in object code form means all
+the source code needed to generate, install, and (for an executable
+work) run the object code and to modify the work, including scripts to
+control those activities. However, it does not include the work's
+System Libraries, or general-purpose tools or generally available free
+programs which are used unmodified in performing those activities but
+which are not part of the work. For example, Corresponding Source
+includes interface definition files associated with source files for
+the work, and the source code for shared libraries and dynamically
+linked subprograms that the work is specifically designed to require,
+such as by intimate data communication or control flow between those
+subprograms and other parts of the work.
+
+ The Corresponding Source need not include anything that users
+can regenerate automatically from other parts of the Corresponding
+Source.
+
+ The Corresponding Source for a work in source code form is that
+same work.
+
+ 2. Basic Permissions.
+
+ All rights granted under this License are granted for the term of
+copyright on the Program, and are irrevocable provided the stated
+conditions are met. This License explicitly affirms your unlimited
+permission to run the unmodified Program. The output from running a
+covered work is covered by this License only if the output, given its
+content, constitutes a covered work. This License acknowledges your
+rights of fair use or other equivalent, as provided by copyright law.
+
+ You may make, run and propagate covered works that you do not
+convey, without conditions so long as your license otherwise remains
+in force. You may convey covered works to others for the sole purpose
+of having them make modifications exclusively for you, or provide you
+with facilities for running those works, provided that you comply with
+the terms of this License in conveying all material for which you do
+not control copyright. Those thus making or running the covered works
+for you must do so exclusively on your behalf, under your direction
+and control, on terms that prohibit them from making any copies of
+your copyrighted material outside their relationship with you.
+
+ Conveying under any other circumstances is permitted solely under
+the conditions stated below. Sublicensing is not allowed; section 10
+makes it unnecessary.
+
+ 3. Protecting Users' Legal Rights From Anti-Circumvention Law.
+
+ No covered work shall be deemed part of an effective technological
+measure under any applicable law fulfilling obligations under article
+11 of the WIPO copyright treaty adopted on 20 December 1996, or
+similar laws prohibiting or restricting circumvention of such
+measures.
+
+ When you convey a covered work, you waive any legal power to forbid
+circumvention of technological measures to the extent such circumvention
+is effected by exercising rights under this License with respect to
+the covered work, and you disclaim any intention to limit operation or
+modification of the work as a means of enforcing, against the work's
+users, your or third parties' legal rights to forbid circumvention of
+technological measures.
+
+ 4. Conveying Verbatim Copies.
+
+ You may convey verbatim copies of the Program's source code as you
+receive it, in any medium, provided that you conspicuously and
+appropriately publish on each copy an appropriate copyright notice;
+keep intact all notices stating that this License and any
+non-permissive terms added in accord with section 7 apply to the code;
+keep intact all notices of the absence of any warranty; and give all
+recipients a copy of this License along with the Program.
+
+ You may charge any price or no price for each copy that you convey,
+and you may offer support or warranty protection for a fee.
+
+ 5. Conveying Modified Source Versions.
+
+ You may convey a work based on the Program, or the modifications to
+produce it from the Program, in the form of source code under the
+terms of section 4, provided that you also meet all of these conditions:
+
+ a) The work must carry prominent notices stating that you modified
+ it, and giving a relevant date.
+
+ b) The work must carry prominent notices stating that it is
+ released under this License and any conditions added under section
+ 7. This requirement modifies the requirement in section 4 to
+ "keep intact all notices".
+
+ c) You must license the entire work, as a whole, under this
+ License to anyone who comes into possession of a copy. This
+ License will therefore apply, along with any applicable section 7
+ additional terms, to the whole of the work, and all its parts,
+ regardless of how they are packaged. This License gives no
+ permission to license the work in any other way, but it does not
+ invalidate such permission if you have separately received it.
+
+ d) If the work has interactive user interfaces, each must display
+ Appropriate Legal Notices; however, if the Program has interactive
+ interfaces that do not display Appropriate Legal Notices, your
+ work need not make them do so.
+
+ A compilation of a covered work with other separate and independent
+works, which are not by their nature extensions of the covered work,
+and which are not combined with it such as to form a larger program,
+in or on a volume of a storage or distribution medium, is called an
+"aggregate" if the compilation and its resulting copyright are not
+used to limit the access or legal rights of the compilation's users
+beyond what the individual works permit. Inclusion of a covered work
+in an aggregate does not cause this License to apply to the other
+parts of the aggregate.
+
+ 6. Conveying Non-Source Forms.
+
+ You may convey a covered work in object code form under the terms
+of sections 4 and 5, provided that you also convey the
+machine-readable Corresponding Source under the terms of this License,
+in one of these ways:
+
+ a) Convey the object code in, or embodied in, a physical product
+ (including a physical distribution medium), accompanied by the
+ Corresponding Source fixed on a durable physical medium
+ customarily used for software interchange.
+
+ b) Convey the object code in, or embodied in, a physical product
+ (including a physical distribution medium), accompanied by a
+ written offer, valid for at least three years and valid for as
+ long as you offer spare parts or customer support for that product
+ model, to give anyone who possesses the object code either (1) a
+ copy of the Corresponding Source for all the software in the
+ product that is covered by this License, on a durable physical
+ medium customarily used for software interchange, for a price no
+ more than your reasonable cost of physically performing this
+ conveying of source, or (2) access to copy the
+ Corresponding Source from a network server at no charge.
+
+ c) Convey individual copies of the object code with a copy of the
+ written offer to provide the Corresponding Source. This
+ alternative is allowed only occasionally and noncommercially, and
+ only if you received the object code with such an offer, in accord
+ with subsection 6b.
+
+ d) Convey the object code by offering access from a designated
+ place (gratis or for a charge), and offer equivalent access to the
+ Corresponding Source in the same way through the same place at no
+ further charge. You need not require recipients to copy the
+ Corresponding Source along with the object code. If the place to
+ copy the object code is a network server, the Corresponding Source
+ may be on a different server (operated by you or a third party)
+ that supports equivalent copying facilities, provided you maintain
+ clear directions next to the object code saying where to find the
+ Corresponding Source. Regardless of what server hosts the
+ Corresponding Source, you remain obligated to ensure that it is
+ available for as long as needed to satisfy these requirements.
+
+ e) Convey the object code using peer-to-peer transmission, provided
+ you inform other peers where the object code and Corresponding
+ Source of the work are being offered to the general public at no
+ charge under subsection 6d.
+
+ A separable portion of the object code, whose source code is excluded
+from the Corresponding Source as a System Library, need not be
+included in conveying the object code work.
+
+ A "User Product" is either (1) a "consumer product", which means any
+tangible personal property which is normally used for personal, family,
+or household purposes, or (2) anything designed or sold for incorporation
+into a dwelling. In determining whether a product is a consumer product,
+doubtful cases shall be resolved in favor of coverage. For a particular
+product received by a particular user, "normally used" refers to a
+typical or common use of that class of product, regardless of the status
+of the particular user or of the way in which the particular user
+actually uses, or expects or is expected to use, the product. A product
+is a consumer product regardless of whether the product has substantial
+commercial, industrial or non-consumer uses, unless such uses represent
+the only significant mode of use of the product.
+
+ "Installation Information" for a User Product means any methods,
+procedures, authorization keys, or other information required to install
+and execute modified versions of a covered work in that User Product from
+a modified version of its Corresponding Source. The information must
+suffice to ensure that the continued functioning of the modified object
+code is in no case prevented or interfered with solely because
+modification has been made.
+
+ If you convey an object code work under this section in, or with, or
+specifically for use in, a User Product, and the conveying occurs as
+part of a transaction in which the right of possession and use of the
+User Product is transferred to the recipient in perpetuity or for a
+fixed term (regardless of how the transaction is characterized), the
+Corresponding Source conveyed under this section must be accompanied
+by the Installation Information. But this requirement does not apply
+if neither you nor any third party retains the ability to install
+modified object code on the User Product (for example, the work has
+been installed in ROM).
+
+ The requirement to provide Installation Information does not include a
+requirement to continue to provide support service, warranty, or updates
+for a work that has been modified or installed by the recipient, or for
+the User Product in which it has been modified or installed. Access to a
+network may be denied when the modification itself materially and
+adversely affects the operation of the network or violates the rules and
+protocols for communication across the network.
+
+ Corresponding Source conveyed, and Installation Information provided,
+in accord with this section must be in a format that is publicly
+documented (and with an implementation available to the public in
+source code form), and must require no special password or key for
+unpacking, reading or copying.
+
+ 7. Additional Terms.
+
+ "Additional permissions" are terms that supplement the terms of this
+License by making exceptions from one or more of its conditions.
+Additional permissions that are applicable to the entire Program shall
+be treated as though they were included in this License, to the extent
+that they are valid under applicable law. If additional permissions
+apply only to part of the Program, that part may be used separately
+under those permissions, but the entire Program remains governed by
+this License without regard to the additional permissions.
+
+ When you convey a copy of a covered work, you may at your option
+remove any additional permissions from that copy, or from any part of
+it. (Additional permissions may be written to require their own
+removal in certain cases when you modify the work.) You may place
+additional permissions on material, added by you to a covered work,
+for which you have or can give appropriate copyright permission.
+
+ Notwithstanding any other provision of this License, for material you
+add to a covered work, you may (if authorized by the copyright holders of
+that material) supplement the terms of this License with terms:
+
+ a) Disclaiming warranty or limiting liability differently from the
+ terms of sections 15 and 16 of this License; or
+
+ b) Requiring preservation of specified reasonable legal notices or
+ author attributions in that material or in the Appropriate Legal
+ Notices displayed by works containing it; or
+
+ c) Prohibiting misrepresentation of the origin of that material, or
+ requiring that modified versions of such material be marked in
+ reasonable ways as different from the original version; or
+
+ d) Limiting the use for publicity purposes of names of licensors or
+ authors of the material; or
+
+ e) Declining to grant rights under trademark law for use of some
+ trade names, trademarks, or service marks; or
+
+ f) Requiring indemnification of licensors and authors of that
+ material by anyone who conveys the material (or modified versions of
+ it) with contractual assumptions of liability to the recipient, for
+ any liability that these contractual assumptions directly impose on
+ those licensors and authors.
+
+ All other non-permissive additional terms are considered "further
+restrictions" within the meaning of section 10. If the Program as you
+received it, or any part of it, contains a notice stating that it is
+governed by this License along with a term that is a further
+restriction, you may remove that term. If a license document contains
+a further restriction but permits relicensing or conveying under this
+License, you may add to a covered work material governed by the terms
+of that license document, provided that the further restriction does
+not survive such relicensing or conveying.
+
+ If you add terms to a covered work in accord with this section, you
+must place, in the relevant source files, a statement of the
+additional terms that apply to those files, or a notice indicating
+where to find the applicable terms.
+
+ Additional terms, permissive or non-permissive, may be stated in the
+form of a separately written license, or stated as exceptions;
+the above requirements apply either way.
+
+ 8. Termination.
+
+ You may not propagate or modify a covered work except as expressly
+provided under this License. Any attempt otherwise to propagate or
+modify it is void, and will automatically terminate your rights under
+this License (including any patent licenses granted under the third
+paragraph of section 11).
+
+ However, if you cease all violation of this License, then your
+license from a particular copyright holder is reinstated (a)
+provisionally, unless and until the copyright holder explicitly and
+finally terminates your license, and (b) permanently, if the copyright
+holder fails to notify you of the violation by some reasonable means
+prior to 60 days after the cessation.
+
+ Moreover, your license from a particular copyright holder is
+reinstated permanently if the copyright holder notifies you of the
+violation by some reasonable means, this is the first time you have
+received notice of violation of this License (for any work) from that
+copyright holder, and you cure the violation prior to 30 days after
+your receipt of the notice.
+
+ Termination of your rights under this section does not terminate the
+licenses of parties who have received copies or rights from you under
+this License. If your rights have been terminated and not permanently
+reinstated, you do not qualify to receive new licenses for the same
+material under section 10.
+
+ 9. Acceptance Not Required for Having Copies.
+
+ You are not required to accept this License in order to receive or
+run a copy of the Program. Ancillary propagation of a covered work
+occurring solely as a consequence of using peer-to-peer transmission
+to receive a copy likewise does not require acceptance. However,
+nothing other than this License grants you permission to propagate or
+modify any covered work. These actions infringe copyright if you do
+not accept this License. Therefore, by modifying or propagating a
+covered work, you indicate your acceptance of this License to do so.
+
+ 10. Automatic Licensing of Downstream Recipients.
+
+ Each time you convey a covered work, the recipient automatically
+receives a license from the original licensors, to run, modify and
+propagate that work, subject to this License. You are not responsible
+for enforcing compliance by third parties with this License.
+
+ An "entity transaction" is a transaction transferring control of an
+organization, or substantially all assets of one, or subdividing an
+organization, or merging organizations. If propagation of a covered
+work results from an entity transaction, each party to that
+transaction who receives a copy of the work also receives whatever
+licenses to the work the party's predecessor in interest had or could
+give under the previous paragraph, plus a right to possession of the
+Corresponding Source of the work from the predecessor in interest, if
+the predecessor has it or can get it with reasonable efforts.
+
+ You may not impose any further restrictions on the exercise of the
+rights granted or affirmed under this License. For example, you may
+not impose a license fee, royalty, or other charge for exercise of
+rights granted under this License, and you may not initiate litigation
+(including a cross-claim or counterclaim in a lawsuit) alleging that
+any patent claim is infringed by making, using, selling, offering for
+sale, or importing the Program or any portion of it.
+
+ 11. Patents.
+
+ A "contributor" is a copyright holder who authorizes use under this
+License of the Program or a work on which the Program is based. The
+work thus licensed is called the contributor's "contributor version".
+
+ A contributor's "essential patent claims" are all patent claims
+owned or controlled by the contributor, whether already acquired or
+hereafter acquired, that would be infringed by some manner, permitted
+by this License, of making, using, or selling its contributor version,
+but do not include claims that would be infringed only as a
+consequence of further modification of the contributor version. For
+purposes of this definition, "control" includes the right to grant
+patent sublicenses in a manner consistent with the requirements of
+this License.
+
+ Each contributor grants you a non-exclusive, worldwide, royalty-free
+patent license under the contributor's essential patent claims, to
+make, use, sell, offer for sale, import and otherwise run, modify and
+propagate the contents of its contributor version.
+
+ In the following three paragraphs, a "patent license" is any express
+agreement or commitment, however denominated, not to enforce a patent
+(such as an express permission to practice a patent or covenant not to
+sue for patent infringement). To "grant" such a patent license to a
+party means to make such an agreement or commitment not to enforce a
+patent against the party.
+
+ If you convey a covered work, knowingly relying on a patent license,
+and the Corresponding Source of the work is not available for anyone
+to copy, free of charge and under the terms of this License, through a
+publicly available network server or other readily accessible means,
+then you must either (1) cause the Corresponding Source to be so
+available, or (2) arrange to deprive yourself of the benefit of the
+patent license for this particular work, or (3) arrange, in a manner
+consistent with the requirements of this License, to extend the patent
+license to downstream recipients. "Knowingly relying" means you have
+actual knowledge that, but for the patent license, your conveying the
+covered work in a country, or your recipient's use of the covered work
+in a country, would infringe one or more identifiable patents in that
+country that you have reason to believe are valid.
+
+ If, pursuant to or in connection with a single transaction or
+arrangement, you convey, or propagate by procuring conveyance of, a
+covered work, and grant a patent license to some of the parties
+receiving the covered work authorizing them to use, propagate, modify
+or convey a specific copy of the covered work, then the patent license
+you grant is automatically extended to all recipients of the covered
+work and works based on it.
+
+ A patent license is "discriminatory" if it does not include within
+the scope of its coverage, prohibits the exercise of, or is
+conditioned on the non-exercise of one or more of the rights that are
+specifically granted under this License. You may not convey a covered
+work if you are a party to an arrangement with a third party that is
+in the business of distributing software, under which you make payment
+to the third party based on the extent of your activity of conveying
+the work, and under which the third party grants, to any of the
+parties who would receive the covered work from you, a discriminatory
+patent license (a) in connection with copies of the covered work
+conveyed by you (or copies made from those copies), or (b) primarily
+for and in connection with specific products or compilations that
+contain the covered work, unless you entered into that arrangement,
+or that patent license was granted, prior to 28 March 2007.
+
+ Nothing in this License shall be construed as excluding or limiting
+any implied license or other defenses to infringement that may
+otherwise be available to you under applicable patent law.
+
+ 12. No Surrender of Others' Freedom.
+
+ If conditions are imposed on you (whether by court order, agreement or
+otherwise) that contradict the conditions of this License, they do not
+excuse you from the conditions of this License. If you cannot convey a
+covered work so as to satisfy simultaneously your obligations under this
+License and any other pertinent obligations, then as a consequence you may
+not convey it at all. For example, if you agree to terms that obligate you
+to collect a royalty for further conveying from those to whom you convey
+the Program, the only way you could satisfy both those terms and this
+License would be to refrain entirely from conveying the Program.
+
+ 13. Remote Network Interaction; Use with the GNU General Public License.
+
+ Notwithstanding any other provision of this License, if you modify the
+Program, your modified version must prominently offer all users
+interacting with it remotely through a computer network (if your version
+supports such interaction) an opportunity to receive the Corresponding
+Source of your version by providing access to the Corresponding Source
+from a network server at no charge, through some standard or customary
+means of facilitating copying of software. This Corresponding Source
+shall include the Corresponding Source for any work covered by version 3
+of the GNU General Public License that is incorporated pursuant to the
+following paragraph.
+
+ Notwithstanding any other provision of this License, you have
+permission to link or combine any covered work with a work licensed
+under version 3 of the GNU General Public License into a single
+combined work, and to convey the resulting work. The terms of this
+License will continue to apply to the part which is the covered work,
+but the work with which it is combined will remain governed by version
+3 of the GNU General Public License.
+
+ 14. Revised Versions of this License.
+
+ The Free Software Foundation may publish revised and/or new versions of
+the GNU Affero General Public License from time to time. Such new versions
+will be similar in spirit to the present version, but may differ in detail to
+address new problems or concerns.
+
+ Each version is given a distinguishing version number. If the
+Program specifies that a certain numbered version of the GNU Affero General
+Public License "or any later version" applies to it, you have the
+option of following the terms and conditions either of that numbered
+version or of any later version published by the Free Software
+Foundation. If the Program does not specify a version number of the
+GNU Affero General Public License, you may choose any version ever published
+by the Free Software Foundation.
+
+ If the Program specifies that a proxy can decide which future
+versions of the GNU Affero General Public License can be used, that proxy's
+public statement of acceptance of a version permanently authorizes you
+to choose that version for the Program.
+
+ Later license versions may give you additional or different
+permissions. However, no additional obligations are imposed on any
+author or copyright holder as a result of your choosing to follow a
+later version.
+
+ 15. Disclaimer of Warranty.
+
+ THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
+APPLICABLE LAW. EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
+HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
+OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+PURPOSE. THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
+IS WITH YOU. SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
+ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
+
+ 16. Limitation of Liability.
+
+ IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
+WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
+THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
+GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
+USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
+DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
+PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
+EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGES.
+
+ 17. Interpretation of Sections 15 and 16.
+
+ If the disclaimer of warranty and limitation of liability provided
+above cannot be given local legal effect according to their terms,
+reviewing courts shall apply local law that most closely approximates
+an absolute waiver of all civil liability in connection with the
+Program, unless a warranty or assumption of liability accompanies a
+copy of the Program in return for a fee.
+
+ END OF TERMS AND CONDITIONS
+
+ How to Apply These Terms to Your New Programs
+
+ If you develop a new program, and you want it to be of the greatest
+possible use to the public, the best way to achieve this is to make it
+free software which everyone can redistribute and change under these terms.
+
+ To do so, attach the following notices to the program. It is safest
+to attach them to the start of each source file to most effectively
+state the exclusion of warranty; and each file should have at least
+the "copyright" line and a pointer to where the full notice is found.
+
+ <one line to give the program's name and a brief idea of what it does.>
+ Copyright (C) <year> <name of author>
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU Affero General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ This program is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU Affero General Public License for more details.
+
+ You should have received a copy of the GNU Affero General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
+
+Also add information on how to contact you by electronic and paper mail.
+
+ If your software can interact with users remotely through a computer
+network, you should also make sure that it provides a way for users to
+get its source. For example, if your program is a web application, its
+interface could display a "Source" link that leads users to an archive
+of the code. There are many ways you could offer source, and different
+solutions will be better for different programs; see section 13 for the
+specific requirements.
+
+ You should also get your employer (if you work as a programmer) or school,
+if any, to sign a "copyright disclaimer" for the program, if necessary.
+For more information on this, and how to apply and follow the GNU AGPL, see
+<http://www.gnu.org/licenses/>.
A => Dockerfile +116 -0
@@ 1,116 @@
+# syntax = docker/dockerfile:experimental
+
+# Dockerfile used to build a deployable image for a Rails application.
+# Adjust as required.
+#
+# Common adjustments you may need to make over time:
+# * Modify version numbers for Ruby, Bundler, and other products.
+# * Add library packages needed at build time for your gems, node modules.
+# * Add deployment packages needed by your application
+# * Add (often fake) secrets needed to compile your assets
+
+#######################################################################
+
+# Learn more about the chosen Ruby stack, Fullstaq Ruby, here:
+# https://github.com/evilmartians/fullstaq-ruby-docker.
+#
+# We recommend using the highest patch level for better security and
+# performance.
+
+ARG RUBY_VERSION=2.7.4
+ARG VARIANT=jemalloc-bullseye-slim
+FROM quay.io/evl.ms/fullstaq-ruby:${RUBY_VERSION}-${VARIANT} as base
+
+LABEL fly_launch_runtime="rails"
+
+ARG BUNDLER_VERSION=2.2.5
+
+ARG RAILS_ENV=production
+ENV RAILS_ENV=${RAILS_ENV}
+
+ENV RAILS_SERVE_STATIC_FILES true
+ENV RAILS_LOG_TO_STDOUT true
+
+ARG BUNDLE_WITHOUT=development:test
+ARG BUNDLE_PATH=vendor/bundle
+ENV BUNDLE_PATH ${BUNDLE_PATH}
+ENV BUNDLE_WITHOUT ${BUNDLE_WITHOUT}
+
+RUN mkdir /app
+WORKDIR /app
+RUN mkdir -p tmp/pids
+
+RUN gem update --system --no-document && \
+ gem install -N bundler -v ${BUNDLER_VERSION}
+
+#######################################################################
+
+# install packages only needed at build time
+
+FROM base as build_deps
+
+ARG BUILD_PACKAGES="git build-essential libpq-dev wget vim curl gzip xz-utils libsqlite3-dev libssl-dev"
+ENV BUILD_PACKAGES ${BUILD_PACKAGES}
+
+RUN --mount=type=cache,id=dev-apt-cache,sharing=locked,target=/var/cache/apt \
+ --mount=type=cache,id=dev-apt-lib,sharing=locked,target=/var/lib/apt \
+ apt-get update -qq && \
+ apt-get install --no-install-recommends -y ${BUILD_PACKAGES} \
+ && rm -rf /var/lib/apt/lists /var/cache/apt/archives
+
+#######################################################################
+
+# install gems
+
+FROM build_deps as gems
+
+COPY Gemfile* ./
+RUN bundle install && rm -rf vendor/bundle/ruby/*/cache
+
+#######################################################################
+
+# install deployment packages
+
+FROM base
+
+ARG DEPLOY_PACKAGES="file vim curl gzip libsqlite3-0 libssl1.1"
+ENV DEPLOY_PACKAGES=${DEPLOY_PACKAGES}
+
+RUN --mount=type=cache,id=prod-apt-cache,sharing=locked,target=/var/cache/apt \
+ --mount=type=cache,id=prod-apt-lib,sharing=locked,target=/var/lib/apt \
+ apt-get update -qq && \
+ apt-get install --no-install-recommends -y \
+ ${DEPLOY_PACKAGES} \
+ && rm -rf /var/lib/apt/lists /var/cache/apt/archives
+
+# copy installed gems
+COPY --from=gems /app /app
+COPY --from=gems /usr/lib/fullstaq-ruby/versions /usr/lib/fullstaq-ruby/versions
+COPY --from=gems /usr/local/bundle /usr/local/bundle
+
+#######################################################################
+
+# Deploy your application
+COPY . .
+
+# Adjust binstubs to run on Linux and set current working directory
+RUN chmod +x /app/bin/* && \
+ sed -i 's/ruby.exe\r*/ruby/' /app/bin/* && \
+ sed -i '/^#!/aDir.chdir File.expand_path("..", __dir__)' /app/bin/*
+
+# The following enable assets to precompile on the build server. Adjust
+# as necessary. If no combination works for you, see:
+# https://fly.io/docs/rails/getting-started/existing/#access-to-environment-variables-at-build-time
+ENV SECRET_KEY_BASE 1
+# ENV AWS_ACCESS_KEY_ID=1
+# ENV AWS_SECRET_ACCESS_KEY=1
+
+# Run build task defined in lib/tasks/fly.rake
+ARG BUILD_COMMAND="bin/rails fly:build"
+RUN ${BUILD_COMMAND}
+
+# Default server start instructions. Generally Overridden by fly.toml.
+ENV PORT 8080
+ARG SERVER_COMMAND="bin/rails fly:server"
+ENV SERVER_COMMAND ${SERVER_COMMAND}
+CMD ${SERVER_COMMAND}
A => Gemfile +45 -0
@@ 1,45 @@
+# frozen_string_literal: true
+
+source "https://rubygems.org"
+
+# Bundle edge Rails instead: gem "rails", github: "rails/rails", branch: "main"
+gem "rails", "~> 7.0.4"
+
+# The original asset pipeline for Rails [https://github.com/rails/sprockets-rails]
+gem "sprockets-rails"
+
+gem "countries"
+gem "faraday"
+gem "faraday-retry"
+gem "faraday-typhoeus"
+gem "shopify_app"
+
+# 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"
+
+# Reduces boot times through caching; required in config/boot.rb
+gem "bootsnap", require: false
+
+# Use Sass to process CSS
+gem "sassc-rails"
+
+gem "importmap-rails"
+
+# Use Active Storage variants [https://guides.rubyonrails.org/active_storage_overview.html#transforming-images]
+# gem "image_processing", "~> 1.2"
+
+group :development, :test do
+ # See https://guides.rubyonrails.org/debugging_rails_applications.html#debugging-with-the-debug-gem
+ gem "debug"
+end
+
+group :development do
+ # Use console on exceptions pages [https://github.com/rails/web-console]
+ gem "web-console"
+
+ # Add speed badges [https://github.com/MiniProfiler/rack-mini-profiler]
+ # gem "rack-mini-profiler"
+end
A => Gemfile.lock +262 -0
@@ 1,262 @@
+GEM
+ remote: https://rubygems.org/
+ specs:
+ actioncable (7.0.4)
+ actionpack (= 7.0.4)
+ activesupport (= 7.0.4)
+ nio4r (~> 2.0)
+ websocket-driver (>= 0.6.1)
+ actionmailbox (7.0.4)
+ actionpack (= 7.0.4)
+ activejob (= 7.0.4)
+ activerecord (= 7.0.4)
+ activestorage (= 7.0.4)
+ activesupport (= 7.0.4)
+ mail (>= 2.7.1)
+ net-imap
+ net-pop
+ net-smtp
+ actionmailer (7.0.4)
+ actionpack (= 7.0.4)
+ actionview (= 7.0.4)
+ activejob (= 7.0.4)
+ activesupport (= 7.0.4)
+ mail (~> 2.5, >= 2.5.4)
+ net-imap
+ net-pop
+ net-smtp
+ rails-dom-testing (~> 2.0)
+ actionpack (7.0.4)
+ actionview (= 7.0.4)
+ activesupport (= 7.0.4)
+ rack (~> 2.0, >= 2.2.0)
+ rack-test (>= 0.6.3)
+ rails-dom-testing (~> 2.0)
+ rails-html-sanitizer (~> 1.0, >= 1.2.0)
+ actiontext (7.0.4)
+ actionpack (= 7.0.4)
+ activerecord (= 7.0.4)
+ activestorage (= 7.0.4)
+ activesupport (= 7.0.4)
+ globalid (>= 0.6.0)
+ nokogiri (>= 1.8.5)
+ actionview (7.0.4)
+ activesupport (= 7.0.4)
+ builder (~> 3.1)
+ erubi (~> 1.4)
+ rails-dom-testing (~> 2.0)
+ rails-html-sanitizer (~> 1.1, >= 1.2.0)
+ activejob (7.0.4)
+ activesupport (= 7.0.4)
+ globalid (>= 0.3.6)
+ activemodel (7.0.4)
+ activesupport (= 7.0.4)
+ activemodel-serializers-xml (1.0.2)
+ activemodel (> 5.x)
+ activesupport (> 5.x)
+ builder (~> 3.1)
+ activerecord (7.0.4)
+ activemodel (= 7.0.4)
+ activesupport (= 7.0.4)
+ activeresource (6.0.0)
+ activemodel (>= 6.0)
+ activemodel-serializers-xml (~> 1.0)
+ activesupport (>= 6.0)
+ activestorage (7.0.4)
+ actionpack (= 7.0.4)
+ activejob (= 7.0.4)
+ activerecord (= 7.0.4)
+ activesupport (= 7.0.4)
+ marcel (~> 1.0)
+ mini_mime (>= 1.1.0)
+ activesupport (7.0.4)
+ concurrent-ruby (~> 1.0, >= 1.0.2)
+ i18n (>= 1.6, < 2)
+ minitest (>= 5.1)
+ tzinfo (~> 2.0)
+ bindex (0.8.1)
+ bootsnap (1.14.0)
+ msgpack (~> 1.2)
+ browser_sniffer (2.1.0)
+ builder (3.2.4)
+ coderay (1.1.3)
+ concurrent-ruby (1.1.10)
+ countries (5.2.0)
+ unaccent (~> 0.3)
+ crass (1.0.6)
+ debug (1.6.3)
+ irb (>= 1.3.6)
+ reline (>= 0.3.1)
+ erubi (1.11.0)
+ ethon (0.16.0)
+ ffi (>= 1.15.0)
+ faraday (2.7.1)
+ faraday-net_http (>= 2.0, < 3.1)
+ ruby2_keywords (>= 0.0.4)
+ faraday-net_http (3.0.2)
+ faraday-retry (2.0.0)
+ faraday (~> 2.0)
+ faraday-typhoeus (1.0.0)
+ faraday (~> 2.0)
+ typhoeus (~> 1.4)
+ ffi (1.15.5)
+ globalid (1.0.0)
+ activesupport (>= 5.0)
+ hash_diff (1.1.1)
+ httparty (0.20.0)
+ mime-types (~> 3.0)
+ multi_xml (>= 0.5.2)
+ i18n (1.12.0)
+ concurrent-ruby (~> 1.0)
+ importmap-rails (1.1.5)
+ actionpack (>= 6.0.0)
+ railties (>= 6.0.0)
+ io-console (0.5.11)
+ irb (1.5.0)
+ reline (>= 0.3.0)
+ jwt (2.5.0)
+ loofah (2.19.0)
+ crass (~> 1.0.2)
+ nokogiri (>= 1.5.9)
+ mail (2.7.1)
+ mini_mime (>= 0.1.1)
+ marcel (1.0.2)
+ method_source (1.0.0)
+ mime-types (3.4.1)
+ mime-types-data (~> 3.2015)
+ mime-types-data (3.2022.0105)
+ mini_mime (1.1.2)
+ minitest (5.16.3)
+ msgpack (1.6.0)
+ multi_xml (0.6.0)
+ net-imap (0.3.1)
+ net-protocol
+ net-pop (0.1.2)
+ net-protocol
+ net-protocol (0.1.3)
+ timeout
+ net-smtp (0.3.3)
+ net-protocol
+ nio4r (2.5.8)
+ nokogiri (1.13.9-x86_64-linux)
+ racc (~> 1.4)
+ oj (3.13.23)
+ openssl (3.0.1)
+ pry (0.14.1)
+ coderay (~> 1.1)
+ method_source (~> 1.0)
+ puma (5.6.5)
+ nio4r (~> 2.0)
+ racc (1.6.0)
+ rack (2.2.4)
+ rack-test (2.0.2)
+ rack (>= 1.3)
+ rails (7.0.4)
+ actioncable (= 7.0.4)
+ actionmailbox (= 7.0.4)
+ actionmailer (= 7.0.4)
+ actionpack (= 7.0.4)
+ actiontext (= 7.0.4)
+ actionview (= 7.0.4)
+ activejob (= 7.0.4)
+ activemodel (= 7.0.4)
+ activerecord (= 7.0.4)
+ activestorage (= 7.0.4)
+ activesupport (= 7.0.4)
+ bundler (>= 1.15.0)
+ railties (= 7.0.4)
+ rails-dom-testing (2.0.3)
+ activesupport (>= 4.2.0)
+ nokogiri (>= 1.6)
+ rails-html-sanitizer (1.4.3)
+ loofah (~> 2.3)
+ railties (7.0.4)
+ actionpack (= 7.0.4)
+ activesupport (= 7.0.4)
+ method_source
+ rake (>= 12.2)
+ thor (~> 1.0)
+ zeitwerk (~> 2.5)
+ rake (13.0.6)
+ redirect_safely (1.0.0)
+ activemodel
+ reline (0.3.1)
+ io-console (~> 0.5)
+ ruby2_keywords (0.0.5)
+ sassc (2.4.0)
+ ffi (~> 1.9)
+ sassc-rails (2.1.2)
+ railties (>= 4.0.0)
+ sassc (>= 2.0)
+ sprockets (> 3.0)
+ sprockets-rails
+ tilt
+ securerandom (0.2.0)
+ shopify_api (12.2.1)
+ concurrent-ruby
+ hash_diff
+ httparty
+ jwt
+ oj
+ openssl
+ securerandom
+ sorbet-runtime
+ zeitwerk (~> 2.5)
+ shopify_app (21.2.0)
+ activeresource
+ browser_sniffer (~> 2.0)
+ jwt (>= 2.2.3)
+ rails (> 5.2.1)
+ redirect_safely (~> 1.0)
+ shopify_api (~> 12.2)
+ sprockets-rails (>= 2.0.0)
+ sorbet-runtime (0.5.10563)
+ sprockets (4.1.1)
+ concurrent-ruby (~> 1.0)
+ rack (> 1, < 3)
+ sprockets-rails (3.4.2)
+ actionpack (>= 5.2)
+ activesupport (>= 5.2)
+ sprockets (>= 3.0.0)
+ sqlite3 (1.5.4-x86_64-linux)
+ thor (1.2.1)
+ tilt (2.0.11)
+ timeout (0.3.0)
+ typhoeus (1.4.0)
+ ethon (>= 0.9.0)
+ tzinfo (2.0.5)
+ concurrent-ruby (~> 1.0)
+ unaccent (0.4.0)
+ web-console (4.2.0)
+ actionview (>= 6.0.0)
+ activemodel (>= 6.0.0)
+ bindex (>= 0.4.0)
+ railties (>= 6.0.0)
+ websocket-driver (0.7.5)
+ websocket-extensions (>= 0.1.0)
+ websocket-extensions (0.1.5)
+ zeitwerk (2.6.6)
+
+PLATFORMS
+ x86_64-linux
+
+DEPENDENCIES
+ bootsnap
+ countries
+ debug
+ faraday
+ faraday-retry
+ faraday-typhoeus
+ importmap-rails
+ pry
+ puma (~> 5.0)
+ rails (~> 7.0.4)
+ sassc-rails
+ shopify_app
+ sprockets-rails
+ sqlite3 (~> 1.4)
+ tzinfo-data
+ web-console
+
+BUNDLED WITH
+ 2.2.5
A => README.md +1 -0
@@ 1,1 @@
+Replacement for Whiplash Shopify integration that supports multi-location and markets.
A => Rakefile +8 -0
@@ 1,8 @@
+# frozen_string_literal: true
+
+# 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
A => app/assets/config/manifest.js +4 -0
@@ 1,4 @@
+//= link_tree ../images
+//= link_directory ../stylesheets .css
+//= link_tree ../../javascript .js
+//= link_tree ../../../vendor/javascript .js
A => app/assets/images/.keep +0 -0
A => app/assets/stylesheets/application.css +15 -0
@@ 1,15 @@
+/*
+ * This is a manifest file that'll be compiled into application.css, which will include all the files
+ * listed below.
+ *
+ * Any CSS (and SCSS, if configured) file within this directory, lib/assets/stylesheets, or any plugin's
+ * vendor/assets/stylesheets directory can be referenced here using a relative path.
+ *
+ * You're free to add application-wide styles to this file and they'll appear at the bottom of the
+ * compiled file so the styles you add here take precedence over styles defined in any other CSS
+ * files in this directory. Styles in this file should be added after the last require_* statement.
+ * It is generally better to create a new file per style scope.
+ *
+ *= require_tree .
+ *= require_self
+ */
A => app/channels/application_cable/channel.rb +6 -0
@@ 1,6 @@
+# frozen_string_literal: true
+
+module ApplicationCable
+ class Channel < ActionCable::Channel::Base
+ end
+end
A => app/channels/application_cable/connection.rb +6 -0
@@ 1,6 @@
+# frozen_string_literal: true
+
+module ApplicationCable
+ class Connection < ActionCable::Connection::Base
+ end
+end
A => app/controllers/application_controller.rb +4 -0
@@ 1,4 @@
+# frozen_string_literal: true
+
+class ApplicationController < ActionController::Base
+end
A => app/controllers/authenticated_controller.rb +5 -0
@@ 1,5 @@
+# frozen_string_literal: true
+
+class AuthenticatedController < ApplicationController
+ include ShopifyApp::Authenticated
+end
A => app/controllers/concerns/.keep +0 -0
A => app/controllers/fulfillment_controller.rb +55 -0
@@ 1,55 @@
+# frozen_string_literal: true
+
+class FulfillmentController < ApplicationController
+ skip_before_action :verify_authenticity_token
+ before_action :shop_and_service
+
+ def shop_and_service
+ shop_domain, _, whiplash_id = params[:id].rpartition("-")
+ @shop = Shop.find_by!(shopify_domain: shop_domain)
+ @service = @shop.fulfillment_services.find_by!(whiplash_id: whiplash_id)
+ end
+
+ def fetch_all_items(page: 1)
+ results = WHIPLASH_HTTP.get("items", { page: page, limit: 1000 }, "X-API-KEY" => @shop.whiplash_api_key).body
+ return results if results.empty?
+
+ results + fetch_all_items(page: page + 1)
+ end
+
+ def fetch_stock
+ item_ids = if params[:sku]
+ WHIPLASH_HTTP.get(
+ "items/sku/#{params[:sku]}",
+ nil,
+ "X-API-KEY" => @shop.whiplash_api_key
+ ).body.each_with_object({}) { |item, h| h[params[:sku]] = item["id"] }
+ else
+ Rails.cache.fetch("all_whiplash_items-#{@shop.id}", expires_in: 4.hours) do
+ fetch_all_items.each_with_object({}) { |item, h| h[item["sku"]] = item["id"] }
+ end
+ end
+
+ WHIPLASH_HTTP.in_parallel do
+ @requests = item_ids.transform_values { |item_id|
+ WHIPLASH_HTTP.get("items/#{item_id}/warehouse_quantities", nil, "X-API-KEY" => @shop.whiplash_api_key)
+ }
+ end
+
+ results = @requests.transform_values { |req|
+ req.body.find { |warehouse| warehouse["id"].to_s == @service.whiplash_id }&.dig("sellable_quantity") || 0
+ }
+
+ render json: results
+ end
+
+ def order_notification
+ req = ShopifyAPI::Webhooks::Request.new(
+ raw_body: request.raw_post,
+ headers: request.headers.to_h.merge("HTTP_X_SHOPIFY_TOPIC" => "fulfillment_order_notification")
+ )
+ raise "Invalid hmac" unless ShopifyAPI::Utils::HmacValidator.validate(req)
+
+ SyncAssignedOrdersJob.perform_later(@shop)
+ end
+end
A => app/controllers/home_controller.rb +50 -0
@@ 1,50 @@
+# frozen_string_literal: true
+
+class HomeController < ApplicationController
+ include ShopifyApp::EmbeddedApp
+ include ShopifyApp::RequireKnownShop
+ include ShopifyApp::ShopAccessScopesVerification
+
+ def index
+ response.set_header("X-Frame-Options", "ALLOW-FROM *")
+ response.set_header("Content-Security-Policy", "frame-ancestors 'self' *")
+
+ if ShopifyAPI::Context.embedded? && (!params[:embedded].present? || params[:embedded] != "1")
+ redirect_to(ShopifyAPI::Auth.embedded_app_url(params[:host]) + request.path, allow_other_host: true)
+ else
+ @shop_origin = current_shopify_domain
+ @host = params[:host]
+ @shop = Shop.find_by!(shopify_domain: @shop_origin)
+ return unless @shop.whiplash_api_key.present?
+
+ @shop.with_shopify_session do
+ any_whiplash_item_id = WHIPLASH_HTTP.get(
+ "items",
+ { limit: 1 },
+ "X-API-KEY" => @shop.whiplash_api_key
+ ).body.first["id"]
+ whiplash_warehouses = WHIPLASH_HTTP.get(
+ "items/#{any_whiplash_item_id}/warehouse_quantities",
+ nil,
+ "X-API-KEY" => @shop.whiplash_api_key
+ ).body
+ whiplash_warehouses.each do |warehouse|
+ next if @shop.fulfillment_services.find_by(whiplash_id: warehouse["id"])
+
+ service = ShopifyAPI::FulfillmentService.new
+ service.name = "Whiplash (#{warehouse['name']})"
+ service.fulfillment_orders_opt_in = true
+ service.callback_url =
+ "https://#{request.host_with_port}/fulfillments/#{@shop.shopify_domain}-#{warehouse['id']}"
+ service.inventory_management = true
+ service.requires_shipping_method = true
+ service.permits_sku_sharing = true
+ service.format = :json
+ service.save!
+
+ @shop.fulfillment_services.create!(whiplash_id: warehouse["id"], shopify_id: service.id)
+ end
+ end
+ end
+ end
+end
A => app/controllers/shops_controller.rb +14 -0
@@ 1,14 @@
+# frozen_string_literal: true
+
+class ShopsController < ApplicationController
+ # TODO: can't use cookies, shopify embedded auth is all JS... just do this for now
+ skip_before_action :verify_authenticity_token
+
+ def update
+ @shop = Shop.find(params[:shop].require(:id))
+ @shop.update!(whiplash_api_key: params[:shop].require(:whiplash_api_key))
+
+ response.headers["X-FRAME-OPTIONS"] = "ALLOW-FROM *"
+ render plain: "Saved\n"
+ end
+end
A => app/helpers/application_helper.rb +4 -0
@@ 1,4 @@
+# frozen_string_literal: true
+
+module ApplicationHelper
+end
A => app/helpers/fulfillment_helper.rb +4 -0
@@ 1,4 @@
+# frozen_string_literal: true
+
+module FulfillmentHelper
+end
A => app/javascript/application.js +3 -0
@@ 1,3 @@
+// Configure your import map in config/importmap.rb. Read more: https://github.com/rails/importmap-rails
+import "@hotwired/turbo-rails"
+import "controllers"
A => app/javascript/controllers/application.js +9 -0
@@ 1,9 @@
+import { Application } from "@hotwired/stimulus"
+
+const application = Application.start()
+
+// Configure Stimulus development experience
+application.debug = false
+window.Stimulus = application
+
+export { application }
A => app/javascript/controllers/hello_controller.js +7 -0
@@ 1,7 @@
+import { Controller } from "@hotwired/stimulus"
+
+export default class extends Controller {
+ connect() {
+ this.element.textContent = "Hello World!"
+ }
+}
A => app/javascript/controllers/index.js +11 -0
@@ 1,11 @@
+// Import and register all your controllers from the importmap under controllers/*
+
+import { application } from "controllers/application"
+
+// Eager load all controllers defined in the import map under controllers/**/*_controller
+import { eagerLoadControllersFrom } from "@hotwired/stimulus-loading"
+eagerLoadControllersFrom("controllers", application)
+
+// Lazy load controllers as they appear in the DOM (remember not to preload controllers in import map!)
+// import { lazyLoadControllersFrom } from "@hotwired/stimulus-loading"
+// lazyLoadControllersFrom("controllers", application)
A => app/javascript/lib/flash_messages.js +24 -0
@@ 1,24 @@
+var eventName = typeof(Turbolinks) !== 'undefined' ? 'turbolinks:load' : 'DOMContentLoaded';
+
+if (!document.documentElement.hasAttribute("data-turbolinks-preview")) {
+ document.addEventListener(eventName, function flash() {
+ var flashData = JSON.parse(document.getElementById('shopify-app-flash').dataset.flash);
+
+ var Toast = window['app-bridge'].actions.Toast;
+
+ if (flashData.notice) {
+ Toast.create(app, {
+ message: flashData.notice,
+ duration: 5000,
+ }).dispatch(Toast.Action.SHOW);
+ }
+
+ if (flashData.error) {
+ Toast.create(app, {
+ message: flashData.error,
+ duration: 5000,
+ isError: true,
+ }).dispatch(Toast.Action.SHOW);
+ }
+ });
+}
A => app/javascript/lib/shopify_app.js +13 -0
@@ 1,13 @@
+var data = document.getElementById('shopify-app-init').dataset;
+var AppBridge = window['app-bridge'];
+var createApp = AppBridge.default;
+window.app = createApp({
+ apiKey: data.apiKey,
+ host: data.host,
+});
+
+var actions = AppBridge.actions;
+var TitleBar = actions.TitleBar;
+TitleBar.create(app, {
+ title: data.page,
+});
A => app/jobs/application_job.rb +9 -0
@@ 1,9 @@
+# frozen_string_literal: true
+
+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
A => app/jobs/sync_assigned_orders_job.rb +97 -0
@@ 1,97 @@
+# frozen_string_literal: true
+
+class SyncAssignedOrdersJob < ApplicationJob
+ queue_as :default
+
+ after_perform do |job|
+ next unless job.arguments.length == 2 && job.arguments.last
+
+ self.class.set(wait: 1.hour).perform_later(*job.arguments)
+ end
+
+ def self.lock_for(shop)
+ @locks ||= {}
+ @locks[shop.id] ||= Mutex.new
+ end
+
+ def perform(shop, _=false)
+ lock = self.class.lock_for(shop)
+ return unless lock.try_lock
+
+ begin
+ shop.with_shopify_session do
+ ShopifyAPI::AssignedFulfillmentOrder.all(assignment_status: :fulfillment_requested).each do |fulfillment_order|
+ sync_fulfillment_order(shop, fulfillment_order)
+ end
+ end
+ rescue StandardError
+ Rails.logger.error $!.to_s
+ ensure
+ lock.unlock
+ end
+ end
+
+ def sync_fulfillment_order(shop, fulfillment_order)
+ existing = WHIPLASH_HTTP.get("orders/originator/#{fulfillment_order.id}", nil, "X-API-KEY" => shop.whiplash_api_key)
+ return unless existing.status == 404
+
+ shopify_service = ShopifyAPI::FulfillmentService.all.find { |service|
+ service.location_id == fulfillment_order.assigned_location_id
+ }
+ service = FulfillmentService.find_by!(shopify_id: shopify_service&.id)
+
+ inventory_items = ShopifyAPI::InventoryItem.all(
+ ids: fulfillment_order.line_items.map { |li| li["inventory_item_id"].to_s }.join(",")
+ )
+ whiplash_items = {}
+ WHIPLASH_HTTP.in_parallel do
+ whiplash_items = inventory_items.each_with_object({}) { |inventory_item, h|
+ h[inventory_item.id] = WHIPLASH_HTTP.get(
+ "items/sku/#{inventory_item.sku}", nil, "X-API-KEY" => shop.whiplash_api_key
+ )
+ }
+ end
+
+ response = WHIPLASH_HTTP.post(
+ "orders",
+ {
+ shipping_name: "#{fulfillment_order.destination['first_name']} #{fulfillment_order.destination['last_name']}",
+ shipping_company: fulfillment_order.destination["company"],
+ shipping_address_1: fulfillment_order.destination["address1"],
+ shipping_address_2: fulfillment_order.destination["address2"],
+ shipping_city: fulfillment_order.destination["city"],
+ shipping_state: fulfillment_order.destination["state"] || fulfillment_order.destination["province"],
+ shipping_country: ISO3166::Country.find_country_by_any_name(fulfillment_order.destination["country"])&.alpha2,
+ shipping_zip: fulfillment_order.destination["zip"],
+ shipping_email: fulfillment_order.destination["email"],
+ shipping_phone: fulfillment_order.destination["phone"],
+ shipping_notes: fulfillment_order.outgoing_requests.map { |r| r["message"] }.join("\n"),
+ shop_created_at: fulfillment_order.fulfill_at,
+ shop_warehouse_id: service.whiplash_id&.to_i,
+ originator_id: fulfillment_order.id,
+ order_items: fulfillment_order.line_items.map { |line_item|
+ {
+ item_id: whiplash_items[line_item["inventory_item_id"]].body.first&.dig("id"),
+ quantity: line_item["fulfillable_quantity"],
+ originator_id: line_item["id"]
+ }
+ }
+ },
+ "X-API-KEY" => shop.whiplash_api_key
+ )
+
+ raise response.inspect unless response.status == 201
+
+ ShopifyAPI::FulfillmentRequest.new.tap { |r|
+ r.fulfillment_order_id = fulfillment_order.id
+ }.accept(message: "Sent to Whiplash")
+ end
+end
+
+module ShopifyAPI
+ class AssignedFulfillmentOrder
+ def self.class_name
+ "fulfillment_order"
+ end
+ end
+end
A => app/jobs/sync_whiplash_order_status_job.rb +51 -0
@@ 1,51 @@
+# frozen_string_literal: true
+
+class SyncWhiplashOrderStatusJob < ApplicationJob
+ queue_as :default
+
+ after_perform do |job|
+ next unless job.arguments.length == 2 && job.arguments.last
+
+ self.class.set(wait: 1.hour).perform_later(*job.arguments)
+ end
+
+ def perform(shop, _=false)
+ shop.with_shopify_session do
+ WHIPLASH_HTTP.get(
+ "orders",
+ { provider: "api", limit: 100, status: [40, 95, 300] },
+ "X-API-KEY" => shop.whiplash_api_key
+ ).body.each do |order|
+ next unless order["originator_id"]
+
+ fulfillment_order = ShopifyAPI::FulfillmentOrder.find(id: order["originator_id"]) rescue nil
+ next unless fulfillment_order
+ next unless fulfillment_order.request_status == "accepted"
+
+ if [40, 95].include?(order["status"])
+ # Accepted but whiplash cancelled or out of stock so reject
+ ShopifyAPI::Fulfillment.all(fulfillment_order_id: fulfillment_order.id).each(&:cancel)
+ fulfillment_order.close
+ next
+ end
+
+ next unless fulfillment_order.status == "in_progress"
+
+ fulfillment = ShopifyAPI::Fulfillment.new
+ fulfillment.message = order["stats_name"]
+ if order["tracking"].present?
+ fulfillment.tracking_info = {
+ number: order["tracking"].first,
+ url: order["tracking_links"].first
+ }
+ end
+ fulfillment.line_items_by_fulfillment_order = [
+ { fulfillment_order_id: fulfillment_order.id }
+ ]
+ fulfillment.save!
+ end
+ end
+ rescue StandardError
+ Rails.logger.error $!.to_s
+ end
+end
A => app/models/application_record.rb +5 -0
@@ 1,5 @@
+# frozen_string_literal: true
+
+class ApplicationRecord < ActiveRecord::Base
+ primary_abstract_class
+end
A => app/models/concerns/.keep +0 -0
A => app/models/fulfillment_service.rb +5 -0
@@ 1,5 @@
+# frozen_string_literal: true
+
+class FulfillmentService < ApplicationRecord
+ belongs_to :shop
+end
A => app/models/shop.rb +11 -0
@@ 1,11 @@
+# frozen_string_literal: true
+
+class Shop < ActiveRecord::Base
+ include ShopifyApp::ShopSessionStorageWithScopes
+
+ has_many :fulfillment_services
+
+ def api_version
+ ShopifyApp.configuration.api_version
+ end
+end
A => app/views/home/index.html.erb +23 -0
@@ 1,23 @@
+<!DOCTYPE html>
+<html lang="en">
+ <head>
+ <meta charset="utf-8" />
+ <meta name="viewport" content="width=device-width, initial-scale=1" />
+ <link
+ rel="stylesheet"
+ href="https://unpkg.com/@shopify/polaris@4.25.0/styles.min.css"
+ />
+ </head>
+ <body>
+ <%= form_for @shop do |f| %>
+ <input type="hidden" name="embedded" value="<%= params[:embedded] %>" />
+ <input type="hidden" name="hmac" value="<%= params[:hmac] %>" />
+ <input type="hidden" name="host" value="<%= params[:host] %>" />
+ <input type="hidden" name="session" value="<%= params[:session] %>" />
+ <%= f.hidden_field :id %>
+ <%= f.label :whiplash_api_key %>
+ <%= f.text_field :whiplash_api_key, type: :password %>
+ <%= f.submit %>
+ <% end %>
+ </body>
+</html>
A => app/views/layouts/_flash_messages.html.erb +3 -0
@@ 1,3 @@
+<% content_for :javascript do %>
+ <%= content_tag(:div, nil, id: 'shopify-app-flash', data: { flash: { notice: flash[:notice], error: flash[:error] } }) %>
+<% end %>
A => app/views/layouts/application.html.erb +16 -0
@@ 1,16 @@
+<!DOCTYPE html>
+<html>
+ <head>
+ <title>WhiplashMboa</title>
+ <meta name="viewport" content="width=device-width,initial-scale=1">
+ <%= csrf_meta_tags %>
+ <%= csp_meta_tag %>
+
+ <%= stylesheet_link_tag "application", "data-turbo-track": "reload" %>
+ <%= javascript_importmap_tags %>
+ </head>
+
+ <body>
+ <%= yield %>
+ </body>
+</html>
A => app/views/layouts/embedded_app.html.erb +44 -0
@@ 1,44 @@
+<!DOCTYPE html>
+<html lang="en">
+ <head>
+ <meta charset="utf-8" />
+ <% application_name = ShopifyApp.configuration.application_name %>
+ <title><%= application_name %></title>
+ <%= stylesheet_link_tag 'application' %>
+ <% if ShopifyApp.use_webpacker? %>
+ <%= javascript_pack_tag 'application', 'data-turbolinks-track': 'reload' %>
+ <% elsif ShopifyApp.use_importmap? %>
+ <%= javascript_importmap_tags %>
+ <% else %>
+ <%= javascript_include_tag 'application', "data-turbolinks-track" => true %>
+ <% end %>
+ <%= csrf_meta_tags %>
+ </head>
+
+ <body>
+ <div class="app-wrapper">
+ <div class="app-content">
+ <main role="main">
+ <%= yield %>
+ </main>
+ </div>
+ </div>
+
+ <%= render 'layouts/flash_messages' %>
+
+ <script src="https://unpkg.com/@shopify/app-bridge@2"></script>
+
+ <%= content_tag(:div, nil, id: 'shopify-app-init', data: {
+ api_key: ShopifyApp.configuration.api_key,
+ shop_origin: @shop_origin || (@current_shopify_session.shop if @current_shopify_session),
+ host: @host,
+ debug: Rails.env.development?
+ } ) %>
+
+ <% if content_for?(:javascript) %>
+ <div id="ContentForJavascript" data-turbolinks-temporary>
+ <%= yield :javascript %>
+ </div>
+ <% end %>
+ </body>
+</html>
A => app/views/layouts/mailer.html.erb +13 -0
@@ 1,13 @@
+<!DOCTYPE html>
+<html>
+ <head>
+ <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
+ <style>
+ /* Email styles need to be inline */
+ </style>
+ </head>
+
+ <body>
+ <%= yield %>
+ </body>
+</html>
A => app/views/layouts/mailer.text.erb +1 -0
A => bin/bundle +114 -0
@@ 1,114 @@
+#!/usr/bin/env ruby2.7
+# 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", __FILE__)
+ end
+
+ def lockfile
+ lockfile =
+ case File.basename(gemfile)
+ when "gems.rb" then gemfile.sub(/\.rb$/, gemfile)
+ 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_version
+ @bundler_version ||=
+ env_var_version || cli_arg_version ||
+ lockfile_version
+ end
+
+ def bundler_requirement
+ return "#{Gem::Requirement.default}.a" unless bundler_version
+
+ bundler_gem_version = Gem::Version.new(bundler_version)
+
+ requirement = bundler_gem_version.approximate_recommendation
+
+ return requirement unless Gem::Version.new(Gem::VERSION) < Gem::Version.new("2.7.0")
+
+ requirement += ".a" if bundler_gem_version.prerelease?
+
+ requirement
+ 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
A => bin/entrypoint.sh +6 -0
@@ 1,6 @@
+#!/bin/sh
+
+while true; do
+ echo On
+ sleep 1
+done
A => bin/importmap +4 -0
@@ 1,4 @@
+#!/usr/bin/env ruby
+
+require_relative "../config/application"
+require "importmap/commands"
A => bin/rails +4 -0
@@ 1,4 @@
+#!/usr/bin/env ruby
+APP_PATH = File.expand_path("../config/application", __dir__)
+require_relative "../config/boot"
+require "rails/commands"
A => bin/rake +4 -0
@@ 1,4 @@
+#!/usr/bin/env ruby
+require_relative "../config/boot"
+require "rake"
+Rake.application.run
A => bin/setup +33 -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
A => config.ru +6 -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
A => config/application.rb +25 -0
@@ 1,25 @@
+# frozen_string_literal: true
+
+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 WhiplashMboa
+ class Application < Rails::Application
+ # Initialize configuration defaults for originally generated Rails version.
+ config.load_defaults 7.0
+ config.action_dispatch.cookies_same_site_protection = :none
+
+ # 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")
+ end
+end
A => config/boot.rb +4 -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.
A => config/cable.yml +11 -0
@@ 1,11 @@
+development:
+ adapter: redis
+ url: redis://localhost:6379/1
+
+test:
+ adapter: test
+
+production:
+ adapter: redis
+ url: <%= ENV.fetch("REDIS_URL") { "redis://localhost:6379/1" } %>
+ channel_prefix: whiplash_mboa_production
A => config/credentials.yml.enc +1 -0
@@ 1,1 @@
+IPINgLNBkNzh2aZMwtbRKNqVJ8DWMZrCpMq+cR0sSdc/iOFBATONutRcT1d/8/wbEj8WTYwXz5Xf8exbLv9usCoAFeCdrkcnheCnfnKDoHW/tpmfHViirSE8sPwY4zUkDtMdGCTuC78j+oYdqugfGp9ad6C2h0sDYPUATftYS9ouumd9SCiN0NygArCYxBb7nt30m9Rn0kP0s8lXCeLF3R4nmYMEgvEa5ruuwLzE1qmk8Rxj41lqx4KiKlKlj8lAMZQNzQ0SNYEKaR5YLXsFIpvCHlO/hJy5HILh55iUWyIgQUW6oXv6IJLt7cs12J0PG1K7O0ZYgdWXPq5LpXA/yNaa1R57ntodr6Y8nf0LB2WjTt/LO/46dyR+FkAyKNZ8Ur76J2gcWpmHDs48vS9PWOM8SzI5D+RvLFyU--8rEkwCFUdjmg1OUO--tQTOIZbSd4ND2FkzposLIw==<
\ No newline at end of file
A => config/database.yml +25 -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: /data/production.sqlite3
A => config/environment.rb +7 -0
@@ 1,7 @@
+# frozen_string_literal: true
+
+# Load the Rails application.
+require_relative "application"
+
+# Initialize the Rails application.
+Rails.application.initialize!
A => config/environments/development.rb +76 -0
@@ 1,76 @@
+# frozen_string_literal: true
+
+require "active_support/core_ext/integer/time"
+
+Rails.application.configure do
+ # Allow ngrok tunnels for secure Shopify OAuth redirects
+ config.hosts = (config.hosts rescue []) << /[-\w]+\.ngrok\.io/
+ # Allow Cloudflare tunnels for secure Shopify OAuth redirects
+ config.hosts = (config.hosts rescue []) << /[-\w]+\.trycloudflare\.com/
+ # 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.action_controller.perform_caching = true
+ config.action_controller.enable_fragment_cache_logging = true
+
+ 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
+
+ # Suppress logger output for asset requests.
+ config.assets.quiet = 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
A => config/environments/production.rb +95 -0
@@ 1,95 @@
+# frozen_string_literal: true
+
+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
+ config.action_controller.perform_caching = true
+
+ # 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?
+
+ # Compress CSS using a preprocessor.
+ # config.assets.css_compressor = :sass
+
+ # Do not fallback to assets pipeline if a precompiled asset is missed.
+ config.assets.compile = false
+
+ # 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 = :memory_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 = "whiplash_mboa_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
A => config/environments/test.rb +62 -0
@@ 1,62 @@
+# frozen_string_literal: true
+
+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
A => config/importmap.rb +10 -0
@@ 1,10 @@
+# frozen_string_literal: true
+
+# Pin npm packages by running ./bin/importmap
+
+pin "application", preload: true
+pin "@hotwired/turbo-rails", to: "turbo.min.js", preload: true
+pin "@hotwired/stimulus", to: "stimulus.min.js", preload: true
+pin "@hotwired/stimulus-loading", to: "stimulus-loading.js", preload: true
+pin_all_from "app/javascript/controllers", under: "controllers"
+pin_all_from "app/javascript/lib", under: "lib"
A => config/initializers/assets.rb +14 -0
@@ 1,14 @@
+# frozen_string_literal: true
+
+# Be sure to restart your server when you modify this file.
+
+# Version of your assets, change this if you want to expire all your assets.
+Rails.application.config.assets.version = "1.0"
+
+# Add additional assets to the asset load path.
+# Rails.application.config.assets.paths << Emoji.images_path
+
+# Precompile additional assets.
+# application.js, application.css, and all non-JS/CSS in the app/assets
+# folder are already added.
+# Rails.application.config.assets.precompile += %w( admin.js admin.css )
A => config/initializers/faraday.rb +9 -0
@@ 1,9 @@
+# frozen_string_literal: true
+
+Faraday.default_adapter = :typhoeus
+# WHIPLASH_HTTP = Faraday.new("https://www.whiplashmerch.com/api/") do |f|
+WHIPLASH_HTTP = Faraday.new("https:///sandbox.getwhiplash.com/api/") do |f|
+ f.request :json
+ f.response :json
+ f.request :retry
+end
A => config/initializers/filter_parameter_logging.rb +10 -0
@@ 1,10 @@
+# frozen_string_literal: true
+
+# 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
+]
A => config/initializers/session_store.rb +5 -0
@@ 1,5 @@
+# frozen_string_literal: true
+
+# Be sure to restart your server when you modify this file.
+
+Rails.application.config.session_store(:cookie_store, key: "_example_session", expire_after: 14.days)
A => config/initializers/shopify_app.rb +54 -0
@@ 1,54 @@
+# frozen_string_literal: true
+
+ShopifyApp.configure do |config|
+ config.application_name = "Whiplash by MBOA"
+ config.old_secret = ""
+ config.scope = "read_products,write_fulfillments,read_assigned_fulfillment_orders,write_assigned_fulfillment_orders,read_inventory,write_merchant_managed_fulfillment_orders"
+ config.embedded_app = true
+ config.after_authenticate_job = false
+ config.api_version = "2022-10"
+ config.shop_session_repository = "Shop"
+
+ config.reauth_on_access_scope_changes = true
+
+ config.api_key = ENV.fetch("SHOPIFY_API_KEY", "").presence
+ config.secret = ENV.fetch("SHOPIFY_API_SECRET", "").presence
+
+ # You may want to charge merchants for using your app. Setting the billing configuration will cause the Authenticated
+ # controller concern to check that the session is for a merchant that has an active one-time payment or subscription.
+ # If no payment is found, it starts off the process and sends the merchant to a confirmation URL so that they can
+ # approve the purchase.
+ #
+ # Learn more about billing in our documentation: https://shopify.dev/apps/billing
+ # config.billing = ShopifyApp::BillingConfiguration.new(
+ # charge_name: "My app billing charge",
+ # amount: 5,
+ # interval: ShopifyApp::BillingConfiguration::INTERVAL_EVERY_30_DAYS,
+ # currency_code: "USD", # Only supports USD for now
+ # )
+
+ if defined? Rails::Server
+ raise("Missing SHOPIFY_API_KEY. See https://github.com/Shopify/shopify_app#requirements") unless config.api_key
+ raise("Missing SHOPIFY_API_SECRET. See https://github.com/Shopify/shopify_app#requirements") unless config.secret
+ end
+end
+
+Rails.application.config.after_initialize do
+ if ShopifyApp.configuration.api_key.present? && ShopifyApp.configuration.secret.present?
+ ShopifyAPI::Context.setup(
+ api_key: ShopifyApp.configuration.api_key,
+ api_secret_key: ShopifyApp.configuration.secret,
+ api_version: ShopifyApp.configuration.api_version,
+ host: ENV["HOST"],
+ scope: ShopifyApp.configuration.scope,
+ is_private: !ENV.fetch("SHOPIFY_APP_PRIVATE_SHOP", "").empty?,
+ is_embedded: ShopifyApp.configuration.embedded_app,
+ session_storage: ShopifyApp::SessionRepository,
+ logger: Rails.logger,
+ private_shop: ENV.fetch("SHOPIFY_APP_PRIVATE_SHOP", nil),
+ user_agent_prefix: "ShopifyApp/#{ShopifyApp::VERSION}"
+ )
+
+ ShopifyApp::WebhooksManager.add_registrations
+ end
+end
A => config/initializers/z_recurring_jobs.rb +14 -0
@@ 1,14 @@
+# frozen_string_literal: true
+
+module WhiplashMboa
+ class Application
+ config.after_initialize do
+ Shop.all.each do |shop|
+ next unless shop.whiplash_api_key
+
+ SyncAssignedOrdersJob.perform_later(shop, true)
+ SyncWhiplashOrderStatusJob.perform_later(shop, true)
+ end
+ end
+ end
+end
A => config/locales/en.yml +33 -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"
A => config/puma.rb +45 -0
@@ 1,45 @@
+# frozen_string_literal: true
+
+# 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
A => config/routes.rb +11 -0
@@ 1,11 @@
+# frozen_string_literal: true
+
+Rails.application.routes.draw do
+ root to: "home#index"
+ get "/fulfillments/:id/fetch_stock",
+ to: "fulfillment#fetch_stock", constraints: { id: /[^\/]+/ }
+ post "/fulfillments/:id/fulfillment_order_notification",
+ to: "fulfillment#order_notification", constraints: { id: /[^\/]+/ }
+ resource :shop, only: [:update]
+ mount ShopifyApp::Engine, at: "/"
+end
A => config/storage.yml +34 -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 ]
A => db/migrate/20221121141951_create_shops.rb +15 -0
@@ 1,15 @@
+class CreateShops < ActiveRecord::Migration[7.0]
+ def self.up
+ create_table :shops do |t|
+ t.string :shopify_domain, null: false
+ t.string :shopify_token, null: false
+ t.timestamps
+ end
+
+ add_index :shops, :shopify_domain, unique: true
+ end
+
+ def self.down
+ drop_table :shops
+ end
+end
A => db/migrate/20221121142016_add_shop_access_scopes_column.rb +5 -0
@@ 1,5 @@
+class AddShopAccessScopesColumn < ActiveRecord::Migration[7.0]
+ def change
+ add_column :shops, :access_scopes, :string
+ end
+end
A => db/migrate/20221122213609_add_whiplash_api_key_to_shop.rb +7 -0
@@ 1,7 @@
+class AddWhiplashApiKeyToShop < ActiveRecord::Migration[7.0]
+ def change
+ change_table :shops do |t|
+ t.string :whiplash_api_key
+ end
+ end
+end
A => db/migrate/20221123145915_add_fulfillment_services.rb +13 -0
@@ 1,13 @@
+class AddFulfillmentServices < ActiveRecord::Migration[7.0]
+ def change
+ create_table :fulfillment_services do |t|
+ t.belongs_to :shop, null: false
+ t.string :whiplash_id, null: false
+ t.string :shopify_id, null: false
+ t.timestamps
+ end
+
+ add_index :fulfillment_services, [:shop_id, :whiplash_id], unique: true
+ add_index :fulfillment_services, [:shop_id, :shopify_id], unique: true
+ end
+end
A => db/schema.rb +35 -0
@@ 1,35 @@
+# This file is auto-generated from the current state of the database. Instead
+# of editing this file, please use the migrations feature of Active Record to
+# incrementally modify your database, and then regenerate this schema definition.
+#
+# This file is the source Rails uses to define your schema when running `bin/rails
+# db:schema:load`. When creating a new database, `bin/rails db:schema:load` tends to
+# be faster and is potentially less error prone than running all of your
+# migrations from scratch. Old migrations may fail to apply correctly if those
+# migrations use external dependencies or application code.
+#
+# It's strongly recommended that you check this file into your version control system.
+
+ActiveRecord::Schema[7.0].define(version: 2022_11_23_145915) do
+ create_table "fulfillment_services", force: :cascade do |t|
+ t.integer "shop_id", null: false
+ t.string "whiplash_id", null: false
+ t.string "shopify_id", null: false
+ t.datetime "created_at", null: false
+ t.datetime "updated_at", null: false
+ t.index ["shop_id", "shopify_id"], name: "index_fulfillment_services_on_shop_id_and_shopify_id", unique: true
+ t.index ["shop_id", "whiplash_id"], name: "index_fulfillment_services_on_shop_id_and_whiplash_id", unique: true
+ t.index ["shop_id"], name: "index_fulfillment_services_on_shop_id"
+ end
+
+ create_table "shops", force: :cascade do |t|
+ t.string "shopify_domain", null: false
+ t.string "shopify_token", null: false
+ t.datetime "created_at", null: false
+ t.datetime "updated_at", null: false
+ t.string "access_scopes"
+ t.string "whiplash_api_key"
+ t.index ["shopify_domain"], name: "index_shops_on_shopify_domain", unique: true
+ end
+
+end
A => db/seeds.rb +7 -0
@@ 1,7 @@
+# This file should contain all the record creation needed to seed the database with its default values.
+# The data can then be loaded with the bin/rails db:seed command (or created alongside the database with db:setup).
+#
+# Examples:
+#
+# movies = Movie.create([{ name: "Star Wars" }, { name: "Lord of the Rings" }])
+# Character.create(name: "Luke", movie: movies.first)
A => fly.toml +51 -0
@@ 1,51 @@
+# fly.toml file generated for whiplash-mboa on 2022-11-21T19:48:56-05:00
+
+app = "whiplash-mboa"
+kill_signal = "SIGINT"
+kill_timeout = 5
+processes = []
+
+[build]
+ [build.args]
+ BUILD_COMMAND = "bin/rails fly:build"
+ SERVER_COMMAND = "bin/rails fly:server"
+
+[deploy]
+ release_command = "bin/rails fly:release"
+
+[env]
+ PORT = "8080"
+
+[experimental]
+ allowed_public_ports = []
+ auto_rollback = true
+
+[[services]]
+ http_checks = []
+ internal_port = 8080
+ processes = ["app"]
+ protocol = "tcp"
+ script_checks = []
+ [services.concurrency]
+ hard_limit = 25
+ soft_limit = 20
+ type = "connections"
+
+ [[services.ports]]
+ force_https = true
+ handlers = ["http"]
+ port = 80
+
+ [[services.ports]]
+ handlers = ["tls", "http"]
+ port = 443
+
+ [[services.tcp_checks]]
+ grace_period = "1s"
+ interval = "15s"
+ restart_limit = 0
+ timeout = "2s"
+
+[[statics]]
+ guest_path = "/app/public"
+ url_prefix = "/"
A => lib/assets/.keep +0 -0
A => lib/tasks/.keep +0 -0
A => lib/tasks/fly.rake +37 -0
@@ 1,37 @@
+# commands used to deploy a Rails application
+namespace :fly do
+ # BUILD step:
+ # - changes to the filesystem made here DO get deployed
+ # - NO access to secrets, volumes, databases
+ # - Failures here prevent deployment
+ task :build => 'assets:precompile'
+
+ # RELEASE step:
+ # - changes to the filesystem made here are DISCARDED
+ # - full access to secrets, databases
+ # - failures here prevent deployment
+ task :release => 'db:migrate'
+
+ # SERVER step:
+ # - changes to the filesystem made here are deployed
+ # - full access to secrets, databases
+ # - failures here result in VM being stated, shutdown, and rolled back
+ # to last successful deploy (if any).
+ task :server => :swapfile do
+ sh 'bin/rails server'
+ end
+
+ # optional SWAPFILE task:
+ # - adjust fallocate size as needed
+ # - performance critical applications should scale memory to the
+ # point where swap is rarely used. 'fly scale help' for details.
+ # - disable by removing dependency on the :server task, thus:
+ # task :server do
+ task :swapfile do
+ sh 'fallocate -l 512M /swapfile'
+ sh 'chmod 0600 /swapfile'
+ sh 'mkswap /swapfile'
+ sh 'echo 10 > /proc/sys/vm/swappiness'
+ sh 'swapon /swapfile'
+ end
+end
A => log/.keep +0 -0
A => public/404.html +67 -0
@@ 1,67 @@
+<!DOCTYPE html>
+<html>
+<head>
+ <title>The page you were looking for doesn't exist (404)</title>
+ <meta name="viewport" content="width=device-width,initial-scale=1">
+ <style>
+ .rails-default-error-page {
+ background-color: #EFEFEF;
+ color: #2E2F30;
+ text-align: center;
+ font-family: arial, sans-serif;
+ margin: 0;
+ }
+
+ .rails-default-error-page div.dialog {
+ width: 95%;
+ max-width: 33em;
+ margin: 4em auto 0;
+ }
+
+ .rails-default-error-page div.dialog > div {
+ border: 1px solid #CCC;
+ border-right-color: #999;
+ border-left-color: #999;
+ border-bottom-color: #BBB;
+ border-top: #B00100 solid 4px;
+ border-top-left-radius: 9px;
+ border-top-right-radius: 9px;
+ background-color: white;
+ padding: 7px 12% 0;
+ box-shadow: 0 3px 8px rgba(50, 50, 50, 0.17);
+ }
+
+ .rails-default-error-page h1 {
+ font-size: 100%;
+ color: #730E15;
+ line-height: 1.5em;
+ }
+
+ .rails-default-error-page div.dialog > p {
+ margin: 0 0 1em;
+ padding: 1em;
+ background-color: #F7F7F7;
+ border: 1px solid #CCC;
+ border-right-color: #999;
+ border-left-color: #999;
+ border-bottom-color: #999;
+ border-bottom-left-radius: 4px;
+ border-bottom-right-radius: 4px;
+ border-top-color: #DADADA;
+ color: #666;
+ box-shadow: 0 3px 8px rgba(50, 50, 50, 0.17);
+ }
+ </style>
+</head>
+
+<body class="rails-default-error-page">
+ <!-- This file lives in public/404.html -->
+ <div class="dialog">
+ <div>
+ <h1>The page you were looking for doesn't exist.</h1>
+ <p>You may have mistyped the address or the page may have moved.</p>
+ </div>
+ <p>If you are the application owner check the logs for more information.</p>
+ </div>
+</body>
+</html>
A => public/422.html +67 -0
@@ 1,67 @@
+<!DOCTYPE html>
+<html>
+<head>
+ <title>The change you wanted was rejected (422)</title>
+ <meta name="viewport" content="width=device-width,initial-scale=1">
+ <style>
+ .rails-default-error-page {
+ background-color: #EFEFEF;
+ color: #2E2F30;
+ text-align: center;
+ font-family: arial, sans-serif;
+ margin: 0;
+ }
+
+ .rails-default-error-page div.dialog {
+ width: 95%;
+ max-width: 33em;
+ margin: 4em auto 0;
+ }
+
+ .rails-default-error-page div.dialog > div {
+ border: 1px solid #CCC;
+ border-right-color: #999;
+ border-left-color: #999;
+ border-bottom-color: #BBB;
+ border-top: #B00100 solid 4px;
+ border-top-left-radius: 9px;
+ border-top-right-radius: 9px;
+ background-color: white;
+ padding: 7px 12% 0;
+ box-shadow: 0 3px 8px rgba(50, 50, 50, 0.17);
+ }
+
+ .rails-default-error-page h1 {
+ font-size: 100%;
+ color: #730E15;
+ line-height: 1.5em;
+ }
+
+ .rails-default-error-page div.dialog > p {
+ margin: 0 0 1em;
+ padding: 1em;
+ background-color: #F7F7F7;
+ border: 1px solid #CCC;
+ border-right-color: #999;
+ border-left-color: #999;
+ border-bottom-color: #999;
+ border-bottom-left-radius: 4px;
+ border-bottom-right-radius: 4px;
+ border-top-color: #DADADA;
+ color: #666;
+ box-shadow: 0 3px 8px rgba(50, 50, 50, 0.17);
+ }
+ </style>
+</head>
+
+<body class="rails-default-error-page">
+ <!-- This file lives in public/422.html -->
+ <div class="dialog">
+ <div>
+ <h1>The change you wanted was rejected.</h1>
+ <p>Maybe you tried to change something you didn't have access to.</p>
+ </div>
+ <p>If you are the application owner check the logs for more information.</p>
+ </div>
+</body>
+</html>
A => public/500.html +66 -0
@@ 1,66 @@
+<!DOCTYPE html>
+<html>
+<head>
+ <title>We're sorry, but something went wrong (500)</title>
+ <meta name="viewport" content="width=device-width,initial-scale=1">
+ <style>
+ .rails-default-error-page {
+ background-color: #EFEFEF;
+ color: #2E2F30;
+ text-align: center;
+ font-family: arial, sans-serif;
+ margin: 0;
+ }
+
+ .rails-default-error-page div.dialog {
+ width: 95%;
+ max-width: 33em;
+ margin: 4em auto 0;
+ }
+
+ .rails-default-error-page div.dialog > div {
+ border: 1px solid #CCC;
+ border-right-color: #999;
+ border-left-color: #999;
+ border-bottom-color: #BBB;
+ border-top: #B00100 solid 4px;
+ border-top-left-radius: 9px;
+ border-top-right-radius: 9px;
+ background-color: white;
+ padding: 7px 12% 0;
+ box-shadow: 0 3px 8px rgba(50, 50, 50, 0.17);
+ }
+
+ .rails-default-error-page h1 {
+ font-size: 100%;
+ color: #730E15;
+ line-height: 1.5em;
+ }
+
+ .rails-default-error-page div.dialog > p {
+ margin: 0 0 1em;
+ padding: 1em;
+ background-color: #F7F7F7;
+ border: 1px solid #CCC;
+ border-right-color: #999;
+ border-left-color: #999;
+ border-bottom-color: #999;
+ border-bottom-left-radius: 4px;
+ border-bottom-right-radius: 4px;
+ border-top-color: #DADADA;
+ color: #666;
+ box-shadow: 0 3px 8px rgba(50, 50, 50, 0.17);
+ }
+ </style>
+</head>
+
+<body class="rails-default-error-page">
+ <!-- This file lives in public/500.html -->
+ <div class="dialog">
+ <div>
+ <h1>We're sorry, but something went wrong.</h1>
+ </div>
+ <p>If you are the application owner check the logs for more information.</p>
+ </div>
+</body>
+</html>
A => public/apple-touch-icon-precomposed.png +0 -0
A => public/apple-touch-icon.png +0 -0
A => public/favicon.ico +0 -0
A => public/robots.txt +1 -0
@@ 1,1 @@
+# See https://www.robotstxt.org/robotstxt.html for documentation on how to use the robots.txt file
A => storage/.keep +0 -0
A => test/controllers/.keep +0 -0
A => test/controllers/fulfillment_controller_test.rb +9 -0
@@ 1,9 @@
+# frozen_string_literal: true
+
+require "test_helper"
+
+class FulfillmentControllerTest < ActionDispatch::IntegrationTest
+ # test "the truth" do
+ # assert true
+ # end
+end
A => test/fixtures/files/.keep +0 -0
A => test/fixtures/fulfillment_services.yml +11 -0
@@ 1,11 @@
+# Read about fixtures at https://api.rubyonrails.org/classes/ActiveRecord/FixtureSet.html
+
+# This model initially had no columns defined. If you add columns to the
+# model remove the "{}" from the fixture names and add the columns immediately
+# below each fixture, per the syntax in the comments below
+#
+one: {}
+# column: value
+#
+two: {}
+# column: value
A => test/fixtures/shops.yml +3 -0
@@ 1,3 @@
+regular_shop:
+ shopify_domain: 'regular-shop.myshopify.com'
+ shopify_token: 'token'
A => test/helpers/.keep +0 -0
A => test/integration/.keep +0 -0
A => test/jobs/sync_assigned_orders_job_test.rb +9 -0
@@ 1,9 @@
+# frozen_string_literal: true
+
+require "test_helper"
+
+class SyncAssignedOrdersJobTest < ActiveJob::TestCase
+ # test "the truth" do
+ # assert true
+ # end
+end
A => test/jobs/sync_whiplash_order_status_job_test.rb +9 -0
@@ 1,9 @@
+# frozen_string_literal: true
+
+require "test_helper"
+
+class SyncWhiplashOrderStatusJobTest < ActiveJob::TestCase
+ # test "the truth" do
+ # assert true
+ # end
+end
A => test/mailers/.keep +0 -0
A => test/models/.keep +0 -0
A => test/models/fulfillment_service_test.rb +9 -0
@@ 1,9 @@
+# frozen_string_literal: true
+
+require "test_helper"
+
+class FulfillmentServiceTest < ActiveSupport::TestCase
+ # test "the truth" do
+ # assert true
+ # end
+end
A => test/system/.keep +0 -0
A => test/test_helper.rb +17 -0
@@ 1,17 @@
+# frozen_string_literal: true
+
+ENV["RAILS_ENV"] ||= "test"
+require_relative "../config/environment"
+require "rails/test_help"
+
+module ActiveSupport
+ class TestCase
+ # Run tests in parallel with specified workers
+ parallelize(workers: :number_of_processors)
+
+ # Setup all fixtures in test/fixtures/*.yml for all tests in alphabetical order.
+ fixtures :all
+
+ # Add more helper methods to be used by all tests here...
+ end
+end
A => tmp/.keep +0 -0
A => tmp/pids/.keep +0 -0
A => tmp/storage/.keep +0 -0
A => vendor/.keep +0 -0
A => vendor/javascript/.keep +0 -0
