Compare commits
39 Commits
b29d1a1ef1
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e4edffd69f | ||
|
|
7dbcc63394 | ||
|
|
fe9794a796 | ||
|
|
24b42352b3 | ||
|
|
81f466ceb0 | ||
|
|
d54d35eed1 | ||
|
|
57618b268d | ||
|
|
3dab3f66b9 | ||
|
|
ba58a13e6a | ||
|
|
db65777780 | ||
|
|
e2795edbe6 | ||
|
|
346069ae96 | ||
|
|
bbabeb6c14 | ||
|
|
65879e092a | ||
|
|
b06baf8c63 | ||
|
|
d4eae63166 | ||
|
|
ba625d738e | ||
|
|
340fcdcf41 | ||
|
|
76303ba097 | ||
|
|
a690189f02 | ||
|
|
a87f4f99c0 | ||
|
|
d7d4e2be9d | ||
|
|
3158a75f5d | ||
|
|
867b2f0f20 | ||
|
|
62d63546c4 | ||
|
|
e1364c9b9b | ||
|
|
8098f24552 | ||
|
|
bd38a29b6d | ||
|
|
ed6d30ec42 | ||
|
|
da9b96de84 | ||
|
|
9a27a5c943 | ||
|
|
11e65c009c | ||
|
|
107e7507f4 | ||
|
|
ecb1717eb3 | ||
|
|
f8bf1b961b | ||
|
|
9db42cb522 | ||
|
|
90e886c62d | ||
|
|
1f28a03d47 | ||
|
|
6c1220b544 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -30,3 +30,4 @@ target
|
||||
.metals
|
||||
project/project
|
||||
project/metals.sbt
|
||||
/result
|
||||
|
||||
674
COPYING
Normal file
674
COPYING
Normal file
@@ -0,0 +1,674 @@
|
||||
GNU GENERAL PUBLIC LICENSE
|
||||
Version 3, 29 June 2007
|
||||
|
||||
Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
|
||||
Everyone is permitted to copy and distribute verbatim copies
|
||||
of this license document, but changing it is not allowed.
|
||||
|
||||
Preamble
|
||||
|
||||
The GNU General Public License is a free, copyleft license for
|
||||
software and other kinds of works.
|
||||
|
||||
The licenses for most software and other practical works are designed
|
||||
to take away your freedom to share and change the works. By contrast,
|
||||
the GNU General Public License is 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. We, the Free Software Foundation, use the
|
||||
GNU General Public License for most of our software; it applies also to
|
||||
any other work released this way by its authors. You can apply it to
|
||||
your programs, too.
|
||||
|
||||
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.
|
||||
|
||||
To protect your rights, we need to prevent others from denying you
|
||||
these rights or asking you to surrender the rights. Therefore, you have
|
||||
certain responsibilities if you distribute copies of the software, or if
|
||||
you modify it: responsibilities to respect the freedom of others.
|
||||
|
||||
For example, if you distribute copies of such a program, whether
|
||||
gratis or for a fee, you must pass on to the recipients the same
|
||||
freedoms that you received. You must make sure that they, too, receive
|
||||
or can get the source code. And you must show them these terms so they
|
||||
know their rights.
|
||||
|
||||
Developers that use the GNU GPL protect your rights with two steps:
|
||||
(1) assert copyright on the software, and (2) offer you this License
|
||||
giving you legal permission to copy, distribute and/or modify it.
|
||||
|
||||
For the developers' and authors' protection, the GPL clearly explains
|
||||
that there is no warranty for this free software. For both users' and
|
||||
authors' sake, the GPL requires that modified versions be marked as
|
||||
changed, so that their problems will not be attributed erroneously to
|
||||
authors of previous versions.
|
||||
|
||||
Some devices are designed to deny users access to install or run
|
||||
modified versions of the software inside them, although the manufacturer
|
||||
can do so. This is fundamentally incompatible with the aim of
|
||||
protecting users' freedom to change the software. The systematic
|
||||
pattern of such abuse occurs in the area of products for individuals to
|
||||
use, which is precisely where it is most unacceptable. Therefore, we
|
||||
have designed this version of the GPL to prohibit the practice for those
|
||||
products. If such problems arise substantially in other domains, we
|
||||
stand ready to extend this provision to those domains in future versions
|
||||
of the GPL, as needed to protect the freedom of users.
|
||||
|
||||
Finally, every program is threatened constantly by software patents.
|
||||
States should not allow patents to restrict development and use of
|
||||
software on general-purpose computers, but in those that do, we wish to
|
||||
avoid the special danger that patents applied to a free program could
|
||||
make it effectively proprietary. To prevent this, the GPL assures that
|
||||
patents cannot be used to render the program non-free.
|
||||
|
||||
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 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. Use with the GNU Affero General Public License.
|
||||
|
||||
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 Affero 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 special requirements of the GNU Affero General Public License,
|
||||
section 13, concerning interaction through a network will apply to the
|
||||
combination as such.
|
||||
|
||||
14. Revised Versions of this License.
|
||||
|
||||
The Free Software Foundation may publish revised and/or new versions of
|
||||
the GNU 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 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 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 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 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 General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
|
||||
Also add information on how to contact you by electronic and paper mail.
|
||||
|
||||
If the program does terminal interaction, make it output a short
|
||||
notice like this when it starts in an interactive mode:
|
||||
|
||||
<program> Copyright (C) <year> <name of author>
|
||||
This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
|
||||
This is free software, and you are welcome to redistribute it
|
||||
under certain conditions; type `show c' for details.
|
||||
|
||||
The hypothetical commands `show w' and `show c' should show the appropriate
|
||||
parts of the General Public License. Of course, your program's commands
|
||||
might be different; for a GUI interface, you would use an "about box".
|
||||
|
||||
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 GPL, see
|
||||
<https://www.gnu.org/licenses/>.
|
||||
|
||||
The GNU General Public License does not permit incorporating your program
|
||||
into proprietary programs. If your program is a subroutine library, you
|
||||
may consider it more useful to permit linking proprietary applications with
|
||||
the library. If this is what you want to do, use the GNU Lesser General
|
||||
Public License instead of this License. But first, please read
|
||||
<https://www.gnu.org/licenses/why-not-lgpl.html>.
|
||||
81
Readme.org
Normal file
81
Readme.org
Normal file
@@ -0,0 +1,81 @@
|
||||
#+title: Readme
|
||||
* Licence:
|
||||
This program is free software: you can redistribute it and/or modify it
|
||||
under the terms of the GNU 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 General Public License for
|
||||
more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License along with
|
||||
this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
* Running dev
|
||||
need 3 teminals
|
||||
** start backend
|
||||
in sbt
|
||||
#+begin_src sbt
|
||||
backend/run
|
||||
#+end_src
|
||||
** continuous ScalaJS compilation
|
||||
in sbt
|
||||
#+begin_src sbt
|
||||
project frontend
|
||||
~fastLinkJS
|
||||
#+end_src
|
||||
** start Vite
|
||||
#+begin_src bash
|
||||
npm run dev
|
||||
#+end_src
|
||||
|
||||
- starting to serve frontend at localhost:5173
|
||||
- started forwarding /api requests to localhost:8080 - backend
|
||||
* Prod deployment (alpha version)
|
||||
** Nix managed server:
|
||||
*** build and copy backend
|
||||
#+begin_src bash
|
||||
sbt backend/assembly
|
||||
scp -r backend/target/scala-3.2.0/backend-assembly-0.1.1.jar <your-server>:~/Downloads/backend-assembly-0.1.1.jar
|
||||
#+end_src
|
||||
|
||||
*** build and copy frontend
|
||||
#+begin_src bash
|
||||
npm run build
|
||||
scp -r dist/* <your-server>:/var/www/planning-poker-grargh
|
||||
#+end_src
|
||||
*** start backend
|
||||
#+begin_src bash
|
||||
nix shell --extra-experimental-features nix-command --extra-experimental-features flakes nixpkgs#jdk
|
||||
java -jar ~/Downloads/backend-assembly-0.1.1.jar &
|
||||
#+end_src
|
||||
**** to kill / restart
|
||||
#+begin_src bash
|
||||
ps aux | grep backend-assembly
|
||||
kill <id of found backend java process>
|
||||
#+end_src
|
||||
**** TODO make nix home-manager module with systemd service
|
||||
*** configure nginx
|
||||
#+begin_src nix
|
||||
services.nginx.virtualHosts."planning-poker.sunshine.industries" = {
|
||||
root = "/var/www/planning-poker-grargh"; # copied manually
|
||||
};
|
||||
|
||||
services.nginx.virtualHosts."planning-poker.sunshine.industries".locations."/api" = {
|
||||
proxyPass = "http://127.0.0.1:8080"; # started manually
|
||||
proxyRedirect = "off";
|
||||
extraConfig = ''
|
||||
rewrite ^/api/(.*)$ /$1 break;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
|
||||
proxy_set_header X-Forwarded-Proto $scheme;
|
||||
|
||||
# Add the following lines for WebSocket support
|
||||
proxy_http_version 1.1;
|
||||
proxy_set_header Upgrade $http_upgrade;
|
||||
proxy_set_header Connection "upgrade";
|
||||
'';
|
||||
};
|
||||
#+end_src
|
||||
@@ -25,91 +25,63 @@ trait Auth[F[_]] {
|
||||
* check that room exists, password is valid call to add user to the players create session
|
||||
* mapping and return cookie
|
||||
*/
|
||||
def joinRoom(
|
||||
roomName: String,
|
||||
roomPassword: String,
|
||||
nickName: String,
|
||||
nickPassword: String
|
||||
): F[Either[String, ResponseCookie]]
|
||||
def joinRoom(roomId: RoomID, playerId: PlayerID): F[ResponseCookie]
|
||||
|
||||
def deleteSession(
|
||||
sessionId: Long
|
||||
): F[Unit]
|
||||
def deleteSession(sessionId: Long): F[ResponseCookie]
|
||||
|
||||
}
|
||||
|
||||
object Auth {
|
||||
def pureBadStub = new Auth[IO] {
|
||||
override def authUser =
|
||||
Kleisli((req: Request[IO]) =>
|
||||
OptionT.liftF(
|
||||
IO(println(s"authUser: $req")) >> IO(
|
||||
PlayerID(14) -> RoomID("testroom")
|
||||
)
|
||||
)
|
||||
)
|
||||
override def joinRoom(
|
||||
roomName: String,
|
||||
roomPassword: String,
|
||||
nickName: String,
|
||||
nickPassword: String
|
||||
) =
|
||||
IO(
|
||||
println(
|
||||
s"> access room for $roomName $roomPassword $nickName, to return stub 111"
|
||||
)
|
||||
) >> IO.pure(Right(ResponseCookie("authcookie", "1")))
|
||||
|
||||
override def deleteSession(sessionId: Long): IO[Unit] =
|
||||
IO(s"got request to leave for $sessionId")
|
||||
}
|
||||
|
||||
type SessionsMap = Map[Long, (RoomID, PlayerID)]
|
||||
|
||||
class SimpleAuth[F[_]: Sync](
|
||||
sessions: Ref[F, SessionsMap],
|
||||
roomService: RoomService[F]
|
||||
) extends Auth[F] {
|
||||
// TODO make "remove session usable from authed route"
|
||||
val authcookieName = "authcookie"
|
||||
|
||||
val authcookie = "authcookie"
|
||||
class SimpleAuth[F[_]: Sync](sessions: Ref[F, SessionsMap]) extends Auth[F] {
|
||||
|
||||
override def joinRoom(
|
||||
roomName: String,
|
||||
roomPassword: String,
|
||||
nickName: String,
|
||||
nickPassword: String
|
||||
): F[Either[String, ResponseCookie]] = {
|
||||
override def joinRoom(roomId: RoomID, playerId: PlayerID): F[ResponseCookie] = {
|
||||
// TODO check for existing session for same room
|
||||
// and do i want to logout if existing session for another room? ugh
|
||||
val roomId = RoomID(roomName)
|
||||
val result = for {
|
||||
playerId <- EitherT(
|
||||
roomService.joinRoom(roomId, nickName, nickPassword, roomPassword)
|
||||
val newSessionId = Random.nextLong()
|
||||
sessions
|
||||
.update(_.updated(newSessionId, (roomId, playerId)))
|
||||
.as(
|
||||
ResponseCookie(
|
||||
name = authcookieName,
|
||||
content = newSessionId.toString(),
|
||||
secure = false
|
||||
)
|
||||
)
|
||||
.leftMap(_.toString())
|
||||
newSessionId = Random.nextLong()
|
||||
_ <- EitherT.liftF(sessions.update(_.updated(newSessionId, (roomId, playerId))))
|
||||
} yield ResponseCookie(name = authcookie, content = newSessionId.toString(), secure = true)
|
||||
|
||||
result.value
|
||||
}
|
||||
|
||||
override def authUser
|
||||
: Kleisli[[A] =>> cats.data.OptionT[F, A], Request[F], (PlayerID, RoomID)] = {
|
||||
// check authcookie presence, exchange it for playerID ad roomID
|
||||
???
|
||||
Kleisli { (request: Request[F]) =>
|
||||
OptionT(sessions.get.map { sessionsMap =>
|
||||
for {
|
||||
authcookie <- request.cookies.find(_.name == authcookieName)
|
||||
sessionId <- authcookie.content.toLongOption
|
||||
(roomId, playerId) <- sessionsMap.get(sessionId)
|
||||
} yield (playerId, roomId)
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
override def deleteSession(sessionId: Long): F[Unit] = {
|
||||
// i suppose leaving the room should just be authed route & method
|
||||
???
|
||||
override def deleteSession(sessionId: Long): F[ResponseCookie] = {
|
||||
sessions
|
||||
.update(_.removed(sessionId))
|
||||
.as(
|
||||
ResponseCookie(
|
||||
name = authcookieName,
|
||||
content = "",
|
||||
secure = false // TODO make true after enabling https
|
||||
).clearCookie
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
def make[F[_]: Sync](roomsService: RoomService[F]): F[Auth[F]] =
|
||||
def make[F[_]: Sync](): F[Auth[F]] =
|
||||
for {
|
||||
sessionsMap <- Ref.of[F, SessionsMap](
|
||||
Map(1L -> (RoomID("testroom"), PlayerID(1L)))
|
||||
)
|
||||
} yield new SimpleAuth(sessionsMap, roomsService)
|
||||
sessionsMap <- Ref.of[F, SessionsMap](Map.empty)
|
||||
} yield new SimpleAuth(sessionsMap)
|
||||
}
|
||||
|
||||
@@ -14,7 +14,8 @@ object BackendApp extends IOApp {
|
||||
|
||||
val wiring = for {
|
||||
roomService <- Resource.eval(RoomService.make[IO])
|
||||
httpService = MyHttpService.create(Auth.pureBadStub)
|
||||
auth <- Resource.eval(Auth.make[IO]())
|
||||
httpService = MyHttpService.create(auth, roomService)
|
||||
server <- EmberServerBuilder
|
||||
.default[IO]
|
||||
.withHost(host)
|
||||
@@ -24,9 +25,7 @@ object BackendApp extends IOApp {
|
||||
} yield server
|
||||
|
||||
wiring.use(server =>
|
||||
IO.delay(println(s"Server Has Started at ${server.address}")) >> IO.never
|
||||
.as(ExitCode.Success)
|
||||
)
|
||||
IO.delay(println(s"Server Has Started at ${server.address}")) >> IO.never.as(ExitCode.Success))
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
@@ -4,7 +4,6 @@ import cats.effect._
|
||||
import cats.syntax.all._
|
||||
import org.http4s._, org.http4s.dsl.io._, org.http4s.implicits._
|
||||
import org.http4s.websocket.WebSocketFrame
|
||||
// import io.circe.generic.auto._
|
||||
import io.circe.syntax._
|
||||
import org.http4s.circe.CirceEntityDecoder._
|
||||
import scala.concurrent.duration._
|
||||
@@ -16,61 +15,89 @@ import org.http4s.server.AuthMiddleware.apply
|
||||
import org.http4s.server.AuthMiddleware
|
||||
|
||||
object MyHttpService {
|
||||
def create(auth: Auth[IO])(
|
||||
wsb: WebSocketBuilder[cats.effect.IO]
|
||||
def create(auth: Auth[IO], roomService: RoomService[IO])(
|
||||
wsb: WebSocketBuilder[IO]
|
||||
): HttpApp[cats.effect.IO] = {
|
||||
|
||||
val authedRoomRoutes: AuthedRoutes[(PlayerID, RoomID), IO] =
|
||||
AuthedRoutes.of {
|
||||
case GET -> Root / "subscribe" as (playerId, roomId) => {
|
||||
val initial = Stream.evals(roomService.getRoom(roomId))
|
||||
val subscription = roomService.subscribe(roomId)
|
||||
|
||||
val send: Stream[IO, WebSocketFrame] =
|
||||
Stream
|
||||
.emits(TestModels.testChangesList)
|
||||
.covary[IO]
|
||||
.metered(1.second)
|
||||
.map(state => WebSocketFrame.Text(state.asJson.noSpaces))
|
||||
(initial ++ subscription)
|
||||
.evalTap(state => IO(println(s">> sending room state $state to $playerId")))
|
||||
.map(state => WebSocketFrame.Text(state.getViewFor(playerId).asJson.noSpaces))
|
||||
|
||||
val receive: Pipe[IO, WebSocketFrame, Unit] = _.evalMap {
|
||||
case WebSocketFrame.Text(text, _) => Sync[IO].delay(println(text))
|
||||
case other => Sync[IO].delay(println(other))
|
||||
}
|
||||
wsb.build(send, receive)
|
||||
IO(println(s"got ws request from $playerId in $roomId")) >>
|
||||
wsb.build(send, receive)
|
||||
}
|
||||
case GET -> Root / "vote" / vote as (playerId, roomId) => {
|
||||
// TODO forward these to the service implementation
|
||||
IO(println(s">> got $vote from $playerId in $roomId")) >> Ok()
|
||||
IO(println(s">> got $vote from $playerId in $roomId")) >>
|
||||
roomService.acceptVote(roomId, playerId, vote) >> Ok()
|
||||
}
|
||||
case GET -> Root / "end-voting" as (playerId, roomId) => {
|
||||
IO(println(s">> got request to end voting from $playerId in $roomId")) >> Ok()
|
||||
IO(println(s">> got request to end voting from $playerId in $roomId")) >>
|
||||
roomService.endVoting(roomId, playerId) >> Ok()
|
||||
}
|
||||
case GET -> Root / "new-poll" as (playerId, roomId) => {
|
||||
IO(println(s">> got request to start new voting from $playerId in $roomId")) >> Ok()
|
||||
IO(println(s">> got request to start new voting from $playerId in $roomId")) >>
|
||||
roomService.startNewPoll(roomId, playerId) >> Ok()
|
||||
}
|
||||
case GET -> Root / "logout" as (playerId, roomId) => {
|
||||
for {
|
||||
_ <- IO(println(s">> got request to logout from $playerId in $roomId"))
|
||||
_ <- roomService.leaveRoom(roomId, playerId)
|
||||
cookie = ResponseCookie(name = Auth.authcookieName, content = "").clearCookie
|
||||
} yield (Response(Status.Ok).addCookie(cookie))
|
||||
}
|
||||
}
|
||||
|
||||
val authMiddleware = AuthMiddleware(auth.authUser)
|
||||
val aa = authMiddleware(authedRoomRoutes)
|
||||
|
||||
import cats.data.EitherT
|
||||
val authenticationRoute = HttpRoutes
|
||||
.of[IO] {
|
||||
case req @ POST -> Root / "login" => {
|
||||
for {
|
||||
data <- req.as[Requests.LogIn]
|
||||
authResult <- auth.joinRoom(
|
||||
data.roomName,
|
||||
data.password,
|
||||
data.nickname,
|
||||
data.nickPassword)
|
||||
resp <- authResult match {
|
||||
case Left(error) =>
|
||||
Forbidden(error)
|
||||
case Right(authCookie) => {
|
||||
IO(println(s"> logging in ${data.nickname} to ${data.roomName}")) >>
|
||||
Ok().map(_.addCookie(authCookie))
|
||||
}
|
||||
}
|
||||
val responseOrError = for {
|
||||
data <- EitherT.right(req.as[Requests.LogIn])
|
||||
Requests.LogIn(roomName, nickName, roomPassword, nickPassword) = data
|
||||
roomId = RoomID(roomName)
|
||||
playerId <- EitherT(roomService.joinRoom(roomId, nickName, nickPassword, roomPassword))
|
||||
authCookie <- EitherT.liftF(auth.joinRoom(roomId, playerId))
|
||||
_ <- EitherT.liftF(IO(println(s"> logging in $nickName to $roomName")))
|
||||
resp = Response(Status.Ok).addCookie(authCookie)
|
||||
} yield resp
|
||||
|
||||
val response = responseOrError.leftSemiflatMap(error => Forbidden(error.toString())).merge
|
||||
|
||||
response
|
||||
}
|
||||
case req @ POST -> Root / "create-room" => {
|
||||
val responseOrError = for {
|
||||
data <- EitherT.right(req.as[Requests.LogIn])
|
||||
Requests.LogIn(roomName, nickName, roomPassword, nickPassword) = data
|
||||
room <- EitherT(roomService.createRoom(roomName, nickName, nickPassword, roomPassword))
|
||||
owner = room.players.head // TODO add check
|
||||
authCookie <- EitherT.liftF(auth.joinRoom(room.id, owner.id))
|
||||
_ <- EitherT.liftF(
|
||||
IO(println(s"> logging in $nickName to new room $room | $authCookie"))
|
||||
)
|
||||
resp = Response(Status.Ok).addCookie(authCookie)
|
||||
_ <- EitherT.liftF(IO(println(s"> about to reply $resp ${resp.cookies}")))
|
||||
} yield resp
|
||||
|
||||
val response = responseOrError.leftSemiflatMap(error => Forbidden(error.toString())).merge
|
||||
|
||||
response
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
(authenticationRoute <+> authMiddleware(authedRoomRoutes)).orNotFound
|
||||
|
||||
@@ -1,8 +1,10 @@
|
||||
package industries.sunshine.planningpoker
|
||||
|
||||
import industries.sunshine.planningpoker.common.Models.*
|
||||
import cats.effect.{Ref, Sync}
|
||||
import cats.effect.{Ref, Concurrent}
|
||||
import cats.syntax.all._
|
||||
import fs2.Stream
|
||||
import fs2.concurrent.Topic
|
||||
import cats.data.EitherT
|
||||
|
||||
enum RoomError {
|
||||
@@ -13,53 +15,155 @@ enum RoomError {
|
||||
}
|
||||
|
||||
trait RoomService[F[_]] {
|
||||
def createRoom(newRoom: Room): F[Either[RoomError, Room]]
|
||||
def updateRoom(room: Room): F[Unit]
|
||||
def createRoom(
|
||||
roomName: String,
|
||||
nickName: String,
|
||||
nickPassword: String,
|
||||
roomPassword: String
|
||||
): F[Either[RoomError, Room]]
|
||||
def updateRoom(roomId: RoomID, roomUpd: Room => Room): F[Unit]
|
||||
def joinRoom(
|
||||
id: RoomID,
|
||||
nickName: String,
|
||||
nickPassword: String,
|
||||
roomPassword: String
|
||||
): F[Either[RoomError, PlayerID]]
|
||||
def acceptVote(roomID: RoomID, playerID: PlayerID, vote: String): F[Unit]
|
||||
def endVoting(roomID: RoomID, playerID: PlayerID): F[Unit]
|
||||
def startNewPoll(roomID: RoomID, playerID: PlayerID): F[Unit]
|
||||
def leaveRoom(roomID: RoomID, playerID: PlayerID): F[Unit]
|
||||
def deleteRoom(roomID: RoomID): F[Unit]
|
||||
def getRoom(roomID: RoomID): F[Option[Room]]
|
||||
def subscribe(roomID: RoomID): Stream[F, Room]
|
||||
}
|
||||
|
||||
class InMemoryRoomService[F[_]: Sync](stateRef: Ref[F, Map[RoomID, Room]]) extends RoomService[F] {
|
||||
override def createRoom(newRoom: Room): F[Either[RoomError, Room]] = {
|
||||
stateRef.modify { rooms =>
|
||||
rooms.get(newRoom.id) match {
|
||||
case Some(_) =>
|
||||
rooms -> RoomError.RoomAlreadyExists(newRoom.id.name).asLeft[Room]
|
||||
case None =>
|
||||
(rooms.updated(newRoom.id, newRoom)) -> newRoom.asRight[RoomError]
|
||||
class InMemoryRoomService[F[_]: Concurrent](stateRef: Ref[F, Map[RoomID, (Room, Topic[F, Room])]])
|
||||
extends RoomService[F] {
|
||||
|
||||
// TODO accept allowed cards and separate request
|
||||
override def createRoom(
|
||||
roomName: String,
|
||||
nickName: String,
|
||||
nickPassword: String,
|
||||
roomPassword: String
|
||||
): F[Either[RoomError, Room]] = {
|
||||
for {
|
||||
updatesTopic <- Topic[F, Room]
|
||||
room <- stateRef.modify { rooms =>
|
||||
val roomId = RoomID(roomName)
|
||||
rooms.get(roomId) match {
|
||||
case Some(_) =>
|
||||
rooms -> RoomError.RoomAlreadyExists(roomName).asLeft[Room]
|
||||
case None =>
|
||||
val ownerPlayer = Player.create(nickName)
|
||||
val newRoom = Room(
|
||||
roomId,
|
||||
players = List(ownerPlayer),
|
||||
owner = ownerPlayer.name,
|
||||
password = roomPassword,
|
||||
allowedCards = List("XS", "S", "M", "L", "XL"), // TODO accept from front
|
||||
round = RoundState.Voting(Map.empty),
|
||||
playersPasswords = Map(nickName -> nickPassword)
|
||||
)
|
||||
rooms.updated(newRoom.id, (newRoom, updatesTopic)) -> newRoom.asRight[RoomError]
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
override def updateRoom(room: Room): F[Unit] = stateRef.update { state =>
|
||||
state.get(room.id).fold(state)(oldRoom => state.updated(room.id, room))
|
||||
} yield room
|
||||
}
|
||||
|
||||
override def deleteRoom(roomID: RoomID): F[Unit] = stateRef.update(_.removed(roomID))
|
||||
override def updateRoom(roomId: RoomID, roomUpd: Room => Room): F[Unit] = {
|
||||
for {
|
||||
// modify is function to update state and compute auxillary value to return, here - topic
|
||||
publishUpd <- stateRef.modify[F[Unit]] { state =>
|
||||
state.get(roomId) match {
|
||||
case Some((oldRoom, topic)) =>
|
||||
val newRoom = roomUpd(oldRoom)
|
||||
state.updated(roomId, (newRoom, topic)) -> topic.publish1(newRoom).void
|
||||
case None =>
|
||||
throw new IllegalStateException(s"updateRoom with $roomId on nonexistent room")
|
||||
}
|
||||
}
|
||||
_ <-
|
||||
publishUpd // update and publish are not atomic, sadly races can happen (TODO use atomic ref)
|
||||
} yield ()
|
||||
}
|
||||
|
||||
override def getRoom(roomID: RoomID): F[Option[Room]] = stateRef.get.map(_.get(roomID))
|
||||
override def acceptVote(roomID: RoomID, playerID: PlayerID, vote: String): F[Unit] =
|
||||
updateRoom(
|
||||
roomID,
|
||||
room =>
|
||||
room.round match {
|
||||
case RoundState.Viewing(_) => room
|
||||
case RoundState.Voting(votes) =>
|
||||
if (room.allowedCards.contains(vote))
|
||||
room.copy(round = RoundState.Voting(votes.updated(playerID, vote)))
|
||||
else room
|
||||
}
|
||||
)
|
||||
// TODO check permission
|
||||
override def endVoting(roomID: RoomID, playerID: PlayerID): F[Unit] = updateRoom(
|
||||
roomID,
|
||||
room =>
|
||||
room.round match {
|
||||
case RoundState.Viewing(_) => room
|
||||
case RoundState.Voting(votes) => room.copy(round = RoundState.Viewing(votes))
|
||||
}
|
||||
)
|
||||
override def startNewPoll(roomID: RoomID, playerID: PlayerID): F[Unit] = updateRoom(
|
||||
roomID,
|
||||
room =>
|
||||
room.round match {
|
||||
case RoundState.Viewing(_) => room.copy(round = RoundState.Voting(Map.empty))
|
||||
case RoundState.Voting(votes) => room
|
||||
}
|
||||
)
|
||||
|
||||
/** removes player from the active players keeps information on nick password, if one was present
|
||||
*/
|
||||
override def leaveRoom(roomID: RoomID, playerID: PlayerID): F[Unit] = updateRoom(
|
||||
roomID,
|
||||
room =>
|
||||
room.copy(
|
||||
players = room.players.filterNot(_.id == playerID),
|
||||
round = room.round.removePlayer(playerID)
|
||||
)
|
||||
)
|
||||
|
||||
override def deleteRoom(roomID: RoomID): F[Unit] = {
|
||||
for {
|
||||
topic <- stateRef.modify[Topic[F, Room]](state =>
|
||||
state.get(roomID) match {
|
||||
case Some((oldRoom, topic)) => state.removed(roomID) -> topic
|
||||
case None =>
|
||||
throw new IllegalStateException(s"call to delete with $roomID on nonexistent room")
|
||||
// TODO - i'd prefer to swallow these errors
|
||||
}
|
||||
)
|
||||
_ <- topic.close
|
||||
} yield ()
|
||||
}
|
||||
|
||||
override def getRoom(roomID: RoomID): F[Option[Room]] = {
|
||||
stateRef.get.map(_.get(roomID).map(_._1))
|
||||
}
|
||||
|
||||
override def joinRoom(
|
||||
id: RoomID,
|
||||
nickName: String,
|
||||
nickPassword: String,
|
||||
roomPassword: String
|
||||
): F[Either[RoomError, PlayerID]] = stateRef.modify { rooms =>
|
||||
// need to cover cases:
|
||||
// - player already present, then return as is, i guess
|
||||
// - nick not known - add new player and new nick-password mapping
|
||||
// - nick known - add new player
|
||||
): F[Either[RoomError, PlayerID]] = {
|
||||
|
||||
/** pure function that adds the player to the room need to cover cases:
|
||||
* - player already present, then return as is, i guess
|
||||
* - nick not known - add new player and new nick-password mapping
|
||||
* - nick known - add new player
|
||||
*/
|
||||
def addPlayer(room: Room): (PlayerID, Room) = {
|
||||
room.players.find(_.name == nickName) match {
|
||||
case Some(player) => player.id -> room
|
||||
case None => // player is not present, but potentially was previously
|
||||
val addingPlayer = Player.create(nickPassword)
|
||||
val addingPlayer = Player.create(nickName)
|
||||
val roomWithPlayer = room.copy(players = addingPlayer :: room.players)
|
||||
room.playersPasswords.get(nickName) match {
|
||||
case Some(_) => addingPlayer.id -> roomWithPlayer
|
||||
@@ -71,8 +175,19 @@ class InMemoryRoomService[F[_]: Sync](stateRef: Ref[F, Map[RoomID, Room]]) exten
|
||||
}
|
||||
}
|
||||
|
||||
val joiningWithChecks = for {
|
||||
room <- rooms.get(id).toRight(RoomError.RoomMissing(id.name))
|
||||
/** to be executed under Ref.modify (i.e with state acquired) checks of whether player can be
|
||||
* added to the room:
|
||||
* - room password is correct
|
||||
* - nickname is either not taken, or correct password was provided
|
||||
* @returns
|
||||
* playerId (new or existing), updatedRoom (to be put into state), topic (to send the udpdate
|
||||
* notification)
|
||||
*/
|
||||
def getWithChecks(
|
||||
rooms: Map[RoomID, (Room, Topic[F, Room])]
|
||||
): Either[RoomError, (PlayerID, Room, Topic[F, Room])] = for {
|
||||
roomAndTopic <- rooms.get(id).toRight(RoomError.RoomMissing(id.name))
|
||||
(room, topic) = roomAndTopic
|
||||
_ <- Either.cond(room.password == roomPassword, (), RoomError.RoomPassIncorrect)
|
||||
isNickPassCorrect = room.playersPasswords
|
||||
.get(nickName)
|
||||
@@ -83,14 +198,54 @@ class InMemoryRoomService[F[_]: Sync](stateRef: Ref[F, Map[RoomID, Room]]) exten
|
||||
RoomError.NickPassIncorrect
|
||||
)
|
||||
(playerId, updatedRoom) = addPlayer(room)
|
||||
} yield playerId
|
||||
} yield (playerId, updatedRoom, topic)
|
||||
|
||||
rooms -> joiningWithChecks
|
||||
// modify returns tuple (updatedState, valueToReturn)
|
||||
// this particular update either keeps room as is, or adds the player
|
||||
// and returns playerId and topic to be used outside
|
||||
//
|
||||
// NOTE here i have a lot of handwaving to pass topic outside
|
||||
// because it's not possible to send F[Unit] update
|
||||
// inside of the stateRef update (which works with pure functions?),
|
||||
// so room notification change has to be returned to outside
|
||||
val maybeUpdatedStateAndNotification = stateRef.modify { rooms =>
|
||||
val maybeAddedUser = getWithChecks(rooms)
|
||||
val updatedState =
|
||||
maybeAddedUser.fold(
|
||||
_ => rooms,
|
||||
{ case (playerId, updatedRoom, topic) => rooms.updated(id, (updatedRoom, topic)) }
|
||||
)
|
||||
val toReturn = maybeAddedUser.map { case (id, updatedRoom, topic) =>
|
||||
(id, topic.publish1(updatedRoom).void)
|
||||
}
|
||||
updatedState -> toReturn
|
||||
}
|
||||
|
||||
// now combining the effects : getting (updatedState & notificationEffect) or error
|
||||
// executing notification
|
||||
// returning only playerId
|
||||
val result = for {
|
||||
updatedState <- EitherT(maybeUpdatedStateAndNotification)
|
||||
(playerId, notification) = updatedState
|
||||
_ <- EitherT.liftF(notification)
|
||||
} yield (playerId)
|
||||
|
||||
result.value
|
||||
}
|
||||
|
||||
override def subscribe(roomID: RoomID): Stream[F, Room] =
|
||||
Stream
|
||||
.eval(stateRef.get)
|
||||
.flatMap(rooms =>
|
||||
rooms.get(roomID) match {
|
||||
case Some((room, topic)) => topic.subscribe(10)
|
||||
case None => Stream.empty
|
||||
}
|
||||
)
|
||||
|
||||
}
|
||||
object RoomService {
|
||||
def make[F[_]: Sync]: F[RoomService[F]] = {
|
||||
Ref.of[F, Map[RoomID, Room]](Map.empty).map(new InMemoryRoomService[F](_))
|
||||
def make[F[_]: Concurrent]: F[RoomService[F]] = {
|
||||
Ref.of[F, Map[RoomID, (Room, Topic[F, Room])]](Map.empty).map(new InMemoryRoomService[F](_))
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import org.scalajs.linker.interface.ModuleSplitStyle
|
||||
|
||||
lazy val commonSettings = Seq(
|
||||
version := "0.1.1",
|
||||
scalaVersion := "3.2.0"
|
||||
)
|
||||
|
||||
@@ -33,7 +34,8 @@ lazy val frontend = project
|
||||
libraryDependencies += "org.scala-js" %%% "scalajs-dom" % "2.4.0",
|
||||
libraryDependencies += "com.raquo" %%% "laminar" % "15.0.1",
|
||||
libraryDependencies += "io.laminext" %%% "websocket-circe" % "0.15.0",
|
||||
libraryDependencies += "io.laminext" %%% "fetch" % "0.15.0"
|
||||
libraryDependencies += "io.laminext" %%% "fetch-circe" % "0.15.0",
|
||||
libraryDependencies += "io.laminext" %%% "validation-cats" % "0.15.0"
|
||||
)
|
||||
.dependsOn(common.js)
|
||||
|
||||
|
||||
@@ -17,33 +17,32 @@ object Models {
|
||||
* \- whether current player has access to button to finish the round
|
||||
*/
|
||||
final case class RoomStateView(
|
||||
roomName: String,
|
||||
players: List[Player],
|
||||
me: PlayerID,
|
||||
allowedCards: List[String],
|
||||
round: RoundState,
|
||||
round: RoundStateView,
|
||||
canCloseRound: Boolean = false
|
||||
) derives Codec.AsObject {
|
||||
def playersCount: Int = players.size
|
||||
}
|
||||
) derives Codec.AsObject
|
||||
|
||||
object RoomStateView {
|
||||
val empty = RoomStateView(
|
||||
"",
|
||||
List.empty,
|
||||
PlayerID(0),
|
||||
List.empty,
|
||||
RoundState.Voting(None, List.empty),
|
||||
RoundStateView.Voting(None, List.empty),
|
||||
false
|
||||
)
|
||||
}
|
||||
|
||||
enum RoundState derives Codec.AsObject:
|
||||
|
||||
enum RoundStateView derives Codec.AsObject:
|
||||
/** view state for round before votes are open player can know their vote and who of the other
|
||||
* players have voted
|
||||
*/
|
||||
case Voting(
|
||||
myCard: Option[String],
|
||||
alreadyVoted: List[Player]
|
||||
alreadyVoted: List[PlayerID]
|
||||
)
|
||||
|
||||
/** view state for round after opening the votes
|
||||
@@ -51,53 +50,59 @@ object Models {
|
||||
case Viewing(
|
||||
votes: List[(PlayerID, String)]
|
||||
)
|
||||
final case class PlayerID(id: Long) derives Codec.AsObject
|
||||
|
||||
final case class PlayerID(id: Long) derives Codec.AsObject
|
||||
final case class Player(name: String, id: PlayerID) derives Codec.AsObject
|
||||
object Player {
|
||||
def create(name: String) = Player(name, PlayerID(Random.nextLong))
|
||||
}
|
||||
|
||||
final case class RoomID(name: String) derives Codec.AsObject
|
||||
|
||||
final case class Room(
|
||||
id: RoomID,
|
||||
players: List[Player],
|
||||
owner: PlayerID,
|
||||
owner: String, // TODO switch to nickname
|
||||
password: String,
|
||||
allowedCards: List[String],
|
||||
round: RoundState,
|
||||
playersPasswords: Map[String, String] = Map.empty // nickname into password
|
||||
playersPasswords: Map[String, String] = Map.empty, // nickname into password
|
||||
) {
|
||||
def toViewFor(playerId: PlayerID): RoomStateView = {
|
||||
def getViewFor(playerId: PlayerID): RoomStateView = {
|
||||
players
|
||||
.find(_.id == playerId)
|
||||
.fold(ifEmpty = RoomStateView.empty)((me: Player) =>
|
||||
RoomStateView(
|
||||
id.name,
|
||||
players,
|
||||
me.id,
|
||||
allowedCards,
|
||||
round,
|
||||
playerId == owner
|
||||
round.toViewFor(playerId),
|
||||
me.name == owner
|
||||
)
|
||||
)
|
||||
}
|
||||
}
|
||||
object Room {
|
||||
val testRoom = Room(
|
||||
id = RoomID("testroom"),
|
||||
players = List(
|
||||
Player("me", PlayerID(1L)),
|
||||
Player("horsey", PlayerID(444L)),
|
||||
Player("froggy", PlayerID(555L)),
|
||||
Player("owley", PlayerID(777L))
|
||||
),
|
||||
owner = PlayerID(1L),
|
||||
password = "password",
|
||||
allowedCards = List("S", "M", "L"),
|
||||
// TODO - this needs to be a different hting
|
||||
round = RoundState.Voting(None, List.empty)
|
||||
)
|
||||
}
|
||||
|
||||
// no need to send to the front end, no deed to derive codec, cool
|
||||
sealed trait RoundState {
|
||||
def toViewFor(player: PlayerID): RoundStateView
|
||||
def removePlayer(id: PlayerID): RoundState
|
||||
}
|
||||
object RoundState {
|
||||
final case class Voting(votes: Map[PlayerID, String]) extends RoundState {
|
||||
override def toViewFor(playerId: PlayerID): RoundStateView.Voting = RoundStateView.Voting(
|
||||
myCard = votes.get(playerId),
|
||||
alreadyVoted = votes.filterKeys(id => id != playerId).keys.toList
|
||||
)
|
||||
override def removePlayer(id: PlayerID): RoundState.Voting =
|
||||
RoundState.Voting(votes.filterKeys(_ != id).toMap)
|
||||
}
|
||||
|
||||
final case class Viewing(votes: Map[PlayerID, String]) extends RoundState {
|
||||
override def toViewFor(player: PlayerID): RoundStateView.Viewing =
|
||||
RoundStateView.Viewing(votes.toList)
|
||||
override def removePlayer(id: PlayerID): RoundState.Viewing =
|
||||
RoundState.Viewing(votes.filterKeys(_ != id).toMap)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -3,104 +3,100 @@ package industries.sunshine.planningpoker
|
||||
import industries.sunshine.planningpoker.common.Models.*
|
||||
|
||||
object TestModels {
|
||||
val me = Player("wormy", PlayerID(1))
|
||||
val me = Player("me", PlayerID(1))
|
||||
val pony = Player("pony", PlayerID(10))
|
||||
val birdy = Player("birdy", PlayerID(11))
|
||||
val horsey = Player("horsey", PlayerID(12))
|
||||
|
||||
val testRoom = {
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = Some("s"), alreadyVoted = List(me, pony)),
|
||||
canCloseRound = true
|
||||
)
|
||||
}
|
||||
val testOpenedRoom = {
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony, horsey),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Viewing(
|
||||
List(me.id -> "xs", pony.id -> "l", birdy.id -> "s", horsey.id -> "m")
|
||||
),
|
||||
canCloseRound = true
|
||||
)
|
||||
}
|
||||
// val testRoomBackend = Room(
|
||||
// id = RoomID("testroom"),
|
||||
// players = List(me, birdy, pony, horsey),
|
||||
// owner = me.id,
|
||||
// password = "password",
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundState.Viewing(
|
||||
// Map(me.id -> "xs", pony.id -> "l", birdy.id -> "s", horsey.id -> "m")
|
||||
// ),
|
||||
// playersPasswords = Map("me" -> "nickpassword") // nickname into password
|
||||
// )
|
||||
|
||||
val testChangesList = List(
|
||||
RoomStateView(
|
||||
players = List(me),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = None, alreadyVoted = List.empty),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, pony),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = None, alreadyVoted = List.empty),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = None, alreadyVoted = List.empty),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = None, alreadyVoted = List(birdy)),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = Some("m"), alreadyVoted = List(birdy)),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = Some("m"), alreadyVoted = List(birdy)),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony, horsey),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = Some("m"), alreadyVoted = List(birdy)),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony, horsey),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = Some("m"), alreadyVoted = List(birdy, horsey)),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony, horsey),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Voting(myCard = Some("m"), alreadyVoted = List(birdy, horsey, pony)),
|
||||
canCloseRound = true
|
||||
),
|
||||
RoomStateView(
|
||||
players = List(me, birdy, pony, horsey),
|
||||
me = me.id,
|
||||
allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
round = RoundState.Viewing(
|
||||
List(me.id -> "m", pony.id -> "l", birdy.id -> "s", horsey.id -> "m")
|
||||
),
|
||||
canCloseRound = true
|
||||
)
|
||||
)
|
||||
// val testSessionId = 1L
|
||||
// val testSessions = Map(testSessionId -> (testRoomBackend.id, me.id))
|
||||
// val testRooms = Map(testRoomBackend.id -> testRoomBackend)
|
||||
|
||||
// val testChangesList = List(
|
||||
// RoomStateView(
|
||||
// players = List(me),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = None, alreadyVoted = List.empty),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, pony),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = None, alreadyVoted = List.empty),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = None, alreadyVoted = List.empty),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = None, alreadyVoted = List(birdy.id)),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = Some("m"), alreadyVoted = List(birdy.id)),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = Some("m"), alreadyVoted = List(birdy.id)),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony, horsey),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = Some("m"), alreadyVoted = List(birdy.id)),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony, horsey),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Voting(myCard = Some("m"), alreadyVoted = List(birdy.id, horsey.id)),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony, horsey),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView
|
||||
// .Voting(myCard = Some("m"), alreadyVoted = List(birdy.id, horsey.id, pony.id)),
|
||||
// canCloseRound = true
|
||||
// ),
|
||||
// RoomStateView(
|
||||
// players = List(me, birdy, pony, horsey),
|
||||
// me = me.id,
|
||||
// allowedCards = List("xs", "s", "m", "l", "xl"),
|
||||
// round = RoundStateView.Viewing(
|
||||
// List(me.id -> "m", pony.id -> "l", birdy.id -> "s", horsey.id -> "m")
|
||||
// ),
|
||||
// canCloseRound = true
|
||||
// )
|
||||
// )
|
||||
}
|
||||
|
||||
40
flake.lock
generated
40
flake.lock
generated
@@ -18,6 +18,21 @@
|
||||
"type": "github"
|
||||
}
|
||||
},
|
||||
"flake-utils_2": {
|
||||
"locked": {
|
||||
"lastModified": 1667395993,
|
||||
"narHash": "sha256-nuEHfE/LcWyuSWnS8t12N1wc105Qtau+/OdUAjtQ0rA=",
|
||||
"owner": "numtide",
|
||||
"repo": "flake-utils",
|
||||
"rev": "5aed5285a952e0b949eb3ba02c12fa4fcfef535f",
|
||||
"type": "github"
|
||||
},
|
||||
"original": {
|
||||
"owner": "numtide",
|
||||
"repo": "flake-utils",
|
||||
"type": "github"
|
||||
}
|
||||
},
|
||||
"nixpkgs": {
|
||||
"locked": {
|
||||
"lastModified": 1682080641,
|
||||
@@ -36,7 +51,30 @@
|
||||
"root": {
|
||||
"inputs": {
|
||||
"flake-utils": "flake-utils",
|
||||
"nixpkgs": "nixpkgs"
|
||||
"nixpkgs": "nixpkgs",
|
||||
"sbt-derivation": "sbt-derivation"
|
||||
}
|
||||
},
|
||||
"sbt-derivation": {
|
||||
"inputs": {
|
||||
"flake-utils": "flake-utils_2",
|
||||
"nixpkgs": [
|
||||
"nixpkgs"
|
||||
]
|
||||
},
|
||||
"locked": {
|
||||
"lastModified": 1675083208,
|
||||
"narHash": "sha256-+sSFhSpV2jckr1qYlX/SaxQ6IdpagD6o4rru/3HAl0I=",
|
||||
"owner": "zaninime",
|
||||
"repo": "sbt-derivation",
|
||||
"rev": "92d6d6d825e3f6ae5642d1cce8ff571c3368aaf7",
|
||||
"type": "github"
|
||||
},
|
||||
"original": {
|
||||
"owner": "zaninime",
|
||||
"ref": "master",
|
||||
"repo": "sbt-derivation",
|
||||
"type": "github"
|
||||
}
|
||||
},
|
||||
"systems": {
|
||||
|
||||
140
flake.nix
140
flake.nix
@@ -1,27 +1,127 @@
|
||||
{
|
||||
description = "Planning Poker web app. Trying to build something and learn new things";
|
||||
description =
|
||||
"Planning Poker web app. Trying to build something and learn new things";
|
||||
inputs.nixpkgs.url = "github:nixos/nixpkgs";
|
||||
inputs.flake-utils.url = "github:numtide/flake-utils";
|
||||
inputs.sbt-derivation.url = "github:zaninime/sbt-derivation/master";
|
||||
inputs.sbt-derivation.inputs.nixpkgs.follows = "nixpkgs";
|
||||
|
||||
outputs = { self, nixpkgs, flake-utils }:
|
||||
flake-utils.lib.eachDefaultSystem
|
||||
(system:
|
||||
let pkgs = nixpkgs.legacyPackages.${system}; in
|
||||
{
|
||||
devShells.default = pkgs.mkShell {
|
||||
buildInputs = [
|
||||
pkgs.nodejs
|
||||
pkgs.sbt
|
||||
pkgs.scalafmt
|
||||
pkgs.jdk
|
||||
# pkgs.nodePackages.tailwindcss
|
||||
# pkgs.nodePackages.postcss
|
||||
];
|
||||
shellHook = ''
|
||||
echo "dev env for planning poker BWARGH started"
|
||||
'';
|
||||
outputs = { self, nixpkgs, flake-utils, sbt-derivation }:
|
||||
flake-utils.lib.eachDefaultSystem (system:
|
||||
let
|
||||
pkgs = nixpkgs.legacyPackages.${system};
|
||||
packageName = "planning-poker-kazbegi";
|
||||
backendName = "${packageName}-backend";
|
||||
version = "0.1.1";
|
||||
backendPackage = sbt-derivation.lib.mkSbtDerivation rec {
|
||||
inherit pkgs version;
|
||||
|
||||
# ...and the rest of the arguments
|
||||
pname = "${backendName}";
|
||||
depsSha256 = "sha256-7MNlMeljYqXY4/kK4BXoycp9xUz0tGwCQvPTlE1RIQU=";
|
||||
src = pkgs.nix-gitignore.gitignoreSource [ ] ./.;
|
||||
buildPhase = ''
|
||||
sbt backend/assembly
|
||||
'';
|
||||
installPhase = ''
|
||||
mkdir -p $out/bin
|
||||
cp backend/target/scala-*/backend-assembly-*.jar $out/bin/${pname}.jar
|
||||
'';
|
||||
};
|
||||
in {
|
||||
# Development shell with things required for local dev
|
||||
devShells.default = pkgs.mkShell {
|
||||
buildInputs = [
|
||||
pkgs.nodejs
|
||||
pkgs.sbt
|
||||
pkgs.scalafmt
|
||||
pkgs.jdk
|
||||
# pkgs.nodePackages.tailwindcss
|
||||
# pkgs.nodePackages.postcss
|
||||
];
|
||||
shellHook = ''
|
||||
echo "dev env for planning poker BWARGH started"
|
||||
'';
|
||||
};
|
||||
# Just the backend jar
|
||||
packages.backend = backendPackage;
|
||||
# Module for NixOS to allow starting backend as SystemD service
|
||||
nixosModules.backendApp = { config, pkgs, ... }:
|
||||
let
|
||||
cfg = config.services.${backendName};
|
||||
lib = pkgs.lib;
|
||||
in {
|
||||
options.services.${backendName} = {
|
||||
enable =
|
||||
lib.mkEnableOption "My frontendmentor exercise ${backendName}";
|
||||
|
||||
port = lib.mkOption {
|
||||
type = lib.types.int;
|
||||
default = 8080;
|
||||
description = "Port to listen on.";
|
||||
};
|
||||
|
||||
host = lib.mkOption {
|
||||
type = lib.types.str;
|
||||
default = "localhost";
|
||||
description = "Host to bind to.";
|
||||
};
|
||||
|
||||
useNginx = lib.mkOption {
|
||||
type = lib.types.bool;
|
||||
default = true;
|
||||
description = "Whether to use Nginx to proxy requests.";
|
||||
};
|
||||
useHostTls = lib.mkOption {
|
||||
type = lib.types.bool;
|
||||
default = false;
|
||||
description =
|
||||
"Whether virtual host should enable NixOS ACME certs";
|
||||
};
|
||||
};
|
||||
config.users = lib.mkIf cfg.enable {
|
||||
groups."${backendName}" = { };
|
||||
users."${backendName}" = {
|
||||
isSystemUser = true;
|
||||
group = "${backendName}";
|
||||
};
|
||||
};
|
||||
config.systemd.services.${backendName} = lib.mkIf cfg.enable {
|
||||
description = "Exercise app ${backendName}";
|
||||
wantedBy = [ "multi-user.target" ];
|
||||
after = [ "network.target" ];
|
||||
startLimitIntervalSec = 30;
|
||||
startLimitBurst = 10;
|
||||
serviceConfig =
|
||||
let serverHost = if cfg.useNginx then "localhost" else cfg.host;
|
||||
in {
|
||||
ExecStart =
|
||||
"${pkgs.jdk}/bin/java -jar ${backendPackage}/bin/${backendName}.jar -p ${
|
||||
toString cfg.port
|
||||
} --host ${serverHost}";
|
||||
WorkingDirectory = "${backendPackage}/bin";
|
||||
Restart = "on-failure";
|
||||
User = "${backendName}";
|
||||
Group = "${backendName}";
|
||||
};
|
||||
};
|
||||
config.services.nginx.virtualHosts.${cfg.host} = {
|
||||
forceSSL = cfg.useHostTls;
|
||||
enableACME = cfg.useHostTls;
|
||||
locations."/api" = lib.mkIf cfg.enable {
|
||||
proxyPass = "http://127.0.0.1:${toString cfg.port}";
|
||||
# this is config for websocket
|
||||
proxyWebsockets = true;
|
||||
extraConfig = ''
|
||||
rewrite ^/api/(.*)$ /$1 break;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
|
||||
proxy_set_header X-Forwarded-Proto $scheme;
|
||||
'';
|
||||
};
|
||||
};
|
||||
};
|
||||
}
|
||||
);
|
||||
});
|
||||
# see https://serokell.io/blog/practical-nix-flakes
|
||||
}
|
||||
|
||||
@@ -20,48 +20,18 @@ def FrontendMain(): Unit =
|
||||
)
|
||||
|
||||
object Main {
|
||||
final case class AppState(
|
||||
myId: Option[PlayerID]
|
||||
)
|
||||
// TODO is this ok for state creation? link with auth component and use in another?
|
||||
val appStateSignal = Var(AppState(Some(TestModels.me.id))).signal
|
||||
val staticStateSignal = Var(TestModels.testRoom).signal
|
||||
|
||||
import io.laminext.websocket.circe.WebSocket._
|
||||
import io.laminext.websocket.circe.webSocketReceiveBuilderSyntax
|
||||
|
||||
val roomStateWSStream = io.laminext.websocket.WebSocket
|
||||
.path("/api/subscribe")
|
||||
.json[RoomStateView, Unit]
|
||||
.build(
|
||||
managed = true,
|
||||
autoReconnect = false,
|
||||
reconnectDelay = 1.second,
|
||||
reconnectDelayOffline = 20.seconds,
|
||||
reconnectRetries = 1
|
||||
)
|
||||
|
||||
val stateStream = roomStateWSStream.received
|
||||
// and what's the difference between EventStream and Signal???
|
||||
val stateSignal =
|
||||
stateStream.startWith(RoomStateView.empty)
|
||||
|
||||
// NOTE let's try with fetch \ rest
|
||||
// import io.laminext.fetch.Fetch
|
||||
// import com.raquo.laminar.api.L._
|
||||
// import scala.concurrent.ExecutionContext.Implicits.global
|
||||
// val testRest = Fetch.get("http://0.0.0.0:5173/api/subscribe").text
|
||||
val loggedIn = Var(true)
|
||||
|
||||
import scala.scalajs.js.Dynamic.{global => g}
|
||||
def appElement(): Element = {
|
||||
div(
|
||||
className := "w-screen h-screen flex flex-col justify-center items-center",
|
||||
div(
|
||||
className := "h-24 w-full flex flex-for justify-center items-center bg-green-200",
|
||||
p(className := "text-2xl", "Here be header")
|
||||
Header.render(loggedIn.writer, loggedIn.signal),
|
||||
child <-- loggedIn.signal.map(if (_) emptyNode else JoinRoomComponent.render(loggedIn.writer)),
|
||||
child <-- loggedIn.signal.map(
|
||||
if (_) RoomView.renderRoom(loggedIn.writer) else emptyNode
|
||||
),
|
||||
RoomView.renderRoom(stateSignal),
|
||||
roomStateWSStream.connect
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,31 @@
|
||||
package industries.sunshine.planningpoker
|
||||
|
||||
import scala.scalajs.js
|
||||
import scala.scalajs.js.annotation.*
|
||||
import com.raquo.laminar.api.L.{*, given}
|
||||
import io.laminext.fetch.Fetch
|
||||
import io.laminext.fetch.FetchResponse
|
||||
import scala.scalajs.js.Dynamic.{global => g}
|
||||
|
||||
import concurrent.ExecutionContext.Implicits.global
|
||||
|
||||
object Header {
|
||||
def render(loggedInObserver: Observer[Boolean], loggedInSignal: Signal[Boolean]): Element = {
|
||||
val (responsesStream, responseReceived) = EventStream.withCallback[FetchResponse[String]]
|
||||
|
||||
val logoutButton = button(
|
||||
"Leave Room",
|
||||
className := "border border-black m-2 p-2 absolute right-2",
|
||||
onClick.flatMap(_ => Fetch.get("/api/logout").text) --> responseReceived,
|
||||
responsesStream --> Observer(resp => g.console.info(s"${resp.toString()}")),
|
||||
responsesStream.collect { case resp if resp.ok => false } --> loggedInObserver
|
||||
)
|
||||
val cachedEmpty = emptyNode
|
||||
|
||||
div(
|
||||
className := "h-24 w-full flex flex-for justify-center items-center bg-green-200",
|
||||
p(className := "text-2xl", "Planning Poker Kazbegi (nonpretty prealpha version)"),
|
||||
child <-- loggedInSignal.map(if (_) logoutButton else cachedEmpty)
|
||||
)
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,181 @@
|
||||
package industries.sunshine.planningpoker
|
||||
|
||||
import scala.scalajs.js
|
||||
import scala.scalajs.js.annotation.*
|
||||
import com.raquo.laminar.api.L.{*, given}
|
||||
import io.laminext.fetch.Fetch
|
||||
import io.laminext.fetch.circe._
|
||||
|
||||
import io.laminext.syntax.core._
|
||||
import io.laminext.syntax.validation._
|
||||
|
||||
import scala.util.Failure
|
||||
import scala.util.Success
|
||||
|
||||
import concurrent.ExecutionContext.Implicits.global
|
||||
|
||||
object JoinRoomComponent {
|
||||
// TODO inputs for room name, room password, nick name, nick password
|
||||
// do the get to /login route
|
||||
// display errors if any.
|
||||
// but then what? attempt to start the websocket?
|
||||
// and if websocket closed show this component,
|
||||
// if it's open - doesn't show this component, show the room.
|
||||
// i suppose it should be managed on a level up
|
||||
// or rather what? ws stream should be retried every time someone presses submit button
|
||||
// and receives 200 ok
|
||||
// so, parent page should send in observer for the successful auth. and on that observer - start \ restart the websocket
|
||||
def nameInput(data: Var[String], placeholderText: String) = input(
|
||||
className := "border-2 m-1 rounded",
|
||||
placeholder := placeholderText,
|
||||
controlled(
|
||||
value <-- data.signal,
|
||||
onInput.mapToValue --> data.writer
|
||||
)
|
||||
).validated(V.nonBlank("name must not be blank"))
|
||||
|
||||
def passInput(data: Var[String], placeholderText: String) = input(
|
||||
tpe := "password",
|
||||
className := "border-2 m-1 rounded",
|
||||
placeholder := placeholderText,
|
||||
controlled(
|
||||
value <-- data.signal,
|
||||
onInput.mapToValue --> data.writer
|
||||
)
|
||||
)
|
||||
|
||||
val roomNameVar = Var("")
|
||||
val roomPassVar = Var("")
|
||||
val nicknameVar = Var("")
|
||||
val nicknamePass = Var("")
|
||||
|
||||
val (responsesStream, responseReceived) = EventStream.withCallback[FetchResponse[String]]
|
||||
|
||||
def render(loggedIn: Observer[Boolean]): Element = {
|
||||
|
||||
val submitButton = button(
|
||||
"Join room",
|
||||
className := "m-1 border-2 rounded-full border-green-400 bg-green-200 shadow-inner shadow-green-400 active:shadow-yellow-400 duration-100 ease-linear",
|
||||
onClick
|
||||
.mapTo {
|
||||
(roomNameVar.now(), roomPassVar.now(), nicknameVar.now(), nicknamePass.now())
|
||||
}
|
||||
.flatMap { case (roomName, roomPass, nickname, nicknamePass) =>
|
||||
Fetch
|
||||
.post(
|
||||
"/api/login",
|
||||
body = Requests.LogIn(
|
||||
roomName,
|
||||
nickname,
|
||||
roomPass,
|
||||
nicknamePass
|
||||
)
|
||||
)
|
||||
.text
|
||||
.map { response =>
|
||||
if (response.ok) {
|
||||
loggedIn.onNext(true)
|
||||
response
|
||||
} else response
|
||||
}
|
||||
} --> responseReceived
|
||||
)
|
||||
val newRoomButton = button(
|
||||
className := "m-1 border-2 rounded-full border-yellow-400 bg-yellow-200 shadow-inner shadow-yellow-400 active:shadow-red-400 duration-100 ease-linear",
|
||||
"Create new room",
|
||||
onClick
|
||||
.mapTo {
|
||||
(roomNameVar.now(), roomPassVar.now(), nicknameVar.now(), nicknamePass.now())
|
||||
}
|
||||
.flatMap { case (roomName, roomPass, nickname, nicknamePass) =>
|
||||
Fetch
|
||||
.post(
|
||||
"/api/create-room",
|
||||
body = Requests.LogIn(
|
||||
roomName,
|
||||
nickname,
|
||||
roomPass,
|
||||
nicknamePass
|
||||
)
|
||||
)
|
||||
.text
|
||||
.map { response =>
|
||||
if (response.ok) {
|
||||
loggedIn.onNext(true)
|
||||
response
|
||||
} else response
|
||||
}
|
||||
} --> responseReceived
|
||||
)
|
||||
|
||||
val roomNameInput = nameInput(roomNameVar, "Enter room name:")
|
||||
val roomPassInput = passInput(roomPassVar, "room password")
|
||||
val nickNameInput = nameInput(nicknameVar, "Enter your nickname:")
|
||||
val nickPassInput = passInput(nicknamePass, "nickname pass")
|
||||
div(
|
||||
className := "bg-green-50 w-full h-full flex justify-center",
|
||||
div(
|
||||
className := "w-60 flex flex-col justify-center",
|
||||
"Logging in:",
|
||||
roomNameInput,
|
||||
div(
|
||||
child.maybe <-- roomNameInput.validationError.optionMap(errors =>
|
||||
span(
|
||||
cls := "text-red-700 text-sm",
|
||||
errors.map(error => div(error))
|
||||
)
|
||||
)
|
||||
),
|
||||
roomPassInput,
|
||||
label("Alert: no https, please use throwaway passwords"),
|
||||
nickNameInput,
|
||||
div(
|
||||
child.maybe <-- nickNameInput.validationError.optionMap(errors =>
|
||||
span(
|
||||
cls := "text-red-700 text-sm",
|
||||
errors.map(error => div(error))
|
||||
)
|
||||
)
|
||||
),
|
||||
nickPassInput,
|
||||
submitButton,
|
||||
newRoomButton,
|
||||
div(
|
||||
div(
|
||||
code("error log:")
|
||||
),
|
||||
div(
|
||||
cls := "flex flex-col space-y-4 p-4 max-h-96 overflow-auto bg-gray-900",
|
||||
children.command <-- responsesStream.recoverToTry.map {
|
||||
case Success(response) => {
|
||||
CollectionCommand.Append(
|
||||
div(
|
||||
div(
|
||||
cls := "flex space-x-2 items-center",
|
||||
code(cls := "text-green-500", "Status: "),
|
||||
code(cls := "text-green-300", s"${response.status} ${response.statusText}")
|
||||
),
|
||||
div(
|
||||
cls := "text-green-400 text-xs",
|
||||
code(response.data)
|
||||
)
|
||||
)
|
||||
)
|
||||
}
|
||||
case Failure(exception) =>
|
||||
CollectionCommand.Append(
|
||||
div(
|
||||
div(
|
||||
cls := "flex space-x-2 items-center",
|
||||
code(cls := "text-red-500", "Error: "),
|
||||
code(cls := "text-red-300", exception.getMessage)
|
||||
)
|
||||
)
|
||||
)
|
||||
}
|
||||
)
|
||||
)
|
||||
)
|
||||
)
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,70 @@
|
||||
package industries.sunshine.planningpoker
|
||||
|
||||
import scala.scalajs.js
|
||||
import com.raquo.laminar.api.L.{*, given}
|
||||
import industries.sunshine.planningpoker.common.Models.*
|
||||
|
||||
object OtherPlayers {
|
||||
def render(roomStateSignal: Signal[RoomStateView]): Element = {
|
||||
val otherPlayers = roomStateSignal.map { state =>
|
||||
state.players.filterNot(_.id == state.me).zipWithIndex
|
||||
}
|
||||
def playerCardsAmountSignal(id: PlayerID): Signal[Int] = {
|
||||
roomStateSignal.map(state => {
|
||||
val totalCards = state.allowedCards.size
|
||||
val playerModification = state.round match {
|
||||
case RoundStateView.Viewing(votes) if votes.toMap.contains(id) => -1
|
||||
case RoundStateView.Voting(_, votedPlayers) if votedPlayers.contains(id) => -1
|
||||
case _ => 0
|
||||
}
|
||||
|
||||
totalCards + playerModification
|
||||
})
|
||||
}
|
||||
|
||||
div(
|
||||
className := "flex flex-row",
|
||||
children <-- otherPlayers.split(_._1.id) { (playerID, initial, playerSignal) =>
|
||||
renderPlayer(playerSignal, playerCardsAmountSignal(playerID))
|
||||
}
|
||||
)
|
||||
}
|
||||
|
||||
def renderPlayer(p: Signal[(Player, Int)], cardsAmount: Signal[Int]): Element = {
|
||||
val xOffsetStyleSignal = p.map(_._2)
|
||||
div(
|
||||
className := "bg-green-200 border-b-2 border-black rounded p-2 m-2 absolute drop-shadow-xl m-3",
|
||||
styleAttr <-- p.map(tuple => s"left: ${(0 + tuple._2) * 200}px"),
|
||||
child.text <-- p.map(_._1.name),
|
||||
renderHandCardBacks(cardsAmount)
|
||||
)
|
||||
}
|
||||
|
||||
/**
|
||||
* adds css variables to be used in tailwindcss classes
|
||||
*/
|
||||
def dynamicCardStyle(index: Int, totalCards: Int): String = {
|
||||
val offCenterIndex = 2*index - (totalCards + 1)
|
||||
val maxOffCenter = (totalCards + 1) / 2
|
||||
val angle = Math.round((offCenterIndex / maxOffCenter.toDouble) * 25)
|
||||
val xOffset = (offCenterIndex * 0.2)
|
||||
s" --custom-rotate: ${angle}deg; --custom-x-translate: ${xOffset}rem; "
|
||||
}
|
||||
|
||||
def renderHandCardBacks(amountSignal: Signal[Int]): Element = {
|
||||
def renderCard(index: Int, totalCards: Int): Element =
|
||||
div(
|
||||
className := "w-8 h-12 rounded bg-green-500 text-yellow m-1 border border-green-700 drop-shadow-md",
|
||||
className := "origin-bottom rotate-[--custom-rotate] translate-x-[--custom-x-translate]",
|
||||
className := "absolute start-5",
|
||||
styleAttr := dynamicCardStyle(index, totalCards),
|
||||
|
||||
)
|
||||
|
||||
div(
|
||||
className := "relative h-16 w-20",
|
||||
children <-- amountSignal.map { amount => (1 to amount).map(renderCard(_, amount)) }
|
||||
)
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,61 @@
|
||||
package industries.sunshine.planningpoker
|
||||
|
||||
import scala.scalajs.js
|
||||
import com.raquo.laminar.api.L.{*, given}
|
||||
import industries.sunshine.planningpoker.common.Models.*
|
||||
import io.laminext.fetch.Fetch
|
||||
import scala.scalajs.js.Dynamic.{global => g}
|
||||
|
||||
import concurrent.ExecutionContext.Implicits.global
|
||||
|
||||
object OwnHandControls {
|
||||
def render(roomStateSignal: Signal[RoomStateView]): Element = {
|
||||
val cardTypesSignal = roomStateSignal.map(myUnselectedCards(_))
|
||||
div(
|
||||
className := " h-1/3 relative",
|
||||
children <-- cardTypesSignal.map(cards => cards.map(renderCard(_, cards.size))),
|
||||
)
|
||||
}
|
||||
|
||||
/**
|
||||
* adds css variables to be used in tailwindcss classes
|
||||
*/
|
||||
def dynamicCardStyle(index: Int, totalCards: Int): String = {
|
||||
val offCenterIndex = 2*index - (totalCards + 1)
|
||||
val maxOffCenter = (totalCards + 1) / 2
|
||||
val angle = Math.round((offCenterIndex / maxOffCenter.toDouble) * 17)
|
||||
val xOffset = offCenterIndex * 1.4
|
||||
val yOffset = -1.7 + Math.pow( Math.abs( offCenterIndex ), 1.5) * 0.2
|
||||
s" --custom-rotate: ${angle}deg; --custom-x-translate: ${xOffset}rem; --custom-y-translate: ${yOffset}rem"
|
||||
}
|
||||
|
||||
private def renderCard(cardWithIndex: (String, Int), totalCards: Int): Element = {
|
||||
val (value, index) = cardWithIndex
|
||||
val submitVote = Fetch.get(s"/api/vote/$value").text
|
||||
|
||||
div(
|
||||
className := "cursor-pointer w-24 h-48 m-1 rounded-l flex justify-center items-center m-3 text-black bg-gray-50 border-black border-2 drop-shadow-md",
|
||||
className := " hover:-translate-y-8 hover:scale-[1.05] hover:z-50 hover:drop-shadow-xl rounded-lg hover:bg-white ease-linear duration-200",
|
||||
className := "absolute origin-bottom start-1/2 rotate-[--custom-rotate] translate-x-[--custom-x-translate] translate-y-[--custom-y-translate]",
|
||||
styleAttr := dynamicCardStyle(index, totalCards),
|
||||
onClick.flatMap(_ => submitVote) --> Observer(resp => g.console.info(resp.toString())),
|
||||
div(
|
||||
className := "-rotate-45 text-3xl",
|
||||
value,
|
||||
)
|
||||
)
|
||||
}
|
||||
|
||||
private def myUnselectedCards(state: RoomStateView): List[(String, Int)] = {
|
||||
val allCards = state.allowedCards
|
||||
val cards = state.round match {
|
||||
case RoundStateView.Voting(myCard, _) =>
|
||||
allCards.filterNot(value => myCard.contains(value))
|
||||
case RoundStateView.Viewing(votes) =>
|
||||
allCards.filterNot(value => votes.toMap.get(state.me).contains(value))
|
||||
}
|
||||
|
||||
cards.zip(1 to state.allowedCards.size)
|
||||
}
|
||||
|
||||
}
|
||||
@@ -3,50 +3,49 @@ package industries.sunshine.planningpoker
|
||||
import scala.scalajs.js
|
||||
import com.raquo.laminar.api.L.{*, given}
|
||||
import industries.sunshine.planningpoker.common.Models.*
|
||||
import io.laminext.websocket.circe.WebSocket._
|
||||
import io.laminext.websocket.circe.webSocketReceiveBuilderSyntax
|
||||
|
||||
import scala.concurrent.duration._
|
||||
|
||||
/** Rendering of the Room state
|
||||
*/
|
||||
object RoomView {
|
||||
// TODO this will take in signal of the room observable
|
||||
// NOTE i guess "other players" would have to be in circle with 'me' as empty space in the bottom
|
||||
def renderRoom(roomStateSignal: Signal[RoomStateView]): Element = {
|
||||
// i want to number other players, for the star arrangement
|
||||
val otherPlayers = roomStateSignal.map { state =>
|
||||
state.players.filterNot(_.id == state.me).zipWithIndex
|
||||
}
|
||||
|
||||
div(
|
||||
className := "w-full h-full border-4 border-amber-900 flex flex-col",
|
||||
div(
|
||||
className := "flex flex-row",
|
||||
children <-- otherPlayers.split(_._1.id) { (id, initial, playerSignal) =>
|
||||
renderPlayer(playerSignal, roomStateSignal.map(_.allowedCards.size))
|
||||
}
|
||||
),
|
||||
TableView.renderTable(roomStateSignal)
|
||||
)
|
||||
}
|
||||
/** Rendering of the Room state central table with cards, player control UI and other players
|
||||
* description
|
||||
*
|
||||
* @param loggedIn
|
||||
* \- channel for signaling to the parent about dead websocket, i.e logged out state
|
||||
*/
|
||||
def renderRoom(loggedIn: Observer[Boolean]): Element = {
|
||||
|
||||
def renderPlayer(p: Signal[(Player, Int)], cardsAmount: Signal[Int]): Element = {
|
||||
val xOffsetStyleSignal = p.map(_._2)
|
||||
div(
|
||||
className := "w-20 h-20 border-2 border-amber-400 m-2 absolute",
|
||||
// left <-- p.map(tuple => ((1 + tuple._2) * 10000).toString()),
|
||||
styleAttr <-- p.map(tuple => s"left: ${(1 + tuple._2) * 100}px"),
|
||||
child.text <-- p.map(_._1.name),
|
||||
renderHandCardBacks(cardsAmount)
|
||||
)
|
||||
}
|
||||
|
||||
def renderHandCardBacks(amountSignal: Signal[Int]): Element = {
|
||||
def renderCard(index: Int): Element =
|
||||
div(
|
||||
className := "w-4 h-8 m-1 rounded bg-gray-600 text-yellow"
|
||||
val wsStream = io.laminext.websocket.WebSocket
|
||||
.path("/api/subscribe")
|
||||
.json[RoomStateView, Unit]
|
||||
.build(
|
||||
managed = true,
|
||||
autoReconnect = true,
|
||||
reconnectDelay = 500.millis,
|
||||
reconnectDelayOffline = 20.seconds,
|
||||
reconnectRetries = 3
|
||||
)
|
||||
|
||||
val roomStateSignal: Signal[RoomStateView] =
|
||||
wsStream.received.startWith(RoomStateView.empty)
|
||||
|
||||
val wsFinalDeathSignal = wsStream.closed.collect { case (_, false) => () }
|
||||
|
||||
div(
|
||||
className := "flex flex-row",
|
||||
children <-- amountSignal.map { amount => (1 to amount).map(renderCard) }
|
||||
className := "w-full h-full border-4 border-amber-900 flex flex-col relative",
|
||||
div(
|
||||
className := "absolute top-2 right-2",
|
||||
child.text <-- roomStateSignal.map(st => s"Room name: '${st.roomName}'"),
|
||||
),
|
||||
OtherPlayers.render(roomStateSignal),
|
||||
TableView.renderTable(roomStateSignal),
|
||||
OwnHandControls.render(roomStateSignal),
|
||||
wsStream.connect,
|
||||
wsFinalDeathSignal.map(_ => false) --> loggedIn
|
||||
)
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -0,0 +1,39 @@
|
||||
package industries.sunshine.planningpoker
|
||||
|
||||
import scala.scalajs.js
|
||||
import com.raquo.laminar.api.L.{*, given}
|
||||
import industries.sunshine.planningpoker.common.Models.RoundStateView
|
||||
import com.raquo.airstream.core.Signal
|
||||
import io.laminext.fetch.Fetch
|
||||
import scala.scalajs.js.Dynamic.{global => g}
|
||||
|
||||
import concurrent.ExecutionContext.Implicits.global
|
||||
|
||||
object TableControls {
|
||||
def render(roundSignal: Signal[RoundStateView]): Element = {
|
||||
div(
|
||||
child <-- roundSignal.map {
|
||||
case RoundStateView.Viewing(_) => newPollButton()
|
||||
case RoundStateView.Voting(_, _) => endPollButton()
|
||||
}
|
||||
)
|
||||
}
|
||||
|
||||
val commonButtonStyle = "border-2 border-black rounded-xl m-2 p-1"
|
||||
def endPollButton(): Element = button(
|
||||
className := commonButtonStyle,
|
||||
"end voting",
|
||||
onClick.flatMap(_ => Fetch.get("/api/end-voting").text) --> Observer(resp =>
|
||||
g.console.info(resp.toString())
|
||||
)
|
||||
)
|
||||
|
||||
def newPollButton(): Element = button(
|
||||
className := commonButtonStyle,
|
||||
"start next round",
|
||||
onClick.flatMap(_ => Fetch.get("/api/new-poll").text) --> Observer(resp =>
|
||||
g.console.info(resp.toString())
|
||||
)
|
||||
)
|
||||
|
||||
}
|
||||
@@ -11,64 +11,78 @@ object TableView {
|
||||
// but, can't have map to player, because overall state is required.
|
||||
// but can i split full state into several observables by that key? i think i should be able to
|
||||
// so, it's more efficient to share an observable, than to create multiple copies...
|
||||
def renderTable(roundSignal: Signal[RoomStateView]): Element = {
|
||||
def renderTable(roomStateSignal: Signal[RoomStateView]): Element = {
|
||||
val playerIdToCardTypeSignal =
|
||||
roundSignal
|
||||
.combineWith(Main.appStateSignal.map(_.myId))
|
||||
.map((state, myIdOpt) =>
|
||||
state.players.map(p => p.id -> getPlayerCardType(p.id, state.round, p.name, myIdOpt))
|
||||
roomStateSignal
|
||||
.map(state =>
|
||||
state.players.map(p => p.id -> getPlayerCardType(p.id, state.round, p.name, state.me))
|
||||
)
|
||||
|
||||
div(
|
||||
className := "w-full h-full border-2 border-amber-700 flex flex-row justify-center items-center bg-green-100",
|
||||
children <-- playerIdToCardTypeSignal.split(_._1) { (id, initial, cardTypeSignal) =>
|
||||
renderPlayerCard(cardTypeSignal.map(_._2))
|
||||
className := "w-full h-full flex flex-col justify-center items-center bg-green-100",
|
||||
div(
|
||||
className := "w-full flex flex-row justify-center items-center bg-green-100",
|
||||
children <-- playerIdToCardTypeSignal.split(_._1) { (id, initial, cardTypeSignal) =>
|
||||
renderPlayerCard(cardTypeSignal.map(_._2))
|
||||
}
|
||||
),
|
||||
child <-- roomStateSignal.map { state =>
|
||||
if (state.canCloseRound) TableControls.render(roomStateSignal.map(_.round)) else emptyNode
|
||||
}
|
||||
)
|
||||
}
|
||||
|
||||
trait CardState
|
||||
case class NoCard(name: String) extends CardState
|
||||
case object CardBack extends CardState
|
||||
case class Open(value: String) extends CardState
|
||||
case class CardBack(name: String) extends CardState
|
||||
case class Open(name: String, value: String) extends CardState
|
||||
|
||||
def getPlayerCardType(
|
||||
id: PlayerID,
|
||||
state: RoundState,
|
||||
state: RoundStateView,
|
||||
name: String,
|
||||
myId: Option[PlayerID]
|
||||
myId: PlayerID
|
||||
): CardState = {
|
||||
state match {
|
||||
case isOpen: RoundState.Voting =>
|
||||
if (myId.forall(_ == id)) {
|
||||
isOpen.myCard.fold(NoCard(name))(vote => Open(vote))
|
||||
} else isOpen.alreadyVoted.find(_.id == id).fold(NoCard(name))(_ => CardBack)
|
||||
case isClosed: RoundState.Viewing =>
|
||||
case isOpen: RoundStateView.Voting =>
|
||||
if (myId == id) {
|
||||
isOpen.myCard.fold(NoCard(name))(vote => Open(name, vote))
|
||||
} else isOpen.alreadyVoted.find(_ == id).fold(NoCard(name))(_ => CardBack(name))
|
||||
case isClosed: RoundStateView.Viewing =>
|
||||
isClosed.votes
|
||||
.find(_._1 == id)
|
||||
.fold {
|
||||
g.console.error(s"missing vote for player $name")
|
||||
Open("error")
|
||||
} { case (_, vote) => Open(vote) }
|
||||
NoCard(name)
|
||||
} { case (_, vote) => Open(name, vote) }
|
||||
}
|
||||
}
|
||||
|
||||
def renderPlayerCard(state: Signal[CardState]): Element = {
|
||||
val cardTypeStyle = state.map {
|
||||
case NoCard(_) => "bg-green-100 text-black border-2 border-black"
|
||||
case CardBack => "bg-green-500 border-4 border-green-700"
|
||||
case Open(_) => "text-black bg-gray-50 border-black border-2"
|
||||
case NoCard(_) => "bg-green-100 text-black border-2 border-black"
|
||||
case CardBack(_) => "bg-green-500 border-4 border-green-700"
|
||||
case Open(_, _) => "text-black bg-gray-50 border-black border-2"
|
||||
}
|
||||
|
||||
div(
|
||||
className := "w-20 h-40 m-1 rounded flex justify-center items-center m-3",
|
||||
className := "w-20 h-40 m-1 rounded m-3 relative",
|
||||
className <-- cardTypeStyle,
|
||||
// the diagonal card value \ place text
|
||||
div(
|
||||
className := "-rotate-45 text-xl",
|
||||
className := "-rotate-45 text-xl absolute top-1/2 left-1/2 transform -translate-x-1/2 -translate-y-1/2",
|
||||
child.text <-- state.map {
|
||||
case NoCard(name) => name
|
||||
case CardBack => ""
|
||||
case Open(vote) => vote
|
||||
case NoCard(name) => name
|
||||
case CardBack(name) => name
|
||||
case Open(_, vote) => vote
|
||||
}
|
||||
),
|
||||
// name under viewing the votes
|
||||
div(
|
||||
className := "text-xl absolute bottom-1 left-1/2 transform -translate-x-1/2",
|
||||
child.text <-- state.map {
|
||||
case Open(name, _) => name
|
||||
case _ => ""
|
||||
}
|
||||
)
|
||||
)
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
<meta charset="UTF-8" />
|
||||
<link rel="icon" type="image/svg+xml" href="/vite.svg" />
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
||||
<title>Vite App</title>
|
||||
<title>Planning Poker Kazbegi : unpretty prealpha version</title>
|
||||
</head>
|
||||
<body>
|
||||
<div id="app"></div>
|
||||
|
||||
4
package-lock.json
generated
4
package-lock.json
generated
@@ -1,11 +1,11 @@
|
||||
{
|
||||
"name": "planning-poker-grargh",
|
||||
"name": "planning-poker-kazbegi",
|
||||
"version": "0.0.0",
|
||||
"lockfileVersion": 3,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
"": {
|
||||
"name": "planning-poker-grargh",
|
||||
"name": "planning-poker-kazbegi",
|
||||
"version": "0.0.0",
|
||||
"devDependencies": {
|
||||
"@scala-js/vite-plugin-scalajs": "^1.0.0",
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
{
|
||||
"name": "planning-poker-grargh",
|
||||
"name": "planning-poker-kazbegi",
|
||||
"private": true,
|
||||
"version": "0.0.0",
|
||||
"type": "module",
|
||||
|
||||
Reference in New Issue
Block a user