Backup_Repos/filestash
1
0
Fork 0
mirror of https://github.com/mickael-kerjean/filestash synced 2025-12-06 08:22:24 +01:00
Code Issues Projects Releases Wiki Activity

chore (workflow): expose triggerEvents

Browse source
This commit is contained in:
MickaelK 2025-11-24 15:27:49 +11:00
parent 0f3173a1fe
commit 79d561e2be
5 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/workflow/trigger/fileaction.go
View file

@ -86,7 +86,7 @@ func processFileAction(ctx *App, params map[string]string) {
if ctx.Context.Value("AUDIT") == false {
return
}
if err := triggerEvents(fileaction_event, fileaction_name, fileactionCallback(params)); err != nil {
if err := TriggerEvents(fileaction_event, fileaction_name, fileactionCallback(params)); err != nil {
Log.Error("[workflow] trigger=event step=triggerEvents err=%s", err.Error())
}
}

2
server/workflow/trigger/filewatch.go
View file

@ -47,7 +47,7 @@ func (this *WatchTrigger) Manifest() WorkflowSpecs {
func (this *WatchTrigger) Init() (chan ITriggerEvent, error) {
go func() {
for {
if err := triggerEvents(filewatch_event, filewatch_name, filewatchCallback); err != nil {
if err := TriggerEvents(filewatch_event, filewatch_name, filewatchCallback); err != nil {
Log.Error("[workflow] trigger=watch step=triggerEvents err=%s", err.Error())
}
time.Sleep(10 * time.Second)

2
server/workflow/trigger/index.go
View file

@ -21,7 +21,7 @@ func (this *TriggerEvent) WorkflowID() string {
return this.ID
}
func triggerEvents(event chan ITriggerEvent, triggerID string, callback func(params map[string]string) (map[string]string, bool)) error {
func TriggerEvents(event chan ITriggerEvent, triggerID string, callback func(params map[string]string) (map[string]string, bool)) error {
workflows, err := FindWorkflows(triggerID)
if err != nil {
return err

2
server/workflow/trigger/schedule.go
View file

@ -40,7 +40,7 @@ func (this *ScheduleTrigger) Manifest() WorkflowSpecs {
func (this *ScheduleTrigger) Init() (chan ITriggerEvent, error) {
go func() {
for {
if err := triggerEvents(cron_event, cron_name, scheduleCallback); err != nil {
if err := TriggerEvents(cron_event, cron_name, scheduleCallback); err != nil {
Log.Error("[workflow] trigger=schedule step=triggerEvents err=%s", err.Error())
}
time.Sleep(60 * time.Second)

2
server/workflow/trigger/webhook.go
View file

@ -18,7 +18,7 @@ func init() {
Hooks.Register.WorkflowTrigger(&WebhookTrigger{})
Hooks.Register.HttpEndpoint(func(r *mux.Router, app *App) error {
r.HandleFunc(WithBase("/api/workflow/webhook"), func(w http.ResponseWriter, r *http.Request) {
if err := triggerEvents(webhook_event, webhook_name, webhookCallback(r)); err != nil {
if err := TriggerEvents(webhook_event, webhook_name, webhookCallback(r)); err != nil {
SendErrorResult(w, err)
return
}