Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Feat/include actions #20

Merged
merged 7 commits into from
Mar 7, 2024
Merged

Feat/include actions #20

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
237ba5f
feat: Added two more actions to discord activity!
amindadgar Mar 5, 2024
d96921e
feat: including the actions for activity!
amindadgar Mar 5, 2024
3a916a7
feat: fix import error!
amindadgar Mar 5, 2024
0c13206
update: interaction and actions compute method!
amindadgar Mar 5, 2024
c713abe
fix: wrong function call!
amindadgar Mar 5, 2024
dc76942
feat: Added test case for actions!
amindadgar Mar 6, 2024
bfbac01
feat: Added more test cases to ensure everything's working properly!
amindadgar Mar 6, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion setup.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

setup(
name="tc-core-analyzer-lib",
version="1.1.0",
version="1.2.0",
author="Mohammad Amin Dadgar, TogetherCrew",
maintainer="Mohammad Amin Dadgar",
maintainer_email="[email protected]",
Expand Down
100 changes: 100 additions & 0 deletions tc_core_analyzer_lib/tests/integration/test_assess_mention.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,100 @@
from unittest import TestCase

import numpy as np
from tc_core_analyzer_lib.assess_engagement import EngagementAssessment
from tc_core_analyzer_lib.utils.activity import DiscordActivity


class TestAssessMentions(TestCase):
def setUp(self) -> None:
self.window_days = 7
self.action_params = {
"INT_THR": 1,
"UW_DEG_THR": 1,
"PAUSED_T_THR": 1,
"CON_T_THR": 4,
"CON_O_THR": 3,
"EDGE_STR_THR": 5,
"UW_THR_DEG_THR": 5,
"VITAL_T_THR": 4,
"VITAL_O_THR": 3,
"STILL_T_THR": 2,
"STILL_O_THR": 2,
"DROP_H_THR": 2,
"DROP_I_THR": 1,
}

def test_assess_single_reply(self):
acc_names = []
acc_count = 5
for i in range(5):
acc_names.append(f"user{i}")

acc_names = np.array(acc_names)

int_mat = {
DiscordActivity.Reply: np.zeros((acc_count, acc_count)),
DiscordActivity.Mention: np.zeros((acc_count, acc_count)),
DiscordActivity.Reaction: np.zeros((acc_count, acc_count)),
DiscordActivity.Lone_msg: np.zeros((acc_count, acc_count)),
DiscordActivity.Thread_msg: np.zeros((acc_count, acc_count)),
}

# user0 mentioning user1
int_mat[DiscordActivity.Mention][0, 1] = 1

activity_dict = {
"all_joined": {"0": set()},
"all_joined_day": {"0": set()},
"all_consistent": {},
"all_vital": {},
"all_active": {},
"all_connected": {},
"all_paused": {},
"all_new_disengaged": {},
"all_disengaged": {},
"all_unpaused": {},
"all_returned": {},
"all_new_active": {},
"all_still_active": {},
"all_dropped": {},
"all_disengaged_were_newly_active": {},
"all_disengaged_were_consistently_active": {},
"all_disengaged_were_vital": {},
"all_lurker": {},
"all_about_to_disengage": {},
"all_disengaged_in_past": {},
}
# window index
w_i = 0

activities = [
DiscordActivity.Reaction,
DiscordActivity.Mention,
DiscordActivity.Reply,
DiscordActivity.Lone_msg,
DiscordActivity.Thread_msg,
]

engagement = EngagementAssessment(
activities=activities,
activities_ignore_0_axis=[
DiscordActivity.Mention,
DiscordActivity.Reaction,
DiscordActivity.Reply,
],
activities_ignore_1_axis=[],
)

(_, *computed_activities) = engagement.compute(
int_mat=int_mat,
w_i=w_i,
acc_names=acc_names,
act_param=self.action_params,
WINDOW_D=self.window_days,
**activity_dict,
)

computed_activities = dict(zip(activity_dict.keys(), computed_activities))

self.assertEqual(computed_activities["all_active"], {"0": set(["user0"])})
100 changes: 100 additions & 0 deletions tc_core_analyzer_lib/tests/integration/test_assess_reactions.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,100 @@
from unittest import TestCase

import numpy as np
from tc_core_analyzer_lib.assess_engagement import EngagementAssessment
from tc_core_analyzer_lib.utils.activity import DiscordActivity


class TestAssessReactions(TestCase):
def setUp(self) -> None:
self.window_days = 7
self.action_params = {
"INT_THR": 1,
"UW_DEG_THR": 1,
"PAUSED_T_THR": 1,
"CON_T_THR": 4,
"CON_O_THR": 3,
"EDGE_STR_THR": 5,
"UW_THR_DEG_THR": 5,
"VITAL_T_THR": 4,
"VITAL_O_THR": 3,
"STILL_T_THR": 2,
"STILL_O_THR": 2,
"DROP_H_THR": 2,
"DROP_I_THR": 1,
}

def test_assess_single_reaction(self):
acc_names = []
acc_count = 5
for i in range(5):
acc_names.append(f"user{i}")

acc_names = np.array(acc_names)

int_mat = {
DiscordActivity.Reply: np.zeros((acc_count, acc_count)),
DiscordActivity.Mention: np.zeros((acc_count, acc_count)),
DiscordActivity.Reaction: np.zeros((acc_count, acc_count)),
DiscordActivity.Lone_msg: np.zeros((acc_count, acc_count)),
DiscordActivity.Thread_msg: np.zeros((acc_count, acc_count)),
}

# user0 reacting to user1
int_mat[DiscordActivity.Reaction][0, 1] = 1

activity_dict = {
"all_joined": {"0": set()},
"all_joined_day": {"0": set()},
"all_consistent": {},
"all_vital": {},
"all_active": {},
"all_connected": {},
"all_paused": {},
"all_new_disengaged": {},
"all_disengaged": {},
"all_unpaused": {},
"all_returned": {},
"all_new_active": {},
"all_still_active": {},
"all_dropped": {},
"all_disengaged_were_newly_active": {},
"all_disengaged_were_consistently_active": {},
"all_disengaged_were_vital": {},
"all_lurker": {},
"all_about_to_disengage": {},
"all_disengaged_in_past": {},
}
# window index
w_i = 0

activities = [
DiscordActivity.Reaction,
DiscordActivity.Mention,
DiscordActivity.Reply,
DiscordActivity.Lone_msg,
DiscordActivity.Thread_msg,
]

engagement = EngagementAssessment(
activities=activities,
activities_ignore_0_axis=[
DiscordActivity.Mention,
DiscordActivity.Reaction,
DiscordActivity.Reply,
],
activities_ignore_1_axis=[],
)

(_, *computed_activities) = engagement.compute(
int_mat=int_mat,
w_i=w_i,
acc_names=acc_names,
act_param=self.action_params,
WINDOW_D=self.window_days,
**activity_dict,
)

computed_activities = dict(zip(activity_dict.keys(), computed_activities))

self.assertEqual(computed_activities["all_active"], {"0": set(["user0"])})
100 changes: 100 additions & 0 deletions tc_core_analyzer_lib/tests/integration/test_assess_replies.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,100 @@
from unittest import TestCase

import numpy as np
from tc_core_analyzer_lib.assess_engagement import EngagementAssessment
from tc_core_analyzer_lib.utils.activity import DiscordActivity


class TestAssessReplies(TestCase):
def setUp(self) -> None:
self.window_days = 7
self.action_params = {
"INT_THR": 1,
"UW_DEG_THR": 1,
"PAUSED_T_THR": 1,
"CON_T_THR": 4,
"CON_O_THR": 3,
"EDGE_STR_THR": 5,
"UW_THR_DEG_THR": 5,
"VITAL_T_THR": 4,
"VITAL_O_THR": 3,
"STILL_T_THR": 2,
"STILL_O_THR": 2,
"DROP_H_THR": 2,
"DROP_I_THR": 1,
}

def test_assess_single_reply(self):
acc_names = []
acc_count = 5
for i in range(5):
acc_names.append(f"user{i}")

acc_names = np.array(acc_names)

int_mat = {
DiscordActivity.Reply: np.zeros((acc_count, acc_count)),
DiscordActivity.Mention: np.zeros((acc_count, acc_count)),
DiscordActivity.Reaction: np.zeros((acc_count, acc_count)),
DiscordActivity.Lone_msg: np.zeros((acc_count, acc_count)),
DiscordActivity.Thread_msg: np.zeros((acc_count, acc_count)),
}

# user0 replying user1
int_mat[DiscordActivity.Reply][0, 1] = 1

activity_dict = {
"all_joined": {"0": set()},
"all_joined_day": {"0": set()},
"all_consistent": {},
"all_vital": {},
"all_active": {},
"all_connected": {},
"all_paused": {},
"all_new_disengaged": {},
"all_disengaged": {},
"all_unpaused": {},
"all_returned": {},
"all_new_active": {},
"all_still_active": {},
"all_dropped": {},
"all_disengaged_were_newly_active": {},
"all_disengaged_were_consistently_active": {},
"all_disengaged_were_vital": {},
"all_lurker": {},
"all_about_to_disengage": {},
"all_disengaged_in_past": {},
}
# window index
w_i = 0

activities = [
DiscordActivity.Reaction,
DiscordActivity.Mention,
DiscordActivity.Reply,
DiscordActivity.Lone_msg,
DiscordActivity.Thread_msg,
]

engagement = EngagementAssessment(
activities=activities,
activities_ignore_0_axis=[
DiscordActivity.Mention,
DiscordActivity.Reaction,
DiscordActivity.Reply,
],
activities_ignore_1_axis=[],
)

(_, *computed_activities) = engagement.compute(
int_mat=int_mat,
w_i=w_i,
acc_names=acc_names,
act_param=self.action_params,
WINDOW_D=self.window_days,
**activity_dict,
)

computed_activities = dict(zip(activity_dict.keys(), computed_activities))

self.assertEqual(computed_activities["all_active"], {"0": set(["user0"])})
Loading
Loading