From 4783b8420a72be4d4fcd69e3b6348f93408f4344 Mon Sep 17 00:00:00 2001 From: Jay Brown Date: Wed, 8 Oct 2025 23:12:51 +0000 Subject: [PATCH] Merged in feature/init-runner-decode (pull request #189) Feature/init runner decode * comment * Merge remote-tracking branch 'origin/main' * init runner decode Approved-by: Mark Tomcza --- api/docInitRunner/runner.go | 2 +- internal/document/store/process.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/api/docInitRunner/runner.go b/api/docInitRunner/runner.go index b723d0c8..767fbb23 100644 --- a/api/docInitRunner/runner.go +++ b/api/docInitRunner/runner.go @@ -37,7 +37,7 @@ type Body struct { func (s Runner) Process(ctx context.Context, body Body) bool { key, err := objectstore.ParseBucketKey(body.Key) if err != nil { - slog.Error("unable to parse key", "key", body.Key) + slog.Error("unable to parse key", "key", body.Key, "error", err) return false } diff --git a/internal/document/store/process.go b/internal/document/store/process.go index 1786820e..e28fbf4e 100644 --- a/internal/document/store/process.go +++ b/internal/document/store/process.go @@ -49,11 +49,11 @@ func (s *Service) Process(ctx context.Context, params Params) error { queueParams.QueueURL = s.cfg.GetDocInitURL() queueParams.Body = docinitrunner.Body{ Bucket: params.Bucket, - Key: params.Key, + Key: decodedKey, Hash: params.Hash, } default: - slog.Info("unsupported key", "key", params.Key) + slog.Info("unsupported key", "key", decodedKey) return nil }