Package org.aktin.broker.db

Class BrokerImpl

java.lang.Object

org.aktin.broker.db.BrokerImpl

All Implemented Interfaces:

BrokerBackend, Broker

@Singleton
public class BrokerImpl
extends Object
implements BrokerBackend, Broker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BrokerImpl.RequestInfoLoader

Constructor Summary

Constructors

Constructor	Description
BrokerImpl()
BrokerImpl(DataSource brokerDB, Path dataDirectory)

Method Summary

Modifier and Type	Method	Description
Principal	accessPrincipal(AuthInfo auth)	Add or retrieve the node principal.
void	clearDataDirectory()
void	clearRequestTargets(int requestId)
int	createRequest()
int	createRequest(String mediaType, Reader content)
void	deleteRequest(int id)
List<Node>	getAllNodes()
protected int	getLastInsertId(Connection dbc)
Node	getNode(int nodeId)
DigestPathDataSource	getNodeResource(int nodeId, String resourceId)
Reader	getRequestDefinition(int requestId, String mediaType)
RequestInfo	getRequestInfo(int requestId)
Reader	getRequestNodeStatusMessage(int requestId, int nodeId)
int[]	getRequestTargets(int requestId)
List<String>	getRequestTypes(int requestId)
List<RequestInfo>	listAllRequests()
List<RequestStatusInfo>	listRequestNodeStatus(Integer requestId)
List<RequestInfo>	listRequestsForNode(int nodeId)
boolean	markRequestDeletedForNode(int nodeId, int requestId)
List<RequestInfo>	searchAllRequests(String mediaType, String searchLanguage, String predicate)
void	setBrokerDB(DataSource brokerDB)
void	setDataDirectory(Path dataDir)
void	setRequestClosed(int requestId, Instant timestamp)
void	setRequestDefinition(int requestId, String mediaType, Reader content)
void	setRequestNodeStatus(int requestId, int nodeId, RequestStatus status, Instant timestamp)
void	setRequestNodeStatusMessage(int requestId, int nodeId, String mediaType, Reader message)
void	setRequestPublished(int requestId, Instant timestamp)
void	setRequestTargets(int requestId, int[] nodes)
void	updateNodeLastSeen(int[] nodeIds, long[] timestamps)
void	updateNodeResource(int nodeId, String resourceId, javax.ws.rs.core.MediaType mediaType, InputStream content)
static int	updatePrincipalDN(DataSource ds, Map<String,String> mapNodeDN)	Update the clientDN string for the nodes given in the provided map.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.aktin.broker.db.BrokerBackend

updateNodeLastSeen

Constructor Details

BrokerImpl

public BrokerImpl()

BrokerImpl

public BrokerImpl(DataSource brokerDB,
 Path dataDirectory)
           throws IOException

Throws:

IOException

Method Details

setBrokerDB

public void setBrokerDB(DataSource brokerDB)

Specified by:

setBrokerDB in interface BrokerBackend

setDataDirectory

public void setDataDirectory(Path dataDir)

clearDataDirectory

public void clearDataDirectory()
                        throws IOException

Specified by:

clearDataDirectory in interface BrokerBackend

Throws:

IOException

getAllNodes

public List<Node> getAllNodes()
                       throws SQLException

Specified by:

getAllNodes in interface Broker

Throws:

SQLException

getNode

public Node getNode(int nodeId)
             throws SQLException

Specified by:

getNode in interface Broker

Throws:

SQLException

getLastInsertId

protected int getLastInsertId(Connection dbc)
                       throws SQLException

Throws:

SQLException

createRequest

public int createRequest(String mediaType,
 Reader content)
                  throws SQLException

Specified by:

createRequest in interface Broker

Throws:

SQLException

createRequest

public int createRequest()
                  throws SQLException

Specified by:

createRequest in interface Broker

Throws:

SQLException

setRequestDefinition

public void setRequestDefinition(int requestId,
 String mediaType,
 Reader content)
                          throws SQLException

Specified by:

setRequestDefinition in interface Broker

Throws:

SQLException

deleteRequest

public void deleteRequest(int id)
                   throws SQLException

Specified by:

deleteRequest in interface Broker

Throws:

SQLException

listAllRequests

public List<RequestInfo> listAllRequests()
                                  throws SQLException

Specified by:

listAllRequests in interface Broker

Throws:

SQLException

getRequestTypes

public List<String> getRequestTypes(int requestId)
                             throws SQLException

Specified by:

getRequestTypes in interface Broker

Throws:

