Sprint 2: Consolida as 3 semanas de sprint

.env.example

@@ -4,7 +4,8 @@ PROJECT_VERSION=1.0.0
 
 ENVIRONMENT=development
 
-FRONTEND_URL=http://syncdesk.pro
+WEB_FRONTEND_URL=http://localhost:3000
+MOBILE_FRONTEND_URL=syncdesk://
 
 # CORS settings
 CORS_ALLOW_ORIGINS=["https://app.example.com","http://localhost:3000"]
@@ -20,8 +21,8 @@ POSTGRES_HOST=localhost
 POSTGRES_PORT=5432
 
 # Configurações do MongoDB
-MONGO_INITDB_ROOT_USERNAME=mongouser # option to be used with docker compose
-MONGO_INITDB_ROOT_PASSWORD=mongopassword # to be used with docker compose
+MONGO_INITDB_ROOT_USERNAME=mongouser
+MONGO_INITDB_ROOT_PASSWORD=mongopassword
 MONGO_USER=mongouser
 MONGO_PASSWORD=mongopassword
 MONGO_HOST=localhost

.github/workflows/deploy-staging.yaml

@@ -0,0 +1,65 @@
+name: Deploy Staging
+on:
+  push:
+    branches: [ "develop" ]
+
+env:
+  REGISTRY: ghcr.io
+  IMAGE_NAME: titus-system/syncdesk-api
+
+jobs:
+  build-and-push:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      packages: write
+
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Log in to the Container registry
+        uses: docker/login-action@v3
+        with:
+          registry: ${{ env.REGISTRY }}
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Build and push Docker image
+        uses: docker/build-push-action@v5
+        with:
+          context: .
+          file: deploy/Dockerfile
+          push: true
+          tags: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:staging
+
+  deploy:
+    needs: build-and-push
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      packages: read
+
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Copy compose files to Droplet
+        uses: appleboy/scp-action@v0.1.7
+        with:
+          host: ${{ secrets.DROPLET_HOST }}
+          username: ${{ secrets.SSH_USERNAME }}
+          key: ${{ secrets.SSH_PRIVATE_KEY }}
+          target: /opt/syncdesk
+          source: docker-compose.yaml,deploy/docker-compose.staging.yaml,deploy/prometheus,deploy/alertmanager,deploy/loki,deploy/promtail,deploy/grafana
+
+      - name: Deploy to Droplet
+        uses: appleboy/ssh-action@v1.0.3
+        with:
+          host: ${{ secrets.DROPLET_HOST }}
+          username: ${{ secrets.SSH_USERNAME }}
+          key: ${{ secrets.SSH_PRIVATE_KEY }}
+          script: |
+            cd /opt/syncdesk
+            docker compose -f docker-compose.yaml -f deploy/docker-compose.staging.yaml pull api
+            docker compose -f docker-compose.yaml -f deploy/docker-compose.staging.yaml up -d --force-recreate

Makefile

@@ -1,4 +1,5 @@
-.PHONY: install run dev lint format typecheck test seed migrate makemigration pre-commit
+.PHONY: install run dev lint format typecheck test seed migrate makemigration pre-commit up down logs
+
 
 install:
 	poetry install
@@ -41,3 +42,12 @@ pre-commit:
 	poetry run mypy app/
 	poetry run bandit -c pyproject.toml -r app/
 	poetry run pytest
+
+up:
+	docker compose up --build
+
+down:
+	docker compose down
+
+logs:
+	docker compose logs -f

alembic/env.py

@@ -8,6 +8,9 @@
 from app.db.postgres.base import Base
 
 import app.domains.auth.models  # noqa: F401 — register models with Base.metadata
+import app.domains.companies.models  # noqa: F401 — register models with Base.metadata
+import app.domains.products.models  # noqa: F401 — register models with Base.metadata
+import app.domains.notifications.models  # noqa: F401 — register models with Base.metadata
 
 config = context.config
 if config.config_file_name is not None:

alembic/versions/14eee043999d_adds_email_outbox.py

