Upload 7 files

cryptopanic_news.py

@@ -0,0 +1,44 @@
+import requests
+
+def get_posts(
+    auth_token: str,
+    kind: str = None,          # e.g. "news", "blogs", "videos"
+    currencies: list = None,   # e.g. ["BTC", "ETH"]
+    regions: list = None,      # e.g. ["en"] or country codes
+    public: bool = True,        # whether to include public posts
+    filter_duplicates: bool = True,
+    page: int = 1,
+    filter: str = None          # a general filter string
+) -> dict:
+    """
+    Fetch posts from CryptoPanic.
+    """
+    API_BASE = "https://cryptopanic.com/api/developer/v2"
+    #url = f"{API_BASE}/posts/"
+    url = "https://cryptopanic.com/api/developer/v2/posts/"
+    headers = {
+        "Accept": "application/json"
+    }
+    params = {
+        "auth_token": auth_token,
+        "public": "true" if public else "false",
+        "page": page,
+    }
+    if kind:
+        params["kind"] = kind
+    if currencies:
+        print(currencies)
+        # CryptoPanic expects multiple items comma-separated or repeated parameters
+        # Checking docs: uses comma-separated list.  
+        params["currencies"] = ",".join(currencies)
+    if regions:
+        params["regions"] = ",".join(regions)
+    if filter_duplicates:
+        params["filter_duplicates"] = "true"
+    if filter:
+        params["filter"] = filter
+
+    response = requests.get(url, params=params, headers=headers)
+    response.raise_for_status()
+    print(url)
+    return response.json()

cryptopanic_news_server.py

@@ -0,0 +1,47 @@
+from mcp.server.fastmcp import FastMCP
+from cryptopanic_news import get_posts
+import os
+from dotenv import load_dotenv
+load_dotenv(override=True)
+
+mcp = FastMCP("cryptopanic_news_server")
+
+@mcp.tool()
+async def get_crypto_news(currencies_ls: list | str | None = None) -> str:
+    """Fetch latest cryptocurrency news from CryptoPanic.
+
+    Args:
+        currencies_ls: The list of cryptocurrency symbols to filter news by. Accepts a single string (e.g. "BTC") or a list of symbols (e.g. ["HYPE", "ETC", "BTC", "XRP"]). 
+
+        If set to None, retrieves the general CryptoPanic news feed 
+        without filtering by any specific currency.
+    """
+    token = os.getenv("CRYPTOPANIC_API_KEY")
+    if not token:
+        return "Error: CRYPTOPANIC_API_KEY not set."
+
+    # Allow a single string or a list
+    if isinstance(currencies_ls, str):
+        currencies_ls = [currencies_ls]
+
+    data = get_posts(
+        auth_token=token,
+        kind="news",
+        currencies=currencies_ls,
+        page=1
+    )
+
+    if not isinstance(data, dict):
+        return f"Error: Unexpected API response: {data!r}"
+
+    results = []
+    for post in data.get("results", []):
+        title = post.get("title") or "No title"
+        desc = post.get("description") or ""
+        pub  = post.get("published_at") or "Unknown time"
+        results.append(f"title: {title}\n{desc[:200]}\npublished at: {pub}\n")
+
+    return "\n".join(results) if results else "No recent crypto news found."
+
+if __name__ == "__main__":
+    mcp.run(transport='stdio')

hype_accounts.py

