Feat/acp

.gitignore

@@ -5,6 +5,7 @@
 *.pyc
 *__pycache__
 *.json
+.python-version
 
 *.DS_Store
 dist/

plugins/acp/acp_plugin_gamesdk/env.py

@@ -0,0 +1,35 @@
+from typing import Optional
+from virtuals_acp.env import EnvSettings
+from pydantic import field_validator
+
+class PluginEnvSettings(EnvSettings):
+    GAME_DEV_API_KEY: str
+    GAME_API_KEY: str
+    BUYER_AGENT_GAME_TWITTER_ACCESS_TOKEN: str
+    SELLER_AGENT_GAME_TWITTER_ACCESS_TOKEN: str
+    WHITELISTED_WALLET_ENTITY_ID: Optional[int] = None
+    # BUYER_AGENT_TWITTER_BEARER_TOKEN: str
+    # BUYER_AGENT_TWITTER_API_KEY: str
+    # BUYER_AGENT_TWITTER_API_SECRET_KEY: str
+    # BUYER_AGENT_TWITTER_ACCESS_TOKEN: str
+    # BUYER_AGENT_TWITTER_ACCESS_TOKEN_SECRET: str
+    # SELLER_AGENT_TWITTER_BEARER_TOKEN: str
+    # SELLER_AGENT_TWITTER_API_KEY: str
+    # SELLER_AGENT_TWITTER_API_SECRET_KEY: str
+    # SELLER_AGENT_TWITTER_ACCESS_TOKEN: str
+    # SELLER_AGENT_TWITTER_ACCESS_TOKEN_SECRET: str
+
+    @field_validator("GAME_DEV_API_KEY", "GAME_API_KEY")
+    @classmethod
+    def check_apt_prefix(cls, v: str) -> str:
+        if v and not v.startswith("apt-"):
+            raise ValueError("GAME key must start with 'apt-'")
+        return v
+
+    @field_validator("BUYER_AGENT_GAME_TWITTER_ACCESS_TOKEN", "SELLER_AGENT_GAME_TWITTER_ACCESS_TOKEN")
+    @classmethod
+    def check_apx_prefix(cls, v: str) -> str:
+        if v and not v.startswith("apx-"):
+            raise ValueError("SELLER_AGENT_GAME_TWITTER_ACCESS_TOKEN must start with 'apx-'")
+        return v
+

plugins/acp/acp_plugin_gamesdk/interface.py

@@ -0,0 +1,147 @@
+from dataclasses import dataclass
+from enum import Enum
+from typing import Optional, List, Literal, Dict, Any
+from pydantic import BaseModel
+
+from virtuals_acp.models import ACPJobPhase, IDeliverable
+
+
+class AcpOffering(BaseModel):
+    name: str
+    price: float
+
+    def __str__(self) -> str:
+        return f"Offering(name={self.name}, price={self.price})"
+
+class AcpJobPhasesDesc(str, Enum):
+    REQUEST = "request"
+    NEGOTIATION = "pending_payment"
+    TRANSACTION = "in_progress"
+    EVALUATION = "evaluation"
+    COMPLETED = "completed"
+    REJECTED = "rejected"
+    EXPIRED = "expired"
+
+ACP_JOB_PHASE_MAP: Dict[ACPJobPhase, AcpJobPhasesDesc] = {
+    ACPJobPhase.REQUEST: AcpJobPhasesDesc.REQUEST,
+    ACPJobPhase.NEGOTIATION: AcpJobPhasesDesc.NEGOTIATION,
+    ACPJobPhase.TRANSACTION: AcpJobPhasesDesc.TRANSACTION,
+    ACPJobPhase.EVALUATION: AcpJobPhasesDesc.EVALUATION,
+    ACPJobPhase.COMPLETED: AcpJobPhasesDesc.COMPLETED,
+    ACPJobPhase.REJECTED: AcpJobPhasesDesc.REJECTED,
+    ACPJobPhase.EXPIRED: AcpJobPhasesDesc.EXPIRED,
+}
+
+ACP_JOB_PHASE_REVERSE_MAP: Dict[str, ACPJobPhase] = {
+    "request": ACPJobPhase.REQUEST,
+    "pending_payment": ACPJobPhase.NEGOTIATION,
+    "in_progress": ACPJobPhase.TRANSACTION,
+    "evaluation": ACPJobPhase.EVALUATION,
+    "completed": ACPJobPhase.COMPLETED,
+    "rejected": ACPJobPhase.REJECTED,
+    "expired": ACPJobPhase.EXPIRED,
+}
+
+class AcpRequestMemo(BaseModel):
+    id: int
+
+    def __repr__(self) -> str:
+        return f"Memo(ID: {self.id})"
+
+class ITweet(BaseModel):
+    type: Literal["buyer", "seller"]
+    tweet_id: str
+    content: str
+    created_at: int
+
+class IAcpJob(BaseModel):
+    job_id: Optional[int]
+    client_name: Optional[str]
+    provider_name: Optional[str]
+    desc: str
+    price: str
+    provider_address: Optional[str]
+    phase: AcpJobPhasesDesc
+    memo: List[AcpRequestMemo]
+    tweet_history: Optional[List[Optional[ITweet]]]
+
+    def __repr__(self) -> str:
+        return (
+            f"Job ID: {self.job_id}, "
+            f"Client Name: {self.client_name}, "
+            f"Provider Name: {self.provider_name}, "
+            f"Description: {self.desc}, "
+            f"Price: {self.price}, "
+            f"Provider Address: {self.provider_address}, "
+            f"Phase: {self.phase.value}, "
+            f"Memo: {self.memo}, "
+            f"Tweet History: {self.tweet_history}"
+        )
+
+
+class IInventory(IDeliverable):
+    job_id: int
+    client_name: Optional[str]
+    provider_name: Optional[str]
+
+class AcpJobsSection(BaseModel):
+    as_a_buyer: List[IAcpJob]
+    as_a_seller: List[IAcpJob]
+
+    def __str__(self) -> str:
+        buyer_jobs = "\n".join([f"#{i+1} {str(job)}" for i, job in enumerate(self.as_a_buyer)])
+        seller_jobs = "\n".join([f"#{i+1} {str(job)}" for i, job in enumerate(self.as_a_seller)])
+        return f"As Buyer:\n{buyer_jobs}\n\nAs Seller:\n{seller_jobs}"
+
+class AcpJobs(BaseModel):
+    active: AcpJobsSection
+    completed: List[IAcpJob]
+    cancelled: List[IAcpJob]
+
+    def __str__(self) -> str:
+        return (
+            f"💻 Jobs\n"
+            f"🌕 Active Jobs:\n{self.active}\n"
+            f"🟢 Completed:\n{self.completed}\n"
+            f"🔴 Cancelled:\n{self.cancelled}"
+        )
+
+class AcpInventory(BaseModel):
+    acquired: List[IInventory]
+    produced: Optional[List[IInventory]]
+
+    def __str__(self) -> str:
+        return (
+            f"💼 Inventory\n"
+            f"Acquired: {self.acquired}\n"
+            f"Produced: {self.produced}"
+        )
+
+class AcpState(BaseModel):
+    inventory: AcpInventory
+    jobs: AcpJobs
+
+    def __str__(self) -> str:
+        return (
+            f"🤖 Agent State".center(50, '=') + "\n"
+            f"{str(self.inventory)}\n"
+            f"{str(self.jobs)}\n"
+            f"State End".center(50, '=')
+        )
+
+def to_serializable_dict(obj: Any) -> Any:
+    if isinstance(obj, Enum):
+        return obj.value
+    elif isinstance(obj, dict):
+        return {k: to_serializable_dict(v) for k, v in obj.items()}
+    elif isinstance(obj, list):
+        return [to_serializable_dict(item) for item in obj]
+    elif hasattr(obj, "__dict__"):
+        return {
+            k: to_serializable_dict(v)
+            for k, v in vars(obj).items()
+            if not k.startswith("_")
+        }
+    else:
+        return obj
+

