mirror of
https://github.com/GoogleContainerTools/kaniko
synced 2026-10-01 11:12:19 +02:00
JackandJason Hall
d4cf49077a
* remove configurables from constants * add configurables to config init * add kaniko dir flag * cleanup pkg constants * replace buildcontext constants pkg occurrences with config * add KanikoDir to KanikoOptions * replace executor constants pkg occurrences with config * remove redundant KanikoDir assignment * replace constants to config for IntermediateStagesDir * fix imports * add default kaniko directory into constants * add check for kanikoDir on use * update init to use default path constant * update executor kanikoDir check Co-authored-by: Jason Hall <jasonhall@redhat.com> * alter checkKanikoDir parameter * add TestKanikoDir func * update error handling style Co-authored-by: Jason Hall <jasonhall@redhat.com> * remove shorthand flag usage from test Co-authored-by: Jason Hall <jasonhall@redhat.com> * add docstring to integration test Co-authored-by: Jason Hall <jasonhall@redhat.com> * remove shorthand flag from kaniko-dir Co-authored-by: Jason Hall <jasonhall@redhat.com>
81 lines
2.1 KiB
Go
81 lines
2.1 KiB
Go
/*
|
|
Copyright 2018 Google LLC
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package buildcontext
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
kConfig "github.com/GoogleContainerTools/kaniko/pkg/config"
|
|
"github.com/GoogleContainerTools/kaniko/pkg/constants"
|
|
"github.com/GoogleContainerTools/kaniko/pkg/util"
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// HTTPSTar struct for https tar.gz files processing
|
|
type HTTPSTar struct {
|
|
context string
|
|
}
|
|
|
|
// UnpackTarFromBuildContext downloads context file from https server
|
|
func (h *HTTPSTar) UnpackTarFromBuildContext() (directory string, err error) {
|
|
|
|
logrus.Info("Retrieving https tar file")
|
|
|
|
// Create directory and target file for downloading the context file
|
|
directory = kConfig.BuildContextDir
|
|
tarPath := filepath.Join(directory, constants.ContextTar)
|
|
file, err := util.CreateTargetTarfile(tarPath)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
// Download tar file from remote https server
|
|
// and save it into the target tar file
|
|
resp, err := http.Get(h.context)
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer func() {
|
|
if closeErr := resp.Body.Close(); err == nil && closeErr != nil {
|
|
err = closeErr
|
|
}
|
|
}()
|
|
|
|
if resp.StatusCode != http.StatusOK {
|
|
return directory, fmt.Errorf("HTTPSTar bad status from server: %s", resp.Status)
|
|
}
|
|
|
|
if _, err = io.Copy(file, resp.Body); err != nil {
|
|
return tarPath, err
|
|
}
|
|
|
|
logrus.Info("Retrieved https tar file")
|
|
|
|
if err = util.UnpackCompressedTar(tarPath, directory); err != nil {
|
|
return
|
|
}
|
|
|
|
logrus.Info("Extracted https tar file")
|
|
|
|
// Remove the tar so it doesn't interfere with subsequent commands
|
|
return directory, os.Remove(tarPath)
|
|
}
|