eosclientbinary: add eos label (#3778)

cs3org · Apr 11, 2023 · 545a88c · 545a88c
1 parent 909d369
commit 545a88c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/changelog/unreleased/eosbinary-tag.md b/changelog/unreleased/eosbinary-tag.md
@@ -0,0 +1,5 @@
+Enhancement: Add support to tag eos traffic
+
+We've added support to tag eos traffic
+
+https://github.com/cs3org/reva/pull/3778
diff --git a/pkg/eosclient/eosbinary/eosbinary.go b/pkg/eosclient/eosbinary/eosbinary.go
@@ -240,6 +240,9 @@ func (c *Client) executeEOS(ctx context.Context, cmdArgs []string, auth eosclien
 
 	cmd.Args = append(cmd.Args, cmdArgs...)
 
+	// add application label
+	cmd.Args = append(cmd.Args, "-a", "reva_eosclient::meta")
+
 	span := trace.SpanFromContext(ctx)
 	cmd.Args = append(cmd.Args, "--comment", span.SpanContext().TraceID().String())
 
@@ -740,7 +743,7 @@ func (c *Client) Read(ctx context.Context, auth eosclient.Authorization, path st
 	if auth.Token != "" {
 		args[3] += "?authz=" + auth.Token
 	} else if auth.Role.UID != "" && auth.Role.GID != "" {
-		args = append(args, fmt.Sprintf("-OSeos.ruid=%s&eos.rgid=%s", auth.Role.UID, auth.Role.GID))
+		args = append(args, fmt.Sprintf("-OSeos.ruid=%s&eos.rgid=%s&eos.app=reva_eosclient::read", auth.Role.UID, auth.Role.GID))
 	}
 
 	_, _, err := c.executeXRDCopy(ctx, args)
@@ -776,7 +779,7 @@ func (c *Client) WriteFile(ctx context.Context, auth eosclient.Authorization, pa
 	if auth.Token != "" {
 		args[4] += "?authz=" + auth.Token
 	} else if auth.Role.UID != "" && auth.Role.GID != "" {
-		args = append(args, fmt.Sprintf("-ODeos.ruid=%s&eos.rgid=%s", auth.Role.UID, auth.Role.GID))
+		args = append(args, fmt.Sprintf("-ODeos.ruid=%s&eos.rgid=%s&eos.app=reva_eosclient::write", auth.Role.UID, auth.Role.GID))
 	}
 
 	_, _, err := c.executeXRDCopy(ctx, args)