Maintainers
-This module is part of the odoonix/education project on GitHub.
-You are welcome to contribute.
-
-
-
-
-
-
-
-
-
diff --git a/bookland/views/book_views.xml b/bookland/views/book_views.xml
deleted file mode 100644
index dc81963..0000000
--- a/bookland/views/book_views.xml
+++ /dev/null
@@ -1,87 +0,0 @@
-
-
-
-Book land a modern library management system
- -
این یک اپلیکشن برای مدیریت کتابخانههای دانشگاه است.
-در این نرم افزار شما امکانات متفاوتی خواهی داشت.
-Table of contents
-
-
--
-
- Changelog -
- نسخه ۱.۰.۰ -
- Bug Tracker -
- Credits
-
-
- Authors -
- Maintainers -
-
-
-Changelog
-
-
-نسخه ۱.۰.۰
-در این نسخه ساختار اولیه نرم افزار ایجاد شده و امکانات زیر ایجاد شده -است.
--
-
- TODO: -
-
-
-Bug Tracker
-Bugs are tracked on GitHub Issues. -In case of trouble, please check there if your issue has already been reported. -If you spotted it first, help us to smash it by providing a detailed and welcomed -feedback.
-Do not contact contributors directly about support or help with technical issues.
-
-
-
-
-
-
-
-
-
diff --git a/docker-compose.yml b/docker-compose.yml
new file mode 100644
index 0000000..2ef2bf5
--- /dev/null
+++ b/docker-compose.yml
@@ -0,0 +1,95 @@
+services:
+
+ # ---------- دیتابیس اختصاصی Odoo ----------
+ odoo-db:
+ image: postgres:15
+ container_name: odoo-db
+ environment:
+ POSTGRES_DB: postgres
+ POSTGRES_USER: odoo
+ POSTGRES_PASSWORD: odoo
+ volumes:
+ - odoo_db_data:/var/lib/postgresql/data
+ healthcheck:
+ test: ["CMD-SHELL", "pg_isready -U odoo"]
+ interval: 5s
+ timeout: 5s
+ retries: 10
+
+ # ---------- سرور Odoo ----------
+ odoo:
+ image: odoo:17
+ container_name: odoo
+ depends_on:
+ odoo-db:
+ condition: service_healthy
+ ports:
+ - "8069:8069"
+ environment:
+ HOST: odoo-db
+ USER: odoo
+ PASSWORD: odoo
+ volumes:
+ - odoo_web_data:/var/lib/odoo
+ - ./odoo/addons:/mnt/extra-addons
+ healthcheck:
+ test: ["CMD", "curl", "-f", "http://localhost:8069/web/login"]
+ interval: 10s
+ timeout: 5s
+ retries: 10
+ start_period: 30s
+
+ # ---------- دیتابیس اپلیکیشن Backend خودمون ----------
+ app-db:
+ image: postgres:15
+ container_name: app-db
+ environment:
+ POSTGRES_DB: syncdb
+ POSTGRES_USER: syncuser
+ POSTGRES_PASSWORD: syncpass
+ ports:
+ - "5433:5432"
+ volumes:
+ - app_db_data:/var/lib/postgresql/data
+ healthcheck:
+ test: ["CMD-SHELL", "pg_isready -U syncuser -d syncdb"]
+ interval: 5s
+ timeout: 5s
+ retries: 10
+
+ # ---------- برنامهی Backend پایتون ----------
+ app:
+ build:
+ context: .
+ dockerfile: Dockerfile.dev
+
+ container_name: sync-app
+
+ depends_on:
+ odoo:
+ condition: service_healthy
+ app-db:
+ condition: service_healthy
+
+ environment:
+ ODOO_URL: http://odoo:8069
+ ODOO_DB: ${ODOO_DB:-my_odoo_project}
+ ODOO_USERNAME: ${ODOO_USERNAME:-admin@gmail.com}
+ ODOO_PASSWORD: ${ODOO_PASSWORD:-Mohamad@77}
+
+ APP_DB_HOST: app-db
+ APP_DB_PORT: "5432"
+ APP_DB_NAME: syncdb
+ APP_DB_USER: syncuser
+ APP_DB_PASSWORD: syncpass
+
+ LOG_LEVEL: INFO
+ # کانتینر بعد از اجرای Migration زنده میمونه (طبق CMD تو Dockerfile).
+ # برای اجرای واقعی Sync، بعد از ساخت دستی دیتابیس Odoo (طبق
+ # USER_DOCUMENTATION) این دستور رو بزن:
+ # docker compose exec app python -m src.main
+
+volumes:
+ odoo_db_data:
+ odoo_web_data:
+ app_db_data:
diff --git a/docs/TECHNICAL_DOCUMENTATION.md b/docs/TECHNICAL_DOCUMENTATION.md
new file mode 100644
index 0000000..8e5aebf
--- /dev/null
+++ b/docs/TECHNICAL_DOCUMENTATION.md
@@ -0,0 +1,137 @@
+# Technical Documentation
+
+## معماری کلی
+
+```
+Odoo (XML-RPC)
+ │
+ ▼
+OdooClient (src/odoo_client/client.py)
+ │ raw dict
+ ▼
+Mapper (src/mappers/)
+ │ Domain Model (dataclass تمیز)
+ ▼
+Service Layer (src/services/)
+ │ orchestration + error handling + logging
+ ▼
+Repository (src/repositories/)
+ │ Upsert (Idempotent)
+ ▼
+PostgreSQL (src/db/models.py — SQLAlchemy ORM)
+```
+
+هر پیکان یک لایهی مجزاست که فقط با لایهی مجاور خودش کار میکنه. این
+Layered Architecture باعث میشه:
+- تغییر یک لایه (مثلاً عوضکردن Odoo با یه سیستم دیگه) بقیه رو خراب نکنه
+- هر لایه جدا و مستقل تست بشه (`tests/unit/`)
+
+## تصمیمات مهم معماری
+
+### ۱. چرا Repository Pattern؟
+Business Logic (Service Layer) نباید بدونه SQLAlchemy چطور کار میکنه.
+Repositoryها این جزئیات رو مخفی میکنن و یک API ساده (`upsert`,
+`get_by_odoo_id`) در اختیار Service Layer میذارن.
+
+### ۲. چطور Idempotency پیادهسازی شده؟
+هر جدولی که از Odoo میاد یک ستون `odoo_id` با `UNIQUE constraint` داره.
+`BaseRepository.upsert()` قبل از insert، با `odoo_id` جستجو میکنه:
+- پیدا شد → فیلدها رو آپدیت میکنه
+- پیدا نشد → رکورد جدید میسازه
+
+
+
+پس اجرای مکرر `python -m src.main` هیچوقت رکورد تکراری نمیسازه.
+
+
+
+### ۳. مدیریت خطا بدون متوقفکردن کل فرآیند
+از تکنیک **SAVEPOINT** (`session.begin_nested()`) استفاده شده. هر رکورد
+داخل یک SAVEPOINT پردازش میشه؛ اگه اون رکورد خطا بده، فقط تغییرات همون
+رکورد rollback میشه، نه کل Transaction. این یعنی رکورد ۱ و ۲ موفق میمونن
+حتی اگه رکورد ۳ خطا بده و رکورد ۴ و ۵ هم پردازش بشن — دقیقاً طبق سناریوی
+درخواستی.
+
+### ۴. چرا Retry فقط روی خطاهای شبکهای اعمال شده، نه همهچیز؟
+اگه پسورد Odoo غلط باشه، retry کردن ۳ باره فایدهای نداره (نتیجه همیشه یکیه).
+`src/core/retry.py` یک لیست `NON_RETRYABLE_EXCEPTIONS` داره
+(`ValueError`, `TypeError`, `KeyError`, `AttributeError`, `IndexError`,
+`KeyboardInterrupt`, `SystemExit`) که این خطاها **هیچوقت** retry نمیشن —
+حتی اگه صراحتاً تو پارامتر `exceptions` هم پاس داده بشن — چون اینها معمولاً
+یعنی باگ تو کد یا داده، نه یه مشکل موقتی شبکه. Retry فقط برای خطاهای واقعاً
+گذرا مثل `ConnectionError`, `OSError`, `TimeoutError` فعال شده، با
+Exponential Backoff (و یک سقف `max_delay` که تأخیر بینهایت زیاد نشه).
+
+### ۵. Dependency Injection
+`Session` و `OdooClient` همیشه از بیرون به Repository/Service تزریق میشن
+(نه اینکه خودشون بسازنش). این باعث میشه تو تستها بتونیم `OdooClient` رو با
+`unittest.mock.MagicMock` جایگزین کنیم و به Odoo واقعی وصل نشیم.
+
+## طراحی دیتابیس
+
+جدولهای اصلی: `contacts`, `products`, `sale_orders`, `sale_order_lines`
+
+روابط:
+- `sale_orders.customer_id` → FK به `contacts.id`
+- `sale_order_lines.sale_order_id` → FK به `sale_orders.id`
+- `sale_order_lines.product_id` → FK به `products.id`
+
+جدولهای Logging: `sync_runs` (خلاصهی هر اجرای Sync)، `sync_logs`
+(جزئیات هر خطا، وابسته به `sync_runs` با FK).
+
+هر ۴ جدول اصلی یک ستون `odoo_id` (UNIQUE) دارن که کلید Idempotency هستن.
+
+### ۶. چطور کل پروژه با `docker compose up` بالا میاد؟
+`Dockerfile` سرویس `app` رو میسازه که به Backend پایتون تبدیلش میکنه.
+پیشفرض این سرویس، فقط `alembic upgrade head` (ساخت جدولها) رو اجرا
+میکنه — چون ساخت دیتابیس Odoo (طبق سناریوی آزمون) یک قدم دستیه که باید
+از طریق مرورگر انجام بشه، و نمیتونیم مطمئن باشیم قبل از اولین
+`docker compose up` انجام شده یا نه. بعد از انجام اون قدم دستی، Sync واقعی
+با این دستور اجرا میشه:
+```
+docker compose run --rm app python -m src.main
+```
+تنظیمات شبکهای (`ODOO_URL=http://odoo:8069`, `APP_DB_HOST=app-db`) مستقیم
+تو `docker-compose.yml` (بخش `environment` سرویس `app`) ست شدن، چون این
+کانتینر داخل شبکهی داکر اجرا میشه و باید از اسم سرویسها استفاده کنه، نه
+`localhost`. مقادیر حساس (پسورد و ...) از فایل `.env` (که هیچوقت وارد
+Docker Image نمیشه، طبق `.dockerignore`) خونده و به Container تزریق میشه.
+
+### ۷. Incremental Sync
+`BaseSyncService.get_last_successful_sync_time()` زمان شروع آخرین اجرای
+موفق همون `operation_type` رو از جدول `sync_runs` پیدا میکنه. Serviceهای
+فرزند این زمان رو بهعنوان `since` به `OdooClient` پاس میدن، که فیلتر
+`write_date >= since` رو به کوئری Odoo اضافه میکنه. یعنی از دومین اجرا به
+بعد، فقط رکوردهایی که واقعاً تغییر کردن خونده میشن، نه کل جدول.
+
+### ۸. Graceful Shutdown
+وقتی `docker stop` یا Ctrl+C بزنی، سیگنال SIGTERM/SIGINT میاد. تو `main.py`
+این سیگنال به `KeyboardInterrupt` تبدیل میشه. `BaseSyncService.run()` این
+Exception رو جدا از خطاهای معمولی مدیریت میکنه: رکورد فعلی رو نیمهکاره
+رها نمیکنه (به لطف SAVEPOINT، رکوردهای قبلی که موفق بودن سالم میمونن)،
+وضعیت رو با `status="cancelled"` تو `sync_runs` ثبت میکنه، و بعد خارج
+میشه — بدون قفلشدن یا خرابی داده.
+
+## محدودیتهای شناختهشده
+
+- **Sync یکطرفه است**: فقط Odoo → PostgreSQL. تغییرات دستی مستقیم تو
+ PostgreSQL به Odoo برنمیگرده (خارج از Scope این پروژه بود).
+- **Delete پشتیبانی نمیشه**: اگه رکوردی تو Odoo حذف بشه، این Sync خودش
+ رو تو PostgreSQL حذف نمیکنه (فقط Create/Update). اضافهکردنش امکانپذیره
+ ولی نیاز به یک استراتژی جدا داره (مثلاً soft-delete بر اساس مقایسهی
+ لیست کامل odoo_idها).
+- **ساخت دیتابیس Odoo دستیه**: طبق سناریوی آزمون، این کار (ساخت دیتابیس از
+ طریق مرورگر، چون Odoo از قبل هیچ دیتابیسی نداره) یک قدم دستیه که با
+ `docker compose up` بهتنهایی خودکار نمیشه. به همین دلیل سرویس `app` تو
+ Docker پیشفرض فقط Migration رو اجرا میکنه، نه Sync کامل رو (جزئیات تو
+ User Documentation).
+- **Concurrency**: اگه دو نمونه از این برنامه همزمان اجرا بشن، ممکنه با
+ race condition روبهرو بشیم (چون بین `get_by_odoo_id` و `insert` قفلی
+ نیست). برای این پروژه (اجرای دستی/زمانبندیشدهی تکی) مشکلی ایجاد نمیکنه.
+- **تستها فقط Unit Test هستن**: به دلیل محدودیت زمانی، Integration Test
+ رسمی (که مستقیم به یک Odoo/Postgres واقعی وصل بشه و end-to-end تست کنه)
+ نوشته نشده؛ اسکریپتهای `scripts/test_*.py` این نقش رو بهصورت دستی ایفا
+ میکنن.
+- **Incremental Sync بر پایهی `write_date`**: اگه یک رکورد بین دو اجرای
+ Sync هم ساخته و هم حذف بشه (خیلی بهندرت پیش میاد)، ممکنه در حالت
+ Incremental دیده نشه. برای Full Sync این مشکل وجود نداره.
diff --git a/docs/USER_DOCUMENTATION.md b/docs/USER_DOCUMENTATION.md
new file mode 100644
index 0000000..0c57798
--- /dev/null
+++ b/docs/USER_DOCUMENTATION.md
@@ -0,0 +1,202 @@
+# User Documentation — راهنمای نصب و اجرا
+
+این راهنما فرض میکنه پروژه رو تازه Clone/Fork کردی و میخوای از صفر اجراش کنی.
+
+## پیشنیازها
+
+- Docker و Docker Compose
+- Python 3.11 یا بالاتر (فقط لازم داری اگه بخوای روش ۲ رو انجام بدی)
+
+این پروژه رو میشه به ۲ روش اجرا کرد:
+- **روش ۱ (پیشنهادی، طبق مستندات آزمون): کامل داخل Docker**
+- **روش ۲: دستی روی سیستم خودت** (برای توسعه/دیباگ راحتتر)
+
+---
+
+## روش ۱: اجرای کامل با Docker
+
+### مرحله ۱: بالا آوردن همهچیز
+
+```bash
+docker compose up -d
+```
+
+این دستور Odoo، دیتابیس اختصاصی Odoo، دیتابیس اپلیکیشن، و Backend پایتون
+(سرویس `app`، که بهمحض بالا اومدن `alembic upgrade head` رو خودکار اجرا
+میکنه) رو بالا میاره. با این دستور مطمئن شو `healthy` شدن:
+
+```bash
+docker compose ps
+```
+
+### مرحله ۲: ساخت دیتابیس در Odoo (یکبار، دستی)
+
+این تنها قدمیه که خودکار نیست (چون Odoo تازهنصبشده هیچ دیتابیسی نداره و
+ساختنش نیاز به وارد کردن دستی اطلاعات داره):
+
+1. برو به `http://localhost:8069`
+2. تو فرم "Create Database":
+ - Database Name: `sync_test`
+ - Email: هرچی دلت خواست
+ - Password: یه پسورد بذار و یادت بمونه
+ - تیک Demo Data رو بردار
+3. بعد از ساخت، از منوی **Apps** اپ **Sales** رو نصب کن.
+
+### مرحله ۳: فایل `.env` رو با پسورد واقعی پر کن
+
+```bash
+cp .env.example .env
+```
+
+`ODOO_PASSWORD` رو با پسوردی که تو مرحلهی ۲ ساختی جایگزین کن.
+`docker-compose.yml` این مقدار رو از همین فایل میخونه و به کانتینر `app`
+تزریق میکنه (بدون اینکه خود `.env` وارد Docker Image بشه).
+
+اگه `.env` رو بعد از `docker compose up` عوض کردی:
+```bash
+docker compose up -d app
+```
+
+### مرحله ۴: ساخت دادهی تستی در Odoo
+
+```bash
+docker compose run --rm app python odoo/init_data.py
+```
+
+### مرحله ۵: اجرای Sync
+
+```bash
+docker compose run --rm app python -m src.main
+```
+
+هر چندبار بخوای میتونی دوباره اجراش کنی — بهخاطر Idempotent Design، دادهی
+تکراری ساخته نمیشه.
+
+### مرحله ۶: اجرای تستها
+
+```bash
+docker compose run --rm app pytest -v
+```
+
+---
+
+## روش ۲: اجرای دستی روی سیستم خودت (برای توسعه)
+
+### مرحله ۱: بالا آوردن Odoo و PostgreSQL
+
+```bash
+docker compose up -d odoo odoo-db app-db
+```
+
+(سرویس `app` رو صدا نمیزنیم، چون خودمون دستی کد رو اجرا میکنیم)
+
+### مرحله ۲: ساخت دیتابیس در Odoo
+
+مثل روش ۱، از طریق `http://localhost:8069`.
+
+### مرحله ۳: تنظیم فایل `.env`
+
+```bash
+cp .env.example .env
+```
+
+مقادیر زیر رو با مقادیر واقعی خودت جایگزین کن:
+
+```
+ODOO_URL=http://localhost:8069
+ODOO_DB=sync_test
+ODOO_USERNAME=admin
+ODOO_PASSWORD=<پسوردی که تو مرحله ۲ ساختی>
+
+APP_DB_HOST=localhost
+APP_DB_PORT=5433
+```
+
+> **نکته:** چون اینبار کد رو مستقیم روی ویندوز/مک/لینوکس خودت اجرا
+> میکنی (نه داخل کانتینر)، همیشه از `localhost` استفاده کن، نه اسم
+> سرویسهای داکر مثل `odoo` یا `app-db` (آنها فقط از *داخل* شبکهی
+> داکر قابلشناساییند).
+
+### مرحله ۴: نصب پکیجهای پایتون
+
+```bash
+python -m venv .venv
+source .venv/bin/activate # ویندوز: .venv\Scripts\Activate.ps1
+pip install -r requirements.txt
+pip install -r requirements-dev.txt
+```
+
+### مرحله ۵: ساخت جدولهای PostgreSQL
+
+```bash
+alembic upgrade head
+```
+
+### مرحله ۶: ساخت دادهی تستی در Odoo
+
+```bash
+python odoo/init_data.py
+```
+
+این اسکریپت idempotent هست — اگه دوباره اجراش کنی، رکورد تکراری نمیسازه.
+
+### مرحله ۷: اجرای فرآیند Sync اصلی
+
+```bash
+python -m src.main
+```
+
+خروجی موفق:
+```
+========== نتیجهی Sync ==========
+contacts_sync | fetched= 3 created= 3 updated= 0 failed= 0 status=success
+products_sync | fetched= 3 created= 3 updated= 0 failed= 0 status=success
+sale_orders_sync | fetched= 3 created= 3 updated= 0 failed= 0 status=success
+sale_order_lines_sync | fetched= 5 created= 5 updated= 0 failed= 0 status=success
+===================================
+```
+
+میتونی این دستور رو چندبار اجرا کنی؛ بار دوم به بعد باید `created=0` و
+`updated>0` ببینی (یعنی رکورد تکراری ساخته نشده). از دومین اجرا به بعد،
+Sync بهشکل Incremental انجام میشه — یعنی فقط رکوردهایی که از آخرین Sync
+موفق به بعد تو Odoo تغییر کردن خونده میشن، نه کل جدول.
+
+لاگها همزمان تو Terminal، فایل `sync.log`، و جدولهای `sync_runs` /
+`sync_logs` داخل PostgreSQL ثبت میشن.
+
+### مرحله ۸: اجرای تستها
+
+```bash
+pytest -v
+```
+
+برای دیدن Test Coverage:
+```bash
+pytest --cov=src --cov-report=term-missing
+```
+
+---
+
+## بررسی مستقیم دادهها (اختیاری)
+
+```bash
+python -c "from src.db.session import get_session; from src.db.models import Contact; s = get_session(); print([c.name for c in s.query(Contact).all()])"
+```
+
+## تست Graceful Shutdown (اختیاری)
+
+وسط اجرای `python -m src.main` یه Ctrl+C بزن (یا اگه داخل Docker اجرا شده،
+`docker compose stop app` رو بزن). باید تو لاگ ببینی که پیام "سیگنال توقف
+دریافت شد" چاپ میشه و برنامه تمیز بسته میشه، بدون خرابی داده. اگه دوباره
+`sync_runs` رو چک کنی، یه ردیف با `status='cancelled'` میبینی.
+
+## اگه چیزی کار نکرد
+
+- **`ConnectionRefusedError`**: مطمئن شو `docker compose ps` نشون میده
+ `odoo` و `app-db` روشن و healthy هستن.
+- **خطای احراز هویت Odoo**: مقادیر `ODOO_USERNAME`/`ODOO_PASSWORD`/`ODOO_DB`
+ رو تو `.env` با چیزی که موقع ساخت دیتابیس (مرحله ۲) وارد کردی مقایسه کن.
+- **`could not translate host name`**: تو روش ۲ (اجرای دستی)، جایی تو
+ `.env` از اسم سرویس داکر (`odoo`, `app-db`) بهجای `localhost` استفاده
+ شده. تو روش ۱ (Docker)، این پیام عادی نیست و یعنی سرویس `app` هنوز به
+ شبکهی داکر وصل نشده — `docker compose ps` رو چک کن.
diff --git a/migrations/__pycache__/env.cpython-313.pyc b/migrations/__pycache__/env.cpython-313.pyc
new file mode 100644
index 0000000..a569008
Binary files /dev/null and b/migrations/__pycache__/env.cpython-313.pyc differ
diff --git a/migrations/env.py b/migrations/env.py
new file mode 100644
index 0000000..1162833
--- /dev/null
+++ b/migrations/env.py
@@ -0,0 +1,84 @@
+import sys
+from logging.config import fileConfig
+from pathlib import Path
+from sqlalchemy import engine_from_config
+from sqlalchemy import pool
+from alembic import context
+
+# اضافه کردن ریشهی پروژه به sys.path که بتونیم src رو import کنیم
+sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
+
+from src.config.settings import settings # noqa: E402
+from src.db.models import Base # noqa: E402
+
+# this is the Alembic Config object, which provides
+# access to the values within the .ini file in use.
+config = context.config
+
+# آدرس دیتابیس رو از settings.py میگیریم، نه از alembic.ini
+config.set_main_option("sqlalchemy.url", settings.database_url)
+
+# 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)
+
+# این خط باعث میشه Alembic بتونه خودش تشخیص بده جدولها چطور باید بسازه (autogenerate)
+target_metadata = Base.metadata
+
+# other values from the config, defined by the needs of env.py,
+# can be acquired:
+# my_important_option = config.get_main_option("my_important_option")
+# ... 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()
diff --git a/migrations/script.py.mako b/migrations/script.py.mako
new file mode 100644
index 0000000..1101630
--- /dev/null
+++ b/migrations/script.py.mako
@@ -0,0 +1,28 @@
+"""${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 ""}
+
+# 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"}
diff --git a/migrations/versions/8f898b04173e_create_initial_tables.py b/migrations/versions/8f898b04173e_create_initial_tables.py
new file mode 100644
index 0000000..945f960
--- /dev/null
+++ b/migrations/versions/8f898b04173e_create_initial_tables.py
@@ -0,0 +1,117 @@
+"""create initial tables
+
+Revision ID: 8f898b04173e
+Revises:
+Create Date: 2026-07-26 19:11:05.149073
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = '8f898b04173e'
+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.create_table('contacts',
+ sa.Column('id', sa.Integer(), nullable=False),
+ sa.Column('odoo_id', sa.Integer(), nullable=False),
+ sa.Column('name', sa.String(length=255), nullable=False),
+ sa.Column('email', sa.String(length=255), nullable=True),
+ sa.Column('phone', sa.String(length=50), nullable=True),
+ sa.Column('mobile', sa.String(length=50), nullable=True),
+ sa.Column('created_at', sa.DateTime(), nullable=True),
+ sa.Column('updated_at', sa.DateTime(), nullable=True),
+ sa.PrimaryKeyConstraint('id')
+ )
+ op.create_index(op.f('ix_contacts_odoo_id'), 'contacts', ['odoo_id'], unique=True)
+ op.create_table('products',
+ sa.Column('id', sa.Integer(), nullable=False),
+ sa.Column('odoo_id', sa.Integer(), nullable=False),
+ sa.Column('name', sa.String(length=255), nullable=False),
+ sa.Column('internal_reference', sa.String(length=100), nullable=True),
+ sa.Column('sale_price', sa.Float(), nullable=False),
+ sa.Column('product_type', sa.String(length=50), nullable=True),
+ sa.Column('created_at', sa.DateTime(), nullable=True),
+ sa.Column('updated_at', sa.DateTime(), nullable=True),
+ sa.PrimaryKeyConstraint('id')
+ )
+ op.create_index(op.f('ix_products_internal_reference'), 'products', ['internal_reference'], unique=False)
+ op.create_index(op.f('ix_products_odoo_id'), 'products', ['odoo_id'], unique=True)
+ op.create_table('sync_runs',
+ sa.Column('id', sa.Integer(), nullable=False),
+ sa.Column('operation_type', sa.String(length=100), nullable=False),
+ sa.Column('started_at', sa.DateTime(), nullable=False),
+ sa.Column('finished_at', sa.DateTime(), nullable=True),
+ sa.Column('status', sa.String(length=50), nullable=True),
+ sa.Column('records_fetched', sa.Integer(), nullable=True),
+ sa.Column('records_created', sa.Integer(), nullable=True),
+ sa.Column('records_updated', sa.Integer(), nullable=True),
+ sa.Column('records_failed', sa.Integer(), nullable=True),
+ sa.PrimaryKeyConstraint('id')
+ )
+ op.create_table('sale_orders',
+ sa.Column('id', sa.Integer(), nullable=False),
+ sa.Column('odoo_id', sa.Integer(), nullable=False),
+ sa.Column('order_number', sa.String(length=100), nullable=False),
+ sa.Column('customer_id', sa.Integer(), nullable=False),
+ sa.Column('order_date', sa.DateTime(), nullable=True),
+ sa.Column('state', sa.String(length=50), nullable=True),
+ sa.Column('total_amount', sa.Float(), nullable=False),
+ sa.Column('created_at', sa.DateTime(), nullable=True),
+ sa.Column('updated_at', sa.DateTime(), nullable=True),
+ sa.ForeignKeyConstraint(['customer_id'], ['contacts.id'], ),
+ sa.PrimaryKeyConstraint('id')
+ )
+ op.create_index(op.f('ix_sale_orders_odoo_id'), 'sale_orders', ['odoo_id'], unique=True)
+ op.create_table('sync_logs',
+ sa.Column('id', sa.Integer(), nullable=False),
+ sa.Column('sync_run_id', sa.Integer(), nullable=False),
+ sa.Column('level', sa.String(length=20), nullable=True),
+ sa.Column('message', sa.Text(), nullable=False),
+ sa.Column('record_reference', sa.String(length=255), nullable=True),
+ sa.Column('created_at', sa.DateTime(), nullable=True),
+ sa.ForeignKeyConstraint(['sync_run_id'], ['sync_runs.id'], ),
+ sa.PrimaryKeyConstraint('id')
+ )
+ op.create_table('sale_order_lines',
+ sa.Column('id', sa.Integer(), nullable=False),
+ sa.Column('odoo_id', sa.Integer(), nullable=False),
+ sa.Column('sale_order_id', sa.Integer(), nullable=False),
+ sa.Column('product_id', sa.Integer(), nullable=False),
+ sa.Column('quantity', sa.Float(), nullable=False),
+ sa.Column('unit_price', sa.Float(), nullable=False),
+ sa.Column('subtotal', sa.Float(), nullable=False),
+ sa.Column('created_at', sa.DateTime(), nullable=True),
+ sa.Column('updated_at', sa.DateTime(), nullable=True),
+ sa.ForeignKeyConstraint(['product_id'], ['products.id'], ),
+ sa.ForeignKeyConstraint(['sale_order_id'], ['sale_orders.id'], ),
+ sa.PrimaryKeyConstraint('id')
+ )
+ op.create_index(op.f('ix_sale_order_lines_odoo_id'), 'sale_order_lines', ['odoo_id'], unique=True)
+ # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+ """Downgrade schema."""
+ # ### commands auto generated by Alembic - please adjust! ###
+ op.drop_index(op.f('ix_sale_order_lines_odoo_id'), table_name='sale_order_lines')
+ op.drop_table('sale_order_lines')
+ op.drop_table('sync_logs')
+ op.drop_index(op.f('ix_sale_orders_odoo_id'), table_name='sale_orders')
+ op.drop_table('sale_orders')
+ op.drop_table('sync_runs')
+ op.drop_index(op.f('ix_products_odoo_id'), table_name='products')
+ op.drop_index(op.f('ix_products_internal_reference'), table_name='products')
+ op.drop_table('products')
+ op.drop_index(op.f('ix_contacts_odoo_id'), table_name='contacts')
+ op.drop_table('contacts')
+ # ### end Alembic commands ###
diff --git a/migrations/versions/__pycache__/8f898b04173e_create_initial_tables.cpython-313.pyc b/migrations/versions/__pycache__/8f898b04173e_create_initial_tables.cpython-313.pyc
new file mode 100644
index 0000000..f14b078
Binary files /dev/null and b/migrations/versions/__pycache__/8f898b04173e_create_initial_tables.cpython-313.pyc differ
diff --git a/odoo/init_data.py b/odoo/init_data.py
new file mode 100644
index 0000000..ee104b4
--- /dev/null
+++ b/odoo/init_data.py
@@ -0,0 +1,196 @@
+"""
+اسکریپت ساخت دادههای تستی در Odoo (Contacts, Products, Sale Orders).
+
+این اسکریپت idempotent هست: اگه دوباره اجراش کنی، رکوردهای تکراری نمیسازه
+(چون قبل از ساخت هر رکورد، چک میکنه که با همون شناسه (مثلاً همون ایمیل یا
+همون Internal Reference) قبلاً وجود داره یا نه).
+
+اجرا:
+ python odoo/init_data.py
+"""
+
+import os
+import ssl
+import xmlrpc.client
+from pathlib import Path
+from dotenv import load_dotenv
+
+# ابتدا تلاش میکند .env.local را بخواند، اگر نبود به سراغ .env میرود
+load_dotenv(".env.local") or load_dotenv(".env")
+
+# # ---------- خواندن سادهی فایل .env.local یا .env بدون نیاز به کتابخانهی خارجی ----------
+# def load_env(base_dir: str | Path = ".") -> None:
+# base_path = Path(base_dir)
+# # اولویت اول با .env.local، در غیر این صورت .env
+# env_file = base_path / ".env.local"
+# if not env_file.exists():
+# env_file = base_path / ".env"
+
+# if not env_file.exists():
+# return
+
+# for line in env_file.read_text(encoding="utf-8").splitlines():
+# line = line.strip()
+# if not line or line.startswith("#") or "=" not in line:
+# continue
+# key, value = line.split("=", 1)
+# # مقداردهی مستقیم تا مقادیر فایل حتماً روی os.environ اعمال شوند
+# os.environ[key.strip()] = value.strip()
+
+
+# load_env()
+
+ODOO_URL = os.getenv("ODOO_URL", "http://localhost:8069")
+ODOO_DB = os.getenv("ODOO_DB", "my_odoo_project")
+ODOO_USERNAME = os.getenv("ODOO_USERNAME", "admin@gmail.com")
+ODOO_PASSWORD = os.getenv("ODOO_PASSWORD", "Mohamad@77")
+
+
+class OdooConnection:
+ """یک wrapper ساده روی XML-RPC برای اتصال و صدا زدن متدهای Odoo."""
+
+ def __init__(self, url: str, db: str, username: str, password: str):
+ self.url = url
+ self.db = db
+ self.username = username
+ self.password = password
+ self.uid = None
+ self.models = None
+
+ def connect(self):
+ common = xmlrpc.client.ServerProxy(f"{self.url}/xmlrpc/2/common")
+ self.uid = common.authenticate(self.db, self.username, self.password, {})
+ if not self.uid:
+ raise RuntimeError(
+ "اتصال به Odoo ناموفق بود. یوزرنیم/پسورد یا اسم دیتابیس رو چک کن."
+ )
+ self.models = xmlrpc.client.ServerProxy(f"{self.url}/xmlrpc/2/object")
+ print(f"[OK] به Odoo وصل شدیم. uid={self.uid}")
+ return self
+
+ def execute(self, model: str, method: str, *args, **kwargs):
+ return self.models.execute_kw(
+ self.db, self.uid, self.password, model, method, list(args), kwargs
+ )
+
+ def search(self, model: str, domain: list) -> list:
+ return self.execute(model, "search", domain)
+
+ def search_read(self, model: str, domain: list, fields: list) -> list:
+ return self.execute(model, "search_read", domain, {"fields": fields})
+
+ def create(self, model: str, values: dict) -> int:
+ return self.execute(model, "create", values)
+
+ def write(self, model: str, record_id: int, values: dict) -> bool:
+ return self.execute(model, "write", [record_id], values)
+
+
+def get_or_create_contact(conn: OdooConnection, data: dict) -> int:
+ """اگه Contact با همین ایمیل وجود داشت همونو برمیگردونه، وگرنه میسازه."""
+ existing = conn.search("res.partner", [["email", "=", data["email"]]])
+ if existing:
+ print(f" - Contact '{data['name']}' از قبل هست (id={existing[0]}), رد شدیم.")
+ return existing[0]
+ contact_id = conn.create("res.partner", data)
+ print(f" + Contact '{data['name']}' ساخته شد (id={contact_id})")
+ return contact_id
+
+
+def get_or_create_product(conn: OdooConnection, data: dict) -> int:
+ """اگه Product با همین Internal Reference (default_code) وجود داشت، همونو برمیگردونه."""
+ existing = conn.search("product.product", [["default_code", "=", data["default_code"]]])
+ if existing:
+ print(f" - Product '{data['name']}' از قبل هست (id={existing[0]}), رد شدیم.")
+ return existing[0]
+ product_id = conn.create("product.product", data)
+ print(f" + Product '{data['name']}' ساخته شد (id={product_id})")
+ return product_id
+
+
+def get_or_create_sale_order(conn: OdooConnection, partner_id: int, order_date: str,
+ lines: list, client_order_ref: str) -> int:
+ """
+ برای جلوگیری از تکرار، از client_order_ref (فیلد "Customer Reference")
+ به عنوان شناسهی یکتا استفاده میکنیم چون در این سناریو مصنوعیه و
+ راحت میتونیم تشخیص بدیم قبلاً ساخته شده یا نه.
+ """
+ existing = conn.search("sale.order", [["client_order_ref", "=", client_order_ref]])
+ if existing:
+ print(f" - Sale Order '{client_order_ref}' از قبل هست (id={existing[0]}), رد شدیم.")
+ return existing[0]
+
+ order_lines = [
+ (0, 0, {
+ "product_id": line["product_id"],
+ "product_uom_qty": line["qty"],
+ "price_unit": line["price_unit"],
+ })
+ for line in lines
+ ]
+
+ order_id = conn.create("sale.order", {
+ "partner_id": partner_id,
+ "date_order": order_date,
+ "client_order_ref": client_order_ref,
+ "order_line": order_lines,
+ })
+ print(f" + Sale Order '{client_order_ref}' ساخته شد (id={order_id})")
+ return order_id
+
+
+def main():
+ conn = OdooConnection(ODOO_URL, ODOO_DB, ODOO_USERNAME, ODOO_PASSWORD).connect()
+
+ print("\n--- ساخت Contacts ---")
+ contacts_data = [
+ {"name": "Ali Rezaei", "email": "ali.rezaei@example.com", "phone": "+98 21 1111 1111", "mobile": "+98 912 111 1111"},
+ {"name": "Sara Ahmadi", "email": "sara.ahmadi@example.com", "phone": "+98 21 2222 2222", "mobile": "+98 912 222 2222"},
+ {"name": "Reza Karimi", "email": "reza.karimi@example.com", "phone": "+98 21 3333 3333", "mobile": "+98 912 333 3333"},
+ ]
+ contact_ids = [get_or_create_contact(conn, c) for c in contacts_data]
+
+ print("\n--- ساخت Products ---")
+ products_data = [
+ {"name": "Wireless Mouse", "default_code": "PRD-001", "list_price": 25.0, "type": "consu"},
+ {"name": "Mechanical Keyboard", "default_code": "PRD-002", "list_price": 75.0, "type": "consu"},
+ {"name": "Consulting Service", "default_code": "PRD-003", "list_price": 100.0, "type": "service"},
+ ]
+ product_ids = [get_or_create_product(conn, p) for p in products_data]
+
+ print("\n--- ساخت Sale Orders ---")
+ get_or_create_sale_order(
+ conn,
+ partner_id=contact_ids[0],
+ order_date="2026-06-01 10:00:00",
+ client_order_ref="TEST-SO-001",
+ lines=[
+ {"product_id": product_ids[0], "qty": 2, "price_unit": 25.0},
+ {"product_id": product_ids[1], "qty": 1, "price_unit": 75.0},
+ ],
+ )
+ get_or_create_sale_order(
+ conn,
+ partner_id=contact_ids[1],
+ order_date="2026-06-05 14:30:00",
+ client_order_ref="TEST-SO-002",
+ lines=[
+ {"product_id": product_ids[2], "qty": 3, "price_unit": 100.0},
+ ],
+ )
+ get_or_create_sale_order(
+ conn,
+ partner_id=contact_ids[2],
+ order_date="2026-06-10 09:15:00",
+ client_order_ref="TEST-SO-003",
+ lines=[
+ {"product_id": product_ids[0], "qty": 5, "price_unit": 25.0},
+ {"product_id": product_ids[2], "qty": 1, "price_unit": 100.0},
+ ],
+ )
+
+ print("\n[DONE] دادههای تستی آمادهست.")
+
+
+if __name__ == "__main__":
+ main()
\ No newline at end of file
diff --git a/pytest.ini b/pytest.ini
new file mode 100644
index 0000000..4584de7
--- /dev/null
+++ b/pytest.ini
@@ -0,0 +1,3 @@
+[pytest]
+testpaths = tests
+pythonpath = .
diff --git a/requirements-dev.txt b/requirements-dev.txt
new file mode 100644
index 0000000..73e0393
--- /dev/null
+++ b/requirements-dev.txt
@@ -0,0 +1,3 @@
+ -r requirements.txt
+ pytest==8.3.4
+ pytest-cov==6.0.0
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..a9a0b35
Binary files /dev/null and b/requirements.txt differ
diff --git a/scripts/__pycache__/test_mapping.cpython-313-pytest-8.3.4.pyc b/scripts/__pycache__/test_mapping.cpython-313-pytest-8.3.4.pyc
new file mode 100644
index 0000000..2261f4a
Binary files /dev/null and b/scripts/__pycache__/test_mapping.cpython-313-pytest-8.3.4.pyc differ
diff --git a/scripts/__pycache__/test_odoo_connection.cpython-313-pytest-8.3.4.pyc b/scripts/__pycache__/test_odoo_connection.cpython-313-pytest-8.3.4.pyc
new file mode 100644
index 0000000..adb945b
Binary files /dev/null and b/scripts/__pycache__/test_odoo_connection.cpython-313-pytest-8.3.4.pyc differ
diff --git a/scripts/__pycache__/test_repository_sync.cpython-313-pytest-8.3.4.pyc b/scripts/__pycache__/test_repository_sync.cpython-313-pytest-8.3.4.pyc
new file mode 100644
index 0000000..e21e3f9
Binary files /dev/null and b/scripts/__pycache__/test_repository_sync.cpython-313-pytest-8.3.4.pyc differ
diff --git a/scripts/test_mapping.py b/scripts/test_mapping.py
new file mode 100644
index 0000000..016beee
--- /dev/null
+++ b/scripts/test_mapping.py
@@ -0,0 +1,74 @@
+"""
+اسکریپت تست مرحله ۵: چک میکنه Mapperها درست کار میکنن.
+
+اجرا:
+ python scripts/test_mapping.py
+"""
+
+import os
+import sys
+from pathlib import Path
+
+# ۱. افزودن مسیر اصلی پروژه به sys.path
+BASE_DIR = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(BASE_DIR))
+
+
+# ۲. بارگذاری فایل .env.local یا .env
+def load_env(base_dir: Path) -> None:
+ # اولویت اول با .env.local، در غیر این صورت .env
+ env_file = base_dir / ".env.local"
+ if not env_file.exists():
+ env_file = base_dir / ".env"
+
+ if not env_file.exists():
+ return
+
+ print(f"[INFO] Loading environment from: {env_file.name}")
+ for line in env_file.read_text().splitlines():
+ line = line.strip()
+ if not line or line.startswith("#") or "=" not in line:
+ continue
+ key, value = line.split("=", 1)
+ os.environ[key.strip()] = value.strip()
+
+
+load_env(BASE_DIR)
+
+from src.odoo_client.client import build_odoo_client
+from src.mappers.contact_mapper import ContactMapper
+from src.mappers.product_mapper import ProductMapper
+from src.mappers.sale_order_mapper import SaleOrderMapper
+from src.mappers.sale_order_line_mapper import SaleOrderLineMapper
+
+
+def main():
+ client = build_odoo_client()
+
+ print("--- Contacts ---")
+ raw_contacts = client.fetch_contacts()
+ contacts = ContactMapper().to_domain_list(raw_contacts)
+ for c in contacts:
+ print(" ", c)
+
+ print("\n--- Products ---")
+ raw_products = client.fetch_products()
+ products = ProductMapper().to_domain_list(raw_products)
+ for p in products:
+ print(" ", p)
+
+ print("\n--- Sale Orders ---")
+ raw_orders = client.fetch_sale_orders()
+ orders = SaleOrderMapper().to_domain_list(raw_orders)
+ for o in orders:
+ print(" ", o)
+
+ print("\n--- Sale Order Lines ---")
+ raw_lines = client.fetch_sale_order_lines()
+ lines = SaleOrderLineMapper().to_domain_list(raw_lines)
+ for l in lines:
+ print(" ", l)
+
+
+if __name__ == "__main__":
+ main()
diff --git a/scripts/test_odoo_connection.py b/scripts/test_odoo_connection.py
new file mode 100644
index 0000000..61e3db2
--- /dev/null
+++ b/scripts/test_odoo_connection.py
@@ -0,0 +1,73 @@
+"""
+اسکریپت تست مرحله ۴: فقط چک میکنه OdooClient درست وصل میشه و میتونه
+داده بخونه. هیچی نمینویسه، فقط میخونه و چاپ میکنه.
+
+اجرا:
+ python scripts/test_odoo_connection.py
+"""
+import os
+import sys
+from pathlib import Path
+
+# ۱. اضافه کردن مسیر پروژه به sys.path
+BASE_DIR = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(BASE_DIR))
+
+# ۲. تابع بارگذاری .env.local یا .env (بدون setdefault تا حتماً مقادیر اعمال شوند)
+def load_env(base_dir: Path) -> None:
+ # اولویت اول با .env.local است؛ اگر نبود سراغ .env میرود
+ env_file = base_dir / ".env.local"
+ if not env_file.exists():
+ env_file = base_dir / ".env"
+
+ if not env_file.exists():
+ return
+
+ for line in env_file.read_text().splitlines():
+ line = line.strip()
+ if not line or line.startswith("#") or "=" not in line:
+ continue
+ key, value = line.split("=", 1)
+ os.environ[key.strip()] = value.strip()
+
+
+# بارگذاری فایل محیطی قبل از فراخوانی odoo_client
+load_env(BASE_DIR)
+
+# sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
+
+from src.odoo_client.client import build_odoo_client
+
+
+def main():
+ print("در حال اتصال به Odoo...")
+ client = build_odoo_client()
+ print("[OK] وصل شدیم.\n")
+
+ contacts = client.fetch_contacts()
+ print(f"تعداد Contacts خوندهشده: {len(contacts)}")
+ for c in contacts[:3]:
+ print(f" - {c['name']} | {c.get('email')}")
+
+ products = client.fetch_products()
+ print(f"\nتعداد Products خوندهشده: {len(products)}")
+ for p in products[:3]:
+ print(
+ f" - {p['name']} | ref={p.get('default_code')} |"
+ f" price={p.get('list_price')}"
+ )
+
+ orders = client.fetch_sale_orders()
+ print(f"\nتعداد Sale Orders خوندهشده: {len(orders)}")
+ for o in orders[:3]:
+ print(
+ f" - {o['name']} | state={o.get('state')} |"
+ f" total={o.get('amount_total')}"
+ )
+
+ lines = client.fetch_sale_order_lines()
+ print(f"\nتعداد Sale Order Lines خوندهشده: {len(lines)}")
+
+
+if __name__ == "__main__":
+ main()
diff --git a/scripts/test_repository_sync.py b/scripts/test_repository_sync.py
new file mode 100644
index 0000000..28c15d4
--- /dev/null
+++ b/scripts/test_repository_sync.py
@@ -0,0 +1,121 @@
+"""
+اسکریپت تست مرحله ۶: کل مسیر «Odoo -> Mapper -> Repository -> PostgreSQL» رو
+یکبار کامل اجرا میکنه. این هنوز Service Layer رسمی نیست (اون مرحلهی بعده)،
+فقط برای اینه که ببینیم Repositoryها درست کار میکنن.
+
+نکتهی مهم برای تست Idempotency:
+این اسکریپت رو ۲ بار پشتسرهم اجرا کن. بار اول باید همهچیز "created" بشه،
+بار دوم باید همهچیز "updated" بشه (نه created) — یعنی رکورد تکراری ساخته نشد.
+
+اجرا:
+ python scripts/test_repository_sync.py
+"""
+
+import os
+import sys
+from pathlib import Path
+
+# ۱. یافتن مسیر ریشه پروژه و افزودن به sys.path
+BASE_DIR = Path(__file__).resolve().parent.parent
+sys.path.insert(0, str(BASE_DIR))
+
+
+# ۲. بارگذاری فایل .env.local یا .env
+def load_env(base_dir: Path) -> None:
+ # اولویت اول با .env.local هست، اگه نبود .env رو میخونه
+ env_file = base_dir / ".env.local"
+ if not env_file.exists():
+ env_file = base_dir / ".env"
+
+ if not env_file.exists():
+ print("[WARN] هیچ فایل .env یا .env.local پیدا نشد!")
+ return
+
+ print(f"[INFO] Loading environment from: {env_file.name}")
+ for line in env_file.read_text().splitlines():
+ line = line.strip()
+ if not line or line.startswith("#") or "=" not in line:
+ continue
+ key, value = line.split("=", 1)
+ # استفاده از مقداردهی مستقیم برای بازنویسی متغیرهای قبلی
+ os.environ[key.strip()] = value.strip()
+
+
+load_env(BASE_DIR)
+
+from src.odoo_client.client import build_odoo_client
+from src.mappers.contact_mapper import ContactMapper
+from src.mappers.product_mapper import ProductMapper
+from src.mappers.sale_order_mapper import SaleOrderMapper
+from src.mappers.sale_order_line_mapper import SaleOrderLineMapper
+from src.db.session import get_session
+from src.repositories.contact_repository import ContactRepository
+from src.repositories.product_repository import ProductRepository
+from src.repositories.sale_order_repository import SaleOrderRepository
+from src.repositories.sale_order_line_repository import SaleOrderLineRepository
+
+
+def main():
+ client = build_odoo_client()
+ session = get_session()
+
+ contact_repo = ContactRepository(session)
+ product_repo = ProductRepository(session)
+ order_repo = SaleOrderRepository(session)
+ line_repo = SaleOrderLineRepository(session)
+
+ stats = {"created": 0, "updated": 0}
+
+ try:
+ # ---------- Contacts ----------
+ print("--- Sync Contacts ---")
+ contacts = ContactMapper().to_domain_list(client.fetch_contacts())
+ for c in contacts:
+ _, created = contact_repo.upsert(c)
+ stats["created" if created else "updated"] += 1
+ print(f" {'created' if created else 'updated'}: {c.name}")
+
+ # ---------- Products ----------
+ print("\n--- Sync Products ---")
+ products = ProductMapper().to_domain_list(client.fetch_products())
+ for p in products:
+ _, created = product_repo.upsert(p)
+ stats["created" if created else "updated"] += 1
+ print(f" {'created' if created else 'updated'}: {p.name}")
+
+ # ---------- Sale Orders ----------
+ print("\n--- Sync Sale Orders ---")
+ orders = SaleOrderMapper().to_domain_list(client.fetch_sale_orders())
+ for o in orders:
+ customer = contact_repo.get_by_odoo_id(o.customer_odoo_id)
+ if customer is None:
+ print(f" [SKIP] مشتری با odoo_id={o.customer_odoo_id} پیدا نشد.")
+ continue
+ _, created = order_repo.upsert(o, customer_id=customer.id)
+ stats["created" if created else "updated"] += 1
+ print(f" {'created' if created else 'updated'}: {o.order_number}")
+
+ # ---------- Sale Order Lines ----------
+ print("\n--- Sync Sale Order Lines ---")
+ lines = SaleOrderLineMapper().to_domain_list(client.fetch_sale_order_lines())
+ for line in lines:
+ order = order_repo.get_by_odoo_id(line.order_odoo_id)
+ product = product_repo.get_by_odoo_id(line.product_odoo_id)
+ if order is None or product is None:
+ print(f" [SKIP] order یا product برای line odoo_id={line.odoo_id} پیدا نشد.")
+ continue
+ _, created = line_repo.upsert(line, sale_order_id=order.id, product_id=product.id)
+ stats["created" if created else "updated"] += 1
+
+ session.commit()
+ print(f"\n[DONE] created={stats['created']} updated={stats['updated']}")
+
+ except Exception:
+ session.rollback()
+ raise
+ finally:
+ session.close()
+
+
+if __name__ == "__main__":
+ main()
diff --git a/bookland_account/__init__.py b/src/__init__.py
similarity index 100%
rename from bookland_account/__init__.py
rename to src/__init__.py
diff --git a/src/__pycache__/__init__.cpython-313.pyc b/src/__pycache__/__init__.cpython-313.pyc
new file mode 100644
index 0000000..d30f730
Binary files /dev/null and b/src/__pycache__/__init__.cpython-313.pyc differ
diff --git a/src/__pycache__/main.cpython-313.pyc b/src/__pycache__/main.cpython-313.pyc
new file mode 100644
index 0000000..7a1f793
Binary files /dev/null and b/src/__pycache__/main.cpython-313.pyc differ
diff --git a/bookland/README.md b/src/config/__init__.py
similarity index 100%
rename from bookland/README.md
rename to src/config/__init__.py
diff --git a/src/config/__pycache__/__init__.cpython-313.pyc b/src/config/__pycache__/__init__.cpython-313.pyc
new file mode 100644
index 0000000..4364cf2
Binary files /dev/null and b/src/config/__pycache__/__init__.cpython-313.pyc differ
diff --git a/src/config/__pycache__/settings.cpython-313.pyc b/src/config/__pycache__/settings.cpython-313.pyc
new file mode 100644
index 0000000..f2e2499
Binary files /dev/null and b/src/config/__pycache__/settings.cpython-313.pyc differ
diff --git a/src/config/settings.py b/src/config/settings.py
new file mode 100644
index 0000000..b920bdc
--- /dev/null
+++ b/src/config/settings.py
@@ -0,0 +1,52 @@
+"""
+تمام تنظیمات پروژه از اینجا خونده میشه. اگه فردا خواستی یه env variable
+جدید اضافه کنی، فقط همینجا اضافهاش میکنی و بقیهی کد بدون تغییر میمونه.
+"""
+
+import os
+from dotenv import load_dotenv
+from pathlib import Path
+
+
+#پیدا کردن مسیر ریشه از دو لایه بالاتر
+BASE_DIR = Path(__file__).resolve().parent.parent.parent
+
+#روی محیط local با .env.local کار میکنه و روی محیط پروداکشن با .env
+env_file = BASE_DIR / ".env.local"
+if not env_file.exists():
+ env_file = BASE_DIR / ".env"
+
+if env_file.exists():
+ load_dotenv(dotenv_path=env_file, override=True)
+
+
+class Settings:
+ def __init__(self):
+ #تنظمیات odoo
+ self.ODOO_URL: str = os.getenv("ODOO_URL", "http://localhost:8069")
+ self.ODOO_DB: str = os.getenv("ODOO_DB", "my_odoo_project")
+ self.ODOO_USERNAME: str = os.getenv("ODOO_USERNAME", "admin@gmail.com")
+ self.ODOO_PASSWORD: str = os.getenv("ODOO_PASSWORD", "Mohamad@77")
+
+ # تنظمیات postgresql
+ self.APP_DB_HOST: str = os.getenv("APP_DB_HOST", "localhost")
+ self.APP_DB_PORT: int = int(os.getenv("APP_DB_PORT", "5432"))
+ self.APP_DB_NAME: str = os.getenv("APP_DB_NAME", "syncdb")
+ self.APP_DB_USER: str = os.getenv("APP_DB_USER", "syncuser")
+ self.APP_DB_PASSWORD: str = os.getenv("APP_DB_PASSWORD", "syncpass")
+
+
+ # تنظیمات لاگ ها
+ self.LOG_LEVEL: str = os.getenv("LOG_LEVEL", "INFO")
+
+ #اتصال به DB
+ @property
+ def database_url(self) -> str:
+ """Connection string کامل برای SQLAlchemy."""
+ return (
+ f"postgresql+psycopg2://{self.APP_DB_USER}:{self.APP_DB_PASSWORD}"
+ f"@{self.APP_DB_HOST}:{self.APP_DB_PORT}/{self.APP_DB_NAME}"
+ )
+
+
+settings = Settings()
diff --git a/bookland_account/README.md b/src/core/__init__.py
similarity index 100%
rename from bookland_account/README.md
rename to src/core/__init__.py
diff --git a/src/core/__pycache__/__init__.cpython-313.pyc b/src/core/__pycache__/__init__.cpython-313.pyc
new file mode 100644
index 0000000..346f9f9
Binary files /dev/null and b/src/core/__pycache__/__init__.cpython-313.pyc differ
diff --git a/src/core/__pycache__/logging_config.cpython-313.pyc b/src/core/__pycache__/logging_config.cpython-313.pyc
new file mode 100644
index 0000000..9951191
Binary files /dev/null and b/src/core/__pycache__/logging_config.cpython-313.pyc differ
diff --git a/src/core/__pycache__/retry.cpython-313.pyc b/src/core/__pycache__/retry.cpython-313.pyc
new file mode 100644
index 0000000..b3f8cb5
Binary files /dev/null and b/src/core/__pycache__/retry.cpython-313.pyc differ
diff --git a/src/core/logging_config.py b/src/core/logging_config.py
new file mode 100644
index 0000000..e8acc32
--- /dev/null
+++ b/src/core/logging_config.py
@@ -0,0 +1,49 @@
+"""
+یکبار تو ابتدای main.py صدا زده میشه و کل سیستم Logging پروژه رو راه
+میاندازه. لاگها همزمان به دو جا میرن:
+ ۱. Standard Output (خود Terminal) — برای دیدن آنی وضعیت
+ ۲. فایل sync.log — برای بررسی بعدی یا اگه کسی Terminal رو نبینه
+
+(علاوه بر این دوتا، جزئیات هر Sync Run تو جدول sync_runs/sync_logs هم
+ذخیره میشه — اون بخش تو BaseSyncService انجام میشه.)
+"""
+
+import logging
+import sys
+from src.config.settings import settings
+from logging.handlers import RotatingFileHandler
+
+def setup_logging() -> None:
+ #لاگ های فراتر از Info رو به من نمایش میده
+ level = getattr(logging, settings.LOG_LEVEL.upper(), logging.INFO)
+
+ # تعیین فرمت لاگ ها
+ formatter = logging.Formatter(
+ fmt="%(asctime)s | %(levelname)-8s | %(name)s | %(message)s",
+ datefmt="%Y-%m-%d %H:%M:%S",
+ )
+
+ # تنظیمات لاگ ریشه
+ root_logger = logging.getLogger()
+ root_logger.setLevel(level)
+ root_logger.handlers.clear()
+
+ # نمایش لاگ ها روی ترمینال
+ console_handler = logging.StreamHandler(sys.stdout)
+ console_handler.setFormatter(formatter)
+ root_logger.addHandler(console_handler)
+
+ # نگهداری لاگ فایل ها بامدیریت حجم
+ file_handler = RotatingFileHandler(
+ "sync.log",
+ maxBytes=5 * 1024 * 1024,
+ backupCount=3,
+ encoding="utf-8",
+ )
+ file_handler.setFormatter(formatter)
+ root_logger.addHandler(file_handler)
+
+ # عدم ذخیره لاگ های کتاب خانه های جانبی مثل warning , info , ...
+ NOISY_LOGGERS = ["urllib3", "requests", "sqlalchemy.engine", "psycopg2"]
+ for logger_name in NOISY_LOGGERS:
+ logging.getLogger(logger_name).setLevel(logging.WARNING)
diff --git a/src/core/retry.py b/src/core/retry.py
new file mode 100644
index 0000000..ad82534
--- /dev/null
+++ b/src/core/retry.py
@@ -0,0 +1,64 @@
+"""
+Retry Decorator: وقتی یک تابع به یه دلیل موقتی (مثلاً قطعی لحظهای شبکه) خطا
+میده، بهجای اینکه فوری شکست بخوریم، چندبار با یه مکث بین هر تلاش دوباره
+امتحان میکنیم. مکث هر بار بیشتر میشه (Exponential Backoff) که فشار زیادی
+هم به سرور مقصد وارد نکنیم.
+
+مثال: delay=1, backoff=2, times=3
+ تلاش ۱ شکست -> ۱ ثانیه صبر
+ تلاش ۲ شکست -> ۲ ثانیه صبر
+ تلاش ۳ شکست -> دیگه تلاش نمیکنیم، خطا رو بالا میفرستیم
+"""
+
+import functools
+import logging
+import time
+from typing import Tuple, Type
+
+logger = logging.getLogger(__name__)
+
+# خطاهایی که تحت هیچ شرایطی نباید retry بشن -- اینها خطاهای منطقی/برنامهنویسی
+# هستن (نه مشکل موقتی شبکه)، پس retry کردنشون فقط وقت تلف میکنه و نتیجه
+# همیشه یکی میمونه.
+NON_RETRYABLE_EXCEPTIONS = (
+ KeyboardInterrupt,
+ SystemExit,
+ TypeError,
+ ValueError,
+ KeyError,
+ AttributeError,
+ IndexError,
+)
+
+
+def retry(
+ times: int = 3,
+ delay: float = 1.0,
+ backoff: float = 2.0,
+ max_delay: float = 30.0, # سقف زمان انتظار بین تلاشها (به ثانیه)
+ exceptions: Tuple[Type[BaseException], ...] = (Exception,),
+):
+ def decorator(func):
+ @functools.wraps(func)
+ def wrapper(*args, **kwargs):
+ current_delay = delay
+ for attempt in range(1, times + 1):
+ try:
+ return func(*args, **kwargs)
+ except NON_RETRYABLE_EXCEPTIONS as exc:
+ logger.error(f"خطای غیرقابل بازتلاش در {func.__name__}: {exc}")
+ raise
+ except exceptions as exc:
+ if attempt == times:
+ logger.error(
+ f"{func.__name__} بعد از {times} تلاش شکست خورد: {exc}"
+ )
+ raise
+ logger.warning(
+ f"تلاش {attempt}/{times} برای {func.__name__} شکست خورد: "
+ f"{exc} — {current_delay:.1f}s صبر میکنیم و دوباره امتحان میکنیم..."
+ )
+ time.sleep(current_delay)
+ current_delay = min(current_delay * backoff, max_delay)
+ return wrapper
+ return decorator
diff --git a/bookland_account/readme/HISTORY.md b/src/db/__init__.py
similarity index 100%
rename from bookland_account/readme/HISTORY.md
rename to src/db/__init__.py
diff --git a/src/db/__pycache__/__init__.cpython-313.pyc b/src/db/__pycache__/__init__.cpython-313.pyc
new file mode 100644
index 0000000..2f2155f
Binary files /dev/null and b/src/db/__pycache__/__init__.cpython-313.pyc differ
diff --git a/src/db/__pycache__/models.cpython-313.pyc b/src/db/__pycache__/models.cpython-313.pyc
new file mode 100644
index 0000000..9926146
Binary files /dev/null and b/src/db/__pycache__/models.cpython-313.pyc differ
diff --git a/src/db/__pycache__/session.cpython-313.pyc b/src/db/__pycache__/session.cpython-313.pyc
new file mode 100644
index 0000000..4c1f952
Binary files /dev/null and b/src/db/__pycache__/session.cpython-313.pyc differ
diff --git a/src/db/models.py b/src/db/models.py
new file mode 100644
index 0000000..ba5bc78
--- /dev/null
+++ b/src/db/models.py
@@ -0,0 +1,143 @@
+"""
+مدلهای SQLAlchemy — هر کلاس اینجا معادل یک جدول تو PostgreSQL هست.
+
+نکتهی مهم دربارهی Idempotency:
+هر جدولی که از Odoo میاد (Contact, Product, SaleOrder, SaleOrderLine) یک ستون
+`odoo_id` داره که UNIQUE هست. یعنی دیتابیس خودش جلوی ساخت رکورد تکراری با
+همون odoo_id رو میگیره، و ما تو کد هم قبلش چک میکنیم (get_or_create).
+"""
+
+from datetime import datetime
+
+from sqlalchemy import (
+ Column, Integer, String, Float, DateTime, ForeignKey, Text, UniqueConstraint
+)
+from sqlalchemy.orm import declarative_base, relationship
+
+Base = declarative_base()
+
+
+class Contact(Base):
+ __tablename__ = "contacts"
+
+ id = Column(Integer, primary_key=True)
+ odoo_id = Column(Integer, unique=True, nullable=False, index=True)
+ name = Column(String(255), nullable=False)
+ email = Column(String(255), nullable=True)
+ phone = Column(String(50), nullable=True)
+ mobile = Column(String(50), nullable=True)
+
+ created_at = Column(DateTime, default=datetime.utcnow)
+ updated_at = Column(DateTime, default=datetime.utcnow, onupdate=datetime.utcnow)
+
+ # یک Contact میتونه چند تا Sale Order داشته باشه (One-to-Many)
+ sale_orders = relationship("SaleOrder", back_populates="customer")
+
+ def __repr__(self):
+ return f"
-
-Book land accounting feature
- -
این ماژول امکانات حسابداری را اضافه میکند
-Table of contents
-
-
-
--
-
- Known issues / Roadmap -
- V2.0.0 -
- Changelog -
- Bug Tracker -
- Credits
-
-
- Authors -
- Maintainers -
-
-
-V2.0.0
--
-
- connect to invoice -
-
-Changelog
-
-
-Bug Tracker
-Bugs are tracked on GitHub Issues. -In case of trouble, please check there if your issue has already been reported. -If you spotted it first, help us to smash it by providing a detailed and welcomed -feedback.
-Do not contact contributors directly about support or help with technical issues.
-
-
-Credits
-
-
-Authors
--
-
- Odoonix -
-
-Maintainers
-This module is part of the odoonix/education project on GitHub.
-You are welcome to contribute.
-