Method UpsertProjectVariable

admin/database/postgres/postgres.go:3195–3243

(ctx context.Context, projectID, environment string, vars map[string]string, userID string)

}

func (c *connection) UpsertProjectVariable(ctx context.Context, projectID, environment string, vars map[string]string, userID string) ([]*database.ProjectVariable, error) {
	var userIDPtr *string
	if userID != "" {
		userIDPtr = &userID
	}

	query := `INSERT INTO project_variables (project_id, environment, name, value, value_encryption_key_id, updated_by_user_id, updated_on)
	VALUES %s
	ON CONFLICT (project_id, environment, lower(name)) DO UPDATE SET
		value = EXCLUDED.value,
		value_encryption_key_id = EXCLUDED.value_encryption_key_id,
		updated_by_user_id = EXCLUDED.updated_by_user_id,
		updated_on = now() RETURNING *`

	var placeholders strings.Builder
	args := []any{projectID, environment, userIDPtr}
	i := 3
	for key, value := range vars {
		// Encrypt the variables
		encryptedValue, valueEncryptionKeyID, err := c.encrypt([]byte(value))
		if err != nil {
			return nil, err
		}

		if valueEncryptionKeyID != "" {
			value = base64.StdEncoding.EncodeToString(encryptedValue)
		}
		args = append(args, key, value, valueEncryptionKeyID)
		if placeholders.Len() > 0 {
			placeholders.WriteString(", ")
		}
		fmt.Fprintf(&placeholders, "($1, $2, $%d, $%d, $%d, $3, now())", i+1, i+2, i+3) // project_id, environment, name, value, value_encryption_key_id, updated_by_user_id, updated_on
		i += 3
	}

	var res []*database.ProjectVariable
	err := c.getDB(ctx).SelectContext(ctx, &res, fmt.Sprintf(query, placeholders.String()), args...)
	if err != nil {
		return nil, parseErr("project variables", err)
	}

	// Decrypt the variables
	err = c.decryptProjectVariables(res)
	if err != nil {
		return nil, err
	}

	return res, nil
}

func (c *connection) DeleteProjectVariables(ctx context.Context, projectID, environment string, names []string) error {
	if len(names) == 0 {