sandbox option via Schwab API Sandbox repo

Author: Cfomodz

.gitignore

@@ -1,4 +1,6 @@
 .idea/
 __pycache__/
 .env
-token_data.json
+token_data.json
+custom/*
+tmp/*

config.py

@@ -2,15 +2,24 @@
 from dotenv import load_dotenv
 
 load_dotenv()
+SANDBOX = False
 
 
 class APIConfig:
-    API_BASE_URL = "https://api.schwabapi.com"
-    TRADER_BASE_URL = f"{API_BASE_URL}/trader/v1"
-    ACCOUNTS_BASE_URL = f"{TRADER_BASE_URL}/accounts"
-    MARKET_DATA_BASE_URL = f"{API_BASE_URL}/marketdata/v1"
-    ORDERS_BASE_URL = ACCOUNTS_BASE_URL
-    STREAMER_INFO_URL = f"{API_BASE_URL}/streamer-info"
+    if SANDBOX:
+        API_BASE_URL = "http://localhost:4020"
+        TRADER_BASE_URL = API_BASE_URL
+        ACCOUNTS_BASE_URL = f"{API_BASE_URL}/accounts"
+        MARKET_DATA_BASE_URL = f"{API_BASE_URL}/marketdata"
+        ORDERS_BASE_URL = ACCOUNTS_BASE_URL
+        STREAMER_INFO_URL = f"{API_BASE_URL}/streamer-info"
+    else:
+        API_BASE_URL = "https://api.schwabapi.com"
+        TRADER_BASE_URL = f"{API_BASE_URL}/trader/v1"
+        ACCOUNTS_BASE_URL = f"{TRADER_BASE_URL}/accounts"
+        MARKET_DATA_BASE_URL = f"{API_BASE_URL}/marketdata/v1"
+        ORDERS_BASE_URL = ACCOUNTS_BASE_URL
+        STREAMER_INFO_URL = f"{API_BASE_URL}/streamer-info"
     REQUEST_TIMEOUT = 30  # Timeout for API requests in seconds
     RETRY_STRATEGY = {
         'total': 3,  # Total number of retries to allow

main.py

@@ -34,25 +34,33 @@ async def main_stream():
 
     stream_client.stop()
 
+
 def main():
     client = APIClient()  # Initialize the API client
     accounts_api = Accounts(client)
     orders_api = Orders(client)
 
     # Get account numbers for linked accounts
-    # print(accounts_api.get_account_numbers())  # working
+    client.account_numbers = accounts_api.get_account_numbers()  # working
+    print(client.account_numbers)
 
     # Get positions for linked accounts
-    # print(accounts_api.get_all_accounts())  # working
+    print(accounts_api.get_all_accounts())  # working
 
-    sample_account = client.account_numbers[0]
-    account_hash = sample_account['accountHash']
+    sample_account = client.account_numbers[0]  # working
+    print(sample_account)
+    account_hash = sample_account['hashValue']  # working
+    print(account_hash)
 
     # Get specific account positions
-    # print(accounts_api.get_account(fields="positions"))
+    print(accounts_api.get_account(account_hash=account_hash, fields="positions"))
 
     # Get up to 3000 orders for an account for the past week
-    print(orders_api.get_orders(3000, datetime.now() - timedelta(days=7), datetime.now()).json())
+    print(orders_api.get_orders(account_hash=account_hash,
+                                max_results=3000,
+                                from_entered_time=datetime.now() - timedelta(days=7),
+                                to_entered_time=datetime.now())
+          )
 
     # Example to place an order (commented out for safety)
     """
@@ -75,11 +83,16 @@ def main():
     # print(orders_api.get_order('account_hash', order_id).json())
 
     # Get up to 3000 orders for all accounts for the past week
-    print(orders_api.get_orders(account_hash=account_hash, max_results=3000, from_entered_time=datetime.now() - timedelta(days=7), to_entered_time=datetime.now()))
+    for account in client.account_numbers:
+        account_hash = account['hashValue']
+        print(orders_api.get_orders(account_hash=account_hash, max_results=3000, from_entered_time=datetime.now() - timedelta(days=7), to_entered_time=datetime.now()))
 
     # Get all transactions for an account
-    print(accounts_api.get_account_transactions('account_hash', datetime.now() - timedelta(days=7), datetime.now(),
-                                                "TRADE").json())
+    print(accounts_api.get_account_transactions(account_hash=account_hash,
+                                                start_date=datetime.now() - timedelta(days=7),
+                                                end_date=datetime.now(),
+                                                types="TRADE")
+          )
 
     # Market-data-related requests
     quotes = Quotes(client)
@@ -98,6 +111,9 @@ def main():
     # Get an option expiration chain
     print(options.get_chains("AAPL").json())
 
+    # Get price history for a symbol
+    print(price_history.by_symbol("AAPL", period_type="day", period=1, frequency_type="minute", frequency=5).json())
+
     # Get movers for an index
     print(movers.get_movers("$DJI").json())
 
@@ -117,6 +133,6 @@ def main():
 if __name__ == '__main__':
     print("Welcome to the unofficial Schwab API interface!\n"
           "GitHub: https://github.com/Patch-Code-Prosperity/Pythonic-Schwab-API")
-    loop = get_event_loop()
-    loop.run_until_complete(main_stream())
-    # main()
+    # loop = get_event_loop()
+    # loop.run_until_complete(main_stream())
+    main()