@@ -0,0 +1,63 @@
+# uv pip install hyperliquid-python-sdk pandas numpy python-dotenv
+import os
+import json
+import eth_account
+import numpy as np
+import pandas as pd
+from eth_account.signers.local import LocalAccount
+
+from hyperliquid.exchange import Exchange
+from hyperliquid.info import Info
+from hyperliquid.utils import constants
+
+from dotenv import load_dotenv
+from datetime import datetime, timezone
+
+
+# Load environment variables
+load_dotenv(override=True)
+
+# https://github.com/hyperliquid-dex/hyperliquid-python-sdk/blob/master/examples/example_utils.py
+def setup(base_url=constants.MAINNET_API_URL, skip_ws=False, perp_dexs=None):
+    account: LocalAccount = eth_account.Account.from_key(os.getenv("HYPERLIQUID_PRIVATE_KEY"))
+    address = os.getenv("HYPERLIQUID_ACCOUNT_ADDRESS") # config["account_address"]
+    if address == "":
+        address = account.address
+    print("Running with account address:", address)
+    if address != account.address:
+        print("Running with agent address:", account.address)
+    info = Info(base_url, skip_ws, perp_dexs=perp_dexs)
+    user_state = info.user_state(address)
+    spot_user_state = info.spot_user_state(address)
+    margin_summary = user_state["marginSummary"]
+    if float(margin_summary["accountValue"]) == 0 and len(spot_user_state["balances"]) == 0:
+        print("Not running the example because the provided account has no equity.")
+        url = info.base_url.split(".", 1)[1]
+        error_string = f"No accountValue:\nIf you think this is a mistake, make sure that {address} has a balance on {url}.\nIf address shown is your API wallet address, update the config to specify the address of your account, not the address of the API wallet."
+        raise Exception(error_string)
+    exchange = Exchange(account, base_url, account_address=address, perp_dexs=perp_dexs)
+    return address, info, exchange
+
+def long_short_shares_mkt_price(symbol, value, leverage, is_buy) -> str:
+    address, info, exchange = setup()
+    end_time = int(datetime.now(timezone.utc).timestamp() * 1000)  # Current time in ms
+    start_time = int(datetime.now(timezone.utc).timestamp() * 1000)  # Current time in ms
+    close_price = float(info.candles_snapshot(symbol, "1m", start_time, end_time)[0]['c'])
+    coins_metadata_df = pd.DataFrame(info.meta()['universe'])
+    rounding_decimals = coins_metadata_df[coins_metadata_df['name']==symbol]['szDecimals'].values[0]
+    quantity = np.round(float(value)/float(close_price),rounding_decimals)
+    print(quantity)
+    mkt_order_result = exchange.market_open(
+        name=symbol, 
+        is_buy=is_buy, 
+        sz=quantity, 
+        px=None,
+        slippage=0.01
+    )
+    is_cross = True
+    user_state = info.user_state(address)
+    for asset_position in user_state["assetPositions"]:
+        if asset_position["position"]["coin"] == symbol:
+            print(f"Current leverage for {symbol}:", json.dumps(asset_position["position"]["leverage"], indent=2))
+    leverage_position = exchange.update_leverage(leverage, symbol, is_cross)
+    return {'mkt_order_result': mkt_order_result, 'leverage_position': leverage_position}

hype_accounts_server.py

@@ -0,0 +1,59 @@
+from mcp.server.fastmcp import FastMCP
+from hype_accounts import setup, long_short_shares_mkt_price
+
+mcp = FastMCP("hype_accounts_server")
+
+@mcp.tool()
+async def get_account_details() -> dict:
+    """Get cash balance, cryptocurrency holdings and PNL of hyperliquid account.
+    """
+    account_details_dict = {
+        "holdings": None,
+        "cash_balance": None,
+        "profit_and_loss": None
+    }
+    address, info, exchange = setup()
+    user_state = info.user_state(address)
+    account_details_dict["cash_balance"] = user_state['marginSummary']['accountValue']
+    if user_state['assetPositions'] == []:
+        account_details_dict["holdings"] = "No holdings"
+    else:
+        account_details_dict["holdings"] = user_state['assetPositions']
+    account_details_dict["profit_and_loss"] = exchange.info.portfolio(address)[3][1]['pnlHistory'][-1][1]
+
+    return account_details_dict
+
+@mcp.tool()
+async def long_perps_mkt_price(symbol: str, value:float, leverage:int) -> str:
+    """Create a long position for a cryptocurrency perpetual contract at market price.
+
+    Args:
+        symbol: The symbol of the cryptocurrency (e.g., "HYPE","ETC","BTC","XRP").
+        value: The USD value to long.
+        leverage: The leverage to use for the position.
+    """
+    return str(long_short_shares_mkt_price(symbol, value, leverage, is_buy=True))
+
+@mcp.tool()
+async def short_perps_mkt_price(symbol: str, value:float, leverage:int) -> str:
+    """Create a short position for a cryptocurrency perpetual contract at market price.
+
+    Args:
+        symbol: The symbol of the cryptocurrency (e.g., "HYPE","ETC","BTC").
+        value: The USD value to short.
+        leverage: The leverage to use for the position.
+    """
+    return str(long_short_shares_mkt_price(symbol, value, leverage, is_buy=False))
+
+@mcp.tool()
+async def close_perps_mkt_price(symbol: str) -> str:
+    """Close the position for a cryptocurrency perpetual contract at market price.
+
+    Args:
+        symbol: The symbol of the cryptocurrency (e.g., "HYPE","ETC","BTC").
+    """
+    _, _, exchange = setup()
+    return str(exchange.market_close(symbol))
+
+if __name__ == "__main__":
+    mcp.run(transport='stdio')

