refactor: identity format

internal/core/plugin_manager/aws_manager/environment.go

@@ -33,6 +33,10 @@ func (r *AWSPluginRuntime) InitEnvironment() error {
 	return nil
 }
 
+func (r *AWSPluginRuntime) Identity() (string, error) {
+	return fmt.Sprintf("%s@%s", r.Config.Identity(), r.Checksum()), nil
+}
+
 func (r *AWSPluginRuntime) initEnvironment() error {
 	r.Log("Starting to initialize environment")
 	// check if the plugin has already been initialized, at most 300s
@@ -96,7 +100,3 @@ func (r *AWSPluginRuntime) initEnvironment() error {
 
 	return nil
 }
-
-func (r *AWSPluginRuntime) Checksum() string {
-	return ""
-}

internal/core/plugin_manager/local_manager/environment.go

@@ -123,3 +123,7 @@ func (r *LocalPluginRuntime) InitEnvironment() error {
 
 	return nil
 }
+
+func (r *LocalPluginRuntime) Identity() (string, error) {
+	return fmt.Sprintf("%s@%s", r.Config.Identity(), r.Checksum()), nil
+}

internal/core/plugin_manager/remote_manager/environment.go

@@ -1,11 +1,13 @@
 package remote_manager
 
 import (
+	"fmt"
 	"strings"
 )
 
 func (r *RemotePluginRuntime) Identity() (string, error) {
-	return strings.Join([]string{r.Configuration().Identity(), r.tenant_id}, ":"), nil
+	identity := strings.Join([]string{r.Configuration().Identity(), r.tenant_id}, ":")
+	return fmt.Sprintf("%s@%s", identity, r.Checksum()), nil
 }
 
 func (r *RemotePluginRuntime) Cleanup() {

internal/types/entities/plugin_entities/runtime.go

@@ -105,10 +105,6 @@ func (r *PluginRuntime) Configuration() *PluginDeclaration {
 	return &r.Config
 }
 
-func (r *PluginRuntime) Identity() (string, error) {
-	return r.Config.Identity(), nil
-}
-
 func HashedIdentity(identity string) string {
 	hash := sha256.New()
 	hash.Write([]byte(identity))