refactor: remove obsolete business paths

internal/store/migrations/003_uploads.sql

@@ -5,7 +5,6 @@ CREATE TABLE IF NOT EXISTS uploads (
     grant BLOB NOT NULL,
     object_key TEXT NOT NULL,
     state TEXT NOT NULL CHECK (state IN ('granted', 'completed', 'failed')),
-    oss_id TEXT,
     created_at TEXT NOT NULL,
     completed_at TEXT
 );

internal/store/upload_notification_test.go

@@ -18,7 +18,7 @@ func TestUploadCompletionRequiresPublishedOriginalNotice(t *testing.T) {
 	if err := s.BindDispatcherID(identityA); err != nil {
 		t.Fatal(err)
 	}
-	if err := s.InsertUpload(UploadRecord{UploadID: "upload-a", Binding: []byte("binding"), Asset: []byte("asset"), Grant: []byte("grant"), ObjectKey: "recordings/recording-a.wav", Bucket: "example-bucket", State: "granted", CreatedAt: now}); err != nil {
+	if _, err := s.IssueUploadGrant(UploadRecord{UploadID: "upload-a", Binding: []byte("binding"), Asset: []byte("asset"), Grant: []byte("grant"), ObjectKey: "recordings/recording-a.wav", Bucket: "example-bucket", State: "granted", CreatedAt: now}, "request-a", "request-hash-a"); err != nil {
 		t.Fatal(err)
 	}
 	raw, err := contracts.Files.ReadFile("upstream/v1/examples/event-recording-uploaded.json")

internal/store/uploads.go

@@ -47,28 +47,3 @@ func (s *Store) LoadUpload(uploadID string) (UploadRecord, error) {
 	}
 	return record, nil
 }
-
-func (s *Store) InsertUpload(record UploadRecord) error {
-	if record.UploadID == "" || len(record.Binding) == 0 || len(record.Asset) == 0 || len(record.Grant) == 0 || record.ObjectKey == "" || record.Bucket == "" || record.State != "granted" {
-		return errors.New("complete granted upload record is required")
-	}
-	if record.CreatedAt.IsZero() {
-		record.CreatedAt = s.now().UTC()
-	}
-	s.mu.Lock()
-	defer s.mu.Unlock()
-	tx, err := s.db.Begin()
-	if err != nil {
-		return err
-	}
-	defer tx.Rollback()
-	_, err = tx.Exec(`INSERT INTO uploads(upload_id,binding,asset,grant,object_key,state,created_at,completed_at)
- VALUES(?,?,?,?,?,?,?,NULL)`, record.UploadID, record.Binding, record.Asset, record.Grant, record.ObjectKey, record.State, record.CreatedAt.UTC().Format(time.RFC3339Nano))
-	if err != nil {
-		return fmt.Errorf("insert upload: %w", err)
-	}
-	if _, err := tx.Exec(`INSERT INTO upload_destinations(upload_id,bucket) VALUES(?,?)`, record.UploadID, record.Bucket); err != nil {
-		return err
-	}
-	return tx.Commit()
-}