Feature/dpsn plugin

[AnishRane]

Summary

The DPSN Plugin enables Virtuals Protocol agents to subscribe to and interact with any data streams available on the DPSN Data Streams Store.

To provide personalized data streams to Virtual Protocol agents for them to interact with , create and publish data into your own DPSN data streams using dpsn-client

Links

• Plugin documentation
• Other useful links:
  • DPSN Official Website
  • DPSN js library

Plugin Documentation Checklist

• README Validation
  • README.md file exists in the plugin root folder
  • Clear installation instructions
  • Usage examples with code snippets
  • List of features and capabilities

Dev Testing

Run Example File to Check Agent Behaviour

1. Refer to the configuration in README.md.
2. Navigate to the DPSN plugin examples folder:

   cd /plugins/dpsn/examples

3. Install dependencies:

   pip install -e .

4. Run the agent:

   python3 dpsn_agent.py

Logs Output

skipped the large task descriptions of agent for simplicity

=== DPSN AGENT STARTING ===
This agent will:
1. Subscribe to the SOLUSDT/ohlc topic
2. Collect messages for 2 minutes or at least 3 messages
3. Unsubscribe and clean up
4. Exit automatically

Task: CurrentTaskResponse(
  task='Subscribe to 0xe14768.../SOLUSDT/ohlc topic',
  task_reasoning='...initial step in my personality description...',
  ...
)
Action Selected: subscribe
Action Args: {'topic': {'value': '0xe14768.../SOLUSDT/ohlc'}}
2025-04-01 15:44:13,359 - DpsnPlugin - INFO - Initializing DpsnClient connection (first time)...
...
2025-04-01 15:44:14,457 - DpsnPlugin - INFO - Successfully subscribed to topic: 0xe14768.../SOLUSDT/ohlc

current_task = CurrentTaskResponse(
  task='Process messages on the 0xe14768.../SOLUSDT/ohlc topic',
  task_reasoning='...check_collection_status function...',
  ...
)
Action Selected: check_collection_status
Function result: ... collection_complete: True ...

Action Selected: unsubscribe
Action Args: {'topic': {'value': '0xe14768.../SOLUSDT/ohlc'}}
2025-04-01 15:44:48,455 - DpsnPlugin - INFO - Successfully unsubscribed from topic

'''As per mentioned tasks agent shuts down DPSN client'''

Action Selected: shutdown
2025-04-01 15:44:50,684 - DpsnPlugin - INFO - DPSN client shutdown complete.

'''Marks agent's task completion and exits code'''

Action Type: WAIT
Task ended completed or ended (not possible with current actions)
Agent state updated: Task marked as complete.

[Ang-dot]

Hey thanks for the PR, @AnishRane! Comprehensive with extensive usage examples. Left some comments for the PR, overall looks good but would love if you could package the plugin to PyPi for direct install and import instead of using relative path imports, thanks!

[Ang-dot]

Overall looks good to me @AnishRane! Once the plugin is up in PyPi then we can have a final test and merge!

[Ang-dot]

Validated that DPSN Plugin is working and package is available on PyPi

Screen Record
https://drive.google.com/file/d/1OKoHmxcpzIceW1pWgGAodOPS9gF5NZGZ/view?usp=drive_link

[Ang-dot]

Thanks again for the PR, @AnishRane!