Function injectSyncHelperFromBytes

pkg/devspace/services/inject/inject.go:290–385

(ctx context.Context, client kubectl.Client, pod *v1.Pod, container string, fi fs.FileInfo, bytesReader io.Reader)

}

func injectSyncHelperFromBytes(ctx context.Context, client kubectl.Client, pod *v1.Pod, container string, fi fs.FileInfo, bytesReader io.Reader) error {
	writerComplete := make(chan struct{})
	readerComplete := make(chan struct{})

	// Compress the sync helper and then copy it to the container
	reader, writer := io.Pipe()
	var (
		retErr    error
		setRetErr sync.Once
	)

	go func() {
		defer close(readerComplete)
		defer func() {
			if r := recover(); r != nil {
				setRetErr.Do(func() {
					retErr = fmt.Errorf("%v", r)
				})
			}
		}()
		defer reader.Close()

		err := client.CopyFromReader(ctx, pod, container, "/tmp", reader)
		setRetErr.Do(func() {
			retErr = err
		})
	}()

	go func() {
		defer close(writerComplete)
		defer func() {
			if r := recover(); r != nil {
				setRetErr.Do(func() {
					retErr = fmt.Errorf("%v", r)
				})
			}
		}()
		defer writer.Close()

		// Use compression
		gw := gzip.NewWriter(writer)
		defer gw.Close()

		// Create tar writer
		tarWriter := tar.NewWriter(gw)
		defer tarWriter.Close()

		hdr, err := tar.FileInfoHeader(fi, DevSpaceHelperTempFolder)
		if err != nil {
			setRetErr.Do(func() {
				retErr = err
			})
			return
		}

		hdr.Name = "devspacehelper"

		// Set permissions correctly