mirror of
https://gitee.com/IrisVega/frp.git
synced 2024-11-01 22:31:29 +08:00
92 lines
2.7 KiB
Go
92 lines
2.7 KiB
Go
package framework
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
"time"
|
|
|
|
flog "github.com/fatedier/frp/pkg/util/log"
|
|
"github.com/fatedier/frp/test/e2e/pkg/process"
|
|
)
|
|
|
|
// RunProcesses run multiple processes from templates.
|
|
// The first template should always be frps.
|
|
func (f *Framework) RunProcesses(serverTemplates []string, clientTemplates []string) {
|
|
templates := make([]string, 0, len(serverTemplates)+len(clientTemplates))
|
|
for _, t := range serverTemplates {
|
|
templates = append(templates, t)
|
|
}
|
|
for _, t := range clientTemplates {
|
|
templates = append(templates, t)
|
|
}
|
|
outs, ports, err := f.RenderTemplates(templates)
|
|
ExpectNoError(err)
|
|
ExpectTrue(len(templates) > 0)
|
|
|
|
for name, port := range ports {
|
|
f.usedPorts[name] = port
|
|
}
|
|
|
|
for i := range serverTemplates {
|
|
path := filepath.Join(f.TempDirectory, fmt.Sprintf("frp-e2e-server-%d", i))
|
|
err = os.WriteFile(path, []byte(outs[i]), 0666)
|
|
ExpectNoError(err)
|
|
flog.Trace("[%s] %s", path, outs[i])
|
|
|
|
p := process.NewWithEnvs(TestContext.FRPServerPath, []string{"-c", path}, f.osEnvs)
|
|
f.serverConfPaths = append(f.serverConfPaths, path)
|
|
f.serverProcesses = append(f.serverProcesses, p)
|
|
err = p.Start()
|
|
ExpectNoError(err)
|
|
}
|
|
time.Sleep(time.Second)
|
|
|
|
for i := range clientTemplates {
|
|
index := i + len(serverTemplates)
|
|
path := filepath.Join(f.TempDirectory, fmt.Sprintf("frp-e2e-client-%d", i))
|
|
err = os.WriteFile(path, []byte(outs[index]), 0666)
|
|
ExpectNoError(err)
|
|
flog.Trace("[%s] %s", path, outs[index])
|
|
|
|
p := process.NewWithEnvs(TestContext.FRPClientPath, []string{"-c", path}, f.osEnvs)
|
|
f.clientConfPaths = append(f.clientConfPaths, path)
|
|
f.clientProcesses = append(f.clientProcesses, p)
|
|
err = p.Start()
|
|
ExpectNoError(err)
|
|
time.Sleep(500 * time.Millisecond)
|
|
}
|
|
time.Sleep(500 * time.Millisecond)
|
|
}
|
|
|
|
func (f *Framework) RunFrps(args ...string) (*process.Process, string, error) {
|
|
p := process.NewWithEnvs(TestContext.FRPServerPath, args, f.osEnvs)
|
|
f.serverProcesses = append(f.serverProcesses, p)
|
|
err := p.Start()
|
|
if err != nil {
|
|
return p, p.StdOutput(), err
|
|
}
|
|
// sleep for a while to get std output
|
|
time.Sleep(500 * time.Millisecond)
|
|
return p, p.StdOutput(), nil
|
|
}
|
|
|
|
func (f *Framework) RunFrpc(args ...string) (*process.Process, string, error) {
|
|
p := process.NewWithEnvs(TestContext.FRPClientPath, args, f.osEnvs)
|
|
f.clientProcesses = append(f.clientProcesses, p)
|
|
err := p.Start()
|
|
if err != nil {
|
|
return p, p.StdOutput(), err
|
|
}
|
|
time.Sleep(500 * time.Millisecond)
|
|
return p, p.StdOutput(), nil
|
|
}
|
|
|
|
func (f *Framework) GenerateConfigFile(content string) string {
|
|
f.configFileIndex++
|
|
path := filepath.Join(f.TempDirectory, fmt.Sprintf("frp-e2e-config-%d", f.configFileIndex))
|
|
err := os.WriteFile(path, []byte(content), 0666)
|
|
ExpectNoError(err)
|
|
return path
|
|
}
|