mirror of
https://github.com/nkanaev/yarr.git
synced 2025-05-24 00:33:14 +00:00
Run go fmt
This patch is the result of running `go fmt ./...` with Go v1.16.15.
This commit is contained in:
parent
2a5692d9a7
commit
c1bcc0c517
@ -7,9 +7,9 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func TestSniff(t *testing.T) {
|
func TestSniff(t *testing.T) {
|
||||||
testcases := []struct{
|
testcases := []struct {
|
||||||
input string
|
input string
|
||||||
want feedProbe
|
want feedProbe
|
||||||
}{
|
}{
|
||||||
{
|
{
|
||||||
`<?xml version="1.0"?><rdf:RDF xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"></rdf:RDF>`,
|
`<?xml version="1.0"?><rdf:RDF xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"></rdf:RDF>`,
|
||||||
|
@ -32,9 +32,9 @@ func (r *Router) Use(h Handler) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (r *Router) For(path string, handler Handler) {
|
func (r *Router) For(path string, handler Handler) {
|
||||||
chain := make([]Handler, 0)
|
chain := make([]Handler, 0)
|
||||||
chain = append(chain, r.middle...)
|
chain = append(chain, r.middle...)
|
||||||
chain = append(chain, handler)
|
chain = append(chain, handler)
|
||||||
|
|
||||||
x := Route{}
|
x := Route{}
|
||||||
x.regex = routeRegexp(path)
|
x.regex = routeRegexp(path)
|
||||||
|
@ -340,7 +340,7 @@ func (s *Server) handleItemList(c *router.Context) {
|
|||||||
items = items[:perPage]
|
items = items[:perPage]
|
||||||
}
|
}
|
||||||
c.JSON(http.StatusOK, map[string]interface{}{
|
c.JSON(http.StatusOK, map[string]interface{}{
|
||||||
"list": items,
|
"list": items,
|
||||||
"has_more": hasMore,
|
"has_more": hasMore,
|
||||||
})
|
})
|
||||||
} else if c.Req.Method == "PUT" {
|
} else if c.Req.Method == "PUT" {
|
||||||
|
@ -10,10 +10,10 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
type Server struct {
|
type Server struct {
|
||||||
Addr string
|
Addr string
|
||||||
db *storage.Storage
|
db *storage.Storage
|
||||||
worker *worker.Worker
|
worker *worker.Worker
|
||||||
cache map[string]interface{}
|
cache map[string]interface{}
|
||||||
cache_mutex *sync.Mutex
|
cache_mutex *sync.Mutex
|
||||||
|
|
||||||
BasePath string
|
BasePath string
|
||||||
@ -28,10 +28,10 @@ type Server struct {
|
|||||||
|
|
||||||
func NewServer(db *storage.Storage, addr string) *Server {
|
func NewServer(db *storage.Storage, addr string) *Server {
|
||||||
return &Server{
|
return &Server{
|
||||||
db: db,
|
db: db,
|
||||||
Addr: addr,
|
Addr: addr,
|
||||||
worker: worker.NewWorker(db),
|
worker: worker.NewWorker(db),
|
||||||
cache: make(map[string]interface{}),
|
cache: make(map[string]interface{}),
|
||||||
cache_mutex: &sync.Mutex{},
|
cache_mutex: &sync.Mutex{},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -291,7 +291,7 @@ func TestDeleteOldItems(t *testing.T) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
db.CreateItems(items)
|
db.CreateItems(items)
|
||||||
|
|
||||||
db.SetFeedSize(feed.Id, itemsKeepSize)
|
db.SetFeedSize(feed.Id, itemsKeepSize)
|
||||||
var feedSize int
|
var feedSize int
|
||||||
err := db.db.QueryRow(
|
err := db.db.QueryRow(
|
||||||
@ -302,7 +302,7 @@ func TestDeleteOldItems(t *testing.T) {
|
|||||||
}
|
}
|
||||||
if feedSize != itemsKeepSize {
|
if feedSize != itemsKeepSize {
|
||||||
t.Fatalf(
|
t.Fatalf(
|
||||||
"expected feed size to get updated\nwant: %d\nhave: %d",
|
"expected feed size to get updated\nwant: %d\nhave: %d",
|
||||||
itemsKeepSize+extraItems,
|
itemsKeepSize+extraItems,
|
||||||
feedSize,
|
feedSize,
|
||||||
)
|
)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user