OWLS-76780 : Modify FMW (domain-in-image) sample to support Restricte…

kubernetes/samples/scripts/create-fmw-infrastructure-domain/domain-home-in-image/common/createFMWRestrictedJRFDomain.py

@@ -0,0 +1,291 @@
+# Copyright 2014, 2019, Oracle Corporation and/or its affiliates.  All rights reserved.
+# Licensed under the Universal Permissive License v 1.0 as shown at http://oss.oracle.com/licenses/upl.
+
+import os
+import sys
+
+import com.oracle.cie.domain.script.jython.WLSTException as WLSTException
+
+class Infra12213Provisioner:
+
+    MACHINES = {
+        'machine1' : {
+            'NMType': 'SSL',
+            'ListenAddress': 'localhost',
+            'ListenPort': 5658
+        }
+    }
+
+    JRF_12213_TEMPLATES = {
+        'baseTemplate' : '@@ORACLE_HOME@@/wlserver/common/templates/wls/wls.jar',
+        'extensionTemplates' : [
+            '@@ORACLE_HOME@@/oracle_common/common/templates/wls/oracle.jrf_restricted_template.jar',
+            '@@ORACLE_HOME@@/em/common/templates/wls/oracle.em_wls_restricted_template.jar'
+        ],
+        'serverGroupsToTarget' : [ 'JRF-MAN-SVR', 'WSMPM-MAN-SVR' ]
+    }
+
+    def __init__(self, oracleHome, javaHome, domainParentDir, adminListenPort, adminName, managedNameBase, managedServerPort, prodMode, managedCount, clusterName):
+        self.oracleHome = self.validateDirectory(oracleHome)
+        self.javaHome = self.validateDirectory(javaHome)
+        self.domainParentDir = self.validateDirectory(domainParentDir, create=True)
+        return
+
+    def createInfraDomain(self, domainName, user, password, adminListenPort, adminName,
+                          managedNameBase, managedServerPort, prodMode, managedCount, clusterName,
+                          exposeAdminT3Channel=None, t3ChannelPublicAddress=None, t3ChannelPort=None):
+        domainHome = self.createBaseDomain(domainName, user, password, adminListenPort, adminName, managedNameBase,
+                                           managedServerPort, prodMode, managedCount, clusterName
+                                           )
+        self.extendDomain(domainHome, exposeAdminT3Channel, t3ChannelPublicAddress, t3ChannelPort)
+
+    def createBaseDomain(self, domainName, user, password, adminListenPort, adminName, managedNameBase, managedServerPort, prodMode, managedCount, clusterName):
+        baseTemplate = self.replaceTokens(self.JRF_12213_TEMPLATES['baseTemplate'])
+
+        readTemplate(baseTemplate)
+        setOption('DomainName', domainName)
+        setOption('JavaHome', self.javaHome)
+        if (prodMode == 'true'):
+            setOption('ServerStartMode', 'prod')
+        else:
+            setOption('ServerStartMode', 'dev')
+        set('Name', domainName)
+
+        admin_port = int(adminListenPort)
+        ms_port    = int(managedServerPort)
+        ms_count   = int(managedCount)
+
+        # Create Admin Server
+        # =======================
+        print 'Creating Admin Server...'
+        cd('/Servers/AdminServer')
+        #set('ListenAddress', '%s-%s' % (domain_uid, admin_server_name_svc))
+        set('ListenPort', admin_port)
+        set('Name', adminName)
+
+        # Define the user password for weblogic
+        # =====================================
+        cd('/Security/' + domainName + '/User/weblogic')
+        set('Name', user)
+        set('Password', password)
+
+        # Create a cluster
+        # ======================
+        print 'Creating cluster...'
+        cd('/')
+        cl=create(clusterName, 'Cluster')
+
+        # Create managed servers
+        for index in range(0, ms_count):
+            cd('/')
+            msIndex = index+1
+            cd('/')
+            name = '%s%s' % (managedNameBase, msIndex)
+            create(name, 'Server')
+            cd('/Servers/%s/' % name )
+            print('managed server name is %s' % name);
+            set('ListenPort', ms_port)
+            set('NumOfRetriesBeforeMSIMode', 0)
+            set('RetryIntervalBeforeMSIMode', 1)
+            set('Cluster', clusterName)
+
+        # Create Node Manager
+        # =======================
+        print 'Creating Node Managers...'
+        for machine in self.MACHINES:
+            cd('/')
+            create(machine, 'Machine')
+            cd('Machine/' + machine)
+            create(machine, 'NodeManager')
+            cd('NodeManager/' + machine)
+            for param in self.MACHINES[machine]:
+                set(param, self.MACHINES[machine][param])
+
+
+        setOption('OverwriteDomain', 'true')
+        domainHome = self.domainParentDir + '/' + domainName
+        print 'Will create Base domain at ' + domainHome
+
+        print 'Writing base domain...'
+        writeDomain(domainHome)
+        closeTemplate()
+        print 'Base domain created at ' + domainHome
+        return domainHome
+
+
+    def extendDomain(self, domainHome, exposeAdminT3Channel, t3ChannelPublicAddress,
+                     t3ChannelPort):
+        print 'Extending domain at ' + domainHome
+        readDomain(domainHome)
+        setOption('AppDir', self.domainParentDir + '/applications')
+
+        print 'ExposeAdminT3Channel %s with %s:%s ' % (exposeAdminT3Channel, t3ChannelPublicAddress, t3ChannelPort)
+        if 'true' == exposeAdminT3Channel:
+            self.enable_admin_channel(t3ChannelPublicAddress, t3ChannelPort)
+
+        print 'Applying JRF templates...'
+        for extensionTemplate in self.JRF_12213_TEMPLATES['extensionTemplates']:
+            addTemplate(self.replaceTokens(extensionTemplate))
+
+        print 'Extension Templates added'
+
+        print 'Preparing to update domain...'
+        updateDomain()
+        print 'Domain updated successfully'
+        closeDomain()
+        return
+
+
+    ###########################################################################
+    # Helper Methods                                                          #
+    ###########################################################################
+
+    def validateDirectory(self, dirName, create=False):
+        directory = os.path.realpath(dirName)
+        if not os.path.exists(directory):
+            if create:
+                os.makedirs(directory)
+            else:
+                message = 'Directory ' + directory + ' does not exist'
+                raise WLSTException(message)
+        elif not os.path.isdir(directory):
+            message = 'Directory ' + directory + ' is not a directory'
+            raise WLSTException(message)
+        return self.fixupPath(directory)
+
+
+    def fixupPath(self, path):
+        result = path
+        if path is not None:
+            result = path.replace('\\', '/')
+        return result
+
+
+    def replaceTokens(self, path):
+        result = path
+        if path is not None:
+            result = path.replace('@@ORACLE_HOME@@', oracleHome)
+        return result
+
+    def enable_admin_channel(self, admin_channel_address, admin_channel_port):
+        if admin_channel_address == None or admin_channel_port == 'None':
+            return
+        cd('/')
+        admin_server_name = get('AdminServerName')
+        print('setting admin server t3channel for ' + admin_server_name)
+        cd('/Servers/' + admin_server_name)
+        create('T3Channel', 'NetworkAccessPoint')
+        cd('/Servers/' + admin_server_name + '/NetworkAccessPoint/T3Channel')
+        set('ListenPort', int(admin_channel_port))
+        set('PublicPort', int(admin_channel_port))
+        set('PublicAddress', admin_channel_address)
+
+#############################
+# Entry point to the script #
+#############################
+
+def usage():
+    print sys.argv[0] + ' -oh <oracle_home> -jh <java_home> -parent <domain_parent_dir> -name <domain-name> ' + \
+          '-user <domain-user> -password <domain-password> ' + \
+          '-rcuDb <rcu-database> -rcuPrefix <rcu-prefix> -rcuSchemaPwd <rcu-schema-password> ' \
+          '-adminListenPort <adminListenPort> -adminName <adminName> ' \
+          '-managedNameBase <managedNameBase> -managedServerPort <managedServerPort> -prodMode <prodMode> ' \
+          '-managedServerCount <managedCount> -clusterName <clusterName> ' \
+          '-exposeAdminT3Channel <quoted true or false> -t3ChannelPublicAddress <address of the cluster> ' \
+          '-t3ChannelPort <t3 channel port> '
+    sys.exit(0)
+
+# Uncomment for Debug only
+#print str(sys.argv[0]) + " called with the following sys.argv array:"
+#for index, arg in enumerate(sys.argv):
+#    print "sys.argv[" + str(index) + "] = " + str(sys.argv[index])
+
+if len(sys.argv) < 16:
+    usage()
+
+#oracleHome will be passed by command line parameter -oh.
+oracleHome = None
+#javaHome will be passed by command line parameter -jh.
+javaHome = None
+#domainParentDir will be passed by command line parameter -parent.
+domainParentDir = None
+#domainUser is hard-coded to weblogic. You can change to other name of your choice. Command line paramter -user.
+domainUser = 'weblogic'
+#domainPassword will be passed by Command line parameter -password.
+domainPassword = None
+#rcuDb will be passed by command line parameter -rcuDb.
+rcuDb = None
+#change rcuSchemaPrefix to your infra schema prefix. Command line parameter -rcuPrefix.
+rcuSchemaPrefix = 'DEV12'
+#change rcuSchemaPassword to your infra schema password. Command line parameter -rcuSchemaPwd.
+rcuSchemaPassword = None
+exposeAdminT3Channel = None
+t3ChannelPort = None
+t3ChannelPublicAddress = None
+i = 1
+while i < len(sys.argv):
+    if sys.argv[i] == '-oh':
+        oracleHome = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-jh':
+        javaHome = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-parent':
+        domainParentDir = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-name':
+        domainName = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-user':
+        domainUser = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-password':
+        domainPassword = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-rcuDb':
+        rcuDb = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-rcuPrefix':
+        rcuSchemaPrefix = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-rcuSchemaPwd':
+        rcuSchemaPassword = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-adminListenPort':
+        adminListenPort = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-adminName':
+        adminName = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-managedNameBase':
+        managedNameBase = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-managedServerPort':
+        managedServerPort = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-prodMode':
+        prodMode = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-managedServerCount':
+        managedCount = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-clusterName':
+        clusterName = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-t3ChannelPublicAddress':
+        t3ChannelPublicAddress = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-t3ChannelPort':
+        t3ChannelPort = sys.argv[i + 1]
+        i += 2
+    elif sys.argv[i] == '-exposeAdminT3Channel':
+        exposeAdminT3Channel = sys.argv[i + 1]
+        i += 2
+    else:
+        print 'Unexpected argument switch at position ' + str(i) + ': ' + str(sys.argv[i])
+        usage()
+        sys.exit(1)
+
+provisioner = Infra12213Provisioner(oracleHome, javaHome, domainParentDir, adminListenPort, adminName, managedNameBase, managedServerPort, prodMode, managedCount, clusterName)
+provisioner.createInfraDomain(domainName, domainUser, domainPassword, adminListenPort, adminName, managedNameBase, managedServerPort, prodMode, managedCount,
+                              clusterName, exposeAdminT3Channel, t3ChannelPublicAddress, t3ChannelPort)

