[Ingest Manager] Use local temp instead of system one (#21883) (#21906)

[Ingest Manager] Use local temp instead of system one (#21883)

Author: michalpristas

x-pack/elastic-agent/CHANGELOG.next.asciidoc

@@ -16,6 +16,7 @@
 - Include inputs in action store actions {pull}21298[21298]
 - Fix issue where inputs without processors defined would panic {pull}21628[21628]
 - Partial extracted beat result in failure to spawn beat {issue}21718[21718]
+- Use local temp instead of system one {pull}21883[21883]
 - Fix issue with named pipes on Windows 7 {pull}21931[21931]
 - Rename monitoring index from `elastic.agent` to `elastic_agent` {pull}21932[21932]
 - Fix missing elastic_agent event data {pull}21994[21994]

x-pack/elastic-agent/pkg/agent/application/paths/paths.go

@@ -10,14 +10,20 @@ import (
 	"os"
 	"path/filepath"
 	"strings"
+	"sync"
 
 	"github.com/elastic/beats/v7/x-pack/elastic-agent/pkg/release"
 )
 
+const (
+	tempSubdir = "tmp"
+)
+
 var (
 	topPath    string
 	configPath string
 	logsPath   string
+	tmpCreator sync.Once
 )
 
 func init() {
@@ -37,6 +43,16 @@ func Top() string {
 	return topPath
 }
 
+// TempDir returns agent temp dir located within data dir.
+func TempDir() string {
+	tmpDir := filepath.Join(Data(), tempSubdir)
+	tmpCreator.Do(func() {
+		// create tempdir as it probably don't exists
+		os.MkdirAll(tmpDir, 0750)
+	})
+	return tmpDir
+}
+
 // Home returns a directory where binary lives
 func Home() string {
 	return versionedHome(topPath)

x-pack/elastic-agent/pkg/artifact/install/atomic/atomic_installer.go

@@ -9,6 +9,8 @@ import (
 	"io/ioutil"
 	"os"
 	"path/filepath"
+
+	"github.com/elastic/beats/v7/x-pack/elastic-agent/pkg/agent/application/paths"
 )
 
 type embeddedInstaller interface {
@@ -31,7 +33,7 @@ func NewInstaller(i embeddedInstaller) (*Installer, error) {
 // Install performs installation of program in a specific version.
 func (i *Installer) Install(ctx context.Context, programName, version, installDir string) error {
 	// tar installer uses Dir of installDir to determine location of unpack
-	tempDir, err := ioutil.TempDir(os.TempDir(), "elastic-agent-install")
+	tempDir, err := ioutil.TempDir(paths.TempDir(), "elastic-agent-install")
 	if err != nil {
 		return err
 	}

x-pack/elastic-agent/pkg/artifact/install/atomic/atomic_installer_test.go

@@ -14,6 +14,8 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/assert"
+
+	"github.com/elastic/beats/v7/x-pack/elastic-agent/pkg/agent/application/paths"
 )
 
 func TestOKInstall(t *testing.T) {
@@ -25,7 +27,7 @@ func TestOKInstall(t *testing.T) {
 	assert.NoError(t, err)
 
 	ctx := context.Background()
-	installDir := filepath.Join(os.TempDir(), "install_dir")
+	installDir := filepath.Join(paths.TempDir(), "install_dir")
 
 	wg.Add(1)
 	go func() {
@@ -59,7 +61,7 @@ func TestContextCancelledInstall(t *testing.T) {
 	assert.NoError(t, err)
 
 	ctx, cancel := context.WithCancel(context.Background())
-	installDir := filepath.Join(os.TempDir(), "install_dir")
+	installDir := filepath.Join(paths.TempDir(), "install_dir")
 
 	wg.Add(1)
 	go func() {