mirror of
https://github.com/aljazceru/nostrdvm.git
synced 2026-02-18 12:44:31 +01:00
122 lines
3.6 KiB
Python
122 lines
3.6 KiB
Python
import asyncio
|
|
import json
|
|
from pathlib import Path
|
|
|
|
import dotenv
|
|
from nostr_sdk import Keys, Client, Tag, EventBuilder, Filter, HandleNotification, Timestamp, nip04_decrypt, \
|
|
nip44_encrypt, Nip44Version, NostrSigner, Event, Kind, init_logger, LogLevel
|
|
|
|
from nostr_dvm.utils.definitions import EventDefinitions
|
|
from nostr_dvm.utils.nostr_utils import send_event, check_and_set_private_key
|
|
|
|
relay_list = ["wss://nostr.oxtr.dev", "wss://relay.nostrdvm.com"]
|
|
|
|
|
|
async def nostr_client_test_mcp_get_tools():
|
|
keys = Keys.parse(check_and_set_private_key("test_client"))
|
|
|
|
outTag = Tag.parse(["output", "application/json"])
|
|
cTag = Tag.parse(["c", "list-tools"])
|
|
alttag = Tag.parse(["alt", "This is a NIP90 Request to contact MCP server"])
|
|
relaysTag = Tag.parse(['relays'] + relay_list)
|
|
|
|
event = EventBuilder(EventDefinitions.KIND_NIP90_MCP, str("MCP request")).tags(
|
|
[outTag, alttag, cTag, relaysTag]).sign_with_keys(keys)
|
|
|
|
|
|
client = Client(NostrSigner.keys(keys))
|
|
|
|
for relay in relay_list:
|
|
await client.add_relay(relay)
|
|
|
|
await client.connect()
|
|
|
|
result = await client.send_event(event)
|
|
print(result)
|
|
return result
|
|
|
|
|
|
async def nostr_client_test_mcp_execute_tool(tool_name, tool_parameters):
|
|
keys = Keys.parse(check_and_set_private_key("test_client"))
|
|
|
|
outTag = Tag.parse(["output", "application/json"])
|
|
cTag = Tag.parse(["c", "execute-tool"])
|
|
alttag = Tag.parse(["alt", "This is a NIP90 Request to contact MCP server"])
|
|
relaysTag = Tag.parse(['relays'] + relay_list)
|
|
|
|
payload = {"name": tool_name,
|
|
"parameters": tool_parameters
|
|
}
|
|
|
|
event = EventBuilder(EventDefinitions.KIND_NIP90_MCP, json.dumps(payload)).tags(
|
|
[outTag, alttag, cTag, relaysTag]).sign_with_keys(keys)
|
|
|
|
|
|
client = Client(NostrSigner.keys(keys))
|
|
|
|
for relay in relay_list:
|
|
await client.add_relay(relay)
|
|
|
|
await client.connect()
|
|
|
|
result = await client.send_event(event)
|
|
print(result)
|
|
return result
|
|
|
|
|
|
|
|
|
|
async def nostr_client():
|
|
|
|
|
|
init_logger(LogLevel.INFO)
|
|
keys = Keys.parse(check_and_set_private_key("test_client"))
|
|
|
|
pk = keys.public_key()
|
|
print(f"Bot public key: {pk.to_bech32()}")
|
|
|
|
signer = NostrSigner.keys(keys)
|
|
client = Client(signer)
|
|
|
|
await client.add_relay("wss://relay.damus.io")
|
|
await client.add_relay("wss://nostr.mom")
|
|
await client.add_relay("wss://nostr.oxtr.dev")
|
|
await client.add_relay("wss://relay.nostrdvm.com")
|
|
await client.connect()
|
|
|
|
now = Timestamp.now()
|
|
|
|
mcp_filter = Filter().pubkey(pk).kind(Kind(6910)).limit(0)
|
|
await client.subscribe(mcp_filter, None)
|
|
|
|
#await nostr_client_test_mcp_get_tools()
|
|
await nostr_client_test_mcp_execute_tool(tool_name="get-crypto-price", tool_parameters={"symbol": "BTC"})
|
|
#await nostr_client_test_mcp_execute_tool(tool_name="echo_tool", tool_parameters={"message": "Hello"})
|
|
|
|
|
|
class NotificationHandler(HandleNotification):
|
|
async def handle(self, relay_url, subscription_id, event: Event):
|
|
print(f"Received new event from {relay_url}: {event.as_json()}")
|
|
|
|
if event.kind().as_u16() == 6910:
|
|
print(event.content())
|
|
|
|
|
|
|
|
async def handle_msg(self, relay_url, msg):
|
|
_var = None
|
|
|
|
await client.handle_notifications(NotificationHandler())
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
env_path = Path('.env')
|
|
if env_path.is_file():
|
|
print(f'loading environment from {env_path.resolve()}')
|
|
dotenv.load_dotenv(env_path, verbose=True, override=True)
|
|
else:
|
|
raise FileNotFoundError(f'.env file not found at {env_path} ')
|
|
|
|
asyncio.run(nostr_client())
|