From 44ad157960bc53ffd94fa3f1e58838646ff1118b Mon Sep 17 00:00:00 2001
From: ShiKhu <alex.kaminsky.11@gmail.com>
Date: Tue, 14 Dec 2021 21:07:04 +0100
Subject: [PATCH] fix(backend-sink): check if dir exists

---
 backend/services/sink/main.go | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/backend/services/sink/main.go b/backend/services/sink/main.go
index b1bdf8d25..5893e93e6 100644
--- a/backend/services/sink/main.go
+++ b/backend/services/sink/main.go
@@ -20,8 +20,13 @@ import (
 func main() {
 	log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
 
-	writer := NewWriter(env.Uint16("FS_ULIMIT"), env.String("FS_DIR"))
-  
+	FS_DIR := env.String("FS_DIR");
+	if _, err := os.Stat(FS_DIR); os.IsNotExist(err) {
+		log.Fatalf("%v doesn't exist. %v", FS_DIR, err)
+	}
+
+	writer := NewWriter(env.Uint16("FS_ULIMIT"), FS_DIR)
+
   count := 0
 
 	consumer := queue.NewMessageConsumer(