Compare commits
2 Commits
795c04fc5a
...
developmen
| Author | SHA1 | Date | |
|---|---|---|---|
|
8c2276de79 | ||
|
|
123dfc606c |
File diff suppressed because it is too large
Load Diff
411
actix_mvc_app/src/views/flows/index copy.html
Normal file
411
actix_mvc_app/src/views/flows/index copy.html
Normal file
@@ -0,0 +1,411 @@
|
||||
{% extends "base.html" %}
|
||||
|
||||
{% block title %}Flows Dashboard{% endblock %}
|
||||
|
||||
{% block content %}
|
||||
<!-- Navigation Tabs -->
|
||||
<div class="row mb-3">
|
||||
<div class="col-12">
|
||||
<ul class="nav nav-tabs">
|
||||
<li class="nav-item">
|
||||
<a class="nav-link active" href="/flows">Dashboard</a>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<a class="nav-link" href="/flows/list">All Workflows</a>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<a class="nav-link" href="/flows/my-flows">My Workflows</a>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<a class="nav-link" href="/flows/create">Create Workflow</a>
|
||||
</li>
|
||||
</ul>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Info Alert -->
|
||||
<div class="row mb-3">
|
||||
<div class="col-12">
|
||||
<div class="alert alert-info alert-dismissible fade show">
|
||||
<button type="button" class="btn-close" data-bs-dismiss="alert" aria-label="Close"></button>
|
||||
<h5><i class="bi bi-info-circle"></i> About Workflows</h5>
|
||||
<p>The workflow system helps you track and manage business processes across your organization. Create new workflows, monitor progress, and collaborate with team members to ensure smooth operations.</p>
|
||||
<div class="mt-2">
|
||||
<a href="/flows/documentation" class="btn btn-sm btn-outline-primary"><i class="bi bi-book"></i> Read Documentation</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Dashboard Main Content -->
|
||||
<div class="row mb-4">
|
||||
<!-- Workflows with Pending Actions -->
|
||||
<div class="col-lg-9 mb-4">
|
||||
<div class="card h-100">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Workflows with Pending Actions</h5>
|
||||
<div>
|
||||
<a href="/flows/pending" class="btn btn-sm btn-outline-primary">View All Pending</a>
|
||||
</div>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
{% if flows and flows|length > 0 %}
|
||||
<div class="table-responsive">
|
||||
<table class="table table-hover align-middle">
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Workflow</th>
|
||||
<th>Type</th>
|
||||
<th>Current Step</th>
|
||||
<th>Last Updated</th>
|
||||
<th>Owner</th>
|
||||
<th>Actions</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for flow in flows %}
|
||||
<tr>
|
||||
<td>
|
||||
<div class="d-flex align-items-center">
|
||||
<div class="flex-shrink-0 me-2">
|
||||
<div class="avatar bg-light text-primary rounded p-2">
|
||||
<i class="bi bi-diagram-3"></i>
|
||||
</div>
|
||||
</div>
|
||||
<div>
|
||||
<a href="/flows/{{ flow.id }}" class="text-decoration-none fw-medium">{{ flow.name }}</a>
|
||||
<div class="small text-muted">ID: {{ flow.id }}</div>
|
||||
</div>
|
||||
</div>
|
||||
</td>
|
||||
<td><span class="badge bg-info">{{ flow.flow_type }}</span></td>
|
||||
<td>
|
||||
{% if flow.current_step %}
|
||||
<span class="text-warning fw-medium">{{ flow.current_step.name }}</span>
|
||||
<div class="small text-muted">{{ flow.current_step.description }}</div>
|
||||
{% else %}
|
||||
<span class="text-muted">No pending step</span>
|
||||
{% endif %}
|
||||
</td>
|
||||
<td>
|
||||
<span>{{ flow.updated_at | date(format="%Y-%m-%d") }}</span>
|
||||
{% if flow.status == 'Stuck' %}
|
||||
<div class="small text-danger">May need attention</div>
|
||||
{% else %}
|
||||
<div class="small text-muted">Last updated</div>
|
||||
{% endif %}
|
||||
</td>
|
||||
<td>
|
||||
<div class="d-flex align-items-center">
|
||||
<div class="flex-shrink-0 me-2">
|
||||
<div class="avatar avatar-sm">
|
||||
<img src="{{ flow.owner_avatar or '/static/img/avatar-placeholder.png' }}" alt="{{ flow.owner_name }}" class="rounded-circle" onerror="this.src='/static/img/avatar-placeholder.png'; this.onerror='';">
|
||||
</div>
|
||||
</div>
|
||||
<div>{{ flow.owner_name }}</div>
|
||||
</div>
|
||||
</td>
|
||||
<td>
|
||||
<div class="d-flex gap-2">
|
||||
<a href="/flows/{{ flow.id }}#take-action" class="btn btn-sm btn-primary">Take Action</a>
|
||||
<div class="dropdown">
|
||||
<button class="btn btn-sm btn-outline-secondary dropdown-toggle" type="button" data-bs-toggle="dropdown" aria-expanded="false">
|
||||
<i class="bi bi-three-dots"></i>
|
||||
</button>
|
||||
<ul class="dropdown-menu">
|
||||
<li><a class="dropdown-item" href="/flows/{{ flow.id }}">View Details</a></li>
|
||||
<li><a class="dropdown-item" href="/flows/{{ flow.id }}/reassign">Reassign</a></li>
|
||||
<li><a class="dropdown-item" href="/flows/{{ flow.id }}/extend">Extend Deadline</a></li>
|
||||
</ul>
|
||||
</div>
|
||||
</div>
|
||||
</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
{% else %}
|
||||
<div class="text-center py-5">
|
||||
<i class="bi bi-check-circle-fill fs-1 text-success mb-3"></i>
|
||||
<h5>No Pending Actions</h5>
|
||||
<p class="text-muted">There are no workflows that require your immediate attention.</p>
|
||||
</div>
|
||||
{% endif %}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Timeline of Recent Flow Steps -->
|
||||
<div class="col-lg-3 mb-4">
|
||||
<div class="card h-100">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Recent Activity</h5>
|
||||
<a href="/flows/activity" class="btn btn-sm btn-outline-primary">View All</a>
|
||||
</div>
|
||||
<div class="card-body p-0">
|
||||
{% if flows and flows|length > 0 %}
|
||||
<div class="list-group list-group-flush">
|
||||
{% set count = 0 %}
|
||||
{% for flow in flows %}
|
||||
{% if count < 8 %}
|
||||
{% set count = count + 1 %}
|
||||
<div class="list-group-item border-start-0 border-end-0 py-3">
|
||||
<div class="d-flex">
|
||||
<div class="me-3">
|
||||
<div class="timeline-icon bg-light text-{% if flow.status == 'Completed' %}success{% elif flow.status == 'Stuck' %}danger{% else %}primary{% endif %} rounded-circle p-2">
|
||||
<i class="bi bi-{% if flow.status == 'Completed' %}check-circle{% elif flow.status == 'Stuck' %}exclamation-triangle{% else %}arrow-right-circle{% endif %} fs-5"></i>
|
||||
</div>
|
||||
</div>
|
||||
<div class="flex-fill">
|
||||
<div class="d-flex justify-content-between align-items-center">
|
||||
<div class="fw-medium">
|
||||
{% if flow.status == 'In Progress' %}Working on{% elif flow.status == 'Completed' %}Completed{% elif flow.status == 'Stuck' %}Stuck at{% else %}Updated{% endif %}
|
||||
{% if flow.current_step %} {{ flow.current_step.name }}{% endif %}
|
||||
</div>
|
||||
<div class="text-muted small">{{ flow.updated_at | date(format="%H:%M") }}</div>
|
||||
</div>
|
||||
<div>in <a href="/flows/{{ flow.id }}" class="text-decoration-none">{{ flow.name }}</a></div>
|
||||
<div class="text-muted small mt-1">by {{ flow.owner_name }}</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
{% endif %}
|
||||
{% endfor %}
|
||||
</div>
|
||||
<div class="card-footer text-center">
|
||||
<a href="/flows/activity" class="btn btn-sm btn-outline-secondary">View Full Activity Log</a>
|
||||
</div>
|
||||
{% else %}
|
||||
<div class="list-group list-group-flush">
|
||||
<div class="list-group-item border-start-0 border-end-0 py-5 text-center">
|
||||
<i class="bi bi-hourglass fs-1 text-muted mb-3"></i>
|
||||
<h6>No Recent Activity</h6>
|
||||
<p class="text-muted small mb-0">Activity will appear here as workflows progress.</p>
|
||||
</div>
|
||||
</div>
|
||||
{% endif %}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Compact Filter Controls -->
|
||||
<div class="row mb-4">
|
||||
<div class="col-12">
|
||||
<div class="card">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Workflow Filters</h5>
|
||||
<button class="btn btn-sm btn-outline-primary" type="button" data-bs-toggle="collapse" data-bs-target="#filterCollapse" aria-expanded="false" aria-controls="filterCollapse">
|
||||
<i class="bi bi-funnel"></i> Show/Hide Filters
|
||||
</button>
|
||||
</div>
|
||||
<div class="collapse show" id="filterCollapse">
|
||||
<div class="card-body">
|
||||
<form class="row g-3" action="/flows" method="get">
|
||||
<div class="col-md-3">
|
||||
<label for="status" class="form-label">Status</label>
|
||||
<select class="form-select" id="status" name="status">
|
||||
<option value="all" selected>All</option>
|
||||
<option value="in_progress">In Progress</option>
|
||||
<option value="completed">Completed</option>
|
||||
<option value="stuck">Stuck</option>
|
||||
<option value="cancelled">Cancelled</option>
|
||||
</select>
|
||||
</div>
|
||||
<!-- Freezone filter - for UI demonstration only -->
|
||||
<div class="col-md-3">
|
||||
<label for="freezone" class="form-label">Freezone</label>
|
||||
<select class="form-select" id="freezone" name="freezone" disabled>
|
||||
<option value="all" selected>All Freezones</option>
|
||||
<option value="dubai_multi_commodities_centre">DMCC</option>
|
||||
<option value="dubai_international_financial_centre">DIFC</option>
|
||||
<option value="jebel_ali_free_zone">JAFZA</option>
|
||||
<option value="dubai_silicon_oasis">DSO</option>
|
||||
<option value="dubai_internet_city">DIC</option>
|
||||
<option value="dubai_media_city">DMC</option>
|
||||
<option value="abu_dhabi_global_market">ADGM</option>
|
||||
</select>
|
||||
<div class="form-text">Coming soon</div>
|
||||
</div>
|
||||
<div class="col-md-3">
|
||||
<label for="type" class="form-label">Workflow Type</label>
|
||||
<select class="form-select" id="type" name="type">
|
||||
<option value="all" selected>All</option>
|
||||
<option value="company_registration">Company Incorporation</option>
|
||||
<option value="user_onboarding">KYC Verification</option>
|
||||
<option value="service_activation">License Activation</option>
|
||||
<option value="payment_processing">Payment Processing</option>
|
||||
</select>
|
||||
</div>
|
||||
<div class="col-md-3">
|
||||
<label for="search" class="form-label">Search</label>
|
||||
<input type="text" class="form-control" id="search" name="search" placeholder="Search workflows...">
|
||||
</div>
|
||||
<div class="col-12 text-end">
|
||||
<button type="submit" class="btn btn-primary">
|
||||
<i class="bi bi-filter me-1"></i> Apply Filters
|
||||
</button>
|
||||
<a href="/flows" class="btn btn-outline-secondary">
|
||||
<i class="bi bi-x-circle me-1"></i> Clear Filters
|
||||
</a>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Recent Active Workflows Section -->
|
||||
<div class="row mb-4">
|
||||
<div class="col-12">
|
||||
<div class="card">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Active Workflows (Recent Updates)</h5>
|
||||
<a href="/flows/list" class="btn btn-sm btn-outline-primary">View All</a>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
<div class="row">
|
||||
{% set count = 0 %}
|
||||
{% for flow in flows %}
|
||||
{% if count < 3 and flow.status == 'In Progress' %}
|
||||
<div class="col-md-4 mb-3">
|
||||
<div class="card h-100">
|
||||
<div class="card-body">
|
||||
<h5 class="card-title">{{ flow.name }}</h5>
|
||||
<h6 class="card-subtitle mb-2 text-muted">Owner: {{ flow.owner_name }}</h6>
|
||||
<div class="mb-3">
|
||||
<span class="badge bg-primary">{{ flow.flow_type }}</span>
|
||||
</div>
|
||||
<p class="mb-2">Current stage:
|
||||
{% set current = flow.current_step %}
|
||||
{% if current %}
|
||||
{{ current.name }}
|
||||
{% else %}
|
||||
<span class="text-muted">No active stage</span>
|
||||
{% endif %}
|
||||
</p>
|
||||
<div class="progress mb-2" style="height: 20px;">
|
||||
<div class="progress-bar bg-primary" role="progressbar"
|
||||
style="width: {{ flow.progress_percentage }}%;"
|
||||
aria-valuenow="{{ flow.progress_percentage }}"
|
||||
aria-valuemin="0" aria-valuemax="100">{{ flow.progress_percentage }}%</div>
|
||||
</div>
|
||||
<div class="d-flex justify-content-between align-items-center mt-3">
|
||||
<small class="text-muted">Updated: {{ flow.updated_at | date(format="%Y-%m-%d") }}</small>
|
||||
<a href="/flows/{{ flow.id }}" class="btn btn-sm btn-outline-primary">View Details</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
{% set count = count + 1 %}
|
||||
{% endif %}
|
||||
{% endfor %}
|
||||
{% if count == 0 %}
|
||||
<div class="col-12 text-center py-4">
|
||||
<i class="bi bi-clipboard-check fs-1 text-muted mb-3"></i>
|
||||
<h5>No active workflows</h5>
|
||||
<p class="text-muted">All workflows are either completed or not yet started.</p>
|
||||
<a href="/flows/create" class="btn btn-primary mt-3">Create New Workflow</a>
|
||||
</div>
|
||||
{% endif %}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Flows Table (Simplified) -->
|
||||
<div class="row">
|
||||
<div class="col-12">
|
||||
<div class="card">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Recent Workflows</h5>
|
||||
<a href="/flows/list" class="btn btn-sm btn-outline-primary">View All Workflows</a>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
{% if flows|length > 0 %}
|
||||
<div class="table-responsive">
|
||||
<table class="table table-hover">
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Workflow Name</th>
|
||||
<th>Type</th>
|
||||
<th>Status</th>
|
||||
<th>Assignee</th>
|
||||
<th>Progress</th>
|
||||
<th>Initiated</th>
|
||||
<th>Last Updated</th>
|
||||
<th>Current Stage</th>
|
||||
<th>Actions</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for flow in flows %}
|
||||
<tr>
|
||||
<td>
|
||||
<a href="/flows/{{ flow.id }}">{{ flow.name }}</a>
|
||||
</td>
|
||||
<td>{{ flow.flow_type }}</td>
|
||||
<td>
|
||||
<span
|
||||
class="badge {% if flow.status == 'In Progress' %}bg-primary{% elif flow.status == 'Completed' %}bg-success{% elif flow.status == 'Stuck' %}bg-danger{% else %}bg-secondary{% endif %}">
|
||||
{{ flow.status }}
|
||||
</span>
|
||||
</td>
|
||||
<td>{{ flow.owner_name }}</td>
|
||||
<td>
|
||||
<div class="progress mb-2" style="height: 20px;">
|
||||
<div class="progress-bar {% if flow.status == 'Completed' %}bg-success{% elif flow.status == 'Stuck' %}bg-danger{% else %}bg-primary{% endif %}"
|
||||
role="progressbar" style="width: {{ flow.progress_percentage }}%;"
|
||||
aria-valuenow="{{ flow.progress_percentage }}" aria-valuemin="0"
|
||||
aria-valuemax="100">{{ flow.progress_percentage }}%</div>
|
||||
</div>
|
||||
</td>
|
||||
<td>{{ flow.created_at | date(format="%Y-%m-%d") }}</td>
|
||||
<td>{{ flow.updated_at | date(format="%Y-%m-%d") }}</td>
|
||||
<td>
|
||||
{% set current = flow.current_step %}
|
||||
{% if current %}
|
||||
{{ current.name }}
|
||||
{% else %}
|
||||
{% if flow.status == 'Completed' %}
|
||||
<span class="text-success">All stages completed</span>
|
||||
{% elif flow.status == 'Cancelled' %}
|
||||
<span class="text-secondary">Workflow cancelled</span>
|
||||
{% else %}
|
||||
<span class="text-muted">No active stage</span>
|
||||
{% endif %}
|
||||
{% endif %}
|
||||
</td>
|
||||
<td>
|
||||
<div class="btn-group">
|
||||
<a href="/flows/{{ flow.id }}" class="btn btn-sm btn-primary" title="View Details">
|
||||
<i class="bi bi-eye"></i>
|
||||
</a>
|
||||
{% if flow.status == 'In Progress' %}
|
||||
<a href="/flows/{{ flow.id }}#advance" class="btn btn-sm btn-success" title="Advance to Next Stage">
|
||||
<i class="bi bi-arrow-right"></i>
|
||||
</a>
|
||||
{% endif %}
|
||||
</div>
|
||||
</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
{% else %}
|
||||
<div class="text-center py-4">
|
||||
<i class="bi bi-search display-1 text-muted"></i>
|
||||
<p class="lead mt-3">No workflows found matching your criteria.</p>
|
||||
<p class="text-muted">Try adjusting your filters or create a new workflow.</p>
|
||||
</div>
|
||||
{% endif %}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
{% endblock %}
|
||||
@@ -3,122 +3,188 @@
|
||||
{% block title %}Flows Dashboard{% endblock %}
|
||||
|
||||
{% block content %}
|
||||
<div class="row mb-4">
|
||||
<div class="col-md-8">
|
||||
<h1 class="display-5 mb-4">Flows Dashboard</h1>
|
||||
<p class="lead">Track and manage workflow processes across the organization.</p>
|
||||
</div>
|
||||
<div class="col-md-4 text-md-end">
|
||||
<a href="/flows/create" class="btn btn-primary">
|
||||
<i class="bi bi-plus-circle me-1"></i> Create New Workflow
|
||||
</a>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Statistics Cards -->
|
||||
<div class="row mb-4">
|
||||
<div class="col-md-3 mb-3">
|
||||
<div class="card text-white bg-primary h-100">
|
||||
<div class="card-body">
|
||||
<h5 class="card-title">Total Flows</h5>
|
||||
<p class="display-4">{{ stats.total_flows }}</p>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="col-md-3 mb-3">
|
||||
<div class="card text-white bg-success h-100">
|
||||
<div class="card-body">
|
||||
<h5 class="card-title">In Progress</h5>
|
||||
<p class="display-4">{{ stats.in_progress_flows }}</p>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="col-md-3 mb-3">
|
||||
<div class="card text-white bg-danger h-100">
|
||||
<div class="card-body">
|
||||
<h5 class="card-title">Stuck</h5>
|
||||
<p class="display-4">{{ stats.stuck_flows }}</p>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="col-md-3 mb-3">
|
||||
<div class="card text-white bg-info h-100">
|
||||
<div class="card-body">
|
||||
<h5 class="card-title">Completed</h5>
|
||||
<p class="display-4">{{ stats.completed_flows }}</p>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Filter Controls -->
|
||||
<div class="row mb-4">
|
||||
<!-- Navigation Tabs -->
|
||||
<div class="row mb-3">
|
||||
<div class="col-12">
|
||||
<div class="card">
|
||||
<div class="card-header">
|
||||
<h5 class="mb-0">Filter Workflows</h5>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
<form class="row g-3" action="/flows" method="get">
|
||||
<div class="col-md-3">
|
||||
<label for="status" class="form-label">Status</label>
|
||||
<select class="form-select" id="status" name="status">
|
||||
<option value="all" selected>All</option>
|
||||
<option value="in_progress">In Progress</option>
|
||||
<option value="completed">Completed</option>
|
||||
<option value="stuck">Stuck</option>
|
||||
<option value="cancelled">Cancelled</option>
|
||||
</select>
|
||||
</div>
|
||||
<!-- Freezone filter - for UI demonstration only -->
|
||||
<div class="col-md-3">
|
||||
<label for="freezone" class="form-label">Freezone</label>
|
||||
<select class="form-select" id="freezone" name="freezone" disabled>
|
||||
<option value="all" selected>All Freezones</option>
|
||||
<option value="dubai_multi_commodities_centre">DMCC</option>
|
||||
<option value="dubai_international_financial_centre">DIFC</option>
|
||||
<option value="jebel_ali_free_zone">JAFZA</option>
|
||||
<option value="dubai_silicon_oasis">DSO</option>
|
||||
<option value="dubai_internet_city">DIC</option>
|
||||
<option value="dubai_media_city">DMC</option>
|
||||
<option value="abu_dhabi_global_market">ADGM</option>
|
||||
</select>
|
||||
<div class="form-text">Coming soon</div>
|
||||
</div>
|
||||
<div class="col-md-3">
|
||||
<label for="type" class="form-label">Workflow Type</label>
|
||||
<select class="form-select" id="type" name="type">
|
||||
<option value="all" selected>All</option>
|
||||
<option value="company_registration">Company Incorporation</option>
|
||||
<option value="user_onboarding">KYC Verification</option>
|
||||
<option value="service_activation">License Activation</option>
|
||||
<option value="payment_processing">Payment Processing</option>
|
||||
</select>
|
||||
</div>
|
||||
<div class="col-md-3">
|
||||
<label for="search" class="form-label">Search</label>
|
||||
<input type="text" class="form-control" id="search" name="search" placeholder="Search workflows...">
|
||||
</div>
|
||||
<div class="col-12 text-end">
|
||||
<button type="submit" class="btn btn-primary">
|
||||
<i class="bi bi-filter me-1"></i> Apply Filters
|
||||
</button>
|
||||
<a href="/flows" class="btn btn-outline-secondary">
|
||||
<i class="bi bi-x-circle me-1"></i> Clear Filters
|
||||
</a>
|
||||
</div>
|
||||
</form>
|
||||
<ul class="nav nav-tabs">
|
||||
<li class="nav-item">
|
||||
<a class="nav-link active" href="/flows">Dashboard</a>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<a class="nav-link" href="/flows/list">All Workflows</a>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<a class="nav-link" href="/flows/my-flows">My Workflows</a>
|
||||
</li>
|
||||
<li class="nav-item">
|
||||
<a class="nav-link" href="/flows/create">Create Workflow</a>
|
||||
</li>
|
||||
</ul>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Info Alert -->
|
||||
<div class="row mb-3">
|
||||
<div class="col-12">
|
||||
<div class="alert alert-info alert-dismissible fade show">
|
||||
<button type="button" class="btn-close" data-bs-dismiss="alert" aria-label="Close"></button>
|
||||
<h5><i class="bi bi-info-circle"></i> About Workflows</h5>
|
||||
<p>The workflow system helps you track and manage business processes across your organization. Create new workflows, monitor progress, and collaborate with team members to ensure smooth operations.</p>
|
||||
<div class="mt-2">
|
||||
<a href="/flows/documentation" class="btn btn-sm btn-outline-primary"><i class="bi bi-book"></i> Read Documentation</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Flows Table -->
|
||||
<!-- Dashboard Main Content -->
|
||||
<div class="row mb-4">
|
||||
<!-- Workflows with Pending Actions -->
|
||||
<div class="col-lg-9 mb-4">
|
||||
<div class="card h-100">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Workflows with Pending Actions</h5>
|
||||
<div>
|
||||
<a href="/flows/pending" class="btn btn-sm btn-outline-primary">View All Pending</a>
|
||||
</div>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
{% if flows and flows|length > 0 %}
|
||||
<div class="table-responsive">
|
||||
<table class="table table-hover align-middle">
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Workflow</th>
|
||||
<th>Type</th>
|
||||
<th>Current Step</th>
|
||||
<th>Last Updated</th>
|
||||
<th>Actions</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for flow in flows %}
|
||||
<tr>
|
||||
<td>
|
||||
<div class="d-flex align-items-center">
|
||||
<div class="flex-shrink-0 me-2">
|
||||
<div class="avatar bg-light text-primary rounded p-2">
|
||||
<i class="bi bi-diagram-3"></i>
|
||||
</div>
|
||||
</div>
|
||||
<div>
|
||||
<a href="/flows/{{ flow.id }}" class="text-decoration-none fw-medium">{{ flow.name }}</a>
|
||||
<div class="small text-muted">ID: {{ flow.id }}</div>
|
||||
</div>
|
||||
</div>
|
||||
</td>
|
||||
<td><span class="badge bg-info">{{ flow.flow_type }}</span></td>
|
||||
<td>
|
||||
{% if flow.current_step %}
|
||||
<span class="text-warning fw-medium">{{ flow.current_step.name }}</span>
|
||||
<div class="small text-muted">{{ flow.current_step.description }}</div>
|
||||
{% else %}
|
||||
<span class="text-muted">No pending step</span>
|
||||
{% endif %}
|
||||
</td>
|
||||
<td>
|
||||
<span>{{ flow.updated_at | date(format="%Y-%m-%d") }}</span>
|
||||
{% if flow.status == 'Stuck' %}
|
||||
<div class="small text-danger">May need attention</div>
|
||||
{% else %}
|
||||
<div class="small text-muted">Last updated</div>
|
||||
{% endif %}
|
||||
</td>
|
||||
<td>
|
||||
<div class="d-flex gap-2">
|
||||
<a href="/flows/{{ flow.id }}#take-action" class="btn btn-sm btn-primary">Take Action</a>
|
||||
<div class="dropdown">
|
||||
<button class="btn btn-sm btn-outline-secondary dropdown-toggle" type="button" data-bs-toggle="dropdown" aria-expanded="false">
|
||||
<i class="bi bi-three-dots"></i>
|
||||
</button>
|
||||
<ul class="dropdown-menu">
|
||||
<li><a class="dropdown-item" href="/flows/{{ flow.id }}">View Details</a></li>
|
||||
<li><a class="dropdown-item" href="/flows/{{ flow.id }}/reassign">Reassign</a></li>
|
||||
<li><a class="dropdown-item" href="/flows/{{ flow.id }}/extend">Extend Deadline</a></li>
|
||||
</ul>
|
||||
</div>
|
||||
</div>
|
||||
</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
{% else %}
|
||||
<div class="text-center py-5">
|
||||
<i class="bi bi-check-circle-fill fs-1 text-success mb-3"></i>
|
||||
<h5>No Pending Actions</h5>
|
||||
<p class="text-muted">There are no workflows that require your immediate attention.</p>
|
||||
</div>
|
||||
{% endif %}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Timeline of Recent Flow Steps -->
|
||||
<div class="col-lg-3 mb-4">
|
||||
<div class="card h-100">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Recent Activity</h5>
|
||||
<a href="/flows/activity" class="btn btn-sm btn-outline-primary">View All</a>
|
||||
</div>
|
||||
<div class="card-body p-0">
|
||||
{% if flows and flows|length > 0 %}
|
||||
<div class="list-group list-group-flush">
|
||||
{% set count = 0 %}
|
||||
{% for flow in flows %}
|
||||
{% if count < 8 %}
|
||||
{% set count = count + 1 %}
|
||||
<div class="list-group-item border-start-0 border-end-0 py-3">
|
||||
<div class="d-flex">
|
||||
<div class="me-3">
|
||||
<div class="timeline-icon bg-light text-{% if flow.status == 'Completed' %}success{% elif flow.status == 'Stuck' %}danger{% else %}primary{% endif %} rounded-circle p-2">
|
||||
<i class="bi bi-{% if flow.status == 'Completed' %}check-circle{% elif flow.status == 'Stuck' %}exclamation-triangle{% else %}arrow-right-circle{% endif %} fs-5"></i>
|
||||
</div>
|
||||
</div>
|
||||
<div class="flex-fill">
|
||||
<div class="d-flex justify-content-between align-items-center">
|
||||
<div class="fw-medium">
|
||||
{% if flow.status == 'In Progress' %}Working on{% elif flow.status == 'Completed' %}Completed{% elif flow.status == 'Stuck' %}Stuck at{% else %}Updated{% endif %}
|
||||
{% if flow.current_step %} {{ flow.current_step.name }}{% endif %}
|
||||
</div>
|
||||
<div class="text-muted small">{{ flow.updated_at | date(format="%H:%M") }}</div>
|
||||
</div>
|
||||
<div>in <a href="/flows/{{ flow.id }}" class="text-decoration-none">{{ flow.name }}</a></div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
{% endif %}
|
||||
{% endfor %}
|
||||
</div>
|
||||
<div class="card-footer text-center">
|
||||
<a href="/flows/activity" class="btn btn-sm btn-outline-secondary">View Full Activity Log</a>
|
||||
</div>
|
||||
{% else %}
|
||||
<div class="list-group list-group-flush">
|
||||
<div class="list-group-item border-start-0 border-end-0 py-5 text-center">
|
||||
<i class="bi bi-hourglass fs-1 text-muted mb-3"></i>
|
||||
<h6>No Recent Activity</h6>
|
||||
<p class="text-muted small mb-0">Activity will appear here as workflows progress.</p>
|
||||
</div>
|
||||
</div>
|
||||
{% endif %}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Flows Table (Simplified) -->
|
||||
<div class="row">
|
||||
<div class="col-12">
|
||||
<div class="card">
|
||||
<div class="card-header">
|
||||
<h5 class="mb-0">All Workflows</h5>
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Recent Workflows</h5>
|
||||
<a href="/flows/list" class="btn btn-sm btn-outline-primary">View All Workflows</a>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
{% if flows|length > 0 %}
|
||||
@@ -129,7 +195,6 @@
|
||||
<th>Workflow Name</th>
|
||||
<th>Type</th>
|
||||
<th>Status</th>
|
||||
<th>Assignee</th>
|
||||
<th>Progress</th>
|
||||
<th>Initiated</th>
|
||||
<th>Last Updated</th>
|
||||
@@ -150,7 +215,6 @@
|
||||
{{ flow.status }}
|
||||
</span>
|
||||
</td>
|
||||
<td>{{ flow.owner_name }}</td>
|
||||
<td>
|
||||
<div class="progress mb-2" style="height: 20px;">
|
||||
<div class="progress-bar {% if flow.status == 'Completed' %}bg-success{% elif flow.status == 'Stuck' %}bg-danger{% else %}bg-primary{% endif %}"
|
||||
|
||||
2809
flowbroker/Cargo.lock
generated
Normal file
2809
flowbroker/Cargo.lock
generated
Normal file
File diff suppressed because it is too large
Load Diff
27
flowbroker/Cargo.toml
Normal file
27
flowbroker/Cargo.toml
Normal file
@@ -0,0 +1,27 @@
|
||||
[package]
|
||||
name = "flowbroker"
|
||||
version = "0.1.0"
|
||||
edition = "2024"
|
||||
|
||||
[dependencies]
|
||||
sigsocket = { path = "../sigsocket" } # Path relative to flowbroker directory
|
||||
actix-web = "4.3.1"
|
||||
actix-rt = "2.8.0"
|
||||
actix-files = "0.6.2"
|
||||
actix-web-actors = "4.2.0"
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
serde_json = "1.0"
|
||||
env_logger = "0.10.0"
|
||||
log = "0.4.0"
|
||||
tera = "1.19.0"
|
||||
tokio = { version = "1.28.0", features = ["full"] }
|
||||
dotenv = "0.15.0"
|
||||
hex = "0.4.3"
|
||||
uuid = { version = "1.4", features = ["v4", "serde"] }
|
||||
chrono = { version = "0.4", features = ["serde"] } # For timestamps
|
||||
rhai = "1.18.0"
|
||||
serde_urlencoded = "0.7"
|
||||
|
||||
# Database models and ORM-like functionality
|
||||
heromodels = { path = "../../db/heromodels" }
|
||||
# Note: heromodels pulls in 'ourdb', 'heromodels_core', 'heromodels_derive'
|
||||
BIN
flowbroker/flowbroker_db/data/0.db
Normal file
BIN
flowbroker/flowbroker_db/data/0.db
Normal file
Binary file not shown.
BIN
flowbroker/flowbroker_db/data/lookup/data
Normal file
BIN
flowbroker/flowbroker_db/data/lookup/data
Normal file
Binary file not shown.
BIN
flowbroker/flowbroker_db/index/0.db
Normal file
BIN
flowbroker/flowbroker_db/index/0.db
Normal file
Binary file not shown.
1
flowbroker/flowbroker_db/index/lookup/.inc
Normal file
1
flowbroker/flowbroker_db/index/lookup/.inc
Normal file
@@ -0,0 +1 @@
|
||||
148
|
||||
BIN
flowbroker/flowbroker_db/index/lookup/data
Normal file
BIN
flowbroker/flowbroker_db/index/lookup/data
Normal file
Binary file not shown.
690
flowbroker/src/main.rs
Normal file
690
flowbroker/src/main.rs
Normal file
@@ -0,0 +1,690 @@
|
||||
use actix_files as fs;
|
||||
use actix_web::{web, App, HttpResponse, HttpServer, Responder, Result as ActixResult};
|
||||
use std::fs as std_fs;
|
||||
use std::path::PathBuf;
|
||||
use actix_web_actors::ws;
|
||||
use serde::{Deserialize, Serialize};
|
||||
use serde_urlencoded; // Added for from_str
|
||||
use tera::{Tera, Context};
|
||||
use std::sync::{Arc, Mutex, RwLock};
|
||||
use sigsocket::service::SigSocketService;
|
||||
use sigsocket::registry::ConnectionRegistry;
|
||||
use log::{info, error};
|
||||
use uuid::Uuid;
|
||||
use rhai::{Engine, EvalAltResult, Position};
|
||||
// use std::collections::HashMap; // Removed as no longer used
|
||||
use heromodels; // Added for database models
|
||||
use heromodels::db::hero::OurDB;
|
||||
use heromodels::db::{Db, Collection}; // Import Db trait for .collection() and Collection trait for .set()/.get_all()
|
||||
use heromodels::models::flowbroker_models::{Flow, FlowStep, SignatureRequirement}; // Import the models
|
||||
use dotenv::dotenv;
|
||||
use std::env;
|
||||
|
||||
// --- Flowbroker Specific Enums (to be used by application logic) ---
|
||||
|
||||
#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
|
||||
pub enum FlowStepStatus {
|
||||
Pending, // Step created, not yet processed
|
||||
InProgress, // Step is actively being processed (e.g., waiting for signatures)
|
||||
Completed, // All requirements for this step are met
|
||||
Failed, // Step failed (e.g., a signature requirement failed or timed out)
|
||||
Skipped, // Step was skipped (e.g., due to conditional logic not yet implemented)
|
||||
}
|
||||
|
||||
impl FlowStepStatus {
|
||||
pub fn to_db_string(&self) -> String {
|
||||
format!("{:?}", self)
|
||||
}
|
||||
|
||||
pub fn from_db_string(s: &str) -> Result<Self, String> {
|
||||
match s {
|
||||
"Pending" => Ok(FlowStepStatus::Pending),
|
||||
"InProgress" => Ok(FlowStepStatus::InProgress),
|
||||
"Completed" => Ok(FlowStepStatus::Completed),
|
||||
"Failed" => Ok(FlowStepStatus::Failed),
|
||||
"Skipped" => Ok(FlowStepStatus::Skipped),
|
||||
_ => Err(format!("Invalid FlowStepStatus string: {}", s)),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
|
||||
pub enum SignatureRequirementStatus {
|
||||
Pending, // Not yet processed or sent for signing
|
||||
SentToClient, // Sent to client via SigSocket, awaiting signature
|
||||
Signed, // Successfully signed
|
||||
Failed, // Signing failed (e.g., client rejected, timeout, error)
|
||||
Error, // An internal error occurred processing this requirement
|
||||
}
|
||||
|
||||
impl SignatureRequirementStatus {
|
||||
pub fn to_db_string(&self) -> String {
|
||||
format!("{:?}", self)
|
||||
}
|
||||
|
||||
pub fn from_db_string(s: &str) -> Result<Self, String> {
|
||||
match s {
|
||||
"Pending" => Ok(SignatureRequirementStatus::Pending),
|
||||
"SentToClient" => Ok(SignatureRequirementStatus::SentToClient),
|
||||
"Signed" => Ok(SignatureRequirementStatus::Signed),
|
||||
"Failed" => Ok(SignatureRequirementStatus::Failed),
|
||||
"Error" => Ok(SignatureRequirementStatus::Error),
|
||||
_ => Err(format!("Invalid SignatureRequirementStatus string: {}", s)),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
|
||||
pub enum FlowStatus {
|
||||
Pending, // Flow created, no steps initiated
|
||||
InProgress, // Flow started, steps are being processed
|
||||
Completed, // All steps successfully signed
|
||||
Failed, // A step failed or timed out
|
||||
}
|
||||
|
||||
impl FlowStatus {
|
||||
pub fn to_db_string(&self) -> String {
|
||||
format!("{:?}", self)
|
||||
}
|
||||
|
||||
pub fn from_db_string(s: &str) -> Result<Self, String> {
|
||||
match s {
|
||||
"Pending" => Ok(FlowStatus::Pending),
|
||||
"InProgress" => Ok(FlowStatus::InProgress),
|
||||
"Completed" => Ok(FlowStatus::Completed),
|
||||
"Failed" => Ok(FlowStatus::Failed),
|
||||
_ => Err(format!("Invalid FlowStatus string: {}", s)),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// NOTE: The old Flow, FlowStep, and SignatureRequirement structs previously here
|
||||
// have been removed. Their definitions are now in the heromodels crate.
|
||||
|
||||
// --- AppState ---
|
||||
pub struct AppState {
|
||||
templates: Tera,
|
||||
sigsocket_service: Arc<SigSocketService>,
|
||||
db: Arc<OurDB>, // Using OurDB from heromodels
|
||||
next_id_counter: Arc<Mutex<u32>>, // For generating temporary primary keys
|
||||
}
|
||||
|
||||
// --- Form Deserialization (for new dynamic form) ---
|
||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone)]
|
||||
pub struct RequirementRealFormData {
|
||||
// The name attributes in HTML are like: steps[0][requirements][0][message]
|
||||
pub message: String, // Made fields public for external construction in tests
|
||||
pub public_key: String, // Made fields public
|
||||
}
|
||||
|
||||
|
||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone)]
|
||||
pub struct FlowStepFormData {
|
||||
description: Option<String>, // If description field is optional and might not be present
|
||||
requirements: Vec<RequirementRealFormData>,
|
||||
}
|
||||
|
||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone)]
|
||||
pub struct CreateFlowRealFormData { // Renamed to avoid confusion with heromodels::Flow
|
||||
flow_name: String,
|
||||
steps: Vec<FlowStepFormData>,
|
||||
}
|
||||
|
||||
#[derive(serde::Deserialize, Debug)]
|
||||
pub struct RhaiScriptFormData {
|
||||
rhai_script: String,
|
||||
}
|
||||
|
||||
|
||||
// --- Context Structs for Templates ---
|
||||
#[derive(Serialize, Clone)]
|
||||
struct RhaiExampleDisplay {
|
||||
name: String,
|
||||
content: String,
|
||||
}
|
||||
|
||||
#[derive(Serialize)]
|
||||
struct ListFlowsContext {
|
||||
flows: Vec<Flow>, // Using heromodels::models::flowbroker_models::Flow
|
||||
example_scripts: Vec<RhaiExampleDisplay>,
|
||||
error_message: Option<String>,
|
||||
success_message: Option<String>,
|
||||
}
|
||||
|
||||
// --- Handlers ---
|
||||
|
||||
// Display list of flows
|
||||
async fn list_flows(data: web::Data<AppState>) -> ActixResult<HttpResponse> {
|
||||
let tera = &data.templates;
|
||||
|
||||
// Fetch actual flows from the database
|
||||
let flows_collection = data.db.collection::<Flow>()
|
||||
.map_err(|e| actix_web::error::ErrorInternalServerError(format!("DB Error: Failed to get flows collection: {}", e)))?;
|
||||
let (mut flows, flow_error_message) = match flows_collection.get_all() {
|
||||
Ok(mut flows_vec) => {
|
||||
flows_vec.sort_by(|a, b| b.base_data.created_at.cmp(&a.base_data.created_at)); // Sort by newest
|
||||
(flows_vec, None)
|
||||
},
|
||||
Err(e) => {
|
||||
error!("Failed to fetch flows: {:?}", e);
|
||||
(Vec::new(), Some(format!("Error fetching flows: {:?}", e)))
|
||||
}
|
||||
};
|
||||
|
||||
// Load Rhai example scripts
|
||||
let examples_path = PathBuf::from("templates/rhai_examples");
|
||||
let mut example_scripts_display = Vec::new();
|
||||
if examples_path.is_dir() {
|
||||
match std_fs::read_dir(examples_path) {
|
||||
Ok(entries) => {
|
||||
for entry in entries {
|
||||
if let Ok(entry) = entry {
|
||||
let path = entry.path();
|
||||
if path.is_file() && path.extension().and_then(std::ffi::OsStr::to_str) == Some("rhai") {
|
||||
let file_stem = path.file_stem().and_then(std::ffi::OsStr::to_str).unwrap_or("Unknown Script");
|
||||
// Convert filename (e.g., simple_two_step) to a nicer name (e.g., Simple Two Step)
|
||||
let script_name = file_stem.replace("_", " ")
|
||||
.split_whitespace()
|
||||
.map(|word| {
|
||||
let mut c = word.chars();
|
||||
match c.next() {
|
||||
None => String::new(),
|
||||
Some(f) => f.to_uppercase().collect::<String>() + c.as_str(),
|
||||
}
|
||||
})
|
||||
.collect::<Vec<String>>().join(" ");
|
||||
|
||||
match std_fs::read_to_string(&path) {
|
||||
Ok(content) => {
|
||||
example_scripts_display.push(RhaiExampleDisplay { name: script_name, content });
|
||||
}
|
||||
Err(e) => {
|
||||
error!("Failed to read Rhai example script {:?}: {}", path, e);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
Err(e) => {
|
||||
error!("Failed to read Rhai examples directory: {}", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
example_scripts_display.sort_by(|a, b| a.name.cmp(&b.name));
|
||||
|
||||
let list_context = ListFlowsContext {
|
||||
flows,
|
||||
example_scripts: example_scripts_display,
|
||||
error_message: flow_error_message,
|
||||
success_message: None, // TODO: Populate from query params or session later if needed
|
||||
};
|
||||
|
||||
let tera_ctx = Context::from_serialize(&list_context).unwrap_or_else(|e| {
|
||||
error!("Failed to serialize ListFlowsContext: {}", e);
|
||||
// Fallback to a minimal context or an error state if serialization fails
|
||||
let mut err_ctx = Context::new();
|
||||
err_ctx.insert("error_message", &"Critical error preparing page data.".to_string());
|
||||
err_ctx
|
||||
});
|
||||
|
||||
// Still rendering to index.html, which will be the revamped list_flows.html
|
||||
let rendered = tera.render("index.html", &tera_ctx)
|
||||
.map_err(|e| actix_web::error::ErrorInternalServerError(format!("Template error (index.html): {}", e)))?;
|
||||
Ok(HttpResponse::Ok().content_type("text/html").body(rendered))
|
||||
}
|
||||
|
||||
// Handle creation of a new flow
|
||||
async fn create_flow(
|
||||
data: web::Data<AppState>,
|
||||
raw_form_data: String, // Changed to accept raw String
|
||||
) -> impl Responder {
|
||||
info!("Received raw form data for create_flow: {}", raw_form_data);
|
||||
|
||||
// Attempt to parse the raw form data
|
||||
let form_parse_result: Result<CreateFlowRealFormData, serde_urlencoded::de::Error> = serde_urlencoded::from_str(&raw_form_data);
|
||||
|
||||
let form = match form_parse_result {
|
||||
Ok(parsed_form_data) => {
|
||||
info!("Successfully parsed form data: {:?}", parsed_form_data);
|
||||
parsed_form_data // Use the successfully parsed data
|
||||
}
|
||||
Err(e) => {
|
||||
error!("Failed to parse form data from string: {}. Raw data: {}", e, raw_form_data);
|
||||
return HttpResponse::BadRequest().body(format!("Form parsing error: {}. Please check input and logs.", e));
|
||||
}
|
||||
};
|
||||
|
||||
// --- Logic starts here, using `form` which is now CreateFlowRealFormData ---
|
||||
info!("Processing create_flow request for: {}", form.flow_name);
|
||||
|
||||
let db = &data.db;
|
||||
let mut id_counter = match data.next_id_counter.lock() {
|
||||
Ok(guard) => guard,
|
||||
Err(poisoned) => {
|
||||
error!("Mutex for next_id_counter was poisoned: {}. Recovering.", poisoned);
|
||||
poisoned.into_inner() // Attempt to recover
|
||||
}
|
||||
};
|
||||
|
||||
// 1. Create and save the main Flow object
|
||||
*id_counter += 1;
|
||||
let flow_db_id = *id_counter;
|
||||
let flow_uuid = Uuid::new_v4().to_string();
|
||||
|
||||
let flow_instance = Flow::new(
|
||||
flow_db_id,
|
||||
&flow_uuid,
|
||||
&form.flow_name,
|
||||
FlowStatus::Pending.to_db_string() // Use local enum's string representation
|
||||
);
|
||||
|
||||
match db.collection::<Flow>() {
|
||||
Ok(flow_collection) => {
|
||||
if let Err(e) = flow_collection.set(&flow_instance) {
|
||||
error!("Failed to save Flow (name: {}): {:?}. Aborting flow creation.", form.flow_name, e);
|
||||
return HttpResponse::InternalServerError().body(format!("Failed to save main flow data: {:?}", e));
|
||||
}
|
||||
info!("Saved Flow object for '{}', UUID: {}, DB_ID: {}", flow_instance.name, flow_instance.flow_uuid, flow_instance.base_data.id);
|
||||
}
|
||||
Err(e) => {
|
||||
error!("Failed to get Flow collection: {:?}. Aborting flow creation.", e);
|
||||
return HttpResponse::InternalServerError().body(format!("Database error getting flow collection: {:?}", e));
|
||||
}
|
||||
}
|
||||
|
||||
// 2. Create and save FlowStep and SignatureRequirement objects
|
||||
for (step_idx, step_form_data) in form.steps.into_iter().enumerate() {
|
||||
*id_counter += 1;
|
||||
let flow_step_db_id = *id_counter;
|
||||
|
||||
let mut flow_step_instance = FlowStep::new(
|
||||
flow_step_db_id,
|
||||
flow_instance.base_data.id, // Use ID from the saved Flow instance
|
||||
step_idx as u32, // step_order
|
||||
FlowStepStatus::Pending.to_db_string() // Use local enum's string representation
|
||||
);
|
||||
|
||||
if let Some(desc) = step_form_data.description {
|
||||
if !desc.is_empty() { // Only set if description is not empty
|
||||
flow_step_instance = flow_step_instance.description(desc);
|
||||
}
|
||||
}
|
||||
|
||||
match db.collection::<FlowStep>() {
|
||||
Ok(step_collection) => {
|
||||
if let Err(e) = step_collection.set(&flow_step_instance) {
|
||||
error!("Failed to save FlowStep (flow: {}, step_idx: {}): {:?}", flow_instance.name, step_idx, e);
|
||||
return HttpResponse::InternalServerError().body(format!("Failed to save flow step: {:?}", e));
|
||||
}
|
||||
info!("Saved FlowStep {} for flow '{}', DB_ID: {}", step_idx + 1, flow_instance.name, flow_step_instance.base_data.id);
|
||||
}
|
||||
Err(e) => {
|
||||
error!("Failed to get FlowStep collection: {:?}. Aborting.", e);
|
||||
return HttpResponse::InternalServerError().body(format!("Database error getting step collection: {:?}", e));
|
||||
}
|
||||
}
|
||||
|
||||
for (req_idx, req_form_data) in step_form_data.requirements.into_iter().enumerate() {
|
||||
*id_counter += 1;
|
||||
let sig_req_db_id = *id_counter;
|
||||
|
||||
let sig_req_instance = SignatureRequirement::new(
|
||||
sig_req_db_id,
|
||||
flow_step_instance.base_data.id, // Use ID from the saved FlowStep instance
|
||||
&req_form_data.public_key,
|
||||
&req_form_data.message,
|
||||
SignatureRequirementStatus::Pending.to_db_string() // Use local enum's string representation
|
||||
);
|
||||
|
||||
match db.collection::<SignatureRequirement>() {
|
||||
Ok(req_collection) => {
|
||||
if let Err(e) = req_collection.set(&sig_req_instance) {
|
||||
error!("Failed to save SignatureRequirement (flow: {}, step: {}, req_idx: {}): {:?}", flow_instance.name, step_idx, req_idx, e);
|
||||
return HttpResponse::InternalServerError().body(format!("Failed to save signature requirement: {:?}", e));
|
||||
}
|
||||
info!(
|
||||
"Saved SignatureRequirement {} for step {} of flow '{}', DB_ID: {}",
|
||||
req_idx + 1, step_idx + 1, flow_instance.name, sig_req_instance.base_data.id
|
||||
);
|
||||
}
|
||||
Err(e) => {
|
||||
error!("Failed to get SignatureRequirement collection: {:?}. Aborting.", e);
|
||||
return HttpResponse::InternalServerError().body(format!("Database error getting requirement collection: {:?}", e));
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
info!("Finished processing all steps for flow '{}', UUID: {}", flow_instance.name, flow_instance.flow_uuid);
|
||||
|
||||
HttpResponse::SeeOther()
|
||||
.append_header((actix_web::http::header::LOCATION, "/"))
|
||||
.finish()
|
||||
}
|
||||
|
||||
// --- Rhai-Callable Helper Functions ---
|
||||
|
||||
fn rhai_create_flow_entry(
|
||||
db_arc: Arc<OurDB>,
|
||||
id_counter_arc: Arc<Mutex<u32>>,
|
||||
name: String,
|
||||
) -> Result<u32, Box<rhai::EvalAltResult>> {
|
||||
info!("Rhai: Attempting to create flow entry with name: {}", name);
|
||||
|
||||
let mut id_counter = match id_counter_arc.lock() {
|
||||
Ok(guard) => guard,
|
||||
Err(poisoned) => {
|
||||
let err_msg = format!("Rhai: Mutex for next_id_counter was poisoned: {}", poisoned);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
};
|
||||
|
||||
*id_counter += 1;
|
||||
let flow_db_id = *id_counter;
|
||||
let flow_uuid = Uuid::new_v4().to_string();
|
||||
|
||||
let flow_instance = Flow::new(
|
||||
flow_db_id,
|
||||
&flow_uuid,
|
||||
&name,
|
||||
FlowStatus::Pending.to_db_string(),
|
||||
);
|
||||
|
||||
match db_arc.collection::<Flow>() {
|
||||
Ok(flow_collection) => {
|
||||
if let Err(e) = flow_collection.set(&flow_instance) {
|
||||
let err_msg = format!("Rhai: Failed to save Flow (name: {}): {:?}", name, e);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
info!("Rhai: Saved Flow object for '{}', UUID: {}, DB_ID: {}", flow_instance.name, flow_instance.flow_uuid, flow_instance.base_data.id);
|
||||
Ok(flow_instance.base_data.id)
|
||||
}
|
||||
Err(e) => {
|
||||
let err_msg = format!("Rhai: Failed to get Flow collection: {:?}", e);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
fn rhai_add_step_entry(
|
||||
db_arc: Arc<OurDB>,
|
||||
id_counter_arc: Arc<Mutex<u32>>,
|
||||
flow_db_id: u32, // ID of the parent flow
|
||||
description: String,
|
||||
order: u32,
|
||||
) -> Result<u32, Box<rhai::EvalAltResult>> {
|
||||
info!(
|
||||
"Rhai: Adding step to flow ID {}, order {}, description: '{}'",
|
||||
flow_db_id, order, description
|
||||
);
|
||||
|
||||
let mut id_counter = match id_counter_arc.lock() {
|
||||
Ok(guard) => guard,
|
||||
Err(poisoned) => {
|
||||
let err_msg = format!("Rhai: Mutex for next_id_counter was poisoned: {}", poisoned);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
};
|
||||
|
||||
*id_counter += 1;
|
||||
let flow_step_db_id = *id_counter;
|
||||
|
||||
let mut flow_step_instance = FlowStep::new(
|
||||
flow_step_db_id,
|
||||
flow_db_id,
|
||||
order,
|
||||
FlowStepStatus::Pending.to_db_string(),
|
||||
);
|
||||
|
||||
if !description.is_empty() {
|
||||
flow_step_instance = flow_step_instance.description(description);
|
||||
}
|
||||
|
||||
match db_arc.collection::<FlowStep>() {
|
||||
Ok(step_collection) => {
|
||||
if let Err(e) = step_collection.set(&flow_step_instance) {
|
||||
let err_msg = format!(
|
||||
"Rhai: Failed to save FlowStep (flow_id: {}, order: {}): {:?}",
|
||||
flow_db_id, order, e
|
||||
);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
info!(
|
||||
"Rhai: Saved FlowStep for flow_id {}, order {}, DB_ID: {}",
|
||||
flow_db_id, order, flow_step_instance.base_data.id
|
||||
);
|
||||
Ok(flow_step_instance.base_data.id)
|
||||
}
|
||||
Err(e) => {
|
||||
let err_msg = format!("Rhai: Failed to get FlowStep collection: {:?}", e);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
fn rhai_add_requirement_entry(
|
||||
db_arc: Arc<OurDB>,
|
||||
id_counter_arc: Arc<Mutex<u32>>,
|
||||
step_db_id: u32, // ID of the parent step
|
||||
public_key: String,
|
||||
message: String,
|
||||
) -> Result<u32, Box<rhai::EvalAltResult>> {
|
||||
info!(
|
||||
"Rhai: Adding requirement to step ID {}, pk: '{}', msg: '{}'",
|
||||
step_db_id, public_key, message
|
||||
);
|
||||
|
||||
let mut id_counter = match id_counter_arc.lock() {
|
||||
Ok(guard) => guard,
|
||||
Err(poisoned) => {
|
||||
let err_msg = format!("Rhai: Mutex for next_id_counter was poisoned: {}", poisoned);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
};
|
||||
|
||||
*id_counter += 1;
|
||||
let sig_req_db_id = *id_counter;
|
||||
|
||||
let sig_req_instance = SignatureRequirement::new(
|
||||
sig_req_db_id,
|
||||
step_db_id,
|
||||
&public_key,
|
||||
&message,
|
||||
SignatureRequirementStatus::Pending.to_db_string(),
|
||||
);
|
||||
|
||||
match db_arc.collection::<SignatureRequirement>() {
|
||||
Ok(req_collection) => {
|
||||
if let Err(e) = req_collection.set(&sig_req_instance) {
|
||||
let err_msg = format!(
|
||||
"Rhai: Failed to save SigRequirement (step_id: {}): {:?}",
|
||||
step_db_id, e
|
||||
);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
info!(
|
||||
"Rhai: Saved SigRequirement for step_id {}, DB_ID: {}",
|
||||
step_db_id, sig_req_instance.base_data.id
|
||||
);
|
||||
Ok(sig_req_instance.base_data.id)
|
||||
}
|
||||
Err(e) => {
|
||||
let err_msg = format!("Rhai: Failed to get SigRequirement collection: {:?}", e);
|
||||
error!("{}", err_msg);
|
||||
return Err(Box::new(rhai::EvalAltResult::ErrorRuntime(err_msg.into(), Position::NONE)));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Handle creation of a new flow from a Rhai script
|
||||
async fn create_flow_from_script(
|
||||
data: web::Data<AppState>,
|
||||
form: web::Form<RhaiScriptFormData>,
|
||||
) -> impl Responder {
|
||||
info!("Received Rhai script for flow creation:\n{}", form.rhai_script);
|
||||
|
||||
let mut engine = Engine::new();
|
||||
|
||||
// Clone Arcs for capturing in closures
|
||||
let db_clone_for_flow = data.db.clone();
|
||||
let id_clone_for_flow = data.next_id_counter.clone();
|
||||
let db_clone_for_step = data.db.clone();
|
||||
let id_clone_for_step = data.next_id_counter.clone();
|
||||
let db_clone_for_req = data.db.clone();
|
||||
let id_clone_for_req = data.next_id_counter.clone();
|
||||
|
||||
engine
|
||||
.register_fn("create_flow", move |name: String| {
|
||||
crate::rhai_create_flow_entry(db_clone_for_flow.clone(), id_clone_for_flow.clone(), name)
|
||||
})
|
||||
.register_fn("add_step", move |flow_id: u32, desc: String, order: i64| {
|
||||
if order < 0 || order > u32::MAX as i64 {
|
||||
return Err(Box::new(EvalAltResult::ErrorRuntime(format!("Order {} is out of range for u32", order).into(), Position::NONE)));
|
||||
}
|
||||
crate::rhai_add_step_entry(db_clone_for_step.clone(), id_clone_for_step.clone(), flow_id, desc, order as u32)
|
||||
})
|
||||
.register_fn("add_requirement", move |step_id: u32, pk: String, msg: String| {
|
||||
crate::rhai_add_requirement_entry(db_clone_for_req.clone(), id_clone_for_req.clone(), step_id, pk, msg)
|
||||
});
|
||||
|
||||
match engine.eval::<()>(&form.rhai_script) { // Expecting () as successful script execution doesn't need to return a value to Rust here.
|
||||
Ok(_) => {
|
||||
info!("Rhai script executed successfully.");
|
||||
HttpResponse::SeeOther()
|
||||
.append_header((actix_web::http::header::LOCATION, "/"))
|
||||
.finish()
|
||||
}
|
||||
Err(e) => {
|
||||
error!("Rhai script execution failed: {}", e.to_string());
|
||||
HttpResponse::BadRequest().body(format!("Rhai script error: {}\n\nYour script was:\n{}", e.to_string(), form.rhai_script))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Placeholder for SigSocket WebSocket handler
|
||||
async fn websocket_handler(
|
||||
req: actix_web::HttpRequest,
|
||||
stream: actix_web::web::Payload,
|
||||
service: web::Data<Arc<SigSocketService>>,
|
||||
) -> ActixResult<HttpResponse> {
|
||||
info!("WebSocket connection attempt");
|
||||
let handler = service.create_websocket_handler();
|
||||
ws::start(handler, &req, stream)
|
||||
}
|
||||
|
||||
|
||||
// --- Extracted Helper Functions for App Setup and Configuration ---
|
||||
|
||||
/// Sets up the shared application data (AppState).
|
||||
/// Allows overriding the database path for testing purposes.
|
||||
pub async fn setup_app_data(db_path_override: Option<String>) -> Result<web::Data<AppState>, std::io::Error> {
|
||||
// Initialize templates
|
||||
let tera = match Tera::new("templates/**/*") {
|
||||
Ok(t) => t,
|
||||
Err(e) => {
|
||||
error!("Critical: Tera template parsing error(s): {}", e);
|
||||
// Convert tera::Error to std::io::Error
|
||||
return Err(std::io::Error::new(std::io::ErrorKind::Other, format!("Tera init error: {}", e)));
|
||||
}
|
||||
};
|
||||
|
||||
// Initialize SigSocket registry and service
|
||||
let registry = Arc::new(RwLock::new(ConnectionRegistry::new()));
|
||||
let sigsocket_service = Arc::new(SigSocketService::new(registry.clone()));
|
||||
|
||||
// Load environment variables from .env file
|
||||
dotenv().ok();
|
||||
|
||||
// Initialize Database
|
||||
let database_path = db_path_override.unwrap_or_else(||
|
||||
env::var("DATABASE_PATH").unwrap_or_else(|_|
|
||||
{
|
||||
info!("DATABASE_PATH not set, defaulting to ./flowbroker_db");
|
||||
"./flowbroker_db".to_string()
|
||||
})
|
||||
);
|
||||
let db = match OurDB::new(&database_path, true) { // true for create_if_missing
|
||||
Ok(db_instance) => Arc::new(db_instance),
|
||||
Err(e) => {
|
||||
error!("Failed to initialize database at '{}': {}. Please ensure the path is writable.", database_path, e);
|
||||
// Convert heromodels::Error to std::io::Error (assuming Error impls std::error::Error)
|
||||
return Err(std::io::Error::new(std::io::ErrorKind::Other, format!("DB init error: {}", e)));
|
||||
}
|
||||
};
|
||||
info!("Database initialized at: {}", database_path);
|
||||
|
||||
// Initialize ID counter for temporary primary keys
|
||||
let next_id_counter = Arc::new(Mutex::new(0_u32));
|
||||
// TODO: Replace this with a robust primary key generation strategy from the database itself if possible.
|
||||
|
||||
// Create shared application state
|
||||
Ok(web::Data::new(AppState {
|
||||
templates: tera,
|
||||
sigsocket_service: sigsocket_service.clone(), // Clone for AppState
|
||||
db,
|
||||
next_id_counter,
|
||||
}))
|
||||
}
|
||||
|
||||
/// Configures the application routes.
|
||||
pub fn configure_app_routes(cfg: &mut web::ServiceConfig) {
|
||||
// Note: AppState should be added via .app_data() before calling this configure function.
|
||||
// The websocket_handler specifically needs web::Data<Arc<SigSocketService>>.
|
||||
// The main HttpServer setup will add AppState (which includes an Arc<SigSocketService>)
|
||||
// and also the specific web::Data<Arc<SigSocketService>> for handlers like websocket_handler that expect it directly.
|
||||
|
||||
cfg.route("/", web::get().to(list_flows))
|
||||
.service(
|
||||
web::scope("/flows") // Group flow-related routes under /flows
|
||||
// .route("", web::get().to(list_flows)) // If you want /flows to also list flows
|
||||
// .route("/new", web::get().to(new_flow_form)) // Deprecated, functionality merged into root list_flows
|
||||
.route("/create", web::post().to(create_flow))
|
||||
.route("/create_script", web::post().to(create_flow_from_script)) // Moved inside /flows scope
|
||||
)
|
||||
.service(web::resource("/ws/").route(web::get().to(websocket_handler)))
|
||||
.service(fs::Files::new("/static", "./static").show_files_listing()); // Static files
|
||||
}
|
||||
|
||||
// --- Main Function ---
|
||||
#[actix_web::main]
|
||||
async fn main() -> std::io::Result<()> {
|
||||
env_logger::init_from_env(env_logger::Env::default().default_filter_or("info"));
|
||||
|
||||
let app_data = match setup_app_data(None).await {
|
||||
Ok(data) => data,
|
||||
Err(e) => {
|
||||
error!("Failed to setup application data: {}", e);
|
||||
std::process::exit(1);
|
||||
}
|
||||
};
|
||||
|
||||
// The AppState (app_data) already contains an Arc<SigSocketService>.
|
||||
// Handlers like websocket_handler that take web::Data<Arc<SigSocketService>> directly
|
||||
// will be able to access it if AppState is correctly registered and the handler signature matches.
|
||||
// Alternatively, if a handler needs *only* the SigSocketService, it can be added separately.
|
||||
// For the websocket_handler as defined (taking web::Data<Arc<SigSocketService>>),
|
||||
// it needs this specific type registered with app_data.
|
||||
let sigsocket_service_for_ws_handler_data = web::Data::new(app_data.sigsocket_service.clone());
|
||||
|
||||
info!("Flowbroker server starting on http://127.0.0.1:8081");
|
||||
info!("SigSocket WebSocket endpoint available at ws://127.0.0.1:8081/ws");
|
||||
|
||||
HttpServer::new(move || {
|
||||
App::new()
|
||||
.app_data(app_data.clone()) // Main app state (includes SigSocketService)
|
||||
.app_data(sigsocket_service_for_ws_handler_data.clone()) // Specifically for handlers expecting web::Data<Arc<SigSocketService>>
|
||||
.configure(configure_app_routes)
|
||||
})
|
||||
.bind("127.0.0.1:8081")? // Using a different port for now
|
||||
.run()
|
||||
.await
|
||||
}
|
||||
34
flowbroker/start.sh
Executable file
34
flowbroker/start.sh
Executable file
@@ -0,0 +1,34 @@
|
||||
#!/bin/zsh
|
||||
|
||||
FORCE_KILL=false
|
||||
|
||||
# Parse command line options
|
||||
while getopts ":f" opt; do
|
||||
case ${opt} in
|
||||
f )
|
||||
FORCE_KILL=true
|
||||
;;
|
||||
\? )
|
||||
echo "Usage: cmd [-f]"
|
||||
exit 1
|
||||
;;
|
||||
esac
|
||||
done
|
||||
|
||||
if [ "$FORCE_KILL" = true ] ; then
|
||||
echo "Attempting to kill process on port 8081..."
|
||||
# Get PID of process using port 8081 and kill it
|
||||
# -t option for lsof outputs only the PID
|
||||
# xargs -r ensures kill is only run if lsof finds a PID
|
||||
lsof -t -i:8081 | xargs -r kill -9
|
||||
if [ $? -eq 0 ]; then
|
||||
echo "Process(es) on port 8081 killed."
|
||||
else
|
||||
echo "No process found on port 8081 or failed to kill."
|
||||
fi
|
||||
# Give a moment for the port to be released
|
||||
sleep 1
|
||||
fi
|
||||
|
||||
echo "Starting Flowbroker server..."
|
||||
cargo run
|
||||
127
flowbroker/static/style.css
Normal file
127
flowbroker/static/style.css
Normal file
@@ -0,0 +1,127 @@
|
||||
body {
|
||||
font-family: sans-serif;
|
||||
margin: 20px;
|
||||
line-height: 1.6;
|
||||
}
|
||||
|
||||
h1, h2 {
|
||||
color: #333;
|
||||
}
|
||||
|
||||
a {
|
||||
color: #007bff;
|
||||
text-decoration: none;
|
||||
}
|
||||
|
||||
a:hover {
|
||||
text-decoration: underline;
|
||||
}
|
||||
|
||||
form div {
|
||||
margin-bottom: 10px;
|
||||
}
|
||||
|
||||
label {
|
||||
display: block;
|
||||
margin-bottom: 5px;
|
||||
}
|
||||
|
||||
input[type="text"], textarea {
|
||||
width: 100%;
|
||||
padding: 8px;
|
||||
box-sizing: border-box;
|
||||
border: 1px solid #ccc;
|
||||
border-radius: 4px;
|
||||
}
|
||||
|
||||
button {
|
||||
background-color: #007bff;
|
||||
color: white;
|
||||
padding: 10px 15px;
|
||||
border: none;
|
||||
border-radius: 4px;
|
||||
cursor: pointer;
|
||||
}
|
||||
|
||||
button:hover {
|
||||
background-color: #0056b3;
|
||||
}
|
||||
|
||||
hr {
|
||||
margin: 20px 0;
|
||||
}
|
||||
|
||||
#flows-list ul {
|
||||
list-style-type: none;
|
||||
padding: 0;
|
||||
}
|
||||
|
||||
#flows-list li {
|
||||
border: 1px solid #eee;
|
||||
padding: 10px;
|
||||
margin-bottom: 10px;
|
||||
border-radius: 4px;
|
||||
}
|
||||
|
||||
/* Styles for dynamic form elements from create_flow.html */
|
||||
.step, .requirement {
|
||||
border: 1px solid #ddd;
|
||||
padding: 15px; /* Increased padding */
|
||||
margin-bottom: 15px;
|
||||
border-radius: 4px;
|
||||
background-color: #f9f9f9;
|
||||
}
|
||||
|
||||
.step h3, .step h4, .requirement h5 {
|
||||
margin-top: 0;
|
||||
color: #555; /* Slightly softer color */
|
||||
}
|
||||
|
||||
.step .requirementsContainer {
|
||||
margin-left: 20px;
|
||||
border-left: 3px solid #007bff; /* Thicker border */
|
||||
padding-left: 20px; /* Increased padding */
|
||||
margin-top: 10px;
|
||||
margin-bottom: 10px;
|
||||
}
|
||||
|
||||
button.removeStepBtn, button.removeRequirementBtn {
|
||||
background-color: #dc3545;
|
||||
color: white;
|
||||
padding: 5px 10px; /* Adjusted padding */
|
||||
border: none;
|
||||
border-radius: 4px;
|
||||
cursor: pointer;
|
||||
margin-top: 10px; /* Increased margin */
|
||||
float: right; /* Align to the right */
|
||||
}
|
||||
button.removeStepBtn:hover, button.removeRequirementBtn:hover {
|
||||
background-color: #c82333;
|
||||
}
|
||||
|
||||
/* Clearfix for floated remove buttons */
|
||||
.step::after, .requirement::after {
|
||||
content: "";
|
||||
clear: both;
|
||||
display: table;
|
||||
}
|
||||
|
||||
.addBtn { /* Style for Add Step / Add Requirement buttons */
|
||||
background-color: #28a745;
|
||||
color: white;
|
||||
padding: 8px 12px;
|
||||
border: none;
|
||||
border-radius: 4px;
|
||||
cursor: pointer;
|
||||
margin-top: 10px;
|
||||
margin-bottom: 10px;
|
||||
}
|
||||
.addBtn:hover {
|
||||
background-color: #218838;
|
||||
}
|
||||
|
||||
/* General styling for form elements within steps/requirements for consistency */
|
||||
.step input[type="text"], .step textarea,
|
||||
.requirement input[type="text"], .requirement textarea {
|
||||
margin-bottom: 8px; /* Add some space below inputs */
|
||||
}
|
||||
187
flowbroker/templates/create_flow.html
Normal file
187
flowbroker/templates/create_flow.html
Normal file
@@ -0,0 +1,187 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="en">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<title>Flowbroker - Create Flow</title>
|
||||
<link rel="stylesheet" href="/static/style.css">
|
||||
<style>
|
||||
.step, .requirement {
|
||||
border: 1px solid #ddd;
|
||||
padding: 10px;
|
||||
margin-bottom: 15px;
|
||||
border-radius: 4px;
|
||||
background-color: #f9f9f9;
|
||||
}
|
||||
.step h3, .step h4, .requirement h5 {
|
||||
margin-top: 0;
|
||||
}
|
||||
.step .requirementsContainer {
|
||||
margin-left: 20px;
|
||||
border-left: 2px solid #007bff;
|
||||
padding-left: 15px;
|
||||
}
|
||||
button.removeStepBtn, button.removeRequirementBtn {
|
||||
background-color: #dc3545;
|
||||
margin-top: 5px;
|
||||
}
|
||||
button.removeStepBtn:hover, button.removeRequirementBtn:hover {
|
||||
background-color: #c82333;
|
||||
}
|
||||
</style>
|
||||
</head>
|
||||
<body>
|
||||
<h1>Create New Flow</h1>
|
||||
<form id="createFlowForm" action="/flows" method="post">
|
||||
<div>
|
||||
<label for="flow_name">Flow Name:</label>
|
||||
<input type="text" id="flow_name" name="flow_name" required>
|
||||
</div>
|
||||
<hr>
|
||||
|
||||
<div id="stepsContainer">
|
||||
<!-- Steps will be added here by JavaScript -->
|
||||
</div>
|
||||
|
||||
<button type="button" id="addStepBtn" class="addBtn">Add Step</button>
|
||||
<hr>
|
||||
<button type="submit">Create Flow</button>
|
||||
</form>
|
||||
<p><a href="/">Back to Flows List</a></p>
|
||||
|
||||
<!-- Template for a new step -->
|
||||
<template id="stepTemplate">
|
||||
<div class="step" data-step-index="">
|
||||
<h3>Step <span class="step-number"></span></h3>
|
||||
<button type="button" class="removeStepBtn">Remove This Step</button>
|
||||
<div>
|
||||
<label>Step Description (Optional):</label>
|
||||
<input type="text" name="steps[X].description" class="step-description">
|
||||
</div>
|
||||
<h4>Signature Requirements for Step <span class="step-number"></span></h4>
|
||||
<div class="requirementsContainer" data-step-index="">
|
||||
<!-- Requirements will be added here -->
|
||||
</div>
|
||||
<button type="button" class="addRequirementBtn addBtn" data-step-index="">Add Signature Requirement</button>
|
||||
</div>
|
||||
</template>
|
||||
|
||||
<!-- Template for a new signature requirement -->
|
||||
<template id="requirementTemplate">
|
||||
<div class="requirement" data-req-index="">
|
||||
<h5>Requirement <span class="req-number"></span></h5>
|
||||
<button type="button" class="removeRequirementBtn">Remove Requirement</button>
|
||||
<div>
|
||||
<label>Message to Sign:</label>
|
||||
<textarea name="steps[X].requirements[Y].message" rows="2" required class="req-message"></textarea>
|
||||
</div>
|
||||
<div>
|
||||
<label>Required Public Key:</label>
|
||||
<input type="text" name="steps[X].requirements[Y].public_key" required class="req-pubkey">
|
||||
</div>
|
||||
</div>
|
||||
</template>
|
||||
|
||||
<script>
|
||||
document.addEventListener('DOMContentLoaded', () => {
|
||||
const stepsContainer = document.getElementById('stepsContainer');
|
||||
const addStepBtn = document.getElementById('addStepBtn');
|
||||
const stepTemplate = document.getElementById('stepTemplate');
|
||||
const requirementTemplate = document.getElementById('requirementTemplate');
|
||||
const form = document.getElementById('createFlowForm');
|
||||
|
||||
const updateIndices = () => {
|
||||
const steps = stepsContainer.querySelectorAll('.step');
|
||||
steps.forEach((step, stepIdx) => {
|
||||
// Update step-level attributes and text
|
||||
step.dataset.stepIndex = stepIdx;
|
||||
step.querySelector('.step-number').textContent = stepIdx + 1;
|
||||
step.querySelector('.step-description').name = `steps[${stepIdx}].description`;
|
||||
|
||||
const addReqBtn = step.querySelector('.addRequirementBtn');
|
||||
if (addReqBtn) addReqBtn.dataset.stepIndex = stepIdx;
|
||||
|
||||
const requirements = step.querySelectorAll('.requirementsContainer .requirement');
|
||||
requirements.forEach((req, reqIdx) => {
|
||||
// Update requirement-level attributes and text
|
||||
req.dataset.reqIndex = reqIdx;
|
||||
req.querySelector('.req-number').textContent = reqIdx + 1;
|
||||
req.querySelector('.req-message').name = `steps[${stepIdx}].requirements[${reqIdx}].message`;
|
||||
req.querySelector('.req-pubkey').name = `steps[${stepIdx}].requirements[${reqIdx}].public_key`;
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
const addRequirement = (currentStepElement, stepIndex) => {
|
||||
const requirementsContainer = currentStepElement.querySelector('.requirementsContainer');
|
||||
const reqFragment = requirementTemplate.content.cloneNode(true);
|
||||
const newRequirement = reqFragment.querySelector('.requirement');
|
||||
|
||||
requirementsContainer.appendChild(newRequirement);
|
||||
updateIndices(); // Update all indices after adding
|
||||
};
|
||||
|
||||
const addStep = () => {
|
||||
const stepFragment = stepTemplate.content.cloneNode(true);
|
||||
const newStep = stepFragment.querySelector('.step');
|
||||
stepsContainer.appendChild(newStep);
|
||||
|
||||
// Add at least one requirement to the new step automatically
|
||||
const currentStepIndex = stepsContainer.querySelectorAll('.step').length - 1;
|
||||
addRequirement(newStep, currentStepIndex);
|
||||
|
||||
updateIndices(); // Update all indices after adding
|
||||
};
|
||||
|
||||
// Event delegation for remove buttons and add requirement button
|
||||
stepsContainer.addEventListener('click', (event) => {
|
||||
if (event.target.classList.contains('removeStepBtn')) {
|
||||
event.target.closest('.step').remove();
|
||||
if (stepsContainer.querySelectorAll('.step').length === 0) { // Ensure at least one step
|
||||
addStep();
|
||||
}
|
||||
updateIndices();
|
||||
} else if (event.target.classList.contains('addRequirementBtn')) {
|
||||
const stepElement = event.target.closest('.step');
|
||||
const stepIndex = parseInt(stepElement.dataset.stepIndex, 10);
|
||||
addRequirement(stepElement, stepIndex);
|
||||
} else if (event.target.classList.contains('removeRequirementBtn')) {
|
||||
const requirementElement = event.target.closest('.requirement');
|
||||
const stepElement = event.target.closest('.step');
|
||||
const requirementsContainer = stepElement.querySelector('.requirementsContainer');
|
||||
requirementElement.remove();
|
||||
// Ensure at least one requirement per step
|
||||
if (requirementsContainer.querySelectorAll('.requirement').length === 0) {
|
||||
const stepIndex = parseInt(stepElement.dataset.stepIndex, 10);
|
||||
addRequirement(stepElement, stepIndex);
|
||||
}
|
||||
updateIndices();
|
||||
}
|
||||
});
|
||||
|
||||
addStepBtn.addEventListener('click', addStep);
|
||||
|
||||
// Add one step by default when the page loads
|
||||
if (stepsContainer.children.length === 0) {
|
||||
addStep();
|
||||
}
|
||||
|
||||
// Optional: Validate that there's at least one step and one requirement before submit
|
||||
form.addEventListener('submit', (event) => {
|
||||
if (stepsContainer.querySelectorAll('.step').length === 0) {
|
||||
alert('Please add at least one step to the flow.');
|
||||
event.preventDefault();
|
||||
return;
|
||||
}
|
||||
const steps = stepsContainer.querySelectorAll('.step');
|
||||
for (let i = 0; i < steps.length; i++) {
|
||||
if (steps[i].querySelectorAll('.requirementsContainer .requirement').length === 0) {
|
||||
alert(`Step ${i + 1} must have at least one signature requirement.`);
|
||||
event.preventDefault();
|
||||
return;
|
||||
}
|
||||
}
|
||||
});
|
||||
});
|
||||
</script>
|
||||
</body>
|
||||
</html>
|
||||
317
flowbroker/templates/index.html
Normal file
317
flowbroker/templates/index.html
Normal file
@@ -0,0 +1,317 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="en">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
||||
<title>FlowBroker Dashboard</title>
|
||||
<link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.2/dist/css/bootstrap.min.css" rel="stylesheet"
|
||||
integrity="sha384-T3c6CoIi6uLrA9TneNEoa7RxnatzjcDSCmG1MXxSR1GAsXEV/Dwwykc2MPK8M2HN" crossorigin="anonymous">
|
||||
<!-- Optional: Link to your custom style.css if needed, but ensure it doesn't conflict heavily with Bootstrap -->
|
||||
<link rel="stylesheet" href="/static/style.css">
|
||||
</head>
|
||||
<body>
|
||||
<nav class="navbar navbar-expand-lg navbar-dark bg-dark">
|
||||
<div class="container-fluid">
|
||||
<a class="navbar-brand" href="/">FlowBroker</a>
|
||||
<button class="navbar-toggler" type="button" data-bs-toggle="collapse" data-bs-target="#navbarNav"
|
||||
aria-controls="navbarNav" aria-expanded="false" aria-label="Toggle navigation">
|
||||
<span class="navbar-toggler-icon"></span>
|
||||
</button>
|
||||
<div class="collapse navbar-collapse" id="navbarNav">
|
||||
<ul class="navbar-nav">
|
||||
<li class="nav-item">
|
||||
<a class="nav-link active" aria-current="page" href="/">Dashboard</a>
|
||||
</li>
|
||||
<!-- Add other nav items here later if needed -->
|
||||
</ul>
|
||||
</div>
|
||||
</div>
|
||||
</nav>
|
||||
|
||||
<div class="container mt-4">
|
||||
{% if error_message %}
|
||||
<div class="alert alert-danger" role="alert">
|
||||
{{ error_message }}
|
||||
</div>
|
||||
{% endif %}
|
||||
{% if success_message %}
|
||||
<div class="alert alert-success" role="alert">
|
||||
{{ success_message }}
|
||||
</div>
|
||||
{% endif %}
|
||||
|
||||
<h2>Active Flows</h2>
|
||||
<div id="flows-list" class="mb-4">
|
||||
{% if flows %}
|
||||
<table class="table table-hover">
|
||||
<thead>
|
||||
<tr>
|
||||
<th scope="col">Name</th>
|
||||
<th scope="col">UUID</th>
|
||||
<th scope="col">Status</th>
|
||||
<th scope="col">Created At</th>
|
||||
<th scope="col">Actions</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for flow in flows %}
|
||||
<tr>
|
||||
<td>{{ flow.name }}</td>
|
||||
<td><small>{{ flow.flow_uuid }}</small></td>
|
||||
<td><span class="badge bg-secondary">{{ flow.status | default(value="Unknown") }}</span></td>
|
||||
<td>{{ flow.base_data.created_at | date(format="%Y-%m-%d %H:%M:%S") }}</td>
|
||||
<td>
|
||||
<a href="/flows/{{ flow.flow_uuid }}" class="btn btn-sm btn-primary">View</a>
|
||||
<button class="btn btn-sm btn-success run-flow-btn" data-flow-uuid="{{ flow.flow_uuid }}">Run</button>
|
||||
</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
{% else %}
|
||||
<p>No active flows found. You can create one below.</p>
|
||||
{% endif %}
|
||||
</div>
|
||||
|
||||
<hr class="my-4">
|
||||
|
||||
<h2>Runnable Example Scripts</h2>
|
||||
<div id="example-scripts-list" class="mb-4">
|
||||
{% if example_scripts %}
|
||||
<ul class="list-group">
|
||||
{% for example in example_scripts %}
|
||||
<li class="list-group-item d-flex justify-content-between align-items-center">
|
||||
{{ example.name }}
|
||||
<button class="btn btn-sm btn-info load-script-btn" data-script-content="{{ example.content | escape }}">Load into Form</button>
|
||||
</li>
|
||||
{% endfor %}
|
||||
</ul>
|
||||
{% else %}
|
||||
<p>No example scripts found.</p>
|
||||
{% endif %}
|
||||
</div>
|
||||
|
||||
<hr class="my-4">
|
||||
|
||||
<div class="row">
|
||||
<div class="col-md-6 mb-4">
|
||||
<h2>Create New Flow from Rhai Script</h2>
|
||||
<div id="create-from-rhai-section">
|
||||
<form action="/flows/create_script" method="POST">
|
||||
<div class="mb-3">
|
||||
<label for="rhai_script_content" class="form-label">Rhai Script:</label>
|
||||
<textarea class="form-control" id="rhai_script_content" name="rhai_script" rows="10" placeholder="Enter your Rhai script here or select an example using the 'Load into Form' buttons above..."></textarea>
|
||||
</div>
|
||||
<button type="submit" class="btn btn-primary">Create Flow from Script</button>
|
||||
</form>
|
||||
</div>
|
||||
</div>
|
||||
<div class="col-md-6 mb-4">
|
||||
<h2>Create New Flow (Step-by-Step UI)</h2>
|
||||
<div id="create-step-by-step-section">
|
||||
<form id="createFlowForm_dynamic" action="/flows/create" method="post">
|
||||
<div class="mb-3">
|
||||
<label for="flow_name_dynamic" class="form-label">Flow Name:</label>
|
||||
<input type="text" id="flow_name_dynamic" name="flow_name" class="form-control" required>
|
||||
</div>
|
||||
<hr>
|
||||
|
||||
<div id="stepsContainer_dynamic" class="mb-3">
|
||||
<!-- Steps will be added here by JavaScript -->
|
||||
<p class="text-muted"><em>Steps will appear here as you add them.</em></p>
|
||||
</div>
|
||||
|
||||
<button type="button" id="addStepBtn_dynamic" class="btn btn-secondary mb-3">Add Step</button>
|
||||
<hr>
|
||||
<button type="submit" class="btn btn-primary">Create Flow (Step-by-Step)</button>
|
||||
</form>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
</div>
|
||||
|
||||
<!-- Templates for Dynamic Step-by-Step Form -->
|
||||
<template id="stepTemplate_dynamic">
|
||||
<div class="step card mb-3" data-step-index="">
|
||||
<div class="card-header d-flex justify-content-between align-items-center">
|
||||
<h5 class="mb-0">Step <span class="step-number"></span></h5>
|
||||
<button type="button" class="btn btn-danger btn-sm removeStepBtn_dynamic">Remove This Step</button>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
<div class="mb-3">
|
||||
<label class="form-label">Step Description (Optional):</label>
|
||||
<input type="text" name="steps[X].description" class="form-control step-description_dynamic">
|
||||
</div>
|
||||
<h6>Signature Requirements for Step <span class="step-number"></span>:</h6>
|
||||
<div class="requirementsContainer_dynamic ps-3" data-step-index="">
|
||||
<!-- Requirements will be added here by JS -->
|
||||
<p class="text-muted small"><em>Requirements for this step will appear here.</em></p>
|
||||
</div>
|
||||
<button type="button" class="btn btn-outline-secondary btn-sm addRequirementBtn_dynamic mt-2" data-step-index="">Add Signature Requirement</button>
|
||||
</div>
|
||||
</div>
|
||||
</template>
|
||||
|
||||
<template id="requirementTemplate_dynamic">
|
||||
<div class="requirement card mb-2" data-req-index="">
|
||||
<div class="card-body">
|
||||
<div class="d-flex justify-content-between align-items-center mb-2">
|
||||
<strong>Requirement <span class="req-number"></span></strong>
|
||||
<button type="button" class="btn btn-danger btn-sm removeRequirementBtn_dynamic">Remove Requirement</button>
|
||||
</div>
|
||||
<div class="mb-2">
|
||||
<label class="form-label">Message to Sign:</label>
|
||||
<textarea name="steps[X].requirements[Y].message" rows="2" class="form-control req-message_dynamic" required></textarea>
|
||||
</div>
|
||||
<div>
|
||||
<label class="form-label">Required Public Key:</label>
|
||||
<input type="text" name="steps[X].requirements[Y].public_key" class="form-control req-pubkey_dynamic" required>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</template>
|
||||
<!-- End of Templates -->
|
||||
|
||||
<script src="https://cdn.jsdelivr.net/npm/bootstrap@5.3.2/dist/js/bootstrap.bundle.min.js"
|
||||
integrity="sha384-C6RzsynM9kWDrMNeT87bh95OGNyZPhcTNXj1NW7RuBCsyN/o0jlpcV8Qyq46cDfL"
|
||||
crossorigin="anonymous"></script>
|
||||
<script>
|
||||
// Basic script to handle 'Load into Form' for example scripts
|
||||
document.addEventListener('DOMContentLoaded', function () {
|
||||
const loadScriptButtons = document.querySelectorAll('.load-script-btn');
|
||||
loadScriptButtons.forEach(button => {
|
||||
button.addEventListener('click', function () {
|
||||
const scriptContent = this.dataset.scriptContent;
|
||||
const rhaiTextarea = document.querySelector('#rhai_script_content'); // Assuming this ID for the textarea
|
||||
if (rhaiTextarea) {
|
||||
rhaiTextarea.value = scriptContent;
|
||||
// Optionally, scroll to the form or give some visual feedback
|
||||
rhaiTextarea.focus();
|
||||
alert('Script loaded into the textarea below!');
|
||||
} else {
|
||||
alert('Rhai script textarea not found on the page. It will be added soon.');
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
// --- Start of Dynamic Step-by-Step Form Logic ---
|
||||
const stepsContainer_dynamic = document.getElementById('stepsContainer_dynamic');
|
||||
const addStepBtn_dynamic = document.getElementById('addStepBtn_dynamic');
|
||||
const stepTemplate_dynamic = document.getElementById('stepTemplate_dynamic');
|
||||
const requirementTemplate_dynamic = document.getElementById('requirementTemplate_dynamic');
|
||||
const form_dynamic = document.getElementById('createFlowForm_dynamic');
|
||||
|
||||
if (stepsContainer_dynamic && addStepBtn_dynamic && stepTemplate_dynamic && requirementTemplate_dynamic && form_dynamic) { // Check if all elements exist
|
||||
|
||||
const updateIndices_dynamic = () => {
|
||||
const steps = stepsContainer_dynamic.querySelectorAll('.step'); // .step is the class on the root of the cloned template
|
||||
steps.forEach((step, stepIdx) => {
|
||||
step.dataset.stepIndex = stepIdx;
|
||||
step.querySelector('.step-number').textContent = stepIdx + 1;
|
||||
const descriptionInput = step.querySelector('.step-description_dynamic');
|
||||
if(descriptionInput) descriptionInput.name = `steps[${stepIdx}].description`;
|
||||
|
||||
const addReqBtn = step.querySelector('.addRequirementBtn_dynamic');
|
||||
if (addReqBtn) addReqBtn.dataset.stepIndex = stepIdx;
|
||||
|
||||
const requirements = step.querySelectorAll('.requirementsContainer_dynamic .requirement'); // .requirement is class on root of its template
|
||||
requirements.forEach((req, reqIdx) => {
|
||||
req.dataset.reqIndex = reqIdx;
|
||||
req.querySelector('.req-number').textContent = reqIdx + 1;
|
||||
const messageTextarea = req.querySelector('.req-message_dynamic');
|
||||
if(messageTextarea) messageTextarea.name = `steps[${stepIdx}].requirements[${reqIdx}].message`;
|
||||
const pubkeyInput = req.querySelector('.req-pubkey_dynamic');
|
||||
if(pubkeyInput) pubkeyInput.name = `steps[${stepIdx}].requirements[${reqIdx}].public_key`;
|
||||
});
|
||||
});
|
||||
// Remove the initial placeholder message if steps are present
|
||||
const placeholder = stepsContainer_dynamic.querySelector('p.text-muted');
|
||||
if (steps.length > 0 && placeholder) {
|
||||
placeholder.style.display = 'none';
|
||||
} else if (steps.length === 0 && placeholder) {
|
||||
placeholder.style.display = 'block';
|
||||
}
|
||||
};
|
||||
|
||||
const addRequirement_dynamic = (currentStepElement, stepIndex) => {
|
||||
const requirementsContainer = currentStepElement.querySelector('.requirementsContainer_dynamic');
|
||||
if (!requirementsContainer) return;
|
||||
const reqFragment = requirementTemplate_dynamic.content.cloneNode(true);
|
||||
const newRequirement = reqFragment.querySelector('.requirement'); // .requirement is class on root
|
||||
// Remove placeholder from requirements container if it exists
|
||||
const reqPlaceholder = requirementsContainer.querySelector('p.text-muted.small');
|
||||
if (reqPlaceholder) reqPlaceholder.style.display = 'none';
|
||||
|
||||
requirementsContainer.appendChild(newRequirement);
|
||||
updateIndices_dynamic();
|
||||
};
|
||||
|
||||
const addStep_dynamic = () => {
|
||||
const stepFragment = stepTemplate_dynamic.content.cloneNode(true);
|
||||
const newStep = stepFragment.querySelector('.step'); // .step is class on root
|
||||
stepsContainer_dynamic.appendChild(newStep);
|
||||
|
||||
const currentStepIndex = stepsContainer_dynamic.querySelectorAll('.step').length - 1;
|
||||
addRequirement_dynamic(newStep, currentStepIndex); // Add one requirement by default
|
||||
|
||||
updateIndices_dynamic();
|
||||
};
|
||||
|
||||
stepsContainer_dynamic.addEventListener('click', (event) => {
|
||||
if (event.target.classList.contains('removeStepBtn_dynamic')) {
|
||||
event.target.closest('.step').remove();
|
||||
if (stepsContainer_dynamic.querySelectorAll('.step').length === 0) {
|
||||
// addStep_dynamic(); // Optionally re-add a step if all are removed
|
||||
}
|
||||
updateIndices_dynamic();
|
||||
} else if (event.target.classList.contains('addRequirementBtn_dynamic')) {
|
||||
const stepElement = event.target.closest('.step');
|
||||
const stepIndex = parseInt(stepElement.dataset.stepIndex, 10);
|
||||
addRequirement_dynamic(stepElement, stepIndex);
|
||||
} else if (event.target.classList.contains('removeRequirementBtn_dynamic')) {
|
||||
const requirementElement = event.target.closest('.requirement');
|
||||
const stepElement = event.target.closest('.step');
|
||||
const requirementsContainer = stepElement.querySelector('.requirementsContainer_dynamic');
|
||||
requirementElement.remove();
|
||||
|
||||
if (requirementsContainer.querySelectorAll('.requirement').length === 0) {
|
||||
// const stepIndex = parseInt(stepElement.dataset.stepIndex, 10);
|
||||
// addRequirement_dynamic(stepElement, stepIndex); // Optionally re-add a requirement
|
||||
const reqPlaceholder = requirementsContainer.querySelector('p.text-muted.small');
|
||||
if (reqPlaceholder) reqPlaceholder.style.display = 'block'; // Show placeholder if no reqs
|
||||
}
|
||||
updateIndices_dynamic();
|
||||
}
|
||||
});
|
||||
|
||||
addStepBtn_dynamic.addEventListener('click', addStep_dynamic);
|
||||
|
||||
// Add one step by default when the page loads, if no steps already (e.g. from server-side render)
|
||||
if (stepsContainer_dynamic.children.length === 1 && stepsContainer_dynamic.firstElementChild.tagName === 'P') { // Only placeholder present
|
||||
addStep_dynamic();
|
||||
}
|
||||
|
||||
form_dynamic.addEventListener('submit', (event) => {
|
||||
if (stepsContainer_dynamic.querySelectorAll('.step').length === 0) {
|
||||
alert('Please add at least one step to the flow.');
|
||||
event.preventDefault();
|
||||
return;
|
||||
}
|
||||
const steps = stepsContainer_dynamic.querySelectorAll('.step');
|
||||
for (let i = 0; i < steps.length; i++) {
|
||||
if (steps[i].querySelectorAll('.requirementsContainer_dynamic .requirement').length === 0) {
|
||||
alert(`Step ${i + 1} must have at least one signature requirement.`);
|
||||
event.preventDefault();
|
||||
return;
|
||||
}
|
||||
}
|
||||
});
|
||||
} else {
|
||||
console.warn('One or more elements for the dynamic step-by-step form were not found. JS not initialized.');
|
||||
}
|
||||
// --- End of Dynamic Step-by-Step Form Logic ---
|
||||
});
|
||||
</script>
|
||||
</body>
|
||||
</html>
|
||||
105
flowbroker/templates/new_flow_form.html
Normal file
105
flowbroker/templates/new_flow_form.html
Normal file
@@ -0,0 +1,105 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="en">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>Create Flow from Rhai Script</title>
|
||||
<link rel="stylesheet" href="/static/style.css">
|
||||
<style>
|
||||
body {
|
||||
font-family: sans-serif;
|
||||
margin: 20px;
|
||||
background-color: #f4f4f9;
|
||||
color: #333;
|
||||
}
|
||||
.container {
|
||||
background-color: #fff;
|
||||
padding: 20px;
|
||||
border-radius: 8px;
|
||||
box-shadow: 0 0 10px rgba(0,0,0,0.1);
|
||||
}
|
||||
h1 {
|
||||
color: #333;
|
||||
}
|
||||
textarea {
|
||||
width: 100%;
|
||||
min-height: 300px;
|
||||
padding: 10px;
|
||||
border: 1px solid #ccc;
|
||||
border-radius: 4px;
|
||||
box-sizing: border-box;
|
||||
margin-bottom: 15px;
|
||||
font-family: monospace;
|
||||
font-size: 14px;
|
||||
}
|
||||
button {
|
||||
background-color: #007bff;
|
||||
color: white;
|
||||
padding: 10px 15px;
|
||||
border: none;
|
||||
border-radius: 4px;
|
||||
cursor: pointer;
|
||||
font-size: 16px;
|
||||
}
|
||||
button:hover {
|
||||
background-color: #0056b3;
|
||||
}
|
||||
a {
|
||||
color: #007bff;
|
||||
text-decoration: none;
|
||||
}
|
||||
a:hover {
|
||||
text-decoration: underline;
|
||||
}
|
||||
.back-link {
|
||||
display: block;
|
||||
margin-bottom: 20px;
|
||||
}
|
||||
</style>
|
||||
</head>
|
||||
<body>
|
||||
<div class="container">
|
||||
<a href="/" class="back-link">← Back to Flow List</a>
|
||||
<h1>Create Flow from Rhai Script</h1>
|
||||
|
||||
<div id="rhai_script_examples_data" style="display: none;">
|
||||
{% for example in example_scripts %}
|
||||
<div id="rhai_example_content_{{ loop.index }}">{{ example.content }}</div>
|
||||
{% endfor %}
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<label for="example_script_selector">Load Example Script:</label>
|
||||
<select id="example_script_selector">
|
||||
<option value="">-- Select an Example --</option>
|
||||
{% for example in example_scripts %}
|
||||
<option value="{{ example.name }}" data-example-id="rhai_example_content_{{ loop.index }}">{{ example.name }}</option>
|
||||
{% endfor %}
|
||||
</select>
|
||||
</div>
|
||||
|
||||
<form action="/flows/create_script" method="POST" style="margin-top: 15px;">
|
||||
<div>
|
||||
<label for="rhai_script">Rhai Script:</label>
|
||||
</div>
|
||||
<div>
|
||||
<textarea id="rhai_script" name="rhai_script" placeholder="Enter your Rhai script here or select an example above..."></textarea>
|
||||
</div>
|
||||
<button type="submit">Create Flow</button>
|
||||
</form>
|
||||
|
||||
<script>
|
||||
document.getElementById('example_script_selector').addEventListener('change', function() {
|
||||
var selectedOption = this.options[this.selectedIndex];
|
||||
var exampleId = selectedOption.getAttribute('data-example-id');
|
||||
if (exampleId) {
|
||||
var scriptContent = document.getElementById(exampleId).textContent; // Use textContent
|
||||
document.getElementById('rhai_script').value = scriptContent;
|
||||
} else {
|
||||
document.getElementById('rhai_script').value = '';
|
||||
}
|
||||
});
|
||||
</script>
|
||||
</div>
|
||||
</body>
|
||||
</html>
|
||||
8
flowbroker/templates/rhai_examples/minimal_flow.rhai
Normal file
8
flowbroker/templates/rhai_examples/minimal_flow.rhai
Normal file
@@ -0,0 +1,8 @@
|
||||
// Minimal Single Signature Flow
|
||||
let flow_id = create_flow("Quick Sign");
|
||||
|
||||
let step1_id = add_step(flow_id, "Sign the message", 0);
|
||||
add_requirement(step1_id, "any_signer_pk", "Please provide your signature.");
|
||||
|
||||
print("Minimal Flow (ID: " + flow_id + ") defined.");
|
||||
()
|
||||
@@ -0,0 +1,18 @@
|
||||
// Flow with Multi-Requirement Step
|
||||
// If create_flow, add_step, or add_requirement fail from Rust,
|
||||
// the script will stop and the error will be reported by the server.
|
||||
|
||||
let flow_id = create_flow("Multi-Req Sign Off");
|
||||
|
||||
let step1_id = add_step(flow_id, "Initial Signatures (3 needed)", 0);
|
||||
|
||||
add_requirement(step1_id, "signer1_pk", "Signatory 1: Please sign terms.");
|
||||
add_requirement(step1_id, "signer2_pk", "Signatory 2: Please sign terms.");
|
||||
add_requirement(step1_id, "signer3_pk", "Signatory 3: Please sign terms.");
|
||||
|
||||
let step2_id = add_step(flow_id, "Final Confirmation", 1);
|
||||
|
||||
add_requirement(step2_id, "final_approver_pk", "Final approval for multi-req sign off.");
|
||||
|
||||
print("Multi-Requirement Flow (ID: " + flow_id + ") defined.");
|
||||
()
|
||||
14
flowbroker/templates/rhai_examples/simple_two_step.rhai
Normal file
14
flowbroker/templates/rhai_examples/simple_two_step.rhai
Normal file
@@ -0,0 +1,14 @@
|
||||
// Simple Two-Step Flow
|
||||
// If create_flow, add_step, or add_requirement fail from Rust,
|
||||
// the script will stop and the error will be reported by the server.
|
||||
|
||||
let flow_id = create_flow("Simple Two-Stepper");
|
||||
|
||||
let step1_id = add_step(flow_id, "Collect Document", 0);
|
||||
add_requirement(step1_id, "user_pubkey_document", "Please sign the document hash.");
|
||||
|
||||
let step2_id = add_step(flow_id, "Approval Signature", 1);
|
||||
add_requirement(step2_id, "approver_pubkey", "Please approve the collected document.");
|
||||
|
||||
print("Simple Two-Step Flow (ID: " + flow_id + ") defined.");
|
||||
()
|
||||
Reference in New Issue
Block a user