make pages deployable

Author: kogai

contents/blogs/news/2020-11-25-新着入荷.md

@@ -0,0 +1,11 @@
+以下の書籍が入荷しました
+
+
+
+
+
+* [Language Implementation Patterns: Create Your Own Domain-Specific and General Programming Languages](https://k9bookshelf.com/products/language-implementation-patterns-create-your-own-domain-specific-and-general-programming-languages)
+* [Node.js Design Patterns - Third edition: Design and implement production-grade Node.js applications using proven patterns and techniques](https://k9bookshelf.com/products/node-js-design-patterns-third-edition-design-and-implement-production-grade-node-js-applications-using-proven-patterns-and-techniques)
+* [The Maker's Guide to the Zombie Apocalypse: Defend Your Base with Simple Circuits, Arduino, and Raspberry Pi](https://k9bookshelf.com/products/the-makers-guide-to-the-zombie-apocalypse-defend-your-base-with-simple-circuits-arduino-and-raspberry-pi)
+* [Programming Webassembly with Rust: Unified Development for Web, Mobile, and Embedded Applications (1ST ed.)](https://k9bookshelf.com/products/programming-webassembly-with-rust)
+

contents/blogs/news/新着入荷.md

@@ -1,2 +1 @@
 k9bookshelfに関するお問い合わせはこちらからお願いいたします。
-

contents/pages/contact.md

@@ -4,10 +4,12 @@ import (
 	"fmt"
 	"io/ioutil"
 	"k9bookshelf/generated"
+	"os"
 	"path"
 	"path/filepath"
 	"sync"
 
+	shopify "github.com/bold-commerce/go-shopify"
 	"github.com/gomarkdown/markdown"
 	"github.com/vbauerster/mpb"
 	"github.com/vbauerster/mpb/decor"
@@ -61,51 +63,148 @@ func deployProducts(contents []Content, bar *mpb.Bar) error {
 	return err
 }
 
-// Deploy uploads contents to store
-func Deploy(input string) error {
-	rawProducts, err := ioutil.ReadDir(path.Join(input, "products"))
-	if err != nil {
-		return err
+func deployPages(contents []Content, bar *mpb.Bar) error {
+	var err error
+	adminClient := establishRestClient()
+	wg := sync.WaitGroup{}
+	c := make(chan error)
+	for _, content := range contents {
+		wg.Add(1)
+
+		go func(handle, html string) {
+			defer wg.Done()
+			defer bar.Increment()
+
+			pages, err := adminClient.Page.List(nil)
+			if err != nil {
+				c <- err
+				return
+			}
+			var page shopify.Page
+			for _, p := range pages {
+				if p.Handle == handle {
+					page = p
+					break
+				}
+			}
+
+			// NOTE: Because Page struct isn't tagged by `omitempty` and Metafields are initialized with nil,
+			metafields := []shopify.Metafield{}
+			if page.Metafields != nil {
+				metafields = page.Metafields
+			}
+			_, err = adminClient.Page.Update(shopify.Page{
+				ID:             page.ID,
+				Author:         page.Author,
+				Handle:         handle,
+				Title:          page.Title,
+				CreatedAt:      page.CreatedAt,
+				UpdatedAt:      page.UpdatedAt,
+				BodyHTML:       html,
+				TemplateSuffix: page.TemplateSuffix,
+				PublishedAt:    page.PublishedAt,
+				ShopID:         page.ShopID,
+				Metafields:     metafields,
+			})
+
+			if err != nil {
+				c <- err
+				return
+			}
+		}(content.handle, content.html)
 	}
-	products := []Content{}
-	for _, file := range rawProducts {
+	go func() {
+		wg.Wait()
+		c <- nil
+	}()
+
+	err = <-c
+	return err
+}
+
+func filesToContents(inputDir string, files []os.FileInfo) ([]Content, error) {
+	contents := []Content{}
+	for _, file := range files {
 		filename := file.Name()
 		handle := filename[0 : len(filename)-len(filepath.Ext(filename))]
-		md, err := ioutil.ReadFile(path.Join(input, "products", filename))
+		md, err := ioutil.ReadFile(path.Join(inputDir, filename))
 		if err != nil {
-			return err
+			return nil, err
 		}
 		html := string(markdown.ToHTML(md, nil, nil))
-		products = append(products, Content{
+		contents = append(contents, Content{
 			handle: handle,
 			html:   html,
 		})
 	}
+	return contents, nil
+}
 
-	// pages, err := ioutil.ReadDir(path.Join(input, "pages"))
-	// if err != nil {
-	// 	return err
-	// }
+type tmpIterable struct {
+	f        func(contents []Content, bar *mpb.Bar) error
+	contents []Content
+}
 
-	wg := sync.WaitGroup{}
-	p := mpb.New(mpb.WithWaitGroup(&wg))
-	bar := p.AddBar(int64(len(products)),
-		mpb.PrependDecorators(
-			decor.Name(path.Join(input, "products")),
-			decor.Percentage(decor.WCSyncSpace),
-		),
-		mpb.AppendDecorators(
-			decor.OnComplete(
-				decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
-			),
-		),
-	)
+// Deploy uploads contents to store
+func Deploy(input string) error {
+	rawProducts, err := ioutil.ReadDir(path.Join(input, "products"))
+	if err != nil {
+		return err
+	}
+	products, err := filesToContents(path.Join(input, "products"), rawProducts)
+	if err != nil {
+		return err
+	}
 
-	err = deployProducts(products, bar)
+	rawPages, err := ioutil.ReadDir(path.Join(input, "pages"))
 	if err != nil {
 		return err
 	}
+	pages, err := filesToContents(path.Join(input, "pages"), rawPages)
 
-	p.Wait()
-	return nil
+	wg := sync.WaitGroup{}
+	p := mpb.New(mpb.WithWaitGroup(&wg))
+
+	c := make(chan error)
+	for name, _f := range map[string]tmpIterable{
+		"products": {
+			f: func(contents []Content, bar *mpb.Bar) error {
+				return deployProducts(products, bar)
+			},
+			contents: products,
+		},
+		"pages": {
+			f: func(contents []Content, bar *mpb.Bar) error {
+				return deployPages(pages, bar)
+			},
+			contents: pages,
+		},
+	} {
+		wg.Add(1)
+		bar := p.AddBar(int64(len(_f.contents)),
+			mpb.PrependDecorators(
+				decor.Name(path.Join(input, name)),
+				decor.Percentage(decor.WCSyncSpace),
+			),
+			mpb.AppendDecorators(
+				decor.OnComplete(
+					decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
+				),
+			),
+		)
+		go func(f func(contents []Content, bar *mpb.Bar) error) {
+			defer wg.Done()
+			if err = f(pages, bar); err != nil {
+				c <- err
+				return
+			}
+		}(_f.f)
+	}
+	go func() {
+		p.Wait()
+		c <- nil
+	}()
+
+	err = <-c
+	return err
 }