Add missing cmd folders, change logrus to slog, update gitignore

cmd/aleesa-webapp-go/main.go

@@ -0,0 +1,138 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+
+	"aleesa-webapp-go/internal/config"
+	"aleesa-webapp-go/internal/lib"
+	"aleesa-webapp-go/internal/log"
+
+	"github.com/go-redis/redis/v8"
+)
+
+var (
+	// ctx контекст редиски.
+	Ctx = context.Background()
+
+	// Subscriber объектик сабскрайбера редиски.
+	Subscriber *redis.PubSub
+
+	// Shutdown ставится в true, если мы получили сигнал на выключение.
+	Shutdown = false
+
+	// SigChan канал, в который приходят уведомления для хэндлера сигналов от траппера сигналов.
+	SigChan = make(chan os.Signal, 1)
+)
+
+// Основная функция программы, не добавить и не убавить.
+func main() {
+	var (
+		logfile *os.File
+	)
+
+	cfg, err := config.ReadConfig()
+
+	if err != nil {
+		log.Errorf("Unable to parse config: %s", err)
+		os.Exit(1)
+	}
+
+	// Откроем лог и скормим его логгеру.
+	if cfg.Log != "" {
+		logfile, err = os.OpenFile(cfg.Log, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0644)
+
+		if err != nil {
+			log.Errorf("Unable to open log file %s: %s", cfg.Log, err)
+			os.Exit(1)
+		}
+	}
+
+	log.Init(cfg.Loglevel, logfile)
+
+	// Иницализируем клиента Редиски.
+	cfg.RedisClient = redis.NewClient(&redis.Options{
+		Addr: fmt.Sprintf("%s:%d", cfg.Server, cfg.Port),
+	}).WithContext(Ctx).WithTimeout(time.Duration(cfg.Timeout) * time.Second)
+
+	// Обозначим, что хотим после соединения подписаться на события из канала config.Channel.
+	Subscriber = cfg.RedisClient.Subscribe(Ctx, cfg.Channel)
+
+	// Самое время поставить трапы на сигналы.
+	signal.Notify(SigChan,
+		syscall.SIGINT,
+		syscall.SIGTERM,
+		syscall.SIGQUIT)
+
+	// Откроем лог и скормим его логгеру.
+	if cfg.Log != "" {
+		logfile, err = os.OpenFile(cfg.Log, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0644)
+
+		if err != nil {
+			log.Errorf("Unable to open log file %s: %s", cfg.Log, err)
+			os.Exit(1)
+		}
+	}
+
+	// Запустим обработчик сигналов.
+	go SigHandler(cfg)
+
+	// Начнём выгребать события из редиски (длина конвеера/буфера канала по-умолчанию - 100 сообщений).
+	ch := Subscriber.Channel()
+
+	log.Info("Service started.")
+
+	for msg := range ch {
+		if !Shutdown {
+			lib.MsgParser(cfg, Ctx, msg.Payload)
+		}
+	}
+}
+
+// SigHandler хэндлер сигналов закрывает все бд и сваливает из приложения.
+func SigHandler(cfg *config.MyConfig) {
+	var err error
+
+	for {
+		var s = <-SigChan
+		switch s {
+		case syscall.SIGINT:
+			log.Info("Got SIGINT, quitting")
+		case syscall.SIGTERM:
+			log.Info("Got SIGTERM, quitting")
+		case syscall.SIGQUIT:
+			log.Info("Got SIGQUIT, quitting")
+
+		// Заходим на новую итерацию, если у нас "неинтересный" сигнал
+		default:
+			continue
+		}
+
+		Shutdown = true
+
+		// Отпишемся от всех каналов и закроем коннект к редиске
+		if err = Subscriber.Unsubscribe(Ctx); err != nil {
+			log.Errorf("Unable to unsubscribe from redis channels cleanly: %s", err)
+		}
+
+		if err = Subscriber.Close(); err != nil {
+			log.Errorf("Unable to close redis connection cleanly: %s", err)
+		}
+
+		if len(cfg.PcacheDB) > 0 {
+			log.Debug("Closing persistent cache db")
+
+			for _, db := range cfg.PcacheDB {
+				_ = db.Close()
+			}
+		}
+
+		os.Exit(0)
+	}
+}
+
+/* vim: set ft=go noet ai ts=4 sw=4 sts=4: */

cmd/flickr_init/main.go

@@ -0,0 +1,22 @@
+package main
+
+import (
+	"aleesa-webapp-go/internal/config"
+	"aleesa-webapp-go/internal/flickr"
+	"fmt"
+	"os"
+)
+
+func main() {
+	if c, err := config.ReadConfig(); err != nil {
+		fmt.Fprintln(os.Stderr, err)
+		os.Exit(1)
+	} else {
+		if err := flickr.APIClientInit(c); err != nil {
+			fmt.Fprintln(os.Stderr, err)
+			os.Exit(1)
+		}
+	}
+}
+
+/* vim: set ft=go noet ai ts=4 sw=4 sts=4: */