@@ -0,0 +1,54 @@
+"""adds_email_outbox
+
+Revision ID: 14eee043999d
+Revises: 337ea87962d5
+Create Date: 2026-04-30 07:22:32.475373
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision: str = '14eee043999d'
+down_revision: Union[str, Sequence[str], None] = '337ea87962d5'
+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! ###
+    op.create_table('email_outbox',
+    sa.Column('id', sa.UUID(), nullable=False),
+    sa.Column('event_type', sa.String(length=64), nullable=False),
+    sa.Column('recipient', sa.String(length=320), nullable=False),
+    sa.Column('payload', postgresql.JSONB(astext_type=sa.Text()), nullable=False),
+    sa.Column('status', sa.Enum('PENDING', 'PROCESSING', 'SENT', 'RETRY', 'DEAD', name='email_outbox_status'), nullable=False),
+    sa.Column('attempts', sa.Integer(), nullable=False),
+    sa.Column('max_attempts', sa.Integer(), nullable=False),
+    sa.Column('last_error', sa.Text(), nullable=True),
+    sa.Column('next_attempt_at', sa.DateTime(), server_default=sa.text('now()'), nullable=False),
+    sa.Column('created_at', sa.DateTime(), server_default=sa.text('now()'), nullable=False),
+    sa.Column('updated_at', sa.DateTime(), server_default=sa.text('now()'), nullable=False),
+    sa.Column('sent_at', sa.DateTime(), nullable=True),
+    sa.Column('locked_at', sa.DateTime(), nullable=True),
+    sa.Column('lock_owner', sa.String(length=128), nullable=True),
+    sa.PrimaryKeyConstraint('id', name=op.f('pk_email_outbox'))
+    )
+    op.create_index('ix_email_outbox_event_type', 'email_outbox', ['event_type'], unique=False)
+    op.create_index('ix_email_outbox_recipient', 'email_outbox', ['recipient'], unique=False)
+    op.create_index('ix_email_outbox_status_next_attempt_at', 'email_outbox', ['status', 'next_attempt_at'], unique=False)
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_index('ix_email_outbox_status_next_attempt_at', table_name='email_outbox')
+    op.drop_index('ix_email_outbox_recipient', table_name='email_outbox')
+    op.drop_index('ix_email_outbox_event_type', table_name='email_outbox')
+    op.drop_table('email_outbox')
+    # ### end Alembic commands ###

alembic/versions/337ea87962d5_add_company_product.py

@@ -0,0 +1,71 @@
+"""add_company_product
+
+Revision ID: 337ea87962d5
+Revises: 55fb7ad5d992
+Create Date: 2026-04-15 23:07:17.118432
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = '337ea87962d5'
+down_revision: Union[str, Sequence[str], None] = '55fb7ad5d992'
+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! ###
+    op.create_table('companies',
+    sa.Column('id', sa.UUID(), nullable=False),
+    sa.Column('legal_name', sa.String(length=255), nullable=False),
+    sa.Column('trade_name', sa.String(length=255), nullable=True),
+    sa.Column('tax_id', sa.String(length=14), nullable=False),
+    sa.Column('created_at', sa.DateTime(), server_default=sa.text('now()'), nullable=False),
+    sa.Column('deleted_at', sa.DateTime(), nullable=True),
+    sa.PrimaryKeyConstraint('id', name=op.f('pk_companies'))
+    )
+    op.create_index(op.f('ix_companies_legal_name'), 'companies', ['legal_name'], unique=True)
+    op.create_index(op.f('ix_companies_tax_id'), 'companies', ['tax_id'], unique=True)
+    op.create_index(op.f('ix_companies_trade_name'), 'companies', ['trade_name'], unique=False)
+    op.create_table('products',
+    sa.Column('id', sa.Integer(), nullable=False),
+    sa.Column('name', sa.String(length=127), nullable=False),
+    sa.Column('description', sa.String(length=500), nullable=True),
+    sa.Column('created_at', sa.DateTime(), server_default=sa.text('now()'), nullable=False),
+    sa.Column('deleted_at', sa.DateTime(), nullable=True),
+    sa.PrimaryKeyConstraint('id', name=op.f('pk_products'))
+    )
+    op.create_table('company_products',
+    sa.Column('company_id', sa.UUID(), nullable=False),
+    sa.Column('product_id', sa.Integer(), nullable=False),
+    sa.Column('bought_at', sa.DateTime(), server_default=sa.text('now()'), nullable=False),
+    sa.Column('support_until', sa.DateTime(), nullable=False),
+    sa.ForeignKeyConstraint(['company_id'], ['companies.id'], name=op.f('fk_company_products_company_id_companies')),
+    sa.ForeignKeyConstraint(['product_id'], ['products.id'], name=op.f('fk_company_products_product_id_products')),
+    sa.PrimaryKeyConstraint('company_id', 'product_id', name=op.f('pk_company_products'))
+    )
+    op.add_column('users', sa.Column('company_id', sa.UUID(), nullable=True))
+    op.create_index(op.f('ix_users_company_id'), 'users', ['company_id'], unique=False)
+    op.create_foreign_key(op.f('fk_users_company_id_companies'), 'users', 'companies', ['company_id'], ['id'])
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_constraint(op.f('fk_users_company_id_companies'), 'users', type_='foreignkey')
+    op.drop_index(op.f('ix_users_company_id'), table_name='users')
+    op.drop_column('users', 'company_id')
+    op.drop_table('company_products')
+    op.drop_table('products')
+    op.drop_index(op.f('ix_companies_trade_name'), table_name='companies')
+    op.drop_index(op.f('ix_companies_tax_id'), table_name='companies')
+    op.drop_index(op.f('ix_companies_legal_name'), table_name='companies')
+    op.drop_table('companies')
+    # ### end Alembic commands ###

