Compare commits
No commits in common. "671286dc392a151939bf3d69c09a01190e62ea85" and "d79b57b1f07966f4412af1c34d6cd4b647cbafa9" have entirely different histories.
671286dc39
...
d79b57b1f0
@ -58,31 +58,21 @@ async def get_accounts(
|
|||||||
|
|
||||||
async def delete_all(bot: AsyncTeleBot, engine: Engine, mes: Message) -> None:
|
async def delete_all(bot: AsyncTeleBot, engine: Engine, mes: Message) -> None:
|
||||||
await base_handler(bot, mes)
|
await base_handler(bot, mes)
|
||||||
master_pass = db.get.get_master_pass(engine, mes.from_user.id)
|
|
||||||
if master_pass is None:
|
|
||||||
await send_tmp_message(bot, mes.chat.id, "У вас нет мастер пароля")
|
|
||||||
return
|
|
||||||
bot_mes = await bot.send_message(
|
bot_mes = await bot.send_message(
|
||||||
mes.chat.id,
|
mes.chat.id,
|
||||||
"Вы действительно хотите удалить все ваши аккаунты? Это действие "
|
"Вы действительно хотите удалить все ваши аккаунты? Это действие "
|
||||||
"нельзя отменить. "
|
"нельзя отменить. "
|
||||||
"Отправьте мастер пароль для подтверждения",
|
"Отправьте YES для подтверждения",
|
||||||
)
|
|
||||||
register_state(
|
|
||||||
mes, functools.partial(_delete_all2, bot, engine, master_pass, bot_mes)
|
|
||||||
)
|
)
|
||||||
|
register_state(mes, functools.partial(_delete_all2, bot, engine, bot_mes))
|
||||||
|
|
||||||
|
|
||||||
async def _delete_all2(
|
async def _delete_all2(
|
||||||
bot: AsyncTeleBot,
|
bot: AsyncTeleBot, engine: Engine, prev_mes: Message, mes: Message
|
||||||
engine: Engine,
|
|
||||||
master_pass: db.models.MasterPass,
|
|
||||||
prev_mes: Message,
|
|
||||||
mes: Message,
|
|
||||||
) -> None:
|
) -> None:
|
||||||
await base_handler(bot, mes, prev_mes)
|
await base_handler(bot, mes, prev_mes)
|
||||||
text = mes.text.strip()
|
text = mes.text.strip()
|
||||||
if encryption.master_pass.check_master_pass(text, master_pass):
|
if text == "YES":
|
||||||
db.delete.purge_accounts(engine, mes.from_user.id)
|
db.delete.purge_accounts(engine, mes.from_user.id)
|
||||||
db.delete.delete_master_pass(engine, mes.from_user.id)
|
db.delete.delete_master_pass(engine, mes.from_user.id)
|
||||||
await send_tmp_message(
|
await send_tmp_message(
|
||||||
@ -95,7 +85,7 @@ async def _delete_all2(
|
|||||||
await send_tmp_message(
|
await send_tmp_message(
|
||||||
bot,
|
bot,
|
||||||
mes.chat.id,
|
mes.chat.id,
|
||||||
"Вы отправили не верный мастер пароль, ничего не удалено",
|
"Вы отправили не YES, ничего не удалено",
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
@ -144,8 +134,7 @@ async def reset_master_pass(
|
|||||||
) -> None:
|
) -> None:
|
||||||
await base_handler(bot, mes)
|
await base_handler(bot, mes)
|
||||||
|
|
||||||
master_pass = db.get.get_master_pass(engine, mes.from_user.id)
|
if db.get.get_master_pass(engine, mes.from_user.id) is None:
|
||||||
if master_pass is None:
|
|
||||||
return await send_tmp_message(
|
return await send_tmp_message(
|
||||||
bot,
|
bot,
|
||||||
mes.chat.id,
|
mes.chat.id,
|
||||||
@ -154,48 +143,17 @@ async def reset_master_pass(
|
|||||||
|
|
||||||
bot_mes = await bot.send_message(
|
bot_mes = await bot.send_message(
|
||||||
mes.chat.id,
|
mes.chat.id,
|
||||||
"Отправьте текущий мастер пароль",
|
"Отправьте новый мастер пароль, осторожно, все текущие аккаунты "
|
||||||
|
"будут удалены навсегда",
|
||||||
)
|
)
|
||||||
|
|
||||||
register_state(
|
register_state(
|
||||||
mes,
|
mes,
|
||||||
functools.partial(
|
functools.partial(_reset_master_pass2, bot, engine, bot_mes),
|
||||||
_reset_master_pass2,
|
|
||||||
bot,
|
|
||||||
engine,
|
|
||||||
master_pass,
|
|
||||||
bot_mes,
|
|
||||||
),
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
async def _reset_master_pass2(
|
async def _reset_master_pass2(
|
||||||
bot: AsyncTeleBot,
|
|
||||||
engine: Engine,
|
|
||||||
master_pass: db.models.MasterPass,
|
|
||||||
prev_mes: Message,
|
|
||||||
mes: Message,
|
|
||||||
) -> None:
|
|
||||||
await base_handler(bot, mes, prev_mes)
|
|
||||||
text = mes.text.strip()
|
|
||||||
if text == "/cancel":
|
|
||||||
await send_tmp_message(bot, mes.chat.id, "Успешная отмена")
|
|
||||||
|
|
||||||
if not encryption.master_pass.check_master_pass(text, master_pass):
|
|
||||||
await send_tmp_message(bot, mes.chat.id, "Неверный мастер пароль")
|
|
||||||
return
|
|
||||||
|
|
||||||
bot_mes = await bot.send_message(
|
|
||||||
mes.chat.id,
|
|
||||||
"Отправьте новый мастер пароль. Осторожно, все аккаунты будут удалены",
|
|
||||||
)
|
|
||||||
register_state(
|
|
||||||
mes,
|
|
||||||
functools.partial(_reset_master_pass3, bot, engine, bot_mes),
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
async def _reset_master_pass3(
|
|
||||||
bot: AsyncTeleBot, engine: Engine, prev_mes: Message, mes: Message
|
bot: AsyncTeleBot, engine: Engine, prev_mes: Message, mes: Message
|
||||||
) -> None:
|
) -> None:
|
||||||
await base_handler(bot, mes, prev_mes)
|
await base_handler(bot, mes, prev_mes)
|
||||||
@ -470,14 +428,13 @@ async def delete_account(
|
|||||||
|
|
||||||
register_state(
|
register_state(
|
||||||
mes,
|
mes,
|
||||||
functools.partial(_delete_account2, bot, engine, master_pass, bot_mes),
|
functools.partial(_delete_account2, bot, engine, bot_mes),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
async def _delete_account2(
|
async def _delete_account2(
|
||||||
bot: AsyncTeleBot,
|
bot: AsyncTeleBot,
|
||||||
engine: Engine,
|
engine: Engine,
|
||||||
master_pass: db.models.MasterPass,
|
|
||||||
prev_mes: Message,
|
prev_mes: Message,
|
||||||
mes: Message,
|
mes: Message,
|
||||||
):
|
):
|
||||||
@ -491,36 +448,27 @@ async def _delete_account2(
|
|||||||
|
|
||||||
bot_mes = await bot.send_message(
|
bot_mes = await bot.send_message(
|
||||||
mes.from_user.id,
|
mes.from_user.id,
|
||||||
f'Вы уверены, что хотите удалить аккаунт "{text}"?\nОтправьте мастер '
|
f'Вы уверены, что хотите удалить аккаунт "{text}"?\nОтправьте YES для '
|
||||||
"пароль для подтверждения",
|
"подтверждения",
|
||||||
)
|
)
|
||||||
|
|
||||||
register_state(
|
register_state(
|
||||||
mes,
|
mes,
|
||||||
functools.partial(
|
functools.partial(_delete_account3, bot, engine, bot_mes, text),
|
||||||
_delete_account3,
|
|
||||||
bot,
|
|
||||||
engine,
|
|
||||||
master_pass,
|
|
||||||
bot_mes,
|
|
||||||
text,
|
|
||||||
),
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
async def _delete_account3(
|
async def _delete_account3(
|
||||||
bot: AsyncTeleBot,
|
bot: AsyncTeleBot,
|
||||||
engine: Engine,
|
engine: Engine,
|
||||||
master_pass: db.models.MasterPass,
|
|
||||||
prev_mes: Message,
|
prev_mes: Message,
|
||||||
account_name: str,
|
account_name: str,
|
||||||
mes: Message,
|
mes: Message,
|
||||||
) -> None:
|
) -> None:
|
||||||
await base_handler(bot, mes, prev_mes)
|
await base_handler(bot, mes, prev_mes)
|
||||||
text = mes.text.strip()
|
text = mes.text.strip()
|
||||||
if not encryption.master_pass.check_master_pass(text, master_pass):
|
if text != "YES":
|
||||||
await send_tmp_message(bot, mes.chat.id, "Неверный пароль")
|
return await send_tmp_message(bot, mes.chat.id, "Успешная отмена")
|
||||||
return
|
|
||||||
|
|
||||||
db.delete.delete_account(engine, mes.from_user.id, account_name)
|
db.delete.delete_account(engine, mes.from_user.id, account_name)
|
||||||
await send_tmp_message(bot, mes.chat.id, "Аккаунт удалён")
|
await send_tmp_message(bot, mes.chat.id, "Аккаунт удалён")
|
||||||
@ -749,13 +697,4 @@ async def message_handler(bot: AsyncTeleBot, mes: Message) -> None:
|
|||||||
"Вы отправили не корректное сообщение",
|
"Вы отправили не корректное сообщение",
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
|
await handler(mes)
|
||||||
try:
|
|
||||||
await handler(mes)
|
|
||||||
except Exception:
|
|
||||||
await send_tmp_message(
|
|
||||||
bot,
|
|
||||||
mes.chat.id,
|
|
||||||
"Произошла непредвиденная ошибка",
|
|
||||||
)
|
|
||||||
raise
|
|
||||||
|
@ -1,43 +1,26 @@
|
|||||||
|
import base64
|
||||||
import os
|
import os
|
||||||
from typing import Self
|
|
||||||
|
|
||||||
|
from cryptography.fernet import Fernet
|
||||||
|
from cryptography.hazmat.backends import default_backend
|
||||||
from cryptography.hazmat.primitives import hashes
|
from cryptography.hazmat.primitives import hashes
|
||||||
from cryptography.hazmat.primitives.ciphers.aead import ChaCha20Poly1305
|
|
||||||
from cryptography.hazmat.primitives.kdf.pbkdf2 import PBKDF2HMAC
|
from cryptography.hazmat.primitives.kdf.pbkdf2 import PBKDF2HMAC
|
||||||
|
|
||||||
from ..db.models import Account
|
from ..db.models import Account
|
||||||
from ..decrypted_account import DecryptedAccount
|
from ..decrypted_account import DecryptedAccount
|
||||||
|
|
||||||
|
|
||||||
class Cipher:
|
def _generate_key(salt: bytes, master_pass: bytes) -> bytes:
|
||||||
def __init__(self, key: bytes) -> None:
|
"""Generates key for fernet encryption"""
|
||||||
self._chacha = ChaCha20Poly1305(key)
|
kdf = PBKDF2HMAC(
|
||||||
|
algorithm=hashes.SHA256(),
|
||||||
@classmethod
|
length=32,
|
||||||
def generate_cipher(cls, salt: bytes, password: bytes) -> Self:
|
salt=salt,
|
||||||
"""Generates cipher which uses key derived from a given password"""
|
iterations=100000,
|
||||||
kdf = PBKDF2HMAC(
|
backend=default_backend(),
|
||||||
algorithm=hashes.SHA256(),
|
)
|
||||||
length=32,
|
key = base64.urlsafe_b64encode(kdf.derive(master_pass))
|
||||||
salt=salt,
|
return key
|
||||||
iterations=100000,
|
|
||||||
)
|
|
||||||
return cls(kdf.derive(password))
|
|
||||||
|
|
||||||
def encrypt(self, data: bytes) -> bytes:
|
|
||||||
nonce = os.urandom(12)
|
|
||||||
return nonce + self._chacha.encrypt(
|
|
||||||
nonce,
|
|
||||||
data,
|
|
||||||
associated_data=None,
|
|
||||||
)
|
|
||||||
|
|
||||||
def decrypt(self, data: bytes) -> bytes:
|
|
||||||
return self._chacha.decrypt(
|
|
||||||
nonce=data[:12],
|
|
||||||
data=data[12:],
|
|
||||||
associated_data=None,
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
def encrypt(
|
def encrypt(
|
||||||
@ -46,10 +29,15 @@ def encrypt(
|
|||||||
) -> Account:
|
) -> Account:
|
||||||
"""Encrypts account using master password and returns Account object"""
|
"""Encrypts account using master password and returns Account object"""
|
||||||
salt = os.urandom(64)
|
salt = os.urandom(64)
|
||||||
cipher = Cipher.generate_cipher(salt, master_pass.encode("utf-8"))
|
key = _generate_key(salt, master_pass.encode("utf-8"))
|
||||||
|
f = Fernet(key)
|
||||||
|
|
||||||
enc_login = cipher.encrypt(account.login.encode("utf-8"))
|
enc_login = base64.urlsafe_b64decode(
|
||||||
enc_password = cipher.encrypt(account.password.encode("utf-8"))
|
f.encrypt(account.login.encode("utf-8")),
|
||||||
|
)
|
||||||
|
enc_password = base64.urlsafe_b64decode(
|
||||||
|
f.encrypt(account.password.encode("utf-8")),
|
||||||
|
)
|
||||||
|
|
||||||
return Account(
|
return Account(
|
||||||
user_id=account.user_id,
|
user_id=account.user_id,
|
||||||
@ -66,10 +54,15 @@ def decrypt(
|
|||||||
) -> DecryptedAccount:
|
) -> DecryptedAccount:
|
||||||
"""Decrypts account using master password and returns
|
"""Decrypts account using master password and returns
|
||||||
DecryptedAccount object"""
|
DecryptedAccount object"""
|
||||||
cipher = Cipher.generate_cipher(account.salt, master_pass.encode("utf-8"))
|
key = _generate_key(account.salt, master_pass.encode("utf-8"))
|
||||||
|
f = Fernet(key)
|
||||||
|
|
||||||
login = cipher.decrypt(account.enc_login).decode("utf-8")
|
login = f.decrypt(
|
||||||
password = cipher.decrypt(account.enc_password).decode("utf-8")
|
base64.urlsafe_b64encode(account.enc_login),
|
||||||
|
).decode("utf-8")
|
||||||
|
password = f.decrypt(
|
||||||
|
base64.urlsafe_b64encode(account.enc_password),
|
||||||
|
).decode("utf-8")
|
||||||
|
|
||||||
return DecryptedAccount(
|
return DecryptedAccount(
|
||||||
user_id=account.user_id,
|
user_id=account.user_id,
|
||||||
|
Reference in New Issue
Block a user