stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java (9 lines): - line 919: // TODO When we get an event system, trigger a repair if this is detected - line 1145: //TODO: does this call and others like it need a graphite reporter? - line 1797: //TODO: change timeservice as below then use timeservice. - line 1948: //TODO: does this need graphite monitoring - line 1956: //TODO: does this need graphite monitoring - line 2103: // TODO this never returns anything - write path not invoked - line 2174: // TODO short circuit - line 2438: // TODO shortcircuit - line 3010: //TODO: ask what the difference is. stack/services/src/main/java/org/apache/usergrid/management/cassandra/ManagementServiceImpl.java (7 lines): - line 2092: // TODO Auto-generated method stub - line 2099: // TODO Auto-generated method stub - line 2528: //TODO: org shouldn't approve org activation, right? - line 2592: //TODO: email for org admin or sysadmin? - line 2730: //TODO: admin specific email - line 3131: // TODO load the user, send the hashType down to maybeSaltPassword - line 3462: // TODO Auto-generated method stub stack/tools/src/main/java/org/apache/usergrid/tools/Import.java (6 lines): - line 452: // TODO: fix Import to work with Core Persistence - line 454: new SimpleEntityRef( "TODO: correct type goes here", UUID.fromString( entityOwnerId )) ); - line 472: // TODO: fix Import to work with Core Persistence - line 474: "TODO: correct type goes here", UUID.fromString( entryId )) ); - line 505: // TODO: fix Import to work with Core Persistence - line 507: "TODO: correct type goes here", UUID.fromString( entryId )) ); stack/services/src/main/java/org/apache/usergrid/management/importer/ImportServiceImpl.java (6 lines): - line 803: // TODO: better way to wait for indexes to catch up - line 951: // TODO: move JSON parser into observable creation so open/close happens within the stream - line 989: // TODO: move JSON parser into observable creation so open/close happens within the stream - line 1093: // TODO: do we need to ensure that all Entity events happen first? - line 1094: // TODO: what happens if ConnectionEvents happen before all entities are saved? - line 1147: // TODO add statistics for dictionary writes and failures stack/core/src/main/java/org/apache/usergrid/corepersistence/CpRelationManager.java (4 lines): - line 116: // TODO: this assert should not be failing - line 170: // TODO: do we need to restrict this to edges prefixed with owns? - line 903: // TODO: someday this should return a list of Core Persistence Ids - line 1039: //TODO T.N. not sure if we still need this. If we do then we ned to modify our query interface. stack/core/src/main/java/org/apache/usergrid/persistence/exceptions/LockingException.java (4 lines): - line 33: // TODO Auto-generated constructor stub - line 42: // TODO Auto-generated constructor stub - line 51: // TODO Auto-generated constructor stub - line 61: // TODO Auto-generated constructor stub stack/services/src/main/java/org/apache/usergrid/services/queues/ImportQueueListener.java (4 lines): - line 38: //TODO: make sure this is properly instantiated by guice - line 51: //TODO: someway to tell the base class what the queuename is. The scope would be different. - line 80: // TODO We still need to hide this queue behind the scheduler importService.downloadAndImportFile( queueMessage ); - line 86: //TODO: make this set from the properties file. Due to having a shared amazon account. stack/core/src/main/java/org/apache/usergrid/locking/exception/UGLockException.java (4 lines): - line 30: // TODO Auto-generated constructor stub - line 36: // TODO Auto-generated constructor stub - line 42: // TODO Auto-generated constructor stub - line 48: // TODO Auto-generated constructor stub stack/services/src/main/java/org/apache/usergrid/services/queues/QueueListener.java (4 lines): - line 85: //TODO: change current injectors to use service module instead of CpSetup - line 99: */ //TODO: make use guice. Currently on spring. Needs to run and finish for main thread. - line 183: //TODO: a model class to get generic queueMessages out of the queueManager. Ask Shawn what should go here. - line 195: //TODO: make sure this has a way to determine which QueueListener needs to be used stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManagerFactory.java (4 lines): - line 156: // TODO: fix this kludge - line 239: // TODO: determine how application name can intermittently be null - line 502: *

