Bytes.hs

{-# language BangPatterns #-}
{-# language DataKinds #-}
{-# language NamedFieldPuns #-}

module Socket.Destined.IPv4.Bytes
  ( Buffer
  , Peer
  , advance
  , length
  , send
  ) where

import Prelude hiding (length)

import Data.Bytes.Types (Bytes(Bytes))
import Foreign.C.Error (Errno)
import Foreign.C.Types (CInt,CSize)
import Net.Types (IPv4(..))
import Socket.IPv4 (Peer(..))
import Socket.Bytes (advance,length)
import System.Posix.Types (Fd)
import qualified Posix.Socket as S

type Buffer = Bytes

send :: Peer -> Fd -> Buffer -> IO (Either Errno CSize)
send !dst !sock (Bytes arr off len) =
  S.uninterruptibleSendToInternetByteArray sock arr
    (intToCInt off)
    (intToCSize len)
    mempty
    (endpointToSocketAddressInternet dst)

endpointToSocketAddressInternet :: Peer -> S.SocketAddressInternet
endpointToSocketAddressInternet (Peer {address, port}) =
  S.SocketAddressInternet
    { S.port = S.hostToNetworkShort port
    , S.address = S.hostToNetworkLong (getIPv4 address)
    }

intToCInt :: Int -> CInt
intToCInt = fromIntegral

intToCSize :: Int -> CSize
intToCSize = fromIntegral