package/mq
1
0
Fork 0
mirror of https://github.com/oarkflow/mq.git synced 2025-10-07 00:43:35 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
sujit
2025-09-20 00:44:47 +05:45
parent 2b37061523
commit 61fff5b6fd
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
examples/form.go
View File

@@ -26,15 +26,15 @@ func main() {
// Add SMS workflow nodes // Add SMS workflow nodes
// Note: Page nodes have no timeout by default, allowing users unlimited time for form input // Note: Page nodes have no timeout by default, allowing users unlimited time for form input
// flow.AddDAGNode(dag.Page, "Login", "login", loginSubDAG(), true) flow.AddDAGNode(dag.Page, "Login", "login", loginSubDAG(), true)
flow.AddNode(dag.Page, "SMS Form", "SMSForm", &SMSFormNode{}, true) flow.AddNode(dag.Page, "SMS Form", "SMSForm", &SMSFormNode{})
flow.AddNode(dag.Function, "Validate Input", "ValidateInput", &ValidateInputNode{}) flow.AddNode(dag.Function, "Validate Input", "ValidateInput", &ValidateInputNode{})
flow.AddNode(dag.Function, "Send SMS", "SendSMS", &SendSMSNode{}) flow.AddNode(dag.Function, "Send SMS", "SendSMS", &SendSMSNode{})
flow.AddNode(dag.Page, "SMS Result", "SMSResult", &SMSResultNode{}) flow.AddNode(dag.Page, "SMS Result", "SMSResult", &SMSResultNode{})
flow.AddNode(dag.Page, "Error Page", "ErrorPage", &ErrorPageNode{}) flow.AddNode(dag.Page, "Error Page", "ErrorPage", &ErrorPageNode{})
// Define edges for SMS workflow // Define edges for SMS workflow
// flow.AddEdge(dag.Simple, "Login to Form", "login", "SMSForm") flow.AddEdge(dag.Simple, "Login to Form", "login", "SMSForm")
flow.AddEdge(dag.Simple, "Form to Validation", "SMSForm", "ValidateInput") flow.AddEdge(dag.Simple, "Form to Validation", "SMSForm", "ValidateInput")
flow.AddCondition("ValidateInput", map[string]string{"valid": "SendSMS"}) // Removed invalid -> ErrorPage since we use ResetTo flow.AddCondition("ValidateInput", map[string]string{"valid": "SendSMS"}) // Removed invalid -> ErrorPage since we use ResetTo
flow.AddCondition("SendSMS", map[string]string{"sent": "SMSResult", "failed": "ErrorPage"}) flow.AddCondition("SendSMS", map[string]string{"sent": "SMSResult", "failed": "ErrorPage"})
@@ -267,6 +267,14 @@ func (p *VerifyCredentials) ProcessTask(ctx context.Context, task *mq.Task) mq.R
} else { } else {
data["authenticated"] = false data["authenticated"] = false
data["error"] = "Invalid credentials" data["error"] = "Invalid credentials"
data["validation_error"] = "Phone number is required"
data["error_field"] = "phone"
bt, _ := json.Marshal(data)
return mq.Result{
Payload: bt,
Ctx: ctx,
ResetTo: "back", // Reset to form instead of going to error page
}
} }
delete(data, "html_content") delete(data, "html_content")
updatedPayload, _ := json.Marshal(data) updatedPayload, _ := json.Marshal(data)
@@ -531,7 +539,7 @@ func (v *ValidateInputNode) ProcessTask(ctx context.Context, task *mq.Task) mq.R
return mq.Result{ return mq.Result{
Payload: bt, Payload: bt,
Ctx: ctx, Ctx: ctx,
ResetTo: "SMSForm", // Reset to form instead of going to error page ResetTo: "back", // Reset to form instead of going to error page
} }
} }