Skip to content

Commit 75b7614

Browse files
author
Peter Wilhelmsson
committed
Added auth support
1 parent 02d92c5 commit 75b7614

File tree

1 file changed

+15
-1
lines changed

1 file changed

+15
-1
lines changed

testkit-backend/src/main/java/CommandProcessor.java

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929

3030
import org.neo4j.driver.AccessMode;
3131
import org.neo4j.driver.AuthTokens;
32+
import org.neo4j.driver.AuthToken;
3233
import org.neo4j.driver.Bookmark;
3334
import org.neo4j.driver.Driver;
3435
import org.neo4j.driver.GraphDatabase;
@@ -170,7 +171,20 @@ public void processRequest( String request)
170171
{
171172
String id = newId();
172173
String response = Testkit.wrap("Driver", Testkit.id(id));
173-
drivers.putIfAbsent( id, GraphDatabase.driver( requestData.get( "uri" ).asText(), AuthTokens.basic( "neo4j", "pass" ) ) );
174+
175+
String uri = requestData.get("uri").asText();
176+
JsonNode requestAuth = requestData.get("authorizationToken").get("data");
177+
AuthToken authToken;
178+
switch (requestAuth.get("scheme").asText()) {
179+
case "basic":
180+
authToken = AuthTokens.basic(requestAuth.get("principal").asText(), requestAuth.get("credentials").asText(), requestAuth.get("realm").asText());
181+
break;
182+
default:
183+
writeResponse(Testkit.wrap("BackendError", Testkit.msg("Unsupported auth scheme")));
184+
return;
185+
}
186+
187+
drivers.putIfAbsent( id, GraphDatabase.driver(uri, authToken));
174188
writeResponse( response);
175189
} else if ( requestType.equals( "NewSession" ))
176190
{

0 commit comments

Comments
 (0)