Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Introuduce SPI for SSM to make testing it easier
- Loading branch information
Showing
3 changed files
with
193 additions
and
42 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
102 changes: 102 additions & 0 deletions
102
community/bolt/src/main/java/org/neo4j/bolt/v1/runtime/internal/StandardStateMachineSPI.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,102 @@ | ||
| package org.neo4j.bolt.v1.runtime.internal; | ||
|
|
||
| import java.util.Map; | ||
|
|
||
| import org.neo4j.bolt.security.auth.Authentication; | ||
| import org.neo4j.bolt.security.auth.AuthenticationException; | ||
| import org.neo4j.bolt.v1.runtime.spi.RecordStream; | ||
| import org.neo4j.bolt.v1.runtime.spi.StatementRunner; | ||
| import org.neo4j.concurrent.DecayingFlags; | ||
| import org.neo4j.kernel.api.AccessMode; | ||
| import org.neo4j.kernel.api.KernelTransaction; | ||
| import org.neo4j.kernel.api.Statement; | ||
| import org.neo4j.kernel.api.exceptions.KernelException; | ||
| import org.neo4j.kernel.impl.core.ThreadToStatementContextBridge; | ||
| import org.neo4j.kernel.impl.factory.GraphDatabaseFacade; | ||
| import org.neo4j.kernel.impl.logging.LogService; | ||
| import org.neo4j.logging.Log; | ||
| import org.neo4j.udc.UsageData; | ||
| import org.neo4j.udc.UsageDataKeys; | ||
|
|
||
| class StandardStateMachineSPI implements SessionStateMachine.SPI | ||
| { | ||
| private final UsageData usageData; | ||
| private final GraphDatabaseFacade db; | ||
| private final StatementRunner statementRunner; | ||
| private final ErrorReporter errorReporter; | ||
| private final Log log; | ||
| private final Authentication authentication; | ||
| private final ThreadToStatementContextBridge txBridge; | ||
| private final DecayingFlags featureUsage; | ||
|
|
||
| StandardStateMachineSPI( UsageData usageData, GraphDatabaseFacade db, StatementRunner statementRunner, | ||
| LogService logging, Authentication authentication, ThreadToStatementContextBridge txBridge ) | ||
| { | ||
| this.usageData = usageData; | ||
| this.db = db; | ||
| this.statementRunner = statementRunner; | ||
| this.txBridge = txBridge; | ||
| this.featureUsage = usageData.get( UsageDataKeys.features ); | ||
| this.errorReporter = new ErrorReporter( logging, this.usageData ); | ||
| this.log = logging.getInternalLog( SessionStateMachine.class ); | ||
| this.authentication = authentication; | ||
| } | ||
|
|
||
| @Override | ||
| public void reportError( Neo4jError err ) | ||
| { | ||
| errorReporter.report( err ); | ||
| } | ||
|
|
||
| @Override | ||
| public void reportError( String message, Throwable cause ) | ||
| { | ||
| log.error( message, cause ); | ||
| } | ||
|
|
||
| @Override | ||
| public KernelTransaction beginTransaction( KernelTransaction.Type type, AccessMode mode ) | ||
| { | ||
| db.beginTransaction( type, mode ); | ||
| return txBridge.getKernelTransactionBoundToThisThread( false ); | ||
| } | ||
|
|
||
| @Override | ||
| public void bindTransactionToCurrentThread( KernelTransaction tx ) | ||
| { | ||
| txBridge.bindTransactionToCurrentThread( tx ); | ||
| } | ||
|
|
||
| @Override | ||
| public void unbindTransactionFromCurrentThread() | ||
| { | ||
| txBridge.unbindTransactionFromCurrentThread(); | ||
| } | ||
|
|
||
| @Override | ||
| public RecordStream run( SessionStateMachine ctx, String statement, Map<String,Object> params ) | ||
| throws KernelException | ||
| { | ||
|
|
||
| featureUsage.flag( UsageDataKeys.Features.bolt ); | ||
| return statementRunner.run( ctx, statement, params ); | ||
| } | ||
|
|
||
| @Override | ||
| public void authenticate( Map<String,Object> authToken ) throws AuthenticationException | ||
| { | ||
| authentication.authenticate( authToken ); | ||
| } | ||
|
|
||
| @Override | ||
| public void udcRegisterClient( String clientName ) | ||
| { | ||
| usageData.get( UsageDataKeys.clientNames ).add( clientName ); | ||
| } | ||
|
|
||
| @Override | ||
| public Statement currentStatement() | ||
| { | ||
| return txBridge.get(); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters