Compare commits
5 Commits
7c80a51a82
...
v2
| Author | SHA1 | Date | |
|---|---|---|---|
| 7254175cdb | |||
| a0cbdd5358 | |||
| 05990bf36e | |||
| f1d782bb74 | |||
| 908aff8b3d |
@@ -1,32 +0,0 @@
|
|||||||
"""init
|
|
||||||
|
|
||||||
Revision ID: 69ef23ef1ed1
|
|
||||||
Revises:
|
|
||||||
Create Date: 2025-09-05 13:53:02.737876
|
|
||||||
|
|
||||||
"""
|
|
||||||
from typing import Sequence, Union
|
|
||||||
|
|
||||||
from alembic import op
|
|
||||||
import sqlalchemy as sa
|
|
||||||
|
|
||||||
|
|
||||||
# revision identifiers, used by Alembic.
|
|
||||||
revision: str = '69ef23ef1ed1'
|
|
||||||
down_revision: Union[str, Sequence[str], None] = None
|
|
||||||
branch_labels: Union[str, Sequence[str], None] = None
|
|
||||||
depends_on: Union[str, Sequence[str], None] = None
|
|
||||||
|
|
||||||
|
|
||||||
def upgrade() -> None:
|
|
||||||
"""Upgrade schema."""
|
|
||||||
# ### commands auto generated by Alembic - please adjust! ###
|
|
||||||
pass
|
|
||||||
# ### end Alembic commands ###
|
|
||||||
|
|
||||||
|
|
||||||
def downgrade() -> None:
|
|
||||||
"""Downgrade schema."""
|
|
||||||
# ### commands auto generated by Alembic - please adjust! ###
|
|
||||||
pass
|
|
||||||
# ### end Alembic commands ###
|
|
||||||
@@ -1,39 +0,0 @@
|
|||||||
"""channel table
|
|
||||||
|
|
||||||
Revision ID: 7506a3320699
|
|
||||||
Revises: 69ef23ef1ed1
|
|
||||||
Create Date: 2025-09-05 14:12:37.430983
|
|
||||||
|
|
||||||
"""
|
|
||||||
from typing import Sequence, Union
|
|
||||||
|
|
||||||
from alembic import op
|
|
||||||
import sqlalchemy as sa
|
|
||||||
from sqlalchemy.sql import table, column
|
|
||||||
|
|
||||||
|
|
||||||
# revision identifiers, used by Alembic.
|
|
||||||
revision: str = '7506a3320699'
|
|
||||||
down_revision: Union[str, Sequence[str], None] = '69ef23ef1ed1'
|
|
||||||
branch_labels: Union[str, Sequence[str], None] = None
|
|
||||||
depends_on: Union[str, Sequence[str], None] = None
|
|
||||||
|
|
||||||
|
|
||||||
def upgrade() -> None:
|
|
||||||
"""Upgrade schema."""
|
|
||||||
# Для SQLite: добавляем столбцы через ALTER TABLE
|
|
||||||
conn = op.get_bind()
|
|
||||||
# Добавить столбец link, если его нет
|
|
||||||
result = conn.execute(sa.text("PRAGMA table_info(channels)")).fetchall()
|
|
||||||
columns = [row[1] for row in result]
|
|
||||||
if 'link' not in columns:
|
|
||||||
conn.execute(sa.text("ALTER TABLE channels ADD COLUMN link VARCHAR(255)"))
|
|
||||||
# Добавить столбец admin_id, если его нет
|
|
||||||
if 'admin_id' not in columns:
|
|
||||||
conn.execute(sa.text("ALTER TABLE channels ADD COLUMN admin_id INTEGER"))
|
|
||||||
|
|
||||||
|
|
||||||
def downgrade() -> None:
|
|
||||||
"""Downgrade schema."""
|
|
||||||
# SQLite не поддерживает удаление столбцов, поэтому просто удаляем таблицу
|
|
||||||
op.drop_table('channels')
|
|
||||||
57
alembic/versions/eeb6744b9452_init.py
Normal file
57
alembic/versions/eeb6744b9452_init.py
Normal file
@@ -0,0 +1,57 @@
|
|||||||
|
"""init
|
||||||
|
|
||||||
|
Revision ID: eeb6744b9452
|
||||||
|
Revises:
|
||||||
|
Create Date: 2025-09-05 14:55:12.005564
|
||||||
|
|
||||||
|
"""
|
||||||
|
from typing import Sequence, Union
|
||||||
|
|
||||||
|
from alembic import op
|
||||||
|
import sqlalchemy as sa
|
||||||
|
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic.
|
||||||
|
revision: str = 'eeb6744b9452'
|
||||||
|
down_revision: Union[str, Sequence[str], None] = None
|
||||||
|
branch_labels: Union[str, Sequence[str], None] = None
|
||||||
|
depends_on: Union[str, Sequence[str], None] = None
|
||||||
|
|
||||||
|
|
||||||
|
def upgrade() -> None:
|
||||||
|
"""Создание всех таблиц согласно моделям."""
|
||||||
|
op.create_table(
|
||||||
|
'admins',
|
||||||
|
sa.Column('id', sa.Integer(), primary_key=True),
|
||||||
|
sa.Column('tg_id', sa.Integer(), unique=True, nullable=False),
|
||||||
|
)
|
||||||
|
op.create_table(
|
||||||
|
'channels',
|
||||||
|
sa.Column('id', sa.Integer(), primary_key=True),
|
||||||
|
sa.Column('name', sa.String, nullable=True),
|
||||||
|
sa.Column('link', sa.String, nullable=True),
|
||||||
|
sa.Column('admin_id', sa.Integer(), sa.ForeignKey('admins.id'), nullable=True),
|
||||||
|
)
|
||||||
|
op.create_table(
|
||||||
|
'groups',
|
||||||
|
sa.Column('id', sa.Integer(), primary_key=True),
|
||||||
|
sa.Column('name', sa.String, nullable=False),
|
||||||
|
sa.Column('link', sa.String, nullable=False),
|
||||||
|
sa.Column('admin_id', sa.Integer(), sa.ForeignKey('admins.id'), nullable=True),
|
||||||
|
)
|
||||||
|
op.create_table(
|
||||||
|
'buttons',
|
||||||
|
sa.Column('id', sa.Integer(), primary_key=True),
|
||||||
|
sa.Column('name', sa.String, nullable=False),
|
||||||
|
sa.Column('url', sa.String, nullable=False),
|
||||||
|
sa.Column('channel_id', sa.Integer(), sa.ForeignKey('channels.id'), nullable=True),
|
||||||
|
sa.Column('group_id', sa.Integer(), sa.ForeignKey('groups.id'), nullable=True),
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade() -> None:
|
||||||
|
"""Удаление всех таблиц."""
|
||||||
|
op.drop_table('buttons')
|
||||||
|
op.drop_table('groups')
|
||||||
|
op.drop_table('channels')
|
||||||
|
op.drop_table('admins')
|
||||||
@@ -1,6 +1,16 @@
|
|||||||
#!/bin/bash
|
#!/bin/bash
|
||||||
set -e
|
set -e
|
||||||
|
|
||||||
|
echo "[update.sh] Проверка bot.db..."
|
||||||
|
if [ -d "bot.db" ]; then
|
||||||
|
echo "Удаляю папку bot.db..."
|
||||||
|
rm -rf bot.db
|
||||||
|
fi
|
||||||
|
if [ ! -f "bot.db" ]; then
|
||||||
|
echo "Создаю пустой файл bot.db..."
|
||||||
|
touch bot.db
|
||||||
|
fi
|
||||||
|
|
||||||
echo "[update.sh] Получение свежего кода..."
|
echo "[update.sh] Получение свежего кода..."
|
||||||
git pull
|
git pull
|
||||||
|
|
||||||
|
|||||||
9
db.py
9
db.py
@@ -10,13 +10,12 @@ DATABASE_URL = os.getenv("DATABASE_URL", "sqlite+aiosqlite:///bot.db")
|
|||||||
if DATABASE_URL.startswith("sqlite+aiosqlite:///"):
|
if DATABASE_URL.startswith("sqlite+aiosqlite:///"):
|
||||||
db_path = DATABASE_URL.replace("sqlite+aiosqlite:///", "")
|
db_path = DATABASE_URL.replace("sqlite+aiosqlite:///", "")
|
||||||
abs_db_path = os.path.abspath(db_path)
|
abs_db_path = os.path.abspath(db_path)
|
||||||
# Проверяем, что путь содержит директорию
|
|
||||||
db_dir = os.path.dirname(abs_db_path)
|
db_dir = os.path.dirname(abs_db_path)
|
||||||
# Если путь содержит директорию, создаём её
|
# Создаём директорию только если она не равна текущей ('.') и не пустая
|
||||||
if db_dir and db_dir != os.path.abspath("") and not os.path.exists(db_dir):
|
if db_dir and db_dir != os.path.abspath("") and db_dir != '.' and not os.path.exists(db_dir):
|
||||||
os.makedirs(db_dir, exist_ok=True)
|
os.makedirs(db_dir, exist_ok=True)
|
||||||
# Если по этому пути уже есть папка, удаляем её и создаём файл
|
# Если по этому пути уже есть папка, удаляем её
|
||||||
if os.path.isdir(abs_db_path):
|
if os.path.exists(abs_db_path) and os.path.isdir(abs_db_path):
|
||||||
import shutil
|
import shutil
|
||||||
shutil.rmtree(abs_db_path)
|
shutil.rmtree(abs_db_path)
|
||||||
# Если файла нет, создаём пустой файл
|
# Если файла нет, создаём пустой файл
|
||||||
|
|||||||
@@ -12,13 +12,15 @@ class Channel(Base):
|
|||||||
id = Column(Integer, primary_key=True)
|
id = Column(Integer, primary_key=True)
|
||||||
name = Column(String)
|
name = Column(String)
|
||||||
link = Column(String)
|
link = Column(String)
|
||||||
admin_id = Column(Integer, ForeignKey('admins.id')) # если есть таблица admins
|
admin_id = Column(Integer, ForeignKey('admins.id'))
|
||||||
|
buttons = relationship('Button', back_populates='channel')
|
||||||
|
|
||||||
class Group(Base):
|
class Group(Base):
|
||||||
__tablename__ = 'groups'
|
__tablename__ = 'groups'
|
||||||
id = Column(Integer, primary_key=True)
|
id = Column(Integer, primary_key=True)
|
||||||
name = Column(String, nullable=False)
|
name = Column(String, nullable=False)
|
||||||
link = Column(String, nullable=False)
|
link = Column(String, nullable=False)
|
||||||
|
admin_id = Column(Integer, ForeignKey('admins.id'))
|
||||||
buttons = relationship('Button', back_populates='group')
|
buttons = relationship('Button', back_populates='group')
|
||||||
|
|
||||||
class Button(Base):
|
class Button(Base):
|
||||||
|
|||||||
Reference in New Issue
Block a user