null.go

// Copyright [2019] LinkedIn Corp. 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.

package goavro

import (
	"bytes"
	"errors"
	"fmt"
	"io"
)

var nullBytes = []byte("null")

func nullNativeFromBinary(buf []byte) (interface{}, []byte, error) { return nil, buf, nil }

func nullBinaryFromNative(buf []byte, datum interface{}) ([]byte, error) {
	if datum != nil {
		return nil, fmt.Errorf("cannot encode binary null: expected: Go nil; received: %T", datum)
	}
	return buf, nil
}

func nullNativeFromTextual(buf []byte) (interface{}, []byte, error) {
	if len(buf) < 4 {
		return nil, nil, fmt.Errorf("cannot decode textual null: %s", io.ErrShortBuffer)
	}
	if bytes.Equal(buf[:4], nullBytes) {
		return nil, buf[4:], nil
	}
	return nil, nil, errors.New("cannot decode textual null: expected: null")
}

func nullTextualFromNative(buf []byte, datum interface{}) ([]byte, error) {
	if datum != nil {
		return nil, fmt.Errorf("cannot encode textual null: expected: Go nil; received: %T", datum)
	}
	return append(buf, nullBytes...), nil
}