// 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" ) func booleanNativeFromBinary(buf []byte) (interface{}, []byte, error) { if len(buf) < 1 { return nil, nil, io.ErrShortBuffer } var b byte b, buf = buf[0], buf[1:] switch b { case byte(0): return false, buf, nil case byte(1): return true, buf, nil default: return nil, nil, fmt.Errorf("cannot decode binary boolean: expected: Go byte(0) or byte(1); received: byte(%d)", b) } } func booleanBinaryFromNative(buf []byte, datum interface{}) ([]byte, error) { value, ok := datum.(bool) if !ok { return nil, fmt.Errorf("cannot encode binary boolean: expected: Go bool; received: %T", datum) } var b byte if value { b = 1 } return append(buf, b), nil } func booleanNativeFromTextual(buf []byte) (interface{}, []byte, error) { if len(buf) < 4 { return nil, nil, fmt.Errorf("cannot decode textual boolean: %s", io.ErrShortBuffer) } if bytes.Equal(buf[:4], []byte("true")) { return true, buf[4:], nil } if len(buf) < 5 { return nil, nil, fmt.Errorf("cannot decode textual boolean: %s", io.ErrShortBuffer) } if bytes.Equal(buf[:5], []byte("false")) { return false, buf[5:], nil } return nil, nil, errors.New("expected false or true") } func booleanTextualFromNative(buf []byte, datum interface{}) ([]byte, error) { value, ok := datum.(bool) if !ok { return nil, fmt.Errorf("boolean: expected: Go bool; received: %T", datum) } if value { return append(buf, "true"...), nil } return append(buf, "false"...), nil }