PostComment service

Author: Onur Menal

build/Dockerfile Dockerfile

@@ -27,10 +27,12 @@ func Run() error {
 	}
 
 	cmtService := comment.NewService(db)
-	fmt.Println(cmtService.GetComment(
-		context.Background(),
-		"904a8e95-b6a0-4f80-9142-5cf0a5895d25",
-	))
+
+	fmt.Println(cmtService.PostComment(context.Background(), comment.Comment{
+		Slug:   "testslug",
+		Body:   "testbody",
+		Author: "onur menal",
+	}))
 
 	fmt.Println("Successfully connected and pinged database")
 

build/Taskfile.yml Taskfile.yml

@@ -7,4 +7,5 @@ require (
 	github.com/google/go-github/v35 v35.2.0 // indirect
 	github.com/jmoiron/sqlx v1.3.5 // indirect
 	github.com/lib/pq v1.10.6 // indirect
+	github.com/satori/go.uuid v1.2.0 // indirect
 )

cmd/server/main.go

@@ -946,6 +946,7 @@ github.com/ruudk/golang-pdf417 v0.0.0-20181029194003-1af4ab5afa58/go.mod h1:6lfF
 github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
 github.com/safchain/ethtool v0.0.0-20190326074333-42ed695e3de8/go.mod h1:Z0q5wiBQGYcxhMZ6gUqHn6pYNLypFAvaL3UvgZLR0U4=
 github.com/safchain/ethtool v0.0.0-20210803160452-9aa261dae9b1/go.mod h1:Z0q5wiBQGYcxhMZ6gUqHn6pYNLypFAvaL3UvgZLR0U4=
+github.com/satori/go.uuid v1.2.0 h1:0uYX9dsZ2yD7q2RtLRtPSdGDWzjeM3TbMJP9utgA0ww=
 github.com/satori/go.uuid v1.2.0/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0=
 github.com/sclevine/agouti v3.0.0+incompatible/go.mod h1:b4WX9W9L1sfQKXeJf1mUTLZKJ48R1S7H23Ji7oFO5Bw=
 github.com/sclevine/spec v1.2.0/go.mod h1:W4J29eT/Kzv7/b9IWLB055Z+qvVC9vt0Arko24q7p+U=

go.mod

@@ -20,6 +20,7 @@ type Comment struct {
 
 type Store interface {
 	GetComment(context.Context, string) (Comment, error)
+	PostComment(context.Context, Comment) (Comment, error)
 }
 
 type Service struct {
@@ -46,10 +47,15 @@ func (s *Service) UpdateComment(ctx context.Context, cmt Comment) error {
 	return ErrorNotImplemented
 }
 
-func (*Service) DeleteCommment(ctx context.Context, id string) error {
+func (s *Service) DeleteCommment(ctx context.Context, id string) error {
 	return ErrorNotImplemented
 }
 
-func (*Service) CreateComment(ctx context.Context, cmt Comment) (Comment, error) {
-	return Comment{}, ErrorNotImplemented
+func (s *Service) PostComment(ctx context.Context, cmt Comment) (Comment, error) {
+	fmt.Println("posting a comment")
+	insertedComment, err := s.Store.PostComment(ctx, cmt)
+	if err != nil {
+		return Comment{}, ErrorMessage
+	}
+	return insertedComment, nil
 }

go.sum

@@ -6,6 +6,7 @@ import (
 	"fmt"
 
 	"github.com/onurmenal/go-rest-api/internal/comment"
+	uuid "github.com/satori/go.uuid"
 )
 
 type CommentRow struct {
@@ -44,3 +45,30 @@ func (d *Database) GetComment(
 
 	return convertCommentRowToComment(cmtRow), nil
 }
+
+func (d *Database) PostComment(ctx context.Context, cmt comment.Comment) (comment.Comment, error) {
+	cmt.ID = uuid.NewV4().String()
+	postRow := CommentRow{
+		ID:     cmt.ID,
+		Slug:   sql.NullString{String: cmt.Slug, Valid: true},
+		Author: sql.NullString{String: cmt.Author, Valid: true},
+		Body:   sql.NullString{String: cmt.Body, Valid: true},
+	}
+
+	rows, err := d.Client.NamedQueryContext(
+		ctx,
+		`INSERT INTO comments
+		(id,slug,author,body)
+		VALUES
+		(:id, :slug, :author, :body)`,
+		postRow,
+	)
+	if err != nil {
+		return comment.Comment{}, fmt.Errorf("failed to insert comment: %w", err)
+	}
+	if err := rows.Close(); err != nil {
+		return comment.Comment{}, fmt.Errorf("failed to close rows: %w", err)
+	}
+
+	return cmt, nil
+}