Event-driven,
same functions.

// 1. Define the trigger source — how to subscribe
const redisSubscribe = pikkuTriggerFunc<
  { channels: string[] },
  { channel: string; message: any }
>(async ({ redis }, { channels }, { trigger }) => {
  const subscriber = redis.duplicate()

  subscriber.on('message', (channel, message) => {
    // Fire the trigger with typed data
    trigger.invoke({ channel, message: JSON.parse(message) })
  })

  await subscriber.subscribe(...channels)

  // Return a teardown function for cleanup
  return async () => {
    await subscriber.unsubscribe()
    await subscriber.quit()
  }
})

// 2. Wire source to target
wireTrigger({
  name: 'order-events',
  func: onOrderEvent,   // Target: your Pikku function
})

wireTriggerSource({
  name: 'order-events',
  func: redisSubscribe,  // Source: the subscription
  input: { channels: ['orders:created', 'orders:updated'] },
})