Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Creative commons Attribution-NonCommercial license. http://creativecommons.org/licenses/by-nc/2.5/au/deed.en_GB NO WARRANTY IS GIVEN OR IMPLIED, USE AT YOUR OWN RISK.
  
  package base.jee.api.cassandra;
  
 import base.KeyValue;
 import base.Throttle;
 
 
 
 import java.util.List;
 import java.util.Set;
 import java.util.UUID;
 
 public class CassandraAPI implements API {
 
 	private DataSource ds;
 	private Settings settings;
 
 	private Session session;
 
 	public CassandraAPI(String hostString keyspaceString emailDbthrows ClassNotFoundExceptionSQLExceptionIOException {
 
 		Cluster cluster = new Cluster.Builder().addContactPoints(host).build();
 
 		int maxConnections = 3;
 
 		pools.setCoreConnectionsPerHost(.maxConnections);
 		pools.setMaxConnectionsPerHost(.maxConnections);
 		pools.setCoreConnectionsPerHost(.maxConnections);
 		pools.setMaxConnectionsPerHost(.maxConnections);
 
 		 = cluster.connect(keyspace);
 
 		Metadata metadata = cluster.getMetadata();
 		..println(String.format("Connected to cluster '%s' on %s."metadata.getClusterName(), metadata.getAllHosts()));
 
 		Class.forName("org.sqlite.JDBC");
 		SQLiteConfig config = new SQLiteConfig();
 		config.setSharedCache(true);
 		.setUrl("jdbc:sqlite:" + emailDb);
 
 		new Setup(this).run();
 
 		 = new Settings(this);
 
 		if(.get("log.hidden.ip"null) == null) {
 			.set("log.hidden.ip""");
 		}
 
 		// Initialise default throttle settings
 		new Throttle("auth", 300, 3, 60);
 		new Throttle("ip", 60, 10, 10);
 	}
 
 		return ;
 	}
 
		return ;
	}
		return ;
	}
	public void initialSetup(String firstNameString lastNameString emailAddressString usernameString passwordString smtpHostnameint smtpPortboolean selfSignupString ipthrows PermissionExceptionIOException {
		new InitialSetup(thisfirstNamelastNameemailAddressusernamepasswordsmtpHostnamesmtpPortselfSignupip).run();
	}
	public void registerApiCalls(JeeBase jee) {
		jee.add(new Authenticate());
		jee.add(new CreatePerson());
		jee.add(new GetBatchResults());
		jee.add(new GetGroup());
		jee.add(new GetGroups());
		jee.add(new GetGroupMembers());
		jee.add(new GetGroupRoles());
		jee.add(new GetPerson());
		jee.add(new GetPersonByEmail());
		jee.add(new GetPersonRoles());
		jee.add(new GetPersonGroups());
		jee.add(new GetSession());
		jee.add(new GetSettings());
		jee.add(new HasPersonRecord());
		jee.add(new InvalidateToken());
		jee.add(new RecentLogEntries());
		jee.add(new SignUp());
		jee.add(new SearchPeople());
		jee.add(new UpsertGroup());
		jee.add(new DeleteGroupRole());
		jee.add(new DeleteRole());
		jee.add(new JoinGroup());
		jee.add(new LeaveGroup());
		jee.add(new RemoveSetting());
		jee.add(new UpsertGroupRole());
		jee.add(new UpsertRole());
		jee.add(new UpsertSetting());
	}
	public List<LocationgetLocationByIP(String ipthrows IOException {
		return new GetLocationByIP(thisip).execute();
	}
	public List<EmailgetPendingEmail(int countthrows IOException {
		return new GetPendingEmail(thiscount).execute();
	}
	public List<KeyValuegetSettings(User userthrows IOException {
		return new GetSettings(thisuser).run();
	}
	public List<AuditLogEntrygetRecentLogEntries(User userString resourceTypeString resourceUidboolean debuglong limitthrows IOException {
		return new RecentLogEntries(thisuserresourceTyperesourceUiddebuglimit).run();
	}
	public List<AuditLogEntrygetRecentLogEntriesByIP(User userString ipboolean debuglong limitthrows IOException {
		return new RecentLogEntriesByIP(thisuseripdebuglimit).run();
	}
	public List<AuditLogEntrygetRecentLogEntriesByPerson(User userUUID uuidboolean debuglong limitthrows IOException {
		return new RecentLogEntriesByPerson(thisuseruuiddebuglimit).run();
	}
	public void removeSetting(User userString namethrows IOException {
		new RemoveSetting(thisusername).run();
	}
	public void sendEmail(User userString emailthrows IOException {
		new SendEmail(thisuseremail).run();
	}
	public void upsertSetting(User userString nameString valuethrows IOException {
		new UpsertSetting(thisusernamevalue).run();
	}
	public void deleteSetting(User userString namethrows IOException {
	}
	public void deleteAllSettings(User userthrows IOException {
	}
	public void createTemplate(User userString basedOnString namethrows IOException {
		new CreateTemplate(thisuserbasedOnname).run();
	}
	public void deleteTemplate(User userString namethrows PermissionException {
		new DeleteTemplate(thisusername);
	}
	public List<ResourcegetTemplateResources(String templatethrows IOException {
		return new GetTemplateResources(thistemplate).execute();
	}
	public List<KeyValuegetTemplates(User userthrows IOException {
		return new GetTemplates(thisuser).execute();
	}
	public void upsertTemplateResource(User userString templateString namebyte[] contentboolean binarythrows IOException {
		new UpsertTemplateResource(thisusertemplatenamecontentbinary).run();
	}
	public void activateAccountUsingToken(String tokenString passwordString password2String ipthrows IOException {
		new ActivateAccountUsingToken(thistokenpasswordpassword2ip).run();
	}
	public List<KeyValueauthenticate(String currentTokenString usernameString passwordString ipthrows IOException {
		return new Authenticate(thiscurrentTokenusernamepasswordip).execute();
	}
	public List<UuidQueryResultcreatePerson(TemplateManager templateManagerUser userString firstNameString lastNameString emailString usernameString passwordString initialRolesString expirythrows IOException {
		return new CreatePerson(thistemplateManageruserfirstNamelastNameemailusernamepasswordinitialRolesexpiry).run();
	}
	public void deleteGroupResourceRole(User userString resourceString uidUUID groupUuidString rolethrows IOException {
		new DeleteGroupResourceRole(thisuserresourceuidgroupUuidrole).run();
	}
	public void deleteGroupRole(User userUUID groupUuidString rolethrows IOException {
		new DeleteGroupRole(thisusergroupUuidrole).run();
	}
	public void deleteResourceRole(User userString resourceString uidUUID personUuidString rolethrows IOException {
		new DeleteResourceRole(thisuserresourceuidpersonUuidrole).run();
	}
	public void deleteRole(User userUUID personUuidString rolethrows IOException {
		new DeleteRole(thisuserpersonUuidrole).run();
	}
	public List<StringQueryResultgetBatchResults(User userUUID batchthrows IOException {
		return new GetBatchResults(thisuserbatch).execute();
	}
	public List<GroupgetGroup(User userUUID uuidthrows IOException {
		return new GetGroup(thisuseruuid).execute();
	}
	public List<PersongetGroupMembers(User userUUID groupthrows IOException {
		return new GetGroupMembers(thisusergroup).execute();
	}
	public List<PersonRolegetGroupRoles(User userUUID groupUuidthrows IOException {
		return new GetGroupRoles(thisusergroupUuid).execute();
	}
	public List<GroupgetGroups(User userthrows IOException {
		return new GetGroups(thisuser).execute();
	}
	public List<PersongetPerson(User userUUID personUuidthrows IOException {
		return new GetPerson(thisuserpersonUuid).execute();
	}
	public List<PersongetPersonByEmail(User userString emailthrows IOException {
		return new GetPersonByEmail(thisuseremail).execute();
	}
	public List<GroupgetPersonGroups(User userUUID personUuidthrows IOException {
		return new GetPersonGroups(thisuserpersonUuid).execute();
	}
	public List<PersonRolegetPersonRoles(User userUUID personUuidthrows IOException {
		return new GetPersonRoles(thisuserpersonUuid).execute();
	}
	public List<UsergetSession(String tokenString ipthrows IOException {
		return new GetSession(thistokenip).execute();
	}
		return new HasPersonRecord(this).execute();
	}
	public List<KeyValueinvalidateToken(String tokenString ipthrows IOException {
		return new InvalidateToken(thistokenip).execute();
	}
	public void joinGroup(User userUUID groupUUID personthrows IOException {
		new JoinGroup(thisusergroupperson).run();
	}
	public void leaveGroup(User userUUID groupUUID personthrows IOException {
		new LeaveGroup(thisusergroupperson).run();
	}
		return new RequestPasswordResetEmail(thistemplatesemailip).execute();
	}
	public void resetPasswordUsingToken(String tokenString passwordString password2String ipthrows IOException {
		new ResetPasswordUsingToken(thistokenpasswordpassword2ip).run();
	}
	public List<PersonsearchPeople(User userString keywordsthrows IOException {
		return new SearchPeople(thisuserkeywords).execute();
	}
	public List<KeyValuesignUp(TemplateManager templateManagerUser userString firstNameString lastNameString emailString usernameString passwordString ipthrows IOException {
		return new SignUp(thistemplateManageruserfirstNamelastNameemailusernamepasswordip).run();
	}
	public void setPendingEmailStatus(UUID uuidString errorthrows IOException {
		new SetPendingEmailStatus(thisuuiderror).run();
	}
	public List<StringQueryResultsignUpConfirmation(String requestTokenString ipthrows IOException {
		return new SignUpConfirmation(thisrequestTokenip).run();
	}
	public void updatePerson(User userUUID uuidString firstNameString lastNameString emailString expirythrows IOException {
		new UpdatePerson(thisuseruuidfirstNamelastNameemailexpiry).run();
	}
	public List<UuidQueryResultupsertGroup(User userString groupint typethrows IOException {
		return new UpsertGroup(thisusergrouptype).run();
	}
	public void upsertGroupResourceRole(User userUUID groupUuidString roleString resourceString uidthrows IOException {
		new UpsertGroupResourceRole(thisusergroupUuidroleresourceuid).run();
	}
	public void upsertGroupRole(User userUUID groupUuidString rolethrows IOException {
		new UpsertGroupRole(thisusergroupUuidrole).run();
	}
	public void upsertResourceRole(User userUUID personUuidString roleString resourceString uidthrows IOException {
		new UpsertResourceRole(thisuserpersonUuidroleresourceuid).run();
	}
	public void upsertRole(User userUUID personUuidString rolethrows IOException {
		new UpsertRole(thisuserpersonUuidrole).run();
	}
	public void log(String levelUser userString messageResourceUid[] resourcesthrows IOException {
		try {
			base.jee.api.sql.util.Log.log(levelusermessageresources);
catch(SQLException e) {
			throw new IOException(e);
		}
	}
	public void expireTokens() throws IOException {
		// Cassandra records are inserted with a TTL. No manual expriy process needed
	}
	public void expireLogEntries() throws IOException {
		// Cassandra records are inserted with a TTL. No manual expriy process needed
	}
	public void wipe() throws IOException {
		.execute("truncate audit_event");
		.execute("truncate audit_type");
		.execute("truncate base_group");
		.execute("truncate ip_location");
		.execute("truncate location");
		.execute("truncate person");
		.execute("truncate session_token");
		.execute("truncate request_token");
		.execute("truncate role");
		.execute("truncate setting");
		.execute("truncate template");
		.execute("truncate template_resource");
		.execute("truncate throttle");
		Connection c = null;
		try {
			truncate(c"email");
catch(SQLException e) {
			throw new IOException(e);
finally {
			if(c != null) {
				try { c.commit(); } catch(SQLException e) {}
				try { c.close(); } catch(SQLException e) {}
			}
		}
	}

Returns roles associated with the "All users" group, and the "Authenticated users" group.
		return new HashSet<>();
	}

Returns roles associated with the "All users" group.
		return new HashSet<>();
	}
	private void truncate(Connection cString tablethrows IOException {
		PreparedStatement s = null;
		try {
			s = c.prepareStatement("delete from " + table);
			s.close();
			s = null;
catch(SQLException e) {
			throw new IOException(e);
finally {
			if(s != null) {
				try { s.close(); } catch(SQLException e) {}
			}
		}
	}
New to GrepCode? Check out our FAQ X