Metacat

move CNReplicationTask to the hazelcast package

only "save" to the shared system metadata map - not directly to the table store.

rely on Hazelcast to store the SystemMetadata locally for the node. Entry event listeners store the shared system metadata on their local node when alerted. TODO: remove old replication code that included system metadata xml when replicating scimeta and data

move bulk of the Hazelcast code into HazelcastService from CNodeService so that it is centrall located - easier to manage and configure

initialize Hazelcast from the custom configuration when initializing the Metacat service.

handle entryAdded and entryUpdated the same - update the entry if it exists, otherwise create it

handle entryAdded (to hzSystemMetadata) to store sysmeta to local store when it is not already present

add code to handle new entry when it is not on the local member of the sysmeta cluster

comment out processCluster connections that use hzClient until that is finalized

use pending replication task queue to check if node is authorized for replication. moved from old ReplicationService code

Add stub methods in CNodeService that implement the Hazelcast EntryListener interface: entryAdded(), entryRemoved(), entryUpdated(), and entryEvicted(). Add a listener to the hzSystemMetadata map so the CNodeService can respond to those events and create appropriate CNReplicationTask objects for distributed execution across the CN cluster. Again, stubs only so far.

Minor cleanup - tabs to spaces.

Enable CNodeService to access 1) the hzNodes map defined in the DataONE process cluster by becoming a Hazelcast client (hzClient) to that cluster and 2) the hzSystemMetadata map defined in the DataONE storage cluster by becoming a member to that cluster (using direct Hazelcast calls). Added fields for maintaining the DataONE cluster properties.

changes for schema update (d1_common)

Update classes to use the DataONE 0.6.4 schema and types. Major changes involve using BigInteger vs long in SystemMetadata.size, and using ObjectFormatIdentifier rather than Object format.

latest D1 jars - changes include:
updateSystemMetadata() impl for CN
new identifier methods (generate is its own method)
removal of the resourceMap pointer from system metadata

use new "v1" types from DataONE

add hasReservation() method (NotImplemented, however)

use objectFormatIdentifier for listObjects()
remove provisional system metadata indicator - Metacat will not implement reserveIdentifier()

allow very minimal system metadata for provisional entries (CN.reserveIdentifier)

remove resolve() test -- not implemented in Metacat

catch exceptions from system meta data query and throw service failure rather than swallowing them with an error msg

use super class' create() method
use string comparison for assertRelation method

return all public objects for the search() method [for now]

add the old ecogrid query code (still commented out) from the old Rest handler

implement reserveIdentifier() and check whether the id is reserved when creating records (only allow the create when the Subject creating matches the Subject who reserved it -- currently stored in rightsHolder)

remove extraneous update() call when create() does the call for us

At Ben's suggestion, add metacatUrl to D1NodeService and make it available to subclasses. Set the metacatUrl in the constructor using SystemUtil rather than all roll your own PropertyService calls. More concise. Also, log the delete event in MNodeService.delete().

Implement [MN|CN]Storage.create() in D1NodeService. Since MetacatHandler requires an IP for event logging, we pass in the metacat URL (hold over from CrudService). To do this in the abstract D1NodeService, change the constructors to take metacatUrl as a parameter and get the URL from the metacat properties file in getInstance() of the subclasses. Needs testing.

include URL in resolve() method as well as placeholder for preference

Metacat does not implement CNRegister

-use every Subject in the session (alt Ids and Group membership)
-consolidate to single isAuthorized method

throw exception for unimplemented methods

implement resolve() method

implement assertRelation

implement CNReplication.setReplicationStatus() but with a note about selecting which replica's status should be set (right now it is all)

implement CNReplication.setReplicationPolicy

correction: implementation is CN-specific

implement getChecksum() in the superclass

implement getChecksum (retrieves from system metadata)

use shared get() method from superclass

use shared getLogRecords method

implement CNAuthorization

Metacat does not implement CNIdentity - it is a stand-alone service

implement registerSystemMetadata

implement object format methods - using a separate class to do the actual metacat lookup/caching so that teh CN implementation looks cleaner

Initial check in of the MNodeService stub methods that implement the D1 MN* interfaces. CrudService methods will be transitioned into this class. The methods follow the D1 0.6.2 API thus far.

Also changed CNodeService to reflect minor changes to the D1NodeService class.

Add a static getInstance() method to CNodeService and make CNodeService a singleton.

Initial check in of the CNodeService stub methods that implement the D1 CN* interfaces. CNCoreImpl methods will be transitioned into this class. The methods follow the D1 0.6.2 API thus far.