Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
4.9 kB · 115 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116package vod
import ( "context" "encoding/json" "testing"
"github.com/stretchr/testify/require" "stream.place/streamplace/pkg/comatproto" "stream.place/streamplace/pkg/placestream")
func TestParseVideoURI(t *testing.T) { u, err := parseVideoURI(" at://did:plc:abc/place.stream.video/3mvmy2nvqbmqv ") require.NoError(t, err) require.Equal(t, "did:plc:abc", u.Authority().String()) require.Equal(t, "3mvmy2nvqbmqv", u.RecordKey().String())
_, err = parseVideoURI("at://did:plc:abc/place.stream.livestream/3mvmy2nvqbmqv") require.ErrorIs(t, err, ErrNotAVideo, "a livestream is not a video") _, err = parseVideoURI("at://did:plc:abc/place.stream.video") require.ErrorIs(t, err, ErrNotAVideo, "a collection is not a record") _, err = parseVideoURI("https://example.com/x") require.ErrorIs(t, err, ErrNotAVideo)}
func TestApplyVideoUpdate(t *testing.T) { desc := "old" v := &placestream.Video{Title: "Old title", Description: &desc, Tags: []string{"a"}, DescriptionFacets: []placestream.RichtextVideoFacet{{}}}
require.False(t, applyVideoUpdate(v, VideoUpdate{}), "nothing asked, nothing changed") blank := " " require.False(t, applyVideoUpdate(v, VideoUpdate{Title: &blank}), "a blank title is ignored, not applied") require.Equal(t, "Old title", v.Title)
title := " New title " require.True(t, applyVideoUpdate(v, VideoUpdate{Title: &title})) require.Equal(t, "New title", v.Title)
nd := "new" require.True(t, applyVideoUpdate(v, VideoUpdate{Description: &nd})) require.Equal(t, "new", *v.Description) require.Nil(t, v.DescriptionFacets, "facets annotated the old text")
empty := "" require.True(t, applyVideoUpdate(v, VideoUpdate{Description: &empty})) require.Nil(t, v.Description, "an empty description clears it")
require.True(t, applyVideoUpdate(v, VideoUpdate{Tags: []string{"b", " ", "c"}})) require.Equal(t, []string{"b", "c"}, v.Tags) require.False(t, applyVideoUpdate(v, VideoUpdate{Tags: []string{"b", "c"}}), "same tags, no change") require.True(t, applyVideoUpdate(v, VideoUpdate{Tags: []string{}})) require.Nil(t, v.Tags, "an empty list clears the tags")}
func TestVideoRecordTrackURIs(t *testing.T) { require.Nil(t, VideoRecord{}.TrackURIs()) require.Nil(t, VideoRecord{Video: &placestream.Video{}}.TrackURIs(), "no source, no tracks") r := VideoRecord{Video: &placestream.Video{Source: placestream.Video_Source{ MediaDefs_SourceTracks: &placestream.MediaDefs_SourceTracks{Tracks: []comatproto.RepoStrongRef{ {Uri: "at://did:plc:abc/place.stream.media.track/1"}, {Uri: "at://did:plc:abc/place.stream.media.track/2"}, }}}}} require.Equal(t, []string{"at://did:plc:abc/place.stream.media.track/1", "at://did:plc:abc/place.stream.media.track/2"}, r.TrackURIs())}
// recordingClient answers getRecord with a canned video and records every// procedure it is asked to run.type recordingClient struct { video placestream.Video cid string calls []string inps []any}
func (c *recordingClient) Do(_ context.Context, _ string, _ string, path string, params map[string]any, body any, out any) error { c.calls = append(c.calls, path) c.inps = append(c.inps, body) if path == "com.atproto.repo.getRecord" { b, _ := json.Marshal(c.video) var o comatproto.RepoGetRecord_Output raw := `{"uri":"at://` + params["repo"].(string) + `/place.stream.video/` + params["rkey"].(string) + `","cid":"` + c.cid + `","value":` + string(b) + `}` if err := json.Unmarshal([]byte(raw), &o); err != nil { return err } *out.(*comatproto.RepoGetRecord_Output) = o } return nil}
func TestGetVideoRecordDecodesTypedRecord(t *testing.T) { c := &recordingClient{cid: "bafyvideo", video: placestream.Video{Title: "Speech", DurationMs: 42, Source: placestream.Video_Source{MediaDefs_SourceTracks: &placestream.MediaDefs_SourceTracks{ Tracks: []comatproto.RepoStrongRef{{Uri: "at://did:plc:abc/place.stream.media.track/v", Cid: "bafyv"}}}}}} u, err := parseVideoURI("at://did:plc:abc/place.stream.video/3mvmy2nvqbmqv") require.NoError(t, err) rec, err := getVideoRecord(context.Background(), c, u) require.NoError(t, err) require.Equal(t, "bafyvideo", rec.CID) require.Equal(t, "Speech", rec.Video.Title) require.Equal(t, int64(42), rec.Video.DurationMs) require.Equal(t, []string{"at://did:plc:abc/place.stream.media.track/v"}, rec.TrackURIs())}
func TestDeleteRecordAddressesTheRightRecord(t *testing.T) { c := &recordingClient{} u, err := parseVideoURI("at://did:plc:abc/place.stream.video/3mvmy2nvqbmqv") require.NoError(t, err) require.NoError(t, deleteRecord(context.Background(), c, u)) require.Equal(t, []string{"com.atproto.repo.deleteRecord"}, c.calls) inp := c.inps[0].(comatproto.RepoDeleteRecord_Input) require.Equal(t, "place.stream.video", inp.Collection) require.Equal(t, "did:plc:abc", inp.Repo) require.Equal(t, "3mvmy2nvqbmqv", inp.Rkey)}