github/vm-import-controller
7
0
Fork 0
mirror of https://github.com/harvester/vm-import-controller.git synced 2025-06-03 01:44:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

changes to server to use a predefined persistent path

Browse Source
This commit is contained in:
Gaurav Mehta 2022-09-14 17:12:03 +10:00
parent 7657e1ffd5
commit 57376e3d34
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/server/server.go
View File

@ -3,7 +3,6 @@ package server
import ( import (
"context" "context"
"fmt" "fmt"
"io/ioutil"
"net/http" "net/http"
"os" "os"
@ -12,11 +11,11 @@ import (
const defaultPort = 8080 const defaultPort = 8080
var tmpDir string const tmpDir = "/tmp/vm-import-controller"
func NewServer(ctx context.Context) error { func NewServer(ctx context.Context) error {
var err error var err error
tmpDir, err = createTmpDir() err = createTmpDir()
if err != nil { if err != nil {
return err return err
} }
@ -43,8 +42,13 @@ func newServer(ctx context.Context, path string) error {
return eg.Wait() return eg.Wait()
} }
func createTmpDir() (string, error) { func createTmpDir() error {
return ioutil.TempDir("/tmp", "vm-import-controller-") if _, err := os.Stat(tmpDir); os.IsNotExist(err) {
return os.Mkdir("/tmp/vm-import-controller", 0755)
} else {
return err
}
return nil
} }
func DefaultPort() int { func DefaultPort() int {

2
pkg/server/server_test.go
View File

@ -17,7 +17,7 @@ func Test_NewServer(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
assert := require.New(t) assert := require.New(t)
var err error var err error
tmpDir, err = createTmpDir() err = createTmpDir()
assert.NoError(err, "expected no error during creation of tmp dir") assert.NoError(err, "expected no error during creation of tmp dir")
go func() { go func() {
err = newServer(ctx, tmpDir) err = newServer(ctx, tmpDir)