plugins/acp/examples/agentic/.env.example

@@ -0,0 +1,28 @@
+# ACP Agents' Credentials
+WHITELISTED_WALLET_PRIVATE_KEY=<0x-your-whitelisted-wallet-private-key>
+BUYER_AGENT_WALLET_ADDRESS=<0x-your-buyer-agent-wallet-address>
+SELLER_AGENT_WALLET_ADDRESS=<0x-your-seller-agent-wallet-address>
+BUYER_ENTITY_ID=<your-buyer-entity-id>
+SELLER_ENTITY_ID=<your-seller-entity-id>
+EVALUATOR_ENTITY_ID=<your-evaluator-entity-id>
+
+# GAME API Key (get from https://console.game.virtuals.io/)
+GAME_API_KEY=<apt-your-game-api-key>
+# GAME Dev API Key (get from Virtuals' DevRels)
+GAME_DEV_API_KEY=<apt-your-game-dev-api-key>
+
+# GAME Twitter Access Token for X (Twitter) Authentication
+BUYER_AGENT_GAME_TWITTER_ACCESS_TOKEN=<apx-your-buyer-agent-game-twitter-access-token>
+SELLER_AGENT_GAME_TWITTER_ACCESS_TOKEN=<apx-your-seller-agent-game-twitter-access-token>
+
+# GAME Twitter Access Token for X (Twitter) Authentication
+BUYER_AGENT_TWITTER_BEARER_TOKEN=<your-buyer-agent-twitter-bearer-token>
+BUYER_AGENT_TWITTER_API_KEY=<your-buyer-agent-twitter-api-key>
+BUYER_AGENT_TWITTER_API_SECRET_KEY=<your-buyer-agent-twitter-api-secret-key>
+BUYER_AGENT_TWITTER_ACCESS_TOKEN=<your-buyer-agent-twitter-access-token>
+BUYER_AGENT_TWITTER_ACCESS_TOKEN_SECRET=<your-buyer-agent-twitter-access-token-secret>
+SELLER_AGENT_TWITTER_BEARER_TOKEN=<your-seller-agent-twitter-bearer-token>
+SELLER_AGENT_TWITTER_API_KEY=<your-seller-agent-twitter-api-key>
+SELLER_AGENT_TWITTER_API_SECRET_KEY=<your-seller-agent-twitter-api-secret-key>
+SELLER_AGENT_TWITTER_ACCESS_TOKEN=<your-seller-agent-twitter-access-token>
+SELLER_AGENT_TWITTER_ACCESS_TOKEN_SECRET=<your-seller-agent-twitter-access-token-secret>