From b8fd93c90a6744272ba38e2ef55c4152d370c37d Mon Sep 17 00:00:00 2001 From: daiyb <570956418@qq.com> Date: Thu, 16 Oct 2025 10:26:28 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E5=B8=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/cast/cast.pb.go | 328 +++++++++++++++++++++++------------ api/cast/cast.pb.validate.go | 204 ++++++++++++++++++++++ api/cast/cast_triple.pb.go | 45 +++++ pkg/router/media.go | 1 + pkg/service/cast/work.go | 21 +++ 5 files changed, 490 insertions(+), 109 deletions(-) diff --git a/api/cast/cast.pb.go b/api/cast/cast.pb.go index 8b748e7..04cab25 100644 --- a/api/cast/cast.pb.go +++ b/api/cast/cast.pb.go @@ -2187,6 +2187,102 @@ func (x *MediaWorksResp) GetData() []*MediaWorksResp_Info { return nil } +type PublishReq struct { + state protoimpl.MessageState `protogen:"open.v1"` + WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *PublishReq) Reset() { + *x = PublishReq{} + mi := &file_pb_fiee_cast_proto_msgTypes[23] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *PublishReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PublishReq) ProtoMessage() {} + +func (x *PublishReq) ProtoReflect() protoreflect.Message { + mi := &file_pb_fiee_cast_proto_msgTypes[23] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PublishReq.ProtoReflect.Descriptor instead. +func (*PublishReq) Descriptor() ([]byte, []int) { + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{23} +} + +func (x *PublishReq) GetWorkUuid() string { + if x != nil { + return x.WorkUuid + } + return "" +} + +type PublishResp struct { + state protoimpl.MessageState `protogen:"open.v1"` + ArtistUuid string `protobuf:"bytes,1,opt,name=artistUuid,proto3" json:"artistUuid"` + WorkCategory int32 `protobuf:"varint,2,opt,name=workCategory,proto3" json:"workCategory"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *PublishResp) Reset() { + *x = PublishResp{} + mi := &file_pb_fiee_cast_proto_msgTypes[24] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *PublishResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PublishResp) ProtoMessage() {} + +func (x *PublishResp) ProtoReflect() protoreflect.Message { + mi := &file_pb_fiee_cast_proto_msgTypes[24] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PublishResp.ProtoReflect.Descriptor instead. +func (*PublishResp) Descriptor() ([]byte, []int) { + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{24} +} + +func (x *PublishResp) GetArtistUuid() string { + if x != nil { + return x.ArtistUuid + } + return "" +} + +func (x *PublishResp) GetWorkCategory() int32 { + if x != nil { + return x.WorkCategory + } + return 0 +} + type RePublishReq struct { state protoimpl.MessageState `protogen:"open.v1"` WorkUuid string `protobuf:"bytes,1,opt,name=workUuid,proto3" json:"workUuid"` @@ -2198,7 +2294,7 @@ type RePublishReq struct { func (x *RePublishReq) Reset() { *x = RePublishReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[23] + mi := &file_pb_fiee_cast_proto_msgTypes[25] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2210,7 +2306,7 @@ func (x *RePublishReq) String() string { func (*RePublishReq) ProtoMessage() {} func (x *RePublishReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[23] + mi := &file_pb_fiee_cast_proto_msgTypes[25] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2223,7 +2319,7 @@ func (x *RePublishReq) ProtoReflect() protoreflect.Message { // Deprecated: Use RePublishReq.ProtoReflect.Descriptor instead. func (*RePublishReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{23} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{25} } func (x *RePublishReq) GetWorkUuid() string { @@ -2257,7 +2353,7 @@ type RePublishResp struct { func (x *RePublishResp) Reset() { *x = RePublishResp{} - mi := &file_pb_fiee_cast_proto_msgTypes[24] + mi := &file_pb_fiee_cast_proto_msgTypes[26] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2269,7 +2365,7 @@ func (x *RePublishResp) String() string { func (*RePublishResp) ProtoMessage() {} func (x *RePublishResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[24] + mi := &file_pb_fiee_cast_proto_msgTypes[26] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2282,7 +2378,7 @@ func (x *RePublishResp) ProtoReflect() protoreflect.Message { // Deprecated: Use RePublishResp.ProtoReflect.Descriptor instead. func (*RePublishResp) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{24} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{26} } func (x *RePublishResp) GetArtistUuid() string { @@ -2308,7 +2404,7 @@ type DelWorkReq struct { func (x *DelWorkReq) Reset() { *x = DelWorkReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[25] + mi := &file_pb_fiee_cast_proto_msgTypes[27] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2320,7 +2416,7 @@ func (x *DelWorkReq) String() string { func (*DelWorkReq) ProtoMessage() {} func (x *DelWorkReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[25] + mi := &file_pb_fiee_cast_proto_msgTypes[27] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2333,7 +2429,7 @@ func (x *DelWorkReq) ProtoReflect() protoreflect.Message { // Deprecated: Use DelWorkReq.ProtoReflect.Descriptor instead. func (*DelWorkReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{25} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{27} } func (x *DelWorkReq) GetWorkUuid() string { @@ -2352,7 +2448,7 @@ type WorkInfoReq struct { func (x *WorkInfoReq) Reset() { *x = WorkInfoReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[26] + mi := &file_pb_fiee_cast_proto_msgTypes[28] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2364,7 +2460,7 @@ func (x *WorkInfoReq) String() string { func (*WorkInfoReq) ProtoMessage() {} func (x *WorkInfoReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[26] + mi := &file_pb_fiee_cast_proto_msgTypes[28] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2377,7 +2473,7 @@ func (x *WorkInfoReq) ProtoReflect() protoreflect.Message { // Deprecated: Use WorkInfoReq.ProtoReflect.Descriptor instead. func (*WorkInfoReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{26} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{28} } func (x *WorkInfoReq) GetWorkUuid() string { @@ -2401,7 +2497,7 @@ type WorkInfoResp struct { func (x *WorkInfoResp) Reset() { *x = WorkInfoResp{} - mi := &file_pb_fiee_cast_proto_msgTypes[27] + mi := &file_pb_fiee_cast_proto_msgTypes[29] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2413,7 +2509,7 @@ func (x *WorkInfoResp) String() string { func (*WorkInfoResp) ProtoMessage() {} func (x *WorkInfoResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[27] + mi := &file_pb_fiee_cast_proto_msgTypes[29] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2426,7 +2522,7 @@ func (x *WorkInfoResp) ProtoReflect() protoreflect.Message { // Deprecated: Use WorkInfoResp.ProtoReflect.Descriptor instead. func (*WorkInfoResp) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{27} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{29} } func (x *WorkInfoResp) GetWorkStatus() uint32 { @@ -2480,7 +2576,7 @@ type OAuthAccountReq struct { func (x *OAuthAccountReq) Reset() { *x = OAuthAccountReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[28] + mi := &file_pb_fiee_cast_proto_msgTypes[30] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2492,7 +2588,7 @@ func (x *OAuthAccountReq) String() string { func (*OAuthAccountReq) ProtoMessage() {} func (x *OAuthAccountReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[28] + mi := &file_pb_fiee_cast_proto_msgTypes[30] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2505,7 +2601,7 @@ func (x *OAuthAccountReq) ProtoReflect() protoreflect.Message { // Deprecated: Use OAuthAccountReq.ProtoReflect.Descriptor instead. func (*OAuthAccountReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{28} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{30} } func (x *OAuthAccountReq) GetMediaAccountUuid() string { @@ -2524,7 +2620,7 @@ type OAuthAccountResp struct { func (x *OAuthAccountResp) Reset() { *x = OAuthAccountResp{} - mi := &file_pb_fiee_cast_proto_msgTypes[29] + mi := &file_pb_fiee_cast_proto_msgTypes[31] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2536,7 +2632,7 @@ func (x *OAuthAccountResp) String() string { func (*OAuthAccountResp) ProtoMessage() {} func (x *OAuthAccountResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[29] + mi := &file_pb_fiee_cast_proto_msgTypes[31] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2549,7 +2645,7 @@ func (x *OAuthAccountResp) ProtoReflect() protoreflect.Message { // Deprecated: Use OAuthAccountResp.ProtoReflect.Descriptor instead. func (*OAuthAccountResp) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{29} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{31} } func (x *OAuthAccountResp) GetUrl() string { @@ -2570,7 +2666,7 @@ type OAuthYoutubeTokenReq struct { func (x *OAuthYoutubeTokenReq) Reset() { *x = OAuthYoutubeTokenReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[30] + mi := &file_pb_fiee_cast_proto_msgTypes[32] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2582,7 +2678,7 @@ func (x *OAuthYoutubeTokenReq) String() string { func (*OAuthYoutubeTokenReq) ProtoMessage() {} func (x *OAuthYoutubeTokenReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[30] + mi := &file_pb_fiee_cast_proto_msgTypes[32] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2595,7 +2691,7 @@ func (x *OAuthYoutubeTokenReq) ProtoReflect() protoreflect.Message { // Deprecated: Use OAuthYoutubeTokenReq.ProtoReflect.Descriptor instead. func (*OAuthYoutubeTokenReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{30} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{32} } func (x *OAuthYoutubeTokenReq) GetMediaAccountUuid() string { @@ -2623,7 +2719,7 @@ type OAuthYoutubeTokenResp struct { func (x *OAuthYoutubeTokenResp) Reset() { *x = OAuthYoutubeTokenResp{} - mi := &file_pb_fiee_cast_proto_msgTypes[31] + mi := &file_pb_fiee_cast_proto_msgTypes[33] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2635,7 +2731,7 @@ func (x *OAuthYoutubeTokenResp) String() string { func (*OAuthYoutubeTokenResp) ProtoMessage() {} func (x *OAuthYoutubeTokenResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[31] + mi := &file_pb_fiee_cast_proto_msgTypes[33] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2648,7 +2744,7 @@ func (x *OAuthYoutubeTokenResp) ProtoReflect() protoreflect.Message { // Deprecated: Use OAuthYoutubeTokenResp.ProtoReflect.Descriptor instead. func (*OAuthYoutubeTokenResp) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{31} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{33} } func (x *OAuthYoutubeTokenResp) GetAccessToken() string { @@ -2683,7 +2779,7 @@ type OAuthCodeToTokenReq struct { func (x *OAuthCodeToTokenReq) Reset() { *x = OAuthCodeToTokenReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[32] + mi := &file_pb_fiee_cast_proto_msgTypes[34] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2695,7 +2791,7 @@ func (x *OAuthCodeToTokenReq) String() string { func (*OAuthCodeToTokenReq) ProtoMessage() {} func (x *OAuthCodeToTokenReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[32] + mi := &file_pb_fiee_cast_proto_msgTypes[34] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2708,7 +2804,7 @@ func (x *OAuthCodeToTokenReq) ProtoReflect() protoreflect.Message { // Deprecated: Use OAuthCodeToTokenReq.ProtoReflect.Descriptor instead. func (*OAuthCodeToTokenReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{32} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{34} } func (x *OAuthCodeToTokenReq) GetCode() string { @@ -2740,7 +2836,7 @@ type OAuthCodeToTokenResp struct { func (x *OAuthCodeToTokenResp) Reset() { *x = OAuthCodeToTokenResp{} - mi := &file_pb_fiee_cast_proto_msgTypes[33] + mi := &file_pb_fiee_cast_proto_msgTypes[35] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2752,7 +2848,7 @@ func (x *OAuthCodeToTokenResp) String() string { func (*OAuthCodeToTokenResp) ProtoMessage() {} func (x *OAuthCodeToTokenResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[33] + mi := &file_pb_fiee_cast_proto_msgTypes[35] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2765,7 +2861,7 @@ func (x *OAuthCodeToTokenResp) ProtoReflect() protoreflect.Message { // Deprecated: Use OAuthCodeToTokenResp.ProtoReflect.Descriptor instead. func (*OAuthCodeToTokenResp) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{33} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{35} } type RefreshTokenReq struct { @@ -2779,7 +2875,7 @@ type RefreshTokenReq struct { func (x *RefreshTokenReq) Reset() { *x = RefreshTokenReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[34] + mi := &file_pb_fiee_cast_proto_msgTypes[36] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2791,7 +2887,7 @@ func (x *RefreshTokenReq) String() string { func (*RefreshTokenReq) ProtoMessage() {} func (x *RefreshTokenReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[34] + mi := &file_pb_fiee_cast_proto_msgTypes[36] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2804,7 +2900,7 @@ func (x *RefreshTokenReq) ProtoReflect() protoreflect.Message { // Deprecated: Use RefreshTokenReq.ProtoReflect.Descriptor instead. func (*RefreshTokenReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{34} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{36} } func (x *RefreshTokenReq) GetRefreshToken() string { @@ -2838,7 +2934,7 @@ type RefreshTokenResp struct { func (x *RefreshTokenResp) Reset() { *x = RefreshTokenResp{} - mi := &file_pb_fiee_cast_proto_msgTypes[35] + mi := &file_pb_fiee_cast_proto_msgTypes[37] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2850,7 +2946,7 @@ func (x *RefreshTokenResp) String() string { func (*RefreshTokenResp) ProtoMessage() {} func (x *RefreshTokenResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[35] + mi := &file_pb_fiee_cast_proto_msgTypes[37] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2863,7 +2959,7 @@ func (x *RefreshTokenResp) ProtoReflect() protoreflect.Message { // Deprecated: Use RefreshTokenResp.ProtoReflect.Descriptor instead. func (*RefreshTokenResp) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{35} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{37} } func (x *RefreshTokenResp) GetAccessToken() string { @@ -2891,7 +2987,7 @@ type PublishMediaInfoReq struct { func (x *PublishMediaInfoReq) Reset() { *x = PublishMediaInfoReq{} - mi := &file_pb_fiee_cast_proto_msgTypes[36] + mi := &file_pb_fiee_cast_proto_msgTypes[38] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2903,7 +2999,7 @@ func (x *PublishMediaInfoReq) String() string { func (*PublishMediaInfoReq) ProtoMessage() {} func (x *PublishMediaInfoReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[36] + mi := &file_pb_fiee_cast_proto_msgTypes[38] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2916,7 +3012,7 @@ func (x *PublishMediaInfoReq) ProtoReflect() protoreflect.Message { // Deprecated: Use PublishMediaInfoReq.ProtoReflect.Descriptor instead. func (*PublishMediaInfoReq) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{36} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{38} } func (x *PublishMediaInfoReq) GetWorkUuid() string { @@ -2952,7 +3048,7 @@ type PublishMediaInfoResp struct { func (x *PublishMediaInfoResp) Reset() { *x = PublishMediaInfoResp{} - mi := &file_pb_fiee_cast_proto_msgTypes[37] + mi := &file_pb_fiee_cast_proto_msgTypes[39] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2964,7 +3060,7 @@ func (x *PublishMediaInfoResp) String() string { func (*PublishMediaInfoResp) ProtoMessage() {} func (x *PublishMediaInfoResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[37] + mi := &file_pb_fiee_cast_proto_msgTypes[39] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2977,7 +3073,7 @@ func (x *PublishMediaInfoResp) ProtoReflect() protoreflect.Message { // Deprecated: Use PublishMediaInfoResp.ProtoReflect.Descriptor instead. func (*PublishMediaInfoResp) Descriptor() ([]byte, []int) { - return file_pb_fiee_cast_proto_rawDescGZIP(), []int{37} + return file_pb_fiee_cast_proto_rawDescGZIP(), []int{39} } func (x *PublishMediaInfoResp) GetWorkUuid() string { @@ -3031,7 +3127,7 @@ type WorkListResp_Info struct { func (x *WorkListResp_Info) Reset() { *x = WorkListResp_Info{} - mi := &file_pb_fiee_cast_proto_msgTypes[38] + mi := &file_pb_fiee_cast_proto_msgTypes[40] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3043,7 +3139,7 @@ func (x *WorkListResp_Info) String() string { func (*WorkListResp_Info) ProtoMessage() {} func (x *WorkListResp_Info) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[38] + mi := &file_pb_fiee_cast_proto_msgTypes[40] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3178,7 +3274,7 @@ type MediaAccountsResp_Info struct { func (x *MediaAccountsResp_Info) Reset() { *x = MediaAccountsResp_Info{} - mi := &file_pb_fiee_cast_proto_msgTypes[40] + mi := &file_pb_fiee_cast_proto_msgTypes[42] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3190,7 +3286,7 @@ func (x *MediaAccountsResp_Info) String() string { func (*MediaAccountsResp_Info) ProtoMessage() {} func (x *MediaAccountsResp_Info) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[40] + mi := &file_pb_fiee_cast_proto_msgTypes[42] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3266,7 +3362,7 @@ type MediaWorksResp_Info struct { func (x *MediaWorksResp_Info) Reset() { *x = MediaWorksResp_Info{} - mi := &file_pb_fiee_cast_proto_msgTypes[41] + mi := &file_pb_fiee_cast_proto_msgTypes[43] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3278,7 +3374,7 @@ func (x *MediaWorksResp_Info) String() string { func (*MediaWorksResp_Info) ProtoMessage() {} func (x *MediaWorksResp_Info) ProtoReflect() protoreflect.Message { - mi := &file_pb_fiee_cast_proto_msgTypes[41] + mi := &file_pb_fiee_cast_proto_msgTypes[43] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3647,7 +3743,15 @@ const file_pb_fiee_cast_proto_rawDesc = "" + "\x06images\x18\b \x03(\tR\x06images\x12\x1a\n" + "\bvideoUrl\x18\t \x01(\tR\bvideoUrl\x12\x1a\n" + "\bcoverUrl\x18\n" + - " \x01(\tR\bcoverUrl\"\x86\x01\n" + + " \x01(\tR\bcoverUrl\"(\n" + + "\n" + + "PublishReq\x12\x1a\n" + + "\bworkUuid\x18\x01 \x01(\tR\bworkUuid\"Q\n" + + "\vPublishResp\x12\x1e\n" + + "\n" + + "artistUuid\x18\x01 \x01(\tR\n" + + "artistUuid\x12\"\n" + + "\fworkCategory\x18\x02 \x01(\x05R\fworkCategory\"\x86\x01\n" + "\fRePublishReq\x12\x1a\n" + "\bworkUuid\x18\x01 \x01(\tR\bworkUuid\x12,\n" + "\x11mediaAccountUuids\x18\x02 \x03(\tR\x11mediaAccountUuids\x12,\n" + @@ -3740,7 +3844,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" + "\x0fAutoPublishENUM\x12\x16\n" + "\x12AutoPublish_UNKONW\x10\x00\x12\x14\n" + "\x10AutoPublish_TRUE\x10\x01\x12\x15\n" + - "\x11AutoPublish_FALSE\x10\x022\xde\t\n" + + "\x11AutoPublish_FALSE\x10\x022\x90\n" + + "\n" + "\x04Cast\x12B\n" + "\rMediaUserList\x12\x16.Cast.MediaUserListReq\x1a\x17.Cast.MediaUserListResp\"\x00\x12Q\n" + "\x12UpdateMediaAccount\x12\x1b.Cast.UpdateMediaAccountReq\x1a\x1c.Cast.UpdateMediaAccountResp\"\x00\x12B\n" + @@ -3754,7 +3859,8 @@ const file_pb_fiee_cast_proto_rawDesc = "" + "\fUpdateStatus\x12\x15.Cast.UpdateStatusReq\x1a\x16.google.protobuf.Empty\"\x00\x12B\n" + "\rMediaAccounts\x12\x16.Cast.MediaAccountsReq\x1a\x17.Cast.MediaAccountsResp\"\x00\x129\n" + "\n" + - "MediaWorks\x12\x13.Cast.MediaWorksReq\x1a\x14.Cast.MediaWorksResp\"\x00\x126\n" + + "MediaWorks\x12\x13.Cast.MediaWorksReq\x1a\x14.Cast.MediaWorksResp\"\x00\x120\n" + + "\aPublish\x12\x10.Cast.PublishReq\x1a\x11.Cast.PublishResp\"\x00\x126\n" + "\tRePublish\x12\x12.Cast.RePublishReq\x1a\x13.Cast.RePublishResp\"\x00\x125\n" + "\aDelWork\x12\x10.Cast.DelWorkReq\x1a\x16.google.protobuf.Empty\"\x00\x123\n" + "\bWorkInfo\x12\x11.Cast.WorkInfoReq\x1a\x12.Cast.WorkInfoResp\"\x00\x12?\n" + @@ -3777,7 +3883,7 @@ func file_pb_fiee_cast_proto_rawDescGZIP() []byte { } var file_pb_fiee_cast_proto_enumTypes = make([]protoimpl.EnumInfo, 4) -var file_pb_fiee_cast_proto_msgTypes = make([]protoimpl.MessageInfo, 42) +var file_pb_fiee_cast_proto_msgTypes = make([]protoimpl.MessageInfo, 44) var file_pb_fiee_cast_proto_goTypes = []any{ (PlatformIDENUM)(0), // 0: Cast.PlatformIDENUM (AuthStatusENUM)(0), // 1: Cast.AuthStatusENUM @@ -3806,26 +3912,28 @@ var file_pb_fiee_cast_proto_goTypes = []any{ (*MediaAccountsResp)(nil), // 24: Cast.MediaAccountsResp (*MediaWorksReq)(nil), // 25: Cast.MediaWorksReq (*MediaWorksResp)(nil), // 26: Cast.MediaWorksResp - (*RePublishReq)(nil), // 27: Cast.RePublishReq - (*RePublishResp)(nil), // 28: Cast.RePublishResp - (*DelWorkReq)(nil), // 29: Cast.DelWorkReq - (*WorkInfoReq)(nil), // 30: Cast.WorkInfoReq - (*WorkInfoResp)(nil), // 31: Cast.WorkInfoResp - (*OAuthAccountReq)(nil), // 32: Cast.OAuthAccountReq - (*OAuthAccountResp)(nil), // 33: Cast.OAuthAccountResp - (*OAuthYoutubeTokenReq)(nil), // 34: Cast.OAuthYoutubeTokenReq - (*OAuthYoutubeTokenResp)(nil), // 35: Cast.OAuthYoutubeTokenResp - (*OAuthCodeToTokenReq)(nil), // 36: Cast.OAuthCodeToTokenReq - (*OAuthCodeToTokenResp)(nil), // 37: Cast.OAuthCodeToTokenResp - (*RefreshTokenReq)(nil), // 38: Cast.RefreshTokenReq - (*RefreshTokenResp)(nil), // 39: Cast.RefreshTokenResp - (*PublishMediaInfoReq)(nil), // 40: Cast.PublishMediaInfoReq - (*PublishMediaInfoResp)(nil), // 41: Cast.PublishMediaInfoResp - (*WorkListResp_Info)(nil), // 42: Cast.WorkListResp.Info - nil, // 43: Cast.WorkDetailResp.MediaAccDataEntry - (*MediaAccountsResp_Info)(nil), // 44: Cast.MediaAccountsResp.Info - (*MediaWorksResp_Info)(nil), // 45: Cast.MediaWorksResp.Info - (*emptypb.Empty)(nil), // 46: google.protobuf.Empty + (*PublishReq)(nil), // 27: Cast.PublishReq + (*PublishResp)(nil), // 28: Cast.PublishResp + (*RePublishReq)(nil), // 29: Cast.RePublishReq + (*RePublishResp)(nil), // 30: Cast.RePublishResp + (*DelWorkReq)(nil), // 31: Cast.DelWorkReq + (*WorkInfoReq)(nil), // 32: Cast.WorkInfoReq + (*WorkInfoResp)(nil), // 33: Cast.WorkInfoResp + (*OAuthAccountReq)(nil), // 34: Cast.OAuthAccountReq + (*OAuthAccountResp)(nil), // 35: Cast.OAuthAccountResp + (*OAuthYoutubeTokenReq)(nil), // 36: Cast.OAuthYoutubeTokenReq + (*OAuthYoutubeTokenResp)(nil), // 37: Cast.OAuthYoutubeTokenResp + (*OAuthCodeToTokenReq)(nil), // 38: Cast.OAuthCodeToTokenReq + (*OAuthCodeToTokenResp)(nil), // 39: Cast.OAuthCodeToTokenResp + (*RefreshTokenReq)(nil), // 40: Cast.RefreshTokenReq + (*RefreshTokenResp)(nil), // 41: Cast.RefreshTokenResp + (*PublishMediaInfoReq)(nil), // 42: Cast.PublishMediaInfoReq + (*PublishMediaInfoResp)(nil), // 43: Cast.PublishMediaInfoResp + (*WorkListResp_Info)(nil), // 44: Cast.WorkListResp.Info + nil, // 45: Cast.WorkDetailResp.MediaAccDataEntry + (*MediaAccountsResp_Info)(nil), // 46: Cast.MediaAccountsResp.Info + (*MediaWorksResp_Info)(nil), // 47: Cast.MediaWorksResp.Info + (*emptypb.Empty)(nil), // 48: google.protobuf.Empty } var file_pb_fiee_cast_proto_depIdxs = []int32{ 0, // 0: Cast.MediaUserListReq.platformID:type_name -> Cast.PlatformIDENUM @@ -3843,16 +3951,16 @@ var file_pb_fiee_cast_proto_depIdxs = []int32{ 14, // 12: Cast.UpdateWorkVideoReq.publishConfig2:type_name -> Cast.PublishConfig 14, // 13: Cast.UpdateWorkVideoReq.publishConfig3:type_name -> Cast.PublishConfig 3, // 14: Cast.UpdateWorkVideoReq.autoPublish:type_name -> Cast.AutoPublishENUM - 42, // 15: Cast.WorkListResp.data:type_name -> Cast.WorkListResp.Info + 44, // 15: Cast.WorkListResp.data:type_name -> Cast.WorkListResp.Info 14, // 16: Cast.WorkDetailResp.publishConfig1:type_name -> Cast.PublishConfig 14, // 17: Cast.WorkDetailResp.publishConfig2:type_name -> Cast.PublishConfig 14, // 18: Cast.WorkDetailResp.publishConfig3:type_name -> Cast.PublishConfig 20, // 19: Cast.WorkDetailResp.WorkLogData:type_name -> Cast.WorkLogInfo - 43, // 20: Cast.WorkDetailResp.mediaAccData:type_name -> Cast.WorkDetailResp.MediaAccDataEntry + 45, // 20: Cast.WorkDetailResp.mediaAccData:type_name -> Cast.WorkDetailResp.MediaAccDataEntry 2, // 21: Cast.UpdateStatusReq.workAction:type_name -> Cast.WorkActionENUM 3, // 22: Cast.UpdateStatusReq.autoPublish:type_name -> Cast.AutoPublishENUM - 44, // 23: Cast.MediaAccountsResp.data:type_name -> Cast.MediaAccountsResp.Info - 45, // 24: Cast.MediaWorksResp.data:type_name -> Cast.MediaWorksResp.Info + 46, // 23: Cast.MediaAccountsResp.data:type_name -> Cast.MediaAccountsResp.Info + 47, // 24: Cast.MediaWorksResp.data:type_name -> Cast.MediaWorksResp.Info 0, // 25: Cast.OAuthCodeToTokenReq.platformID:type_name -> Cast.PlatformIDENUM 0, // 26: Cast.RefreshTokenReq.platformID:type_name -> Cast.PlatformIDENUM 5, // 27: Cast.WorkDetailResp.MediaAccDataEntry.value:type_name -> Cast.MediaUserInfo @@ -3867,35 +3975,37 @@ var file_pb_fiee_cast_proto_depIdxs = []int32{ 22, // 36: Cast.Cast.UpdateStatus:input_type -> Cast.UpdateStatusReq 23, // 37: Cast.Cast.MediaAccounts:input_type -> Cast.MediaAccountsReq 25, // 38: Cast.Cast.MediaWorks:input_type -> Cast.MediaWorksReq - 27, // 39: Cast.Cast.RePublish:input_type -> Cast.RePublishReq - 29, // 40: Cast.Cast.DelWork:input_type -> Cast.DelWorkReq - 30, // 41: Cast.Cast.WorkInfo:input_type -> Cast.WorkInfoReq - 32, // 42: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq - 36, // 43: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq - 38, // 44: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq - 40, // 45: Cast.Cast.PublishMediaInfo:input_type -> Cast.PublishMediaInfoReq - 46, // 46: Cast.Cast.Test:input_type -> google.protobuf.Empty - 6, // 47: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp - 8, // 48: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp - 10, // 49: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp - 46, // 50: Cast.Cast.BindManager:output_type -> google.protobuf.Empty - 13, // 51: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp - 16, // 52: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp - 18, // 53: Cast.Cast.WorkList:output_type -> Cast.WorkListResp - 21, // 54: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp - 46, // 55: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty - 24, // 56: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp - 26, // 57: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp - 28, // 58: Cast.Cast.RePublish:output_type -> Cast.RePublishResp - 46, // 59: Cast.Cast.DelWork:output_type -> google.protobuf.Empty - 31, // 60: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp - 33, // 61: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp - 37, // 62: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp - 39, // 63: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp - 41, // 64: Cast.Cast.PublishMediaInfo:output_type -> Cast.PublishMediaInfoResp - 46, // 65: Cast.Cast.Test:output_type -> google.protobuf.Empty - 47, // [47:66] is the sub-list for method output_type - 28, // [28:47] is the sub-list for method input_type + 27, // 39: Cast.Cast.Publish:input_type -> Cast.PublishReq + 29, // 40: Cast.Cast.RePublish:input_type -> Cast.RePublishReq + 31, // 41: Cast.Cast.DelWork:input_type -> Cast.DelWorkReq + 32, // 42: Cast.Cast.WorkInfo:input_type -> Cast.WorkInfoReq + 34, // 43: Cast.Cast.OAuthAccount:input_type -> Cast.OAuthAccountReq + 38, // 44: Cast.Cast.OAuthCodeToToken:input_type -> Cast.OAuthCodeToTokenReq + 40, // 45: Cast.Cast.RefreshToken:input_type -> Cast.RefreshTokenReq + 42, // 46: Cast.Cast.PublishMediaInfo:input_type -> Cast.PublishMediaInfoReq + 48, // 47: Cast.Cast.Test:input_type -> google.protobuf.Empty + 6, // 48: Cast.Cast.MediaUserList:output_type -> Cast.MediaUserListResp + 8, // 49: Cast.Cast.UpdateMediaAccount:output_type -> Cast.UpdateMediaAccountResp + 10, // 50: Cast.Cast.UnbindManager:output_type -> Cast.UnbindManagerResp + 48, // 51: Cast.Cast.BindManager:output_type -> google.protobuf.Empty + 13, // 52: Cast.Cast.UpdateWorkImage:output_type -> Cast.UpdateWorkImageResp + 16, // 53: Cast.Cast.UpdateWorkVideo:output_type -> Cast.UpdateWorkVideoResp + 18, // 54: Cast.Cast.WorkList:output_type -> Cast.WorkListResp + 21, // 55: Cast.Cast.WorkDetail:output_type -> Cast.WorkDetailResp + 48, // 56: Cast.Cast.UpdateStatus:output_type -> google.protobuf.Empty + 24, // 57: Cast.Cast.MediaAccounts:output_type -> Cast.MediaAccountsResp + 26, // 58: Cast.Cast.MediaWorks:output_type -> Cast.MediaWorksResp + 28, // 59: Cast.Cast.Publish:output_type -> Cast.PublishResp + 30, // 60: Cast.Cast.RePublish:output_type -> Cast.RePublishResp + 48, // 61: Cast.Cast.DelWork:output_type -> google.protobuf.Empty + 33, // 62: Cast.Cast.WorkInfo:output_type -> Cast.WorkInfoResp + 35, // 63: Cast.Cast.OAuthAccount:output_type -> Cast.OAuthAccountResp + 39, // 64: Cast.Cast.OAuthCodeToToken:output_type -> Cast.OAuthCodeToTokenResp + 41, // 65: Cast.Cast.RefreshToken:output_type -> Cast.RefreshTokenResp + 43, // 66: Cast.Cast.PublishMediaInfo:output_type -> Cast.PublishMediaInfoResp + 48, // 67: Cast.Cast.Test:output_type -> google.protobuf.Empty + 48, // [48:68] is the sub-list for method output_type + 28, // [28:48] is the sub-list for method input_type 28, // [28:28] is the sub-list for extension type_name 28, // [28:28] is the sub-list for extension extendee 0, // [0:28] is the sub-list for field type_name @@ -3912,7 +4022,7 @@ func file_pb_fiee_cast_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_pb_fiee_cast_proto_rawDesc), len(file_pb_fiee_cast_proto_rawDesc)), NumEnums: 4, - NumMessages: 42, + NumMessages: 44, NumExtensions: 0, NumServices: 1, }, diff --git a/api/cast/cast.pb.validate.go b/api/cast/cast.pb.validate.go index c5d9b35..bd60999 100644 --- a/api/cast/cast.pb.validate.go +++ b/api/cast/cast.pb.validate.go @@ -3080,6 +3080,210 @@ var _ interface { ErrorName() string } = MediaWorksRespValidationError{} +// Validate checks the field values on PublishReq with the rules defined in the +// proto definition for this message. If any rules are violated, the first +// error encountered is returned, or nil if there are no violations. +func (m *PublishReq) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PublishReq with the rules defined in +// the proto definition for this message. If any rules are violated, the +// result is a list of violation errors wrapped in PublishReqMultiError, or +// nil if none found. +func (m *PublishReq) ValidateAll() error { + return m.validate(true) +} + +func (m *PublishReq) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for WorkUuid + + if len(errors) > 0 { + return PublishReqMultiError(errors) + } + + return nil +} + +// PublishReqMultiError is an error wrapping multiple validation errors +// returned by PublishReq.ValidateAll() if the designated constraints aren't met. +type PublishReqMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PublishReqMultiError) Error() string { + msgs := make([]string, 0, len(m)) + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PublishReqMultiError) AllErrors() []error { return m } + +// PublishReqValidationError is the validation error returned by +// PublishReq.Validate if the designated constraints aren't met. +type PublishReqValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PublishReqValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PublishReqValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PublishReqValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PublishReqValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PublishReqValidationError) ErrorName() string { return "PublishReqValidationError" } + +// Error satisfies the builtin error interface +func (e PublishReqValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPublishReq.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PublishReqValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PublishReqValidationError{} + +// Validate checks the field values on PublishResp with the rules defined in +// the proto definition for this message. If any rules are violated, the first +// error encountered is returned, or nil if there are no violations. +func (m *PublishResp) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PublishResp with the rules defined in +// the proto definition for this message. If any rules are violated, the +// result is a list of violation errors wrapped in PublishRespMultiError, or +// nil if none found. +func (m *PublishResp) ValidateAll() error { + return m.validate(true) +} + +func (m *PublishResp) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for ArtistUuid + + // no validation rules for WorkCategory + + if len(errors) > 0 { + return PublishRespMultiError(errors) + } + + return nil +} + +// PublishRespMultiError is an error wrapping multiple validation errors +// returned by PublishResp.ValidateAll() if the designated constraints aren't met. +type PublishRespMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PublishRespMultiError) Error() string { + msgs := make([]string, 0, len(m)) + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PublishRespMultiError) AllErrors() []error { return m } + +// PublishRespValidationError is the validation error returned by +// PublishResp.Validate if the designated constraints aren't met. +type PublishRespValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PublishRespValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PublishRespValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PublishRespValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PublishRespValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PublishRespValidationError) ErrorName() string { return "PublishRespValidationError" } + +// Error satisfies the builtin error interface +func (e PublishRespValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPublishResp.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PublishRespValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PublishRespValidationError{} + // Validate checks the field values on RePublishReq with the rules defined in // the proto definition for this message. If any rules are violated, the first // error encountered is returned, or nil if there are no violations. diff --git a/api/cast/cast_triple.pb.go b/api/cast/cast_triple.pb.go index 7383277..b1a04af 100644 --- a/api/cast/cast_triple.pb.go +++ b/api/cast/cast_triple.pb.go @@ -40,6 +40,7 @@ type CastClient interface { UpdateStatus(ctx context.Context, in *UpdateStatusReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) MediaAccounts(ctx context.Context, in *MediaAccountsReq, opts ...grpc_go.CallOption) (*MediaAccountsResp, common.ErrorWithAttachment) MediaWorks(ctx context.Context, in *MediaWorksReq, opts ...grpc_go.CallOption) (*MediaWorksResp, common.ErrorWithAttachment) + Publish(ctx context.Context, in *PublishReq, opts ...grpc_go.CallOption) (*PublishResp, common.ErrorWithAttachment) RePublish(ctx context.Context, in *RePublishReq, opts ...grpc_go.CallOption) (*RePublishResp, common.ErrorWithAttachment) DelWork(ctx context.Context, in *DelWorkReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) WorkInfo(ctx context.Context, in *WorkInfoReq, opts ...grpc_go.CallOption) (*WorkInfoResp, common.ErrorWithAttachment) @@ -66,6 +67,7 @@ type CastClientImpl struct { UpdateStatus func(ctx context.Context, in *UpdateStatusReq) (*emptypb.Empty, error) MediaAccounts func(ctx context.Context, in *MediaAccountsReq) (*MediaAccountsResp, error) MediaWorks func(ctx context.Context, in *MediaWorksReq) (*MediaWorksResp, error) + Publish func(ctx context.Context, in *PublishReq) (*PublishResp, error) RePublish func(ctx context.Context, in *RePublishReq) (*RePublishResp, error) DelWork func(ctx context.Context, in *DelWorkReq) (*emptypb.Empty, error) WorkInfo func(ctx context.Context, in *WorkInfoReq) (*WorkInfoResp, error) @@ -154,6 +156,12 @@ func (c *castClient) MediaWorks(ctx context.Context, in *MediaWorksReq, opts ... return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/MediaWorks", in, out) } +func (c *castClient) Publish(ctx context.Context, in *PublishReq, opts ...grpc_go.CallOption) (*PublishResp, common.ErrorWithAttachment) { + out := new(PublishResp) + interfaceKey := ctx.Value(constant.InterfaceKey).(string) + return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/Publish", in, out) +} + func (c *castClient) RePublish(ctx context.Context, in *RePublishReq, opts ...grpc_go.CallOption) (*RePublishResp, common.ErrorWithAttachment) { out := new(RePublishResp) interfaceKey := ctx.Value(constant.InterfaceKey).(string) @@ -217,6 +225,7 @@ type CastServer interface { UpdateStatus(context.Context, *UpdateStatusReq) (*emptypb.Empty, error) MediaAccounts(context.Context, *MediaAccountsReq) (*MediaAccountsResp, error) MediaWorks(context.Context, *MediaWorksReq) (*MediaWorksResp, error) + Publish(context.Context, *PublishReq) (*PublishResp, error) RePublish(context.Context, *RePublishReq) (*RePublishResp, error) DelWork(context.Context, *DelWorkReq) (*emptypb.Empty, error) WorkInfo(context.Context, *WorkInfoReq) (*WorkInfoResp, error) @@ -266,6 +275,9 @@ func (UnimplementedCastServer) MediaAccounts(context.Context, *MediaAccountsReq) func (UnimplementedCastServer) MediaWorks(context.Context, *MediaWorksReq) (*MediaWorksResp, error) { return nil, status.Errorf(codes.Unimplemented, "method MediaWorks not implemented") } +func (UnimplementedCastServer) Publish(context.Context, *PublishReq) (*PublishResp, error) { + return nil, status.Errorf(codes.Unimplemented, "method Publish not implemented") +} func (UnimplementedCastServer) RePublish(context.Context, *RePublishReq) (*RePublishResp, error) { return nil, status.Errorf(codes.Unimplemented, "method RePublish not implemented") } @@ -637,6 +649,35 @@ func _Cast_MediaWorks_Handler(srv interface{}, ctx context.Context, dec func(int return interceptor(ctx, in, info, handler) } +func _Cast_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { + in := new(PublishReq) + if err := dec(in); err != nil { + return nil, err + } + base := srv.(dubbo3.Dubbo3GrpcService) + args := []interface{}{} + args = append(args, in) + md, _ := metadata.FromIncomingContext(ctx) + invAttachment := make(map[string]interface{}, len(md)) + for k, v := range md { + invAttachment[k] = v + } + invo := invocation.NewRPCInvocation("Publish", args, invAttachment) + if interceptor == nil { + result := base.XXX_GetProxyImpl().Invoke(ctx, invo) + return result, result.Error() + } + info := &grpc_go.UnaryServerInfo{ + Server: srv, + FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + result := base.XXX_GetProxyImpl().Invoke(ctx, invo) + return result, result.Error() + } + return interceptor(ctx, in, info, handler) +} + func _Cast_RePublish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(RePublishReq) if err := dec(in); err != nil { @@ -920,6 +961,10 @@ var Cast_ServiceDesc = grpc_go.ServiceDesc{ MethodName: "MediaWorks", Handler: _Cast_MediaWorks_Handler, }, + { + MethodName: "Publish", + Handler: _Cast_Publish_Handler, + }, { MethodName: "RePublish", Handler: _Cast_RePublish_Handler, diff --git a/pkg/router/media.go b/pkg/router/media.go index 6dc5867..75c069b 100644 --- a/pkg/router/media.go +++ b/pkg/router/media.go @@ -37,6 +37,7 @@ func MediaRouter(r *gin.RouterGroup) { work.Any("list-export", serviceCast.WorkListExport) work.POST("detail", serviceCast.WorkDetail) work.POST("republish", serviceCast.RePublish) + work.POST("publish", serviceCast.Publish) work.POST("delete", serviceCast.DelWork) work.POST("remind", serviceCast.Remind) work.POST("publish-info", serviceCast.PublishInfo) diff --git a/pkg/service/cast/work.go b/pkg/service/cast/work.go index be000ec..ed6f30a 100644 --- a/pkg/service/cast/work.go +++ b/pkg/service/cast/work.go @@ -219,6 +219,27 @@ func CheckUserBundleBalance(userID int32, balanceType modelCast.BalanceTypeEnum) return } +func Publish(ctx *gin.Context) { + var ( + req *cast.PublishReq + resp *cast.PublishResp + //workInfoResp *cast.WorkInfoResp + ) + var err error + if err = ctx.ShouldBind(&req); err != nil { + service.Error(ctx, err) + return + } + newCtx := NewCtxWithUserInfo(ctx) + resp, err = service.CastProvider.Publish(newCtx, req) + if err != nil { + service.Error(ctx, err) + return + } + service.Success(ctx, resp) + return +} + func RePublish(ctx *gin.Context) { var ( req *cast.RePublishReq