👁 Image
ActFlow 1.1.1

<p align="center"> <img src="https://github.com/user-attachments/assets/e7750a92-fe96-4742-8327-a34978d587fe" width="200" height="200" /> </p>

👁 Build and Publish
👁 Nuget
👁 Nuget
👁 GitHub last commit (branch)
👁 GitHub commit activity (branch)
👁 Static Badge
👁 Static Badge
👁 Static Badge

ActFlow

ActFlow is a simple, no-code, workflow system that takes in a set of activities and strings them together as workflows. The intention for this is to enable you to run complex business logic by means of script files instead of hardwired integrations. This makes it significantly easier to make workflows such as one for waiting and answering emails, keep a database updated with data an LLM found from an email, integrity check data in a database, etc. The ActFlow engine in of itself is very independent and does not require any complex scheduling system to run.

<img alt="ezgif-38bb13d50e11c73e" src="https://github.com/user-attachments/assets/ab0b15c4-cb63-4206-88c4-fcab62f7cb6d" />

By its core, it consists of a set of workers and activities. Workers execute activities, while activities define some input data for the workers.

All workers and activities are JSON serializable

How to Use (CLI)

For just using ActFlow, you can install the CLI tool by entering

dotnet tool install ActFlow.CLI -g

You can then call the CLI tool by the actflow command.

How to Use (Docker)

You can also choose to use the Docker image. This requires that you have a config.json config on your computer that contains the IWorker configuration. Simply change the bind mount in the docker-compose.yaml

After you have set that up, you can start the docker container:

docker compose up -d

This will then start the HTTP server of the CLI, open on port 5523 as well as a web server where you can interact with your workflows.

Developing

Start by installing the NuGet package ActFlow into your project. This package contains the actual engine used to run the workflows. You can add whichever integration nuget package afterwards, to give you workers and activities (I will assume you have ActFlow.Integrations.Core installed for the following). You can then setup the ActFlow engine by doing the following:

var engine = new ActFlowEngine(new List<IWorker>()
{
	new NoActivityWorker("a"),
 new CreateContextWorker("b")
});

This has now defined an engine instance with two workers, NoActivityWorker with the ID a and a CreateContextWorker with the id b. The IDs are important, since they are used by activities to know what worker to run (this also means you can have multiple workers with different configurations).

You can then run the following script (represented in JSON):

{
	"Name":"test workflow",
	"Globals":{ "noactivityworker":"a", "createcontextworker":"b" },
	"Activities": [
		{
			"$type":"NoActivity",
			"WorkerID":"${{noactivityworker}}"
		},
		{
			"$type":"CreateContextActivity",
			"WorkerID":"${{createcontextworker}}",
			"Context": {
				"$type":"StringContext",
				"Text":"abc"
			}
		}
	]
}

You can execute is as:

var state = await engine.Execute(
 JsonSerializer.Deserialize<Workflow>(
 ..., 
 JsonSerializerOptions() { 
 TypeInfoResolver = 
 new DefaultJsonTypeInfoResolver()
 .WithAddedModifier(JsonExtensions.AddNativePolymorphicTypInfo) 
 }
 )
 );

This will run the script, and return the final state of the execution. The result of each step will be visible through the ContextStore property. As an example, the resulting context of the last activity will be accessible through the key b.Text where it will give the result "abc".

Using this simple system syntax, you can combine many different activities to create complex business logic.

Integrations

Each of the integrations below can be found as NuGet packages by their name.

• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • Conditional If
    • Compares two string values against each other. True or false redirects to different activity indexes in the workflow file.
  • Conditional (user) If
    • Same as the conditional if, but where one of the values is a user input.
  • Create Context
    • Directly creates a new context.
  • Insert Globals
    • Insert some global values that can be used across the entire workflow.
  • No Action
    • A placeholder activity that does nothing.
  • Load File
    • Loads the content of a file in the persistent directory into context.
  • Save File
    • Saves some text to a file in the persistent directory.
  • List Files
    • Lists files in a given path in the persistent directory.
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • DatabaseSharp
  • Execute STP
    • Execute a STP with some parameters and get the result.
  • Execute SQL
    • Execute a free SQL string and get the result.
  • Execute SQL to CSV
    • Execute a free SQL string and save the resulting table to a CSV file.
  • Insert Workflow From Databaser
    • Fetch a workflow from a database and insert it after this activity.
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • Reply to Email
    • Reply to a given email
  • Send Email
    • Send a new email
  • Wait for Email
    • Wait for a reply on a given email
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • Extract Value From JSON
    • Given some text, extract some data by means of a JSONPath
  • Extract Value From JSON File
    • Given some file, extract some data by means of a JSONPath
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • ML.NET
  • Train Text Classitifer
    • Train a text classifier with some data
  • Classify Text
    • Classify some text
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • OpenWebUISharp
  • Extract Data From Text
    • Extract data from text using a LLM
  • Extract Data From Text (RAG)
    • Extract data from text using a LLM (RAG)
  • Query
    • Query an LLM
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • Extract Values from XML
    • Given some text, extract values to a dictionary
  • Extract Values from XML file
    • Given some file, extract values to a dictionary
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • Execute Javascript
    • Execute some javascript code
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • Delay
    • Wait for some specified amount of time
  • Cron Wait
    • Wait for the next occurence from some Cron expression
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • SerializableHttps
  • Execute HTTP
    • Executes a HTTP request with automatic JSON serialization/deserialization
• 👁 Static Badge
  👁 Nuget
  👁 Nuget
  
  • Evaluate
    • Evaluate a mathmatical expression