From fdab54a77513276a29e978e7372f1b035268b311 Mon Sep 17 00:00:00 2001
From: Eli Ribble <eli@gleipnir.technology>
Date: Thu, 19 Mar 2026 20:49:17 +0000
Subject: [PATCH] Fix saving note images and transcoding

---
 api/image.go      | 13 +++++++------
 platform/audio.go |  4 ++--
 platform/start.go |  2 ++
 3 files changed, 11 insertions(+), 8 deletions(-)

diff --git a/api/image.go b/api/image.go
index 7ec8866f..11f9a604 100644
--- a/api/image.go
+++ b/api/image.go
@@ -38,12 +38,13 @@ func apiImagePost(w http.ResponseWriter, r *http.Request, u platform.User) {
 	}
 	ctx := r.Context()
 	setter := models.NoteImageSetter{
-		Created:   omit.From(payload.Created),
-		CreatorID: omit.From(int32(u.ID)),
-		Deleted:   omitnull.FromPtr(payload.Deleted),
-		DeletorID: omitnull.FromPtr(payload.DeletorID),
-		Version:   omit.From(payload.Version),
-		UUID:      omit.From(noteUUID),
+		Created:        omit.From(payload.Created),
+		CreatorID:      omit.From(int32(u.ID)),
+		Deleted:        omitnull.FromPtr(payload.Deleted),
+		DeletorID:      omitnull.FromPtr(payload.DeletorID),
+		OrganizationID: omit.From(u.Organization.ID()),
+		Version:        omit.From(payload.Version),
+		UUID:           omit.From(noteUUID),
 	}
 	err = platform.NoteImageCreate(ctx, u, setter)
 	if err != nil {
diff --git a/platform/audio.go b/platform/audio.go
index ad80b3b3..2b881344 100644
--- a/platform/audio.go
+++ b/platform/audio.go
@@ -7,7 +7,7 @@ import (
 	"github.com/Gleipnir-Technology/bob"
 	"github.com/Gleipnir-Technology/nidus-sync/db"
 	"github.com/Gleipnir-Technology/nidus-sync/db/models"
-	"github.com/Gleipnir-Technology/nidus-sync/platform/background"
+	//"github.com/Gleipnir-Technology/nidus-sync/platform/background"
 	"github.com/Gleipnir-Technology/nidus-sync/platform/subprocess"
 	//"github.com/google/uuid"
 	//"github.com/rs/zerolog/log"
@@ -33,6 +33,6 @@ func processAudioFile(ctx context.Context, txn bob.Executor, audio_id int32) err
 		return fmt.Errorf("failed to transcode audio %s to OGG: %v", a.UUID, err)
 	}
 
-	background.NewLabelStudioAudioCreate(ctx, db.PGInstance.BobDB, audio_id)
+	//background.NewLabelStudioAudioCreate(ctx, db.PGInstance.BobDB, audio_id)
 	return nil
 }
diff --git a/platform/start.go b/platform/start.go
index e95b3c84..130a1ca1 100644
--- a/platform/start.go
+++ b/platform/start.go
@@ -106,6 +106,8 @@ func addWaitingJobs(ctx context.Context) error {
 }
 func handleJob(ctx context.Context, txn bob.Executor, job *models.Job) error {
 	switch job.Type {
+	case enums.JobtypeAudioTranscode:
+		return processAudioFile(ctx, txn, job.RowID)
 	case enums.JobtypeCSVCommit:
 		return csv.JobCommit(ctx, txn, job.RowID)
 	case enums.JobtypeCSVImport: