| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. The ASF licenses this file to You |
| * under the Apache License, Version 2.0 (the "License"); you may not |
| * use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. For additional information regarding |
| * copyright in this work, please see the NOTICE file in the top level |
| * directory of this distribution. |
| */ |
| |
| |
| // |
| // configure_usergrid.groovy |
| // |
| // Emits usergrid properties file based on environment and Cassandra node registry in SimpleDB |
| // |
| import com.amazonaws.auth.* |
| import com.amazonaws.services.simpledb.* |
| import com.amazonaws.services.simpledb.model.* |
| |
| |
| String accessKey = (String)System.getenv().get("AWS_ACCESS_KEY") |
| String secretKey = (String)System.getenv().get("AWS_SECRET_KEY") |
| |
| def baseUrl = "http://${System.getenv().get("DNS_NAME")}.${System.getenv().get("DNS_DOMAIN")}" |
| String stackName = (String)System.getenv().get("STACK_NAME") |
| String domain = stackName |
| String hostName = (String)System.getenv().get("PUBLIC_HOSTNAME") |
| def replFactor = System.getenv().get("CASSANDRA_REPLICATION_FACTOR") |
| def clusterName = System.getenv().get("CASSANDRA_CLUSTER_NAME") |
| def readConsistencyLevel = System.getenv().get("CASSANDRA_READ_CONSISTENCY") |
| def writeConsistencyLevel = System.getenv().get("CASSANDRA_WRITE_CONSISTENCY") |
| |
| def superUserEmail = System.getenv().get("SUPER_USER_EMAIL") |
| def testAdminUserEmail = System.getenv().get("TEST_ADMIN_USER_EMAIL") |
| |
| def numEsNodes = Integer.parseInt(System.getenv().get("ES_NUM_SERVERS")) |
| //Override number of shards. Set it to 2x the cluster size |
| def esShards = numEsNodes*2; |
| |
| |
| //This gives us 3 copies, which means we'll have a quorum with primary + 1 replica |
| def esReplicas = 1; |
| |
| def tomcatThreads = System.getenv().get("TOMCAT_THREADS") |
| |
| def workerCount = System.getenv().get("INDEX_WORKER_COUNT") |
| |
| //temporarily set to equal since we now have a sane tomcat thread calculation |
| def hystrixThreads = tomcatThreads |
| |
| //if we end in -1, we remove it |
| def ec2Region = System.getenv().get("EC2_REGION") |
| def cassEc2Region = ec2Region.replace("-1", "") |
| |
| NodeRegistry registry = new NodeRegistry(); |
| |
| def selectResult = registry.searchNode('cassandra') |
| |
| // build seed list by listing all Cassandra nodes found in SimpleDB domain with our stackName |
| def cassandras = "" |
| def sep = "" |
| for (item in selectResult) { |
| cassandras = "${cassandras}${sep}${item}:9160" |
| sep = "," |
| } |
| |
| // TODO T.N Make this the graphite url |
| selectResult = registry.searchNode('graphite') |
| def graphite = "" |
| sep = "" |
| for (item in selectResult) { |
| graphite = "${graphite}${sep}${item}" |
| sep = "," |
| } |
| |
| // cassandra nodes are also our elasticsearch nodes |
| selectResult = registry.searchNode('elasticsearch') |
| def esnodes = "" |
| sep = "" |
| for (item in selectResult) { |
| esnodes = "${esnodes}${sep}${item}" |
| sep = "," |
| } |
| |
| def usergridConfig = """ |
| ###################################################### |
| # Minimal Usergrid configuration properties for local Tomcat and Cassandra |
| |
| cassandra.url=${cassandras} |
| cassandra.cluster=${clusterName} |
| cassandra.keyspace.strategy=org.apache.cassandra.locator.NetworkTopologyStrategy |
| cassandra.keyspace.replication=${cassEc2Region}:${replFactor} |
| |
| # This property is required to be set and cannot be left to the default. |
| usergrid.cluster_name=usergrid |
| |
| cassandra.timeout=5000 |
| cassandra.connections=${tomcatThreads} |
| hystrix.threadpool.graph_user.coreSize=${hystrixThreads} |
| hystrix.threadpool.graph_async.coreSize=${hystrixThreads} |
| usergrid.read.cl=${readConsistencyLevel} |
| usergrid.write.cl=${writeConsistencyLevel} |
| |
| |
| |
| elasticsearch.cluster_name=${clusterName} |
| elasticsearch.hosts=${esnodes} |
| elasticsearch.port=9300 |
| elasticsearch.number_shards=${esShards} |
| elasticsearch.number_replicas=${esReplicas} |
| |
| ###################################################### |
| # Custom mail transport |
| |
| mail.transport.protocol=smtp |
| mail.smtp.host=localhost |
| mail.smtp.port=25 |
| mail.smtp.auth=false |
| mail.smtp.quitwait=false |
| |
| # TODO: make all usernames and passwords configurable via Cloud Formation parameters. |
| |
| |
| ###################################################### |
| # Admin and test user setup |
| |
| usergrid.sysadmin.login.allowed=true |
| usergrid.sysadmin.login.name=superuser |
| usergrid.sysadmin.login.password=test |
| usergrid.sysadmin.login.email=${superUserEmail} |
| |
| usergrid.sysadmin.email=${superUserEmail} |
| #We don't want to require user approval so we can quickly create tests |
| usergrid.sysadmin.approve.users=false |
| #We dont want to require organizations to be approved so we can auto create them |
| usergrid.sysadmin.approve.organizations=false |
| |
| # Base mailer account - default for all outgoing messages |
| usergrid.management.mailer=Admin <${superUserEmail}> |
| |
| usergrid.setup-test-account=true |
| |
| usergrid.test-account.app=test-app |
| usergrid.test-account.organization=test-organization |
| usergrid.test-account.admin-user.username=test |
| usergrid.test-account.admin-user.name=Test User |
| usergrid.test-account.admin-user.email=${testAdminUserEmail} |
| usergrid.test-account.admin-user.password=test |
| |
| ###################################################### |
| # Auto-confirm and sign-up notifications settings |
| |
| usergrid.management.admin_users_require_confirmation=false |
| usergrid.management.admin_users_require_activation=false |
| |
| usergrid.management.organizations_require_activation=false |
| usergrid.management.notify_sysadmin_of_new_organizations=true |
| usergrid.management.notify_sysadmin_of_new_admin_users=true |
| |
| ###################################################### |
| # URLs |
| |
| # Redirect path when request come in for TLD |
| usergrid.redirect_root=${baseUrl}/status |
| usergrid.api.url.base=${baseUrl} |
| |
| \n\ |
| |
| |
| usergrid.metrics.graphite.host=${graphite} |
| |
| usergrid.queue.region=${ec2Region} |
| |
| # Enable scheduler for import/export jobs |
| usergrid.scheduler.enabled=true |
| usergrid.scheduler.job.workers=1 |
| |
| |
| #Set our ingest rate |
| elasticsearch.worker_count=${workerCount} |
| |
| """ |
| |
| println usergridConfig |
