aboutsummaryrefslogtreecommitdiff
path: root/routes/node.go
blob: 2f5b7d36f2432666739fb22d05cd98f9b1c30544 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
package routes

import (
	"fmt"
	"net/http"
	"strconv"

	"github.com/labstack/echo/v4"
	"gitrepo.ru/neonxp/gorum/contextlib"
	"gitrepo.ru/neonxp/gorum/models"
	"gitrepo.ru/neonxp/gorum/utils"
	"gitrepo.ru/neonxp/gorum/views"
)

func (r *Router) Node(c echo.Context) error {
	sParentID := c.Param("id")
	parentID := 0
	var err error
	if sParentID != "" {
		parentID, err = strconv.Atoi(sParentID)
		if err != nil {
			return err
		}
	}

	node := &models.Node{
		ID:   0,
		Text: "Gorum",
	}
	if parentID > 0 {
		node, err = r.nodeRepo.Get(c.Request().Context(), parentID)
		if err != nil {
			return err
		}
	}

	nodes, err := r.nodeRepo.List(c.Request().Context(), parentID)
	if err != nil {
		return err
	}

	topics := make([]*models.Node, 0, len(nodes))
	posts := make([]*models.Node, 0, len(nodes))
	for _, n := range nodes {
		switch n.Type {
		case models.PostType:
			posts = append(posts, n)
		case models.TopicType:
			topics = append(topics, n)
		}
	}

	return utils.Render(c, views.Node(node, topics, posts))
}

func (r *Router) NewPost(c echo.Context) error {
	req := new(nodeRequest)
	if err := c.Bind(req); err != nil {
		return err
	}
	user := contextlib.GetUser(c.Request().Context())
	if user == nil {
		return echo.ErrForbidden
	}
	sParentID := c.Param("id")
	parentID, err := strconv.Atoi(sParentID)
	if err != nil {
		return err
	}

	if c.Request().Method == http.MethodPost {
		postID, err := r.nodeRepo.Create(c.Request().Context(), req.Type, req.Text, user.ID, parentID)
		if err != nil {
			return err
		}

		return c.Redirect(302, fmt.Sprintf("/t/%d#post%d", parentID, postID))
	}

	node, err := r.nodeRepo.Get(c.Request().Context(), parentID)
	if err != nil {
		return err
	}

	return utils.Render(c, views.NewPost(node))
}
func (r *Router) NewTopic(c echo.Context) error {
	req := new(nodeRequest)
	if err := c.Bind(req); err != nil {
		return err
	}
	user := contextlib.GetUser(c.Request().Context())
	if user == nil {
		return echo.ErrForbidden
	}
	sParentID := c.Param("id")
	parentID, err := strconv.Atoi(sParentID)
	if err != nil {
		return err
	}

	if c.Request().Method == http.MethodPost {
		postID, err := r.nodeRepo.Create(c.Request().Context(), req.Type, req.Text, user.ID, parentID)
		if err != nil {
			return err
		}

		return c.Redirect(302, fmt.Sprintf("/t/%d", postID))
	}

	node, err := r.nodeRepo.Get(c.Request().Context(), parentID)
	if err != nil {
		return err
	}

	return utils.Render(c, views.NewTopic(node))
}