Skip to content

Commit

Permalink
Add inet DBType (circuithub#227)
Browse files Browse the repository at this point in the history
  • Loading branch information
JonathanLorimer authored Apr 14, 2023
1 parent bbc97ea commit ecf34ae
Show file tree
Hide file tree
Showing 3 changed files with 40 additions and 2 deletions.
5 changes: 4 additions & 1 deletion rel8.cabal
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,8 @@ library
, case-insensitive
, comonad
, contravariant
, hasql ^>= 1.4.5.1 || ^>= 1.5.0.0 || ^>= 1.6.0.0
, hasql ^>= 1.6.1.2
, network-ip
, opaleye ^>= 0.9.6.1
, pretty
, profunctors
Expand Down Expand Up @@ -212,10 +213,12 @@ test-suite tests
, bytestring
, case-insensitive
, containers
, data-dword
, hasql
, hasql-transaction
, hedgehog ^>= 1.0 || ^>= 1.1
, mmorph
, network-ip
, rel8
, scientific
, tasty
Expand Down
11 changes: 11 additions & 0 deletions src/Rel8/Type.hs
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,8 @@ import Data.Time.Format ( formatTime, defaultTimeLocale )
import Data.UUID ( UUID )
import qualified Data.UUID as UUID

-- ip
import Network.IP.Addr (NetAddr, IP, printNetAddr)

-- | Haskell types that can be represented as expressions in a database. There
-- should be an instance of @DBType@ for all column types in your database
Expand Down Expand Up @@ -279,6 +281,15 @@ instance DBType Value where
, typeName = "jsonb"
}

-- | Corresponds to @inet@
instance DBType (NetAddr IP) where
typeInformation = TypeInformation
{ encode =
Opaleye.ConstExpr . Opaleye.StringLit . printNetAddr
, decode = Hasql.inet
, typeName = "inet"
}


instance Sql DBType a => DBType [a] where
typeInformation = listTypeInformation nullable typeInformation
Expand Down
26 changes: 25 additions & 1 deletion tests/Main.hs
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ import Data.Int ( Int32, Int64 )
import Data.List ( nub, sort )
import Data.Maybe ( catMaybes )
import Data.String ( fromString )
import Data.Word (Word32)
import Data.Word (Word32, Word8)
import GHC.Generics ( Generic )

-- bytestring
Expand Down Expand Up @@ -87,6 +87,9 @@ import qualified Database.Postgres.Temp as TmpPostgres
-- uuid
import qualified Data.UUID

-- ip
import Network.IP.Addr (NetAddr, IP, IP4(..), IP6(..), IP46(..), net4Addr, net6Addr, fromNetAddr46, Net4Addr, Net6Addr)
import Data.DoubleWord (Word128(..))

main :: IO ()
main = defaultMain tests
Expand Down Expand Up @@ -425,6 +428,7 @@ testDBType getTestDatabase = testGroup "DBType instances"
, dbTypeTest "TimeOfDay" genTimeOfDay
, dbTypeTest "UTCTime" $ UTCTime <$> genDay <*> genDiffTime
, dbTypeTest "UUID" $ Data.UUID.fromWords <$> genWord32 <*> genWord32 <*> genWord32 <*> genWord32
, dbTypeTest "INet" genNetAddrIP
]

where
Expand Down Expand Up @@ -469,6 +473,26 @@ testDBType getTestDatabase = testGroup "DBType instances"
genWord32 :: Gen Word32
genWord32 = Gen.integral Range.linearBounded

genWord128 :: Gen Word128
genWord128 = Gen.integral Range.linearBounded

genNetAddrIP :: Gen (NetAddr IP)
genNetAddrIP =
let
genIP4Mask :: Gen Word8
genIP4Mask = Gen.integral (Range.linearFrom 0 0 32)

genIPv4 :: Gen (IP46 Net4Addr Net6Addr)
genIPv4 = IPv4 <$> (liftA2 net4Addr (IP4 <$> genWord32) genIP4Mask)

genIP6Mask :: Gen Word8
genIP6Mask = Gen.integral (Range.linearFrom 0 0 128)

genIPv6 :: Gen (IP46 Net4Addr Net6Addr)
genIPv6 = IPv6 <$> (liftA2 net6Addr (IP6 <$> genWord128) genIP6Mask)

in fromNetAddr46 <$> Gen.choice [ genIPv4, genIPv6 ]


testDBEq :: IO TmpPostgres.DB -> TestTree
testDBEq getTestDatabase = testGroup "DBEq instances"
Expand Down

0 comments on commit ecf34ae

Please sign in to comment.