summaryrefslogtreecommitdiff
path: root/tests/plugins/service
diff options
context:
space:
mode:
Diffstat (limited to 'tests/plugins/service')
-rw-r--r--tests/plugins/service/configs/.rr-service-error.yaml16
-rw-r--r--tests/plugins/service/configs/.rr-service-init.yaml22
-rw-r--r--tests/plugins/service/configs/.rr-service-restarts.yaml16
-rw-r--r--tests/plugins/service/service_plugin_test.go254
-rw-r--r--tests/plugins/service/test_files/loop.php6
-rwxr-xr-xtests/plugins/service/test_files/test_binarybin1363968 -> 0 bytes
6 files changed, 0 insertions, 314 deletions
diff --git a/tests/plugins/service/configs/.rr-service-error.yaml b/tests/plugins/service/configs/.rr-service-error.yaml
deleted file mode 100644
index 3b0f1eb9..00000000
--- a/tests/plugins/service/configs/.rr-service-error.yaml
+++ /dev/null
@@ -1,16 +0,0 @@
-service:
- some_service_1:
- command: "php test_files/loopo.php"
- process_num: 1
- exec_timeout: 5s # s,m,h (seconds, minutes, hours)
- remain_after_exit: true
- restart_sec: 1
-
-logs:
- level: info
- mode: raw
-
-endure:
- grace_period: 120s
- print_graph: false
- log_level: error
diff --git a/tests/plugins/service/configs/.rr-service-init.yaml b/tests/plugins/service/configs/.rr-service-init.yaml
deleted file mode 100644
index e32f2eda..00000000
--- a/tests/plugins/service/configs/.rr-service-init.yaml
+++ /dev/null
@@ -1,22 +0,0 @@
-service:
- some_service_1:
- command: "php test_files/loop.php"
- process_num: 1
- exec_timeout: 5s # s,m,h (seconds, minutes, hours)
- remain_after_exit: true
- restart_sec: 1
- some_service_2:
- command: "test_files/test_binary"
- process_num: 1
- remain_after_exit: true
- restart_delay: 1s
- exec_timeout: 5s
-
-logs:
- level: info
- mode: raw
-
-endure:
- grace_period: 120s
- print_graph: false
- log_level: error
diff --git a/tests/plugins/service/configs/.rr-service-restarts.yaml b/tests/plugins/service/configs/.rr-service-restarts.yaml
deleted file mode 100644
index f08d5720..00000000
--- a/tests/plugins/service/configs/.rr-service-restarts.yaml
+++ /dev/null
@@ -1,16 +0,0 @@
-service:
- some_service_2:
- command: "test_files/test_binary"
- process_num: 1
- remain_after_exit: true
- restart_delay: 1s
- exec_timeout: 2s
-
-logs:
- level: debug
- mode: raw
-
-endure:
- grace_period: 120s
- print_graph: false
- log_level: error
diff --git a/tests/plugins/service/service_plugin_test.go b/tests/plugins/service/service_plugin_test.go
deleted file mode 100644
index ddf54520..00000000
--- a/tests/plugins/service/service_plugin_test.go
+++ /dev/null
@@ -1,254 +0,0 @@
-//go:build linux
-// +build linux
-
-package service
-
-import (
- "os"
- "os/signal"
- "sync"
- "syscall"
- "testing"
- "time"
-
- "github.com/golang/mock/gomock"
- endure "github.com/spiral/endure/pkg/container"
- "github.com/spiral/roadrunner/v2/plugins/config"
- "github.com/spiral/roadrunner/v2/plugins/service"
- "github.com/spiral/roadrunner/v2/tests/mocks"
- "github.com/stretchr/testify/assert"
-)
-
-func TestServiceInit(t *testing.T) {
- cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
- assert.NoError(t, err)
-
- cfg := &config.Viper{
- Path: "configs/.rr-service-init.yaml",
- Prefix: "rr",
- }
-
- controller := gomock.NewController(t)
- mockLogger := mocks.NewMockLogger(controller)
-
- mockLogger.EXPECT().Debug("worker destructed", "pid", gomock.Any()).AnyTimes()
- mockLogger.EXPECT().Debug("worker constructed", "pid", gomock.Any()).AnyTimes()
- mockLogger.EXPECT().Info("The number is: 0\n").MinTimes(1)
- mockLogger.EXPECT().Info("The number is: 1\n").MinTimes(1)
- mockLogger.EXPECT().Info("The number is: 2\n").MinTimes(1)
- mockLogger.EXPECT().Info("The number is: 3\n").MinTimes(1)
- mockLogger.EXPECT().Info("The number is: 4\n").AnyTimes()
-
- // process interrupt error
- mockLogger.EXPECT().Error("process wait error", gomock.Any()).MinTimes(2)
-
- mockLogger.EXPECT().Info("Hello 0").MinTimes(1)
- mockLogger.EXPECT().Info("Hello 1").MinTimes(1)
- mockLogger.EXPECT().Info("Hello 2").MinTimes(1)
- mockLogger.EXPECT().Info("Hello 3").MinTimes(1)
- mockLogger.EXPECT().Info("Hello 4").AnyTimes()
-
- err = cont.RegisterAll(
- cfg,
- mockLogger,
- &service.Plugin{},
- )
- assert.NoError(t, err)
-
- err = cont.Init()
- if err != nil {
- t.Fatal(err)
- }
-
- ch, err := cont.Serve()
- assert.NoError(t, err)
-
- sig := make(chan os.Signal, 1)
- signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
- wg := &sync.WaitGroup{}
- wg.Add(1)
-
- stopCh := make(chan struct{}, 1)
-
- go func() {
- defer wg.Done()
- for {
- select {
- case e := <-ch:
- assert.Fail(t, "error", e.Error.Error())
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- case <-sig:
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- case <-stopCh:
- // timeout
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- }
- }
- }()
-
- time.Sleep(time.Second * 10)
- stopCh <- struct{}{}
- wg.Wait()
-}
-
-func TestServiceError(t *testing.T) {
- cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
- assert.NoError(t, err)
-
- cfg := &config.Viper{
- Path: "configs/.rr-service-error.yaml",
- Prefix: "rr",
- }
-
- controller := gomock.NewController(t)
- mockLogger := mocks.NewMockLogger(controller)
-
- mockLogger.EXPECT().Debug("worker destructed", "pid", gomock.Any()).AnyTimes()
- mockLogger.EXPECT().Debug("worker constructed", "pid", gomock.Any()).AnyTimes()
-
- // process interrupt error
- mockLogger.EXPECT().Error("process wait error", gomock.Any()).MinTimes(2)
-
- err = cont.RegisterAll(
- cfg,
- mockLogger,
- &service.Plugin{},
- )
- assert.NoError(t, err)
-
- err = cont.Init()
- assert.NoError(t, err)
- ch, err := cont.Serve()
- assert.NoError(t, err)
-
- sig := make(chan os.Signal, 1)
- signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
- wg := &sync.WaitGroup{}
- wg.Add(1)
-
- stopCh := make(chan struct{}, 1)
-
- go func() {
- defer wg.Done()
- for {
- select {
- case e := <-ch:
- assert.Fail(t, "error", e.Error.Error())
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- case <-sig:
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- case <-stopCh:
- // timeout
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- }
- }
- }()
-
- time.Sleep(time.Second * 10)
- stopCh <- struct{}{}
- wg.Wait()
-}
-
-func TestServiceRestarts(t *testing.T) {
- cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
- assert.NoError(t, err)
-
- cfg := &config.Viper{
- Path: "configs/.rr-service-restarts.yaml",
- Prefix: "rr",
- }
-
- controller := gomock.NewController(t)
- mockLogger := mocks.NewMockLogger(controller)
-
- mockLogger.EXPECT().Debug("worker destructed", "pid", gomock.Any()).AnyTimes()
- mockLogger.EXPECT().Debug("worker constructed", "pid", gomock.Any()).AnyTimes()
-
- // process interrupt error
- mockLogger.EXPECT().Error("process wait error", gomock.Any()).MinTimes(1)
-
- // should not be more than Hello 0, because of restarts
- mockLogger.EXPECT().Info("Hello 0").MinTimes(1)
- mockLogger.EXPECT().Info("Hello 1").AnyTimes()
-
- err = cont.RegisterAll(
- cfg,
- mockLogger,
- &service.Plugin{},
- )
- assert.NoError(t, err)
-
- err = cont.Init()
- if err != nil {
- t.Fatal(err)
- }
-
- ch, err := cont.Serve()
- assert.NoError(t, err)
-
- sig := make(chan os.Signal, 1)
- signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
- wg := &sync.WaitGroup{}
- wg.Add(1)
-
- stopCh := make(chan struct{}, 1)
-
- go func() {
- defer wg.Done()
- for {
- select {
- case e := <-ch:
- assert.Fail(t, "error", e.Error.Error())
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- case <-sig:
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- case <-stopCh:
- // timeout
- err = cont.Stop()
- if err != nil {
- assert.FailNow(t, "error", err.Error())
- }
- return
- }
- }
- }()
-
- time.Sleep(time.Second * 10)
- stopCh <- struct{}{}
- wg.Wait()
-}
diff --git a/tests/plugins/service/test_files/loop.php b/tests/plugins/service/test_files/loop.php
deleted file mode 100644
index 6ba488ef..00000000
--- a/tests/plugins/service/test_files/loop.php
+++ /dev/null
@@ -1,6 +0,0 @@
-<?php
-for ($x = 0; $x <= 1000; $x++) {
- sleep(1);
- error_log("The number is: $x", 0);
-}
-?>
diff --git a/tests/plugins/service/test_files/test_binary b/tests/plugins/service/test_files/test_binary
deleted file mode 100755
index 480fb7e2..00000000
--- a/tests/plugins/service/test_files/test_binary
+++ /dev/null
Binary files differ
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-23 13:26:30 +0000