pluginapi/media_test.go

Rama main · réplica de lectura del repositorio original.

package pluginapi

import (
	"encoding/base64"
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

func TestDecodeMedia(t *testing.T) {
	png := []byte{0x89, 'P', 'N', 'G'}
	b64 := base64.StdEncoding.EncodeToString(png)
	tests := []struct {
		name     string
		part     Part
		want     []byte
		wantType string
		wantOK   bool
	}{
		{"image data uri", Part{Kind: PartImage, URL: "data:image/png;base64," + b64}, png, "image/png", true},
		{"image data uri with charset param", Part{Kind: PartImage, URL: "data:image/png;charset=binary;base64," + b64}, png, "image/png", true},
		{"image remote url", Part{Kind: PartImage, URL: "https://x/y.png"}, nil, "", false},
		{"image not base64", Part{Kind: PartImage, URL: "data:image/png," + b64}, nil, "", false},
		{"audio base64", Part{Kind: PartAudio, Data: []byte(b64), MediaType: "audio/wav"}, png, "audio/wav", true},
		{"audio data uri", Part{Kind: PartAudio, Data: []byte("data:audio/mp3;base64," + b64)}, png, "audio/mp3", true},
		{"audio garbage", Part{Kind: PartAudio, Data: []byte("***")}, nil, "", false},
		{"text", Part{Kind: PartText, Text: b64}, nil, "", false},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			data, mediaType, ok := tt.part.DecodeMedia()
			require.Equal(t, tt.wantOK, ok)
			require.Equal(t, string(tt.want), string(data))
			require.Equal(t, tt.wantType, mediaType, "DecodeMedia() = %q, %q, %v; want %q, %q, %v", data, mediaType, ok, tt.want, tt.wantType, tt.wantOK)
		})
	}
}

func TestPromptSetMedia(t *testing.T) {
	redacted := []byte("redacted-bytes")
	p := toolPrompt()
	p.Messages[1].Parts[1].Raw = []byte(`{"type":"input_image","image_url":"https://x/y.png"}`)
	p.Messages = append(p.Messages, Message{ID: "m5", Role: RoleUser, Parts: []Part{{Kind: PartAudio, Data: []byte("AAAA"), MediaType: "audio/wav"}}})
	err := p.SetMedia("m1", 1, "image/jpeg", redacted)
	require.NoError(t, err)

	img := p.Messages[1].Parts[1]
	require.Equal(t, "data:image/jpeg;base64,"+base64.StdEncoding.EncodeToString(redacted), img.URL)
	require.Equal(t, "image/jpeg", img.MediaType)
	require.Nil(t, img.Data)
	require.Nil(t, img.Raw, "image part after SetMedia = %+v", img)
	data, mediaType, ok := img.DecodeMedia()
	require.True(t, ok)
	require.Equal(t, string(redacted), string(data))
	require.Equal(t, "image/jpeg", mediaType, "DecodeMedia() after SetMedia = %q, %q, %v", data, mediaType, ok)
	err = p.SetMedia("m5", 0, " audio/mp3 ", redacted)
	require.NoError(t, err)

	audio := p.Messages[5].Parts[0]
	require.Equal(t, base64.StdEncoding.EncodeToString(redacted), string(audio.Data))
	require.Equal(t, "audio/mp3", audio.MediaType)
	require.Empty(t, audio.URL, "audio part after SetMedia = %+v", audio)

	ch := p.Changes()
	require.True(t, ch.Dirty)
	require.Equal(t, ChangeEdited, ch.Messages["m1"])
	require.Equal(t, ChangeEdited, ch.Messages["m5"])
	require.Len(t, ch.Messages, 2, "changes = %+v", ch)
}

func TestPromptSetMediaErrors(t *testing.T) {
	tests := []struct {
		name      string
		msgID     string
		partIdx   int
		mediaType string
		data      []byte
		want      string
	}{
		{"unknown message", "zz", 0, "image/png", []byte("x"), "unknown message"},
		{"part out of range", "m1", 7, "image/png", []byte("x"), "no part 7"},
		{"text part", "m1", 0, "image/png", []byte("x"), "not image or audio"},
		{"tool call part", "m2", 0, "image/png", []byte("x"), "not image or audio"},
		{"bad media type", "m1", 1, "png", []byte("x"), "not a MIME type"},
		{"audio type on an image part", "m1", 1, "audio/wav", []byte("x"), "does not fit the image part"},
		{"image type on an audio part", "m5", 0, "image/png", []byte("x"), "does not fit the audio part"},
		{"empty data", "m1", 1, "image/png", nil, "is empty"},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			p := toolPrompt()
			p.Messages = append(p.Messages, Message{ID: "m5", Role: RoleUser, Parts: []Part{{Kind: PartAudio, Data: []byte("AAAA"), MediaType: "audio/wav"}}})
			err := p.SetMedia(tt.msgID, tt.partIdx, tt.mediaType, tt.data)
			require.Error(t, err)
			require.Contains(t, err.Error(), tt.want)
			assert.False(t, p.Changes().Dirty)
			assert.Equal(t, "https://x/y.png", p.Messages[1].Parts[1].URL)
		})
	}
}