A bit more cleanup into an api to use before testing out authentication.
This commit is contained in:
parent
55f59d88b6
commit
8c04bffa5d
2 changed files with 15 additions and 7 deletions
11
main.go
11
main.go
|
|
@ -58,8 +58,7 @@ func main() {
|
||||||
})
|
})
|
||||||
|
|
||||||
app.Post("/api/link", func (c *fiber.Ctx) error {
|
app.Post("/api/link", func (c *fiber.Ctx) error {
|
||||||
link, err := tools.GetThing[Link](c)
|
link, err := tools.ReceivePost[Link](c)
|
||||||
|
|
||||||
if(err != nil) {
|
if(err != nil) {
|
||||||
log.Println(err)
|
log.Println(err)
|
||||||
c.Redirect("/live/")
|
c.Redirect("/live/")
|
||||||
|
|
@ -67,14 +66,14 @@ func main() {
|
||||||
|
|
||||||
sql, args, err := sq.Insert("stream_link").Columns("stream_id", "url", "description").Values(link.StreamId, link.Url, link.Description).ToSql()
|
sql, args, err := sq.Insert("stream_link").Columns("stream_id", "url", "description").Values(link.StreamId, link.Url, link.Description).ToSql()
|
||||||
|
|
||||||
|
err = tools.Insert(db, err, sql, args...)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println(err)
|
log.Println(err)
|
||||||
|
c.Redirect("/live/")
|
||||||
|
} else {
|
||||||
return c.Redirect("/live/")
|
return c.Redirect("/live/")
|
||||||
}
|
}
|
||||||
|
|
||||||
db.MustExec(sql, args...)
|
|
||||||
|
|
||||||
return c.Redirect("/live/")
|
|
||||||
})
|
})
|
||||||
|
|
||||||
app.Static("/", "./public")
|
app.Static("/", "./public")
|
||||||
|
|
|
||||||
|
|
@ -37,7 +37,7 @@ func GetJson[T any](db *sqlx.DB, c *fiber.Ctx, err error, sql string, args ...in
|
||||||
return c.JSON(&result);
|
return c.JSON(&result);
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetThing[T any](c *fiber.Ctx) (*T, error) {
|
func ReceivePost[T any](c *fiber.Ctx) (*T, error) {
|
||||||
var result *T
|
var result *T
|
||||||
result = new(T)
|
result = new(T)
|
||||||
|
|
||||||
|
|
@ -57,3 +57,12 @@ func GetThing[T any](c *fiber.Ctx) (*T, error) {
|
||||||
|
|
||||||
return result, nil
|
return result, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func Insert(db *sqlx.DB, err error, sql string, args ...interface{}) error {
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
return db.MustExec(sql, args...)
|
||||||
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue