Mirroristas/planetmint
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint.git synced 2025-11-25 06:55:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

first mongodb to tarantool transitions

Browse Source
This commit is contained in:
Jürgen Eckel 2022-02-25 13:21:02 +01:00
parent 9e3358889a
commit 3d39cae603
4 changed files with 15 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
planetmint/backend/connection_tarantool.py
View File

@ -54,13 +54,15 @@ class TarantoolDB:
commands = self.__read_commands(file_path=f_path)
run(commands=commands, config=config)
def connect(host: str = None, port: int = None, username: str = "admin", password: str = "pass",
backend: str = None, reset_database: bool = False):
backend: str = None, reset_database: bool = False, name=None, max_tries=None,
connection_timeout=None, replicaset=None, ssl=None, login: str = "admin", ctl_config=None,
ca_cert=None, certfile=None, keyfile=None, keyfile_passphrase=None, reconnect_delay=None,
crlfile=None, connect_now=True, encoding=None):
backend = backend or get_planetmint_config_value_or_key_error('backend') # TODO Rewrite Configs
host = host or get_planetmint_config_value_or_key_error('host')
port = port or get_planetmint_config_value_or_key_error('port')
username = username or get_planetmint_config_value('login')
username = username or login or get_planetmint_config_value('login')
password = password or get_planetmint_config_value('password')
try: # Here we get class using getattr function

3
planetmint/backend/schema.py
View File

@ -9,7 +9,8 @@ from functools import singledispatch
import logging
import planetmint
from planetmint.backend.connection import connect
from planetmint.backend.connection import connect as connect_mongo
from planetmint.backend.connection_tarantool import connect
from planetmint.common.exceptions import ValidationError
from planetmint.common.utils import validate_all_values_for_key_in_obj, validate_all_values_for_key_in_list

10
planetmint/commands/planetmint.py
View File

@ -26,7 +26,7 @@ import planetmint
from planetmint import (backend, ValidatorElection,
Planetmint)
from planetmint.backend import schema
from planetmint.backend.tarantool import tarantool
from planetmint.backend import tarantool
from planetmint.commands import utils
from planetmint.commands.utils import (configure_planetmint,
input_on_stderr)
@ -318,12 +318,12 @@ def create_parser():
help='Prepare the config file.')
config_parser.add_argument('backend',
choices=['localmongodb'],
default='localmongodb',
const='localmongodb',
choices=['tarantool_db'],
default='tarantool_db',
const='tarantool_db',
nargs='?',
help='The backend to use. It can only be '
'"localmongodb", currently.')
'"tarantool_db", currently.')
# parser for managing elections
election_parser = subparsers.add_parser('election',

2
planetmint/lib.py
View File

@ -76,7 +76,7 @@ class Planetmint(object):
else:
self.validation = BaseValidationRules
self.connection = connection if connection else backend.connect(**planetmint.config['database'])
self.connection = connection if connection else backend.connection_tarantool.connect(**planetmint.config['database'])
def post_transaction(self, transaction, mode):
"""Submit a valid transaction to the mempool."""