add source for plugin task query api (#628)

Author: zyssyz123

internal/service/install_plugin.go

@@ -108,7 +108,7 @@ func InstallMultiplePluginsToTenant(
 	}
 
 	// create tasks for each plugin
-	statuses := buildTaskStatuses(pluginUniqueIdentifiers, declarations)
+	statuses := buildTaskStatuses(pluginUniqueIdentifiers, declarations, source)
 	taskRegistry, err := createInstallTasks(tenants, statuses)
 	if err != nil {
 		return exception.InternalServerError(err).ToResponse()
@@ -285,6 +285,7 @@ func UpgradePlugin(
 	statuses := buildTaskStatuses(
 		[]plugin_entities.PluginUniqueIdentifier{newPluginUniqueIdentifier},
 		[]*plugin_entities.PluginDeclaration{{}},
+		source,
 	)
 
 	taskRegistry, err := createInstallTasks(tenants, statuses)

internal/service/install_plugin_utils.go

@@ -10,6 +10,7 @@ import (
 func buildTaskStatuses(
 	pluginUniqueIdentifiers []plugin_entities.PluginUniqueIdentifier,
 	declarations []*plugin_entities.PluginDeclaration,
+	source string,
 ) []models.InstallTaskPluginStatus {
 	statuses := make([]models.InstallTaskPluginStatus, len(pluginUniqueIdentifiers))
 	for i, identifier := range pluginUniqueIdentifiers {
@@ -21,6 +22,7 @@ func buildTaskStatuses(
 			IconDark:               declarations[i].IconDark,
 			Labels:                 declarations[i].Label,
 			Message:                "",
+			Source:                 source,
 		}
 	}
 	return statuses

internal/types/models/task.go

@@ -19,6 +19,7 @@ type InstallTaskPluginStatus struct {
 	PluginID               string                                 `json:"plugin_id"`
 	Status                 InstallTaskStatus                      `json:"status"`
 	Message                string                                 `json:"message"`
+	Source                 string                                 `json:"source"`
 }
 
 type InstallTask struct {