сделал Start_ctx()

camunda_connect/camunda_connect.go

@@ -233,9 +233,17 @@ func StartCamunda(HandleJob func(client worker.JobClient, job entities.Job), CAM
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, HandleJob func(client worker.JobClient, job entities.Job), CAMUNDA_JOBTYPE string, BPMN_filename string) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	// var err error

chatgpt_connect/chatgpt_connect.go

@@ -162,9 +162,17 @@ func Start() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

chatgpt_proxy/chatgpt_proxy.go

@@ -158,9 +158,17 @@ func Start() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

email/email.go

@@ -258,9 +258,17 @@ func Start() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	LoadEnv()

email_imap/email_imap.go

@@ -288,9 +288,17 @@ func Start() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	LoadEnv()

fiber_connect/fiber_connect.go

@@ -137,9 +137,17 @@ func Start() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) {
 	//var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	if Client == nil {

kafka_connect/kafka_connect.go

@@ -82,9 +82,17 @@ func StartKafka() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

liveness/liveness.go

@@ -48,9 +48,17 @@ func Start() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) {
 	//var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	FillSettings()

minio_connect/minio_connect.go

@@ -216,9 +216,17 @@ func StartMinio() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

mssql_connect/mssql_connect.go

@@ -222,9 +222,17 @@ func StartDB() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

mssql_gorm/mssql_gorm.go

@@ -236,9 +236,17 @@ func StartDB() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

nats_connect/nats_connect.go

@@ -85,9 +85,17 @@ func StartNats() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

nats_liveness/nats_liveness.go

@@ -211,9 +211,17 @@ func Start(ServiceName string) {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ServiceName string) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = CheckSettingsNATS()

postgres_connect/postgres_connect.go

@@ -234,9 +234,17 @@ func StartDB() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

postgres_gorm/postgres_gorm.go

@@ -299,9 +299,17 @@ func StartDB() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

postgres_pgx/postgres_pgx.go

@@ -262,9 +262,17 @@ func StartDB() {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err()

postgres_stek/postgres_stek.go

@@ -292,9 +292,17 @@ func StartDB(Connection connections.Connection) {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, Connection connections.Connection) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err(Connection)

stopapp/stopapp.go

@@ -94,7 +94,8 @@ func StopAppAndWait() {
 	if contextmain.CancelContext != nil {
 		contextmain.CancelContext()
 	} else {
-		os.Exit(0)
+		//os.Exit(0)
+		log.Warn("Context = nil")
 	}
 
 	GetWaitGroup_Main().Wait()
@@ -106,7 +107,9 @@ func WaitStop() {
 	select {
 	case <-SignalInterrupt:
 		log.Warn("Interrupt clean shutdown.")
-		contextmain.CancelContext()
+		if contextmain.CancelContext != nil {
+			contextmain.CancelContext()
+		}
 	case <-contextmain.GetContext().Done():
 		log.Warn("Context app is canceled.")
 	}

sync_exchange_connect/sync_exchange_connect.go

@@ -58,9 +58,17 @@ func Start(ServiceName string) {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ServiceName string) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err(ServiceName)

telegram_client/telegram_client.go

@@ -831,9 +831,17 @@ func StartTelegram(func_OnNewMessage func(ctx context.Context, entities tg.Entit
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, func_OnNewMessage func(ctx context.Context, entities tg.Entities, u *tg.UpdateNewMessage, Peer1 storage.Peer) error) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	CreateTelegramClient(func_OnNewMessage)

whatsapp_connect/whatsapp_connect.go

@@ -326,9 +326,17 @@ func Start(eventHandler func(evt interface{})) {
 func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, eventHandler func(evt interface{})) error {
 	var err error
 
-	//запомним к себе контекст и WaitGroup
+	//запомним к себе контекст
 	contextmain.Ctx = ctx
+	if ctx == nil {
+		contextmain.GetContext()
+	}
+
+	//запомним к себе WaitGroup
 	stopapp.SetWaitGroup_Main(WaitGroup)
+	if WaitGroup == nil {
+		stopapp.StartWaitStop()
+	}
 
 	//
 	err = Connect_err(eventHandler)