ALF - Flow-based Application Layer Framework

antonmi · December 8, 2021, 9:31am

Hey colleagues!
I’ve returned to work on Flow-based programming in Elixir recently.
My new project is very ambitiously called ALF - Application Layer Framework :).
The core functionality is ready and I’m gradually promoting it. Please check it here GitHub - antonmi/ALF: Flow-based Application Layer Framework
There is also an introductory article in Medium
ALF — Flow-based Application Layer Framework | by Anton Mishchuk | Dec, 2021 | Medium

dmitriid · December 8, 2021, 6:45pm

Exactly what I needed

Minor nitpick: It would be awesome to have an “error handling stage”. If a stage function throws an error, it would be nice to catch it somehow

antonmi · December 8, 2021, 7:35pm

Hey @dmitriid !
I’m happy that you like it.
In ALF I decided to move error handling to the developer side.
When an error has occurred one will see a special %ALF.ErrorIP{} struct.
I’ll give you an example a bit later because I’ve found a bug related to that :).

antonmi · December 9, 2021, 7:04am

@dmitriid See for example

github.com

antonmi/ALF/blob/bf46b62fda2b85fb96bb060989a0f9e12f874030/test/integration/component_error_test.exs#L35

    
      
          setup do
            Manager.start(ErrorInStagePipeline)
          end
          
          
test "returns error immediately (skips mult_two)" do
            results =
              [1, 2, 3]
              |> Manager.stream_to(ErrorInStagePipeline)
              |> Enum.to_list()
          
          
  assert [
                     4,
                     %ErrorIP{
                       component: %ALF.Components.Stage{function: :add_one},
                       ip: %IP{} = ip,
                       error: %RuntimeError{message: "Error in :add_one"}
                     },
                     8
                   ] = results
          
          
  assert [{{:add_one, 0}, _event}] = ip.history

dmitriid · December 9, 2021, 8:17am

Thank you! I’ll check it out!