Data.Acid.Remote

This module provides the ability perform update and query calls from a remote process.

On the server-side you:

1. open your AcidState normally
2. then use acidServer to share the state

On the client-side you:

1. use openRemoteState to connect to the remote state
2. use the returned AcidState like any other AcidState handle

openRemoteState and acidServer communicate over an unencrypted socket. If you need an encrypted connection, see acid-state-tls.

On Unix®-like systems you can use SockAddrUnix to create a socket file for local communication between the client and server. Access can be controlled by setting the permissions of the parent directory containing the socket file.

It is also possible to perform some simple authentication using sharedSecretCheck and sharedSecretPerform. Keep in mind that secrets will be sent in plain-text if you do not use acid-state-tls. If you are using a SockAddrUnix additional authentication may not be required, so you can use skipAuthenticationCheck and skipAuthenticationPerform.

Working with a remote AcidState is nearly identical to working with a local AcidState with a few important differences.

The connection to the remote AcidState can be lost. The client will automatically attempt to reconnect every second. Because query events do not affect the state, an aborted query will be retried automatically after the server is reconnected.

If the connection was lost during an update event, the event will not be retried. Instead RemoteConnectionError will be raised. This is because it is impossible for the client to know if the aborted update completed on the server-side or not.

When using a local AcidState, an update event in one thread does not block query events taking place in other threads. With a remote connection, all queries and requests are channeled over a single connection. As a result, updates and queries are performed in the order they are executed and do block each other. In the rare case where this is an issue, you could create one remote connection per thread.

When working with local state, a query or update which returns the whole state is not usually a problem due to memory sharing. The update/query event basically just needs to return a pointer to the data already in memory. But, when working remotely, the entire result will be serialized and sent to the remote client. Hence, it is good practice to create queries and updates that will only return the required data.

This module is designed to be extenible. You can easily add your own authentication methods by creating a suitable pair of functions and passing them to acidServer and openRemoteState.

It is also possible to create alternative communication layers using CommChannel, process, and processRemoteState.

Server/Client

acidServer

Arguments

:: (CommChannel -> IO Bool)

check authentication, see sharedSecretPerform

-> PortNumber

Port to listen on

-> AcidState st

state to serve

-> IO ()

Accept connections on port and handle requests using the given AcidState. This call doesn't return.

see also: acidServerSockAddr, openRemoteState and sharedSecretCheck.

acidServerSockAddr

Arguments

:: (CommChannel -> IO Bool)

check authentication, see sharedSecretPerform

-> SockAddr

SockAddr to listen on

-> AcidState st

state to serve

-> IO ()

Accept connections on sockAddr and handle requests using the given AcidState. This call doesn't return.

see also: acidServer, openRemoteState and sharedSecretCheck.

acidServer'

Arguments

:: (CommChannel -> IO Bool)

check authentication, see sharedSecretPerform

-> Socket

binded socket to accept connections from

-> AcidState st

state to serve

-> IO ()

Works the same way as acidServer, but uses pre-binded socket listenSocket.

Can be useful when fine-tuning of socket binding parameters is needed (for example, listening on a particular network interface, IPv4/IPv6 options).

openRemoteState

Arguments

:: IsAcidic st

=> (CommChannel -> IO ())

authentication function, see sharedSecretPerform

-> HostName

remote host to connect to

-> PortNumber

remote port to connect to

-> IO (AcidState st)

Connect to an acid-state server which is sharing an AcidState.

openRemoteStateSockAddr

Arguments

:: IsAcidic st

=> (CommChannel -> IO ())

authentication function, see sharedSecretPerform

-> SockAddr

remote SockAddr to connect to

-> IO (AcidState st)

Connect to an acid-state server which is sharing an AcidState.

Authentication

skipAuthenticationCheck :: CommChannel -> IO Bool

skip server-side authentication checking entirely.

skipAuthenticationPerform :: CommChannel -> IO ()

skip client-side authentication entirely.

sharedSecretCheck

Arguments

:: Set ByteString

set of shared secrets

-> CommChannel -> IO Bool

check that the client knows a shared secret.

The function takes a Set of shared secrets. If a client knows any of them, it is considered to be trusted.

The shared secret is any ByteString of your choice.

If you give each client a different shared secret then you can revoke access individually.

see also: sharedSecretPerform

sharedSecretPerform

Arguments

:: ByteString

shared secret

-> CommChannel -> IO ()

attempt to authenticate with the server using a shared secret.

Exception type

data AcidRemoteException

Constructors

RemoteConnectionError

AcidStateClosed

SerializeError String

AuthenticationError String

Instances

Exception AcidRemoteException

Defined in Data.Acid.Remote

Methods

toException :: AcidRemoteException -> SomeException

fromException :: SomeException -> Maybe AcidRemoteException

displayException :: AcidRemoteException -> String

Show AcidRemoteException

Defined in Data.Acid.Remote

Methods

showsPrec :: Int -> AcidRemoteException -> ShowS

show :: AcidRemoteException -> String

showList :: [AcidRemoteException] -> ShowS

Eq AcidRemoteException

Defined in Data.Acid.Remote

Methods

(==) :: AcidRemoteException -> AcidRemoteException -> Bool

(/=) :: AcidRemoteException -> AcidRemoteException -> Bool

Low-Level functions needed to implement additional communication channels

data CommChannel

CommChannel is a record containing the IO functions we need for communication between the server and client.

We abstract this out of the core processing function so that we can easily add support for SSL/TLS and Unit testing.

Constructors

CommChannel

Fields

• ccPut :: ByteString -> IO ()
• ccGetSome :: Int -> IO ByteString
• ccClose :: IO ()

process

Arguments

:: CommChannel

a connected, authenticated communication channel

-> AcidState st

state to share

-> IO ()

Server inner-loop

This function is generally only needed if you are adding a new communication channel.

processRemoteState

Arguments

:: IsAcidic st

=> IO CommChannel

(re-)connect function

-> IO (AcidState st)

Client inner-loop

This function is generally only needed if you are adding a new communication channel.