Merge commit 'b54e107d445a7dc40ed3f204dc6a6bdaaa9d31ff' into feat/acp

Author: stevensf1998

plugins/acp/acp_plugin_gamesdk/acp_client.py

@@ -169,5 +169,5 @@ def reset_state(self, wallet_address: str ) -> None:
             headers={"x-api-key": self.api_key}
         )
 
-        if response.status_code != 200:
+        if response.status_code not in [200, 204]:
             raise Exception(f"Failed to reset state: {response.status_code} {response.text}")

plugins/acp/acp_plugin_gamesdk/acp_plugin.py

@@ -50,7 +50,7 @@ def add_produce_item(self, item: IInventory) -> None:
         self.produced_inventory.append(item)
 
     def reset_state(self) -> None:
-        self.acp_client.reset_state()
+        self.acp_client.reset_state(self.acp_client.wallet_address)
 
     def get_acp_state(self) -> Dict:
         server_state = self.acp_client.get_state()

plugins/acp/tools/reset_states.py

@@ -0,0 +1,30 @@
+import os
+from acp_plugin_gamesdk.acp_plugin import AcpToken, AcpPlugin, AdNetworkPluginOptions
+
+
+def reset_acp_states() -> None:
+    """Reset plugin state for all configured ACP tokens."""
+    acp_tokens = [
+        os.environ.get("ACP_TOKEN_BUYER"),
+        os.environ.get("ACP_TOKEN_SELLER")
+    ]
+
+    for token in acp_tokens:
+        try:
+            acp_plugin = AcpPlugin(
+                options=AdNetworkPluginOptions(
+                    api_key=os.environ.get("GAME_DEV_API_KEY"),
+                    acp_token_client=AcpToken(
+                        token,
+                        "https://base-sepolia-rpc.publicnode.com/"
+                    )
+                )
+            )
+            acp_plugin.reset_state()
+            print(f"Successfully reset state for token: {token}")
+        except Exception as e:
+            print(f"Failed to reset state for token {token}: {e}")
+
+
+if __name__ == "__main__":
+    reset_acp_states()