cleanup

internal/cron/service.go

@@ -49,7 +49,7 @@ func (s *cronService) Start() error {
 	}
 
 	_, err = scheduler.NewJob(
-		gocron.DurationJob(15*time.Second),
+		gocron.DurationJob(10*time.Second),
 		gocron.NewTask(s.sseJob),
 		gocron.WithSingletonMode(gocron.LimitModeReschedule),
 	)

internal/post/constants.go

@@ -22,6 +22,9 @@ const (
 	SELECT_RANDOM_POST_QUERY string = "SELECT id, body, author, type, created_at FROM submissions WHERE type = $1 ORDER BY RANDOM() LIMIT 1"
 )
 
-const ALLOWED_CHARS string = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789,.'-_ !"
+const (
+	ALLOWED_CHARS string = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789,.'-_ !"
+	RESERVED_NAME string = "ary82"
+)
 
 const SQLSTATE_ERR_NOT_UNIQUE string = "23505"

internal/post/service.go

@@ -36,6 +36,10 @@ func (s *postService) CreatePost(post *Post) error {
 		return fmt.Errorf("author name too short")
 	}
 
+	if strings.ReplaceAll(post.Author, " ", "") == RESERVED_NAME {
+		return fmt.Errorf("that's my name.")
+	}
+
 	for i, v := range post.Body {
 		if !strings.ContainsRune(ALLOWED_CHARS, v) {
 			return fmt.Errorf("body contains invalid characters at index: %d", i)

internal/server/handlers.go

@@ -24,9 +24,6 @@ func (s *FiberServer) sse(c *fiber.Ctx) error {
 				negMsg := html.EscapeString(s.CurrentNegativePosts.Body)
 				negAuthor := html.EscapeString(s.CurrentNegativePosts.Author)
 
-				_ = posAuthor
-				_ = negAuthor
-
 				fmt.Fprintf(w,
 					"event: positive_body\ndata: %s\n\nevent: positive_author\ndata: %s\n\nevent: negative_body\ndata: %s\n\nevent: negative_author\ndata: %s\n\n",
 					posMsg, posAuthor,
@@ -35,7 +32,7 @@ func (s *FiberServer) sse(c *fiber.Ctx) error {
 
 				err := w.Flush()
 				if err != nil {
-					fmt.Printf("Error while flushing: %v. Closing http connection.\n", err)
+					fmt.Printf("%v. Closing http connection.\n", err)
 					break
 				}
 				time.Sleep(3 * time.Second)