const $move = createStore({ distance: 0 });
const $direction = createStore('left')

const moveLeft = createEvent();
const moveRight = createEvent();

variant({
  source: $move,
  key: $direction,
  target: {
    left: moveLeft,
    right: moveRight,
  }
})

const message = createEvent()

const bob = createEvent()
const alice = createEvent()
const guest = createEvent()

variant({
  source: message, 
  key: 'user',
  target: { bob, alice, __: guest }),
})

bob.watch(({text}) => {
  console.log('[bob]: ', text)
})
alice.watch(({text}) => {
  console.log('[alice]: ', text)
})

message({user: 'bob', text: 'Hello'})
// => [bob]: Hello
message({user: 'alice', text: 'Hi bob'})
// => [alice]: Hi bob

/* default case, triggered if no one condition met */
guest.watch(({text}) => {
  console.log('[guest]: ', text)
})
message({user: 'unregistered', text: 'hi'})
// => [guest]: hi

const message = createEvent()

const messageByAuthor = split(message, {
  bob: ({user}) => user === 'bob',
  alice: ({user}) => user === 'alice',
})
messageByAuthor.bob.watch(({text}) => {
  console.log('[bob]: ', text)
})
messageByAuthor.alice.watch(({text}) => {
  console.log('[alice]: ', text)
})

message({user: 'bob', text: 'Hello'})
// => [bob]: Hello
message({user: 'alice', text: 'Hi bob'})
// => [alice]: Hi bob

/* default case, triggered if no one condition met */
const {__: guest} = messageByAuthor
guest.watch(({text}) => {
  console.log('[guest]: ', text)
})
message({user: 'unregistered', text: 'hi'})
// => [guest]: hi

variant({
  source: message, 
  key: 'user',
  target: { bob, alice },
  fallback: guest,
})

guard({
  source: message,
  filter: ({user}) => user === 'alice',
  target: alice,
});

guard({
  source: message,
  filter: ({user}) => user === 'bob',
  target: bob,
});

guard({
  source: message,
  filter: ({user}) => user !== 'alice' && user !== 'bob',
  target: guest,
});

forward({
  from: message.filter({ fn: ({user}) => user === 'alice' }),
  to: alice,
})

forward({
  from: message.filter({ fn: ({user}) => user === 'bob' }),
  to: bob,
})

forward({
  from: message.filter({ fn: ({user}) => user !== 'alice' && user !== 'bob' }),
  to: guest,
})

guard({
  source: message,
  filter: ({user}) => user === 'alice',
  target: alice,
  fallback: notAlice
});

variant({
  source: sample(page, nextPage),
  target: createApi(page, {
    '/intro': () => '/article',
    '/article': () => '/pricing',
    '/pricing': () => '/signup',
  })
})

variant({
  source: uploadFx.done,
  key: gate.status,
  cases: {
    true: $uploadResult,
    false: showNotification.prepend(() => “uploaded!”)
  }
})

export function variant({ source, key, cases, clock, fn }) {
  const keyReader = typeof key === 'function'
    ? key
    : is.store(key)
      ? () => String(key.getState())
      : value => String(value[key])
  if (clock || fn) {
    source = sample({ source, ...clock && { clock }, fn })
  }
  let defaultCase = false
  for (const caseName in cases) {
    if (caseName === '__') {
      defaultCase = true
      continue
    }
    guard({
      source,
      filter: value => keyReader(value) === caseName,
      target: cases[caseName],
    })
  }
  if (defaultCase) {
    const namedCases = Object.keys(cases)
    guard({
      source,
      filter: value => !namedCases.includes(keyReader(value)),
      target: cases.__,
    })
  }
}