Function networkIntegrationGet

cmd/incusd/network_integrations.go:502–597

swagger:operation GET /1.0/network-integrations/{integration} network-integrations network_integration_get Get the network integration Gets a specific network integration. --- produces: - application/json parameters: - in: path name: integration description: Integration name

(d *Daemon, r *http.Request)

//	  "500":
//	    $ref: "#/responses/InternalServerError"
func networkIntegrationGet(d *Daemon, r *http.Request) response.Response {
	s := d.State()

	// Get the integration name.
	integrationName, err := pathVar(r, "integration")
	if err != nil {
		return response.SmartError(err)
	}

	// Network integrations aren't project aware, we only load the per-project data to apply name restrictions.
	projectName := request.ProjectParam(r)

	// Get the integration.
	var info *api.NetworkIntegration

	err = s.DB.Cluster.Transaction(r.Context(), func(ctx context.Context, tx *db.ClusterTx) error {
		// Get the project.
		dbProject, err := dbCluster.GetProject(ctx, tx.Tx(), projectName)
		if err != nil {
			return fmt.Errorf("Failed to load network restrictions from project %q: %w", projectName, err)
		}

		p, err := dbProject.ToAPI(ctx, tx.Tx())
		if err != nil {
			return fmt.Errorf("Failed to load network restrictions from project %q: %w", projectName, err)
		}

		// Filter for project restrictions.
		if !project.NetworkIntegrationAllowed(p.Config, integrationName) {
			return nil
		}

		// Get the integration.
		dbRecord, err := dbCluster.GetNetworkIntegration(ctx, tx.Tx(), integrationName)
		if err != nil {
			return err
		}

		info, err = dbRecord.ToAPI(ctx, tx.Tx())
		if err != nil {
			return err
		}

		// Check if the user should see the configuration.
		err = s.Authorizer.CheckPermission(r.Context(), r, auth.ObjectNetworkIntegration(info.Name), auth.EntitlementCanEdit)
		if err != nil {
			info.Config = map[string]string{}
		}

		// Add UsedBy field.
		integrationID := dbRecord.ID
		allPeers, err := dbCluster.GetNetworkPeers(ctx, tx.Tx()) // Fetch all peers
		if err != nil {
			return fmt.Errorf("Failed to load network peers: %w", err)
		}

		usedBy := []string{}
		for _, peer := range allPeers {