menu crud operations

.github/workflows/test.yml

@@ -4,10 +4,9 @@
 name: Run unit Tests
 
 on:
-  push:
-    branches: ['main', 'develop']
   pull_request:
-    branches: ['main', 'develop']
+    paths:
+      - 'app/**'
 
 jobs:
   test:

app/domain/city_domain_test.go

@@ -0,0 +1,51 @@
+package domain
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestNewCity(t *testing.T) {
+
+	type input struct {
+		cityCode       int32
+		cityName       string
+		prefectureCode int32
+		prefectureName string
+	}
+	testCases := []struct {
+		name       string
+		createStub func() input
+		check      func(*City, error)
+	}{
+		{
+			name: "OK",
+			createStub: func() input {
+				return input{
+					cityCode:       1,
+					cityName:       "cityName",
+					prefectureCode: 1,
+					prefectureName: "prefectureName",
+				}
+			},
+			check: func(c *City, err error) {
+				require.NoError(t, err)
+				require.NotNil(t, c)
+				require.Equal(t, int32(1), c.CityCode)
+				require.Equal(t, "cityName", c.CityName)
+				require.Equal(t, int32(1), c.PrefectureCode)
+				require.Equal(t, "prefectureName", c.PrefectureName)
+			},
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			input := tc.createStub()
+			c := NewCity(input.cityCode, input.cityName, input.prefectureCode, input.prefectureName)
+			tc.check(c, nil)
+		})
+	}
+
+}

app/domain/common.go

@@ -1,5 +1,7 @@
 package domain
 
+import "time"
+
 const (
 	DEFAULT_LIMIT  = int32(10)
 	DEFAULT_OFFSET = int32(0)
@@ -9,8 +11,20 @@ type Response struct {
 	Data interface{} `json:"data"`
 }
 
+type FetchResponse struct {
+	Data interface{} `json:"data"`
+	Next interface{} `json:"next"`
+}
+
 func NewResponse(data interface{}) *Response {
 	return &Response{
 		Data: data,
 	}
 }
+
+func NewFetchResponse[T string | int32 | time.Time](data interface{}, next T) *FetchResponse {
+	return &FetchResponse{
+		Data: data,
+		Next: next,
+	}
+}

app/domain/common_test.go

@@ -0,0 +1,36 @@
+package domain
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestNewResponse(t *testing.T) {
+
+	testCases := []struct {
+		name       string
+		createStub func() interface{}
+		check      func(*Response)
+	}{
+		{
+			name: "OK",
+			createStub: func() interface{} {
+				return "data"
+			},
+			check: func(r *Response) {
+				require.NotNil(t, r)
+				require.Equal(t, "data", r.Data)
+			},
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			data := tc.createStub()
+			r := NewResponse(data)
+			tc.check(r)
+		})
+	}
+
+}

app/domain/dish_domain.go

@@ -2,6 +2,7 @@ package domain
 
 import (
 	"context"
+	"encoding/json"
 
 	"github.com/ogurilab/school-lunch-api/util"
 )
@@ -48,3 +49,15 @@ func NewDish(menuID string, name string) (*Dish, error) {
 
 	return newDish(id, menuID, name)
 }
+
+func NewDishesFromJson(
+	input json.RawMessage,
+) ([]*Dish, error) {
+	var dishes []*Dish
+
+	if err := json.Unmarshal(input, &dishes); err != nil {
+		return nil, err
+	}
+
+	return dishes, nil
+}

app/domain/dish_domain_test.go

@@ -0,0 +1,146 @@
+package domain
+
+import (
+	"encoding/json"
+	"fmt"
+	"testing"
+
+	"github.com/ogurilab/school-lunch-api/util"
+	"github.com/stretchr/testify/require"
+)
+
+func TestNewDish(t *testing.T) {
+
+	testCases := []struct {
+		name     string
+		menuID   string
+		dishName string
+		check    func(*Dish, error)
+	}{
+		{
+			name:     "OK",
+			menuID:   "dish1",
+			dishName: "dish1",
+			check: func(dish *Dish, err error) {
+				require.NoError(t, err)
+				require.NotNil(t, dish)
+				require.Equal(t, "dish1", dish.MenuID)
+				require.Equal(t, "dish1", dish.Name)
+				require.NotEmpty(t, dish.ID)
+			},
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			dish, err := NewDish(tc.menuID, tc.dishName)
+			tc.check(dish, err)
+		})
+	}
+
+}
+
+func TestReNewDish(t *testing.T) {
+	id := util.NewUlid()
+	testCases := []struct {
+		name     string
+		id       string
+		menuID   string
+		dishName string
+		check    func(*Dish, error)
+	}{
+		{
+			name:     "OK",
+			id:       id,
+			menuID:   "dish1",
+			dishName: "dish1",
+			check: func(dish *Dish, err error) {
+				require.NoError(t, err)
+				require.NotNil(t, dish)
+				require.Equal(t, "dish1", dish.MenuID)
+				require.Equal(t, "dish1", dish.Name)
+				require.Equal(t, id, dish.ID)
+			},
+		},
+
+		{
+			name:     "Invalid Ulid",
+			id:       "invalid",
+			menuID:   "dish1",
+			dishName: "dish1",
+			check: func(dish *Dish, err error) {
+				require.Error(t, err)
+				require.Nil(t, dish)
+			},
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			dish, err := ReNewDish(tc.id, tc.menuID, tc.dishName)
+			tc.check(dish, err)
+		})
+	}
+}
+
+func TestNewDishesFromJson(t *testing.T) {
+	id := util.NewUlid()
+	testCases := []struct {
+		name        string
+		createStubs func() json.RawMessage
+		check       func([]*Dish, error)
+	}{
+		{
+			name: "OK",
+			createStubs: func() json.RawMessage {
+				data := fmt.Sprintf(`[{"id": "%s", "menu_id": "menu1", "name": "dish1"}]`, id)
+
+				return json.RawMessage(data)
+			},
+			check: func(dishes []*Dish, err error) {
+				require.NoError(t, err)
+				require.NotNil(t, dishes)
+				require.Len(t, dishes, 1)
+				require.Equal(t, "menu1", dishes[0].MenuID)
+				require.Equal(t, "dish1", dishes[0].Name)
+				require.Equal(t, id, dishes[0].ID)
+			},
+		},
+
+		{
+			name: "Multiple Dishes",
+			createStubs: func() json.RawMessage {
+				data := fmt.Sprintf(`[{"id": "%s", "menu_id": "menu1", "name": "dish1"},{"id": "%s", "menu_id": "menu1", "name": "dish2"}]`, id, id)
+
+				return json.RawMessage(data)
+
+			},
+			check: func(dishes []*Dish, err error) {
+				require.NoError(t, err)
+				require.NotNil(t, dishes)
+				require.Len(t, dishes, 2)
+			},
+		},
+		{
+			name: "Invalid JSON",
+			createStubs: func() json.RawMessage {
+				data := fmt.Sprintf(`[{"id": "%s", "menu_id": "menu1", "name": "dish1"}`, id)
+
+				return json.RawMessage(data)
+			},
+			check: func(dishes []*Dish, err error) {
+				require.Error(t, err)
+				require.Nil(t, dishes)
+			},
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			stub := tc.createStubs()
+			dishes, err := NewDishesFromJson(stub)
+			tc.check(dishes, err)
+		})
+
+	}
+}