added task switching and closing on the termination

deployment/dev.tf

@@ -43,7 +43,7 @@ resource "aws_sqs_queue" "event_queue" {
 }
 
 # data "aws_api_gateway_api_key" "webhook_end_point_api_key" {
-#   id = "ru3mpjgse6"
+# 	#  id = "ru3mpjgse6"
 # }
 
 

handler/common.go

@@ -5,9 +5,11 @@ import (
 	"errors"
 	"fmt"
 	"os"
+	"os/signal"
 	"strconv"
 	"strings"
 	"sync"
+	"syscall"
 	"time"
 	"unicode"
 
@@ -75,6 +77,31 @@ func init() {
 		ErrorOutputPaths: []string{"stderr"},
 	}.Build()
 	log = logger.Sugar()
+
+	go func() {
+		sc := make(chan os.Signal, 1)
+		signal.Notify(sc, syscall.SIGPIPE, syscall.SIGKILL, syscall.SIGTERM)
+
+		for {
+			select {
+			case <-time.Tick(time.Minute * 10):
+				if taskID != 0 && taskRecordCount > 0 && time.Now().Sub(taskCreatedAt).Minutes() > taskRetentionMin {
+					taskSetUpWG.Add(1)
+					go (&Task{ID: taskID}).activateTask()
+					taskSetUpWG.Add(1)
+					go newTask()
+					taskSetUpWG.Done()
+				}
+			case <-sc:
+				if taskID != 0 && taskRecordCount > 0 && time.Now().Sub(taskCreatedAt).Minutes() > taskRetentionMin {
+					taskSetUpWG.Add(1)
+					go (&Task{ID: taskID}).activateTask()
+					taskSetUpWG.Done()
+				}
+				break
+			}
+		}
+	}()
 }
 
 func setup() {

handler/main.go

@@ -5,8 +5,6 @@ package main
 import (
 	"context"
 	"os"
-	"os/signal"
-	"syscall"
 
 	"github.com/aws/aws-lambda-go/lambda"
 
@@ -38,18 +36,5 @@ func main() {
 		log = logger.Sugar()
 	}
 
-	sc := make(chan os.Signal, 1)
-	signal.Notify(sc, syscall.SIGPIPE)
-
-	go func() {
-		<-sc
-		if taskID != 0 {
-			log.Info("====================== SIGPIPE ======================================================")
-			log.Infof("task (ID: %d) activated", taskID)
-			log.Info("====================== SIGPIPE ======================================================")
-			logger.Sync()
-		}
-	}()
-
 	lambda.Start(HandleRequest)
 }