Method LargeFileReceive

server/hdl_files.go:447–576

LargeFileReceive is the gRPC equivalent of LargeFileReceiveHTTP.

(stream pbx.Node_LargeFileReceiveServer)

// LargeFileReceive is the gRPC equivalent of LargeFileReceiveHTTP.
func (*grpcNodeServer) LargeFileReceive(stream pbx.Node_LargeFileReceiveServer) error {
	now := types.TimeNow()
	mh := store.Store.GetMediaHandler()

	writeResponse := func(msg *ServerComMessage, err error) {
		stream.SendAndClose(&pbx.FileUpResp{Id: msg.Ctrl.Id, Code: int32(msg.Ctrl.Code), Text: msg.Ctrl.Text})
		if err != nil {
			logs.Info.Println("media receive:", msg.Ctrl.Code, msg.Ctrl.Text, "/", err)
		}
	}

	req, err := stream.Recv()
	if err != nil {
		if errors.Is(err, io.EOF) {
			writeResponse(ErrDisconnected("", "", now), err)
		} else {
			writeResponse(decodeStoreError(err, "", now, nil), err)
		}
		return nil
	}

	msgID := req.GetId()
	// Check authorization: auth information must be present (SID is not used for gRPC).
	authMethod, secret := req.Auth.Scheme, req.Auth.Secret
	var remoteAddr string
	if p, ok := peer.FromContext(stream.Context()); ok {
		remoteAddr = p.Addr.String()
	}
	uid, challenge, err := authFileRequest(authMethod, secret, "", remoteAddr)
	if err != nil {
		writeResponse(decodeStoreError(err, msgID, now, nil), err)
		return nil
	}

	if challenge != nil {
		writeResponse(InfoChallenge(msgID, now, challenge), nil)
		return nil
	}

	if uid.IsZero() {
		// Not authenticated
		writeResponse(ErrAuthRequired(msgID, "", now, now), errors.New("user not authenticated"))
		return nil
	}

	// Check if uploads are handled elsewhere.
	headers, statusCode, err := mh.Headers(http.MethodPost, nil, http.Header{}, false)
	if err != nil {
		logs.Info.Println("media upload: headers check failed", err)
		writeResponse(decodeStoreError(err, "", now, nil), nil)
		return nil
	}

	if statusCode != 0 {
		// The handler requested to terminate further processing.
		err = stream.SendAndClose(&pbx.FileUpResp{
			Id:       msgID,
			Code:     int32(statusCode),