memories.json

@@ -0,0 +1,5 @@
+{"timestamp": "2025-10-11T16:21:26.049373", "summary": "Trades executed as planned:\n\n- Added a long BTC position worth $10 at 3x leverage.\n- Opened a short XRP position with $10 size at 3x leverage at an average price of about $2.4567.\n- Closed the existing long LTC position fully at an average price of about $98.955.\n- Added to the ZEC long position with about $10 value at 3x leverage, average price around $266.42.\n\nCurrent portfolio now has increased exposure to BTC and ZEC aligned with bullish momentum and medium-term bullish news outlook. LTC exposure was removed due to lack of signals, and a short position was added on XRP given bearish pressure and whale selling.\n\nCash balance is around $32 remaining for any further opportunities. Overall, the portfolio is positioned to benefit from both growth in BTC/ZEC and short-term declines or weakness in XRP.\n\nI will continue monitoring price and news for any updates or new trading opportunities. Let me know if you need further analysis or adjustments."}
+{"timestamp": "2025-10-11T16:45:07.448681", "summary": "Step 1: Current holdings and balance review:\n- Holdings: BTC (0.00031 BTC, 3x leveraged long), ETH (0.0053 ETH, 3x leveraged long), ZEC (0.13 ZEC, 3x leveraged long)\n- Cash balance: $62.60\n- Unrealized PnL positive, with ZEC showing strong gains; BTC slightly underwater, ETH slightly positive.\n\nStep 2: Latest news and opportunities summary:\n- BTC has rallied near previous all-time highs (~$126K), with strong demand and an implied volatility spike. Long opportunities on dips (~$120K), target ~$180K; caution around upcoming options expiry volatility.\n- ETH consolidating with elevated volatility; long above $4,600-$4,800 possible, risk below $4,250.\n- ZEC and privacy coins are on a strong rally with institutional interest; long possible but watch overbought signals and corrections.\n- XRP faces heavy whale selling and bearish momentum, with spot ETF approval as a conditional reversal catalyst. Presently a short candidate.\n- Emerging altcoins like Railgun showing high volatility and gains, but higher risk.\n\nStep 3: Technical indicators on 1-hour timeframe:\n- BTC: Bearish momentum indicated by MACD crossover below signal line, negative accumulation/distribution, price below EMA(20), stochastic RSI neutral. Current price ~114,700.\n- ETH: Bearish momentum, MACD below signal, negative distribution, price near mid consolidation zone (~4367), stochastic RSI below 50.\n- ZEC: Bullish momentum with MACD above signal line, accumulation continuing, but stochastic RSI overbought (~95%), current price ~237. Potential short-term pullback risk.\n- XRP: Bearish overall; MACD negative, EMA downtrend, negative accumulation, stochastic RSI often oversold, price ~2.44-2.48.\n\nStep 4: Recommendations and trades:\n- BTC: Wait for a dip towards $120K (current 114.7K is below suggested support for buying). No new long yet. Hold existing long.\n- ETH: Price consolidating, bearish signals dominate; no clear long signal unless price breaks above $4600-4800. Hold current.\n- ZEC: Strong momentum ongoing but stochastic RSI overbought; no new long additions now, potentially consider partial profit-taking if short-term pullback confirmed.\n- XRP: Bearish signals confirmed with whale selling; initiate a short position using part of cash balance to capitalize on downside.\n- Cash available: $62.60 \u2014 use about $30-$40 to short XRP at market with 3x leverage.\n\nI will execute the following trade now:\n- Short XRP perpetual contract, $35 size, 3x leverage.\n\nNo other trade actions currently best given risk/reward and technicals.\n\nProceeding with the short XRP trade now."}
+{"timestamp": "2025-10-11T16:48:19.104493", "summary": "Trade executed: Added a $35 size long position on ZEC perpetual contract with 3x leverage at an average price of about $279.39.\n\nSummary:\n- Current holdings after the trade: BTC long, ETH long, and increased exposure to ZEC long.\n- Cash balance remains around $28.45.\n- No current trades on XRP due to mixed signals.\n- Strategy is to hold BTC and ETH while capitalizing on the potential upside move in ZEC amid its stabilizing momentum.\n- Will continue monitoring price action and news for further opportunities or risks.\n\nLet me know if you want me to research or trade other cryptocurrencies or adjust existing positions."}
+{"timestamp": "2025-10-11T17:03:41.710319", "summary": "Trade executed: Opened a long position on ADA perpetual contract with $30 value at 3x leverage at an average price of about $0.67879.\n\nSummary:\n- Holdings: BTC, ETH, ZEC (all long), plus new ADA long position.\n- Cash balance after trade: approximately $35.42 remaining.\n- Strategy: Hold existing BTC and ETH longs, monitor ZEC for pullback, avoid XRP for now, and capitalize on promising altcoin momentum with ADA long.\n- Continuing to monitor price action and news for further opportunities or risks.\n\nLet me know if you want me to research or trade other cryptocurrencies or adjust existing positions."}
+{"timestamp": "2025-10-11T17:11:27.846277", "summary": "Trades executed:\n- Opened a short position on XRP perpetual contract for $30 size at 3x leverage, average short price ~2.5006.\n- Added a long position on ADA perpetual contract for $30 size at 3x leverage, average long price ~0.67957.\n\nSummary:\n- Holdings remain BTC, ETH, ADA (now increased), and ZEC longs; new short position on XRP.\n- Cash balance will be approximately $5 remaining.\n- Strategy: Hold existing BTC and ETH longs; capitalize on ADA's momentum with added long; use short on weak XRP setup to profit from downside.\n\nI will continue monitoring prices and news for further opportunities or needed adjustments. Let me know if you want me to research or manage any other cryptocurrencies."}