TODO: add scheduled task that can completely delete all deleted application data.

- line 515: //TODO: return status for restore stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/api/QueueResource.java (4 lines): - line 142: // TODO: create design to handle large number of queues, e.g. paging and/or hierarchy of queues - line 144: // TODO: create design to support multi-tenant usage, authentication, etc. - line 154: // TODO: implement GET /queues/{queueName}/stats - line 416: // // TODO: implement DELETE /queues/{queueName}/messages" stack/rest/src/main/java/org/apache/usergrid/rest/management/organizations/applications/ApplicationResource.java (4 lines): - line 330: // // TODO: throw descriptive error message and or include on in the response - line 331: // // TODO: fix below, it doesn't work if there is an exception. - line 402: // // TODO: throw descriptive error message and or include on in the response - line 403: // // TODO: fix below, it doesn't work if there is an exception. stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/core/impl/QueueMessageManagerImpl.java (3 lines): - line 99: // TODO: implement delay and expiration - line 238: // TODO: implement requeueMessage - line 244: // TODO: implement delete of message data too stack/services/src/main/java/org/apache/usergrid/services/AbstractConnectionsService.java (3 lines): - line 220: // TODO check that entity is in fact connected - line 264: //TODO T.N. USERGRID-1919 actually validate this is connected - line 452: //TODO wire the RX scheduler in here and use our parallelism system stack/services/src/main/java/org/apache/usergrid/services/AbstractService.java (3 lines): - line 151: // TODO Auto-generated method stub - line 344: // TODO Auto-generated method stub - line 351: // TODO Auto-generated method stub stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/mvcc/stage/delete/UniqueCleanup.java (3 lines): - line 102: //TODO Refactor this logic into a a class that can be invoked from anywhere - line 113: //TODO: does this emit for every version before the staticComparator? - line 118: //TODO: should this be equals? That way we clean up the one marked as well stack/services/src/main/java/org/apache/usergrid/management/export/ExportServiceImpl.java (2 lines): - line 529: //TODO:shouldn't the below be UTF-16? - line 561: //TODO:Needs further refactoring. stack/rest/src/main/java/org/apache/usergrid/rest/management/organizations/OrganizationResource.java (2 lines): - line 347: // //TODO:throw descriptive error message and or include on in the response - line 348: // //TODO:fix below, it doesn't work if there is an exception. Make it look like the OauthResponse. stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java (2 lines): - line 91: //TODO refactor this into a central component that will start/stop services - line 197: //TODO: stop copying around this area as it gets notification specific. stack/core/src/main/java/org/apache/usergrid/mq/cassandra/QueueManagerImpl.java (2 lines): - line 1304: // TODO Auto-generated method stub - line 1311: // TODO Auto-generated method stub stack/rest/src/main/java/org/apache/usergrid/rest/system/MigrateResource.java (2 lines): - line 78: //TODO make this use the task scheduler - line 130: //TODO make this use the task scheduler stack/services/src/main/java/org/apache/usergrid/services/AbstractCollectionService.java (2 lines): - line 142: // TODO : Keep thinking if the double-check read after repair is necessary. Favoring stability here - line 369: //TODO: write rest test for these line of codes stack/core/src/main/java/org/apache/usergrid/mq/QueueSet.java (2 lines): - line 170: // TODO Auto-generated method stub - line 177: // TODO Auto-generated method stub deployment/aws/src/main/groovy/configure_usergrid.groovy (2 lines): - line 76: // TODO T.N Make this the graphite url - line 130: # TODO: make all usernames and passwords configurable via Cloud Formation parameters. stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java (2 lines): - line 232: //TODO need to leverage optional here - line 587: //TODO: check if a notification is done and mark it stack/core/src/main/java/org/apache/usergrid/batch/service/JobSchedulerService.java (2 lines): - line 79: //TODO Add meters for throughput of start and stop - line 228: // TODO wrap and throw specifically typed exception for onFailure, stack/core/src/main/java/org/apache/usergrid/count/Slf4JBatchSubmitter.java (2 lines): - line 43: // TODO custom logger for printing counts - line 62: // TODO perhaps this could be pushed down further into CountProducer Impl? stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EntityMappingParser.java (2 lines): - line 34: * TODO: Decide if we're really getting rid of the Entity field object. If not, this can be much faster using a visitor - line 151: //TODO figure out our nested array structure stack/tools/src/main/java/org/apache/usergrid/tools/Export.java (2 lines): - line 113: //TODO : Add blocking queues for these executors where appropriate - line 623: //TODO : still using JsonGenerator stack/rest/src/main/java/org/apache/usergrid/rest/management/ManagementResource.java (2 lines): - line 192: //@TODO - This code takes the access token from the principal in the cache instead of using the sesssion token. - line 399: //TODO: this could be fixed to return the reason why a user is null. In some cases the USER is not found stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/mvcc/stage/delete/MarkCommit.java (2 lines): - line 129: // TODO: do we need this or can we rely on UniqueCleanup + Cassandra replication? - line 153: // //TODO Refactor this logic into a a class that can be invoked from anywhere stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/search/CandidateEntityFilter.java (2 lines): - line 434: //TODO trigger an audit after a fail count where we explicitly try to repair from other regions - line 492: //TODO trigger an audit after a fail count where we explicitly try to repair from other regions stack/rest/src/main/java/org/apache/usergrid/rest/applications/ServiceResource.java (2 lines): - line 155: //TODO TN query parameters are not being correctly decoded here. The URL encoded strings - line 629: // TODO Temporarily removed until we test further stack/rest/src/main/java/org/apache/usergrid/rest/security/SecuredResourceFilterFactory.java (2 lines): - line 354: // TODO not safe. could load arbitrary application - line 512: // TODO is this right? stack/rest/src/main/java/org/apache/usergrid/rest/applications/assets/AssetsResource.java (2 lines): - line 207: // TODO range parser - line 227: // TODO build content range header if needed stack/launcher/src/main/java/org/apache/usergrid/launcher/CustomJSPTemplateProcessor.java (1 line): - line 106: // TODO log chop/plugin/src/main/java/org/apache/usergrid/chop/plugin/DestroyMojo.java (1 line): - line 71: /** Destroy stack TODO use chop-client module to talk to the coordinator */ stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/IndexingUtils.java (1 line): - line 138: * TODO make this format more readable and parsable stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/impl/QakkaQueueManager.java (1 line): - line 72: // TODO: read defaults from config stack/rest/src/main/java/org/apache/usergrid/rest/filters/MeteringFilter.java (1 line): - line 50: // TODO: Metering for Jersey 2 (https://issues.apache.org/jira/browse/USERGRID-1103) deployment/aws/src/main/groovy/configure_elasticsearch.groovy (1 line): - line 40: //TODO get this from the number of master nodes chop/api/src/main/java/org/apache/usergrid/chop/api/Module.java (1 line): - line 63: // TODO Enum for vcs type later stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesServiceImpl.java (1 line): - line 312: // TODO: replace this configuration stuff with equivalent Java code in the above "create" methods? content/v101-portal-demo/js/libs/usergrid.sdk.js (1 line): - line 1316: ///TODO add code to deal with the type as a path stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReIndexServiceImpl.java (1 line): - line 113: //TODO: optional delay, param. chop/amazon/src/main/java/org/apache/usergrid/chop/api/store/amazon/AmazonIpRuleManager.java (1 line): - line 49: /** TODO check outbound rules */ portal/js/libs/usergrid.sdk.js (1 line): - line 1316: ///TODO add code to deal with the type as a path stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/uniquevalues/UniqueValuesService.java (1 line): - line 62: // TODO: is this really necessary? MarkCommit and UniqueCleanup should do the trick chop/plugin/src/main/java/org/apache/usergrid/chop/plugin/StartMojo.java (1 line): - line 74: /** Start tests TODO use chop-client module to talk to the coordinator */ stack/core/src/main/java/org/apache/usergrid/count/CounterStore.java (1 line): - line 27: // TODO consider inforcing Async via Future as return type stack/services/src/main/java/org/apache/usergrid/services/assets/data/AWSBinaryStore.java (1 line): - line 98: //TODO: GREY rework how the s3 client works because currently it handles initlization and returning of the client stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/AbstractPathFilter.java (1 line): - line 40: //TODO not a big fan of this, but not sure how to build resume otherwise stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/rx/OrderedMerge.java (1 line): - line 290: * TODO: T.N. Once backpressure makes it into RX Java, this needs to be remove and should use backpressure stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/IndexFig.java (1 line): - line 113: @Default( "2" ) // TODO: does this timeout get extended on each query? stack/tools/src/main/java/org/apache/usergrid/tools/bean/MetricQuery.java (1 line): - line 80: query.addCounterFilter( metricSort.queryFilter() ); // TODO MetricSort.queryFilter stack/launcher/src/main/java/org/apache/usergrid/launcher/Server.java (1 line): - line 159: // TODO: find replacement ClasspathStaticHandler, because we had to remove it for ASF policy reasons stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/App.java (1 line): - line 86: Integer.parseInt(actorSystemFig.getPort()), // TODO: make port an int in Actor System module stack/rest/src/main/java/org/apache/usergrid/rest/applications/ApplicationResource.java (1 line): - line 180: // TODO change to singular stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/QakkaModule.java (1 line): - line 66: // TODO: reconcile with usergrid props stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/api/impl/URIStrategyLocalhost.java (1 line): - line 30: /** TODO: implement a "real" URI strategy */ stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventService.java (1 line): - line 65: * TODO: We shouldn't take an entity here, only the id. It doesn't make sense in a distributed context stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/serialization/impl/MvccEntitySerializationStrategyV3Impl.java (1 line): - line 373: //TODO fix this stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/util/AvailablePortFinder.java (1 line): - line 36: * TODO: move this to test packages once Query Index uses it correctly. stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/sharding/impl/PlaceholderShardStrategy.java (1 line): - line 31: // TODO: delete me! stack/services/src/main/java/org/apache/usergrid/services/applications/ApplicationsService.java (1 line): - line 227: // TODO TN finish this return getApplicationRoles(); stack/services/src/main/java/org/apache/usergrid/management/AppInfoMigrationPlugin.java (1 line): - line 238: * TODO: Use Graph to get application_info for an specified Application. chop/plugin/src/main/java/org/apache/usergrid/chop/plugin/DeployMojo.java (1 line): - line 162: /** Upload TODO use chop-client module to talk to the coordinator */ stack/rest/src/main/java/org/apache/usergrid/rest/TextToJsonSwapWriter.java (1 line): - line 40: // TODO: text to JSON swapping for Jersey 2 stack/services/src/main/java/org/apache/usergrid/services/users/activities/ActivitiesService.java (1 line): - line 108: // TODO TN should this also populate id? stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/serialization/impl/UniqueFieldRowKeySerializer.java (1 line): - line 37: // TODO: replace with "real" serializer chop/webapp/src/main/java/org/apache/usergrid/chop/webapp/view/log/LogLayout.java (1 line): - line 60: // TODO make this file point configurable stack/services/src/main/java/org/apache/usergrid/services/notifications/wns/WNSAdapter.java (1 line): - line 136: //TODO: allow for badges and toasts at same time stack/core/src/main/java/org/apache/usergrid/persistence/Query.java (1 line): - line 571: // TODO tnine. After users have had time to change their query limits, stack/mongo-emulator/src/main/java/org/apache/usergrid/mongo/MongoServer.java (1 line): - line 153: // TODO if config'ed for SSL, start the SslMSPF instead, change port as well? chop/client/src/main/java/org/apache/usergrid/chop/client/ssh/Job.java (1 line): - line 302: // TODO to be implemented stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexProducerImpl.java (1 line): - line 128: //TODO: look at indexing ordering stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/distributed/actors/QueueWriter.java (1 line): - line 84: // TODO: implement deliveryTime and expirationTime stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/SearchRequestBuilderStrategy.java (1 line): - line 217: // TODO evaluate performance when it's an all query. stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/impl/EntityCollectionManagerImpl.java (1 line): - line 426: //TODO: explore making this an Async process stack/rest/src/main/java/org/apache/usergrid/rest/system/IndexResource.java (1 line): - line 368: //TODO: wire this up through spring, and in the future guice. stack/test-utils/src/main/java/org/apache/usergrid/cassandra/CassandraResource.java (1 line): - line 35: * TODO move from instance to static stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/read/traverse/EntityLoadVerifyFilter.java (1 line): - line 53: * TODO refactor this into a common command that both ES search and graphSearch can use for repair and verification stack/scripts/multitenant_migrate.py (1 line): - line 368: # TODO fix this URL stack/core/src/main/java/org/apache/usergrid/corepersistence/index/CollectionDeleteServiceImpl.java (1 line): - line 115: //TODO: optional delay, param. chop/plugin/src/main/java/org/apache/usergrid/chop/plugin/ResetMojo.java (1 line): - line 91: /** Reset stopped tests TODO use chop-client module to talk to the coordinator */ stack/tools/src/main/java/org/apache/usergrid/tools/ApiDoc.java (1 line): - line 88: //TODO: fix line above stack/tools/src/main/java/org/apache/usergrid/tools/Repersist.java (1 line): - line 116: // TODO: can we do this without updating the update of each entity? stack/core/src/main/java/org/apache/usergrid/count/AbstractBatcher.java (1 line): - line 58: // TODO add batchCount, remove shouldSubmit, impl submit, change simpleBatcher to just be an extension chop/webapp/src/main/java/org/apache/usergrid/chop/webapp/coordinator/StackCoordinator.java (1 line): - line 185: // TODO should we also check run state of stack? stack/websocket/src/main/java/org/apache/usergrid/websocket/WebSocketChannelHandler.java (1 line): - line 318: // TODO Review this for concurrency safety stack/mongo-emulator/src/main/java/org/apache/usergrid/mongo/protocol/OpDelete.java (1 line): - line 136: // TODO TN set an error stack/services/src/main/java/org/apache/usergrid/security/providers/FoursquareProvider.java (1 line): - line 65: // TODO user extraction chop/client/src/main/java/org/apache/usergrid/chop/client/ssh/RuntimeJob.java (1 line): - line 81: // TODO warnings are also in the stderr, so for now error messages are only for exceptions chop/plugin/src/main/java/org/apache/usergrid/chop/plugin/StopMojo.java (1 line): - line 71: /** Stop tests TODO use chop-client module to talk to the coordinator */ stack/services/src/main/java/org/apache/usergrid/security/providers/PingIdentityProvider.java (1 line): - line 66: // TODO what to do here? stack/corepersistence/model/src/main/java/org/apache/usergrid/persistence/model/util/UUIDGenerator.java (1 line): - line 32: * TODO replace this with the Astyanax generator libs stack/tools/src/main/java/org/apache/usergrid/tools/AppAudit.java (1 line): - line 80: // TODO TN use row iterator to fix this! stack/services/src/main/java/org/apache/usergrid/services/devices/DevicesService.java (1 line): - line 88: // TODO: may want to actually remove the device stack/core/src/main/java/org/apache/usergrid/batch/service/SchedulerServiceImpl.java (1 line): - line 229: // @TODO - what's the point to this sychronized block on an argument? website/layouts/default.html (1 line): - line 14: