Add config for dClent

This commit is contained in:
James Quinley
2022-01-23 16:53:12 -08:00
parent 1b3635d011
commit df3971294c
7 changed files with 128 additions and 10 deletions

View File

@ -0,0 +1,30 @@
package com.jamesquinley.DelegationServices;
import com.mongodb.ConnectionString;
import com.mongodb.MongoClientSettings;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import static java.util.concurrent.TimeUnit.SECONDS;
public class delegationServices {
static ConnectionString scReadconnectionString = new ConnectionString("mongodb+srv://serverClient:ej2ookJGgpV6JyFS@accountdelegation.n06hb.mongodb.net/myFirstDatabase?retryWrites=true&w=majoritymongodb+srv://client:dPMtaqHXJSpPaX3d@socialcreditdatabase.rqsyf.mongodb.net/socialCreditDatabase?retryWrites=true&w=majority");
static MongoClientSettings scReadsettings = MongoClientSettings.builder()
.applyConnectionString(scReadconnectionString)
.applyToSocketSettings(builder ->
builder.connectTimeout(5, SECONDS)
.readTimeout(6, SECONDS))
.build();
static MongoClient dClient = MongoClients.create(scReadsettings);
static MongoDatabase dClientDatabase = dClient.getDatabase("DelegationRequest");
static MongoCollection<Document> dCollection = dClientDatabase.getCollection("accountRequest");
//still need to config
public static void delegationProcesser () {
System.out.println("delegation Trigger Set");
delegationTimer.trigger();
}
}

View File

@ -0,0 +1,24 @@
package com.jamesquinley.DelegationServices;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class delegationTimer {
public static void trigger ()
{
final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
final Runnable runnable = new Runnable() {
int countdownStarter = 5;
public void run() {
countdownStarter--;
if (countdownStarter <= 0) {
countdownStarter = 5;
delegationServices.delegationProcesser();
scheduler.shutdown();
}
}
};
scheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);
}
}

View File

@ -1,7 +1,7 @@
package com.jamesquinley;
/**
* Hello world!
Hey there! This is the source code for AOTSK-Delegation Server, for login
*
*/
public class startup
@ -9,6 +9,6 @@ public class startup
public static void main( String[] args )
{
System.out.println( "We're starting the login delegation server, please wait one moment while we check a few things.");
com.jamesquinley.DelegationServices.delegationTimer.trigger();
}
}