memory_utils.py

@@ -0,0 +1,53 @@
+# memory_utils.py
+import json
+import pandas as pd
+from datetime import datetime
+from pathlib import Path
+from typing import Optional, List, Dict, Any
+
+
+MEMORY_FILE = Path("memories.json")
+
+def load_memories(n: int = 3) -> list[str]:
+    """
+    Load the last n summarized memories from the JSONL file.
+    Returns a list of summary strings.
+    """
+    if not MEMORY_FILE.exists():
+        return []
+    with open(MEMORY_FILE, "r", encoding="utf-8") as f:
+        lines = [json.loads(l) for l in f if l.strip()]
+    return [m["summary"] for m in lines[-n:]]
+
+def save_memory(summary: str):
+    """
+    Append a new memory summary to the JSONL file.
+    Each line is a JSON object: {"timestamp": "...", "summary": "..."}
+    """
+    entry = {"timestamp": datetime.now().isoformat(), "summary": summary}
+    with open(MEMORY_FILE, "a", encoding="utf-8") as f:
+        f.write(json.dumps(entry) + "\n")
+
+def show_memories(n: int = 5) -> str:
+    """
+    Return a formatted string showing the latest n memories.
+    Useful for displaying in Gradio or CLI.
+    """
+    memories = load_memories(n)
+    if not memories:
+        return "No memories yet."
+    formatted = "\n\n".join(
+        [f"🕒 Memory {i+1}: {m}" for i, m in enumerate(memories[::-1])]
+    )
+    return formatted
+
+
+def load_memories_df(n: Optional[int] = None):
+    """
+    Return recent memories as a pandas DataFrame (newest first).
+    """
+    with open("memories.json", "r", encoding="utf-8") as f:
+        lines = [json.loads(line) for line in f if line.strip()]
+    df = pd.DataFrame(lines)
+
+    return df.tail(n).iloc[::-1] if n else df.iloc[::-1]

requirements.txt

@@ -0,0 +1,11 @@
+gradio
+pandas
+numpy
+python-dotenv
+openai
+openai-agents
+fastmcp
+cryptopanic-news
+hyperliquid-python-sdk
+eth-account
+hype-accounts-server