mirrors/Cloudreve
1
0
Fork 0
mirror of https://github.com/cloudreve/cloudreve.git synced 2025-12-15 10:04:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(fs): fs change event notification via SSE / show panic stack trace in task queue

Browse Source
This commit is contained in:
Aaron Liu
2025-12-13 14:46:25 +08:00
parent 05c68b4062
commit c01b748dfc
44 changed files with 5160 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
ent/hook/hook.go
View File

@@ -57,6 +57,18 @@ func (f FileFunc) Mutate(ctx context.Context, m ent.Mutation) (ent.Value, error)
return nil, fmt.Errorf("unexpected mutation type %T. expect *ent.FileMutation", m)
}
// The FsEventFunc type is an adapter to allow the use of ordinary
// function as FsEvent mutator.
type FsEventFunc func(context.Context, *ent.FsEventMutation) (ent.Value, error)
// Mutate calls f(ctx, m).
func (f FsEventFunc) Mutate(ctx context.Context, m ent.Mutation) (ent.Value, error) {
if mv, ok := m.(*ent.FsEventMutation); ok {
return f(ctx, mv)
}
return nil, fmt.Errorf("unexpected mutation type %T. expect *ent.FsEventMutation", m)
}
// The GroupFunc type is an adapter to allow the use of ordinary
// function as Group mutator.
type GroupFunc func(context.Context, *ent.GroupMutation) (ent.Value, error)