summaryrefslogtreecommitdiff
path: root/pkg/varlinkapi/transfers.go
blob: 96f76bcdcbbce05ef0c7420b3c030962387ee5e6 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
// +build varlink

package varlinkapi

import (
	"bufio"
	"fmt"
	"io"
	"io/ioutil"
	"os"

	"github.com/containers/libpod/cmd/podman/varlink"
	"github.com/sirupsen/logrus"
)

// SendFile allows a client to send a file to the varlink server
func (i *LibpodAPI) SendFile(call iopodman.VarlinkCall, ftype string, length int64) error {
	if !call.WantsUpgrade() {
		return call.ReplyErrorOccurred("client must use upgraded connection to send files")
	}

	outputFile, err := ioutil.TempFile("", "varlink_send")
	if err != nil {
		return call.ReplyErrorOccurred(err.Error())
	}
	defer outputFile.Close()

	if err = call.ReplySendFile(outputFile.Name()); err != nil {
		return call.ReplyErrorOccurred(err.Error())
	}

	writer := bufio.NewWriter(outputFile)
	defer writer.Flush()

	reader := call.Call.Reader
	if _, err := io.CopyN(writer, reader, length); err != nil {
		return err
	}

	logrus.Debugf("successfully received %s", outputFile.Name())
	// Send an ACK to the client
	call.Call.Writer.WriteString(fmt.Sprintf("%s:", outputFile.Name()))
	call.Call.Writer.Flush()
	return nil

}

// ReceiveFile allows the varlink server to send a file to a client
func (i *LibpodAPI) ReceiveFile(call iopodman.VarlinkCall, filepath string, delete bool) error {
	if !call.WantsUpgrade() {
		return call.ReplyErrorOccurred("client must use upgraded connection to send files")
	}
	fs, err := os.Open(filepath)
	if err != nil {
		return call.ReplyErrorOccurred(err.Error())
	}
	fileInfo, err := fs.Stat()
	if err != nil {
		return call.ReplyErrorOccurred(err.Error())
	}

	// Send the file length down to client
	// Varlink connection upraded
	if err = call.ReplyReceiveFile(fileInfo.Size()); err != nil {
		return call.ReplyErrorOccurred(err.Error())
	}

	reader := bufio.NewReader(fs)
	_, err = reader.WriteTo(call.Writer)
	if err != nil {
		return err
	}
	if delete {
		if err := os.Remove(filepath); err != nil {
			return err
		}
	}
	return call.Writer.Flush()
}