From 024a88c92fbcc5eee09959bb7c4c83f7fb71cfb4 Mon Sep 17 00:00:00 2001 From: Santiago Lo Coco Date: Sun, 11 Dec 2022 16:51:33 -0300 Subject: [PATCH] Refactor backend and add redis client --- bsition/api/api.py | 2 - bsition/api/endpoints/documents.py | 3 +- bsition/api/endpoints/tables.py | 2 +- bsition/api/endpoints/token.py | 2 +- bsition/api/endpoints/users.py | 6 +- bsition/api/utils/security.py | 2 +- bsition/backend/configure.py | 5 +- bsition/backend/elastic/__init__.py | 0 .../backend/{elastic.py => elastic/search.py} | 23 +---- bsition/backend/elastic/utils.py | 22 +++++ bsition/backend/mongo/__init__.py | 0 .../backend/{mongo.py => mongo/documents.py} | 11 +-- bsition/backend/mongo/utils.py | 8 ++ bsition/backend/postgres/__init__.py | 0 .../{postgres.py => postgres/tables.py} | 93 +------------------ bsition/backend/postgres/users.py | 84 +++++++++++++++++ bsition/backend/postgres/utils.py | 12 +++ bsition/backend/redis/__init__.py | 0 bsition/backend/redis/tokens.py | 15 +++ bsition/backend/redis/utils.py | 7 ++ docker-compose.yml | 10 ++ poetry.lock | 85 ++++++++++++++++- pyproject.toml | 1 + 23 files changed, 259 insertions(+), 134 deletions(-) create mode 100644 bsition/backend/elastic/__init__.py rename bsition/backend/{elastic.py => elastic/search.py} (64%) create mode 100644 bsition/backend/elastic/utils.py create mode 100644 bsition/backend/mongo/__init__.py rename bsition/backend/{mongo.py => mongo/documents.py} (89%) create mode 100644 bsition/backend/mongo/utils.py create mode 100644 bsition/backend/postgres/__init__.py rename bsition/backend/{postgres.py => postgres/tables.py} (72%) create mode 100644 bsition/backend/postgres/users.py create mode 100644 bsition/backend/postgres/utils.py create mode 100644 bsition/backend/redis/__init__.py create mode 100644 bsition/backend/redis/tokens.py create mode 100644 bsition/backend/redis/utils.py diff --git a/bsition/api/api.py b/bsition/api/api.py index 30ea74f..212e14a 100644 --- a/bsition/api/api.py +++ b/bsition/api/api.py @@ -1,12 +1,10 @@ from fastapi import APIRouter, Depends -from fastapi.responses import JSONResponse from bsition.api.endpoints import documents, tables, token, users from bsition.api.utils.security import get_current_user router = APIRouter() - router.include_router(token.router) router.include_router( documents.router, prefix="/documents", dependencies=[Depends(get_current_user)] diff --git a/bsition/api/endpoints/documents.py b/bsition/api/endpoints/documents.py index cc32e91..c849a50 100644 --- a/bsition/api/endpoints/documents.py +++ b/bsition/api/endpoints/documents.py @@ -4,7 +4,8 @@ from fastapi import APIRouter from fastapi.responses import JSONResponse from bsition.api.models.document import Document, DocumentUpdate -from bsition.backend import elastic, mongo +from bsition.backend.mongo import documents as mongo +from bsition.backend.elastic import search as elastic router = APIRouter() diff --git a/bsition/api/endpoints/tables.py b/bsition/api/endpoints/tables.py index 91ec0a1..bd0c151 100644 --- a/bsition/api/endpoints/tables.py +++ b/bsition/api/endpoints/tables.py @@ -2,7 +2,7 @@ from fastapi import APIRouter from fastapi.responses import JSONResponse from bsition.api.models.table import Filter, Sort, Table -from bsition.backend import postgres +from bsition.backend.postgres import tables as postgres router = APIRouter() diff --git a/bsition/api/endpoints/token.py b/bsition/api/endpoints/token.py index d458eff..dce48f8 100644 --- a/bsition/api/endpoints/token.py +++ b/bsition/api/endpoints/token.py @@ -4,7 +4,7 @@ from fastapi.security import OAuth2PasswordRequestForm from bsition.api.utils.jwt import write_token from bsition.api.utils.password import verify_password -from bsition.backend.postgres import get_user_by_username +from bsition.backend.postgres.users import get_user_by_username router = APIRouter() diff --git a/bsition/api/endpoints/users.py b/bsition/api/endpoints/users.py index 24292ca..c8723f7 100644 --- a/bsition/api/endpoints/users.py +++ b/bsition/api/endpoints/users.py @@ -1,17 +1,17 @@ -from fastapi import APIRouter, Depends, HTTPException, Request +from fastapi import APIRouter, Depends, HTTPException from fastapi.responses import JSONResponse from bsition.api.models.user import User from bsition.api.utils.password import get_hashed_password from bsition.api.utils.security import get_current_user -from bsition.backend import postgres +from bsition.backend.postgres import users as postgres router = APIRouter() @router.post("") def create_user(user: User): - aux = postgres.get_user_by_username_and_password(user.username, user.password) + aux = postgres.get_user_by_username(user.username) if aux is not None: raise HTTPException( status_code=400, diff --git a/bsition/api/utils/security.py b/bsition/api/utils/security.py index 0335d87..52a4d64 100644 --- a/bsition/api/utils/security.py +++ b/bsition/api/utils/security.py @@ -4,7 +4,7 @@ from jwt import exceptions from starlette import status from bsition.api.utils.jwt import validate_token -from bsition.backend.postgres import get_user_by_username +from bsition.backend.postgres.users import get_user_by_username oauth2_scheme = OAuth2PasswordBearer(tokenUrl="api/token") diff --git a/bsition/backend/configure.py b/bsition/backend/configure.py index dceafef..7def069 100644 --- a/bsition/backend/configure.py +++ b/bsition/backend/configure.py @@ -1,7 +1,8 @@ from dotenv import load_dotenv -from bsition.backend.elastic import * -from bsition.backend.postgres import * +from bsition.backend.elastic.utils import create_index +from bsition.backend.postgres.users import create_user_table +from bsition.backend.postgres.tables import add_function def configure(): diff --git a/bsition/backend/elastic/__init__.py b/bsition/backend/elastic/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/bsition/backend/elastic.py b/bsition/backend/elastic/search.py similarity index 64% rename from bsition/backend/elastic.py rename to bsition/backend/elastic/search.py index 5cb5eb4..9dc4456 100644 --- a/bsition/backend/elastic.py +++ b/bsition/backend/elastic/search.py @@ -1,25 +1,4 @@ -from os import getenv - -from elasticsearch import Elasticsearch - - -def get_client(): - return Elasticsearch(getenv("ELASTIC_URL"), timeout=300) - - -def create_index(index): - client = get_client() - client.indices.create(index=index) - - -def add_document(index, id, doc): - client = get_client() - client.index(index=index, id=id, document=doc) - - -def refresh_index(index): - client = get_client() - client.indices.refresh(index=index) +from bsition.backend.elastic.utils import get_client def search(index, query): diff --git a/bsition/backend/elastic/utils.py b/bsition/backend/elastic/utils.py new file mode 100644 index 0000000..dcf2c7e --- /dev/null +++ b/bsition/backend/elastic/utils.py @@ -0,0 +1,22 @@ +from os import getenv + +from elasticsearch import Elasticsearch + + +def get_client(): + return Elasticsearch(getenv("ELASTIC_URL"), timeout=300) + + +def create_index(index): + client = get_client() + client.indices.create(index=index) + + +def add_document(index, id, doc): + client = get_client() + client.index(index=index, id=id, document=doc) + + +def refresh_index(index): + client = get_client() + client.indices.refresh(index=index) diff --git a/bsition/backend/mongo/__init__.py b/bsition/backend/mongo/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/bsition/backend/mongo.py b/bsition/backend/mongo/documents.py similarity index 89% rename from bsition/backend/mongo.py rename to bsition/backend/mongo/documents.py index 699c853..5ac054f 100644 --- a/bsition/backend/mongo.py +++ b/bsition/backend/mongo/documents.py @@ -1,14 +1,7 @@ -from os import getenv - from bson import ObjectId -from pymongo import MongoClient -from bsition.backend import elastic - - -def get_database(): - client = MongoClient(getenv("MONGO_URL")) - return client["documents"] +from bsition.backend.elastic import utils as elastic +from bsition.backend.mongo.utils import get_database def get_documents(): diff --git a/bsition/backend/mongo/utils.py b/bsition/backend/mongo/utils.py new file mode 100644 index 0000000..a3e33b4 --- /dev/null +++ b/bsition/backend/mongo/utils.py @@ -0,0 +1,8 @@ +from os import getenv + +from pymongo import MongoClient + + +def get_database(): + client = MongoClient(getenv("MONGO_URL")) + return client["documents"] diff --git a/bsition/backend/postgres/__init__.py b/bsition/backend/postgres/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/bsition/backend/postgres.py b/bsition/backend/postgres/tables.py similarity index 72% rename from bsition/backend/postgres.py rename to bsition/backend/postgres/tables.py index 2098219..f6fa81b 100644 --- a/bsition/backend/postgres.py +++ b/bsition/backend/postgres/tables.py @@ -1,16 +1,6 @@ -import inspect -from os import getenv +from psycopg2 import sql -from psycopg2 import connect, sql - - -def get_connection(): - return connect( - host=getenv("POSTGRES_HOST"), - database=getenv("POSTGRES_DB"), - user=getenv("POSTGRES_USER"), - password=getenv("POSTGRES_PASSWORD"), - ) +from bsition.backend.postgres.utils import get_connection def create_table(name): @@ -233,82 +223,3 @@ def filter(name): ), ) return list(cur.fetchall()) - - -def create_user_table(): - conn = get_connection() - cur = conn.cursor() - cur.execute( - "CREATE TABLE users (id SERIAL PRIMARY KEY, username TEXT UNIQUE, password TEXT)" - ) - conn.commit() - - -def add_user(username, password): - conn = get_connection() - cur = conn.cursor() - cur.execute( - "INSERT INTO users VALUES (DEFAULT, %s, %s)", - (username, password), - ) - conn.commit() - - -def get_users(): - conn = get_connection() - cur = conn.cursor() - cur.execute("SELECT * FROM users") - return list(cur.fetchall()) - - -def get_user_by_id(id): - conn = get_connection() - cur = conn.cursor() - cur.execute( - "SELECT * FROM users WHERE id = %s", - id, - ) - return cur.fetchone() - - -def get_user_by_username(username): - conn = get_connection() - cur = conn.cursor() - cur.execute( - sql.SQL("SELECT * FROM users WHERE username = {username}").format( - username=sql.Literal(username) - ) - ) - return cur.fetchone() - - -def get_user_by_username_and_password(username, password): - conn = get_connection() - cur = conn.cursor() - cur.execute( - sql.SQL( - "SELECT * FROM users WHERE username = {username} AND password = {password}" - ).format(username=sql.Literal(username), password=sql.Literal(password)) - ) - return cur.fetchone() - - -def edit_user(id, username, password): - conn = get_connection() - cur = conn.cursor() - columns = inspect.getfullargspec(edit_user)[0][1:] - data = [username, password] - i = -1 - for column in columns: - i += 1 - if data[i] is None: - continue - - cur.execute( - sql.SQL("UPDATE users SET {col} = {value} WHERE id = {id}").format( - col=sql.Identifier(column), - value=sql.Literal(data[i]), - id=sql.Literal(id), - ), - ) - conn.commit() diff --git a/bsition/backend/postgres/users.py b/bsition/backend/postgres/users.py new file mode 100644 index 0000000..de0c31f --- /dev/null +++ b/bsition/backend/postgres/users.py @@ -0,0 +1,84 @@ +import inspect + +from psycopg2 import sql + +from bsition.backend.postgres.utils import get_connection + + +def create_user_table(): + conn = get_connection() + cur = conn.cursor() + cur.execute( + "CREATE TABLE users (id SERIAL PRIMARY KEY, username TEXT UNIQUE, password TEXT)" + ) + conn.commit() + + +def add_user(username, password): + conn = get_connection() + cur = conn.cursor() + cur.execute( + "INSERT INTO users VALUES (DEFAULT, %s, %s)", + (username, password), + ) + conn.commit() + + +def get_users(): + conn = get_connection() + cur = conn.cursor() + cur.execute("SELECT * FROM users") + return list(cur.fetchall()) + + +def get_user_by_id(id): + conn = get_connection() + cur = conn.cursor() + cur.execute( + "SELECT * FROM users WHERE id = %s", + id, + ) + return cur.fetchone() + + +def get_user_by_username(username): + conn = get_connection() + cur = conn.cursor() + cur.execute( + sql.SQL("SELECT * FROM users WHERE username = {username}").format( + username=sql.Literal(username) + ) + ) + return cur.fetchone() + + +def get_user_by_username_and_password(username, password): + conn = get_connection() + cur = conn.cursor() + cur.execute( + sql.SQL( + "SELECT * FROM users WHERE username = {username} AND password = {password}" + ).format(username=sql.Literal(username), password=sql.Literal(password)) + ) + return cur.fetchone() + + +def edit_user(id, username, password): + conn = get_connection() + cur = conn.cursor() + columns = inspect.getfullargspec(edit_user)[0][1:] + data = [username, password] + i = -1 + for column in columns: + i += 1 + if data[i] is None: + continue + + cur.execute( + sql.SQL("UPDATE users SET {col} = {value} WHERE id = {id}").format( + col=sql.Identifier(column), + value=sql.Literal(data[i]), + id=sql.Literal(id), + ), + ) + conn.commit() diff --git a/bsition/backend/postgres/utils.py b/bsition/backend/postgres/utils.py new file mode 100644 index 0000000..113fb44 --- /dev/null +++ b/bsition/backend/postgres/utils.py @@ -0,0 +1,12 @@ +from os import getenv + +from psycopg2 import connect + + +def get_connection(): + return connect( + host=getenv("POSTGRES_HOST"), + database=getenv("POSTGRES_DB"), + user=getenv("POSTGRES_USER"), + password=getenv("POSTGRES_PASSWORD"), + ) diff --git a/bsition/backend/redis/__init__.py b/bsition/backend/redis/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/bsition/backend/redis/tokens.py b/bsition/backend/redis/tokens.py new file mode 100644 index 0000000..63c4cce --- /dev/null +++ b/bsition/backend/redis/tokens.py @@ -0,0 +1,15 @@ +from dotenv import load_dotenv + +from redis import Redis + +from bsition.backend.redis.utils import get_client + + +def test(): + load_dotenv() + client = get_client() + client.set("foo", "bar") + print(client.get("foo")) + + +test() diff --git a/bsition/backend/redis/utils.py b/bsition/backend/redis/utils.py new file mode 100644 index 0000000..a93d98e --- /dev/null +++ b/bsition/backend/redis/utils.py @@ -0,0 +1,7 @@ +from os import getenv + +from redis import Redis + + +def get_client(): + return Redis(host=getenv("REDIS_HOST"), port=int(getenv("REDIS_PORT"))) diff --git a/docker-compose.yml b/docker-compose.yml index a918ad1..65241b3 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -39,3 +39,13 @@ services: ports: - "9200:9200" - "9300:9300" + + redis: + image: redis + container_name: bsition-redis + sysctls: + - net.core.somaxconn=512 + ports: + - "6379:6379" + volumes: + - ./data/redis:/data diff --git a/poetry.lock b/poetry.lock index 748a702..f2c9a72 100644 --- a/poetry.lock +++ b/poetry.lock @@ -15,6 +15,14 @@ doc = ["packaging", "sphinx-autodoc-typehints (>=1.2.0)", "sphinx-rtd-theme"] test = ["contextlib2", "coverage[toml] (>=4.5)", "hypothesis (>=4.0)", "mock (>=4)", "pytest (>=7.0)", "pytest-mock (>=3.6.1)", "trustme", "uvloop (<0.15)", "uvloop (>=0.15)"] trio = ["trio (>=0.16,<0.22)"] +[[package]] +name = "async-timeout" +version = "4.0.2" +description = "Timeout context manager for asyncio programs" +category = "main" +optional = false +python-versions = ">=3.6" + [[package]] name = "bcrypt" version = "4.0.1" @@ -232,6 +240,14 @@ category = "main" optional = false python-versions = ">=3.7" +[[package]] +name = "hiredis" +version = "2.0.0" +description = "Python wrapper for hiredis" +category = "main" +optional = false +python-versions = ">=3.6" + [[package]] name = "httptools" version = "0.5.0" @@ -456,6 +472,22 @@ category = "main" optional = false python-versions = ">=3.6" +[[package]] +name = "redis" +version = "4.4.0" +description = "Python client for Redis database and key-value store" +category = "main" +optional = false +python-versions = ">=3.7" + +[package.dependencies] +async-timeout = ">=4.0.2" +hiredis = {version = ">=1.0.0", optional = true, markers = "extra == \"hiredis\""} + +[package.extras] +hiredis = ["hiredis (>=1.0.0)"] +ocsp = ["cryptography (>=36.0.1)", "pyopenssl (==20.0.1)", "requests (>=2.26.0)"] + [[package]] name = "rsa" version = "4.9" @@ -621,13 +653,17 @@ python-versions = ">=3.7" [metadata] lock-version = "1.1" python-versions = "^3.10" -content-hash = "429171733b03d8dcf9e45a013ca95956732269978898de2f03661672469c2793" +content-hash = "420a75cff85aae27f0a66a9739d2b4ff0cf90f52ef73db164e40e74da6a5ff2b" [metadata.files] anyio = [ {file = "anyio-3.6.2-py3-none-any.whl", hash = "sha256:fbbe32bd270d2a2ef3ed1c5d45041250284e31fc0a4df4a5a6071842051a51e3"}, {file = "anyio-3.6.2.tar.gz", hash = "sha256:25ea0d673ae30af41a0c442f81cf3b38c7e79fdc7b60335a4c14e05eb0947421"}, ] +async-timeout = [ + {file = "async-timeout-4.0.2.tar.gz", hash = "sha256:2163e1640ddb52b7a8c80d0a67a08587e5d245cc9c553a74a847056bc2976b15"}, + {file = "async_timeout-4.0.2-py3-none-any.whl", hash = "sha256:8ca1e4fcf50d07413d66d1a5e416e42cfdf5851c981d679a09851a6853383b3c"}, +] bcrypt = [ {file = "bcrypt-4.0.1-cp36-abi3-macosx_10_10_universal2.whl", hash = "sha256:b1023030aec778185a6c16cf70f359cbb6e0c289fd564a7cfa29e727a1c38f8f"}, {file = "bcrypt-4.0.1-cp36-abi3-manylinux_2_17_aarch64.manylinux2014_aarch64.manylinux_2_24_aarch64.whl", hash = "sha256:08d2947c490093a11416df18043c27abe3921558d2c03e2076ccb28a116cb6d0"}, @@ -811,6 +847,49 @@ h11 = [ {file = "h11-0.14.0-py3-none-any.whl", hash = "sha256:e3fe4ac4b851c468cc8363d500db52c2ead036020723024a109d37346efaa761"}, {file = "h11-0.14.0.tar.gz", hash = "sha256:8f19fbbe99e72420ff35c00b27a34cb9937e902a8b810e2c88300c6f0a3b699d"}, ] +hiredis = [ + {file = "hiredis-2.0.0-cp36-cp36m-macosx_10_9_x86_64.whl", hash = "sha256:b4c8b0bc5841e578d5fb32a16e0c305359b987b850a06964bd5a62739d688048"}, + {file = "hiredis-2.0.0-cp36-cp36m-manylinux1_i686.whl", hash = "sha256:0adea425b764a08270820531ec2218d0508f8ae15a448568109ffcae050fee26"}, + {file = "hiredis-2.0.0-cp36-cp36m-manylinux1_x86_64.whl", hash = "sha256:3d55e36715ff06cdc0ab62f9591607c4324297b6b6ce5b58cb9928b3defe30ea"}, + {file = "hiredis-2.0.0-cp36-cp36m-manylinux2010_i686.whl", hash = "sha256:5d2a48c80cf5a338d58aae3c16872f4d452345e18350143b3bf7216d33ba7b99"}, + {file = "hiredis-2.0.0-cp36-cp36m-manylinux2010_x86_64.whl", hash = "sha256:240ce6dc19835971f38caf94b5738092cb1e641f8150a9ef9251b7825506cb05"}, + {file = "hiredis-2.0.0-cp36-cp36m-manylinux2014_aarch64.whl", hash = "sha256:5dc7a94bb11096bc4bffd41a3c4f2b958257085c01522aa81140c68b8bf1630a"}, + {file = "hiredis-2.0.0-cp36-cp36m-win32.whl", hash = "sha256:139705ce59d94eef2ceae9fd2ad58710b02aee91e7fa0ccb485665ca0ecbec63"}, + {file = "hiredis-2.0.0-cp36-cp36m-win_amd64.whl", hash = "sha256:c39c46d9e44447181cd502a35aad2bb178dbf1b1f86cf4db639d7b9614f837c6"}, + {file = "hiredis-2.0.0-cp37-cp37m-macosx_10_9_x86_64.whl", hash = "sha256:adf4dd19d8875ac147bf926c727215a0faf21490b22c053db464e0bf0deb0485"}, + {file = "hiredis-2.0.0-cp37-cp37m-manylinux1_i686.whl", hash = "sha256:0f41827028901814c709e744060843c77e78a3aca1e0d6875d2562372fcb405a"}, + {file = "hiredis-2.0.0-cp37-cp37m-manylinux1_x86_64.whl", hash = "sha256:508999bec4422e646b05c95c598b64bdbef1edf0d2b715450a078ba21b385bcc"}, + {file = "hiredis-2.0.0-cp37-cp37m-manylinux2010_i686.whl", hash = "sha256:0d5109337e1db373a892fdcf78eb145ffb6bbd66bb51989ec36117b9f7f9b579"}, + {file = "hiredis-2.0.0-cp37-cp37m-manylinux2010_x86_64.whl", hash = "sha256:04026461eae67fdefa1949b7332e488224eac9e8f2b5c58c98b54d29af22093e"}, + {file = "hiredis-2.0.0-cp37-cp37m-manylinux2014_aarch64.whl", hash = "sha256:a00514362df15af041cc06e97aebabf2895e0a7c42c83c21894be12b84402d79"}, + {file = "hiredis-2.0.0-cp37-cp37m-win32.whl", hash = "sha256:09004096e953d7ebd508cded79f6b21e05dff5d7361771f59269425108e703bc"}, + {file = "hiredis-2.0.0-cp37-cp37m-win_amd64.whl", hash = "sha256:f8196f739092a78e4f6b1b2172679ed3343c39c61a3e9d722ce6fcf1dac2824a"}, + {file = "hiredis-2.0.0-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:294a6697dfa41a8cba4c365dd3715abc54d29a86a40ec6405d677ca853307cfb"}, + {file = "hiredis-2.0.0-cp38-cp38-manylinux1_i686.whl", hash = "sha256:3dddf681284fe16d047d3ad37415b2e9ccdc6c8986c8062dbe51ab9a358b50a5"}, + {file = "hiredis-2.0.0-cp38-cp38-manylinux1_x86_64.whl", hash = "sha256:dcef843f8de4e2ff5e35e96ec2a4abbdf403bd0f732ead127bd27e51f38ac298"}, + {file = "hiredis-2.0.0-cp38-cp38-manylinux2010_i686.whl", hash = "sha256:87c7c10d186f1743a8fd6a971ab6525d60abd5d5d200f31e073cd5e94d7e7a9d"}, + {file = "hiredis-2.0.0-cp38-cp38-manylinux2010_x86_64.whl", hash = "sha256:7f0055f1809b911ab347a25d786deff5e10e9cf083c3c3fd2dd04e8612e8d9db"}, + {file = "hiredis-2.0.0-cp38-cp38-manylinux2014_aarch64.whl", hash = "sha256:11d119507bb54e81f375e638225a2c057dda748f2b1deef05c2b1a5d42686048"}, + {file = "hiredis-2.0.0-cp38-cp38-win32.whl", hash = "sha256:7492af15f71f75ee93d2a618ca53fea8be85e7b625e323315169977fae752426"}, + {file = "hiredis-2.0.0-cp38-cp38-win_amd64.whl", hash = "sha256:65d653df249a2f95673976e4e9dd7ce10de61cfc6e64fa7eeaa6891a9559c581"}, + {file = "hiredis-2.0.0-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:ae8427a5e9062ba66fc2c62fb19a72276cf12c780e8db2b0956ea909c48acff5"}, + {file = "hiredis-2.0.0-cp39-cp39-manylinux1_i686.whl", hash = "sha256:3f5f7e3a4ab824e3de1e1700f05ad76ee465f5f11f5db61c4b297ec29e692b2e"}, + {file = "hiredis-2.0.0-cp39-cp39-manylinux1_x86_64.whl", hash = "sha256:e3447d9e074abf0e3cd85aef8131e01ab93f9f0e86654db7ac8a3f73c63706ce"}, + {file = "hiredis-2.0.0-cp39-cp39-manylinux2010_i686.whl", hash = "sha256:8b42c0dc927b8d7c0eb59f97e6e34408e53bc489f9f90e66e568f329bff3e443"}, + {file = "hiredis-2.0.0-cp39-cp39-manylinux2010_x86_64.whl", hash = "sha256:b84f29971f0ad4adaee391c6364e6f780d5aae7e9226d41964b26b49376071d0"}, + {file = "hiredis-2.0.0-cp39-cp39-manylinux2014_aarch64.whl", hash = "sha256:0b39ec237459922c6544d071cdcf92cbb5bc6685a30e7c6d985d8a3e3a75326e"}, + {file = "hiredis-2.0.0-cp39-cp39-win32.whl", hash = "sha256:a7928283143a401e72a4fad43ecc85b35c27ae699cf5d54d39e1e72d97460e1d"}, + {file = "hiredis-2.0.0-cp39-cp39-win_amd64.whl", hash = "sha256:a4ee8000454ad4486fb9f28b0cab7fa1cd796fc36d639882d0b34109b5b3aec9"}, + {file = "hiredis-2.0.0-pp36-pypy36_pp73-macosx_10_9_x86_64.whl", hash = "sha256:1f03d4dadd595f7a69a75709bc81902673fa31964c75f93af74feac2f134cc54"}, + {file = "hiredis-2.0.0-pp36-pypy36_pp73-manylinux1_x86_64.whl", hash = "sha256:04927a4c651a0e9ec11c68e4427d917e44ff101f761cd3b5bc76f86aaa431d27"}, + {file = "hiredis-2.0.0-pp36-pypy36_pp73-manylinux2010_x86_64.whl", hash = "sha256:a39efc3ade8c1fb27c097fd112baf09d7fd70b8cb10ef1de4da6efbe066d381d"}, + {file = "hiredis-2.0.0-pp36-pypy36_pp73-win32.whl", hash = "sha256:07bbf9bdcb82239f319b1f09e8ef4bdfaec50ed7d7ea51a56438f39193271163"}, + {file = "hiredis-2.0.0-pp37-pypy37_pp73-macosx_10_9_x86_64.whl", hash = "sha256:807b3096205c7cec861c8803a6738e33ed86c9aae76cac0e19454245a6bbbc0a"}, + {file = "hiredis-2.0.0-pp37-pypy37_pp73-manylinux1_x86_64.whl", hash = "sha256:1233e303645f468e399ec906b6b48ab7cd8391aae2d08daadbb5cad6ace4bd87"}, + {file = "hiredis-2.0.0-pp37-pypy37_pp73-manylinux2010_x86_64.whl", hash = "sha256:cb2126603091902767d96bcb74093bd8b14982f41809f85c9b96e519c7e1dc41"}, + {file = "hiredis-2.0.0-pp37-pypy37_pp73-win32.whl", hash = "sha256:f52010e0a44e3d8530437e7da38d11fb822acfb0d5b12e9cd5ba655509937ca0"}, + {file = "hiredis-2.0.0.tar.gz", hash = "sha256:81d6d8e39695f2c37954d1011c0480ef7cf444d4e3ae24bc5e89ee5de360139a"}, +] httptools = [ {file = "httptools-0.5.0-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:8f470c79061599a126d74385623ff4744c4e0f4a0997a353a44923c0b561ee51"}, {file = "httptools-0.5.0-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:e90491a4d77d0cb82e0e7a9cb35d86284c677402e4ce7ba6b448ccc7325c5421"}, @@ -1084,6 +1163,10 @@ PyYAML = [ {file = "PyYAML-6.0-cp39-cp39-win_amd64.whl", hash = "sha256:b3d267842bf12586ba6c734f89d1f5b871df0273157918b0ccefa29deb05c21c"}, {file = "PyYAML-6.0.tar.gz", hash = "sha256:68fb519c14306fec9720a2a5b45bc9f0c8d1b9c72adf45c37baedfcd949c35a2"}, ] +redis = [ + {file = "redis-4.4.0-py3-none-any.whl", hash = "sha256:cae3ee5d1f57d8caf534cd8764edf3163c77e073bdd74b6f54a87ffafdc5e7d9"}, + {file = "redis-4.4.0.tar.gz", hash = "sha256:7b8c87d19c45d3f1271b124858d2a5c13160c4e74d4835e28273400fa34d5228"}, +] rsa = [ {file = "rsa-4.9-py3-none-any.whl", hash = "sha256:90260d9058e514786967344d0ef75fa8727eed8a7d2e43ce9f4bcf1b536174f7"}, {file = "rsa-4.9.tar.gz", hash = "sha256:e38464a49c6c85d7f1351b0126661487a7e0a14a50f1675ec50eb34d4f20ef21"}, diff --git a/pyproject.toml b/pyproject.toml index d4e01e6..4bc8706 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -22,6 +22,7 @@ elasticsearch = "^8.5.0" python-jose = {extras = ["cryptography"], version = "^3.3.0"} passlib = {extras = ["bcrypt"], version = "^1.7.4"} python-multipart = "^0.0.5" +redis = {extras = ["hiredis"], version = "^4.4.0"} [tool.poetry.dev-dependencies] pre-commit = "^2.20.0"