Function CreateJsModelHandler

server/jsmodel_handler.go:153–337

(initConfig *resource.CmsConfig, cruds map[string]*resource.DbResource, transaction *sqlx.Tx)

}

func CreateJsModelHandler(initConfig *resource.CmsConfig, cruds map[string]*resource.DbResource, transaction *sqlx.Tx) func(*gin.Context) {
	tableMap := make(map[string]table_info.TableInfo)
	for _, table := range initConfig.Tables {

		//log.Printf("Default permission for [%v]: [%v]", table.TableName, table.Columns)

		tableMap[table.TableName] = table
	}

	streamMap := make(map[string]resource.StreamContract)
	for _, stream := range initConfig.Streams {
		streamMap[stream.StreamName] = stream
	}

	worlds, _, err := cruds["world"].GetRowsByWhereClause("world", nil, transaction)
	if err != nil {
		log.Errorf("Failed to get worlds list")
	}

	worldToReferenceId := make(map[string]daptinid.DaptinReferenceId)

	for _, world := range worlds {
		worldToReferenceId[world["table_name"].(string)] = daptinid.InterfaceToDIR(world["reference_id"])
	}
	var cacheMap sync.Map
	//cacheMap := make(map[string]string)

	return func(c *gin.Context) {
		typeName := strings.Split(c.Param("typename"), ".")[0]
		if jsModel, ok := cacheMap.Load(typeName); ok {
			c.String(200, jsModel.(string))
			return
		}
		selectedTable, isTable := tableMap[typeName]

		if !isTable {
			log.Printf("%v is not a table", typeName)
			selectedStream, isStream := streamMap[typeName]

			if !isStream {
				c.AbortWithStatus(404)
				return

			} else {
				selectedTable = table_info.TableInfo{}
				selectedTable.TableName = selectedStream.StreamName
				selectedTable.Columns = selectedStream.Columns
				selectedTable.Relations = make([]api2go.TableRelation, 0)

			}

		}

		cols := selectedTable.Columns

		//log.Printf("data: %v", selectedTable.Relations)
		tx, err := cruds["world"].Connection().Beginx()
		if err != nil {