Method CallReceive

server/types/type.go:1168–1184

CallReceive is a way to call the `receive` function for this type.

(ctx *sql.Context, val []byte)

// CallReceive is a way to call the `receive` function for this type.
func (t *DoltgresType) CallReceive(ctx *sql.Context, val []byte) (any, error) {
	if t.TypType == TypeType_Domain {
		return globalFunctionRegistry.GetFunction(ctx, t.ReceiveFunc).CallVariadic(ctx, val, t.BaseTypeType.ID.AsId(), t.attTypMod)
	} else if t.ModInFunc != 0 || t.IsArrayType() {
		if t.Elem.ID != id.NullType {
			return globalFunctionRegistry.GetFunction(ctx, t.ReceiveFunc).CallVariadic(ctx, val, t.Elem.ID.AsId(), t.attTypMod)
		} else {
			return globalFunctionRegistry.GetFunction(ctx, t.ReceiveFunc).CallVariadic(ctx, val, t.ID.AsId(), t.attTypMod)
		}
	} else if t.TypType == TypeType_Enum {
		return globalFunctionRegistry.GetFunction(ctx, t.ReceiveFunc).CallVariadic(ctx, val, t.ID.AsId())
	} else if t.IsCompositeType() {
		return globalFunctionRegistry.GetFunction(ctx, t.ReceiveFunc).CallVariadic(ctx, val, t.ID.AsId(), t.attTypMod)
	} else {
		return globalFunctionRegistry.GetFunction(ctx, t.ReceiveFunc).CallVariadic(ctx, val)
	}
}

// ConvertSerialized implements the val.TupleTypeHandler interface.
func (t *DoltgresType) ConvertSerialized(ctx context.Context, other val.TupleTypeHandler, val []byte) ([]byte, error) {