job_offering.py

import json
from datetime import datetime, timezone, timedelta
from typing import Any, Dict, Optional, Union, TYPE_CHECKING, List

from jsonschema import ValidationError, validate
from pydantic import BaseModel, field_validator, ConfigDict
from web3 import Web3
from web3.constants import ADDRESS_ZERO

from virtuals_acp.configs.configs import (
    BASE_SEPOLIA_CONFIG,
    BASE_MAINNET_CONFIG,
    BASE_SEPOLIA_ACP_X402_CONFIG,
    BASE_MAINNET_ACP_X402_CONFIG
)
from virtuals_acp.constants import USDC_TOKEN_ADDRESS
from virtuals_acp.contract_clients.base_contract_client import BaseAcpContractClient
from virtuals_acp.fare import FareAmount
from virtuals_acp.models import ACPJobPhase, MemoType, OperationPayload, PriceType

if TYPE_CHECKING:
    from virtuals_acp.client import VirtualsACP


class ACPJobOffering(BaseModel):
    acp_client: "VirtualsACP"
    contract_client: BaseAcpContractClient
    provider_address: str
    name: str
    price: float
    price_type: PriceType
    required_funds: bool
    sla_minutes: int
    requirement: Optional[Union[Dict[str, Any], str]] = None
    deliverable: Optional[Union[Dict[str, Any], str]] = None

    model_config = ConfigDict(arbitrary_types_allowed=True)

    @field_validator("requirement", mode="before")
    def parse_requirement_schema(cls, v):
        if isinstance(v, str):
            try:
                return json.loads(json.dumps(v))
            except json.JSONDecodeError:
                return None
        return v

    def __str__(self):
        return f"ACPJobOffering({self.model_dump(exclude={'acp_client'})})"

    def __repr__(self) -> str:
        return self.__str__()

    def initiate_job(
        self,
        service_requirement: Union[Dict[str, Any], str],
        evaluator_address: Optional[str] = None,
    ) -> int:
        expired_at = datetime.now(timezone.utc) + timedelta(minutes=self.sla_minutes)

        # Validate against requirement schema if present
        if self.requirement:
            try:
                service_requirement = json.loads(json.dumps(service_requirement))
            except json.JSONDecodeError:
                raise ValueError(
                    f"Invalid JSON in service requirement. Required format: {json.dumps(self.requirement, indent=2)}"
                )

            if isinstance(self.requirement, dict):
                try:
                    validate(instance=service_requirement, schema=self.requirement)
                except ValidationError as e:
                    raise ValueError(f"Invalid service requirement: {str(e)}")

        final_service_requirement: Dict[str, Any] = {
            "name": self.name,
            "requirement": service_requirement,
            "priceValue": self.price,
            "priceType": self.price_type,
        }

        eval_addr = (
            Web3.to_checksum_address(evaluator_address)
            if evaluator_address
            else self.contract_client.agent_wallet_address
        )

        # Prepare fare amount based on this offering's price and contract's base fare
        fare_amount = FareAmount(
            self.price if self.price_type == PriceType.FIXED else 0,
            self.contract_client.config.base_fare,
        )

        # Lookup existing account between client and provider
        account = self.acp_client.get_by_client_and_provider(
            self.contract_client.agent_wallet_address,
            self.provider_address,
            self.contract_client,
        )

        base_contract_addresses = {
            BASE_SEPOLIA_CONFIG.contract_address.lower(),
            BASE_SEPOLIA_ACP_X402_CONFIG.contract_address.lower(),
            BASE_MAINNET_CONFIG.contract_address.lower(),
            BASE_MAINNET_ACP_X402_CONFIG.contract_address.lower(),
        }

        use_simple_create = (
            self.contract_client.config.contract_address.lower()
            in base_contract_addresses
        )

        chain_id = self.contract_client.config.chain_id
        usdc_token_address = USDC_TOKEN_ADDRESS[chain_id]
        is_usdc_payment_token = usdc_token_address == fare_amount.fare.contract_address
        
        # If the contract has x402_config and USDC is used, call create_job_with_x402
        is_x402_job =  bool(getattr(self.contract_client.config, "x402_config", None) and is_usdc_payment_token)
        if use_simple_create or not account:
            create_job_operation = self.contract_client.create_job(
                self.provider_address,
                eval_addr,
                expired_at,
                fare_amount.fare.contract_address,
                fare_amount.amount,
                "",
                is_x402_job=is_x402_job,
            )
        else:
            evaluator_address = (
                Web3.to_checksum_address(evaluator_address)
                if evaluator_address
                else ADDRESS_ZERO
            )
            create_job_operation = self.contract_client.create_job_with_account(
                account.id,
                evaluator_address or self.contract_client.agent_wallet_address,
                fare_amount.amount,
                fare_amount.fare.contract_address,
                expired_at,
                is_x402_job=is_x402_job,
            )

        response = self.contract_client.handle_operation([create_job_operation])

        job_id = self.contract_client.get_job_id(
            response,
            self.contract_client.agent_wallet_address,
            self.provider_address,
        )

        operations: List[OperationPayload] = []

        operation = self.contract_client.set_budget_with_payment_token(
            job_id,
            fare_amount.amount,
            fare_amount.fare.contract_address,
        )

        if operation:
            operations.append(operation)

        operations.append(
            self.contract_client.create_memo(
                job_id,
                json.dumps(final_service_requirement),
                MemoType.MESSAGE,
                True,
                ACPJobPhase.NEGOTIATION,
            )
        )
        self.contract_client.handle_operation(operations)

        return job_id


class ACPResourceOffering(BaseModel):
    acp_client: "VirtualsACP"
    name: str
    description: str
    url: str
    parameters: Optional[Dict[str, Any]]
    id: int

    model_config = ConfigDict(arbitrary_types_allowed=True)