From 46e022c731d510c4724ab9f8ed8f1f7249fd4bc6 Mon Sep 17 00:00:00 2001 From: sneak Date: Thu, 19 Dec 2019 06:42:41 -0800 Subject: [PATCH] seems to save toots to disk now --- instance/instance.go | 2 -- manager/manager.go | 2 +- storage/tootstore.go | 6 ++++++ 3 files changed, 7 insertions(+), 3 deletions(-) diff --git a/instance/instance.go b/instance/instance.go index 4254eec..67e5de1 100644 --- a/instance/instance.go +++ b/instance/instance.go @@ -456,8 +456,6 @@ func (i *Instance) fetchRecentToots() error { Msgf("unable to parse recent toot list") i.registerError() i.Event("TOOT_FETCH_ERROR") - - fmt.Printf(string(body)) return err } diff --git a/manager/manager.go b/manager/manager.go index a8570cc..fa09afd 100644 --- a/manager/manager.go +++ b/manager/manager.go @@ -10,7 +10,7 @@ import "github.com/sneak/feta/toot" import "github.com/sneak/feta/seeds" import "github.com/sneak/feta/instance" -const hostDiscoveryParallelism = 20 +const hostDiscoveryParallelism = 5 // LogReportInterval defines how long between logging internal // stats/reporting for user supervision diff --git a/storage/tootstore.go b/storage/tootstore.go index 1a0c143..370988f 100644 --- a/storage/tootstore.go +++ b/storage/tootstore.go @@ -2,6 +2,7 @@ package storage import "errors" import "io/ioutil" +import "path/filepath" import "os" import "strings" import "sync" @@ -63,6 +64,11 @@ func (ts *TootFSStorage) TootExists(t toot.Toot) bool { func (ts *TootFSStorage) StoreToot(t toot.Toot) error { path := t.DiskStoragePath() full := ts.root + "/" + path + dir := filepath.Dir(full) + err := os.MkdirAll(dir, 0755) + if err != nil { + return err + } return ioutil.WriteFile(full, t.Original, 0644) }