Skip to main content

A lightweight, modular event system for Python applications with plugin architecture support.

Project description

Moduvent - Python Event-Driven Framework

A lightweight, modular event system for Python applications with plugin architecture support.

Features

🎯 Simple and intuitive event subscription and emission

🧩 Dynamic module loading system for extensibility

📝 Comprehensive logging with Loguru integration

🏗️ Class-based event handlers with metaclass support

🔧 Type annotations throughout for better development experience

Installation

pip install moduvent

Quick Start

Everything below can be imporrted from the moduvent package.

Define a custom event

We say an event holds data that is relevant to a certain type of event. For example, a UserLoggedIn event might hold the user ID and timestamp of the login.

class UserLoggedIn(Event):
    def __init__(self, user_id, timestamp):
        self.user_id = user_id
        self.timestamp = timestamp

Subscribe your events

Once you finished defining your events, you can subscribe some functions (both bound methods and unbound functions) to them using the subscribe decorator for unbound functions and subscribe_classmethod for bound methods.

# Unbound function
@subscribe(UserLoggedIn)
def handle_user_login(event):
    """Once a UserLoggedIn event is emitted, this function will be called."""
    # use your event data!
    print(f"User {event.user_id} logged in at {event.timestamp}")

# Bound method
class UserManager(EventAwareBase):
    @subscribe_classmethod(UserLoggedIn)
    def on_user_login(self, event):
        """Once a UserLoggedIn event is emitted, this method will be called."""
        # use your event data here!
        print(f"UserManager noticed login: {event.user_id}")

The regirstration of a bound method is realized by inherting from the EventAwareBase class, which provides a metaclass that automatically registers the class method as an event handler when the class is instantiated.

Emit events

if __name__ == "__main__":
    emit(UserLoggedIn(user_id=123, timestamp="2023-01-01 12:00:00"))
    # or anywhere else in your code

Unsubscribe events

You can unsubscribe subscriptions in many ways:

# Unsubscribe a function from an event type
unsubscribe(handle_user_login, UserLoggedIn)
# or
unsubscribe(a_user_manager_instance.handle_user_login, UserLoggedIn)

# Unsubscribe all functions from an instance
unsubscribe_instance(a_user_manager_instance)

# Unsubscribe a function from all event types
remove_function(handle_user_login)

# Unsubscribe all functions from an event type
clear_event_type(UserLoggedIn)

Module System

Moduvent includes a dynamic module loader for plugin architecture:

from moduvent import discover_modules

# Load all modules from the 'modules' directory (default)
discover_modules()

# Or specify a custom directory
discover_modules("plugins")

This will try to load all modules in the specified directory and register their event handlers if possible.

API Reference

Core Classes

  • Event: Base class for all events

  • EventManager: Central event system coordinator

  • EventAwareBase: Base class for event-handling components

  • ModuleLoader: Dynamic module loader

Decorators

  • subscribe(*event_types): Decorator for functions to subscribe to events

  • subscribe(*event_types): Decorator for functions to subscribe to events

  • subscribe_classmethod(*event_types): Decorator for class methods

Functions

  • emit(event): Emit an event to all subscribers

  • discover_modules(modules_dir="modules"): Discover and load modules from a directory

  • unsubscribe(self, func: Callable[[Event], None], event_type: Type[Event]): Unsubscribe a function from an event type

  • unsubscribe_instance(self, instance: object): Unsubscribe all functions from an instance

  • remove_function(self, func: Callable[[Event], None]): Unsubscribe a function from all event types

  • clear_event_type(self, event_type: Type[Event]): Unsubscribe all functions from an event type

Module Structure

Modules should be placed in a directory (default: modules) with a structure similar as the following:

modules/
    analytics/
        __init__.py
        events.py
        ...
    auth/
        __init__.py
        ...
    notifications/
        __init__.py
        ...

Configuration

Moduvent uses loguru for logging, which can be configured using the logger object.

from moduvent import logger

# Intercept standard logging
logger.add(
    "moduvent.log",
    rotation="10 MB",
    retention="10 days",
    level="DEBUG"
)

Contributing

Contributions are welcome! Please feel free to submit a Pull Request.

License

This project is licensed under the MIT License.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

moduvent-1.0.tar.gz (6.7 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

moduvent-1.0-py3-none-any.whl (6.7 kB view details)

Uploaded Python 3

File details

Details for the file moduvent-1.0.tar.gz.

File metadata

  • Download URL: moduvent-1.0.tar.gz
  • Upload date:
  • Size: 6.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: uv/0.8.2

File hashes

Hashes for moduvent-1.0.tar.gz
Algorithm Hash digest
SHA256 c19d0e98756cf894ed14f53ca416afa9e817c9c409c18c3837f6ffdbc5655313
MD5 bfd7ad811009aa4a1d633821b0bf1b9e
BLAKE2b-256 02ac90863317ecf7d17d5f3263b76422300587b0df9252c7d4ec450784b1cc64

See more details on using hashes here.

File details

Details for the file moduvent-1.0-py3-none-any.whl.

File metadata

  • Download URL: moduvent-1.0-py3-none-any.whl
  • Upload date:
  • Size: 6.7 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: uv/0.8.2

File hashes

Hashes for moduvent-1.0-py3-none-any.whl
Algorithm Hash digest
SHA256 e144256572c81fc2a9c96a2f3ef05c6627958d3125c4dcda26d21f54d3cfe6f7
MD5 13b79d0bfead10b03ae802a7539581b8
BLAKE2b-256 a89bb160dda24d95b784444d116c8b9e881bb9843e5ae931e7df5571e7ccaa80

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page