mirror of
https://github.com/nkanaev/yarr.git
synced 2025-05-24 00:33:14 +00:00
remove prints
This commit is contained in:
parent
9d5d8f4df2
commit
d9437d46e4
@ -9,7 +9,6 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"log"
|
"log"
|
||||||
"io"
|
"io"
|
||||||
"fmt"
|
|
||||||
"mime"
|
"mime"
|
||||||
"strings"
|
"strings"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
@ -54,7 +53,6 @@ type NewFolder struct {
|
|||||||
func FolderListHandler(rw http.ResponseWriter, req *http.Request) {
|
func FolderListHandler(rw http.ResponseWriter, req *http.Request) {
|
||||||
if req.Method == "GET" {
|
if req.Method == "GET" {
|
||||||
list := db(req).ListFolders()
|
list := db(req).ListFolders()
|
||||||
fmt.Println(list)
|
|
||||||
json.NewEncoder(rw).Encode(list)
|
json.NewEncoder(rw).Encode(list)
|
||||||
} else if req.Method == "POST" {
|
} else if req.Method == "POST" {
|
||||||
var body NewFolder
|
var body NewFolder
|
||||||
|
@ -7,7 +7,6 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
"github.com/nkanaev/yarr/storage"
|
"github.com/nkanaev/yarr/storage"
|
||||||
"log"
|
"log"
|
||||||
"fmt"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type Route struct {
|
type Route struct {
|
||||||
@ -26,16 +25,13 @@ type Handler struct {
|
|||||||
|
|
||||||
func (h *Handler) startJobs() {
|
func (h *Handler) startJobs() {
|
||||||
go func() {
|
go func() {
|
||||||
fmt.Println("one")
|
|
||||||
for {
|
for {
|
||||||
feed := <-h.feedQueue
|
feed := <-h.feedQueue
|
||||||
fmt.Println("got feed", feed)
|
|
||||||
items := listItems(feed)
|
items := listItems(feed)
|
||||||
h.db.CreateItems(items)
|
h.db.CreateItems(items)
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
go func() {
|
go func() {
|
||||||
fmt.Println("two")
|
|
||||||
for {
|
for {
|
||||||
val := <-h.counter
|
val := <-h.counter
|
||||||
h.queueSize += val
|
h.queueSize += val
|
||||||
@ -51,7 +47,6 @@ func (h *Handler) fetchFeed(feed storage.Feed) {
|
|||||||
|
|
||||||
func (h *Handler) fetchAllFeeds() {
|
func (h *Handler) fetchAllFeeds() {
|
||||||
for _, feed := range h.db.ListFeeds() {
|
for _, feed := range h.db.ListFeeds() {
|
||||||
fmt.Println("here", feed)
|
|
||||||
h.fetchFeed(feed)
|
h.fetchFeed(feed)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user