Function CreateSubSites

server/subsites.go:27–185

(cmsConfig *resource.CmsConfig, transaction *sqlx.Tx,
	cruds map[string]*resource.DbResource, authMiddleware *auth.AuthMiddleware,
	rateConfig RateConfig, max_connections int, olricClient *olric.EmbeddedClient)

)

func CreateSubSites(cmsConfig *resource.CmsConfig, transaction *sqlx.Tx,
	cruds map[string]*resource.DbResource, authMiddleware *auth.AuthMiddleware,
	rateConfig RateConfig, max_connections int, olricClient *olric.EmbeddedClient) (hostswitch.HostSwitch, map[daptinid.DaptinReferenceId]*assetcachepojo.AssetFolderCache) {

	hs := hostswitch.HostSwitch{
		AdministratorGroupId: cruds["usergroup"].AdministratorGroupId,
	}
	subsiteCacheFolders := make(map[daptinid.DaptinReferenceId]*assetcachepojo.AssetFolderCache)
	hs.HandlerMap = make(map[string]*gin.Engine)
	hs.SiteMap = make(map[string]subsite.SubSite)
	hs.AuthMiddleware = authMiddleware

	// Initialize the subsite cache with Olric client
	if olricClient != nil {
		err := InitSubsiteCache(olricClient)
		if err != nil {
			log.Errorf("Failed to initialize subsite cache: %v", err)
		} else {
			log.Infof("Subsite cache initialized with Olric")
		}
	} else {
		log.Warnf("Olric client is nil, subsite cache will not be available")
	}

	//log.Printf("Cruds before making sub sits: %v", cruds)
	sites, err := subsite.GetAllSites(cruds["site"], transaction)
	if err != nil {
		log.Printf("Failed to get all sites 117: %v", err)
	}
	stores, err := cloud_store.GetAllCloudStores(cruds["cloud_store"], transaction)
	if err != nil {
		log.Printf("Failed to get all cloudstores 121: %v", err)
	}
	cloudStoreMap := make(map[int64]rootpojo.CloudStore)

	adminEmailId := cruds[resource.USER_ACCOUNT_TABLE_NAME].GetAdminEmailId(transaction)
	log.Printf("Admin email id: %s", adminEmailId)

	for _, store := range stores {
		cloudStoreMap[store.Id] = store
	}

	siteMap := make(map[string]resource.SubSiteInformation)

	if err != nil {
		log.Errorf("Failed to load sites from database: %v", err)
		return hs, subsiteCacheFolders
	}

	//max_connections, err := configStore.GetConfigIntValueFor("limit.max_connections", "backend")
	//rate_limit, err := configStore.GetConfigIntValueFor("limit.rate", "backend")

	rateLimiter := limit2.NewRateLimiter(func(c *gin.Context) string {
		requestPath := c.Request.Host + "/" + strings.Split(c.Request.RequestURI, "?")[0]
		return c.ClientIP() + requestPath // limit rate by client ip
	}, func(c *gin.Context) (*rate.Limiter, time.Duration) {
		requestPath := c.Request.Host + "/" + strings.Split(c.Request.RequestURI, "?")[0]
		limitValue, ok := rateConfig.limits[requestPath]