app/api/api_router.py

@@ -7,11 +7,13 @@
 from app.core.config import get_settings
 from app.core.dependencies import ResponseFactoryDep
 from app.domains.auth import auth_router, permission_router, role_router, user_router
+from app.domains.companies import company_router
 from app.domains.live_chat import chat_router, conversation_router
-from app.domains.ticket import ticket_router
+from app.domains.products import product_router
+from app.domains.ticket.routers import ticket_router
 from app.schemas.response import ErrorContent, GenericSuccessContent
 
-from app.domains.chatbot.routers import router as chatbot_router
+from app.domains.chatbot import chatbot_router
 
 api_router = APIRouter()
 
@@ -51,4 +53,7 @@ async def root(response_factory: ResponseFactoryDep, request: Request) -> JSONRe
 
 api_router.include_router(ticket_router, prefix="/tickets", tags=["Tickets"])
 
-api_router.include_router(chatbot_router)
+api_router.include_router(chatbot_router, prefix="/chatbot", tags=["Chatbot URA"])
+
+api_router.include_router(company_router, prefix="/companies", tags=["Companies"])
+api_router.include_router(product_router, prefix="/products", tags=["Products"])

app/core/background_tasks.py

@@ -6,5 +6,12 @@
 
 
 def global_background_tasks(pg_engine: AsyncEngine) -> list[asyncio.Task[None]]:
-    tasks: list[asyncio.Task[None]] = [asyncio.create_task(update_system_metrics(pg_engine))]
+    from app.core.dependencies import get_email_service
+    from app.domains.notifications.worker import run_email_outbox_worker
+
+    email_strategy = get_email_service()
+    tasks: list[asyncio.Task[None]] = [
+        asyncio.create_task(update_system_metrics(pg_engine)),
+        asyncio.create_task(run_email_outbox_worker(pg_engine, email_strategy)),
+    ]
     return tasks

app/core/config.py

@@ -19,8 +19,8 @@ def project_client_identifier(self) -> str:
 
     ENVIRONMENT: str = "development"
 
-    MOBILE_FRONTEND_URL: str = "syncdesk:/"
-    WEB_FRONTEND_URL: str = "http://localhost:3000"
+    MOBILE_FRONTEND_URL: str = "http://syncdesk.pro"
+    WEB_FRONTEND_URL: str = "http://syncdesk.pro"
 
     # CORS settings
     CORS_ALLOW_ORIGINS: list[str] = ["*"]
@@ -135,6 +135,14 @@ def invite_token_timedelta(self) -> timedelta:
     RUN_RESEND_INTEGRATION_TESTS: bool = False
     RESEND_TEST_TO_EMAIL: str = ""
 
+    # Email Outbox
+    EMAIL_OUTBOX_ENABLED: bool = True
+    EMAIL_OUTBOX_POLL_SECONDS: int = 5
+    EMAIL_OUTBOX_BATCH_SIZE: int = 50
+    EMAIL_OUTBOX_MAX_ATTEMPTS: int = 5
+    EMAIL_OUTBOX_BACKOFF_MAX_SECONDS: int = 900
+    EMAIL_OUTBOX_WORKER_ID: str = ""
+
     model_config = SettingsConfigDict(extra="allow", env_file=".env", env_file_encoding="utf-8")