ERP Connect

# config.yaml - Desktop Agent Configuration

# Integration Settings
integration:
  id: "your-integration-id"
  name: "Supermarket ABC"

# API Configuration
api:
  base_url: "https://selfimart.com"
  key: "erp_your_api_key_here"
  secret: "your_secret_hash_here"
  timeout: 30

# Local Database Connection
database:
  type: "mysql"  # mysql, postgresql, sqlserver
  host: "localhost"
  port: 3306
  database: "erp_database"
  username: "erp_user"
  password: "erp_password"

# Sync Settings
sync:
  interval: 5  # minutes
  batch_size: 100
  retry_attempts: 3
  retry_delay: 60  # seconds

# Field Mappings
mapping:
  products:
    table: "items"
    columns:
      id: "item_id"
      name: "item_name"
      sku: "item_code"
      price: "selling_price"
      quantity: "qty_in_stock"
      updated_at: "modified_date"
    field_mappings:
      item_name: "name"
      item_code: "sku"
      selling_price: "price"
      qty_in_stock: "stock_quantity"

# Pricing Rules
pricing:
  markup: 10  # percentage markup to add to ERP prices
  tax_inclusive: false

# Agent Settings
agent:
  port: 8080  # Local HTTP server for status
  log_level: "info"

import requests
import hmac
import hashlib
import json
from datetime import datetime

class SelfimartErpClient:
    def __init__(self, api_key: str, secret_hash: str, base_url: str = "https://selfimart.com/api/v1"):
        self.api_key = api_key
        self.secret_hash = secret_hash
        self.base_url = base_url
        self.session = requests.Session()
        self.session.headers.update({
            "Content-Type": "application/json",
            "Accept": "application/json",
        })
    
    def _generate_signature(self, payload: str) -> str:
        """Generate HMAC signature for request authentication."""
        return hmac.new(
            self.secret_hash.encode(),
            payload.encode(),
            hashlib.sha256
        ).hexdigest()
    
    def _make_request(self, method: str, endpoint: str, data: dict = None) -> dict:
        """Make authenticated API request."""
        url = f"{self.base_url}{endpoint}"
        payload = json.dumps(data) if data else ""
        
        headers = {
            "X-Integration-Key": self.api_key,
            "X-Signature": self._generate_signature(payload),
            "X-Timestamp": datetime.utcnow().isoformat(),
        }
        
        response = self.session.request(
            method,
            url,
            data=payload,
            headers=headers
        )
        response.raise_for_status()
        return response.json()
    
    def sync_products(self, products: list) -> dict:
        """Sync products to Selfimart."""
        return self._make_request("POST", "/middleware/sync/products", {
            "products": products,
            "timestamp": datetime.utcnow().isoformat()
        })
    
    def sync_inventory(self, inventory: list) -> dict:
        """Sync inventory levels to Selfimart."""
        return self._make_request("POST", "/middleware/sync/inventory", {
            "inventory": inventory,
            "timestamp": datetime.utcnow().isoformat()
        })
    
    def get_orders(self, last_sync: str = None) -> dict:
        """Get orders from Selfimart for ERP import."""
        params = {"last_sync": last_sync} if last_sync else {}
        return self._make_request("GET", "/middleware/sync/orders", params)

# Usage
client = SelfimartErpClient(
    api_key="erp_your_key",
    secret_hash="your_secret_hash"
)

# Sync products
result = client.sync_products([
    {
        "id": "PROD-001",
        "name": "Product Name",
        "sku": "SKU-001",
        "price": 99.99,
        "quantity": 100
    }
])