require "uuid"
require "../spec_helper"

describe PG::Decoders do
  #           name,             sql,              result
  test_decode "undefined    ", "'what'         ", "what"
  test_decode "text         ", "'what'::text   ", "what"
  test_decode "varchar      ", "'wh'::varchar  ", "wh"
  test_decode "empty strings", "''             ", ""
  test_decode "null as nil  ", "null           ", nil
  test_decode "boolean false", "false          ", false
  test_decode "boolean true ", "true           ", true
  test_decode "int2 smallint", "1::int2        ", 1
  test_decode "int2 smallint", "-1::int2       ", -1
  test_decode "int4 int     ", "1::int4        ", 1
  test_decode "int4 int     ", "-1::int4       ", -1
  test_decode "int8 bigint  ", "1::int8        ", 1
  test_decode "int8 bigint  ", "-1::int8       ", -1
  test_decode "bigint       ", "12928394059603 ", 12928394059603
  test_decode "bigint       ", "-12928394059603", -12928394059603
  test_decode "float        ", "0.123::float   ", 0.123
  test_decode "float        ", "-0.123::float  ", -0.123
  test_decode "regtype      ", "pg_typeof(3)   ", 23

  test_decode "uint64       ", "'FFFFFFFF/FFFFFFFF'::pg_lsn", 18446744073709551615_u64

  test_decode "double prec.", "'35.03554004971999'::float8", 35.03554004971999
  test_decode "flot prec.", "'0.10000122'::float4", 0.10000122_f32

  test_decode "bytea", "E'\\\\001\\\\134\\\\176'::bytea",
    Slice(UInt8).new(UInt8[0o001, 0o134, 0o176].to_unsafe, 3)
  test_decode "bytea", "E'\\\\005\\\\000\\\\377\\\\200'::bytea",
    Slice(UInt8).new(UInt8[5, 0, 255, 128].to_unsafe, 4)
  test_decode "bytea empty", "E''::bytea",
    Slice(UInt8).new(UInt8[].to_unsafe, 0)

  test_decode "uuid", "'7d61d548124c4b38bc05cfbb88cfd1d1'::uuid",
    UUID.new("7d61d548-124c-4b38-bc05-cfbb88cfd1d1")
  test_decode "uuid", "'7d61d548-124c-4b38-bc05-cfbb88cfd1d1'::uuid",
    UUID.new("7d61d548-124c-4b38-bc05-cfbb88cfd1d1")

  if Helper.db_version_gte(9, 2)
    test_decode "json", %('[1,"a",true]'::json), JSON::PullParser.new(%([1,"a",true]))
    test_decode "json", %('{"a":1}'::json), JSON::PullParser.new(%({"a":1}))
  end
  if Helper.db_version_gte(9, 4)
    test_decode "jsonb", "'[1,2,3]'::jsonb", JSON::PullParser.new("[1,2,3]")
  end

  test_decode "timestamptz", "'2015-02-03 16:15:13-01'::timestamptz",
    Time.utc(2015, 2, 3, 17, 15, 13)

  test_decode "timestamptz", "'2015-02-03 16:15:14.23-01'::timestamptz",
    Time.utc(2015, 2, 3, 17, 15, 14, nanosecond: 230_000_000)

  test_decode "timestamptz", "'2015-02-03 16:15:14.23 America/New_York'::timestamptz",
    Time.local(2015, 2, 3, 16, 15, 14, nanosecond: 230_000_000, location: Time::Location.load("America/New_York")),
    time_zone: Time::Location.load("America/New_York")

  test_decode "timestamp", "'2015-02-03 16:15:15'::timestamp",
    Time.utc(2015, 2, 3, 16, 15, 15)

  test_decode "date", "'2015-02-03'::date",
    Time.utc(2015, 2, 3, 0, 0, 0)

  # -14706000000 = microseconds in -4 hours, -5 minutes -6 seconds
  test_decode "interval", "'P-1Y-2M3DT-4H-5M-6S'::interval", PG::Interval.new(-14706000000, 3, -14)
  test_decode "interval", "'178000000 years'::interval", PG::Interval.new(0, 0, 2_136_000_000)
  test_decode "interval", "'178000000 years 1 months 5 days 999999 microseconds'::interval", PG::Interval.new(999_999, 5, 2_136_000_001)

  it "numeric" do
    x = ->(q : String) do
      PG_DB.query_one "select '#{q}'::numeric", &.read(PG::Numeric)
    end
    x.call("1.3").to_f.should eq(1.3)
    x.call("nan").nan?.should be_true
  end

  it "decodes many uuids (#148)" do
    uuid = UUID.new("aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa")
    ids = PG_DB.query_all("select '#{uuid}'::uuid from generate_series(1,1000)", as: UUID)
    ids.uniq.should eq([uuid])
  end

  test_decode "xml", "'<json>false</json>'::xml", "<json>false</json>"
  test_decode "char", %('c'::"char"), 'c'
  test_decode "bpchar", %('c'::char), "c"
  test_decode "bpchar", %('c'::char(5)), "c    "
  test_decode "name", %('hi'::name), "hi"
  test_decode "oid", %(2147483648::oid), 2147483648_u32
  test_decode "point", "'(1.2,3.4)'::point", PG::Geo::Point.new(1.2, 3.4)
  if Helper.db_version_gte(9, 4)
    test_decode "line ", "'(1,2,3,4)'::line ", PG::Geo::Line.new(1.0, -1.0, 1.0)
    test_decode "line ", "'1,2,3'::circle   ", PG::Geo::Circle.new(1.0, 2.0, 3.0)
  end
  test_decode "lseg ", "'(1,2,3,4)'::lseg ", PG::Geo::LineSegment.new(1.0, 2.0, 3.0, 4.0)
  test_decode "box  ", "'(1,2,3,4)'::box  ", PG::Geo::Box.new(1.0, 2.0, 3.0, 4.0)
  test_decode "path ", "'(1,2,3,4)'::path ", PG::Geo::Path.new([PG::Geo::Point.new(1.0, 2.0), PG::Geo::Point.new(3.0, 4.0)], closed: true)
  test_decode "path ", "'[1,2,3,4,5,6]'::path", PG::Geo::Path.new([PG::Geo::Point.new(1.0, 2.0), PG::Geo::Point.new(3.0, 4.0), PG::Geo::Point.new(5.0, 6.0)], closed: false)
  test_decode "polygon", "'1,2,3,4,5,6'::polygon", PG::Geo::Polygon.new([PG::Geo::Point.new(1.0, 2.0), PG::Geo::Point.new(3.0, 4.0), PG::Geo::Point.new(5.0, 6.0)])
end