Compare commits
6 Commits
0365659d55
...
v2
| Author | SHA1 | Date | |
|---|---|---|---|
| 7254175cdb | |||
| a0cbdd5358 | |||
| 05990bf36e | |||
| f1d782bb74 | |||
| 908aff8b3d | |||
| 4ea540021a |
@@ -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')
|
||||
10
bin/update.sh
Executable file → Normal file
10
bin/update.sh
Executable file → Normal file
@@ -1,6 +1,16 @@
|
||||
#!/bin/bash
|
||||
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] Получение свежего кода..."
|
||||
git pull
|
||||
|
||||
|
||||
10
db.py
10
db.py
@@ -9,15 +9,13 @@ DATABASE_URL = os.getenv("DATABASE_URL", "sqlite+aiosqlite:///bot.db")
|
||||
|
||||
if DATABASE_URL.startswith("sqlite+aiosqlite:///"):
|
||||
db_path = DATABASE_URL.replace("sqlite+aiosqlite:///", "")
|
||||
# Убираем лишний слэш в конце, если есть
|
||||
if db_path.endswith(os.sep):
|
||||
db_path = db_path.rstrip(os.sep)
|
||||
abs_db_path = os.path.abspath(db_path)
|
||||
db_dir = os.path.dirname(abs_db_path)
|
||||
if db_dir 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)
|
||||
# Если по этому пути уже есть папка, удаляем её и создаём файл
|
||||
if os.path.isdir(abs_db_path):
|
||||
# Если по этому пути уже есть папка, удаляем её
|
||||
if os.path.exists(abs_db_path) and os.path.isdir(abs_db_path):
|
||||
import shutil
|
||||
shutil.rmtree(abs_db_path)
|
||||
# Если файла нет, создаём пустой файл
|
||||
|
||||
@@ -12,13 +12,15 @@ class Channel(Base):
|
||||
id = Column(Integer, primary_key=True)
|
||||
name = 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):
|
||||
__tablename__ = 'groups'
|
||||
id = Column(Integer, primary_key=True)
|
||||
name = Column(String, nullable=False)
|
||||
link = Column(String, nullable=False)
|
||||
admin_id = Column(Integer, ForeignKey('admins.id'))
|
||||
buttons = relationship('Button', back_populates='group')
|
||||
|
||||
class Button(Base):
|
||||
|
||||
Reference in New Issue
Block a user