Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
5d70550e8b |
@ -1,10 +1,3 @@
|
|||||||
- 0.3.1
|
|
||||||
* Change license to AGPL3 and copyright waived to public domain
|
|
||||||
- 0.3.0
|
|
||||||
* Implement on chainlib 0.3.0
|
|
||||||
- 0.2.12
|
|
||||||
* Breaking upgrade of chainlib.
|
|
||||||
* Implement generic block and tx.
|
|
||||||
- 0.2.11
|
- 0.2.11
|
||||||
* Upgrade shep to handle exception in filestore list
|
* Upgrade shep to handle exception in filestore list
|
||||||
- 0.2.10
|
- 0.2.10
|
||||||
|
141
LICENSE
141
LICENSE
@ -1,5 +1,5 @@
|
|||||||
GNU AFFERO GENERAL PUBLIC LICENSE
|
GNU GENERAL PUBLIC LICENSE
|
||||||
Version 3, 19 November 2007
|
Version 3, 29 June 2007
|
||||||
|
|
||||||
Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
|
Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
|
||||||
Everyone is permitted to copy and distribute verbatim copies
|
Everyone is permitted to copy and distribute verbatim copies
|
||||||
@ -7,15 +7,17 @@
|
|||||||
|
|
||||||
Preamble
|
Preamble
|
||||||
|
|
||||||
The GNU Affero General Public License is a free, copyleft license for
|
The GNU General Public License is a free, copyleft license for
|
||||||
software and other kinds of works, specifically designed to ensure
|
software and other kinds of works.
|
||||||
cooperation with the community in the case of network server software.
|
|
||||||
|
|
||||||
The licenses for most software and other practical works are designed
|
The licenses for most software and other practical works are designed
|
||||||
to take away your freedom to share and change the works. By contrast,
|
to take away your freedom to share and change the works. By contrast,
|
||||||
our General Public Licenses are intended to guarantee your freedom to
|
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
|
share and change all versions of a program--to make sure it remains free
|
||||||
software for all its users.
|
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
|
When we speak of free software, we are referring to freedom, not
|
||||||
price. Our General Public Licenses are designed to make sure that you
|
price. Our General Public Licenses are designed to make sure that you
|
||||||
@ -24,34 +26,44 @@ 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
|
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.
|
free programs, and that you know you can do these things.
|
||||||
|
|
||||||
Developers that use our General Public Licenses protect your rights
|
To protect your rights, we need to prevent others from denying you
|
||||||
with two steps: (1) assert copyright on the software, and (2) offer
|
these rights or asking you to surrender the rights. Therefore, you have
|
||||||
you this License which gives you legal permission to copy, distribute
|
certain responsibilities if you distribute copies of the software, or if
|
||||||
and/or modify the software.
|
you modify it: responsibilities to respect the freedom of others.
|
||||||
|
|
||||||
A secondary benefit of defending all users' freedom is that
|
For example, if you distribute copies of such a program, whether
|
||||||
improvements made in alternate versions of the program, if they
|
gratis or for a fee, you must pass on to the recipients the same
|
||||||
receive widespread use, become available for other developers to
|
freedoms that you received. You must make sure that they, too, receive
|
||||||
incorporate. Many developers of free software are heartened and
|
or can get the source code. And you must show them these terms so they
|
||||||
encouraged by the resulting cooperation. However, in the case of
|
know their rights.
|
||||||
software used on network servers, this result may fail to come about.
|
|
||||||
The GNU General Public License permits making a modified version and
|
|
||||||
letting the public access it on a server without ever releasing its
|
|
||||||
source code to the public.
|
|
||||||
|
|
||||||
The GNU Affero General Public License is designed specifically to
|
Developers that use the GNU GPL protect your rights with two steps:
|
||||||
ensure that, in such cases, the modified source code becomes available
|
(1) assert copyright on the software, and (2) offer you this License
|
||||||
to the community. It requires the operator of a network server to
|
giving you legal permission to copy, distribute and/or modify it.
|
||||||
provide the source code of the modified version running there to the
|
|
||||||
users of that server. Therefore, public use of a modified version, on
|
|
||||||
a publicly accessible server, gives the public access to the source
|
|
||||||
code of the modified version.
|
|
||||||
|
|
||||||
An older license, called the Affero General Public License and
|
For the developers' and authors' protection, the GPL clearly explains
|
||||||
published by Affero, was designed to accomplish similar goals. This is
|
that there is no warranty for this free software. For both users' and
|
||||||
a different license, not a version of the Affero GPL, but Affero has
|
authors' sake, the GPL requires that modified versions be marked as
|
||||||
released a new version of the Affero GPL which permits relicensing under
|
changed, so that their problems will not be attributed erroneously to
|
||||||
this license.
|
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
|
The precise terms and conditions for copying, distribution and
|
||||||
modification follow.
|
modification follow.
|
||||||
@ -60,7 +72,7 @@ modification follow.
|
|||||||
|
|
||||||
0. Definitions.
|
0. Definitions.
|
||||||
|
|
||||||
"This License" refers to version 3 of the GNU Affero General Public License.
|
"This License" refers to version 3 of the GNU General Public License.
|
||||||
|
|
||||||
"Copyright" also means copyright-like laws that apply to other kinds of
|
"Copyright" also means copyright-like laws that apply to other kinds of
|
||||||
works, such as semiconductor masks.
|
works, such as semiconductor masks.
|
||||||
@ -537,45 +549,35 @@ 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
|
the Program, the only way you could satisfy both those terms and this
|
||||||
License would be to refrain entirely from conveying the Program.
|
License would be to refrain entirely from conveying the Program.
|
||||||
|
|
||||||
13. Remote Network Interaction; Use with the GNU General Public License.
|
13. Use with the GNU Affero General Public License.
|
||||||
|
|
||||||
Notwithstanding any other provision of this License, if you modify the
|
|
||||||
Program, your modified version must prominently offer all users
|
|
||||||
interacting with it remotely through a computer network (if your version
|
|
||||||
supports such interaction) an opportunity to receive the Corresponding
|
|
||||||
Source of your version by providing access to the Corresponding Source
|
|
||||||
from a network server at no charge, through some standard or customary
|
|
||||||
means of facilitating copying of software. This Corresponding Source
|
|
||||||
shall include the Corresponding Source for any work covered by version 3
|
|
||||||
of the GNU General Public License that is incorporated pursuant to the
|
|
||||||
following paragraph.
|
|
||||||
|
|
||||||
Notwithstanding any other provision of this License, you have
|
Notwithstanding any other provision of this License, you have
|
||||||
permission to link or combine any covered work with a work licensed
|
permission to link or combine any covered work with a work licensed
|
||||||
under version 3 of the GNU General Public License into a single
|
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
|
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,
|
License will continue to apply to the part which is the covered work,
|
||||||
but the work with which it is combined will remain governed by version
|
but the special requirements of the GNU Affero General Public License,
|
||||||
3 of the GNU General Public License.
|
section 13, concerning interaction through a network will apply to the
|
||||||
|
combination as such.
|
||||||
|
|
||||||
14. Revised Versions of this License.
|
14. Revised Versions of this License.
|
||||||
|
|
||||||
The Free Software Foundation may publish revised and/or new versions of
|
The Free Software Foundation may publish revised and/or new versions of
|
||||||
the GNU Affero General Public License from time to time. Such new versions
|
the GNU General Public License from time to time. Such new versions will
|
||||||
will be similar in spirit to the present version, but may differ in detail to
|
be similar in spirit to the present version, but may differ in detail to
|
||||||
address new problems or concerns.
|
address new problems or concerns.
|
||||||
|
|
||||||
Each version is given a distinguishing version number. If the
|
Each version is given a distinguishing version number. If the
|
||||||
Program specifies that a certain numbered version of the GNU Affero General
|
Program specifies that a certain numbered version of the GNU General
|
||||||
Public License "or any later version" applies to it, you have the
|
Public License "or any later version" applies to it, you have the
|
||||||
option of following the terms and conditions either of that numbered
|
option of following the terms and conditions either of that numbered
|
||||||
version or of any later version published by the Free Software
|
version or of any later version published by the Free Software
|
||||||
Foundation. If the Program does not specify a version number of the
|
Foundation. If the Program does not specify a version number of the
|
||||||
GNU Affero General Public License, you may choose any version ever published
|
GNU General Public License, you may choose any version ever published
|
||||||
by the Free Software Foundation.
|
by the Free Software Foundation.
|
||||||
|
|
||||||
If the Program specifies that a proxy can decide which future
|
If the Program specifies that a proxy can decide which future
|
||||||
versions of the GNU Affero General Public License can be used, that proxy's
|
versions of the GNU General Public License can be used, that proxy's
|
||||||
public statement of acceptance of a version permanently authorizes you
|
public statement of acceptance of a version permanently authorizes you
|
||||||
to choose that version for the Program.
|
to choose that version for the Program.
|
||||||
|
|
||||||
@ -633,29 +635,40 @@ the "copyright" line and a pointer to where the full notice is found.
|
|||||||
Copyright (C) <year> <name of author>
|
Copyright (C) <year> <name of author>
|
||||||
|
|
||||||
This program is free software: you can redistribute it and/or modify
|
This program is free software: you can redistribute it and/or modify
|
||||||
it under the terms of the GNU Affero General Public License as published by
|
it under the terms of the GNU General Public License as published by
|
||||||
the Free Software Foundation, either version 3 of the License, or
|
the Free Software Foundation, either version 3 of the License, or
|
||||||
(at your option) any later version.
|
(at your option) any later version.
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
This program is distributed in the hope that it will be useful,
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
GNU Affero General Public License for more details.
|
GNU General Public License for more details.
|
||||||
|
|
||||||
You should have received a copy of the GNU Affero General Public License
|
You should have received a copy of the GNU General Public License
|
||||||
along with this program. If not, see <https://www.gnu.org/licenses/>.
|
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.
|
Also add information on how to contact you by electronic and paper mail.
|
||||||
|
|
||||||
If your software can interact with users remotely through a computer
|
If the program does terminal interaction, make it output a short
|
||||||
network, you should also make sure that it provides a way for users to
|
notice like this when it starts in an interactive mode:
|
||||||
get its source. For example, if your program is a web application, its
|
|
||||||
interface could display a "Source" link that leads users to an archive
|
<program> Copyright (C) <year> <name of author>
|
||||||
of the code. There are many ways you could offer source, and different
|
This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
|
||||||
solutions will be better for different programs; see section 13 for the
|
This is free software, and you are welcome to redistribute it
|
||||||
specific requirements.
|
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,
|
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.
|
if any, to sign a "copyright disclaimer" for the program, if necessary.
|
||||||
For more information on this, and how to apply and follow the GNU AGPL, see
|
For more information on this, and how to apply and follow the GNU GPL, see
|
||||||
<https://www.gnu.org/licenses/>.
|
<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>.
|
||||||
|
@ -1 +1 @@
|
|||||||
include *requirements.txt LICENSE WAIVER WAIVER.asc CHANGELOG chaind/data/config/* chaind/data/config/syncer/*
|
include *requirements.txt chaind/data/config/* chaind/data/config/syncer/*
|
||||||
|
17
WAIVER
17
WAIVER
@ -1,17 +0,0 @@
|
|||||||
# Copyright waiver for the python package "chaind"
|
|
||||||
|
|
||||||
I dedicate any and all copyright interest in this software to the
|
|
||||||
public domain. I make this dedication for the benefit of the public at
|
|
||||||
large and to the detriment of my heirs and successors. I intend this
|
|
||||||
dedication to be an overt act of relinquishment in perpetuity of all
|
|
||||||
present and future rights to this software under copyright law.
|
|
||||||
|
|
||||||
To the best of my knowledge and belief, my contributions are either
|
|
||||||
originally authored by me or are derived from prior works which I have
|
|
||||||
verified are also in the public domain and are not subject to claims
|
|
||||||
of copyright by other parties.
|
|
||||||
|
|
||||||
To the best of my knowledge and belief, no individual, business,
|
|
||||||
organization, government, or other entity has any copyright interest
|
|
||||||
in my contributions, and I affirm that I will not make contributions
|
|
||||||
that are otherwise encumbered.
|
|
28
WAIVER.asc
28
WAIVER.asc
@ -1,28 +0,0 @@
|
|||||||
-----BEGIN PGP MESSAGE-----
|
|
||||||
|
|
||||||
owGVU2tQVFUcX0BkvY6jTQFjBJ4FA2tWgl6YyZLD8BIFiYeQOXT37lnuifviPnbd
|
|
||||||
AkIweRnhCAbpEDBWyHNsoJkm0QYICpTZScIv4IAPHlEqZTU0gp27C2r1qQ87s/ee
|
|
||||||
///3PLdynZtG66L7Yfrrkp7Po13a3Djj6n0749KiXqdybl8KAJG8YBNRFi0DK4ks
|
|
||||||
UARmXgQyDYFgk2meAwJJZZNZEPhTNIk4kz9BxAETNCGKlCEgORv+mQDJMIB6AIQ4
|
|
||||||
GYpQUv9gJCQBiTfLVlKEQOZVaEJQjAyigIlnMWQwiAMsmQ2do8vQCDOvCDFCDpqR
|
|
||||||
DHizU5dzmZQJhhSzoIPfiYuXZRGxkHPMsjZAQyRKjgFJoSgoSbwoqXSqQHULExKP
|
|
||||||
EGIUo4oHeJyDDEjKgSNCBnE5CpJoBzL2JEBRgLKCZJt6jr0TArarHqpUZkVWsFVH
|
|
||||||
FJJT2aMRKJwJh/wwLIa0BhNECr9sVVrRns3xVgaalg0asQho1qsHFM9hl0ZFlYzN
|
|
||||||
YUiI8K5I8BgQcVgO7kTB3YkQ79kACwEOUp3DxLhhrFDkWSCICL+28mK2BKw0omic
|
|
||||||
C01aIIG9IzPCY+oKyUi8s8YHwTtbc9aOJzhexuka34Y4LWyWYkjESgT28NAiFsGr
|
|
||||||
CvFdEmUEpf/hl1PZTciCTArJ6IFRkRCHe9Rjs1kkh95xFKcHWWpjnNqPXjXrZMNP
|
|
||||||
akU0KTnu6X/vJ4Ft/DtQvYM+DpBmMxJZLJKU8ZMV4QuuOnVc1H8sEI4RNQkHqxVJ
|
|
||||||
uBCOUlgj5jAFE6WuL6zSuGg1vl66VdrAXxqErX7F/deKk1a+SHdX9TvUEGs2rLz5
|
|
||||||
8sT6++kJ1+OPLe74jGlMjj5M+Obp7L+3921dXaWZ+Nk7sN2jubh1Ls/65kD5YCIb
|
|
||||||
USRMCEc2kImvFBYacgOT6wa1jQHD9ry5xYqhvu+fGR5dd4jtqk+3HCBTH6ub3p17
|
|
||||||
cMvuK4XdMaGV8wl0WpR7fG3DpwtTZ5VWu2z5KPPdn5gztye3HzxRWlrt1x4WuQf2
|
|
||||||
pUy2E6H+sSdv2OHxXV0ex9tCaWlpku5cmz9U00nQixUdcWlzpfaRJ+WWWo/W87MX
|
|
||||||
N22M6j2WEX0+vSCiXvx4gyE/dn/NtpHMsjtrqmPGerq2B53y/OTH2VsGw+jpirVF
|
|
||||||
C6476QmXHZqae16VS2dto/xTTQfSzK9e0Dz3wRSXOfINsfelsj/aky2DxTfOlX8X
|
|
||||||
YprouzCli6mN+O3Zy8arh2D9E/d3hRf4Td1L6Viafc0eftJt/nSnT0vWW3HMuSt3
|
|
||||||
iyuo8Nw/xzx9P2wzzle5N5fHdGi/8Aj71hIemxLi4v3r0eTJJK/h1CbLzaKBW2Tr
|
|
||||||
V4szM1pD0+XenIik2fUNOqH5TC/dFTXSX7kxhKpyObLp5Yp9wYk+qfnTGd3XDFzH
|
|
||||||
4Za/xsf33DW835bSe9Q7drNWDHtxf+1A/RsLngWFmrSJgchTnmU943XRNwu6rzam
|
|
||||||
PG5IzEhYuFMyu6Vy296gGh82ngvo181cD4p+enNDbmGJUG26NDT8fMbF98b+Bg==
|
|
||||||
=vZcN
|
|
||||||
-----END PGP MESSAGE-----
|
|
12
chaind/cli/__init__.py
Normal file
12
chaind/cli/__init__.py
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
# standard imports
|
||||||
|
import os
|
||||||
|
|
||||||
|
# local imports
|
||||||
|
from .base import *
|
||||||
|
from .arg import process_flags
|
||||||
|
from .config import process_config
|
||||||
|
|
||||||
|
|
||||||
|
__script_dir = os.path.dirname(os.path.realpath(__file__))
|
||||||
|
data_dir = os.path.join(os.path.dirname(__script_dir), 'data')
|
||||||
|
config_dir = os.path.join(data_dir, 'config')
|
@ -1,19 +1,17 @@
|
|||||||
def apply_flag(flag):
|
# local imports
|
||||||
flag.add('session')
|
from .base import ChaindFlag
|
||||||
flag.add('dispatch')
|
|
||||||
flag.add('socket')
|
|
||||||
flag.add('socket_client')
|
|
||||||
flag.add('token')
|
|
||||||
|
|
||||||
flag.alias('chaind_base', 'session')
|
def process_flags(argparser, flags):
|
||||||
flag.alias('chaind_socket_client', 'session', 'socket', 'socket_client')
|
if flags & ChaindFlag.SESSION > 0:
|
||||||
|
argparser.add_argument('--session-id', dest='session_id', type=str, help='Session to store state and data under')
|
||||||
|
argparser.add_argument('--runtime-dir', dest='runtime_dir', type=str, help='Directory to store volatile data')
|
||||||
|
argparser.add_argument('--data-dir', dest='data_dir', type=str, help='Directory to store persistent data')
|
||||||
|
|
||||||
return flag
|
if flags & ChaindFlag.SOCKET > 0:
|
||||||
|
argparser.add_argument('--socket-path', dest='socket', type=str, help='UNIX socket path')
|
||||||
|
|
||||||
|
if flags & ChaindFlag.SOCKET_CLIENT > 0:
|
||||||
|
argparser.add_argument('--send-socket', dest='socket_send', action='store_true', help='Send to UNIX socket')
|
||||||
|
|
||||||
def apply_arg(arg):
|
if flags & ChaindFlag.TOKEN > 0:
|
||||||
arg.add_long('session-id', 'session', help='Session to store state and data under')
|
argparser.add_argument('--token-module', dest='token_module', type=str, help='Python module path to resolve tokens from identifiers')
|
||||||
arg.add_long('socket-path', 'socket', help='UNIX socket path')
|
|
||||||
arg.add_long('send-socket', 'socket_client', typ=bool, help='Send to UNIX socket')
|
|
||||||
arg.add_long('token-module', 'token', help='Python module path to resolve tokens from identifiers')
|
|
||||||
return arg
|
|
||||||
|
@ -1,19 +1,23 @@
|
|||||||
def process_config(config, arg, args, flags):
|
# external imports
|
||||||
args_override = {}
|
from chaind.cli import ChaindFlag
|
||||||
if arg.match('session', flags):
|
|
||||||
args_override['SESSION_ID'] = getattr(args, 'session_id')
|
|
||||||
args_override['SESSION_RUNTIME_DIR'] = getattr(args, 'runtime_path')
|
|
||||||
args_override['SESSION_DATA_DIR'] = getattr(args, 'state_path')
|
|
||||||
|
|
||||||
if arg.match('socket', flags):
|
|
||||||
|
def process_config(config, args, flags):
|
||||||
|
args_override = {}
|
||||||
|
if flags & ChaindFlag.SESSION:
|
||||||
|
args_override['SESSION_ID'] = getattr(args, 'session_id')
|
||||||
|
args_override['SESSION_RUNTIME_DIR'] = getattr(args, 'runtime_dir')
|
||||||
|
args_override['SESSION_DATA_DIR'] = getattr(args, 'data_dir')
|
||||||
|
|
||||||
|
if flags & ChaindFlag.SOCKET:
|
||||||
args_override['SESSION_SOCKET_PATH'] = getattr(args, 'socket')
|
args_override['SESSION_SOCKET_PATH'] = getattr(args, 'socket')
|
||||||
|
|
||||||
if arg.match('token', flags):
|
if flags & ChaindFlag.TOKEN:
|
||||||
args_override['TOKEN_MODULE'] = getattr(args, 'token_module')
|
args_override['TOKEN_MODULE'] = getattr(args, 'token_module')
|
||||||
|
|
||||||
config.dict_override(args_override, 'local cli args')
|
config.dict_override(args_override, 'local cli args')
|
||||||
|
|
||||||
if arg.match('socket_client', flags):
|
if flags & ChaindFlag.SOCKET_CLIENT:
|
||||||
config.add(getattr(args, 'send_socket'), '_SOCKET_SEND', False)
|
config.add(getattr(args, 'socket_send'), '_SOCKET_SEND', False)
|
||||||
|
|
||||||
return config
|
return config
|
||||||
|
@ -1,6 +0,0 @@
|
|||||||
# standard imports
|
|
||||||
import os
|
|
||||||
|
|
||||||
|
|
||||||
data_dir = os.path.realpath(os.path.dirname(__file__))
|
|
||||||
config_dir = os.path.join(data_dir, 'config')
|
|
@ -1,5 +1,5 @@
|
|||||||
[session]
|
[session]
|
||||||
socket_path =
|
socket_path =
|
||||||
runtime_path =
|
runtime_dir =
|
||||||
id =
|
id =
|
||||||
data_path =
|
data_dir =
|
||||||
|
@ -115,7 +115,7 @@ class StateFilter(SyncFilter):
|
|||||||
queue_adapter = self.__get_adapter(block, force_reload=True)
|
queue_adapter = self.__get_adapter(block, force_reload=True)
|
||||||
continue
|
continue
|
||||||
|
|
||||||
logg.info('filter registered {} for {} in {}'.format(tx.status_name, tx.hash, block))
|
logg.info('filter registered {} for {} in {}'.format(tx.status.name, tx.hash, block))
|
||||||
|
|
||||||
if self.throttler != None:
|
if self.throttler != None:
|
||||||
self.throttler.dec(tx.hash)
|
self.throttler.dec(tx.hash)
|
||||||
|
@ -4,31 +4,27 @@ import os
|
|||||||
import uuid
|
import uuid
|
||||||
|
|
||||||
# external imports
|
# external imports
|
||||||
from chainlib.settings import ChainSettings
|
from chainsyncer.settings import ChainsyncerSettings
|
||||||
from chainqueue.settings import *
|
from chainqueue.settings import ChainqueueSettings
|
||||||
|
|
||||||
logg = logging.getLogger(__name__)
|
logg = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
class ChaindSettings(ChainSettings):
|
class ChaindSettings(ChainsyncerSettings, ChainqueueSettings):
|
||||||
|
|
||||||
def __init__(settings, include_sync=False, include_queue=False):
|
def __init__(self, include_sync=False, include_queue=False):
|
||||||
super(ChaindSettings, settings).__init__()
|
super(ChaindSettings, self).__init__()
|
||||||
settings.include_sync = include_sync
|
self.include_sync = include_sync
|
||||||
settings.include_queue = include_queue
|
self.include_queue = include_queue
|
||||||
|
|
||||||
|
|
||||||
def dir_for(self, k):
|
def process_session(self, config):
|
||||||
return os.path.join(self.o['SESSION_PATH'], k)
|
|
||||||
|
|
||||||
|
|
||||||
def process_session(settings, config):
|
|
||||||
session_id = config.get('SESSION_ID')
|
session_id = config.get('SESSION_ID')
|
||||||
|
|
||||||
base_dir = os.getcwd()
|
base_dir = os.getcwd()
|
||||||
data_dir = config.get('SESSION_DATA_PATH')
|
data_dir = config.get('SESSION_DATA_DIR')
|
||||||
if data_dir == None:
|
if data_dir == None:
|
||||||
data_dir = os.path.join(base_dir, '.chaind', 'chaind', settings.get('CHAIND_BACKEND'))
|
data_dir = os.path.join(base_dir, '.chaind', 'chaind', self.o.get('CHAIND_BACKEND'))
|
||||||
data_engine_dir = os.path.join(data_dir, config.get('CHAIND_ENGINE'))
|
data_engine_dir = os.path.join(data_dir, config.get('CHAIND_ENGINE'))
|
||||||
os.makedirs(data_engine_dir, exist_ok=True)
|
os.makedirs(data_engine_dir, exist_ok=True)
|
||||||
|
|
||||||
@ -48,79 +44,82 @@ def process_session(settings, config):
|
|||||||
session_id = str(uuid.uuid4())
|
session_id = str(uuid.uuid4())
|
||||||
make_default = True
|
make_default = True
|
||||||
|
|
||||||
chain_spec = settings.get('CHAIN_SPEC')
|
|
||||||
network_id_str = str(chain_spec.network_id())
|
|
||||||
# create the session persistent dir
|
# create the session persistent dir
|
||||||
session_path = os.path.join(
|
session_dir = os.path.join(data_engine_dir, session_id)
|
||||||
data_engine_dir,
|
|
||||||
chain_spec.arch(),
|
|
||||||
chain_spec.fork(),
|
|
||||||
network_id_str,
|
|
||||||
session_id,
|
|
||||||
)
|
|
||||||
if make_default:
|
if make_default:
|
||||||
fp = os.path.join(data_engine_dir, 'default')
|
fp = os.path.join(data_engine_dir, 'default')
|
||||||
os.symlink(session_path, fp)
|
os.symlink(session_dir, fp)
|
||||||
|
|
||||||
data_path = session_path
|
#data_dir = os.path.join(session_dir, config.get('CHAIND_COMPONENT'))
|
||||||
os.makedirs(data_path, exist_ok=True)
|
data_dir = session_dir
|
||||||
|
os.makedirs(data_dir, exist_ok=True)
|
||||||
|
|
||||||
# create volatile dir
|
# create volatile dir
|
||||||
uid = os.getuid()
|
uid = os.getuid()
|
||||||
runtime_path = config.get('SESSION_RUNTIME_PATH')
|
runtime_dir = config.get('SESSION_RUNTIME_DIR')
|
||||||
if runtime_path == None:
|
if runtime_dir == None:
|
||||||
runtime_path = os.path.join('/run', 'user', str(uid), 'chaind', settings.get('CHAIND_BACKEND'))
|
runtime_dir = os.path.join('/run', 'user', str(uid), 'chaind', self.o.get('CHAIND_BACKEND'))
|
||||||
runtime_path = os.path.join(
|
#runtime_dir = os.path.join(runtime_dir, config.get('CHAIND_ENGINE'), session_id, config.get('CHAIND_COMPONENT'))
|
||||||
runtime_path,
|
runtime_dir = os.path.join(runtime_dir, config.get('CHAIND_ENGINE'), session_id)
|
||||||
config.get('CHAIND_ENGINE'),
|
os.makedirs(runtime_dir, exist_ok=True)
|
||||||
chain_spec.arch(),
|
|
||||||
chain_spec.fork(),
|
|
||||||
str(chain_spec.network_id()),
|
|
||||||
session_id,
|
|
||||||
)
|
|
||||||
os.makedirs(runtime_path, exist_ok=True)
|
|
||||||
|
|
||||||
settings.set('SESSION_RUNTIME_PATH', runtime_path)
|
self.o['SESSION_RUNTIME_DIR'] = runtime_dir
|
||||||
settings.set('SESSION_PATH', session_path)
|
self.o['SESSION_DIR'] = session_dir
|
||||||
settings.set('SESSION_DATA_PATH', data_path)
|
self.o['SESSION_DATA_DIR'] = data_dir
|
||||||
settings.set('SESSION_ID', session_id)
|
self.o['SESSION_ID'] = session_id
|
||||||
|
|
||||||
return settings
|
|
||||||
|
|
||||||
|
|
||||||
def process_socket(settings, config):
|
def process_sync_interface(self, config):
|
||||||
|
raise NotImplementedError('no sync interface implementation defined')
|
||||||
|
|
||||||
|
|
||||||
|
def process_sync(self, config):
|
||||||
|
self.process_sync_interface(config)
|
||||||
|
self.process_sync_range(config)
|
||||||
|
|
||||||
|
|
||||||
|
def process_socket(self, config):
|
||||||
socket_path = config.get('SESSION_SOCKET_PATH')
|
socket_path = config.get('SESSION_SOCKET_PATH')
|
||||||
if socket_path == None:
|
if socket_path == None:
|
||||||
socket_path = os.path.join(settings.get('SESSION_RUNTIME_PATH'), 'chaind.sock')
|
socket_path = os.path.join(self.o['SESSION_RUNTIME_DIR'], 'chaind.sock')
|
||||||
settings.set('SESSION_SOCKET_PATH', socket_path)
|
self.o['SESSION_SOCKET_PATH'] = socket_path
|
||||||
return settings
|
|
||||||
|
|
||||||
|
|
||||||
def process_dispatch(settings, config):
|
def process_dispatch(self, config):
|
||||||
settings.set('SESSION_DISPATCH_DELAY', 0.01)
|
self.o['SESSION_DISPATCH_DELAY'] = 0.01
|
||||||
return settings
|
|
||||||
|
|
||||||
|
|
||||||
def process_token(settings, config):
|
def process_token(self, config):
|
||||||
settings.set('TOKEN_MODULE', config.get('TOKEN_MODULE'))
|
self.o['TOKEN_MODULE'] = config.get('TOKEN_MODULE')
|
||||||
return settings
|
|
||||||
|
|
||||||
|
|
||||||
def process_backend(settings, config):
|
def process_backend(self, config):
|
||||||
settings.set('CHAIND_BACKEND', config.get('STATE_BACKEND')) #backend)
|
if self.include_sync and self.include_queue:
|
||||||
return settings
|
if self.o['QUEUE_BACKEND'] != self.o['SYNCER_BACKEND']:
|
||||||
|
raise ValueError('queue and syncer backends must match. queue "{}" != syncer "{}"'.format(self.o['QUEUE_BACKEND'], self.o['SYNCER_BACKEND']))
|
||||||
|
self.o['CHAIND_BACKEND'] = self.o['SYNCER_BACKEND']
|
||||||
|
elif self.include_sync:
|
||||||
|
self.o['CHAIND_BACKEND'] = self.o['SYNCER_BACKEND']
|
||||||
|
elif self.include_queue:
|
||||||
|
self.o['CHAIND_BACKEND'] = self.o['QUEUE_BACKEND']
|
||||||
|
else:
|
||||||
|
raise ValueError('at least one backend must be set')
|
||||||
|
|
||||||
|
|
||||||
def process_queue(settings, config):
|
def process(self, config):
|
||||||
if config.get('STATE_PATH') == None:
|
super(ChaindSettings, self).process(config)
|
||||||
queue_state_dir = settings.dir_for('queue')
|
if self.include_sync:
|
||||||
config.add(queue_state_dir, 'STATE_PATH', False)
|
self.process_sync(config)
|
||||||
logg.debug('setting queue state path {}'.format(queue_state_dir))
|
self.process_sync_backend(config)
|
||||||
|
if self.include_queue:
|
||||||
|
self.process_queue_backend(config)
|
||||||
|
self.process_dispatch(config)
|
||||||
|
self.process_token(config)
|
||||||
|
|
||||||
settings = process_queue_tx(settings, config)
|
self.process_backend(config)
|
||||||
settings = process_queue_paths(settings, config)
|
self.process_session(config)
|
||||||
if config.get('STATE_BACKEND') == 'fs':
|
self.process_socket(config)
|
||||||
settings = process_queue_backend_fs(settings, config)
|
|
||||||
settings = process_queue_store(settings, config)
|
|
||||||
|
|
||||||
return settings
|
|
||||||
|
def dir_for(self, k):
|
||||||
|
return os.path.join(self.o['SESSION_DIR'], k)
|
||||||
|
@ -7,11 +7,6 @@ from chainqueue.cache import CacheTokenTx
|
|||||||
from chainlib.status import Status as TxStatus
|
from chainlib.status import Status as TxStatus
|
||||||
from chainlib.chain import ChainSpec
|
from chainlib.chain import ChainSpec
|
||||||
from chainlib.error import RPCException
|
from chainlib.error import RPCException
|
||||||
from chainlib.tx import (
|
|
||||||
Tx,
|
|
||||||
TxResult,
|
|
||||||
)
|
|
||||||
from chainlib.block import Block
|
|
||||||
|
|
||||||
|
|
||||||
class MockCacheAdapter(CacheTokenTx):
|
class MockCacheAdapter(CacheTokenTx):
|
||||||
@ -39,17 +34,14 @@ class MockDispatcher:
|
|||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
class MockTx(Tx):
|
class MockTx:
|
||||||
|
|
||||||
def __init__(self, tx_hash, status=TxStatus.SUCCESS):
|
def __init__(self, tx_hash, status=TxStatus.SUCCESS):
|
||||||
result = TxResult()
|
self.hash = tx_hash
|
||||||
result.status = status
|
self.status = status
|
||||||
super(MockTx, self).__init__(result=result)
|
|
||||||
self.set_hash(tx_hash)
|
|
||||||
|
|
||||||
|
|
||||||
class MockBlock(Block):
|
class MockBlock:
|
||||||
|
|
||||||
def __init__(self, number):
|
def __init__(self, number):
|
||||||
super(MockBlock, self).__init__()
|
|
||||||
self.number = number
|
self.number = number
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
chainlib~=0.3.0
|
chainlib~=0.1.2
|
||||||
chainqueue~=0.2.0
|
chainqueue~=0.1.15
|
||||||
chainsyncer~=0.5.0
|
chainsyncer~=0.4.7
|
||||||
confini~=0.6.1
|
confini~=0.6.0
|
||||||
funga~=0.5.2
|
funga~=0.5.2
|
||||||
pyxdg~=0.26
|
pyxdg~=0.26
|
||||||
|
11
setup.cfg
11
setup.cfg
@ -1,24 +1,24 @@
|
|||||||
[metadata]
|
[metadata]
|
||||||
name = chaind
|
name = chaind
|
||||||
version = 0.3.2
|
version = 0.2.11
|
||||||
description = Base package for chain queue service
|
description = Base package for chain queue service
|
||||||
author = Louis Holbrook
|
author = Louis Holbrook
|
||||||
author_email = dev@holbrook.no
|
author_email = dev@holbrook.no
|
||||||
url = https://git.defalsify.org/chaind.eth
|
url = https://gitlab.com/chaintool/chaind
|
||||||
keywords =
|
keywords =
|
||||||
blockchain
|
blockchain
|
||||||
cryptocurrency
|
cryptocurrency
|
||||||
dlt
|
p2p
|
||||||
classifiers =
|
classifiers =
|
||||||
Programming Language :: Python :: 3
|
Programming Language :: Python :: 3
|
||||||
Operating System :: OS Independent
|
Operating System :: OS Independent
|
||||||
Development Status :: 3 - Alpha
|
Development Status :: 3 - Alpha
|
||||||
Environment :: Console
|
Environment :: Console
|
||||||
Intended Audience :: Developers
|
Intended Audience :: Developers
|
||||||
License :: OSI Approved :: GNU Affero General Public License v3 or later (AGPLv3+)
|
License :: OSI Approved :: GNU General Public License v3 or later (GPLv3+)
|
||||||
Topic :: Internet
|
Topic :: Internet
|
||||||
# Topic :: Blockchain :: EVM
|
# Topic :: Blockchain :: EVM
|
||||||
license = OSI Approved :: GNU Affero General Public License v3 or later (AGPLv3+)
|
license = GPL3
|
||||||
licence_files =
|
licence_files =
|
||||||
LICENSE
|
LICENSE
|
||||||
|
|
||||||
@ -30,7 +30,6 @@ packages =
|
|||||||
# chaind.runnable
|
# chaind.runnable
|
||||||
chaind.adapters
|
chaind.adapters
|
||||||
chaind.unittest
|
chaind.unittest
|
||||||
chaind.data
|
|
||||||
chaind.cli
|
chaind.cli
|
||||||
|
|
||||||
#[options.entry_points]
|
#[options.entry_points]
|
||||||
|
Loading…
Reference in New Issue
Block a user