# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You 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.
# See the License for the specific language governing permissions and
# limitations under the License.

use strict;
use warnings;
use lib 'buildlib';

use Test::More tests => 5;
use Carp;
use File::Spec::Functions qw( tmpdir catdir catfile );
use Lucy::Test::TestUtils qw( init_test_index_loc );

sub slurp_file {
    my $path = shift;
    open( my $fh, '<', $path ) or confess "Couldn't open '$path': $!";
    local $/;
    return <$fh>;
}

my $dir      = init_test_index_loc();
my $filename = 'hogus_bogus';
my $filepath = catfile( $dir, $filename );
my ( $outstream, $instream );
my $folder = Lucy::Store::FSFolder->new( path => $dir );
my $foo;

sub new_outstream {
    undef $outstream;
    unlink $filepath;
    my $fh = Lucy::Store::FSFileHandle->open(
        path       => $filepath,
        create     => 1,
        write_only => 1,
        exclusive  => 1,
    );
    my $outstream = Lucy::Store::OutStream->open( file => $fh )
        or confess Clownfish->error;
    return $outstream;
}

sub new_instream {
    undef $instream;
    return $folder->open_in($filename) || confess Clownfish->error;
}

$outstream = new_outstream();
$outstream->print("foo");
$outstream->close;
$instream = new_instream();
undef $foo;
$instream->read( $foo, 3 );
is( $foo, "foo", "outstream writes, instream reads" );
$instream->close;

my $long_string = 'a' x 5000;
$outstream = new_outstream();
$outstream->print( 'foo', $long_string );
$outstream->close;
$instream = new_instream();
undef $foo;
$instream->read( $foo, 5003 );
is( $foo, "foo$long_string", "long string" );

eval { my $blah; $instream->read( $blah, 2 ) };
like( $@, qr/EOF/, "reading past EOF throws an error" );
undef $instream;

$outstream = new_outstream();
$outstream->print( 'a' x 1024 );
$outstream->print('foo');
$outstream->close;

$instream = new_instream();
$instream->seek(1024);
undef $foo;
$instream->read( $foo, 3 );
is( $foo, 'foo', "InStream seek" );

my $dupe = $instream->reopen(
    filename => 'foo',
    offset   => 1023,
    len      => 4
);
undef $foo;
$dupe->read( $foo, 4 );

is( $foo, 'afoo', "reopened instream" );

# Trigger destruction.
undef $folder;