Function taskPluginProtocolRendererContext

controller/plugin_protocol.go:1154–1198

(
	request pluginruntime.ProtocolRequestContext,
	pinned pluginruntime.PinnedEndpoint,
	task *model.Task,
	artifactContentURL func(taskID, artifactKey string) (string, error),
)

}

func taskPluginProtocolRendererContext(
	request pluginruntime.ProtocolRequestContext,
	pinned pluginruntime.PinnedEndpoint,
	task *model.Task,
	artifactContentURL func(taskID, artifactKey string) (string, error),
) (map[string]any, error) {
	rendererContext := request.JSValue()
	if task == nil || task.Status != model.TaskStatusSuccess {
		return rendererContext, nil
	}
	if pinned.Plugin == nil {
		return nil, errors.New("task artifact projection is unavailable")
	}

	artifacts, err := taskjsplugin.New(pinned.Plugin).ListArtifacts(task)
	if err != nil {
		return nil, fmt.Errorf("project task artifacts: %w", err)
	}
	artifacts, err = validateProjectedTaskArtifacts(artifacts)
	if err != nil {
		return nil, err
	}
	if len(artifacts) > 0 && artifactContentURL == nil {
		return nil, errors.New("task artifact projection is unavailable")
	}

	rendererArtifacts := make(map[string]any, len(artifacts))
	for _, artifact := range artifacts {
		contentURL, buildErr := artifactContentURL(task.TaskID, artifact.Key)
		if buildErr != nil {
			return nil, fmt.Errorf("build task artifact content URL: %w", buildErr)
		}
		item := map[string]any{
			"key":  artifact.Key,
			"type": artifact.Type,
			"url":  contentURL,
		}
		if artifact.MimeType != "" {
			item["mimeType"] = artifact.MimeType
		}
		rendererArtifacts[artifact.Key] = item
	}
	rendererContext["artifacts"] = rendererArtifacts
	return rendererContext, nil
}

func pluginProtocolTickDelay(taskID string, tick uint64, base, jitter time.Duration) time.Duration {
	if jitter <= 0 {