jmb/scanfile
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

processing start for PE and ELF files

Browse source
This commit is contained in:
Johannes Bülow 2025-08-15 19:16:49 +02:00
parent d58533db05
commit 5385bfeb6e
Signed by: jmb
GPG key ID: B56971CF7B8F83A6
1 changed files with 21 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
server/internal/processing/processing.go
View file

@ -8,6 +8,7 @@ import (
"git.jmbit.de/jmb/scanfile/server/internal/database" "git.jmbit.de/jmb/scanfile/server/internal/database"
"git.jmbit.de/jmb/scanfile/server/internal/processing/basic" "git.jmbit.de/jmb/scanfile/server/internal/processing/basic"
"git.jmbit.de/jmb/scanfile/server/internal/processing/capa"
"git.jmbit.de/jmb/scanfile/server/internal/processing/msoffice" "git.jmbit.de/jmb/scanfile/server/internal/processing/msoffice"
"git.jmbit.de/jmb/scanfile/server/internal/processing/yara" "git.jmbit.de/jmb/scanfile/server/internal/processing/yara"
"github.com/jackc/pgx/v5/pgtype" "github.com/jackc/pgx/v5/pgtype"
@ -32,12 +33,12 @@ func Submit(ctx context.Context, file pgtype.UUID) error {
go basic.BasicProcessing(job) go basic.BasicProcessing(job)
yaraJob, err := database.NewProcessingJob(ctx, file, TypeYARA) //yaraJob, err := database.NewProcessingJob(ctx, file, TypeYARA)
if err != nil { //if err != nil {
slog.Error("Could not submit processing job", "error", err, "file-uuid", file, "type", TypeBasic) // slog.Error("Could not submit processing job", "error", err, "file-uuid", file, "type", TypeBasic)
return err // return err
} //}
go yara.YaraProcessing(yaraJob) //go yara.YaraProcessing(yaraJob)
mimeType, err := database.GetFileMime(file) mimeType, err := database.GetFileMime(file)
if err != nil { if err != nil {
@ -52,6 +53,20 @@ func Submit(ctx context.Context, file pgtype.UUID) error {
return err return err
} }
go msoffice.MSOfficeProcessing(officeJob) go msoffice.MSOfficeProcessing(officeJob)
case TypeELF:
capaJob, err := database.NewProcessingJob(ctx, file, TypeELF)
if err != nil {
slog.Error("Could not submit processing job", "error", err, "file-uuid", file, "type", TypeCAPA)
return err
}
go capa.CapaProcessing(capaJob)
case TypePE:
capaJob, err := database.NewProcessingJob(ctx, file, TypeELF)
if err != nil {
slog.Error("Could not submit processing job", "error", err, "file-uuid", file, "type", TypeCAPA)
return err
}
go capa.CapaProcessing(capaJob)
} }
return nil return nil
} }