This commit is contained in:
17
.gitea/workflows/deploy.yaml
Normal file
17
.gitea/workflows/deploy.yaml
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
name: Deploy Amap
|
||||||
|
on:
|
||||||
|
push:
|
||||||
|
branches:
|
||||||
|
- main
|
||||||
|
workflow_dispatch:
|
||||||
|
jobs:
|
||||||
|
deploy:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: Checkout repository
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
- name: Build & deploy
|
||||||
|
run: |
|
||||||
|
docker compose -f docker-compose.yaml up -d --build
|
||||||
|
docker compose -f docker-compose.yaml exec backend alembic upgrade head
|
||||||
@@ -18,6 +18,19 @@ hatch shell
|
|||||||
fastapi dev src/main.py
|
fastapi dev src/main.py
|
||||||
```
|
```
|
||||||
|
|
||||||
|
### Migration
|
||||||
|
This repository use `alembic` for migrations
|
||||||
|
|
||||||
|
On first installation copy the `alembic.ini.example` to `alembic.ini`
|
||||||
|
#### Create migration
|
||||||
|
```console
|
||||||
|
alembic revision --autogenerate -m "message"
|
||||||
|
```
|
||||||
|
#### Apply migration
|
||||||
|
```console
|
||||||
|
alembic upgrade head
|
||||||
|
```
|
||||||
|
|
||||||
## License
|
## License
|
||||||
|
|
||||||
`backend` is distributed under the terms of the [MIT](https://spdx.org/licenses/MIT.html) license.
|
`backend` is distributed under the terms of the [MIT](https://spdx.org/licenses/MIT.html) license.
|
||||||
|
|||||||
147
backend/alembic.ini
Normal file
147
backend/alembic.ini
Normal file
@@ -0,0 +1,147 @@
|
|||||||
|
# A generic, single database configuration.
|
||||||
|
|
||||||
|
[alembic]
|
||||||
|
# path to migration scripts.
|
||||||
|
# this is typically a path given in POSIX (e.g. forward slashes)
|
||||||
|
# format, relative to the token %(here)s which refers to the location of this
|
||||||
|
# ini file
|
||||||
|
script_location = %(here)s/alembic
|
||||||
|
|
||||||
|
# template used to generate migration file names; The default value is %%(rev)s_%%(slug)s
|
||||||
|
# Uncomment the line below if you want the files to be prepended with date and time
|
||||||
|
# see https://alembic.sqlalchemy.org/en/latest/tutorial.html#editing-the-ini-file
|
||||||
|
# for all available tokens
|
||||||
|
# file_template = %%(year)d_%%(month).2d_%%(day).2d_%%(hour).2d%%(minute).2d-%%(rev)s_%%(slug)s
|
||||||
|
# Or organize into date-based subdirectories (requires recursive_version_locations = true)
|
||||||
|
# file_template = %%(year)d/%%(month).2d/%%(day).2d_%%(hour).2d%%(minute).2d_%%(second).2d_%%(rev)s_%%(slug)s
|
||||||
|
|
||||||
|
# sys.path path, will be prepended to sys.path if present.
|
||||||
|
# defaults to the current working directory. for multiple paths, the path separator
|
||||||
|
# is defined by "path_separator" below.
|
||||||
|
prepend_sys_path = .
|
||||||
|
|
||||||
|
|
||||||
|
# timezone to use when rendering the date within the migration file
|
||||||
|
# as well as the filename.
|
||||||
|
# If specified, requires the tzdata library which can be installed by adding
|
||||||
|
# `alembic[tz]` to the pip requirements.
|
||||||
|
# string value is passed to ZoneInfo()
|
||||||
|
# leave blank for localtime
|
||||||
|
# timezone =
|
||||||
|
|
||||||
|
# max length of characters to apply to the "slug" field
|
||||||
|
# truncate_slug_length = 40
|
||||||
|
|
||||||
|
# set to 'true' to run the environment during
|
||||||
|
# the 'revision' command, regardless of autogenerate
|
||||||
|
# revision_environment = false
|
||||||
|
|
||||||
|
# set to 'true' to allow .pyc and .pyo files without
|
||||||
|
# a source .py file to be detected as revisions in the
|
||||||
|
# versions/ directory
|
||||||
|
# sourceless = false
|
||||||
|
|
||||||
|
# version location specification; This defaults
|
||||||
|
# to <script_location>/versions. When using multiple version
|
||||||
|
# directories, initial revisions must be specified with --version-path.
|
||||||
|
# The path separator used here should be the separator specified by "path_separator"
|
||||||
|
# below.
|
||||||
|
# version_locations = %(here)s/bar:%(here)s/bat:%(here)s/alembic/versions
|
||||||
|
|
||||||
|
# path_separator; This indicates what character is used to split lists of file
|
||||||
|
# paths, including version_locations and prepend_sys_path within configparser
|
||||||
|
# files such as alembic.ini.
|
||||||
|
# The default rendered in new alembic.ini files is "os", which uses os.pathsep
|
||||||
|
# to provide os-dependent path splitting.
|
||||||
|
#
|
||||||
|
# Note that in order to support legacy alembic.ini files, this default does NOT
|
||||||
|
# take place if path_separator is not present in alembic.ini. If this
|
||||||
|
# option is omitted entirely, fallback logic is as follows:
|
||||||
|
#
|
||||||
|
# 1. Parsing of the version_locations option falls back to using the legacy
|
||||||
|
# "version_path_separator" key, which if absent then falls back to the legacy
|
||||||
|
# behavior of splitting on spaces and/or commas.
|
||||||
|
# 2. Parsing of the prepend_sys_path option falls back to the legacy
|
||||||
|
# behavior of splitting on spaces, commas, or colons.
|
||||||
|
#
|
||||||
|
# Valid values for path_separator are:
|
||||||
|
#
|
||||||
|
# path_separator = :
|
||||||
|
# path_separator = ;
|
||||||
|
# path_separator = space
|
||||||
|
# path_separator = newline
|
||||||
|
#
|
||||||
|
# Use os.pathsep. Default configuration used for new projects.
|
||||||
|
path_separator = os
|
||||||
|
|
||||||
|
# set to 'true' to search source files recursively
|
||||||
|
# in each "version_locations" directory
|
||||||
|
# new in Alembic version 1.10
|
||||||
|
# recursive_version_locations = false
|
||||||
|
|
||||||
|
# the output encoding used when revision files
|
||||||
|
# are written from script.py.mako
|
||||||
|
# output_encoding = utf-8
|
||||||
|
|
||||||
|
# database URL. This is consumed by the user-maintained env.py script only.
|
||||||
|
# other means of configuring database URLs may be customized within the env.py
|
||||||
|
# file.
|
||||||
|
|
||||||
|
[post_write_hooks]
|
||||||
|
# post_write_hooks defines scripts or Python functions that are run
|
||||||
|
# on newly generated revision scripts. See the documentation for further
|
||||||
|
# detail and examples
|
||||||
|
|
||||||
|
# format using "black" - use the console_scripts runner, against the "black" entrypoint
|
||||||
|
# hooks = black
|
||||||
|
# black.type = console_scripts
|
||||||
|
# black.entrypoint = black
|
||||||
|
# black.options = -l 79 REVISION_SCRIPT_FILENAME
|
||||||
|
|
||||||
|
# lint with attempts to fix using "ruff" - use the module runner, against the "ruff" module
|
||||||
|
# hooks = ruff
|
||||||
|
# ruff.type = module
|
||||||
|
# ruff.module = ruff
|
||||||
|
# ruff.options = check --fix REVISION_SCRIPT_FILENAME
|
||||||
|
|
||||||
|
# Alternatively, use the exec runner to execute a binary found on your PATH
|
||||||
|
# hooks = ruff
|
||||||
|
# ruff.type = exec
|
||||||
|
# ruff.executable = ruff
|
||||||
|
# ruff.options = check --fix REVISION_SCRIPT_FILENAME
|
||||||
|
|
||||||
|
# Logging configuration. This is also consumed by the user-maintained
|
||||||
|
# env.py script only.
|
||||||
|
[loggers]
|
||||||
|
keys = root,sqlalchemy,alembic
|
||||||
|
|
||||||
|
[handlers]
|
||||||
|
keys = console
|
||||||
|
|
||||||
|
[formatters]
|
||||||
|
keys = generic
|
||||||
|
|
||||||
|
[logger_root]
|
||||||
|
level = WARNING
|
||||||
|
handlers = console
|
||||||
|
qualname =
|
||||||
|
|
||||||
|
[logger_sqlalchemy]
|
||||||
|
level = WARNING
|
||||||
|
handlers =
|
||||||
|
qualname = sqlalchemy.engine
|
||||||
|
|
||||||
|
[logger_alembic]
|
||||||
|
level = INFO
|
||||||
|
handlers =
|
||||||
|
qualname = alembic
|
||||||
|
|
||||||
|
[handler_console]
|
||||||
|
class = StreamHandler
|
||||||
|
args = (sys.stderr,)
|
||||||
|
level = NOTSET
|
||||||
|
formatter = generic
|
||||||
|
|
||||||
|
[formatter_generic]
|
||||||
|
format = %(levelname)-5.5s [%(name)s] %(message)s
|
||||||
|
datefmt = %H:%M:%S
|
||||||
1
backend/alembic/README
Normal file
1
backend/alembic/README
Normal file
@@ -0,0 +1 @@
|
|||||||
|
Generic single-database configuration.
|
||||||
81
backend/alembic/env.py
Normal file
81
backend/alembic/env.py
Normal file
@@ -0,0 +1,81 @@
|
|||||||
|
from logging.config import fileConfig
|
||||||
|
|
||||||
|
from sqlalchemy import engine_from_config
|
||||||
|
from sqlalchemy import pool
|
||||||
|
|
||||||
|
from alembic import context
|
||||||
|
|
||||||
|
from sqlmodel import SQLModel
|
||||||
|
from src.settings import settings
|
||||||
|
|
||||||
|
# this is the Alembic Config object, which provides
|
||||||
|
# access to the values within the .ini file in use.
|
||||||
|
config = context.config
|
||||||
|
|
||||||
|
# Interpret the config file for Python logging.
|
||||||
|
# This line sets up loggers basically.
|
||||||
|
if config.config_file_name is not None:
|
||||||
|
fileConfig(config.config_file_name)
|
||||||
|
|
||||||
|
# add your model's MetaData object here
|
||||||
|
# for 'autogenerate' support
|
||||||
|
# from myapp import mymodel
|
||||||
|
# target_metadata = mymodel.Base.metadata
|
||||||
|
target_metadata = SQLModel.metadata
|
||||||
|
|
||||||
|
# other values from the config, defined by the needs of env.py,
|
||||||
|
# can be acquired:
|
||||||
|
config.set_main_option("sqlalchemy.url", f'postgresql://{settings.db_user}:{settings.db_pass}@{settings.db_host}:5432/{settings.db_name}')
|
||||||
|
# ... etc.
|
||||||
|
|
||||||
|
|
||||||
|
def run_migrations_offline() -> None:
|
||||||
|
"""Run migrations in 'offline' mode.
|
||||||
|
|
||||||
|
This configures the context with just a URL
|
||||||
|
and not an Engine, though an Engine is acceptable
|
||||||
|
here as well. By skipping the Engine creation
|
||||||
|
we don't even need a DBAPI to be available.
|
||||||
|
|
||||||
|
Calls to context.execute() here emit the given string to the
|
||||||
|
script output.
|
||||||
|
|
||||||
|
"""
|
||||||
|
url = config.get_main_option("sqlalchemy.url")
|
||||||
|
context.configure(
|
||||||
|
url=url,
|
||||||
|
target_metadata=target_metadata,
|
||||||
|
literal_binds=True,
|
||||||
|
dialect_opts={"paramstyle": "named"},
|
||||||
|
)
|
||||||
|
|
||||||
|
with context.begin_transaction():
|
||||||
|
context.run_migrations()
|
||||||
|
|
||||||
|
|
||||||
|
def run_migrations_online() -> None:
|
||||||
|
"""Run migrations in 'online' mode.
|
||||||
|
|
||||||
|
In this scenario we need to create an Engine
|
||||||
|
and associate a connection with the context.
|
||||||
|
|
||||||
|
"""
|
||||||
|
connectable = engine_from_config(
|
||||||
|
config.get_section(config.config_ini_section, {}),
|
||||||
|
prefix="sqlalchemy.",
|
||||||
|
poolclass=pool.NullPool,
|
||||||
|
)
|
||||||
|
|
||||||
|
with connectable.connect() as connection:
|
||||||
|
context.configure(
|
||||||
|
connection=connection, target_metadata=target_metadata
|
||||||
|
)
|
||||||
|
|
||||||
|
with context.begin_transaction():
|
||||||
|
context.run_migrations()
|
||||||
|
|
||||||
|
|
||||||
|
if context.is_offline_mode():
|
||||||
|
run_migrations_offline()
|
||||||
|
else:
|
||||||
|
run_migrations_online()
|
||||||
29
backend/alembic/script.py.mako
Normal file
29
backend/alembic/script.py.mako
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
"""${message}
|
||||||
|
|
||||||
|
Revision ID: ${up_revision}
|
||||||
|
Revises: ${down_revision | comma,n}
|
||||||
|
Create Date: ${create_date}
|
||||||
|
|
||||||
|
"""
|
||||||
|
from typing import Sequence, Union
|
||||||
|
|
||||||
|
from alembic import op
|
||||||
|
import sqlalchemy as sa
|
||||||
|
${imports if imports else ""}
|
||||||
|
import sqlmodel.sql.sqltypes
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic.
|
||||||
|
revision: str = ${repr(up_revision)}
|
||||||
|
down_revision: Union[str, Sequence[str], None] = ${repr(down_revision)}
|
||||||
|
branch_labels: Union[str, Sequence[str], None] = ${repr(branch_labels)}
|
||||||
|
depends_on: Union[str, Sequence[str], None] = ${repr(depends_on)}
|
||||||
|
|
||||||
|
|
||||||
|
def upgrade() -> None:
|
||||||
|
"""Upgrade schema."""
|
||||||
|
${upgrades if upgrades else "pass"}
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade() -> None:
|
||||||
|
"""Downgrade schema."""
|
||||||
|
${downgrades if downgrades else "pass"}
|
||||||
155
backend/alembic/versions/370137544ee6_initial_repository.py
Normal file
155
backend/alembic/versions/370137544ee6_initial_repository.py
Normal file
@@ -0,0 +1,155 @@
|
|||||||
|
"""Initial repository
|
||||||
|
|
||||||
|
Revision ID: 370137544ee6
|
||||||
|
Revises:
|
||||||
|
Create Date: 2026-02-19 22:55:19.804879
|
||||||
|
|
||||||
|
"""
|
||||||
|
from typing import Sequence, Union
|
||||||
|
|
||||||
|
from alembic import op
|
||||||
|
import sqlalchemy as sa
|
||||||
|
from sqlalchemy.dialects import postgresql
|
||||||
|
import sqlmodel.sql.sqltypes
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic.
|
||||||
|
revision: str = '370137544ee6'
|
||||||
|
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! ###
|
||||||
|
op.drop_table('template')
|
||||||
|
op.drop_table('user')
|
||||||
|
op.drop_table('form')
|
||||||
|
op.drop_table('usercontracttypelink')
|
||||||
|
op.drop_table('shipment')
|
||||||
|
op.drop_table('cheque')
|
||||||
|
op.drop_table('productor')
|
||||||
|
op.drop_table('paymentmethod')
|
||||||
|
op.drop_table('contract')
|
||||||
|
op.drop_table('contractproduct')
|
||||||
|
op.drop_table('contracttype')
|
||||||
|
op.drop_table('product')
|
||||||
|
op.drop_table('shipmentproductlink')
|
||||||
|
# ### end Alembic commands ###
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade() -> None:
|
||||||
|
"""Downgrade schema."""
|
||||||
|
# ### commands auto generated by Alembic - please adjust! ###
|
||||||
|
op.create_table('shipmentproductlink',
|
||||||
|
sa.Column('shipment_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('product_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['product_id'], ['product.id'], name=op.f('shipmentproductlink_product_id_fkey')),
|
||||||
|
sa.ForeignKeyConstraint(['shipment_id'], ['shipment.id'], name=op.f('shipmentproductlink_shipment_id_fkey')),
|
||||||
|
sa.PrimaryKeyConstraint('shipment_id', 'product_id', name=op.f('shipmentproductlink_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('product',
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('unit', postgresql.ENUM('GRAMS', 'KILO', 'PIECE', name='unit'), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('price', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('price_kg', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('quantity', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('quantity_unit', sa.VARCHAR(), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('type', postgresql.ENUM('OCCASIONAL', 'RECCURENT', name='producttype'), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('productor_id', sa.INTEGER(), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['productor_id'], ['productor.id'], name=op.f('product_productor_id_fkey')),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('product_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('contracttype',
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('contracttype_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('contractproduct',
|
||||||
|
sa.Column('product_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('shipment_id', sa.INTEGER(), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('quantity', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.Column('contract_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['contract_id'], ['contract.id'], name=op.f('contractproduct_contract_id_fkey'), ondelete='CASCADE'),
|
||||||
|
sa.ForeignKeyConstraint(['product_id'], ['product.id'], name=op.f('contractproduct_product_id_fkey'), ondelete='CASCADE'),
|
||||||
|
sa.ForeignKeyConstraint(['shipment_id'], ['shipment.id'], name=op.f('contractproduct_shipment_id_fkey'), ondelete='CASCADE'),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('contractproduct_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('contract',
|
||||||
|
sa.Column('firstname', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('lastname', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('email', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('phone', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('payment_method', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('cheque_quantity', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.Column('form_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('file', postgresql.BYTEA(), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('total_price', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True),
|
||||||
|
sa.ForeignKeyConstraint(['form_id'], ['form.id'], name=op.f('contract_form_id_fkey'), ondelete='CASCADE'),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('contract_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('paymentmethod',
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('details', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.Column('productor_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['productor_id'], ['productor.id'], name=op.f('paymentmethod_productor_id_fkey'), ondelete='CASCADE'),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('paymentmethod_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('productor',
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('address', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('type', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('productor_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('cheque',
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('value', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.Column('contract_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['contract_id'], ['contract.id'], name=op.f('cheque_contract_id_fkey'), ondelete='CASCADE'),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('cheque_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('shipment',
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('date', sa.DATE(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('form_id', sa.INTEGER(), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['form_id'], ['form.id'], name=op.f('shipment_form_id_fkey'), ondelete='CASCADE'),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('shipment_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('usercontracttypelink',
|
||||||
|
sa.Column('user_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('contract_type_id', sa.INTEGER(), autoincrement=False, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['contract_type_id'], ['contracttype.id'], name=op.f('usercontracttypelink_contract_type_id_fkey')),
|
||||||
|
sa.ForeignKeyConstraint(['user_id'], ['user.id'], name=op.f('usercontracttypelink_user_id_fkey')),
|
||||||
|
sa.PrimaryKeyConstraint('user_id', 'contract_type_id', name=op.f('usercontracttypelink_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('form',
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('productor_id', sa.INTEGER(), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('referer_id', sa.INTEGER(), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('season', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('start', sa.DATE(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('end', sa.DATE(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('minimum_shipment_value', sa.DOUBLE_PRECISION(precision=53), autoincrement=False, nullable=True),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.ForeignKeyConstraint(['productor_id'], ['productor.id'], name=op.f('form_productor_id_fkey')),
|
||||||
|
sa.ForeignKeyConstraint(['referer_id'], ['user.id'], name=op.f('form_referer_id_fkey')),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('form_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('user',
|
||||||
|
sa.Column('name', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('email', sa.VARCHAR(), autoincrement=False, nullable=False),
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('user_pkey'))
|
||||||
|
)
|
||||||
|
op.create_table('template',
|
||||||
|
sa.Column('id', sa.INTEGER(), autoincrement=True, nullable=False),
|
||||||
|
sa.PrimaryKeyConstraint('id', name=op.f('template_pkey'))
|
||||||
|
)
|
||||||
|
# ### end Alembic commands ###
|
||||||
@@ -22,9 +22,7 @@ jwk_client = PyJWKClient(JWKS_URL)
|
|||||||
security = HTTPBearer()
|
security = HTTPBearer()
|
||||||
|
|
||||||
@router.get('/logout')
|
@router.get('/logout')
|
||||||
def logout(
|
def logout():
|
||||||
refresh_token: Annotated[str | None, Cookie()] = None,
|
|
||||||
):
|
|
||||||
params = {
|
params = {
|
||||||
'client_id': settings.keycloak_client_id,
|
'client_id': settings.keycloak_client_id,
|
||||||
'post_logout_redirect_uri': settings.origins,
|
'post_logout_redirect_uri': settings.origins,
|
||||||
@@ -34,26 +32,20 @@ def logout(
|
|||||||
key='access_token',
|
key='access_token',
|
||||||
path='/',
|
path='/',
|
||||||
secure=not settings.debug,
|
secure=not settings.debug,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
)
|
)
|
||||||
response.delete_cookie(
|
response.delete_cookie(
|
||||||
key='refresh_token',
|
key='refresh_token',
|
||||||
path='/',
|
path='/',
|
||||||
secure=not settings.debug,
|
secure=not settings.debug,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
)
|
)
|
||||||
response.delete_cookie(
|
response.delete_cookie(
|
||||||
key='id_token',
|
key='id_token',
|
||||||
path='/',
|
path='/',
|
||||||
secure=not settings.debug,
|
secure=not settings.debug,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
)
|
)
|
||||||
# if refresh_token:
|
|
||||||
# requests.post(LOGOUT_URL, data={
|
|
||||||
# 'client_id': settings.keycloak_client_id,
|
|
||||||
# 'client_secret': settings.keycloak_client_secret,
|
|
||||||
# 'refresh_token': refresh_token
|
|
||||||
# })
|
|
||||||
return response
|
return response
|
||||||
|
|
||||||
|
|
||||||
@@ -127,7 +119,7 @@ def callback(code: str, session: Session = Depends(get_session)):
|
|||||||
value=token_data['access_token'],
|
value=token_data['access_token'],
|
||||||
httponly=True,
|
httponly=True,
|
||||||
secure=not settings.debug,
|
secure=not settings.debug,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
max_age=settings.max_age
|
max_age=settings.max_age
|
||||||
)
|
)
|
||||||
response.set_cookie(
|
response.set_cookie(
|
||||||
@@ -135,7 +127,7 @@ def callback(code: str, session: Session = Depends(get_session)):
|
|||||||
value=token_data['refresh_token'] or '',
|
value=token_data['refresh_token'] or '',
|
||||||
httponly=True,
|
httponly=True,
|
||||||
secure=not settings.debug,
|
secure=not settings.debug,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
max_age=30 * 24 * settings.max_age
|
max_age=30 * 24 * settings.max_age
|
||||||
)
|
)
|
||||||
response.set_cookie(
|
response.set_cookie(
|
||||||
@@ -143,7 +135,7 @@ def callback(code: str, session: Session = Depends(get_session)):
|
|||||||
value=token_data['id_token'],
|
value=token_data['id_token'],
|
||||||
httponly=True,
|
httponly=True,
|
||||||
secure=not settings.debug,
|
secure=not settings.debug,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
max_age=settings.max_age
|
max_age=settings.max_age
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -152,15 +144,15 @@ def callback(code: str, session: Session = Depends(get_session)):
|
|||||||
def verify_token(token: str):
|
def verify_token(token: str):
|
||||||
try:
|
try:
|
||||||
signing_key = jwk_client.get_signing_key_from_jwt(token)
|
signing_key = jwk_client.get_signing_key_from_jwt(token)
|
||||||
decoded = jwt.decode(token, options={'verify_signature': False})
|
decoded = jwt.decode(
|
||||||
payload = jwt.decode(
|
|
||||||
token,
|
token,
|
||||||
signing_key.key,
|
signing_key.key,
|
||||||
algorithms=['RS256'],
|
algorithms=['RS256'],
|
||||||
audience=settings.keycloak_client_id,
|
audience=settings.keycloak_client_id,
|
||||||
issuer=ISSUER,
|
issuer=ISSUER,
|
||||||
|
leeway=60,
|
||||||
)
|
)
|
||||||
return payload
|
return decoded
|
||||||
except jwt.ExpiredSignatureError:
|
except jwt.ExpiredSignatureError:
|
||||||
raise HTTPException(status_code=401, detail=messages.tokenexipired)
|
raise HTTPException(status_code=401, detail=messages.tokenexipired)
|
||||||
except jwt.InvalidTokenError:
|
except jwt.InvalidTokenError:
|
||||||
@@ -210,7 +202,7 @@ def refresh_token(refresh_token: Annotated[str | None, Cookie()] = None):
|
|||||||
value=token_data['access_token'],
|
value=token_data['access_token'],
|
||||||
httponly=True,
|
httponly=True,
|
||||||
secure=True if settings.debug == False else True,
|
secure=True if settings.debug == False else True,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
max_age=settings.max_age
|
max_age=settings.max_age
|
||||||
)
|
)
|
||||||
response.set_cookie(
|
response.set_cookie(
|
||||||
@@ -218,7 +210,7 @@ def refresh_token(refresh_token: Annotated[str | None, Cookie()] = None):
|
|||||||
value=token_data['refresh_token'] or '',
|
value=token_data['refresh_token'] or '',
|
||||||
httponly=True,
|
httponly=True,
|
||||||
secure=True if settings.debug == False else True,
|
secure=True if settings.debug == False else True,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
max_age=30 * 24 * settings.max_age
|
max_age=30 * 24 * settings.max_age
|
||||||
)
|
)
|
||||||
response.set_cookie(
|
response.set_cookie(
|
||||||
@@ -226,7 +218,7 @@ def refresh_token(refresh_token: Annotated[str | None, Cookie()] = None):
|
|||||||
value=token_data['id_token'],
|
value=token_data['id_token'],
|
||||||
httponly=True,
|
httponly=True,
|
||||||
secure=not settings.debug,
|
secure=not settings.debug,
|
||||||
samesite='lax',
|
samesite='strict',
|
||||||
max_age=settings.max_age
|
max_age=settings.max_age
|
||||||
)
|
)
|
||||||
return response
|
return response
|
||||||
|
|||||||
@@ -5,6 +5,8 @@ import html
|
|||||||
from weasyprint import HTML
|
from weasyprint import HTML
|
||||||
import io
|
import io
|
||||||
|
|
||||||
|
import pathlib
|
||||||
|
|
||||||
def generate_html_contract(
|
def generate_html_contract(
|
||||||
contract: models.Contract,
|
contract: models.Contract,
|
||||||
cheques: list[dict],
|
cheques: list[dict],
|
||||||
@@ -13,7 +15,7 @@ def generate_html_contract(
|
|||||||
recurrent_price: float,
|
recurrent_price: float,
|
||||||
total_price: float
|
total_price: float
|
||||||
):
|
):
|
||||||
template_dir = "./src/contracts/templates"
|
template_dir = pathlib.Path().resolve() + "/src/contracts/templates"
|
||||||
template_loader = jinja2.FileSystemLoader(searchpath=template_dir)
|
template_loader = jinja2.FileSystemLoader(searchpath=template_dir)
|
||||||
template_env = jinja2.Environment(loader=template_loader, autoescape=jinja2.select_autoescape(["html", "xml"]))
|
template_env = jinja2.Environment(loader=template_loader, autoescape=jinja2.select_autoescape(["html", "xml"]))
|
||||||
template_file = "layout.html"
|
template_file = "layout.html"
|
||||||
@@ -57,7 +59,8 @@ def generate_html_contract(
|
|||||||
|
|
||||||
return HTML(
|
return HTML(
|
||||||
string=output_text,
|
string=output_text,
|
||||||
base_url=template_dir
|
base_url=template_dir,
|
||||||
|
**options
|
||||||
).write_pdf()
|
).write_pdf()
|
||||||
|
|
||||||
from odfdo import Document, Table, Row, Cell
|
from odfdo import Document, Table, Row, Cell
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ from src.users.users import router as users_router
|
|||||||
from src.auth.auth import router as auth_router
|
from src.auth.auth import router as auth_router
|
||||||
from src.shipments.shipments import router as shipment_router
|
from src.shipments.shipments import router as shipment_router
|
||||||
from src.settings import settings
|
from src.settings import settings
|
||||||
from src.database import engine
|
from src.database import engine, create_all_tables
|
||||||
|
|
||||||
app = FastAPI()
|
app = FastAPI()
|
||||||
|
|
||||||
@@ -37,4 +37,5 @@ app.include_router(users_router, prefix="/api")
|
|||||||
app.include_router(auth_router, prefix="/api")
|
app.include_router(auth_router, prefix="/api")
|
||||||
app.include_router(shipment_router, prefix="/api")
|
app.include_router(shipment_router, prefix="/api")
|
||||||
|
|
||||||
SQLModel.metadata.create_all(engine)
|
if settings.debug == True:
|
||||||
|
create_all_tables()
|
||||||
@@ -12,7 +12,6 @@ class Settings(BaseSettings):
|
|||||||
keycloak_client_id: str
|
keycloak_client_id: str
|
||||||
keycloak_client_secret: str
|
keycloak_client_secret: str
|
||||||
keycloak_redirect_uri: str
|
keycloak_redirect_uri: str
|
||||||
vite_api_url: str
|
|
||||||
max_age: int
|
max_age: int
|
||||||
debug: bool
|
debug: bool
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"version": "1",
|
"version": "1",
|
||||||
"name": "amapcontract",
|
"name": "bruno",
|
||||||
"type": "collection",
|
"type": "collection",
|
||||||
"ignore": [
|
"ignore": [
|
||||||
"node_modules",
|
"node_modules",
|
||||||
55
docker-compose.dev.yaml
Normal file
55
docker-compose.dev.yaml
Normal file
@@ -0,0 +1,55 @@
|
|||||||
|
services:
|
||||||
|
frontend:
|
||||||
|
build:
|
||||||
|
context: .
|
||||||
|
dockerfile: frontend/Dockerfile.dev
|
||||||
|
volumes:
|
||||||
|
- ./frontend:/app
|
||||||
|
- /app/node_modules
|
||||||
|
environment:
|
||||||
|
VITE_API_URL: ${VITE_API_URL}
|
||||||
|
ports:
|
||||||
|
- "5173:5173"
|
||||||
|
depends_on:
|
||||||
|
- backend
|
||||||
|
backend:
|
||||||
|
build:
|
||||||
|
context: .
|
||||||
|
dockerfile: backend/Dockerfile
|
||||||
|
volumes:
|
||||||
|
- ./backend:/code/app
|
||||||
|
command: >
|
||||||
|
sh -c "fastapi run app/src/main.py --reload --port 8000"
|
||||||
|
environment:
|
||||||
|
ORIGINS: ${ORIGINS}
|
||||||
|
DB_HOST: database
|
||||||
|
DB_USER: ${DB_USER}
|
||||||
|
DB_PASS: ${DB_PASS}
|
||||||
|
DB_NAME: ${DB_NAME}
|
||||||
|
SECRET_KEY: ${SECRET_KEY}
|
||||||
|
KEYCLOAK_SERVER: ${KEYCLOAK_SERVER}
|
||||||
|
KEYCLOAK_REALM: ${KEYCLOAK_REALM}
|
||||||
|
KEYCLOAK_CLIENT_ID: ${KEYCLOAK_CLIENT_ID}
|
||||||
|
KEYCLOAK_CLIENT_SECRET: ${KEYCLOAK_CLIENT_SECRET}
|
||||||
|
KEYCLOAK_REDIRECT_URI: ${KEYCLOAK_REDIRECT_URI}
|
||||||
|
DEBUG: ${DEBUG}
|
||||||
|
MAX_AGE: ${MAX_AGE}
|
||||||
|
ports:
|
||||||
|
- "8000:8000"
|
||||||
|
depends_on:
|
||||||
|
- database
|
||||||
|
|
||||||
|
database:
|
||||||
|
image: postgres
|
||||||
|
restart: always
|
||||||
|
shm_size: 128mb
|
||||||
|
volumes:
|
||||||
|
- db:/var/lib/postgresql
|
||||||
|
environment:
|
||||||
|
POSTGRES_USER: ${DB_USER}
|
||||||
|
POSTGRES_PASSWORD: ${DB_PASS}
|
||||||
|
POSTGRES_DB: ${DB_NAME}
|
||||||
|
ports:
|
||||||
|
- 5432:5432
|
||||||
|
volumes:
|
||||||
|
db:
|
||||||
@@ -9,8 +9,8 @@ services:
|
|||||||
ports:
|
ports:
|
||||||
- 80:80
|
- 80:80
|
||||||
depends_on:
|
depends_on:
|
||||||
- back
|
- backend
|
||||||
back:
|
backend:
|
||||||
build:
|
build:
|
||||||
context: .
|
context: .
|
||||||
dockerfile: backend/Dockerfile
|
dockerfile: backend/Dockerfile
|
||||||
@@ -22,7 +22,6 @@ services:
|
|||||||
DB_PASS: ${DB_PASS}
|
DB_PASS: ${DB_PASS}
|
||||||
DB_NAME: ${DB_NAME}
|
DB_NAME: ${DB_NAME}
|
||||||
SECRET_KEY: ${SECRET_KEY}
|
SECRET_KEY: ${SECRET_KEY}
|
||||||
VITE_API_URL: ${VITE_API_URL}
|
|
||||||
KEYCLOAK_SERVER: ${KEYCLOAK_SERVER}
|
KEYCLOAK_SERVER: ${KEYCLOAK_SERVER}
|
||||||
KEYCLOAK_REALM: ${KEYCLOAK_REALM}
|
KEYCLOAK_REALM: ${KEYCLOAK_REALM}
|
||||||
KEYCLOAK_CLIENT_ID: ${KEYCLOAK_CLIENT_ID}
|
KEYCLOAK_CLIENT_ID: ${KEYCLOAK_CLIENT_ID}
|
||||||
@@ -42,5 +41,7 @@ services:
|
|||||||
POSTGRES_USER: ${DB_USER}
|
POSTGRES_USER: ${DB_USER}
|
||||||
POSTGRES_PASSWORD: ${DB_PASS}
|
POSTGRES_PASSWORD: ${DB_PASS}
|
||||||
POSTGRES_DB: ${DB_NAME}
|
POSTGRES_DB: ${DB_NAME}
|
||||||
|
ports:
|
||||||
|
- 5432:5432
|
||||||
volumes:
|
volumes:
|
||||||
db:
|
db:
|
||||||
12
frontend/Dockerfile.dev
Normal file
12
frontend/Dockerfile.dev
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
FROM node:20 AS dev
|
||||||
|
|
||||||
|
WORKDIR /app
|
||||||
|
|
||||||
|
COPY frontend/package.json ./
|
||||||
|
COPY frontend/package-lock.json ./
|
||||||
|
|
||||||
|
RUN npm install
|
||||||
|
|
||||||
|
COPY frontend .
|
||||||
|
|
||||||
|
CMD ["npm", "run", "dev", "--", "--host"]
|
||||||
Reference in New Issue
Block a user