Function CreateProjectTask

cmd/cql-proxy/api/project.go:155–212

CreateProjectTask handles the project creation process.

(ctx context.Context, cfg *config.Config, db *gorp.DbMap, t *model.Task)

// CreateProjectTask handles the project creation process.
func CreateProjectTask(ctx context.Context, cfg *config.Config, db *gorp.DbMap, t *model.Task) (r gin.H, err error) {
	args := struct {
		NodeCount uint16 `json:"node_count"`
	}{}

	err = json.Unmarshal(t.RawArgs, &args)
	if err != nil {
		err = errors.Wrapf(err, "unmarshal task args failed")
		return
	}

	tx, dbID, key, err := createDatabase(db, t.Developer, t.Account, args.NodeCount)
	if err != nil {
		err = errors.Wrapf(err, "create database failed")
		return
	}

	// wait for transaction to complete in several cycles
	timeoutCtx, cancelCtx := context.WithTimeout(ctx, 3*time.Minute)
	defer cancelCtx()

	lastState, err := waitForTxState(timeoutCtx, tx)
	if err != nil {
		err = errors.Wrapf(err, "wait for database creation confirmation failed")
		r = gin.H{
			"project": dbID,
			"db":      dbID,
			"tx":      tx.String(),
			"state":   lastState.String(),
		}

		return
	}

	// wait for projectDB to ready deployed
	time.Sleep(30 * time.Second)

	_, err = initProjectDB(dbID, key)
	if err != nil {
		err = errors.Wrapf(err, "init project database meta tables failed")
		return
	}

	// bind database to current developer
	_, err = model.AddProject(db, dbID, t.Developer, t.Account)
	if err != nil {
		err = errors.Wrapf(err, "register project failed")
	}

	r = gin.H{
		"tx":      tx.String(),
		"state":   lastState.String(),
		"project": dbID,
		"db":      dbID,
	}

	return
}