Function GetResource

server/resource_methods_test.go:36–124

()

}

func GetResource() (*InMemoryTestDatabase, *resource.DbResource) {
	wrapper := GetInMemoryDbForTest()

	configStore, _ := resource.NewConfigStore(wrapper)

	initConfig, _ := LoadConfigFiles()

	existingTables, _ := GetTablesFromWorld(wrapper)

	allTables := MergeTables(existingTables, initConfig.Tables)

	initConfig.Tables = allTables

	cruds := make(map[string]*resource.DbResource)

	olricDb1, _ := olric.New(olricConfig.New("local"))
	olricDb := olricDb1.NewEmbeddedClient()

	dtopicMap := make(map[string]*olric.PubSub)

	store := ydb.NewDiskStore("/tmp")
	ms := BuildMiddlewareSet(&initConfig, &cruds, store, &dtopicMap)
	for _, table := range initConfig.Tables {
		model := api2go.NewApi2GoModel(table.TableName, table.Columns, int64(table.DefaultPermission), table.Relations)
		res, _ := resource.NewDbResource(model, wrapper, &ms, cruds, configStore, olricDb, table)
		cruds[table.TableName] = res
	}

	for key := range cruds {
		pubSub, err := olricDb.NewPubSub()
		if err != nil {
			resource.CheckErr(err, "Failed to create pubsub for table: %v", key)
			continue
		}
		dtopicMap[key] = pubSub
	}

	resource.CheckRelations(&initConfig)
	resource.CheckAuditTables(&initConfig)

	tx, errb := wrapper.Beginx()
	resource.CheckErr(errb, "Failed to begin transaction [76]")
	resource.CheckAllTableStatus(&initConfig, wrapper)
	errc := tx.Commit()
	resource.CheckErr(errc, "Failed to commit transaction after creating tables")

	tx, errb = wrapper.Beginx()
	resource.CheckErr(errb, "Failed to begin transaction [82]")
	resource.CreateRelations(&initConfig, wrapper)
	errc = tx.Commit()
	resource.CheckErr(errc, "Failed to commit transaction after creating relations")

	tx, errb = wrapper.Beginx()
	resource.CheckErr(errb, "Failed to begin transaction [88]")
	resource.CreateUniqueConstraints(&initConfig, tx)
	errc = tx.Commit()
	resource.CheckErr(errc, "Failed to commit transaction after creating unique constrains")