main.go

package main

import (
	"flag"
	"log"
	"os/user"
	"time"

	"github.com/kpetku/syndie-core/data"
	"github.com/kpetku/syndie-core/fetcher"
	"github.com/kpetku/syndie-core/gateway"
)

func main() {
	usr, err := user.Current()
	if err != nil {
		log.Fatal(err)
	}
	fetchURL := flag.String("fetch", "http://localhost:8080/", "Fetch all known messages from a Syndie archive server")
	fetchPath := flag.String("folder", usr.HomeDir+"/.syndie/incoming", "Specifies which folder to fetch messages into")
	fetchTimeout := flag.Int("timeout", 10, "HTTP timeout value in seconds")
	fetchDelay := flag.Int("delayms", 100, "Impose a random delay of up to n miliseconds when fetching")
	anonOnly := flag.Bool("anon", false, "Only allow the client to make anonymous connections")
	samaddr := flag.String("i2p", "127.0.0.1:7656", "SAM API address for fetching from I2P")
	toraddr := flag.String("tor", "127.0.0.1:9050", "TOR Socks address for fetching from .onion and clearnet anonymously.")

	flag.Parse()

	log.Println("options configured, intializing syndie database")

	derr := data.OpenDB(usr.HomeDir + "/.syndie/db/bolt.db")
	if derr != nil {
		log.Fatal(err)
	}
	defer func() {
		err := data.DB.Close()
		if err != nil {
			log.Print(err)
		}
	}()
	err = data.InitDB()
	if err != nil {
		log.Printf("err: %s", err)
	}
	log.Println("syndie database initialized, setting up fetcher")

	f, err := fetcher.NewOpts(
		fetcher.SetLocalLocation(*fetchPath),
		fetcher.SetRemoteLocation(*fetchURL),
		fetcher.SetTimeout(*fetchTimeout),
		fetcher.SetDelay(*fetchDelay),
		fetcher.SetAnonOnly(*anonOnly),
		fetcher.SetSAMAPIAddr(*samaddr),
		fetcher.SetTORSocksaddr(*toraddr),
	)
	if err != nil {
		log.Fatalf("err: %s", err)
	}

	ferr := f.RemoteFetch()
	if ferr != nil {
		log.Printf("Error indexing: %s", ferr)
	}

	go gateway.New()
	time.Sleep(time.Second * 60)
	log.Printf("Importing messages from incoming folder to http://localhost:9090/recentmessages")
	f.LocalDir(usr.HomeDir + "/.syndie/incoming/")
	log.Printf("Sleeping for 5 minutes then exiting")
	time.Sleep(time.Minute * 5)
}