kubernetes/samples/scripts/create-fmw-infrastructure-domain/domain-home-in-image/create-domain-inputs.yaml

@@ -160,3 +160,6 @@ rcuDatabaseURL: database:1521/service
 
 # The kubernetes secret containing the database credentials
 rcuCredentialsSecret: domain1-rcu-credentials
+
+# FMW Infrastructure Domain Type. Legal values are JRF or RestrictedJRF
+fmwDomainType: JRF

kubernetes/samples/scripts/create-fmw-infrastructure-domain/domain-home-in-image/create-domain.sh

@@ -203,7 +203,18 @@ function createDomainHome {
   cp ${domainPropertiesOutput} ${dockerPropsDir}
   sed  -i  '$ a extract_env IMAGE_TAG ${PROPERTIES_FILE} ' ${dockerDir}/container-scripts/setEnv.sh
 
-  #exit -1000
+  if [ "${fmwDomainType}" == "RestrictedJRF" ];
+  then
+   if [ ! -f ${dockerDir}/container-scripts/createFMWDomain.py.bak ]; then
+    mv ${dockerDir}/container-scripts/createFMWDomain.py \
+       ${dockerDir}/container-scripts/createFMWDomain.py.bak
+   fi
+   echo "Replacing file ${dockerDir}/container-scripts/createFMWDomain.py for RestrictedJRF Domain creation" 
+   cp -f ${scriptDir}/common/createFMWRestrictedJRFDomain.py \
+         ${dockerDir}/container-scripts/createFMWDomain.py
+
+  fi
+
   bash ${dockerDir}/build.sh
 
   if [ "$?" != "0" ]; then