From c99ac1a6b31933ccf493160f09ef73960c7c80b8 Mon Sep 17 00:00:00 2001 From: "daniel.w" Date: Thu, 29 Aug 2024 23:53:43 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=A7=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- etc/tweeting.yaml | 6 -- go.mod | 88 ------------------- internal/config/config.go | 7 -- .../logic/commentservice/count_like_logic.go | 31 ------- .../commentservice/delete_comment_logic.go | 31 ------- .../commentservice/get_comments_logic.go | 31 ------- .../commentservice/get_like_status_logic.go | 31 ------- .../commentservice/like_comment_logic.go | 31 ------- .../logic/commentservice/like_list_logic.go | 31 ------- .../logic/commentservice/new_comment_logic.go | 31 ------- .../commentservice/update_comment_logic.go | 31 ------- .../logic/postservice/count_like_logic.go | 31 ------- .../logic/postservice/delete_post_logic.go | 31 ------- .../postservice/get_like_status_logic.go | 31 ------- internal/logic/postservice/like_list_logic.go | 31 ------- internal/logic/postservice/like_logic.go | 31 ------- .../logic/postservice/list_posts_logic.go | 31 ------- internal/logic/postservice/new_post_logic.go | 31 ------- .../logic/postservice/update_post_logic.go | 31 ------- internal/model/mongo/comment_likes_model.go | 25 ------ .../model/mongo/comment_likes_model_gen.go | 74 ---------------- internal/model/mongo/comment_likes_types.go | 14 --- internal/model/mongo/comment_model.go | 28 ------ internal/model/mongo/comment_model_gen.go | 77 ---------------- internal/model/mongo/comment_types.go | 14 --- internal/model/mongo/error.go | 12 --- internal/model/mongo/post_likes_model.go | 25 ------ internal/model/mongo/post_likes_model_gen.go | 74 ---------------- internal/model/mongo/post_likes_types.go | 14 --- internal/model/mongo/post_model.go | 28 ------ internal/model/mongo/post_model_gen.go | 77 ---------------- internal/model/mongo/post_types.go | 14 --- internal/model/mongo/tags_model.go | 25 ------ internal/model/mongo/tags_model_gen.go | 74 ---------------- internal/model/mongo/tags_types.go | 14 --- .../commentservice/comment_service_server.go | 71 --------------- .../server/postservice/post_service_server.go | 71 --------------- internal/svc/service_context.go | 13 --- tweeting.go | 41 --------- 39 files changed, 1382 deletions(-) delete mode 100644 etc/tweeting.yaml delete mode 100644 go.mod delete mode 100755 internal/config/config.go delete mode 100644 internal/logic/commentservice/count_like_logic.go delete mode 100644 internal/logic/commentservice/delete_comment_logic.go delete mode 100644 internal/logic/commentservice/get_comments_logic.go delete mode 100644 internal/logic/commentservice/get_like_status_logic.go delete mode 100644 internal/logic/commentservice/like_comment_logic.go delete mode 100644 internal/logic/commentservice/like_list_logic.go delete mode 100644 internal/logic/commentservice/new_comment_logic.go delete mode 100644 internal/logic/commentservice/update_comment_logic.go delete mode 100644 internal/logic/postservice/count_like_logic.go delete mode 100644 internal/logic/postservice/delete_post_logic.go delete mode 100644 internal/logic/postservice/get_like_status_logic.go delete mode 100644 internal/logic/postservice/like_list_logic.go delete mode 100644 internal/logic/postservice/like_logic.go delete mode 100644 internal/logic/postservice/list_posts_logic.go delete mode 100644 internal/logic/postservice/new_post_logic.go delete mode 100644 internal/logic/postservice/update_post_logic.go delete mode 100644 internal/model/mongo/comment_likes_model.go delete mode 100644 internal/model/mongo/comment_likes_model_gen.go delete mode 100644 internal/model/mongo/comment_likes_types.go delete mode 100644 internal/model/mongo/comment_model.go delete mode 100644 internal/model/mongo/comment_model_gen.go delete mode 100644 internal/model/mongo/comment_types.go delete mode 100644 internal/model/mongo/error.go delete mode 100644 internal/model/mongo/post_likes_model.go delete mode 100644 internal/model/mongo/post_likes_model_gen.go delete mode 100644 internal/model/mongo/post_likes_types.go delete mode 100644 internal/model/mongo/post_model.go delete mode 100644 internal/model/mongo/post_model_gen.go delete mode 100644 internal/model/mongo/post_types.go delete mode 100644 internal/model/mongo/tags_model.go delete mode 100644 internal/model/mongo/tags_model_gen.go delete mode 100644 internal/model/mongo/tags_types.go delete mode 100644 internal/server/commentservice/comment_service_server.go delete mode 100644 internal/server/postservice/post_service_server.go delete mode 100644 internal/svc/service_context.go delete mode 100644 tweeting.go diff --git a/etc/tweeting.yaml b/etc/tweeting.yaml deleted file mode 100644 index c611c48..0000000 --- a/etc/tweeting.yaml +++ /dev/null @@ -1,6 +0,0 @@ -Name: tweeting.rpc -ListenOn: 0.0.0.0:8080 -Etcd: - Hosts: - - 127.0.0.1:2379 - Key: tweeting.rpc diff --git a/go.mod b/go.mod deleted file mode 100644 index 1be6bfb..0000000 --- a/go.mod +++ /dev/null @@ -1,88 +0,0 @@ -module app-cloudep-tweeting-service - -go 1.22.3 - -require ( - github.com/zeromicro/go-zero v1.7.0 - google.golang.org/grpc v1.66.0 - google.golang.org/protobuf v1.34.2 -) - -require ( - github.com/beorn7/perks v1.0.1 // indirect - github.com/cenkalti/backoff/v4 v4.3.0 // indirect - github.com/cespare/xxhash/v2 v2.3.0 // indirect - github.com/coreos/go-semver v0.3.1 // indirect - github.com/coreos/go-systemd/v22 v22.5.0 // indirect - github.com/davecgh/go-spew v1.1.1 // indirect - github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect - github.com/emicklei/go-restful/v3 v3.11.0 // indirect - github.com/fatih/color v1.17.0 // indirect - github.com/go-logr/logr v1.4.2 // indirect - github.com/go-logr/stdr v1.2.2 // indirect - github.com/go-openapi/jsonpointer v0.19.6 // indirect - github.com/go-openapi/jsonreference v0.20.2 // indirect - github.com/go-openapi/swag v0.22.4 // indirect - github.com/gogo/protobuf v1.3.2 // indirect - github.com/golang/mock v1.6.0 // indirect - github.com/golang/protobuf v1.5.4 // indirect - github.com/google/gnostic-models v0.6.8 // indirect - github.com/google/go-cmp v0.6.0 // indirect - github.com/google/gofuzz v1.2.0 // indirect - github.com/google/uuid v1.6.0 // indirect - github.com/grpc-ecosystem/grpc-gateway/v2 v2.20.0 // indirect - github.com/josharian/intern v1.0.0 // indirect - github.com/json-iterator/go v1.1.12 // indirect - github.com/mailru/easyjson v0.7.7 // indirect - github.com/mattn/go-colorable v0.1.13 // indirect - github.com/mattn/go-isatty v0.0.20 // indirect - github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect - github.com/modern-go/reflect2 v1.0.2 // indirect - github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect - github.com/openzipkin/zipkin-go v0.4.3 // indirect - github.com/pelletier/go-toml/v2 v2.2.2 // indirect - github.com/prometheus/client_golang v1.19.1 // indirect - github.com/prometheus/client_model v0.5.0 // indirect - github.com/prometheus/common v0.48.0 // indirect - github.com/prometheus/procfs v0.12.0 // indirect - github.com/redis/go-redis/v9 v9.6.1 // indirect - github.com/spaolacci/murmur3 v1.1.0 // indirect - go.etcd.io/etcd/api/v3 v3.5.15 // indirect - go.etcd.io/etcd/client/pkg/v3 v3.5.15 // indirect - go.etcd.io/etcd/client/v3 v3.5.15 // indirect - go.opentelemetry.io/otel v1.24.0 // indirect - go.opentelemetry.io/otel/exporters/jaeger v1.17.0 // indirect - go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.24.0 // indirect - go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.24.0 // indirect - go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.24.0 // indirect - go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.24.0 // indirect - go.opentelemetry.io/otel/exporters/zipkin v1.24.0 // indirect - go.opentelemetry.io/otel/metric v1.24.0 // indirect - go.opentelemetry.io/otel/sdk v1.24.0 // indirect - go.opentelemetry.io/otel/trace v1.24.0 // indirect - go.opentelemetry.io/proto/otlp v1.3.1 // indirect - go.uber.org/atomic v1.10.0 // indirect - go.uber.org/automaxprocs v1.5.3 // indirect - go.uber.org/multierr v1.9.0 // indirect - go.uber.org/zap v1.24.0 // indirect - golang.org/x/net v0.27.0 // indirect - golang.org/x/oauth2 v0.21.0 // indirect - golang.org/x/sys v0.22.0 // indirect - golang.org/x/term v0.22.0 // indirect - golang.org/x/text v0.16.0 // indirect - golang.org/x/time v0.5.0 // indirect - google.golang.org/genproto/googleapis/api v0.0.0-20240711142825-46eb208f015d // indirect - google.golang.org/genproto/googleapis/rpc v0.0.0-20240701130421-f6361c86f094 // indirect - gopkg.in/inf.v0 v0.9.1 // indirect - gopkg.in/yaml.v2 v2.4.0 // indirect - gopkg.in/yaml.v3 v3.0.1 // indirect - k8s.io/api v0.29.3 // indirect - k8s.io/apimachinery v0.29.4 // indirect - k8s.io/client-go v0.29.3 // indirect - k8s.io/klog/v2 v2.110.1 // indirect - k8s.io/kube-openapi v0.0.0-20231010175941-2dd684a91f00 // indirect - k8s.io/utils v0.0.0-20240711033017-18e509b52bc8 // indirect - sigs.k8s.io/json v0.0.0-20221116044647-bc3834ca7abd // indirect - sigs.k8s.io/structured-merge-diff/v4 v4.4.1 // indirect - sigs.k8s.io/yaml v1.3.0 // indirect -) diff --git a/internal/config/config.go b/internal/config/config.go deleted file mode 100755 index c1f85b9..0000000 --- a/internal/config/config.go +++ /dev/null @@ -1,7 +0,0 @@ -package config - -import "github.com/zeromicro/go-zero/zrpc" - -type Config struct { - zrpc.RpcServerConf -} diff --git a/internal/logic/commentservice/count_like_logic.go b/internal/logic/commentservice/count_like_logic.go deleted file mode 100644 index c656dc8..0000000 --- a/internal/logic/commentservice/count_like_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type CountLikeLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewCountLikeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CountLikeLogic { - return &CountLikeLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// CountLike 取得讚/不讚評論數量 -func (l *CountLikeLogic) CountLike(in *tweeting.LikeCountReq) (*tweeting.LikeCountResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.LikeCountResp{}, nil -} diff --git a/internal/logic/commentservice/delete_comment_logic.go b/internal/logic/commentservice/delete_comment_logic.go deleted file mode 100644 index 665cf06..0000000 --- a/internal/logic/commentservice/delete_comment_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type DeleteCommentLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewDeleteCommentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteCommentLogic { - return &DeleteCommentLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// DeleteComment 刪除評論 -func (l *DeleteCommentLogic) DeleteComment(in *tweeting.DeleteCommentReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/commentservice/get_comments_logic.go b/internal/logic/commentservice/get_comments_logic.go deleted file mode 100644 index 5f54081..0000000 --- a/internal/logic/commentservice/get_comments_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type GetCommentsLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewGetCommentsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetCommentsLogic { - return &GetCommentsLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// GetComments 查詢評論 -func (l *GetCommentsLogic) GetComments(in *tweeting.GetCommentsReq) (*tweeting.GetCommentsResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.GetCommentsResp{}, nil -} diff --git a/internal/logic/commentservice/get_like_status_logic.go b/internal/logic/commentservice/get_like_status_logic.go deleted file mode 100644 index 6dbce00..0000000 --- a/internal/logic/commentservice/get_like_status_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type GetLikeStatusLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewGetLikeStatusLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetLikeStatusLogic { - return &GetLikeStatusLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// GetLikeStatus 取得讚/不讚評論狀態 -func (l *GetLikeStatusLogic) GetLikeStatus(in *tweeting.LikeReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/commentservice/like_comment_logic.go b/internal/logic/commentservice/like_comment_logic.go deleted file mode 100644 index 60cd2c4..0000000 --- a/internal/logic/commentservice/like_comment_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type LikeCommentLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewLikeCommentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LikeCommentLogic { - return &LikeCommentLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// LikeComment 點讚/取消讚 評論 -func (l *LikeCommentLogic) LikeComment(in *tweeting.LikeReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/commentservice/like_list_logic.go b/internal/logic/commentservice/like_list_logic.go deleted file mode 100644 index 351a367..0000000 --- a/internal/logic/commentservice/like_list_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type LikeListLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewLikeListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LikeListLogic { - return &LikeListLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// LikeList 取得讚/不讚評論列表 -func (l *LikeListLogic) LikeList(in *tweeting.LikeListReq) (*tweeting.LikeListResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.LikeListResp{}, nil -} diff --git a/internal/logic/commentservice/new_comment_logic.go b/internal/logic/commentservice/new_comment_logic.go deleted file mode 100644 index 5dcc84f..0000000 --- a/internal/logic/commentservice/new_comment_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type NewCommentLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewNewCommentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NewCommentLogic { - return &NewCommentLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// NewComment 發表評論 -func (l *NewCommentLogic) NewComment(in *tweeting.CommentPostReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/commentservice/update_comment_logic.go b/internal/logic/commentservice/update_comment_logic.go deleted file mode 100644 index f38e6de..0000000 --- a/internal/logic/commentservice/update_comment_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package commentservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type UpdateCommentLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewUpdateCommentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateCommentLogic { - return &UpdateCommentLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// UpdateComment 更新評論 -func (l *UpdateCommentLogic) UpdateComment(in *tweeting.UpdateCommentReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/postservice/count_like_logic.go b/internal/logic/postservice/count_like_logic.go deleted file mode 100644 index 4fb4e67..0000000 --- a/internal/logic/postservice/count_like_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type CountLikeLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewCountLikeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CountLikeLogic { - return &CountLikeLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// CountLike 取得讚/不讚數量 -func (l *CountLikeLogic) CountLike(in *tweeting.LikeCountReq) (*tweeting.LikeCountResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.LikeCountResp{}, nil -} diff --git a/internal/logic/postservice/delete_post_logic.go b/internal/logic/postservice/delete_post_logic.go deleted file mode 100644 index 714e1f5..0000000 --- a/internal/logic/postservice/delete_post_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type DeletePostLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewDeletePostLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeletePostLogic { - return &DeletePostLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// DeletePost 刪除貼文 -func (l *DeletePostLogic) DeletePost(in *tweeting.DeletePostsReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/postservice/get_like_status_logic.go b/internal/logic/postservice/get_like_status_logic.go deleted file mode 100644 index ba92101..0000000 --- a/internal/logic/postservice/get_like_status_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type GetLikeStatusLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewGetLikeStatusLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetLikeStatusLogic { - return &GetLikeStatusLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// GetLikeStatus 取得讚/不讚狀態 -func (l *GetLikeStatusLogic) GetLikeStatus(in *tweeting.LikeReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/postservice/like_list_logic.go b/internal/logic/postservice/like_list_logic.go deleted file mode 100644 index 6f4023b..0000000 --- a/internal/logic/postservice/like_list_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type LikeListLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewLikeListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LikeListLogic { - return &LikeListLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// LikeList 取得讚/不讚列表 -func (l *LikeListLogic) LikeList(in *tweeting.LikeListReq) (*tweeting.LikeListResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.LikeListResp{}, nil -} diff --git a/internal/logic/postservice/like_logic.go b/internal/logic/postservice/like_logic.go deleted file mode 100644 index 3965b38..0000000 --- a/internal/logic/postservice/like_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type LikeLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewLikeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LikeLogic { - return &LikeLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// Like 點讚/取消讚 貼文 -func (l *LikeLogic) Like(in *tweeting.LikeReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/logic/postservice/list_posts_logic.go b/internal/logic/postservice/list_posts_logic.go deleted file mode 100644 index abba88d..0000000 --- a/internal/logic/postservice/list_posts_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type ListPostsLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewListPostsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListPostsLogic { - return &ListPostsLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// ListPosts 查詢貼文 -func (l *ListPostsLogic) ListPosts(in *tweeting.QueryPostsReq) (*tweeting.ListPostsResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.ListPostsResp{}, nil -} diff --git a/internal/logic/postservice/new_post_logic.go b/internal/logic/postservice/new_post_logic.go deleted file mode 100644 index a755c05..0000000 --- a/internal/logic/postservice/new_post_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type NewPostLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewNewPostLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NewPostLogic { - return &NewPostLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// NewPost 新增貼文 -func (l *NewPostLogic) NewPost(in *tweeting.NewPostReq) (*tweeting.PostResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.PostResp{}, nil -} diff --git a/internal/logic/postservice/update_post_logic.go b/internal/logic/postservice/update_post_logic.go deleted file mode 100644 index 454844b..0000000 --- a/internal/logic/postservice/update_post_logic.go +++ /dev/null @@ -1,31 +0,0 @@ -package postservicelogic - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/logx" -) - -type UpdatePostLogic struct { - ctx context.Context - svcCtx *svc.ServiceContext - logx.Logger -} - -func NewUpdatePostLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdatePostLogic { - return &UpdatePostLogic{ - ctx: ctx, - svcCtx: svcCtx, - Logger: logx.WithContext(ctx), - } -} - -// UpdatePost 更新貼文 -func (l *UpdatePostLogic) UpdatePost(in *tweeting.UpdatePostReq) (*tweeting.OKResp, error) { - // todo: add your logic here and delete this line - - return &tweeting.OKResp{}, nil -} diff --git a/internal/model/mongo/comment_likes_model.go b/internal/model/mongo/comment_likes_model.go deleted file mode 100644 index 720b166..0000000 --- a/internal/model/mongo/comment_likes_model.go +++ /dev/null @@ -1,25 +0,0 @@ -package model - -import "github.com/zeromicro/go-zero/core/stores/mon" - -var _ Comment_likesModel = (*customComment_likesModel)(nil) - -type ( - // Comment_likesModel is an interface to be customized, add more methods here, - // and implement the added methods in customComment_likesModel. - Comment_likesModel interface { - comment_likesModel - } - - customComment_likesModel struct { - *defaultComment_likesModel - } -) - -// NewComment_likesModel returns a model for the mongo. -func NewComment_likesModel(url, db, collection string) Comment_likesModel { - conn := mon.MustNewModel(url, db, collection) - return &customComment_likesModel{ - defaultComment_likesModel: newDefaultComment_likesModel(conn), - } -} diff --git a/internal/model/mongo/comment_likes_model_gen.go b/internal/model/mongo/comment_likes_model_gen.go deleted file mode 100644 index cf5a194..0000000 --- a/internal/model/mongo/comment_likes_model_gen.go +++ /dev/null @@ -1,74 +0,0 @@ -// Code generated by goctl. DO NOT EDIT. -package model - -import ( - "context" - "time" - - "github.com/zeromicro/go-zero/core/stores/mon" - "go.mongodb.org/mongo-driver/bson" - "go.mongodb.org/mongo-driver/bson/primitive" - "go.mongodb.org/mongo-driver/mongo" -) - -type comment_likesModel interface { - Insert(ctx context.Context, data *Comment_likes) error - FindOne(ctx context.Context, id string) (*Comment_likes, error) - Update(ctx context.Context, data *Comment_likes) (*mongo.UpdateResult, error) - Delete(ctx context.Context, id string) (int64, error) -} - -type defaultComment_likesModel struct { - conn *mon.Model -} - -func newDefaultComment_likesModel(conn *mon.Model) *defaultComment_likesModel { - return &defaultComment_likesModel{conn: conn} -} - -func (m *defaultComment_likesModel) Insert(ctx context.Context, data *Comment_likes) error { - if data.ID.IsZero() { - data.ID = primitive.NewObjectID() - data.CreateAt = time.Now() - data.UpdateAt = time.Now() - } - - _, err := m.conn.InsertOne(ctx, data) - return err -} - -func (m *defaultComment_likesModel) FindOne(ctx context.Context, id string) (*Comment_likes, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return nil, ErrInvalidObjectId - } - - var data Comment_likes - - err = m.conn.FindOne(ctx, &data, bson.M{"_id": oid}) - switch err { - case nil: - return &data, nil - case mon.ErrNotFound: - return nil, ErrNotFound - default: - return nil, err - } -} - -func (m *defaultComment_likesModel) Update(ctx context.Context, data *Comment_likes) (*mongo.UpdateResult, error) { - data.UpdateAt = time.Now() - - res, err := m.conn.UpdateOne(ctx, bson.M{"_id": data.ID}, bson.M{"$set": data}) - return res, err -} - -func (m *defaultComment_likesModel) Delete(ctx context.Context, id string) (int64, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return 0, ErrInvalidObjectId - } - - res, err := m.conn.DeleteOne(ctx, bson.M{"_id": oid}) - return res, err -} diff --git a/internal/model/mongo/comment_likes_types.go b/internal/model/mongo/comment_likes_types.go deleted file mode 100644 index be19d28..0000000 --- a/internal/model/mongo/comment_likes_types.go +++ /dev/null @@ -1,14 +0,0 @@ -package model - -import ( - "time" - - "go.mongodb.org/mongo-driver/bson/primitive" -) - -type Comment_likes struct { - ID primitive.ObjectID `bson:"_id,omitempty" json:"id,omitempty"` - // TODO: Fill your own fields - UpdateAt time.Time `bson:"updateAt,omitempty" json:"updateAt,omitempty"` - CreateAt time.Time `bson:"createAt,omitempty" json:"createAt,omitempty"` -} diff --git a/internal/model/mongo/comment_model.go b/internal/model/mongo/comment_model.go deleted file mode 100644 index 00478ac..0000000 --- a/internal/model/mongo/comment_model.go +++ /dev/null @@ -1,28 +0,0 @@ -package model - -import ( - "github.com/zeromicro/go-zero/core/stores/cache" - "github.com/zeromicro/go-zero/core/stores/monc" -) - -var _ CommentModel = (*customCommentModel)(nil) - -type ( - // CommentModel is an interface to be customized, add more methods here, - // and implement the added methods in customCommentModel. - CommentModel interface { - commentModel - } - - customCommentModel struct { - *defaultCommentModel - } -) - -// NewCommentModel returns a model for the mongo. -func NewCommentModel(url, db, collection string, c cache.CacheConf) CommentModel { - conn := monc.MustNewModel(url, db, collection, c) - return &customCommentModel{ - defaultCommentModel: newDefaultCommentModel(conn), - } -} diff --git a/internal/model/mongo/comment_model_gen.go b/internal/model/mongo/comment_model_gen.go deleted file mode 100644 index 85b05dd..0000000 --- a/internal/model/mongo/comment_model_gen.go +++ /dev/null @@ -1,77 +0,0 @@ -// Code generated by goctl. DO NOT EDIT. -package model - -import ( - "context" - "time" - - "github.com/zeromicro/go-zero/core/stores/monc" - "go.mongodb.org/mongo-driver/bson" - "go.mongodb.org/mongo-driver/bson/primitive" - "go.mongodb.org/mongo-driver/mongo" -) - -var prefixCommentCacheKey = "cache:comment:" - -type commentModel interface { - Insert(ctx context.Context, data *Comment) error - FindOne(ctx context.Context, id string) (*Comment, error) - Update(ctx context.Context, data *Comment) (*mongo.UpdateResult, error) - Delete(ctx context.Context, id string) (int64, error) -} - -type defaultCommentModel struct { - conn *monc.Model -} - -func newDefaultCommentModel(conn *monc.Model) *defaultCommentModel { - return &defaultCommentModel{conn: conn} -} - -func (m *defaultCommentModel) Insert(ctx context.Context, data *Comment) error { - if data.ID.IsZero() { - data.ID = primitive.NewObjectID() - data.CreateAt = time.Now() - data.UpdateAt = time.Now() - } - - key := prefixCommentCacheKey + data.ID.Hex() - _, err := m.conn.InsertOne(ctx, key, data) - return err -} - -func (m *defaultCommentModel) FindOne(ctx context.Context, id string) (*Comment, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return nil, ErrInvalidObjectId - } - - var data Comment - key := prefixCommentCacheKey + id - err = m.conn.FindOne(ctx, key, &data, bson.M{"_id": oid}) - switch err { - case nil: - return &data, nil - case monc.ErrNotFound: - return nil, ErrNotFound - default: - return nil, err - } -} - -func (m *defaultCommentModel) Update(ctx context.Context, data *Comment) (*mongo.UpdateResult, error) { - data.UpdateAt = time.Now() - key := prefixCommentCacheKey + data.ID.Hex() - res, err := m.conn.UpdateOne(ctx, key, bson.M{"_id": data.ID}, bson.M{"$set": data}) - return res, err -} - -func (m *defaultCommentModel) Delete(ctx context.Context, id string) (int64, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return 0, ErrInvalidObjectId - } - key := prefixCommentCacheKey + id - res, err := m.conn.DeleteOne(ctx, key, bson.M{"_id": oid}) - return res, err -} diff --git a/internal/model/mongo/comment_types.go b/internal/model/mongo/comment_types.go deleted file mode 100644 index f82cabc..0000000 --- a/internal/model/mongo/comment_types.go +++ /dev/null @@ -1,14 +0,0 @@ -package model - -import ( - "time" - - "go.mongodb.org/mongo-driver/bson/primitive" -) - -type Comment struct { - ID primitive.ObjectID `bson:"_id,omitempty" json:"id,omitempty"` - // TODO: Fill your own fields - UpdateAt time.Time `bson:"updateAt,omitempty" json:"updateAt,omitempty"` - CreateAt time.Time `bson:"createAt,omitempty" json:"createAt,omitempty"` -} diff --git a/internal/model/mongo/error.go b/internal/model/mongo/error.go deleted file mode 100644 index 27d9244..0000000 --- a/internal/model/mongo/error.go +++ /dev/null @@ -1,12 +0,0 @@ -package model - -import ( - "errors" - - "github.com/zeromicro/go-zero/core/stores/mon" -) - -var ( - ErrNotFound = mon.ErrNotFound - ErrInvalidObjectId = errors.New("invalid objectId") -) diff --git a/internal/model/mongo/post_likes_model.go b/internal/model/mongo/post_likes_model.go deleted file mode 100644 index 9d1a52a..0000000 --- a/internal/model/mongo/post_likes_model.go +++ /dev/null @@ -1,25 +0,0 @@ -package model - -import "github.com/zeromicro/go-zero/core/stores/mon" - -var _ Post_likesModel = (*customPost_likesModel)(nil) - -type ( - // Post_likesModel is an interface to be customized, add more methods here, - // and implement the added methods in customPost_likesModel. - Post_likesModel interface { - post_likesModel - } - - customPost_likesModel struct { - *defaultPost_likesModel - } -) - -// NewPost_likesModel returns a model for the mongo. -func NewPost_likesModel(url, db, collection string) Post_likesModel { - conn := mon.MustNewModel(url, db, collection) - return &customPost_likesModel{ - defaultPost_likesModel: newDefaultPost_likesModel(conn), - } -} diff --git a/internal/model/mongo/post_likes_model_gen.go b/internal/model/mongo/post_likes_model_gen.go deleted file mode 100644 index e0499b7..0000000 --- a/internal/model/mongo/post_likes_model_gen.go +++ /dev/null @@ -1,74 +0,0 @@ -// Code generated by goctl. DO NOT EDIT. -package model - -import ( - "context" - "time" - - "github.com/zeromicro/go-zero/core/stores/mon" - "go.mongodb.org/mongo-driver/bson" - "go.mongodb.org/mongo-driver/bson/primitive" - "go.mongodb.org/mongo-driver/mongo" -) - -type post_likesModel interface { - Insert(ctx context.Context, data *Post_likes) error - FindOne(ctx context.Context, id string) (*Post_likes, error) - Update(ctx context.Context, data *Post_likes) (*mongo.UpdateResult, error) - Delete(ctx context.Context, id string) (int64, error) -} - -type defaultPost_likesModel struct { - conn *mon.Model -} - -func newDefaultPost_likesModel(conn *mon.Model) *defaultPost_likesModel { - return &defaultPost_likesModel{conn: conn} -} - -func (m *defaultPost_likesModel) Insert(ctx context.Context, data *Post_likes) error { - if data.ID.IsZero() { - data.ID = primitive.NewObjectID() - data.CreateAt = time.Now() - data.UpdateAt = time.Now() - } - - _, err := m.conn.InsertOne(ctx, data) - return err -} - -func (m *defaultPost_likesModel) FindOne(ctx context.Context, id string) (*Post_likes, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return nil, ErrInvalidObjectId - } - - var data Post_likes - - err = m.conn.FindOne(ctx, &data, bson.M{"_id": oid}) - switch err { - case nil: - return &data, nil - case mon.ErrNotFound: - return nil, ErrNotFound - default: - return nil, err - } -} - -func (m *defaultPost_likesModel) Update(ctx context.Context, data *Post_likes) (*mongo.UpdateResult, error) { - data.UpdateAt = time.Now() - - res, err := m.conn.UpdateOne(ctx, bson.M{"_id": data.ID}, bson.M{"$set": data}) - return res, err -} - -func (m *defaultPost_likesModel) Delete(ctx context.Context, id string) (int64, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return 0, ErrInvalidObjectId - } - - res, err := m.conn.DeleteOne(ctx, bson.M{"_id": oid}) - return res, err -} diff --git a/internal/model/mongo/post_likes_types.go b/internal/model/mongo/post_likes_types.go deleted file mode 100644 index 5b8f595..0000000 --- a/internal/model/mongo/post_likes_types.go +++ /dev/null @@ -1,14 +0,0 @@ -package model - -import ( - "time" - - "go.mongodb.org/mongo-driver/bson/primitive" -) - -type Post_likes struct { - ID primitive.ObjectID `bson:"_id,omitempty" json:"id,omitempty"` - // TODO: Fill your own fields - UpdateAt time.Time `bson:"updateAt,omitempty" json:"updateAt,omitempty"` - CreateAt time.Time `bson:"createAt,omitempty" json:"createAt,omitempty"` -} diff --git a/internal/model/mongo/post_model.go b/internal/model/mongo/post_model.go deleted file mode 100644 index 096dda8..0000000 --- a/internal/model/mongo/post_model.go +++ /dev/null @@ -1,28 +0,0 @@ -package model - -import ( - "github.com/zeromicro/go-zero/core/stores/cache" - "github.com/zeromicro/go-zero/core/stores/monc" -) - -var _ PostModel = (*customPostModel)(nil) - -type ( - // PostModel is an interface to be customized, add more methods here, - // and implement the added methods in customPostModel. - PostModel interface { - postModel - } - - customPostModel struct { - *defaultPostModel - } -) - -// NewPostModel returns a model for the mongo. -func NewPostModel(url, db, collection string, c cache.CacheConf) PostModel { - conn := monc.MustNewModel(url, db, collection, c) - return &customPostModel{ - defaultPostModel: newDefaultPostModel(conn), - } -} diff --git a/internal/model/mongo/post_model_gen.go b/internal/model/mongo/post_model_gen.go deleted file mode 100644 index c7aa965..0000000 --- a/internal/model/mongo/post_model_gen.go +++ /dev/null @@ -1,77 +0,0 @@ -// Code generated by goctl. DO NOT EDIT. -package model - -import ( - "context" - "time" - - "github.com/zeromicro/go-zero/core/stores/monc" - "go.mongodb.org/mongo-driver/bson" - "go.mongodb.org/mongo-driver/bson/primitive" - "go.mongodb.org/mongo-driver/mongo" -) - -var prefixPostCacheKey = "cache:post:" - -type postModel interface { - Insert(ctx context.Context, data *Post) error - FindOne(ctx context.Context, id string) (*Post, error) - Update(ctx context.Context, data *Post) (*mongo.UpdateResult, error) - Delete(ctx context.Context, id string) (int64, error) -} - -type defaultPostModel struct { - conn *monc.Model -} - -func newDefaultPostModel(conn *monc.Model) *defaultPostModel { - return &defaultPostModel{conn: conn} -} - -func (m *defaultPostModel) Insert(ctx context.Context, data *Post) error { - if data.ID.IsZero() { - data.ID = primitive.NewObjectID() - data.CreateAt = time.Now() - data.UpdateAt = time.Now() - } - - key := prefixPostCacheKey + data.ID.Hex() - _, err := m.conn.InsertOne(ctx, key, data) - return err -} - -func (m *defaultPostModel) FindOne(ctx context.Context, id string) (*Post, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return nil, ErrInvalidObjectId - } - - var data Post - key := prefixPostCacheKey + id - err = m.conn.FindOne(ctx, key, &data, bson.M{"_id": oid}) - switch err { - case nil: - return &data, nil - case monc.ErrNotFound: - return nil, ErrNotFound - default: - return nil, err - } -} - -func (m *defaultPostModel) Update(ctx context.Context, data *Post) (*mongo.UpdateResult, error) { - data.UpdateAt = time.Now() - key := prefixPostCacheKey + data.ID.Hex() - res, err := m.conn.UpdateOne(ctx, key, bson.M{"_id": data.ID}, bson.M{"$set": data}) - return res, err -} - -func (m *defaultPostModel) Delete(ctx context.Context, id string) (int64, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return 0, ErrInvalidObjectId - } - key := prefixPostCacheKey + id - res, err := m.conn.DeleteOne(ctx, key, bson.M{"_id": oid}) - return res, err -} diff --git a/internal/model/mongo/post_types.go b/internal/model/mongo/post_types.go deleted file mode 100644 index 1a5802f..0000000 --- a/internal/model/mongo/post_types.go +++ /dev/null @@ -1,14 +0,0 @@ -package model - -import ( - "time" - - "go.mongodb.org/mongo-driver/bson/primitive" -) - -type Post struct { - ID primitive.ObjectID `bson:"_id,omitempty" json:"id,omitempty"` - // TODO: Fill your own fields - UpdateAt time.Time `bson:"updateAt,omitempty" json:"updateAt,omitempty"` - CreateAt time.Time `bson:"createAt,omitempty" json:"createAt,omitempty"` -} diff --git a/internal/model/mongo/tags_model.go b/internal/model/mongo/tags_model.go deleted file mode 100644 index 6863721..0000000 --- a/internal/model/mongo/tags_model.go +++ /dev/null @@ -1,25 +0,0 @@ -package model - -import "github.com/zeromicro/go-zero/core/stores/mon" - -var _ TagsModel = (*customTagsModel)(nil) - -type ( - // TagsModel is an interface to be customized, add more methods here, - // and implement the added methods in customTagsModel. - TagsModel interface { - tagsModel - } - - customTagsModel struct { - *defaultTagsModel - } -) - -// NewTagsModel returns a model for the mongo. -func NewTagsModel(url, db, collection string) TagsModel { - conn := mon.MustNewModel(url, db, collection) - return &customTagsModel{ - defaultTagsModel: newDefaultTagsModel(conn), - } -} diff --git a/internal/model/mongo/tags_model_gen.go b/internal/model/mongo/tags_model_gen.go deleted file mode 100644 index db82d2b..0000000 --- a/internal/model/mongo/tags_model_gen.go +++ /dev/null @@ -1,74 +0,0 @@ -// Code generated by goctl. DO NOT EDIT. -package model - -import ( - "context" - "time" - - "github.com/zeromicro/go-zero/core/stores/mon" - "go.mongodb.org/mongo-driver/bson" - "go.mongodb.org/mongo-driver/bson/primitive" - "go.mongodb.org/mongo-driver/mongo" -) - -type tagsModel interface { - Insert(ctx context.Context, data *Tags) error - FindOne(ctx context.Context, id string) (*Tags, error) - Update(ctx context.Context, data *Tags) (*mongo.UpdateResult, error) - Delete(ctx context.Context, id string) (int64, error) -} - -type defaultTagsModel struct { - conn *mon.Model -} - -func newDefaultTagsModel(conn *mon.Model) *defaultTagsModel { - return &defaultTagsModel{conn: conn} -} - -func (m *defaultTagsModel) Insert(ctx context.Context, data *Tags) error { - if data.ID.IsZero() { - data.ID = primitive.NewObjectID() - data.CreateAt = time.Now() - data.UpdateAt = time.Now() - } - - _, err := m.conn.InsertOne(ctx, data) - return err -} - -func (m *defaultTagsModel) FindOne(ctx context.Context, id string) (*Tags, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return nil, ErrInvalidObjectId - } - - var data Tags - - err = m.conn.FindOne(ctx, &data, bson.M{"_id": oid}) - switch err { - case nil: - return &data, nil - case mon.ErrNotFound: - return nil, ErrNotFound - default: - return nil, err - } -} - -func (m *defaultTagsModel) Update(ctx context.Context, data *Tags) (*mongo.UpdateResult, error) { - data.UpdateAt = time.Now() - - res, err := m.conn.UpdateOne(ctx, bson.M{"_id": data.ID}, bson.M{"$set": data}) - return res, err -} - -func (m *defaultTagsModel) Delete(ctx context.Context, id string) (int64, error) { - oid, err := primitive.ObjectIDFromHex(id) - if err != nil { - return 0, ErrInvalidObjectId - } - - res, err := m.conn.DeleteOne(ctx, bson.M{"_id": oid}) - return res, err -} diff --git a/internal/model/mongo/tags_types.go b/internal/model/mongo/tags_types.go deleted file mode 100644 index 6972376..0000000 --- a/internal/model/mongo/tags_types.go +++ /dev/null @@ -1,14 +0,0 @@ -package model - -import ( - "time" - - "go.mongodb.org/mongo-driver/bson/primitive" -) - -type Tags struct { - ID primitive.ObjectID `bson:"_id,omitempty" json:"id,omitempty"` - // TODO: Fill your own fields - UpdateAt time.Time `bson:"updateAt,omitempty" json:"updateAt,omitempty"` - CreateAt time.Time `bson:"createAt,omitempty" json:"createAt,omitempty"` -} diff --git a/internal/server/commentservice/comment_service_server.go b/internal/server/commentservice/comment_service_server.go deleted file mode 100644 index 8e4eab8..0000000 --- a/internal/server/commentservice/comment_service_server.go +++ /dev/null @@ -1,71 +0,0 @@ -// Code generated by goctl. DO NOT EDIT. -// Source: tweeting.proto - -package server - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/logic/commentservice" - "app-cloudep-tweeting-service/internal/svc" -) - -type CommentServiceServer struct { - svcCtx *svc.ServiceContext - tweeting.UnimplementedCommentServiceServer -} - -func NewCommentServiceServer(svcCtx *svc.ServiceContext) *CommentServiceServer { - return &CommentServiceServer{ - svcCtx: svcCtx, - } -} - -// NewComment 發表評論 -func (s *CommentServiceServer) NewComment(ctx context.Context, in *tweeting.CommentPostReq) (*tweeting.OKResp, error) { - l := commentservicelogic.NewNewCommentLogic(ctx, s.svcCtx) - return l.NewComment(in) -} - -// GetComments 查詢評論 -func (s *CommentServiceServer) GetComments(ctx context.Context, in *tweeting.GetCommentsReq) (*tweeting.GetCommentsResp, error) { - l := commentservicelogic.NewGetCommentsLogic(ctx, s.svcCtx) - return l.GetComments(in) -} - -// DeleteComment 刪除評論 -func (s *CommentServiceServer) DeleteComment(ctx context.Context, in *tweeting.DeleteCommentReq) (*tweeting.OKResp, error) { - l := commentservicelogic.NewDeleteCommentLogic(ctx, s.svcCtx) - return l.DeleteComment(in) -} - -// UpdateComment 更新評論 -func (s *CommentServiceServer) UpdateComment(ctx context.Context, in *tweeting.UpdateCommentReq) (*tweeting.OKResp, error) { - l := commentservicelogic.NewUpdateCommentLogic(ctx, s.svcCtx) - return l.UpdateComment(in) -} - -// LikeComment 點讚/取消讚 評論 -func (s *CommentServiceServer) LikeComment(ctx context.Context, in *tweeting.LikeReq) (*tweeting.OKResp, error) { - l := commentservicelogic.NewLikeCommentLogic(ctx, s.svcCtx) - return l.LikeComment(in) -} - -// GetLikeStatus 取得讚/不讚評論狀態 -func (s *CommentServiceServer) GetLikeStatus(ctx context.Context, in *tweeting.LikeReq) (*tweeting.OKResp, error) { - l := commentservicelogic.NewGetLikeStatusLogic(ctx, s.svcCtx) - return l.GetLikeStatus(in) -} - -// LikeList 取得讚/不讚評論列表 -func (s *CommentServiceServer) LikeList(ctx context.Context, in *tweeting.LikeListReq) (*tweeting.LikeListResp, error) { - l := commentservicelogic.NewLikeListLogic(ctx, s.svcCtx) - return l.LikeList(in) -} - -// CountLike 取得讚/不讚評論數量 -func (s *CommentServiceServer) CountLike(ctx context.Context, in *tweeting.LikeCountReq) (*tweeting.LikeCountResp, error) { - l := commentservicelogic.NewCountLikeLogic(ctx, s.svcCtx) - return l.CountLike(in) -} diff --git a/internal/server/postservice/post_service_server.go b/internal/server/postservice/post_service_server.go deleted file mode 100644 index b5fdaad..0000000 --- a/internal/server/postservice/post_service_server.go +++ /dev/null @@ -1,71 +0,0 @@ -// Code generated by goctl. DO NOT EDIT. -// Source: tweeting.proto - -package server - -import ( - "context" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/logic/postservice" - "app-cloudep-tweeting-service/internal/svc" -) - -type PostServiceServer struct { - svcCtx *svc.ServiceContext - tweeting.UnimplementedPostServiceServer -} - -func NewPostServiceServer(svcCtx *svc.ServiceContext) *PostServiceServer { - return &PostServiceServer{ - svcCtx: svcCtx, - } -} - -// NewPost 新增貼文 -func (s *PostServiceServer) NewPost(ctx context.Context, in *tweeting.NewPostReq) (*tweeting.PostResp, error) { - l := postservicelogic.NewNewPostLogic(ctx, s.svcCtx) - return l.NewPost(in) -} - -// DeletePost 刪除貼文 -func (s *PostServiceServer) DeletePost(ctx context.Context, in *tweeting.DeletePostsReq) (*tweeting.OKResp, error) { - l := postservicelogic.NewDeletePostLogic(ctx, s.svcCtx) - return l.DeletePost(in) -} - -// UpdatePost 更新貼文 -func (s *PostServiceServer) UpdatePost(ctx context.Context, in *tweeting.UpdatePostReq) (*tweeting.OKResp, error) { - l := postservicelogic.NewUpdatePostLogic(ctx, s.svcCtx) - return l.UpdatePost(in) -} - -// ListPosts 查詢貼文 -func (s *PostServiceServer) ListPosts(ctx context.Context, in *tweeting.QueryPostsReq) (*tweeting.ListPostsResp, error) { - l := postservicelogic.NewListPostsLogic(ctx, s.svcCtx) - return l.ListPosts(in) -} - -// Like 點讚/取消讚 貼文 -func (s *PostServiceServer) Like(ctx context.Context, in *tweeting.LikeReq) (*tweeting.OKResp, error) { - l := postservicelogic.NewLikeLogic(ctx, s.svcCtx) - return l.Like(in) -} - -// GetLikeStatus 取得讚/不讚狀態 -func (s *PostServiceServer) GetLikeStatus(ctx context.Context, in *tweeting.LikeReq) (*tweeting.OKResp, error) { - l := postservicelogic.NewGetLikeStatusLogic(ctx, s.svcCtx) - return l.GetLikeStatus(in) -} - -// LikeList 取得讚/不讚列表 -func (s *PostServiceServer) LikeList(ctx context.Context, in *tweeting.LikeListReq) (*tweeting.LikeListResp, error) { - l := postservicelogic.NewLikeListLogic(ctx, s.svcCtx) - return l.LikeList(in) -} - -// CountLike 取得讚/不讚數量 -func (s *PostServiceServer) CountLike(ctx context.Context, in *tweeting.LikeCountReq) (*tweeting.LikeCountResp, error) { - l := postservicelogic.NewCountLikeLogic(ctx, s.svcCtx) - return l.CountLike(in) -} diff --git a/internal/svc/service_context.go b/internal/svc/service_context.go deleted file mode 100644 index 37ac177..0000000 --- a/internal/svc/service_context.go +++ /dev/null @@ -1,13 +0,0 @@ -package svc - -import "app-cloudep-tweeting-service/internal/config" - -type ServiceContext struct { - Config config.Config -} - -func NewServiceContext(c config.Config) *ServiceContext { - return &ServiceContext{ - Config: c, - } -} diff --git a/tweeting.go b/tweeting.go deleted file mode 100644 index 64e8540..0000000 --- a/tweeting.go +++ /dev/null @@ -1,41 +0,0 @@ -package main - -import ( - "flag" - "fmt" - - "app-cloudep-tweeting-service/gen_result/pb/tweeting" - "app-cloudep-tweeting-service/internal/config" - commentserviceServer "app-cloudep-tweeting-service/internal/server/commentservice" - postserviceServer "app-cloudep-tweeting-service/internal/server/postservice" - "app-cloudep-tweeting-service/internal/svc" - - "github.com/zeromicro/go-zero/core/conf" - "github.com/zeromicro/go-zero/core/service" - "github.com/zeromicro/go-zero/zrpc" - "google.golang.org/grpc" - "google.golang.org/grpc/reflection" -) - -var configFile = flag.String("f", "etc/tweeting.yaml", "the config file") - -func main() { - flag.Parse() - - var c config.Config - conf.MustLoad(*configFile, &c) - ctx := svc.NewServiceContext(c) - - s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) { - tweeting.RegisterPostServiceServer(grpcServer, postserviceServer.NewPostServiceServer(ctx)) - tweeting.RegisterCommentServiceServer(grpcServer, commentserviceServer.NewCommentServiceServer(ctx)) - - if c.Mode == service.DevMode || c.Mode == service.TestMode { - reflection.Register(grpcServer) - } - }) - defer s.Stop() - - fmt.Printf("Starting rpc server at %s...\n", c.ListenOn) - s.Start() -}