Subscribing to Events

const threadify = await Threadify.connect('your-api-key', 'my-service', {
  engineUrl: 'http://localhost:8081',
  maxInFlight: 50  // Default: 10, Max: 100
});

conn, err := threadify.Connect(ctx, "your-api-key", 
    threadify.WithServiceName("my-service"),
    threadify.WithEngineURL("http://localhost:8081"),
    threadify.WithMaxInFlight(50), // Default: 10, Max: 100
)
if err != nil {
    log.Fatal(err)
}

from threadify import Threadify

connection = await Threadify.connect(
    "your-api-key",
    service_name="my-service",
    engine_url="http://localhost:8081",
    max_in_flight=50,  # Default: 10, Max: 100
)

// Thread events (2 parameters)
threadify.on('thread.completed', (notification) => {
  console.log('Thread completed');
  notification.ack();
});

// Step events (3 parameters: event, stepName, handler)
threadify.on('step.failed', 'payment_processed', (notification) => {
  console.error('Payment failed:', notification.message);
  notification.ack();
});

// Contract-specific (use @ syntax)
threadify.on('rule.violated', 'product_delivery@order_placed', (notification) => {
  console.error('Contract violation:', notification.message);
  notification.ack();
});

// Thread events
err := conn.Subscribe(ctx, "thread.completed", "", func(n *threadify.Notification) {
    fmt.Println("Thread completed")
    n.Ack()
})
if err != nil {
    log.Fatal(err)
}

// Step events (specify step name)
err = conn.Subscribe(ctx, "step.failed", "payment_processed", func(n *threadify.Notification) {
    fmt.Printf("Payment failed: %s\n", n.Message)
    n.Ack()
})
if err != nil {
    log.Fatal(err)
}

// Contract-specific (use @ syntax)
err = conn.Subscribe(ctx, "rule.violated", "product_delivery@order_placed", func(n *threadify.Notification) {
    fmt.Printf("Contract violation: %s\n", n.Message)
    n.Ack()
})
if err != nil {
    log.Fatal(err)
}

# Thread events
def on_thread_completed(notification):
    print("Thread completed")
    notification.ack()

connection.subscribe("thread.completed", on_thread_completed)

# Step events (specify step name)
def on_payment_failed(notification):
    print(f"Payment failed: {notification.message}")
    notification.ack()

connection.subscribe("step.failed", "payment_processed", on_payment_failed)

# Contract-specific (use @ syntax)
def on_contract_violation(notification):
    print(f"Contract violation: {notification.message}")
    notification.ack()

connection.subscribe("rule.violated", "product_delivery@order_placed", on_contract_violation)