Skip to content
This repository was archived by the owner on Jan 31, 2026. It is now read-only.

Commit 073e3ff

Browse files
Merge pull request #119 from Maker-Management-Platform/118-implement-new-temp-file-notification
#118
2 parents 05ed35f + 9d5e769 commit 073e3ff

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

core/integrations/slicer/endpoints.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111
"github.com/eduardooliveira/stLib/core/processing"
1212
"github.com/eduardooliveira/stLib/core/runtime"
1313
"github.com/eduardooliveira/stLib/core/state"
14+
"github.com/eduardooliveira/stLib/core/system"
1415
"github.com/labstack/echo/v4"
1516
)
1617

@@ -97,5 +98,6 @@ func upload(c echo.Context) error {
9798
state.TempFiles[tempFile.UUID] = tempFile
9899
}
99100

101+
system.Publish("tempfile.new", map[string]any{"name": name})
100102
return c.NoContent(http.StatusOK)
101103
}

core/system/eventManagement.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ func (em *eventManagement) OnNewSub() error {
2525
}
2626

2727
func (em *eventManagement) Read() chan *events.Message {
28-
rtn := make(chan *events.Message, 100)
28+
rtn := make(chan *events.Message, 1)
2929
eventName := "system.state"
3030
go func() {
3131
for {
@@ -35,7 +35,7 @@ func (em *eventManagement) Read() chan *events.Message {
3535
Event: eventName,
3636
Data: m,
3737
}:
38-
log.Println("qweqwe")
38+
log.Println("event sent")
3939
default:
4040
log.Println("status update channel full")
4141
}

0 commit comments

Comments
 (0)