Minimise code
This commit is contained in:
parent
b1165a6180
commit
b3998e369e
1 changed files with 4 additions and 7 deletions
|
@ -180,29 +180,26 @@ func routes(s *fibre.Fibre) {
|
||||||
},
|
},
|
||||||
}).PathIs("/sql"))
|
}).PathIs("/sql"))
|
||||||
|
|
||||||
s.Get("/sql", func(c *fibre.Context) error {
|
// --------------------------------------------------
|
||||||
|
// Endpoints for submitting websocket sql
|
||||||
|
// --------------------------------------------------
|
||||||
|
|
||||||
|
s.Get("/sql", func(c *fibre.Context) error {
|
||||||
if err := c.Upgrade(); err != nil {
|
if err := c.Upgrade(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
for {
|
for {
|
||||||
|
|
||||||
_, msg, err := c.Socket().Read()
|
_, msg, err := c.Socket().Read()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
if res, err := db.Execute(c, msg, nil); err != nil {
|
if res, err := db.Execute(c, msg, nil); err != nil {
|
||||||
c.Socket().SendText(err.Error())
|
c.Socket().SendText(err.Error())
|
||||||
} else {
|
} else {
|
||||||
c.Socket().SendJSON(res)
|
c.Socket().SendJSON(res)
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|
||||||
})
|
})
|
||||||
|
|
||||||
// --------------------------------------------------
|
// --------------------------------------------------
|
||||||
|
|
Loading…
Reference in a new issue