Impl ListEntries

Author: gedorinku

api/entries.pb.go

@@ -49,6 +49,21 @@
     }
   },
   "definitions": {
+    "prolab_accountsBlog": {
+      "type": "object",
+      "properties": {
+        "blog_id": {
+          "type": "integer",
+          "format": "int64"
+        },
+        "url": {
+          "type": "string"
+        },
+        "feed_url": {
+          "type": "string"
+        }
+      }
+    },
     "prolab_accountsEntry": {
       "type": "object",
       "properties": {
@@ -81,6 +96,9 @@
         "updated_at": {
           "type": "string",
           "format": "date-time"
+        },
+        "blog": {
+          "$ref": "#/definitions/prolab_accountsBlog"
         }
       }
     },

api/entries.swagger.json

@@ -10,6 +10,7 @@ import "google/api/annotations.proto";
 import "google/protobuf/empty.proto";
 import "google/protobuf/timestamp.proto";
 
+import "user_blogs.proto";
 import "users.proto";
 
 service EntryService {
@@ -30,6 +31,7 @@ message Entry {
   string image_url = 7;
   google.protobuf.Timestamp published_at = 8;
   google.protobuf.Timestamp updated_at = 9;
+  Blog blog = 10;
 }
 
 message ListEntriesRequest {

api/entries.validator.pb.go

@@ -55,6 +55,7 @@ func Run() error {
 			server.NewUserServiceServer(store, cfg),
 			server.NewOAuthServiceServer(cli, store),
 			server.NewUserBlogServiceServer(store),
+			server.NewEntryServiceServer(store, cfg),
 			server.NewPingServiceServer(store),
 		),
 	)

api/protos/entries.proto

@@ -2,12 +2,17 @@ package server
 
 import (
 	"context"
+	"database/sql"
+	"time"
 
+	"github.com/golang/protobuf/ptypes/timestamp"
 	"github.com/izumin5210/grapi/pkg/grapiserver"
-	"google.golang.org/grpc/codes"
-	"google.golang.org/grpc/status"
+	"github.com/pkg/errors"
 
 	api_pb "github.com/ProgrammingLab/prolab-accounts/api"
+	"github.com/ProgrammingLab/prolab-accounts/app/config"
+	"github.com/ProgrammingLab/prolab-accounts/app/di"
+	"github.com/ProgrammingLab/prolab-accounts/infra/record"
 )
 
 // EntryServiceServer is a composite interface of api_pb.EntryServiceServer and grapiserver.Server.
@@ -17,14 +22,68 @@ type EntryServiceServer interface {
 }
 
 // NewEntryServiceServer creates a new EntryServiceServer instance.
-func NewEntryServiceServer() EntryServiceServer {
-	return &entryServiceServerImpl{}
+func NewEntryServiceServer(store di.StoreComponent, cfg *config.Config) EntryServiceServer {
+	return &entryServiceServerImpl{
+		StoreComponent: store,
+		cfg:            cfg,
+	}
 }
 
 type entryServiceServerImpl struct {
+	di.StoreComponent
+	cfg *config.Config
 }
 
 func (s *entryServiceServerImpl) ListEntries(ctx context.Context, req *api_pb.ListEntriesRequest) (*api_pb.ListEntriesResponse, error) {
-	// TODO: Not yet implemented.
-	return nil, status.Error(codes.Unimplemented, "TODO: You should implement it!")
+	es := s.EntryStore(ctx)
+	entries, err := es.ListPublicEntries()
+	if err != nil {
+		if errors.Cause(err) == sql.ErrNoRows {
+			return &api_pb.ListEntriesResponse{}, nil
+		}
+		return nil, err
+	}
+
+	resp := entriesToResponse(entries, false, s.cfg)
+	return &api_pb.ListEntriesResponse{
+		Entries: resp,
+	}, nil
+}
+
+func entriesToResponse(entries []*record.Entry, includeEmail bool, cfg *config.Config) []*api_pb.Entry {
+	res := make([]*api_pb.Entry, 0, len(entries))
+	for _, e := range entries {
+		res = append(res, entryToResponse(e, includeEmail, cfg))
+	}
+
+	return res
+}
+
+func entryToResponse(entry *record.Entry, includeEmail bool, cfg *config.Config) *api_pb.Entry {
+	e := &api_pb.Entry{
+		EntryId:     uint32(entry.ID),
+		Title:       entry.Title,
+		Description: entry.Description,
+		Content:     entry.Content,
+		Link:        entry.Link,
+		ImageUrl:    entry.ImageURL,
+		UpdatedAt:   timeToResponse(entry.UpdatedAt),
+	}
+	if t := entry.PublishedAt; t.Valid {
+		e.PublishedAt = timeToResponse(t.Time)
+	}
+	if r := entry.R; r != nil {
+		e.Author = userToResponse(r.Author, includeEmail, cfg)
+		e.Blog = blogToResponse(r.Blog)
+	}
+
+	return e
+}
+
+func timeToResponse(t time.Time) *timestamp.Timestamp {
+	t = t.UTC()
+	return &timestamp.Timestamp{
+		Seconds: t.Unix(),
+		Nanos:   int32(t.Nanosecond()),
+	}
 }

api/users.validator.pb.go

@@ -167,6 +167,10 @@ func getFeedURL(ctx context.Context, s di.StoreComponent, req blogRequest) (stri
 }
 
 func blogToResponse(blog *record.Blog) *api_pb.Blog {
+	if blog == nil {
+		return nil
+	}
+
 	return &api_pb.Blog{
 		BlogId:  uint32(blog.ID),
 		Url:     blog.URL,

app/run.go

@@ -186,6 +186,10 @@ func usersToResponse(users []*record.User, includeEmail bool, cfg *config.Config
 }
 
 func userToResponse(user *record.User, includeEmail bool, cfg *config.Config) *api_pb.User {
+	if user == nil {
+		return nil
+	}
+
 	var email string
 	if includeEmail {
 		email = user.Email

app/server/entries_server.go

@@ -16,6 +16,7 @@ import (
 	"github.com/ProgrammingLab/prolab-accounts/app/util"
 	"github.com/ProgrammingLab/prolab-accounts/infra/record"
 	"github.com/ProgrammingLab/prolab-accounts/infra/store"
+	"github.com/ProgrammingLab/prolab-accounts/model"
 )
 
 type entryStoreImpl struct {
@@ -31,6 +32,22 @@ func NewEntryStore(ctx context.Context, db *sql.DB) store.EntryStore {
 	}
 }
 
+func (s *entryStoreImpl) ListPublicEntries() ([]*record.Entry, error) {
+	mods := []qm.QueryMod{
+		qm.Load(record.EntryRels.Author),
+		qm.Load(record.EntryRels.Blog),
+		qm.InnerJoin("users on users.id = entries.author_id"),
+		qm.InnerJoin("profiles on profiles.id = users.profile_id"),
+		qm.Where("profiles.profile_scope = ?", model.Public),
+	}
+
+	e, err := record.Entries(mods...).All(s.ctx, s.db)
+	if err != nil {
+		return nil, errors.WithStack(err)
+	}
+	return e, nil
+}
+
 func (s *entryStoreImpl) CreateEntries(blog *record.Blog, feed *gofeed.Feed) (n int64, err error) {
 	tx, err := s.db.Begin()
 	if err != nil {

app/server/user_blogs_server.go

@@ -7,5 +7,6 @@ import (
 
 // EntryStore accesses entry data
 type EntryStore interface {
+	ListPublicEntries() ([]*record.Entry, error)
 	CreateEntries(blog *record.Blog, feed *gofeed.Feed) (int64, error)
 }