diff --git a/database/seeds/fillTables.go b/database/seeds/product_categories.go similarity index 56% rename from database/seeds/fillTables.go rename to database/seeds/product_categories.go index d5e6e87..6e2da38 100644 --- a/database/seeds/fillTables.go +++ b/database/seeds/product_categories.go @@ -3,23 +3,10 @@ package seeds import ( "log" "online-order/entity" - repository_product "online-order/repository/product" repository_product_category "online-order/repository/product_category" - service_product "online-order/usecase/product" service_product_category "online-order/usecase/product_category" ) -func fetchProductsFromJsonFile() *[]entity.ProductCreateUpdate { - file := CreateFile("database/seeds/resources/products.json") - pl := []entity.ProductCreateUpdate{} - - if err := file.ReadJson(&pl); err != nil { - log.Println("on FillProducts an error occured: ", err) - return nil - } - return &pl -} - func fetchProductCategoriesFromJsonFile() *[]entity.ProductCategoryCreateUpdate { file := CreateFile("database/seeds/resources/categories.json") pl := []entity.ProductCategoryCreateUpdate{} @@ -47,21 +34,3 @@ func FillProductCategories(server *entity.Routers) { productCategoryService.SyncWithSlug(item.Slug, &item) } } - -func FillProducts(server *entity.Routers) { - products := fetchProductsFromJsonFile() - - activeBusiness := entity.ActiveBusiness{ - BusinessID: 1, - DomainID: 1, - Domain: "localhost", - } - - productRepo := repository_product.NewProductRepository(server.Database, &activeBusiness) - - productService := service_product.NewProductService(productRepo) - - for _, item := range *products { - productService.Create(&item) - } -} diff --git a/database/seeds/products.go b/database/seeds/products.go new file mode 100644 index 0000000..8d53925 --- /dev/null +++ b/database/seeds/products.go @@ -0,0 +1,37 @@ +package seeds + +import ( + "log" + "online-order/entity" + repository_product "online-order/repository/product" + service_product "online-order/usecase/product" +) + +func fetchProductsFromJsonFile() *[]entity.ProductCreateUpdate { + file := CreateFile("database/seeds/resources/products.json") + pl := []entity.ProductCreateUpdate{} + + if err := file.ReadJson(&pl); err != nil { + log.Println("on FillProducts an error occured: ", err) + return nil + } + return &pl +} + +func FillProducts(server *entity.Routers) { + products := fetchProductsFromJsonFile() + + activeBusiness := entity.ActiveBusiness{ + BusinessID: 1, + DomainID: 1, + Domain: "localhost", + } + + productRepo := repository_product.NewProductRepository(server.Database, &activeBusiness) + + productService := service_product.NewProductService(productRepo) + + for _, item := range *products { + productService.Create(&item) + } +}