Refactor the proto

This commit is contained in:
Alexander
2026-05-07 17:02:46 +02:00
parent 3d111f9008
commit 54d94b939e
5 changed files with 371 additions and 248 deletions
+15 -35
View File
@@ -32,24 +32,14 @@ const (
// MetadataServiceClient is the client API for MetadataService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
//
// MetadataService provides music metadata aggregation.
type MetadataServiceClient interface {
// GetArtist retrieves an artist by ID or external source ID.
GetArtist(ctx context.Context, in *GetArtistRequest, opts ...grpc.CallOption) (*Artist, error)
// SearchArtists searches for artists by name.
GetArtist(ctx context.Context, in *GetArtistRequest, opts ...grpc.CallOption) (*GetArtistResponse, error)
SearchArtists(ctx context.Context, in *SearchArtistsRequest, opts ...grpc.CallOption) (*SearchArtistsResponse, error)
// GetAlbum retrieves an album by ID.
GetAlbum(ctx context.Context, in *GetAlbumRequest, opts ...grpc.CallOption) (*Album, error)
// GetArtistAlbums retrieves all albums by an artist.
GetAlbum(ctx context.Context, in *GetAlbumRequest, opts ...grpc.CallOption) (*GetAlbumResponse, error)
GetArtistAlbums(ctx context.Context, in *GetArtistAlbumsRequest, opts ...grpc.CallOption) (*GetArtistAlbumsResponse, error)
// GetTrack retrieves a track by ID.
GetTrack(ctx context.Context, in *GetTrackRequest, opts ...grpc.CallOption) (*Track, error)
// GetAlbumTracks retrieves all tracks on an album.
GetTrack(ctx context.Context, in *GetTrackRequest, opts ...grpc.CallOption) (*GetTrackResponse, error)
GetAlbumTracks(ctx context.Context, in *GetAlbumTracksRequest, opts ...grpc.CallOption) (*GetAlbumTracksResponse, error)
// SearchAlbums searches for albums by name, optionally filtered by artist.
SearchAlbums(ctx context.Context, in *SearchAlbumsRequest, opts ...grpc.CallOption) (*SearchAlbumsResponse, error)
// SyncArtist triggers ingestion of an artist from external sources.
SyncArtist(ctx context.Context, in *SyncArtistRequest, opts ...grpc.CallOption) (*SyncArtistResponse, error)
}
@@ -61,9 +51,9 @@ func NewMetadataServiceClient(cc grpc.ClientConnInterface) MetadataServiceClient
return &metadataServiceClient{cc}
}
func (c *metadataServiceClient) GetArtist(ctx context.Context, in *GetArtistRequest, opts ...grpc.CallOption) (*Artist, error) {
func (c *metadataServiceClient) GetArtist(ctx context.Context, in *GetArtistRequest, opts ...grpc.CallOption) (*GetArtistResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Artist)
out := new(GetArtistResponse)
err := c.cc.Invoke(ctx, MetadataService_GetArtist_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
@@ -81,9 +71,9 @@ func (c *metadataServiceClient) SearchArtists(ctx context.Context, in *SearchArt
return out, nil
}
func (c *metadataServiceClient) GetAlbum(ctx context.Context, in *GetAlbumRequest, opts ...grpc.CallOption) (*Album, error) {
func (c *metadataServiceClient) GetAlbum(ctx context.Context, in *GetAlbumRequest, opts ...grpc.CallOption) (*GetAlbumResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Album)
out := new(GetAlbumResponse)
err := c.cc.Invoke(ctx, MetadataService_GetAlbum_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
@@ -101,9 +91,9 @@ func (c *metadataServiceClient) GetArtistAlbums(ctx context.Context, in *GetArti
return out, nil
}
func (c *metadataServiceClient) GetTrack(ctx context.Context, in *GetTrackRequest, opts ...grpc.CallOption) (*Track, error) {
func (c *metadataServiceClient) GetTrack(ctx context.Context, in *GetTrackRequest, opts ...grpc.CallOption) (*GetTrackResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Track)
out := new(GetTrackResponse)
err := c.cc.Invoke(ctx, MetadataService_GetTrack_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
@@ -144,24 +134,14 @@ func (c *metadataServiceClient) SyncArtist(ctx context.Context, in *SyncArtistRe
// MetadataServiceServer is the server API for MetadataService service.
// All implementations must embed UnimplementedMetadataServiceServer
// for forward compatibility.
//
// MetadataService provides music metadata aggregation.
type MetadataServiceServer interface {
// GetArtist retrieves an artist by ID or external source ID.
GetArtist(context.Context, *GetArtistRequest) (*Artist, error)
// SearchArtists searches for artists by name.
GetArtist(context.Context, *GetArtistRequest) (*GetArtistResponse, error)
SearchArtists(context.Context, *SearchArtistsRequest) (*SearchArtistsResponse, error)
// GetAlbum retrieves an album by ID.
GetAlbum(context.Context, *GetAlbumRequest) (*Album, error)
// GetArtistAlbums retrieves all albums by an artist.
GetAlbum(context.Context, *GetAlbumRequest) (*GetAlbumResponse, error)
GetArtistAlbums(context.Context, *GetArtistAlbumsRequest) (*GetArtistAlbumsResponse, error)
// GetTrack retrieves a track by ID.
GetTrack(context.Context, *GetTrackRequest) (*Track, error)
// GetAlbumTracks retrieves all tracks on an album.
GetTrack(context.Context, *GetTrackRequest) (*GetTrackResponse, error)
GetAlbumTracks(context.Context, *GetAlbumTracksRequest) (*GetAlbumTracksResponse, error)
// SearchAlbums searches for albums by name, optionally filtered by artist.
SearchAlbums(context.Context, *SearchAlbumsRequest) (*SearchAlbumsResponse, error)
// SyncArtist triggers ingestion of an artist from external sources.
SyncArtist(context.Context, *SyncArtistRequest) (*SyncArtistResponse, error)
mustEmbedUnimplementedMetadataServiceServer()
}
@@ -173,19 +153,19 @@ type MetadataServiceServer interface {
// pointer dereference when methods are called.
type UnimplementedMetadataServiceServer struct{}
func (UnimplementedMetadataServiceServer) GetArtist(context.Context, *GetArtistRequest) (*Artist, error) {
func (UnimplementedMetadataServiceServer) GetArtist(context.Context, *GetArtistRequest) (*GetArtistResponse, error) {
return nil, status.Error(codes.Unimplemented, "method GetArtist not implemented")
}
func (UnimplementedMetadataServiceServer) SearchArtists(context.Context, *SearchArtistsRequest) (*SearchArtistsResponse, error) {
return nil, status.Error(codes.Unimplemented, "method SearchArtists not implemented")
}
func (UnimplementedMetadataServiceServer) GetAlbum(context.Context, *GetAlbumRequest) (*Album, error) {
func (UnimplementedMetadataServiceServer) GetAlbum(context.Context, *GetAlbumRequest) (*GetAlbumResponse, error) {
return nil, status.Error(codes.Unimplemented, "method GetAlbum not implemented")
}
func (UnimplementedMetadataServiceServer) GetArtistAlbums(context.Context, *GetArtistAlbumsRequest) (*GetArtistAlbumsResponse, error) {
return nil, status.Error(codes.Unimplemented, "method GetArtistAlbums not implemented")
}
func (UnimplementedMetadataServiceServer) GetTrack(context.Context, *GetTrackRequest) (*Track, error) {
func (UnimplementedMetadataServiceServer) GetTrack(context.Context, *GetTrackRequest) (*GetTrackResponse, error) {
return nil, status.Error(codes.Unimplemented, "method GetTrack not implemented")
}
func (UnimplementedMetadataServiceServer) GetAlbumTracks(context.Context, *GetAlbumTracksRequest) (*GetAlbumTracksResponse, error) {