Skip to content
Snippets Groups Projects
Commit 8a0a5a5e authored by Loïck Bonniot's avatar Loïck Bonniot
Browse files

[tests] Add skeletton for integration tests

parent 9b42fc4c
No related branches found
No related tags found
1 merge request!32186 integration tests
package tests
import (
"io/ioutil"
"os"
"testing"
"time"
"github.com/bmizerany/assert"
)
func TestSimple(t *testing.T) {
// Start the platform
workingDir, err := ioutil.TempDir("", "dfss_")
assert.Equal(t, nil, err)
cmd, ca, err := StartPlatform(workingDir)
assert.Equal(t, nil, err)
time.Sleep(3 * time.Second)
// Start a client
_, err = CreateClient(workingDir, ca)
assert.Equal(t, nil, err)
// Shutdown
err = cmd.Process.Kill()
assert.Equal(t, nil, err)
// Cleanup
_ = os.RemoveAll(workingDir)
}
package tests
import (
"io/ioutil"
"os"
"os/exec"
"path/filepath"
"strconv"
)
const testPort = "9090"
var currentClient = 0
// StartPlatform creates root certificate for the platform and starts the platform.
func StartPlatform(tmpDir string) (*exec.Cmd, []byte, error) {
path := filepath.Join(os.Getenv("GOPATH"), "bin", "dfssp")
db := os.Getenv("DFSS_MONGO_URI")
if db == "" {
db = "mongodb://localhost/dfss"
}
// Create temporary directory for platform
dir, err := ioutil.TempDir(tmpDir, "p_")
if err != nil {
return nil, nil, err
}
// Init
cmd := exec.Command(path, "-cn", "localhost", "-path", dir, "-v", "init")
err = cmd.Run()
if err != nil {
return nil, nil, err
}
// Get root certificate
ca, err := ioutil.ReadFile(filepath.Join(dir, "dfssp_rootCA.pem"))
if err != nil {
return nil, nil, err
}
// Start
cmd = exec.Command(path, "-db", db, "-path", dir, "-p", testPort, "-v", "start")
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
err = cmd.Start()
return cmd, ca, err
}
// CreateClient creates a new working directory for a client, creating ca.pem.
// It returns a ready-to-run command, but you probably want to change the last argument of the command.
func CreateClient(tmpDir string, ca []byte) (*exec.Cmd, error) {
path := filepath.Join(os.Getenv("GOPATH"), "bin", "dfssc")
// Create temporary directory for client
clientID := strconv.Itoa(currentClient)
currentClient++
dir, err := ioutil.TempDir(tmpDir, "c"+clientID+"_")
if err != nil {
return nil, err
}
caPath := filepath.Join(dir, "ca.pem")
certPath := filepath.Join(dir, "cert.pem")
keyPath := filepath.Join(dir, "key.pem")
// Write the CA
err = ioutil.WriteFile(caPath, ca, os.ModePerm)
if err != nil {
return nil, err
}
// Prepare the client command.
// The last argument is up to you!
cmd := exec.Command(path, "-ca", caPath, "-cert", certPath, "-host", "localhost:"+testPort, "-key", keyPath, "-v", "CHANGE_ME")
return cmd, nil
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment