From 155fc72db15f35cacce5cd7a7029aa0632c0b97e Mon Sep 17 00:00:00 2001
From: Khushi Patel <khushipatel1033@gmail.com>
Date: Wed, 1 Apr 2026 14:36:16 -0400
Subject: [PATCH] feat: send set_user_attributes event

---
 src/Rokt-Kit.js   |   6 +++
 test/src/tests.js | 122 ++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 128 insertions(+)

diff --git a/src/Rokt-Kit.js b/src/Rokt-Kit.js
index 0e4e697..4778205 100644
--- a/src/Rokt-Kit.js
+++ b/src/Rokt-Kit.js
@@ -642,6 +642,12 @@ var constructor = function () {
 
     function setUserAttribute(key, value) {
         self.userAttributes[key] = value;
+        _sendEventStream(
+            _buildIdentityEvent(
+                'set_user_attributes',
+                self.filters.filteredUser || {}
+            )
+        );
     }
 
     function removeUserAttribute(key) {
diff --git a/test/src/tests.js b/test/src/tests.js
index c95ca9c..4cc16a8 100644
--- a/test/src/tests.js
+++ b/test/src/tests.js
@@ -3111,6 +3111,128 @@ describe('Rokt Forwarder', () => {
                 'test-attribute': 'test-value',
             });
         });
+
+        describe('event stream', () => {
+            beforeEach(() => {
+                window.mParticle.forwarder.eventStreamQueue = [];
+                window.mParticle.sessionManager = {
+                    getSession: function () {
+                        return 'test-mp-session-id';
+                    },
+                };
+            });
+
+            afterEach(() => {
+                delete window.Rokt.__event_stream__;
+                window.mParticle.forwarder.eventStreamQueue = [];
+            });
+
+            it('should send a set_user_attributes event to window.Rokt.__event_stream__', () => {
+                var receivedEvents = [];
+                window.Rokt.__event_stream__ = function (event) {
+                    receivedEvents.push(event);
+                };
+
+                window.mParticle.forwarder.setUserAttribute(
+                    'test-attribute',
+                    'test-value'
+                );
+
+                receivedEvents.length.should.equal(1);
+                receivedEvents[0].EventName.should.equal('set_user_attributes');
+                receivedEvents[0].EventDataType.should.equal(14);
+            });
+
+            it('should include updated UserAttributes in the event', () => {
+                var receivedEvents = [];
+                window.Rokt.__event_stream__ = function (event) {
+                    receivedEvents.push(event);
+                };
+
+                window.mParticle.forwarder.setUserAttribute(
+                    'new-attr',
+                    'new-value'
+                );
+
+                receivedEvents[0].UserAttributes.should.deepEqual({
+                    'new-attr': 'new-value',
+                });
+            });
+
+            it('should include MPID from filteredUser and SessionId from sessionManager', () => {
+                var receivedEvents = [];
+                window.Rokt.__event_stream__ = function (event) {
+                    receivedEvents.push(event);
+                };
+
+                window.mParticle.forwarder.filters.filteredUser = {
+                    getMPID: function () {
+                        return 'attr-mpid-123';
+                    },
+                    getUserIdentities: function () {
+                        return {
+                            userIdentities: { email: 'user@example.com' },
+                        };
+                    },
+                };
+
+                window.mParticle.forwarder.setUserAttribute('k', 'v');
+
+                receivedEvents[0].MPID.should.equal('attr-mpid-123');
+                receivedEvents[0].SessionId.should.equal('test-mp-session-id');
+                receivedEvents[0].UserIdentities.should.deepEqual({
+                    email: 'user@example.com',
+                });
+            });
+
+            it('should include null MPID and null UserIdentities when filteredUser is not set', () => {
+                var receivedEvents = [];
+                window.Rokt.__event_stream__ = function (event) {
+                    receivedEvents.push(event);
+                };
+
+                window.mParticle.forwarder.filters.filteredUser = null;
+                window.mParticle.forwarder.setUserAttribute('k', 'v');
+
+                (receivedEvents[0].MPID === null).should.be.true();
+                (receivedEvents[0].UserIdentities === null).should.be.true();
+            });
+
+            it('should queue event when window.Rokt.__event_stream__ is not available', () => {
+                window.mParticle.forwarder.setUserAttribute(
+                    'queued-attr',
+                    'queued-value'
+                );
+
+                window.mParticle.forwarder.eventStreamQueue.length.should.equal(
+                    1
+                );
+                window.mParticle.forwarder.eventStreamQueue[0].EventName.should.equal(
+                    'set_user_attributes'
+                );
+                window.mParticle.forwarder.eventStreamQueue[0].EventDataType.should.equal(
+                    14
+                );
+            });
+
+            it('should not throw when window.Rokt is undefined', () => {
+                var savedRokt = window.Rokt;
+                window.Rokt = undefined;
+
+                (function () {
+                    window.mParticle.forwarder.setUserAttribute('k', 'v');
+                }).should.not.throw();
+
+                window.mParticle.forwarder.eventStreamQueue.length.should.equal(
+                    1
+                );
+                window.mParticle.forwarder.eventStreamQueue[0].EventName.should.equal(
+                    'set_user_attributes'
+                );
+
+                window.Rokt = savedRokt;
+            });
+        });
     });
 
     describe('#removeUserAttribute', () => {