Add p8p minimal workflow runner

Author: stife

README.md

@@ -22,3 +22,9 @@ Version 0.224.1
 ## Facebook Page Management
 
 A simple web interface to manage the Facebook page **"Techno auf den Augen"** is included in the [`facebook-manager`](./facebook-manager) directory. It relies on Express and the built-in Node.js `fetch` API to list and create posts and display basic page insights. Further documentation is available in the [Facebook manager wiki](./facebook-manager/WIKI.md).
+
+## p8p - open source workflows
+
+An experimental project named **p8p** is included in the [`p8p`](./p8p) directory.
+It provides a very small workflow runner that can load and execute JSON-based
+workflows. Use it as a starting point for building your own automation tool.

p8p/README.md

@@ -0,0 +1,38 @@
+# p8p
+
+p8p is a minimal open source workflow runner inspired by [n8n](https://n8n.io). It allows defining simple workflows in JSON and executing them either via a small HTTP API or from the command line.
+
+## Features
+
+- Create workflows via HTTP POST `/workflow/:name`
+- Run saved workflows via HTTP POST `/run/:name`
+- CLI mode to execute a workflow file directly
+- Supports basic `log`, `delay`, and `http` steps
+
+## Usage
+
+Install dependencies and start the server:
+
+```bash
+cd p8p
+npm install
+node cli.js
+```
+
+To run a workflow from a file:
+
+```bash
+node cli.js my-workflow.json
+```
+
+Example `my-workflow.json`:
+
+```json
+[
+  { "type": "log", "message": "Hello from p8p" },
+  { "type": "delay", "ms": 1000 },
+  { "type": "http", "url": "https://example.com" }
+]
+```
+
+This is not a full replacement for n8n but demonstrates how you might begin building your own automation tool.

p8p/cli.js

@@ -0,0 +1,62 @@
+#!/usr/bin/env node
+import fs from 'fs/promises';
+import express from 'express';
+import path from 'path';
+import { fileURLToPath } from 'url';
+
+const __dirname = path.dirname(fileURLToPath(import.meta.url));
+
+const app = express();
+app.use(express.json());
+
+// Simple in-memory workflows
+const workflows = new Map();
+
+app.post('/workflow/:name', async (req, res) => {
+  workflows.set(req.params.name, req.body);
+  res.json({ status: 'saved', workflow: req.params.name });
+});
+
+app.post('/run/:name', async (_req, res) => {
+  const flow = workflows.get(_req.params.name);
+  if (!flow) return res.status(404).json({ error: 'Workflow not found' });
+  await runWorkflow(flow);
+  res.json({ status: 'executed', workflow: _req.params.name });
+});
+
+async function runWorkflow(steps) {
+  for (const step of steps) {
+    switch (step.type) {
+      case 'log':
+        console.log(step.message);
+        break;
+      case 'delay':
+        await new Promise(resolve => setTimeout(resolve, step.ms || 0));
+        break;
+      case 'http':
+        try {
+          const res = await fetch(step.url, { method: step.method || 'GET' });
+          console.log('HTTP', res.status, step.url);
+        } catch (err) {
+          console.error('HTTP error', err.message);
+        }
+        break;
+      default:
+        console.warn('Unknown step', step);
+    }
+  }
+}
+
+const PORT = process.env.PORT || 3000;
+app.listen(PORT, () => {
+  console.log(`p8p listening on port ${PORT}`);
+});
+
+// CLI usage: load workflow from file and run
+if (process.argv[2]) {
+  const filePath = path.resolve(process.cwd(), process.argv[2]);
+  fs.readFile(filePath, 'utf8').then(data => {
+    const flow = JSON.parse(data);
+    runWorkflow(flow);
+  });
+}

p8p/package.json

@@ -0,0 +1,13 @@
+{
+  "name": "p8p",
+  "version": "0.1.0",
+  "description": "Minimal open source workflow engine inspired by n8n",
+  "main": "cli.js",
+  "type": "module",
+  "bin": {
+    "p8p": "./cli.js"
+  },
+  "dependencies": {
+    "express": "^4.19.0"
+  }
+}