fastmcp_server.cpython-310.pyc•7.96 kB
o
��\h�/ � @ s d dl Z d dlZd dlZd dlmZmZmZ d dlmZ d dl
m Z d dl m
Z
d dlmZmZmZmZ d dlmZ dZe jed� e �d �ZG d
d � d �Zdad d
� Zdd� Z dee ef de fdd�Z dee fdd�Z e dkr~dd� Z!e �"e!� � dS dS )� N)�Dict�Any�List)�Server)� stdio_server)�Tool� TextContent�CallToolResult�ListToolsResult)�SupplyChainToolsz'AIzaSyB-d7vpvd2W8kXyVmfjn7XJNiZmDNP6hHM)Zapi_keyzgemini-2.0-flash-expc @ s~ e Zd Zdd� Zdd� Zdd� Zdeeef defd d
�Z d edeeef defd d
�Z
dd� Z dd� Z de
e fdd�ZdS )�
FastMCPServerc C s, t d�| _t� | _| �� | �� d| _d S )Nzsupply-chain-optimizerF)r �serverr �tools� setup_tools�
setup_prompts�
is_running��self� r �;/Users/anshriyal/Downloads/github/FastMCP/fastmcp_server.py�__init__ s
zFastMCPServer.__init__c s6 � j �� dd� �}� j �� dtdtf� fdd� �}dS )z/Register all supply chain tools with MCP serverc
� s� �t tddddddd�id�d �td
d ddd d�dd
d�ddd�d�g d�d�d �tddddd d�ddd�ddd�ddd�d�g d�d�d �tddddd d�ddd�d�dd gd�d �td d ddd d�dd d�d �dd!gd�d �gd"�S )#N�get_inventory_statusz:Get current inventory status for a product or all products�object�
product_id�stringz Product ID to check (optional))�type� description)r �
properties)�namer Z inputSchema�update_inventoryz5Update inventory for a specific product and warehousez
Product IDz1Warehouse (warehouse_A, warehouse_B, warehouse_C)�integerzQuantity to add/subtract)r � warehouse�quantity)r r �required�calculate_transferz;Calculate and execute inventory transfer between warehouseszSource warehousezDestination warehousezQuantity to transfer)r �from_warehouse� to_warehouser" �predict_stockoutz-Predict when a product might run out of stockzWarehouse to check)r r! r! �recommend_reorderz&Recommend reorder action for a productzQuantity to reorder)r r" r" )r )r
r r r r r �handle_list_tools sn �
���
���
������ �����z4FastMCPServer.setup_tools.<locals>.handle_list_toolsr � argumentsc
� s" �zn| dkr� j �|�d��}nP| dkr#� j �|d |d |d �}n=| dkr9� j �|d |d |d |d �}n'| d krI� j �|d |d �}n| d
krY� j �|d |d �}nd d | � �i}ttd
t j
|dd�d�gd�W S t y� } zttd
dt |�� �d�gd�W Y d }~S d }~ww )Nr r r r! r" r$ r% r& r' r( �errorzUnknown tool: �text� ��indent)r r, )�contentzError: )
r r �getr r$ r' r( r r �json�dumps� Exception�str)r r* �result�er r r �handle_call_tool_ sJ ���������z3FastMCPServer.setup_tools.<locals>.handle_call_toolN)r
Z
list_toolsZ call_toolr5 �dict)r r) r8 r r r r s
C zFastMCPServer.setup_toolsc C s d| _ d| _dS )z,Setup system prompts for different scenariosaW You are a Supply Chain Optimization Agent. Your job is to:
1. Analyze supply chain events (demand spikes, delays, cost increases)
2. Check current inventory status
3. Make intelligent recommendations for:
- Inventory transfers between warehouses
- Reorder quantities
- Stockout predictions
- Cost optimization
Always think step by step:
1. First, get current inventory status
2. Analyze the event impact
3. Check for potential stockouts
4. Recommend specific actions
5. Execute the actions if needed
Be concise but thorough in your analysis. Use the available tools to make decisions.z�New Supply Chain Event: {event_type} for {product_id} - {value}
Current Inventory Status:
{inventory_status}
Please analyze this event and recommend appropriate actions using the available tools.N)�
system_prompt�event_prompt_templater r r r r � s
zFastMCPServer.setup_prompts�event�returnc
� s� �z5| j �|�d��}| jj|�d�|�d�|�d�tj|dd�d�}| j� d|� �}| �||�I dH }|W S t yO } z
d t
|�� �W Y d}~S d}~ww )
z7Process a supply chain event with parallel tool callingr �
event_type�valuer- r. )r> r r? �inventory_status�
NzError processing event: ) r r r1 r; �formatr2 r3 r: � _process_with_gemini_and_toolsr4 r5 )r r< r@ Z event_promptZ full_prompt�responser7 r r r �process_event_parallel� s � ���z$FastMCPServer.process_event_parallel�promptc
� s� �zbt �|�}|j}g }d|�� v r.|�d�dkr.| j�dddd�}|�d|�dd �� �� d
|�� v s:d |�� v rP| j�|�d�d �}|�d
|�dd�� �� d|� d�}|ra|dd� |� 7 }|W S t
y| } z
dt | �� �W Y d} ~ S d} ~ ww )zFProcess prompt with Gemini and execute tools in parallel when possibleZtransferr �P001Z warehouse_BZ warehouse_A� z
TRANSFER: �actionzTransfer executedZreorder�order�2 z REORDER: zReorder recommendedz
AI Analysis:
rA zExecuted Actions:
�
zError in AI processing: N) �modelZgenerate_contentr, �lowerr1 r r$ �appendr( �joinr4 r5 )
r rF r< rD Z
response_textZactionsZtransfer_resultZreorder_resultZfinal_responser7 r r r rC � s0 �
�
� ��z,FastMCPServer._process_with_gemini_and_toolsc � sB �t d� t d� | j�� }t dt|�� d�� d| _t d� dS )zStart the MCP serveru, 🚀 Starting FastMCP Supply Chain Server...u 📊 Loading inventory data...u ✅ Loaded z productsTu ✅ FastMCP Server is running!)�printr r �lenr )r Zinitial_inventoryr r r � start_server� s �
zFastMCPServer.start_serverc � s. �t d� | j�� t d� d| _t d� dS )z"Stop the server and save inventoryu 💾 Saving inventory changes...u ✅ Inventory saved!Fu 🛑 FastMCP Server stopped!N)rQ r Zsave_inventoryr r r r r � stop_server� s �
zFastMCPServer.stop_serverc C s
| j �� S )zGet all recorded actions)r �get_actions_logr r r r rU � s
z FastMCPServer.get_actions_logN)�__name__�
__module__� __qualname__r r r r r5 r rE rC rS rT r rU r r r r r s n %r c � s �t � at�� I d H S �N)r �server_instancerS r r r r rS s �rS c � s �t r t �� I d H d S d S rY )rZ rT r r r r rT s ��rT r< r= c � s �t r t �| �I d H S dS )NzServer not running)rZ rE )r< r r r �
process_event s �r[ c C s t rt �� S g S rY )rZ rU r r r r rU s rU �__main__c � s@ �t � I d H dddd�} t| �I d H }t|� t� I d H d S )NZ DEMAND_SPIKErG z40 units)r> r r? )rS r[ rQ rT )Z
test_eventr6 r r r �test s � �r] )#�asyncior2 �os�typingr r r Zgoogle.generativeaiZ generativeaiZgenaiZ
mcp.serverr Zmcp.server.stdior Z mcp.typesr r r r
Zsupply_chain_toolsr ZGEMINI_API_KEYZ configureZGenerativeModelrM r rZ rS rT r5 r[ rU rV r] �runr r r r �<module> s.
p �