SQLException

getRequestDefinition

public Reader getRequestDefinition(int requestId,
 String mediaType)
                            throws SQLException,
IOException

Specified by:

getRequestDefinition in interface Broker

Throws:

SQLException

IOException

listRequestsForNode

public List<RequestInfo> listRequestsForNode(int nodeId)
                                      throws SQLException

Specified by:

listRequestsForNode in interface Broker

Throws:

SQLException

getRequestInfo

public RequestInfo getRequestInfo(int requestId)
                           throws SQLException

Specified by:

getRequestInfo in interface Broker

Throws:

SQLException

setRequestNodeStatus

public void setRequestNodeStatus(int requestId,
 int nodeId,
 RequestStatus status,
 Instant timestamp)
                          throws SQLException

Specified by:

setRequestNodeStatus in interface Broker

Throws:

SQLException

setRequestNodeStatusMessage

public void setRequestNodeStatusMessage(int requestId,
 int nodeId,
 String mediaType,
 Reader message)
                                 throws SQLException

Specified by:

setRequestNodeStatusMessage in interface Broker

Throws:

SQLException

getRequestNodeStatusMessage

public Reader getRequestNodeStatusMessage(int requestId,
 int nodeId)
                                   throws SQLException,
IOException

Specified by:

getRequestNodeStatusMessage in interface Broker

Throws:

SQLException

IOException

markRequestDeletedForNode

public boolean markRequestDeletedForNode(int nodeId,
 int requestId)
                                  throws SQLException

Specified by:

markRequestDeletedForNode in interface Broker

Throws:

SQLException

listRequestNodeStatus

public List<RequestStatusInfo> listRequestNodeStatus(Integer requestId)
                                              throws SQLException

Specified by:

listRequestNodeStatus in interface Broker

Throws:

SQLException

accessPrincipal

public Principal accessPrincipal(AuthInfo auth)
                          throws SQLException

Description copied from interface: BrokerBackend

Add or retrieve the node principal. The node is identified by its key. The key can be any string value. It is used as primary identifier and should not change. For API-Key authentication, this can be the API key. For TLS client certificate authentication, this may be the certificate serial number. For external auth, a user id / login name can be used.

Specified by:

accessPrincipal in interface BrokerBackend

Parameters:

auth - authentication information

Returns:

principal

Throws:

SQLException - SQL error

setRequestPublished

public void setRequestPublished(int requestId,
 Instant timestamp)
                         throws SQLException

Specified by:

setRequestPublished in interface Broker

Throws:

SQLException

setRequestClosed

public void setRequestClosed(int requestId,
 Instant timestamp)
                      throws SQLException

Specified by:

setRequestClosed in interface Broker

Throws:

SQLException

updateNodeLastSeen

public void updateNodeLastSeen(int[] nodeIds,
 long[] timestamps)
                        throws SQLException

Specified by:

updateNodeLastSeen in interface BrokerBackend

Throws:

SQLException

setRequestTargets

public void setRequestTargets(int requestId,
 int[] nodes)
                       throws SQLException

Specified by:

setRequestTargets in interface Broker

Throws:

SQLException

getRequestTargets

public int[] getRequestTargets(int requestId)
                        throws SQLException

Specified by:

getRequestTargets in interface Broker

Throws:

SQLException

clearRequestTargets

public void clearRequestTargets(int requestId)
                         throws SQLException

Specified by:

clearRequestTargets in interface Broker

Throws:

SQLException

updateNodeResource

public void updateNodeResource(int nodeId,
 String resourceId,
 javax.ws.rs.core.MediaType mediaType,
 InputStream content)
                        throws IOException,
SQLException

Specified by:

updateNodeResource in interface BrokerBackend

Throws:

IOException

SQLException

getNodeResource

public DigestPathDataSource getNodeResource(int nodeId,
 String resourceId)
                                     throws SQLException

Specified by:

getNodeResource in interface Broker

Throws:

SQLException

updatePrincipalDN

public static int updatePrincipalDN(DataSource ds,
 Map<String,String> mapNodeDN)
                             throws SQLException

Update the clientDN string for the nodes given in the provided map.

Parameters:

ds - data source

mapNodeDN - Map of node keys pointing to clientDN strings

Returns:

number of updated nodes

Throws:

SQLException - SQL error

searchAllRequests

public List<RequestInfo> searchAllRequests(String mediaType,
 String searchLanguage,
 String predicate)
                                    throws IOException

Specified by:

searchAllRequests in interface Broker

Throws:

IOException