Function findByProjectName

backend/plugins/webhook/api/deployments.go:357–389

findByProjectName finds the connection by project name and plugin name

(connection interface{}, params map[string]string, pluginName string, webhookName string)

// findByProjectName finds the connection by project name and plugin name
func findByProjectName(connection interface{}, params map[string]string, pluginName string, webhookName string) errors.Error {
	projectName := params["projectName"]
	if projectName == "" {
		return errors.BadInput.New("missing projectName")
	}
	if len(projectName) > 100 {
		return errors.BadInput.New("invalid projectName")
	}
	if pluginName == "" {
		return errors.BadInput.New("missing pluginName")
	}
	// We need to join three tables: _tool_webhook_connections, _devlake_blueprint_connections, and _devlake_blueprints
	// to find the connection associated with the given project name and plugin name.
	// The SQL query would look something like this:
	// SELECT wc.*
	// FROM _tool_webhook_connections AS wc
	// JOIN _devlake_blueprint_connections AS bc ON wc.id = bc.connection_id AND bc.plugin_name = ?
	// JOIN _devlake_blueprints AS bp ON bc.blueprint_id = bp.id
	// WHERE bp.project_name = ? and _tool_webhook_connections.name = ?
	// LIMIT 1;

	basicRes.GetLogger().Debug("finding project webhook connection for project %s and plugin %s", projectName, pluginName)
	// Using DAL to construct the query
	clauses := []dal.Clause{dal.From(connection)}
	clauses = append(clauses,
		dal.Join("left join _devlake_blueprint_connections bc ON _tool_webhook_connections.id = bc.connection_id and bc.plugin_name = ?", pluginName),
		dal.Join("left join _devlake_blueprints bp ON bc.blueprint_id = bp.id"),
		dal.Where("bp.project_name = ? and _tool_webhook_connections.name = ?", projectName, webhookName),
	)

	dal := basicRes.GetDal()
	return dal.First(connection, clauses...)
}