Compare commits
51 commits
feature/ai
...
main
Author | SHA1 | Date | |
---|---|---|---|
|
014f55a2c4 | ||
|
9e308c1cfd | ||
|
d9f21f3606 | ||
|
74a2d4f196 | ||
|
555ff14e29 | ||
|
8e2cac27fa | ||
|
22ef4fa77e | ||
|
5e2951efd0 | ||
|
cc8f955b02 | ||
|
ed1a6dedd3 | ||
|
218a74b1cf | ||
|
cd28a560cc | ||
|
2e96f58cce | ||
|
f4f67656ad | ||
|
87401f7ac0 | ||
|
caade24f8c | ||
|
e3df5d715e | ||
|
e2cd688eff | ||
|
e662e5b7aa | ||
|
7a6f64fce0 | ||
|
a0fbd7aa9b | ||
|
179cdc9bd7 | ||
|
a00770c8a9 | ||
|
9af5572346 | ||
|
4dc0156f23 | ||
|
d64a6b5652 | ||
|
2cd4820f1c | ||
|
81bb48ff54 | ||
|
bab31cb0f8 | ||
|
747c11ac85 | ||
|
f4a3a3d86a | ||
|
e41627ffc7 | ||
|
2a601849dc | ||
|
cffb761c4d | ||
|
d637f2a0ee | ||
|
7ed839d391 | ||
|
8a64f84140 | ||
|
202f7b7eb6 | ||
|
0c2fdf5591 | ||
|
4d445f3408 | ||
|
3d928b6437 | ||
|
58da718c5d | ||
|
bc78e2f2cb | ||
|
f1a0ed3ab1 | ||
|
e1010793dc | ||
|
58d4af812d | ||
|
33bc5ca0bb | ||
|
1277dbb132 | ||
|
6178592d10 | ||
|
dc1f7b6376 | ||
|
abca50d615 |
39 changed files with 3490 additions and 1066 deletions
1
.gitignore
vendored
1
.gitignore
vendored
|
@ -2,6 +2,7 @@ __pycache__
|
|||
venv
|
||||
config.py
|
||||
misp_cache.sqlite
|
||||
backup.json
|
||||
|
||||
# Logs
|
||||
logs
|
||||
|
|
|
@ -1,4 +1,6 @@
|
|||
# misp-exercise-dashboard
|
||||
# SkillAegis
|
||||
|
||||
<img alt="SkillAegis Logo" src="src/assets/skillaegis-logo.svg"/>
|
||||
|
||||
## Installation
|
||||
```bash
|
||||
|
|
1
active_exercises/spearphishing-incident.json
Symbolic link
1
active_exercises/spearphishing-incident.json
Symbolic link
|
@ -0,0 +1 @@
|
|||
../exercises/spearphishing-incident.json
|
38
appConfig.py
Normal file
38
appConfig.py
Normal file
|
@ -0,0 +1,38 @@
|
|||
|
||||
live_logs_accepted_scope = {
|
||||
'events': ['add', 'edit', 'delete', 'restSearch',],
|
||||
'attributes': ['add', 'add_attachment', 'edit', 'revise_object', 'delete', 'restSearch',],
|
||||
'eventReports': ['add', 'edit', 'delete',],
|
||||
'tags': '*',
|
||||
}
|
||||
|
||||
user_activity_accepted_scope = {
|
||||
'events': ['view', 'add', 'edit', 'delete', 'restSearch',],
|
||||
'attributes': ['add', 'add_attachment', 'edit', 'delete', 'restSearch',],
|
||||
'objects': ['add', 'edit', 'revise_object', 'delete',],
|
||||
'eventReports': ['view', 'add', 'edit', 'delete',],
|
||||
'tags': '*',
|
||||
}
|
||||
|
||||
misp_settings = {
|
||||
'Plugin.ZeroMQ_enable': True,
|
||||
'Plugin.ZeroMQ_audit_notifications_enable': True,
|
||||
'Plugin.ZeroMQ_event_notifications_enable': True,
|
||||
'Plugin.ZeroMQ_attribute_notifications_enable': True,
|
||||
'MISP.log_paranoid': True,
|
||||
'MISP.log_paranoid_skip_db': True,
|
||||
'MISP.log_paranoid_include_post_body': True,
|
||||
'MISP.log_auth': True,
|
||||
'Security.allow_unsafe_cleartext_apikey_logging': True,
|
||||
}
|
||||
|
||||
import logging
|
||||
logger = logging.getLogger('SkillAegis')
|
||||
format = '[%(levelname)s] %(asctime)s - %(message)s'
|
||||
formatter = logging.Formatter(format)
|
||||
logging.basicConfig(filename='SkillAegis.log', encoding='utf-8', level=logging.DEBUG, format=format)
|
||||
# create console handler and set level to debug
|
||||
ch = logging.StreamHandler()
|
||||
ch.setLevel(logging.INFO)
|
||||
ch.setFormatter(formatter)
|
||||
logger.addHandler(ch)
|
|
@ -6,19 +6,3 @@ zmq_url = 'tcp://localhost:50000'
|
|||
misp_url = 'https://localhost/'
|
||||
misp_apikey = 'FI4gCRghRZvLVjlLPLTFZ852x2njkkgPSz0zQ3E0'
|
||||
misp_skipssl = True
|
||||
|
||||
live_logs_accepted_scope = {
|
||||
'events': ['add', 'edit', 'delete', 'restSearch',],
|
||||
'attributes': ['add', 'edit', 'delete', 'restSearch',],
|
||||
'tags': '*',
|
||||
}
|
||||
|
||||
import logging
|
||||
logger = logging.getLogger('misp-exercise-dashboard')
|
||||
format = '[%(levelname)s] %(asctime)s - %(message)s'
|
||||
formatter = logging.Formatter(format)
|
||||
logging.basicConfig(filename='misp-exercise-dashboard.log', encoding='utf-8', level=logging.DEBUG, format=format)
|
||||
ch = logging.StreamHandler()
|
||||
ch.setLevel(logging.INFO)
|
||||
ch.setFormatter(formatter)
|
||||
logger.addHandler(ch)
|
||||
|
|
36
db.py
36
db.py
|
@ -5,17 +5,49 @@ import collections
|
|||
|
||||
USER_ID_TO_EMAIL_MAPPING = {}
|
||||
USER_ID_TO_AUTHKEY_MAPPING = {}
|
||||
|
||||
ALL_EXERCISES = []
|
||||
SELECTED_EXERCISES = []
|
||||
INJECT_BY_UUID = {}
|
||||
INJECT_SEQUENCE_BY_INJECT_UUID = {}
|
||||
INJECT_REQUIREMENTS_BY_INJECT_UUID = {}
|
||||
EXERCISES_STATUS = {}
|
||||
PROGRESS = {
|
||||
}
|
||||
|
||||
NOTIFICATION_BUFFER_SIZE = 30
|
||||
NOTIFICATION_MESSAGES = collections.deque([], NOTIFICATION_BUFFER_SIZE)
|
||||
|
||||
NOTIFICATION_HISTORY_BUFFER_RESOLUTION_PER_MIN = 12
|
||||
NOTIFICATION_HISTORY_BUFFER_TIMESPAN_MIN = 20
|
||||
NOTIFICATION_HISTORY_FREQUENCY = 60 / NOTIFICATION_HISTORY_BUFFER_RESOLUTION_PER_MIN
|
||||
notification_history_buffer_size = NOTIFICATION_HISTORY_BUFFER_RESOLUTION_PER_MIN * NOTIFICATION_HISTORY_BUFFER_TIMESPAN_MIN
|
||||
NOTIFICATION_HISTORY = collections.deque([], notification_history_buffer_size)
|
||||
NOTIFICATION_HISTORY.extend([0] * notification_history_buffer_size)
|
||||
|
||||
USER_ACTIVITY_BUFFER_RESOLUTION_PER_MIN = 2
|
||||
USER_ACTIVITY_TIMESPAN_MIN = 20
|
||||
USER_ACTIVITY_FREQUENCY = 60 / USER_ACTIVITY_BUFFER_RESOLUTION_PER_MIN
|
||||
USER_ACTIVITY = {}
|
||||
user_activity_buffer_size = USER_ACTIVITY_BUFFER_RESOLUTION_PER_MIN * USER_ACTIVITY_TIMESPAN_MIN
|
||||
|
||||
|
||||
def resetNotificationMessage():
|
||||
global NOTIFICATION_MESSAGES
|
||||
NOTIFICATION_MESSAGES = collections.deque([], NOTIFICATION_BUFFER_SIZE)
|
||||
|
||||
def resetNotificationHistory():
|
||||
global NOTIFICATION_HISTORY
|
||||
NOTIFICATION_HISTORY = collections.deque([], notification_history_buffer_size)
|
||||
NOTIFICATION_HISTORY.extend([0] * notification_history_buffer_size)
|
||||
|
||||
def addUserActivity(user_id: int, count: int):
|
||||
global USER_ACTIVITY, USER_ACTIVITY_TIMESPAN_MIN
|
||||
|
||||
if user_id not in USER_ACTIVITY:
|
||||
USER_ACTIVITY[user_id] = collections.deque([], user_activity_buffer_size)
|
||||
USER_ACTIVITY[user_id].extend([0] * user_activity_buffer_size)
|
||||
USER_ACTIVITY[user_id].append(count)
|
||||
|
||||
def resetUserActivity():
|
||||
for user_id in USER_ACTIVITY.keys():
|
||||
USER_ACTIVITY[user_id] = collections.deque([], user_activity_buffer_size)
|
||||
USER_ACTIVITY[user_id].extend([0] * user_activity_buffer_size)
|
File diff suppressed because one or more lines are too long
1487
dist/assets/index-BS0mgB3_.js
vendored
Normal file
1487
dist/assets/index-BS0mgB3_.js
vendored
Normal file
File diff suppressed because one or more lines are too long
778
dist/assets/index-C72pAF6z.js
vendored
778
dist/assets/index-C72pAF6z.js
vendored
File diff suppressed because one or more lines are too long
4
dist/index.html
vendored
4
dist/index.html
vendored
|
@ -5,8 +5,8 @@
|
|||
<link rel="icon" href="/favicon.ico">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>Vite App</title>
|
||||
<script type="module" crossorigin src="/assets/index-C72pAF6z.js"></script>
|
||||
<link rel="stylesheet" crossorigin href="/assets/index-BZKBaN7W.css">
|
||||
<script type="module" crossorigin src="/assets/index-BS0mgB3_.js"></script>
|
||||
<link rel="stylesheet" crossorigin href="/assets/index-7ybfbefL.css">
|
||||
</head>
|
||||
<body>
|
||||
<div id="app"></div>
|
||||
|
|
92
exercise.py
92
exercise.py
|
@ -11,11 +11,11 @@ import jq
|
|||
import db
|
||||
from inject_evaluator import eval_data_filtering, eval_query_mirror, eval_query_search
|
||||
import misp_api
|
||||
import config
|
||||
from config import logger
|
||||
from appConfig import logger
|
||||
|
||||
|
||||
ACTIVE_EXERCISES_DIR = "active_exercises"
|
||||
LAST_BACKUP = {}
|
||||
|
||||
def debounce_check_active_tasks(debounce_seconds: int = 1):
|
||||
func_last_execution_time = {}
|
||||
|
@ -60,6 +60,49 @@ def read_exercise_dir():
|
|||
return exercises
|
||||
|
||||
|
||||
def backup_exercises_progress():
|
||||
global LAST_BACKUP
|
||||
toBackup = {
|
||||
'EXERCISES_STATUS': db.EXERCISES_STATUS,
|
||||
'SELECTED_EXERCISES': db.SELECTED_EXERCISES,
|
||||
'USER_ID_TO_EMAIL_MAPPING': db.USER_ID_TO_EMAIL_MAPPING,
|
||||
'USER_ID_TO_AUTHKEY_MAPPING': db.USER_ID_TO_AUTHKEY_MAPPING,
|
||||
}
|
||||
if toBackup != LAST_BACKUP:
|
||||
with open('backup.json', 'w') as f:
|
||||
json.dump(toBackup, f)
|
||||
LAST_BACKUP = toBackup
|
||||
|
||||
|
||||
def restore_exercices_progress():
|
||||
try:
|
||||
|
||||
with open('backup.json', 'r') as f:
|
||||
data = json.load(f)
|
||||
db.EXERCISES_STATUS = data['EXERCISES_STATUS']
|
||||
db.SELECTED_EXERCISES = data['SELECTED_EXERCISES']
|
||||
db.USER_ID_TO_EMAIL_MAPPING = {}
|
||||
for user_id_str, email in data['USER_ID_TO_EMAIL_MAPPING'].items():
|
||||
db.USER_ID_TO_EMAIL_MAPPING[int(user_id_str)] = email
|
||||
db.USER_ID_TO_AUTHKEY_MAPPING = {}
|
||||
for user_id_str, authkey in data['USER_ID_TO_AUTHKEY_MAPPING'].items():
|
||||
db.USER_ID_TO_AUTHKEY_MAPPING[int(user_id_str)] = authkey
|
||||
except:
|
||||
logger.info('Could not restore exercise progress')
|
||||
resetAll()
|
||||
|
||||
if len(db.EXERCISES_STATUS) == 0:
|
||||
init_exercises_tasks()
|
||||
|
||||
|
||||
def resetAll():
|
||||
db.EXERCISES_STATUS = {}
|
||||
db.SELECTED_EXERCISES = []
|
||||
db.USER_ID_TO_EMAIL_MAPPING = {}
|
||||
db.USER_ID_TO_AUTHKEY_MAPPING = {}
|
||||
init_exercises_tasks()
|
||||
|
||||
|
||||
def is_validate_exercises(exercises: list) -> bool:
|
||||
exercises_uuid = set()
|
||||
tasks_uuid = set()
|
||||
|
@ -181,17 +224,23 @@ def resetAllExerciseProgress():
|
|||
for exercise_status in db.EXERCISES_STATUS.values():
|
||||
for task in exercise_status['tasks'].values():
|
||||
mark_task_incomplete(user_id, exercise_status['uuid'], task['uuid'])
|
||||
backup_exercises_progress()
|
||||
|
||||
|
||||
def resetAllCommand():
|
||||
resetAll()
|
||||
backup_exercises_progress()
|
||||
|
||||
|
||||
def get_completed_tasks_for_user(user_id: int):
|
||||
completion = get_completion_for_users()[user_id]
|
||||
completion = get_completion_for_users().get(user_id, {})
|
||||
completed_tasks = {}
|
||||
for exec_uuid, tasks in completion.items():
|
||||
completed_tasks[exec_uuid] = [task_uuid for task_uuid, completed in tasks.items() if completed]
|
||||
return completed_tasks
|
||||
|
||||
def get_incomplete_tasks_for_user(user_id: int):
|
||||
completion = get_completion_for_users()[user_id]
|
||||
completion = get_completion_for_users().get(user_id, {})
|
||||
incomplete_tasks = {}
|
||||
for exec_uuid, tasks in completion.items():
|
||||
incomplete_tasks[exec_uuid] = [task_uuid for task_uuid, completed in tasks.items() if not completed]
|
||||
|
@ -212,8 +261,8 @@ def get_available_tasks_for_user(user_id: int) -> list[str]:
|
|||
|
||||
|
||||
def get_model_action(data: dict):
|
||||
if 'Log' in data:
|
||||
data = data['Log']
|
||||
if 'Log' in data or 'AuditLog' in data:
|
||||
data = data['Log'] if 'Log' in data else data['AuditLog']
|
||||
if 'model' in data and 'action' in data:
|
||||
return (data['model'], data['action'],)
|
||||
return (None, None,)
|
||||
|
@ -222,14 +271,12 @@ def is_accepted_query(data: dict) -> bool:
|
|||
model, action = get_model_action(data)
|
||||
if model in ['Event', 'Attribute', 'Object', 'Tag',]:
|
||||
if action in ['add', 'edit', 'delete', 'publish', 'tag']:
|
||||
# # improved condition below. It blocks some queries
|
||||
# if data['Log']['change'].startswith('attribute_count'):
|
||||
# return False
|
||||
if 'Log' in data:
|
||||
if data['Log']['change'].startswith('Validation errors:'):
|
||||
return False
|
||||
return True
|
||||
|
||||
if data.get('user_agent', None) == 'misp-exercise-dashboard':
|
||||
if data.get('user_agent', None) == 'SkillAegis':
|
||||
return None
|
||||
url = data.get('url', None)
|
||||
if url is not None:
|
||||
|
@ -250,8 +297,9 @@ def get_completion_for_users():
|
|||
for user_id in completion_per_user.keys():
|
||||
completion_per_user[int(user_id)][exercise_status['uuid']][task['uuid']] = False
|
||||
for entry in task['completed_by_user']:
|
||||
user_id = entry['user_id']
|
||||
completion_per_user[int(user_id)][exercise_status['uuid']][task['uuid']] = entry
|
||||
user_id = int(entry['user_id'])
|
||||
if user_id in completion_per_user: # Ensure the user_id is known in USER_ID_TO_EMAIL_MAPPING
|
||||
completion_per_user[user_id][exercise_status['uuid']][task['uuid']] = entry
|
||||
|
||||
return completion_per_user
|
||||
|
||||
|
@ -297,9 +345,13 @@ def mark_task_incomplete(user_id: int, exercise_uuid: str , task_uuid: str):
|
|||
def get_progress():
|
||||
completion_for_users = get_completion_for_users()
|
||||
progress = {}
|
||||
for user_id in completion_for_users:
|
||||
for user_id in completion_for_users.keys():
|
||||
if user_id not in db.USER_ID_TO_EMAIL_MAPPING:
|
||||
print('unknown user id', user_id)
|
||||
continue
|
||||
progress[user_id] = {
|
||||
'email': db.USER_ID_TO_EMAIL_MAPPING[user_id],
|
||||
'user_id': user_id,
|
||||
'exercises': {},
|
||||
}
|
||||
for exec_uuid, tasks_completion in completion_for_users[user_id].items():
|
||||
|
@ -315,10 +367,10 @@ async def check_inject(user_id: int, inject: dict, data: dict, context: dict) ->
|
|||
for inject_evaluation in inject['inject_evaluation']:
|
||||
success = await inject_checker_router(user_id, inject_evaluation, data, context)
|
||||
if not success:
|
||||
logger.info(f"Task not completed: {inject['uuid']}")
|
||||
logger.info(f"Task not completed[{user_id}]: {inject['uuid']}")
|
||||
return False
|
||||
mark_task_completed(user_id, inject['exercise_uuid'], inject['uuid'])
|
||||
logger.info(f"Task success: {inject['uuid']}")
|
||||
logger.info(f"Task success[{user_id}]: {inject['uuid']}")
|
||||
return True
|
||||
|
||||
|
||||
|
@ -335,13 +387,14 @@ def is_valid_evaluation_context(user_id: int, inject_evaluation: dict, data: dic
|
|||
else:
|
||||
logger.debug('Unknown request type')
|
||||
return False
|
||||
return False
|
||||
return True
|
||||
|
||||
async def inject_checker_router(user_id: int, inject_evaluation: dict, data: dict, context: dict) -> bool:
|
||||
if not is_valid_evaluation_context(user_id, inject_evaluation, data, context):
|
||||
return False
|
||||
|
||||
if 'evaluation_strategy' not in inject_evaluation:
|
||||
logger.warning('Evaluation strategy not specified in inject')
|
||||
return False
|
||||
|
||||
data_to_validate = await get_data_to_validate(user_id, inject_evaluation, data)
|
||||
|
@ -390,6 +443,13 @@ def parse_event_id_from_log(data: dict) -> Union[int, None]:
|
|||
if event_id_search is not None:
|
||||
event_id = event_id_search.group(1)
|
||||
return event_id
|
||||
elif 'AuditLog' in data:
|
||||
log = data['AuditLog']
|
||||
if 'model' in log and 'model_id' in log and log['model'] == 'Event':
|
||||
return int(log['model_id'])
|
||||
if 'change' in log:
|
||||
if 'event_id' in log and log['event_id'] is not None:
|
||||
return int(log['event_id'])
|
||||
return None
|
||||
|
||||
|
||||
|
|
|
@ -54,8 +54,7 @@
|
|||
"followed_by": [
|
||||
"3e61a340-0314-4622-91cc-042f3ff8543a"
|
||||
],
|
||||
"trigger": [
|
||||
]
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
|
@ -66,7 +65,7 @@
|
|||
"inject_uuid": "3e61a340-0314-4622-91cc-042f3ff8543a",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "8f636640-e4f0-4ffb-abff-4e85597aa1bd"
|
||||
"inject_uuid": "8e8dbda2-0f5e-4101-83ff-63c1ddda2cae"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
|
@ -76,8 +75,7 @@
|
|||
"followed_by": [
|
||||
"8a2d58c8-2b3a-4ba2-bb77-15bcfa704828"
|
||||
],
|
||||
"trigger": [
|
||||
]
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
|
@ -88,7 +86,7 @@
|
|||
"inject_uuid": "8a2d58c8-2b3a-4ba2-bb77-15bcfa704828",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "3e61a340-0314-4622-91cc-042f3ff8543a"
|
||||
"inject_uuid": "8e8dbda2-0f5e-4101-83ff-63c1ddda2cae"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
|
@ -98,8 +96,7 @@
|
|||
"followed_by": [
|
||||
"9df13cc8-b61b-4c9f-a1a8-66def8b64439"
|
||||
],
|
||||
"trigger": [
|
||||
]
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
|
@ -110,7 +107,7 @@
|
|||
"inject_uuid": "9df13cc8-b61b-4c9f-a1a8-66def8b64439",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "8a2d58c8-2b3a-4ba2-bb77-15bcfa704828"
|
||||
"inject_uuid": "8e8dbda2-0f5e-4101-83ff-63c1ddda2cae"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
|
@ -120,8 +117,7 @@
|
|||
"followed_by": [
|
||||
"c5c03af1-7ef3-44e7-819a-6c4fd402148a"
|
||||
],
|
||||
"trigger": [
|
||||
]
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
|
@ -132,7 +128,7 @@
|
|||
"inject_uuid": "c5c03af1-7ef3-44e7-819a-6c4fd402148a",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "9df13cc8-b61b-4c9f-a1a8-66def8b64439"
|
||||
"inject_uuid": "8e8dbda2-0f5e-4101-83ff-63c1ddda2cae"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
|
@ -142,8 +138,7 @@
|
|||
"followed_by": [
|
||||
"11f6f0c2-8813-42ee-a312-136649d3f077"
|
||||
],
|
||||
"trigger": [
|
||||
]
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
|
@ -154,7 +149,7 @@
|
|||
"inject_uuid": "11f6f0c2-8813-42ee-a312-136649d3f077",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "c5c03af1-7ef3-44e7-819a-6c4fd402148a"
|
||||
"inject_uuid": "8e8dbda2-0f5e-4101-83ff-63c1ddda2cae"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
|
@ -164,8 +159,7 @@
|
|||
"followed_by": [
|
||||
"e3ef4e5f-454a-48c8-a5d7-b3d1d25ecc9f"
|
||||
],
|
||||
"trigger": [
|
||||
]
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
|
@ -176,23 +170,21 @@
|
|||
"inject_uuid": "e3ef4e5f-454a-48c8-a5d7-b3d1d25ecc9f",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "11f6f0c2-8813-42ee-a312-136649d3f077"
|
||||
"inject_uuid": "8e8dbda2-0f5e-4101-83ff-63c1ddda2cae"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"trigger": [
|
||||
]
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
}
|
||||
],
|
||||
"inject_payloads": [
|
||||
],
|
||||
"inject_payloads": [],
|
||||
"injects": [
|
||||
{
|
||||
"action": "event-creation",
|
||||
|
@ -210,8 +202,7 @@
|
|||
],
|
||||
"result": "MISP Event created",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
@ -248,8 +239,7 @@
|
|||
],
|
||||
"result": "Infection Email added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
@ -285,8 +275,7 @@
|
|||
],
|
||||
"result": "Malicious payload added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
@ -322,8 +311,7 @@
|
|||
],
|
||||
"result": "C2 IP added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
@ -359,8 +347,7 @@
|
|||
],
|
||||
"result": "Registry key added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
@ -396,8 +383,7 @@
|
|||
],
|
||||
"result": "Public key added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
@ -433,8 +419,7 @@
|
|||
],
|
||||
"result": "Context added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
@ -469,8 +454,7 @@
|
|||
],
|
||||
"result": "Event published",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {
|
||||
},
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
|
|
519
exercises/spearphishing-incident.json
Normal file
519
exercises/spearphishing-incident.json
Normal file
|
@ -0,0 +1,519 @@
|
|||
{
|
||||
"exercise": {
|
||||
"description": "MISP Encoding Exercise : Spearphishing Incident",
|
||||
"expanded": "MISP Encoding Exercise : Spearphishing Incident",
|
||||
"meta": {
|
||||
"author": "MISP Project",
|
||||
"level": "beginner",
|
||||
"priority": 5
|
||||
},
|
||||
"name": "MISP Encoding Exercise : Spearphishing Incident",
|
||||
"namespace": "data-model",
|
||||
"tags": [
|
||||
"exercise:software-scope=\"misp\"",
|
||||
"state:production"
|
||||
],
|
||||
"total_duration": "7200",
|
||||
"uuid": "53b20321-ac8c-4a3e-9c56-e772caf669e6",
|
||||
"version": "20240715"
|
||||
},
|
||||
"inject_flow": [
|
||||
{
|
||||
"description": "event-creation",
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd",
|
||||
"reporting_callback": [],
|
||||
"requirements": {},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": [
|
||||
"startex"
|
||||
]
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "IP-address",
|
||||
"inject_uuid": "92fc404b-2dce-4815-8a7e-b68a582c3569",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "malicious-payloads",
|
||||
"inject_uuid": "cfc47f7c-590c-4897-bfb9-cc72965fee24",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "Download URL",
|
||||
"inject_uuid": "e849a314-3394-4501-a9e1-126e0e61f11d",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "CVE",
|
||||
"inject_uuid": "32141393-adce-4007-950c-77b4c7c60a39",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "C2",
|
||||
"inject_uuid": "a0d7f076-1737-4c1c-af36-c2717885299e",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "Person",
|
||||
"inject_uuid": "92a55537-0e4c-44f8-8bcd-102c38d343a9",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "Contextualization",
|
||||
"inject_uuid": "b19e8d39-e64e-4a51-94ee-462cd74b8d24",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
},
|
||||
{
|
||||
"description": "Published",
|
||||
"inject_uuid": "930459b8-ed61-4e62-b072-071577ea0430",
|
||||
"reporting_callback": [],
|
||||
"requirements": {
|
||||
"inject_uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
"sequence": {
|
||||
"completion_trigger": [
|
||||
"time_expiration",
|
||||
"completion"
|
||||
],
|
||||
"followed_by": [],
|
||||
"trigger": []
|
||||
},
|
||||
"timing": {
|
||||
"triggered_at": null
|
||||
}
|
||||
}
|
||||
],
|
||||
"inject_payloads": [],
|
||||
"injects": [
|
||||
{
|
||||
"action": "event-creation",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "MISP Event created",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
10
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "Event Creation",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "a95726bb-2761-442d-8b5c-842e384df2bd"
|
||||
},
|
||||
{
|
||||
"action": "ip-address",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
"[.Event.Object[].Attribute[], .Event.Attribute[]] | .[] | select(.value == \"john.doe@luxembourg.edu\")": {
|
||||
"extract_type": "all",
|
||||
"comparison": "count",
|
||||
"values": [
|
||||
">0"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "Email address spoofed",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "Email address",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "92fc404b-2dce-4815-8a7e-b68a582c3569"
|
||||
},
|
||||
{
|
||||
"action": "malware-sample",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
".Event.Object[].Attribute[].value": {
|
||||
"extract_type": "all",
|
||||
"comparison": "contains",
|
||||
"values": [
|
||||
"7c08ddb3b57cf9a00f02a484e23a4b6c8a6d738d"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "Malware samples added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "Malware sample",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "cfc47f7c-590c-4897-bfb9-cc72965fee24"
|
||||
},
|
||||
{
|
||||
"action": "download url",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
".Event.Object[].Attribute[] | select((.type == \"url\")).value": {
|
||||
"extract_type": "all",
|
||||
"comparison": "contains",
|
||||
"values": [
|
||||
"https://evilprovider.com/this-is-not-malicious.exe"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
".Event.Object[].Attribute[] | select((.type == \"domain\") or (.type == \"hostname\")).value": {
|
||||
"extract_type": "all",
|
||||
"comparison": "equals",
|
||||
"values": [
|
||||
"evilprovider.com"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "Download URL added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "Download URL",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "e849a314-3394-4501-a9e1-126e0e61f11d"
|
||||
},
|
||||
{
|
||||
"action": "CVE",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
"[.Event.Object[].Attribute[], .Event.Attribute[]] | .[].value": {
|
||||
"extract_type": "all",
|
||||
"comparison": "contains",
|
||||
"values": [
|
||||
"CVE-2015-5465"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "CVE",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "CVE",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "32141393-adce-4007-950c-77b4c7c60a39"
|
||||
},
|
||||
{
|
||||
"action": "C2",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
".Event.Object[] | select((.name == \"url\")).Attribute[] | select(.type == \"url\").value": {
|
||||
"extract_type": "all",
|
||||
"comparison": "contains-regex",
|
||||
"values": [
|
||||
"https:\\/\\/another\\.evil\\.provider\\.com(:57666)?"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "C2 added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "C2",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "a0d7f076-1737-4c1c-af36-c2717885299e"
|
||||
},
|
||||
{
|
||||
"action": "Email Provider",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
"[(.Event.Object[] | select((.name == \"email\")).Attribute[]), .Event.Attribute[]] | .[].value": {
|
||||
"extract_type": "all",
|
||||
"comparison": "contains",
|
||||
"values": [
|
||||
"throwaway-email-provider.com"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "Email Provider added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "Email Provider",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "92a55537-0e4c-44f8-8bcd-102c38d343a9"
|
||||
},
|
||||
{
|
||||
"action": "context",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
".Event.Tag | select(length > 0) | .[].name": {
|
||||
"extract_type": "all",
|
||||
"comparison": "count",
|
||||
"values": [
|
||||
">=3"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "Context added",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "Contextualization",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "b19e8d39-e64e-4a51-94ee-462cd74b8d24"
|
||||
},
|
||||
{
|
||||
"action": "published",
|
||||
"inject_evaluation": [
|
||||
{
|
||||
"parameters": [
|
||||
{
|
||||
".Event.info": {
|
||||
"comparison": "regex",
|
||||
"values": [
|
||||
".*[sS]pear[-\\s]?phishing.*"
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
".Event.published": {
|
||||
"comparison": "equals",
|
||||
"values": [
|
||||
"1"
|
||||
]
|
||||
}
|
||||
}
|
||||
],
|
||||
"result": "Event published",
|
||||
"evaluation_strategy": "data_filtering",
|
||||
"evaluation_context": {},
|
||||
"score_range": [
|
||||
0,
|
||||
20
|
||||
]
|
||||
}
|
||||
],
|
||||
"name": "Published",
|
||||
"target_tool": "MISP",
|
||||
"uuid": "930459b8-ed61-4e62-b072-071577ea0430"
|
||||
}
|
||||
]
|
||||
}
|
|
@ -2,7 +2,7 @@
|
|||
<html lang="en">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<link rel="icon" href="/favicon.ico">
|
||||
<link rel="icon" href="/skillaegis-logo.png">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>Vite App</title>
|
||||
</head>
|
||||
|
|
|
@ -3,7 +3,7 @@ from typing import Union
|
|||
import jq
|
||||
import re
|
||||
import operator
|
||||
from config import logger
|
||||
from appConfig import logger
|
||||
|
||||
|
||||
def jq_extract(path: str, data: dict, extract_type='first'):
|
||||
|
@ -95,7 +95,7 @@ def eval_condition_list(evaluation_config: dict, data_to_validate: str, context:
|
|||
if comparison_type == 'contains-regex':
|
||||
regex = re.compile(values[0])
|
||||
for candidate in data_to_validate:
|
||||
if regex.match(candidate):
|
||||
if regex.match(candidate) is not None:
|
||||
return True
|
||||
return False
|
||||
elif comparison_type == 'count':
|
||||
|
|
38
misp_api.py
38
misp_api.py
|
@ -11,7 +11,8 @@ from requests_cache import CachedSession
|
|||
from requests.packages.urllib3.exceptions import InsecureRequestWarning # type: ignore
|
||||
requests.packages.urllib3.disable_warnings(InsecureRequestWarning)
|
||||
|
||||
from config import misp_url, misp_apikey, misp_skipssl, logger
|
||||
from config import misp_url, misp_apikey, misp_skipssl
|
||||
from appConfig import logger, misp_settings
|
||||
|
||||
requestSession = CachedSession(cache_name='misp_cache', expire_after=timedelta(seconds=5))
|
||||
adapterCache = requests.adapters.HTTPAdapter(pool_connections=50, pool_maxsize=50)
|
||||
|
@ -21,7 +22,7 @@ requestSession.mount('http://', adapterCache)
|
|||
|
||||
async def get(url, data={}, api_key=misp_apikey):
|
||||
headers = {
|
||||
'User-Agent': 'misp-exercise-dashboard',
|
||||
'User-Agent': 'SkillAegis',
|
||||
"Authorization": api_key,
|
||||
"Accept": "application/json",
|
||||
"Content-Type": "application/json"
|
||||
|
@ -45,7 +46,7 @@ async def get(url, data={}, api_key=misp_apikey):
|
|||
|
||||
async def post(url, data={}, api_key=misp_apikey):
|
||||
headers = {
|
||||
'User-Agent': 'misp-exercise-dashboard',
|
||||
'User-Agent': 'SkillAegis',
|
||||
"Authorization": api_key,
|
||||
"Accept": "application/json",
|
||||
"Content-Type": "application/json"
|
||||
|
@ -83,20 +84,25 @@ async def getVersion() -> Union[None, dict]:
|
|||
|
||||
|
||||
async def getSettings() -> Union[None, dict]:
|
||||
SETTING_TO_QUERY = [
|
||||
'Plugin.ZeroMQ_enable',
|
||||
'Plugin.ZeroMQ_audit_notifications_enable',
|
||||
'Plugin.ZeroMQ_event_notifications_enable',
|
||||
'Plugin.ZeroMQ_attribute_notifications_enable',
|
||||
'MISP.log_paranoid',
|
||||
'MISP.log_paranoid_skip_db',
|
||||
'MISP.log_paranoid_include_post_body',
|
||||
'MISP.log_auth',
|
||||
'Security.allow_unsafe_cleartext_apikey_logging',
|
||||
]
|
||||
settings = await get(f'/servers/serverSettings.json')
|
||||
if not settings:
|
||||
return None
|
||||
return {
|
||||
setting['setting']: setting['value'] for setting in settings.get('finalSettings', []) if setting['setting'] in SETTING_TO_QUERY
|
||||
data = {}
|
||||
for settingName, expectedSettingValue in misp_settings.items():
|
||||
data[settingName] = {
|
||||
'expected_value': expectedSettingValue,
|
||||
'value': None
|
||||
}
|
||||
for setting in settings.get('finalSettings', []):
|
||||
if setting['setting'] in misp_settings:
|
||||
data[setting['setting']]['value'] = setting['value']
|
||||
return data
|
||||
|
||||
|
||||
async def remediateSetting(setting) ->dict:
|
||||
if setting in misp_settings:
|
||||
payload = {
|
||||
'value': misp_settings[setting],
|
||||
'force': 1,
|
||||
}
|
||||
return await post(f'/servers/serverSettingsEdit/{setting}', payload)
|
|
@ -5,6 +5,7 @@ import re
|
|||
from typing import Union
|
||||
import db
|
||||
import config
|
||||
import appConfig
|
||||
from urllib.parse import parse_qs
|
||||
|
||||
|
||||
|
@ -27,6 +28,30 @@ def get_notifications() -> list[dict]:
|
|||
return list(db.NOTIFICATION_MESSAGES)
|
||||
|
||||
|
||||
def get_notifications_history() -> dict:
|
||||
return {
|
||||
'history': list(db.NOTIFICATION_HISTORY),
|
||||
'config': {
|
||||
'buffer_resolution_per_minute': db.NOTIFICATION_HISTORY_BUFFER_RESOLUTION_PER_MIN,
|
||||
'buffer_timestamp_min': db.NOTIFICATION_HISTORY_BUFFER_TIMESPAN_MIN,
|
||||
'frequency': db.NOTIFICATION_HISTORY_FREQUENCY,
|
||||
'notification_history_size': db.notification_history_buffer_size,
|
||||
},
|
||||
}
|
||||
|
||||
|
||||
def get_users_activity() -> dict:
|
||||
return {
|
||||
'activity': {user_id: list(activity) for user_id, activity in db.USER_ACTIVITY.items()},
|
||||
'config': {
|
||||
'timestamp_min': db.USER_ACTIVITY_TIMESPAN_MIN,
|
||||
'buffer_resolution_per_minute': db.USER_ACTIVITY_BUFFER_RESOLUTION_PER_MIN,
|
||||
'frequency': db.USER_ACTIVITY_FREQUENCY,
|
||||
'activity_buffer_size': db.user_activity_buffer_size,
|
||||
},
|
||||
}
|
||||
|
||||
|
||||
def reset_notifications():
|
||||
db.resetNotificationMessage()
|
||||
|
||||
|
@ -35,6 +60,14 @@ def record_notification(notification: dict):
|
|||
db.NOTIFICATION_MESSAGES.appendleft(notification)
|
||||
|
||||
|
||||
def record_notification_history(message_count: int):
|
||||
db.NOTIFICATION_HISTORY.append(message_count)
|
||||
|
||||
|
||||
def record_user_activity(user_id: int, count: int):
|
||||
db.addUserActivity(user_id, count)
|
||||
|
||||
|
||||
def get_user_id(data: dict):
|
||||
if 'user_id' in data:
|
||||
return int(data['user_id'])
|
||||
|
@ -42,6 +75,10 @@ def get_user_id(data: dict):
|
|||
data = data['Log']
|
||||
if 'user_id' in data:
|
||||
return int(data['user_id'])
|
||||
if 'AuditLog' in data:
|
||||
data = data['AuditLog']
|
||||
if 'user_id' in data:
|
||||
return int(data['user_id'])
|
||||
return None
|
||||
|
||||
|
||||
|
@ -150,7 +187,7 @@ def get_scope_action_from_url(url) -> Union[str, None]:
|
|||
def is_accepted_notification(notification) -> bool:
|
||||
global VERBOSE_MODE
|
||||
|
||||
if notification['user_agent'] == 'misp-exercise-dashboard': # Ignore message generated from this app
|
||||
if notification['user_agent'] == 'SkillAegis': # Ignore message generated from this app
|
||||
return False
|
||||
if VERBOSE_MODE:
|
||||
return True
|
||||
|
@ -160,9 +197,26 @@ def is_accepted_notification(notification) -> bool:
|
|||
return False
|
||||
|
||||
scope, action = get_scope_action_from_url(notification['url'])
|
||||
if scope in config.live_logs_accepted_scope:
|
||||
if config.live_logs_accepted_scope == '*':
|
||||
if scope in appConfig.live_logs_accepted_scope:
|
||||
if appConfig.live_logs_accepted_scope == '*':
|
||||
return True
|
||||
elif action in config.live_logs_accepted_scope[scope]:
|
||||
elif action in appConfig.live_logs_accepted_scope[scope]:
|
||||
return True
|
||||
return False
|
||||
|
||||
|
||||
def is_accepted_user_activity(notification) -> bool:
|
||||
global VERBOSE_MODE
|
||||
|
||||
if notification['user_agent'] == 'SkillAegis': # Ignore message generated from this app
|
||||
return False
|
||||
if '@' not in notification['user']: # Ignore message from system
|
||||
return False
|
||||
|
||||
scope, action = get_scope_action_from_url(notification['url'])
|
||||
if scope in appConfig.user_activity_accepted_scope:
|
||||
if appConfig.user_activity_accepted_scope == '*':
|
||||
return True
|
||||
elif action in appConfig.user_activity_accepted_scope[scope]:
|
||||
return True
|
||||
return False
|
130
package-lock.json
generated
130
package-lock.json
generated
|
@ -1,11 +1,11 @@
|
|||
{
|
||||
"name": "misp-exercise-dashboard",
|
||||
"name": "SkillAegis",
|
||||
"version": "0.0.0",
|
||||
"lockfileVersion": 3,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
"": {
|
||||
"name": "misp-exercise-dashboard",
|
||||
"name": "SkillAegis",
|
||||
"version": "0.0.0",
|
||||
"dependencies": {
|
||||
"@fortawesome/fontawesome-svg-core": "^6.5.2",
|
||||
|
@ -13,8 +13,10 @@
|
|||
"@fortawesome/free-regular-svg-icons": "^6.5.2",
|
||||
"@fortawesome/free-solid-svg-icons": "^6.5.2",
|
||||
"@fortawesome/vue-fontawesome": "^3.0.8",
|
||||
"apexcharts": "^3.49.2",
|
||||
"lodash.debounce": "^4.0.8",
|
||||
"vue": "^3.4.29"
|
||||
"vue": "^3.4.29",
|
||||
"vue3-apexcharts": "^1.5.3"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@rushstack/eslint-patch": "^1.8.0",
|
||||
|
@ -1077,6 +1079,12 @@
|
|||
"resolved": "https://registry.npmjs.org/@vue/shared/-/shared-3.4.29.tgz",
|
||||
"integrity": "sha512-hQ2gAQcBO/CDpC82DCrinJNgOHI2v+FA7BDW4lMSPeBpQ7sRe2OLHWe5cph1s7D8DUQAwRt18dBDfJJ220APEA=="
|
||||
},
|
||||
"node_modules/@yr/monotone-cubic-spline": {
|
||||
"version": "1.0.3",
|
||||
"resolved": "https://registry.npmjs.org/@yr/monotone-cubic-spline/-/monotone-cubic-spline-1.0.3.tgz",
|
||||
"integrity": "sha512-FQXkOta0XBSUPHndIKON2Y9JeQz5ZeMqLYZVVK93FliNBFm7LNMIZmY6FrMEB9XPcDbE2bekMbZD6kzDkxwYjA==",
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/acorn": {
|
||||
"version": "8.12.0",
|
||||
"resolved": "https://registry.npmjs.org/acorn/-/acorn-8.12.0.tgz",
|
||||
|
@ -1157,6 +1165,21 @@
|
|||
"node": ">= 8"
|
||||
}
|
||||
},
|
||||
"node_modules/apexcharts": {
|
||||
"version": "3.49.2",
|
||||
"resolved": "https://registry.npmjs.org/apexcharts/-/apexcharts-3.49.2.tgz",
|
||||
"integrity": "sha512-vBB8KgwfD9rSObA7s4kY2rU6DeaN67gTR3JN7r32ztgKVf8lKkdFQ6iUhk6oIHrV7W8PoHhr5EwKymn0z5Fz6A==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"@yr/monotone-cubic-spline": "^1.0.3",
|
||||
"svg.draggable.js": "^2.2.2",
|
||||
"svg.easing.js": "^2.0.0",
|
||||
"svg.filter.js": "^2.0.2",
|
||||
"svg.pathmorphing.js": "^0.1.3",
|
||||
"svg.resize.js": "^1.4.3",
|
||||
"svg.select.js": "^3.0.1"
|
||||
}
|
||||
},
|
||||
"node_modules/arg": {
|
||||
"version": "5.0.2",
|
||||
"resolved": "https://registry.npmjs.org/arg/-/arg-5.0.2.tgz",
|
||||
|
@ -3292,6 +3315,97 @@
|
|||
"url": "https://github.com/sponsors/ljharb"
|
||||
}
|
||||
},
|
||||
"node_modules/svg.draggable.js": {
|
||||
"version": "2.2.2",
|
||||
"resolved": "https://registry.npmjs.org/svg.draggable.js/-/svg.draggable.js-2.2.2.tgz",
|
||||
"integrity": "sha512-JzNHBc2fLQMzYCZ90KZHN2ohXL0BQJGQimK1kGk6AvSeibuKcIdDX9Kr0dT9+UJ5O8nYA0RB839Lhvk4CY4MZw==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"svg.js": "^2.0.1"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 0.8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/svg.easing.js": {
|
||||
"version": "2.0.0",
|
||||
"resolved": "https://registry.npmjs.org/svg.easing.js/-/svg.easing.js-2.0.0.tgz",
|
||||
"integrity": "sha512-//ctPdJMGy22YoYGV+3HEfHbm6/69LJUTAqI2/5qBvaNHZ9uUFVC82B0Pl299HzgH13rKrBgi4+XyXXyVWWthA==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"svg.js": ">=2.3.x"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 0.8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/svg.filter.js": {
|
||||
"version": "2.0.2",
|
||||
"resolved": "https://registry.npmjs.org/svg.filter.js/-/svg.filter.js-2.0.2.tgz",
|
||||
"integrity": "sha512-xkGBwU+dKBzqg5PtilaTb0EYPqPfJ9Q6saVldX+5vCRy31P6TlRCP3U9NxH3HEufkKkpNgdTLBJnmhDHeTqAkw==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"svg.js": "^2.2.5"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 0.8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/svg.js": {
|
||||
"version": "2.7.1",
|
||||
"resolved": "https://registry.npmjs.org/svg.js/-/svg.js-2.7.1.tgz",
|
||||
"integrity": "sha512-ycbxpizEQktk3FYvn/8BH+6/EuWXg7ZpQREJvgacqn46gIddG24tNNe4Son6omdXCnSOaApnpZw6MPCBA1dODA==",
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/svg.pathmorphing.js": {
|
||||
"version": "0.1.3",
|
||||
"resolved": "https://registry.npmjs.org/svg.pathmorphing.js/-/svg.pathmorphing.js-0.1.3.tgz",
|
||||
"integrity": "sha512-49HWI9X4XQR/JG1qXkSDV8xViuTLIWm/B/7YuQELV5KMOPtXjiwH4XPJvr/ghEDibmLQ9Oc22dpWpG0vUDDNww==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"svg.js": "^2.4.0"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 0.8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/svg.resize.js": {
|
||||
"version": "1.4.3",
|
||||
"resolved": "https://registry.npmjs.org/svg.resize.js/-/svg.resize.js-1.4.3.tgz",
|
||||
"integrity": "sha512-9k5sXJuPKp+mVzXNvxz7U0uC9oVMQrrf7cFsETznzUDDm0x8+77dtZkWdMfRlmbkEEYvUn9btKuZ3n41oNA+uw==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"svg.js": "^2.6.5",
|
||||
"svg.select.js": "^2.1.2"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 0.8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/svg.resize.js/node_modules/svg.select.js": {
|
||||
"version": "2.1.2",
|
||||
"resolved": "https://registry.npmjs.org/svg.select.js/-/svg.select.js-2.1.2.tgz",
|
||||
"integrity": "sha512-tH6ABEyJsAOVAhwcCjF8mw4crjXSI1aa7j2VQR8ZuJ37H2MBUbyeqYr5nEO7sSN3cy9AR9DUwNg0t/962HlDbQ==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"svg.js": "^2.2.5"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 0.8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/svg.select.js": {
|
||||
"version": "3.0.1",
|
||||
"resolved": "https://registry.npmjs.org/svg.select.js/-/svg.select.js-3.0.1.tgz",
|
||||
"integrity": "sha512-h5IS/hKkuVCbKSieR9uQCj9w+zLHoPh+ce19bBYyqF53g6mnPB8sAtIbe1s9dh2S2fCmYX2xel1Ln3PJBbK4kw==",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"svg.js": "^2.6.5"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 0.8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/synckit": {
|
||||
"version": "0.8.8",
|
||||
"resolved": "https://registry.npmjs.org/synckit/-/synckit-0.8.8.tgz",
|
||||
|
@ -3564,6 +3678,16 @@
|
|||
"eslint": ">=6.0.0"
|
||||
}
|
||||
},
|
||||
"node_modules/vue3-apexcharts": {
|
||||
"version": "1.5.3",
|
||||
"resolved": "https://registry.npmjs.org/vue3-apexcharts/-/vue3-apexcharts-1.5.3.tgz",
|
||||
"integrity": "sha512-yaHTPoj0iVKAtEVg8wEwIwwvf0VG+lPYNufCf3txRzYQOqdKPoZaZ9P3Dj3X+2A1XY9O1kcTk9HVqvLo+rppvQ==",
|
||||
"license": "MIT",
|
||||
"peerDependencies": {
|
||||
"apexcharts": "> 3.0.0",
|
||||
"vue": "> 3.0.0"
|
||||
}
|
||||
},
|
||||
"node_modules/which": {
|
||||
"version": "2.0.2",
|
||||
"resolved": "https://registry.npmjs.org/which/-/which-2.0.2.tgz",
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
{
|
||||
"name": "misp-exercise-dashboard",
|
||||
"name": "SkillAegis",
|
||||
"version": "0.0.0",
|
||||
"private": true,
|
||||
"type": "module",
|
||||
|
@ -16,8 +16,10 @@
|
|||
"@fortawesome/free-regular-svg-icons": "^6.5.2",
|
||||
"@fortawesome/free-solid-svg-icons": "^6.5.2",
|
||||
"@fortawesome/vue-fontawesome": "^3.0.8",
|
||||
"apexcharts": "^3.49.2",
|
||||
"lodash.debounce": "^4.0.8",
|
||||
"vue": "^3.4.29"
|
||||
"vue": "^3.4.29",
|
||||
"vue3-apexcharts": "^1.5.3"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@rushstack/eslint-patch": "^1.8.0",
|
||||
|
|
BIN
public/skillaegis-logo.png
Normal file
BIN
public/skillaegis-logo.png
Normal file
Binary file not shown.
After Width: | Height: | Size: 5.6 KiB |
129
server.py
129
server.py
|
@ -1,9 +1,11 @@
|
|||
#!/usr/bin/env python3
|
||||
|
||||
import collections
|
||||
import functools
|
||||
import json
|
||||
import sys
|
||||
import time
|
||||
import traceback
|
||||
import zmq
|
||||
import socketio
|
||||
from aiohttp import web
|
||||
|
@ -13,12 +15,14 @@ import exercise as exercise_model
|
|||
import notification as notification_model
|
||||
import db
|
||||
import config
|
||||
from config import logger
|
||||
from appConfig import logger
|
||||
import misp_api
|
||||
|
||||
|
||||
ZMQ_MESSAGE_COUNT_LAST_TIMESPAN = 0
|
||||
ZMQ_MESSAGE_COUNT = 0
|
||||
ZMQ_LAST_TIME = None
|
||||
USER_ACTIVITY = collections.defaultdict(int)
|
||||
|
||||
|
||||
def debounce(debounce_seconds: int = 1):
|
||||
|
@ -40,6 +44,20 @@ def debounce(debounce_seconds: int = 1):
|
|||
return decorator
|
||||
|
||||
|
||||
def timer():
|
||||
def decorator(func):
|
||||
@functools.wraps(func)
|
||||
def wrapper(*args, **kwargs):
|
||||
t1 = time.time()
|
||||
res = func(*args, **kwargs)
|
||||
elapsed = time.time() - t1
|
||||
if elapsed > 0.1:
|
||||
print(elapsed)
|
||||
return res
|
||||
return wrapper
|
||||
return decorator
|
||||
|
||||
|
||||
|
||||
# Initialize ZeroMQ context and subscriber socket
|
||||
context = zmq.asyncio.Context()
|
||||
|
@ -50,7 +68,6 @@ zsocket.setsockopt_string(zmq.SUBSCRIBE, '')
|
|||
|
||||
|
||||
# Initialize Socket.IO server
|
||||
# sio = socketio.Server(cors_allowed_origins='*', async_mode='eventlet')
|
||||
sio = socketio.AsyncServer(cors_allowed_origins='*', async_mode='aiohttp')
|
||||
app = web.Application()
|
||||
sio.attach(app)
|
||||
|
@ -101,6 +118,10 @@ async def mark_task_incomplete(sid, payload):
|
|||
async def reset_all_exercise_progress(sid):
|
||||
return exercise_model.resetAllExerciseProgress()
|
||||
|
||||
@sio.event
|
||||
async def reset_all(sid):
|
||||
return exercise_model.resetAllCommand()
|
||||
|
||||
@sio.event
|
||||
async def reset_notifications(sid):
|
||||
return notification_model.reset_notifications()
|
||||
|
@ -109,6 +130,10 @@ async def reset_notifications(sid):
|
|||
async def get_diagnostic(sid):
|
||||
return await getDiagnostic()
|
||||
|
||||
@sio.event
|
||||
async def get_users_activity(sid):
|
||||
return notification_model.get_users_activity()
|
||||
|
||||
@sio.event
|
||||
async def toggle_verbose_mode(sid, payload):
|
||||
return notification_model.set_verbose_mode(payload['verbose'])
|
||||
|
@ -117,22 +142,28 @@ async def toggle_verbose_mode(sid, payload):
|
|||
async def toggle_apiquery_mode(sid, payload):
|
||||
return notification_model.set_apiquery_mode(payload['apiquery'])
|
||||
|
||||
@sio.event
|
||||
async def remediate_setting(sid, payload):
|
||||
return await doSettingRemediation(payload['name'])
|
||||
|
||||
@sio.on('*')
|
||||
async def any_event(event, sid, data={}):
|
||||
logger.info('>> Unhandled event %s', event)
|
||||
|
||||
async def handleMessage(topic, s, message):
|
||||
global ZMQ_MESSAGE_COUNT_LAST_TIMESPAN
|
||||
|
||||
data = json.loads(message)
|
||||
|
||||
if topic == 'misp_json_audit':
|
||||
user_id, email = notification_model.get_user_email_id_pair(data)
|
||||
if user_id is not None and '@' in email:
|
||||
if user_id is not None and user_id != 0 and '@' in email:
|
||||
if user_id not in db.USER_ID_TO_EMAIL_MAPPING:
|
||||
db.USER_ID_TO_EMAIL_MAPPING[user_id] = email
|
||||
await sio.emit('new_user', email)
|
||||
|
||||
user_id, authkey = notification_model.get_user_authkey_id_pair(data)
|
||||
if user_id is not None:
|
||||
if user_id is not None and user_id != 0:
|
||||
if authkey not in db.USER_ID_TO_AUTHKEY_MAPPING:
|
||||
db.USER_ID_TO_AUTHKEY_MAPPING[user_id] = authkey
|
||||
return
|
||||
|
@ -141,15 +172,23 @@ async def handleMessage(topic, s, message):
|
|||
notification = notification_model.get_notification_message(data)
|
||||
if notification_model.is_accepted_notification(notification):
|
||||
notification_model.record_notification(notification)
|
||||
ZMQ_MESSAGE_COUNT_LAST_TIMESPAN += 1
|
||||
await sio.emit('notification', notification)
|
||||
if notification_model.is_accepted_user_activity(notification):
|
||||
user_id = notification_model.get_user_id(data)
|
||||
if user_id is not None:
|
||||
USER_ACTIVITY[user_id] += 1
|
||||
|
||||
user_id = notification_model.get_user_id(data)
|
||||
if user_id is not None:
|
||||
if exercise_model.is_accepted_query(data):
|
||||
context = get_context(topic, user_id, data)
|
||||
succeeded_once = await exercise_model.check_active_tasks(user_id, data, context)
|
||||
checking_task = exercise_model.check_active_tasks(user_id, data, context)
|
||||
if checking_task is not None: # Make sure check_active_tasks was not debounced
|
||||
succeeded_once = await checking_task
|
||||
if succeeded_once:
|
||||
await sendRefreshScore()
|
||||
sendRefreshScoreTask = sendRefreshScore()
|
||||
await sendRefreshScoreTask if sendRefreshScoreTask is not None else None # Make sure check_active_tasks was not debounced
|
||||
|
||||
|
||||
@debounce(debounce_seconds=1)
|
||||
|
@ -188,6 +227,33 @@ async def getDiagnostic() -> dict:
|
|||
return diagnostic
|
||||
|
||||
|
||||
async def doSettingRemediation(setting) -> dict:
|
||||
result = await misp_api.remediateSetting(setting)
|
||||
return result
|
||||
|
||||
|
||||
async def notification_history():
|
||||
global ZMQ_MESSAGE_COUNT_LAST_TIMESPAN
|
||||
while True:
|
||||
await sio.sleep(db.NOTIFICATION_HISTORY_FREQUENCY)
|
||||
notification_model.record_notification_history(ZMQ_MESSAGE_COUNT_LAST_TIMESPAN)
|
||||
ZMQ_MESSAGE_COUNT_LAST_TIMESPAN = 0
|
||||
payload = notification_model.get_notifications_history()
|
||||
await sio.emit('update_notification_history', payload)
|
||||
|
||||
|
||||
async def record_users_activity():
|
||||
global USER_ACTIVITY
|
||||
|
||||
while True:
|
||||
await sio.sleep(db.USER_ACTIVITY_FREQUENCY)
|
||||
for user_id, activity in USER_ACTIVITY.items():
|
||||
notification_model.record_user_activity(user_id, activity)
|
||||
USER_ACTIVITY[user_id] = 0
|
||||
payload = notification_model.get_users_activity()
|
||||
await sio.emit('update_users_activity', payload)
|
||||
|
||||
|
||||
async def keepalive():
|
||||
global ZMQ_LAST_TIME
|
||||
while True:
|
||||
|
@ -198,6 +264,12 @@ async def keepalive():
|
|||
await sio.emit('keep_alive', payload)
|
||||
|
||||
|
||||
async def backup_exercises_progress():
|
||||
while True:
|
||||
await sio.sleep(5)
|
||||
exercise_model.backup_exercises_progress()
|
||||
|
||||
|
||||
# Function to forward zmq messages to Socket.IO
|
||||
async def forward_zmq_to_socketio():
|
||||
global ZMQ_MESSAGE_COUNT, ZMQ_LAST_TIME
|
||||
|
@ -210,12 +282,57 @@ async def forward_zmq_to_socketio():
|
|||
ZMQ_LAST_TIME = time.time()
|
||||
await handleMessage(topic, s, m)
|
||||
except Exception as e:
|
||||
print(e)
|
||||
logger.error('Error handling message %s', e)
|
||||
|
||||
|
||||
# Function to forward zmq messages to Socket.IO
|
||||
async def forward_fake_zmq_to_socketio():
|
||||
global ZMQ_MESSAGE_COUNT, ZMQ_LAST_TIME
|
||||
filename = sys.argv[1]
|
||||
line_number = sum(1 for _ in open(filename))
|
||||
print(f'Preparing to feed {line_number} lines..')
|
||||
await sio.sleep(2)
|
||||
|
||||
print('Feeding started')
|
||||
line_count = 0
|
||||
last_print = time.time()
|
||||
with open(filename) as f:
|
||||
for line in f:
|
||||
line_count += 1
|
||||
now = time.time()
|
||||
if line_count % (int(line_number/100)) == 0 or (now - last_print >= 5):
|
||||
last_print = now
|
||||
print(f'Feeding {line_count} / {line_number} - ({100* line_count / line_number:.1f}%)')
|
||||
split = line.split(' ', 1)
|
||||
topic = split[0]
|
||||
s = ''
|
||||
m = split[1]
|
||||
if topic != 'misp_json_self':
|
||||
await sio.sleep(0.01)
|
||||
try:
|
||||
ZMQ_MESSAGE_COUNT += 1
|
||||
ZMQ_LAST_TIME = time.time()
|
||||
await handleMessage(topic, s, m)
|
||||
except Exception as e:
|
||||
print(e)
|
||||
print(line)
|
||||
print(traceback.format_exc())
|
||||
logger.error('Error handling message: %s', e)
|
||||
await sio.sleep(5)
|
||||
print('Feeding done.')
|
||||
|
||||
|
||||
async def init_app():
|
||||
if len(sys.argv) == 2:
|
||||
sio.start_background_task(forward_fake_zmq_to_socketio)
|
||||
else:
|
||||
exercise_model.restore_exercices_progress()
|
||||
sio.start_background_task(forward_zmq_to_socketio)
|
||||
sio.start_background_task(keepalive)
|
||||
sio.start_background_task(notification_history)
|
||||
sio.start_background_task(record_users_activity)
|
||||
sio.start_background_task(backup_exercises_progress)
|
||||
return app
|
||||
|
||||
|
||||
|
|
26
src/App.vue
26
src/App.vue
|
@ -5,17 +5,25 @@ import TheAdminPanel from './components/TheAdminPanel.vue'
|
|||
import TheSocketConnectionState from './components/TheSocketConnectionState.vue'
|
||||
import TheDahboard from './TheDahboard.vue'
|
||||
import { socketConnected } from "@/socket";
|
||||
import { darkModeEnabled } from "@/settings.js"
|
||||
|
||||
|
||||
onMounted(() => {
|
||||
if (darkModeEnabled.value) {
|
||||
document.getElementsByTagName('body')[0].classList.add('dark')
|
||||
}
|
||||
})
|
||||
|
||||
</script>
|
||||
|
||||
<template>
|
||||
<main>
|
||||
<h1 class="text-2xl text-center text-slate-500 dark:text-slate-400 absolute top-1 left-1">Exercise Dashboard</h1>
|
||||
<h1 class="text-xl text-center text-slate-500 dark:text-slate-400 absolute inset-x-0 top-0">
|
||||
<div class="flex flex-col items-center mt-2">
|
||||
<span id="logo" class="hover:cursor-pointer"></span>
|
||||
<span>SkillAegis</span>
|
||||
</div>
|
||||
</h1>
|
||||
<div class="absolute top-1 right-1">
|
||||
<div class="flex gap-2">
|
||||
<TheThemeButton></TheThemeButton>
|
||||
|
@ -23,7 +31,9 @@ onMounted(() => {
|
|||
<TheSocketConnectionState></TheSocketConnectionState>
|
||||
</div>
|
||||
</div>
|
||||
<div class="mt-12">
|
||||
<TheDahboard></TheDahboard>
|
||||
</div>
|
||||
</main>
|
||||
</template>
|
||||
|
||||
|
@ -40,8 +50,18 @@ body {
|
|||
@apply 3xl:container mx-auto;
|
||||
@apply mx-auto;
|
||||
@apply mt-4;
|
||||
@apply 3xl:w-11/12;
|
||||
@apply lg:w-5/6;
|
||||
@apply lg:w-11/12;
|
||||
@apply 3xl:w-5/6;
|
||||
}
|
||||
|
||||
#logo {
|
||||
background-image: url(@/assets/skillaegis-logo.svg);
|
||||
width: 64px;
|
||||
height: 64px;
|
||||
display: block;
|
||||
background-size: 64px;
|
||||
/* cyan-400 */
|
||||
/* filter: invert(71%) sepia(97%) saturate(1333%) hue-rotate(147deg) brightness(95%) contrast(96%); */
|
||||
}
|
||||
|
||||
</style>
|
|
@ -3,6 +3,7 @@ import { onMounted, watch } from 'vue'
|
|||
import TheLiveLogs from './components/TheLiveLogs.vue'
|
||||
import TheScores from './components/TheScores.vue'
|
||||
import { resetState, fullReload, socketConnected } from "@/socket";
|
||||
import { fullscreenModeOn } from "@/settings.js"
|
||||
|
||||
|
||||
watch(socketConnected, (isConnected) => {
|
||||
|
@ -19,6 +20,8 @@ onMounted(() => {
|
|||
</script>
|
||||
|
||||
<template>
|
||||
<div class="mb-3">
|
||||
<TheScores></TheScores>
|
||||
<TheLiveLogs></TheLiveLogs>
|
||||
<TheLiveLogs v-show="!fullscreenModeOn"></TheLiveLogs>
|
||||
</div>
|
||||
</template>
|
||||
|
|
BIN
src/assets/skillaegis-logo-lg.png
Normal file
BIN
src/assets/skillaegis-logo-lg.png
Normal file
Binary file not shown.
After Width: | Height: | Size: 27 KiB |
58
src/assets/skillaegis-logo.svg
Normal file
58
src/assets/skillaegis-logo.svg
Normal file
File diff suppressed because one or more lines are too long
After Width: | Height: | Size: 27 KiB |
67
src/components/LiveLogsUserActivityGraph.vue
Normal file
67
src/components/LiveLogsUserActivityGraph.vue
Normal file
|
@ -0,0 +1,67 @@
|
|||
<script setup>
|
||||
import { ref, watch, computed } from "vue"
|
||||
import { userActivity, userActivityConfig } from "@/socket";
|
||||
import { darkModeEnabled } from "@/settings.js"
|
||||
|
||||
const props = defineProps(['user_id', 'compact_view', 'ultra_compact_view'])
|
||||
|
||||
const theChart = ref(null)
|
||||
const bufferSize = computed(() => userActivityConfig.value.activity_buffer_size)
|
||||
const bufferSizeMin = computed(() => userActivityConfig.value.timestamp_min)
|
||||
const chartInitSeries = computed(() => Array.from(Array(bufferSize.value)).map(() => 0))
|
||||
|
||||
const hasActivity = computed(() => userActivity.value.length != 0)
|
||||
const chartSeries = computed(() => {
|
||||
return !hasActivity.value ? chartInitSeries.value : activitySeries.value
|
||||
})
|
||||
|
||||
const activitySeries = computed(() => {
|
||||
const data = userActivity.value[props.user_id] === undefined ? chartInitSeries.value : userActivity.value[props.user_id]
|
||||
return data
|
||||
})
|
||||
|
||||
const colorRanges = [0, 1, 2, 3, 4, 5, 1000]
|
||||
const palleteColor = 'blue'
|
||||
const colorPalleteIndexDark = [
|
||||
'900',
|
||||
'700',
|
||||
'600',
|
||||
'500',
|
||||
'400',
|
||||
'300',
|
||||
'200',
|
||||
]
|
||||
const colorPalleteIndexLight = [
|
||||
'50',
|
||||
'100',
|
||||
'300',
|
||||
'400',
|
||||
'500',
|
||||
'600',
|
||||
'700',
|
||||
]
|
||||
|
||||
function getPalleteIndexFromValue(value) {
|
||||
for (let palleteIndex = 0; palleteIndex < colorRanges.length; palleteIndex++) {
|
||||
const colorRangeValue = colorRanges[palleteIndex];
|
||||
if (value <= colorRangeValue) {
|
||||
return darkModeEnabled.value ? colorPalleteIndexDark[palleteIndex] : colorPalleteIndexLight[palleteIndex]
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
</script>
|
||||
|
||||
<template>
|
||||
<span
|
||||
:class="`${props.ultra_compact_view ? 'w-[120px]' : 'w-60'} ${props.compact_view ? 'h-1.5 inline-flex' : 'h-3'}`"
|
||||
:title="`Activity over ${bufferSizeMin}min`"
|
||||
>
|
||||
<span
|
||||
v-for="(value, i) in chartSeries"
|
||||
:key="i"
|
||||
:class="[`inline-block rounded-[1px] mr-px`, props.compact_view ? 'h-1.5' : 'h-3', `bg-${palleteColor}-${getPalleteIndexFromValue(value)}`]"
|
||||
:style="`width: ${(((props.ultra_compact_view ? 120 : 240) - chartSeries.length) / chartSeries.length).toFixed(1)}px`"
|
||||
></span>
|
||||
</span>
|
||||
</template>
|
|
@ -1,10 +1,11 @@
|
|||
<script setup>
|
||||
import { ref, computed, onMounted } from 'vue'
|
||||
import { exercises, selected_exercises, diagnostic, fullReload, resetAllExerciseProgress, resetLiveLogs, changeExerciseSelection, debouncedGetDiangostic } from "@/socket";
|
||||
import { exercises, selected_exercises, diagnostic, fullReload, resetAllExerciseProgress, resetAll, resetLiveLogs, changeExerciseSelection, debouncedGetDiangostic, remediateSetting } from "@/socket";
|
||||
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome'
|
||||
import { faScrewdriverWrench, faTrash, faSuitcaseMedical, faGraduationCap, faBan, faRotate } from '@fortawesome/free-solid-svg-icons'
|
||||
import { faScrewdriverWrench, faTrash, faSuitcaseMedical, faGraduationCap, faBan, faRotate, faHammer, faCheck } from '@fortawesome/free-solid-svg-icons'
|
||||
|
||||
const admin_modal = ref(null)
|
||||
const clickedButtons = ref([])
|
||||
|
||||
const diagnosticLoading = computed(() => Object.keys(diagnostic.value).length == 0)
|
||||
const isMISPOnline = computed(() => diagnostic.value.version?.version !== undefined)
|
||||
|
@ -15,10 +16,16 @@
|
|||
changeExerciseSelection(exec_uuid, state_enabled);
|
||||
}
|
||||
|
||||
function settingHandler(setting) {
|
||||
remediateSetting(setting)
|
||||
}
|
||||
|
||||
function showTheModal() {
|
||||
admin_modal.value.showModal()
|
||||
clickedButtons.value = []
|
||||
debouncedGetDiangostic()
|
||||
}
|
||||
|
||||
</script>
|
||||
|
||||
<template>
|
||||
|
@ -58,6 +65,13 @@
|
|||
<FontAwesomeIcon :icon="faTrash" size="lg" fixed-width></FontAwesomeIcon>
|
||||
Reset All Exercises
|
||||
</button>
|
||||
<button
|
||||
@click="resetAll()"
|
||||
class="h-10 min-h-10 px-2 py-1 font-semibold bg-red-600 text-slate-200 hover:bg-red-700 btn btn-sm gap-1"
|
||||
>
|
||||
<FontAwesomeIcon :icon="faTrash" size="lg" fixed-width></FontAwesomeIcon>
|
||||
Reset All
|
||||
</button>
|
||||
<button
|
||||
@click="resetLiveLogs()"
|
||||
class="h-10 min-h-10 px-2 py-1 font-semibold bg-amber-600 text-slate-200 hover:bg-amber-700 btn btn-sm gap-1"
|
||||
|
@ -131,29 +145,60 @@
|
|||
<div v-if="diagnosticLoading" class="flex justify-center">
|
||||
<span class="loading loading-dots loading-lg"></span>
|
||||
</div>
|
||||
<div
|
||||
v-for="(value, setting) in diagnostic['settings']"
|
||||
<table v-else class="bg-white dark:bg-slate-700 rounded-lg shadow-xl w-full mt-2">
|
||||
<thead>
|
||||
<tr>
|
||||
<th class="border-b border-slate-200 dark:border-slate-600 p-2 text-left">Setting</th>
|
||||
<th class="border-b border-slate-200 dark:border-slate-600 p-2 text-left">Value</th>
|
||||
<th class="border-b border-slate-200 dark:border-slate-600 p-2 text-left">Expected Value</th>
|
||||
<th class="border-b border-slate-200 dark:border-slate-600 p-2 text-center">Action</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
<tr
|
||||
v-for="(settingValues, setting) in diagnostic['settings']"
|
||||
:key="setting"
|
||||
>
|
||||
<div>
|
||||
<label class="label cursor-pointer justify-start p-0 pt-1">
|
||||
<input
|
||||
type="checkbox"
|
||||
:checked="value"
|
||||
:value="setting"
|
||||
:class="`checkbox ${value ? 'checkbox-success' : 'checkbox-danger'} [--fallback-bc:#cbd5e1]`"
|
||||
disabled
|
||||
/>
|
||||
<span class="font-mono font-semibold text-base ml-3">{{ setting }}</span>
|
||||
</label>
|
||||
</div>
|
||||
</div>
|
||||
<td class="font-mono font-semibold text-base px-2">{{ setting }}</td>
|
||||
<td
|
||||
:class="`font-mono text-base tracking-tight px-2 ${settingValues.expected_value != settingValues.value ? 'text-red-600 dark:text-red-600' : ''}`"
|
||||
>
|
||||
<i v-if="settingValues.value === undefined || settingValues.value === null" class="text-nowrap">- none -</i>
|
||||
{{ settingValues.value }}
|
||||
</td>
|
||||
<td class="font-mono text-base tracking-tight px-2">{{ settingValues.expected_value }}</td>
|
||||
<td class="px-2 text-center">
|
||||
<span v-if="settingValues.error === true"
|
||||
class="text-red-600 dark:text-red-600"
|
||||
>Error: {{ settingValues.errorMessage }}</span>
|
||||
<button
|
||||
v-else-if="settingValues.expected_value != settingValues.value"
|
||||
@click="clickedButtons.push(setting) && settingHandler(setting)"
|
||||
:disabled="clickedButtons.includes(setting)"
|
||||
class="h-8 min-h-8 px-2 font-semibold bg-green-600 text-slate-200 hover:bg-green-700 btn gap-1"
|
||||
>
|
||||
<template v-if="!clickedButtons.includes(setting)">
|
||||
<FontAwesomeIcon :icon="faHammer" size="sm" fixed-width></FontAwesomeIcon>
|
||||
Remediate
|
||||
</template>
|
||||
<template v-else>
|
||||
<span class="loading loading-dots loading-sm"></span>
|
||||
</template>
|
||||
</button>
|
||||
<span v-else class="text-base font-bold text-green-600 dark:text-green-600">
|
||||
<FontAwesomeIcon :icon="faCheck" class=""></FontAwesomeIcon>
|
||||
OK
|
||||
</span>
|
||||
</td>
|
||||
</tr>
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
</template>
|
||||
|
||||
</div>
|
||||
</div>
|
||||
<form method="dialog" class="modal-backdrop">
|
||||
<form method="dialog" class="modal-backdrop backdrop-blur">
|
||||
<button>close</button>
|
||||
</form>
|
||||
</dialog>
|
||||
|
|
|
@ -1,8 +1,9 @@
|
|||
<script setup>
|
||||
import { ref, watch } from "vue"
|
||||
import { ref, watch, computed } from "vue"
|
||||
import { notifications, userCount, notificationCounter, notificationAPICounter, toggleVerboseMode, toggleApiQueryMode } from "@/socket";
|
||||
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome'
|
||||
import { faSignal, faCloud, faCog, faUser, faCircle } from '@fortawesome/free-solid-svg-icons'
|
||||
import { faSignal, faCloud, faCog, faUsers, faCircle } from '@fortawesome/free-solid-svg-icons'
|
||||
import TheLiveLogsActivityGraphVue from "./TheLiveLogsActivityGraph.vue";
|
||||
|
||||
|
||||
const verbose = ref(false)
|
||||
|
@ -17,7 +18,7 @@
|
|||
})
|
||||
|
||||
function getClassFromResponseCode(response_code) {
|
||||
if (String(response_code).startsWith('2')) {
|
||||
if (String(response_code).startsWith('2') || response_code == 302) {
|
||||
return 'text-green-500'
|
||||
} else if (String(response_code).startsWith('5')) {
|
||||
return 'text-red-600'
|
||||
|
@ -29,6 +30,7 @@
|
|||
</script>
|
||||
|
||||
<template>
|
||||
<div>
|
||||
<h3 class="text-2xl mt-6 mb-2 font-bold text-blue-500 dark:text-blue-400">
|
||||
<FontAwesomeIcon :icon="faSignal"></FontAwesomeIcon>
|
||||
Live logs
|
||||
|
@ -37,7 +39,7 @@
|
|||
<div class="mb-2 flex flex-wrap gap-x-3">
|
||||
<span class="rounded-lg py-1 px-2 dark:bg-sky-700 bg-sky-400 text-slate-800 dark:text-slate-200">
|
||||
<span class="mr-1">
|
||||
<FontAwesomeIcon :icon="faUser" size="sm"></FontAwesomeIcon>
|
||||
<FontAwesomeIcon :icon="faUsers" size="sm"></FontAwesomeIcon>
|
||||
Players:
|
||||
</span>
|
||||
<span class="font-bold">{{ userCount }}</span>
|
||||
|
@ -71,9 +73,11 @@
|
|||
</span>
|
||||
</div>
|
||||
|
||||
<TheLiveLogsActivityGraphVue></TheLiveLogsActivityGraphVue>
|
||||
|
||||
<table class="bg-white dark:bg-slate-800 rounded-lg shadow-xl w-full">
|
||||
<thead>
|
||||
<tr class="font-medium dark:text-slate-200 text-slate-600 ">
|
||||
<tr class="font-medium dark:text-slate-200 text-slate-600">
|
||||
<th class="border-b border-slate-100 dark:border-slate-700 p-3 pl-6 text-left"></th>
|
||||
<th class="border-b border-slate-100 dark:border-slate-700 p-3 pl-2 text-left">User</th>
|
||||
<th class="border-b border-slate-100 dark:border-slate-700 p-3 text-left">Time</th>
|
||||
|
@ -147,4 +151,5 @@
|
|||
</template>
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
</template>
|
84
src/components/TheLiveLogsActivityGraph.vue
Normal file
84
src/components/TheLiveLogsActivityGraph.vue
Normal file
|
@ -0,0 +1,84 @@
|
|||
<script setup>
|
||||
import { ref, watch, computed } from "vue"
|
||||
import { notificationHistory, notificationHistoryConfig } from "@/socket";
|
||||
import { darkModeEnabled } from "@/settings.js"
|
||||
|
||||
const theChart = ref(null)
|
||||
const chartInitSeries = [
|
||||
{data: Array.from(Array(12*20)).map(()=> 0)}
|
||||
]
|
||||
const hasActivity = computed(() => notificationHistory.value.length > 0)
|
||||
const chartSeries = computed(() => {
|
||||
return notificationHistory.value ? notificationHistorySeries.value : chartInitSeries.value
|
||||
})
|
||||
|
||||
const notificationHistorySeries = computed(() => {
|
||||
return [{data: Array.from(notificationHistory.value)}]
|
||||
})
|
||||
|
||||
const chartOptions = computed(() => {
|
||||
return {
|
||||
chart: {
|
||||
type: 'bar',
|
||||
width: '100%',
|
||||
height: 32,
|
||||
sparkline: {
|
||||
enabled: true
|
||||
},
|
||||
dropShadow: {
|
||||
enabled: true,
|
||||
enabledOnSeries: undefined,
|
||||
top: 2,
|
||||
left: 1,
|
||||
blur: 2,
|
||||
color: '#000',
|
||||
opacity: darkModeEnabled.value ? 0.35 : 0.15
|
||||
},
|
||||
animations: {
|
||||
enabled: false,
|
||||
easing: 'easeinout',
|
||||
speed: 200,
|
||||
},
|
||||
},
|
||||
colors: [darkModeEnabled.value ? '#008ffb' : '#1f9eff'],
|
||||
plotOptions: {
|
||||
bar: {
|
||||
columnWidth: '80%'
|
||||
}
|
||||
},
|
||||
yaxis: {
|
||||
min: 0,
|
||||
max: 20,
|
||||
labels: {
|
||||
show: false,
|
||||
}
|
||||
},
|
||||
tooltip: {
|
||||
enabled: false,
|
||||
},
|
||||
}
|
||||
})
|
||||
|
||||
</script>
|
||||
|
||||
<template>
|
||||
<div class="my-2 --ml-1 bg-slate-50 dark:bg-slate-600 py-1 pl-1 pr-3 rounded-md relative flex flex-col">
|
||||
<div :class="`${!hasActivity ? 'hidden' : 'absolute'} h-10 -mt-1 w-full z-30`">
|
||||
<div class="text-xxs flex justify-between h-full items-center text-slate-500 dark:text-slate-300 select-none">
|
||||
<span class="-rotate-90 w-8 -ml-3">- {{ notificationHistoryConfig.buffer_timestamp_min }}min</span>
|
||||
<span class="-rotate-90 w-8 text-xs">–</span>
|
||||
<span class="-rotate-90 w-8 text-lg">–</span>
|
||||
<span class="-rotate-90 w-8 text-xs">–</span>
|
||||
<span class="-rotate-90 w-8 -mr-1.5">- 0min</span>
|
||||
</div>
|
||||
</div>
|
||||
<i :class="['text-center text-slate-600 dark:text-slate-400', hasActivity ? 'hidden' : 'block']">
|
||||
- No recorded activity -
|
||||
</i>
|
||||
<apexchart
|
||||
ref="theChart" :class="hasActivity ? 'block' : 'absolute h-8 w-full'" height="32" width="100%"
|
||||
:options="chartOptions"
|
||||
:series="chartSeries"
|
||||
></apexchart>
|
||||
</div>
|
||||
</template>
|
58
src/components/ThePlayerGrid.vue
Normal file
58
src/components/ThePlayerGrid.vue
Normal file
|
@ -0,0 +1,58 @@
|
|||
<script setup>
|
||||
import { ref, computed } from "vue";
|
||||
import { progresses, userCount } from "@/socket";
|
||||
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome'
|
||||
import { faUsers } from '@fortawesome/free-solid-svg-icons'
|
||||
import { darkModeEnabled } from "@/settings.js"
|
||||
import LiveLogsUserActivityGraph from "./LiveLogsUserActivityGraph.vue"
|
||||
|
||||
|
||||
const compactGrid = computed(() => { return userCount.value > 70 })
|
||||
const sortedProgress = computed(() => Object.values(progresses.value).sort((a, b) => {
|
||||
if (a.email < b.email) {
|
||||
return -1;
|
||||
}
|
||||
if (a.email > b.email) {
|
||||
return 1;
|
||||
}
|
||||
return 0;
|
||||
}))
|
||||
</script>
|
||||
|
||||
<template>
|
||||
<div class="
|
||||
mt-2 px-2 pt-1 pb-2 rounded border
|
||||
bg-slate-100 border-slate-300 dark:bg-slate-600 dark:border-slate-800
|
||||
">
|
||||
|
||||
<h4 class="text-xl mb-2 font-bold text-blue-500 dark:text-blue-400">
|
||||
<FontAwesomeIcon :icon="faUsers"></FontAwesomeIcon>
|
||||
Active Players
|
||||
</h4>
|
||||
|
||||
<div :class="`flex flex-wrap ${compactGrid ? 'gap-1' : 'gap-2'}`">
|
||||
<span
|
||||
v-for="(progress) in sortedProgress"
|
||||
:key="progress.user_id"
|
||||
class="bg-slate-200 dark:bg-slate-900 rounded border drop-shadow-lg border-slate-700"
|
||||
>
|
||||
<span class="
|
||||
flex p-2 mb-1
|
||||
text-slate-600 dark:text-slate-400
|
||||
">
|
||||
<span :class="`flex flex-col ${compactGrid ? 'w-[120px]' : 'w-60'}`">
|
||||
<span :title="progress.user_id" class="text-nowrap inline-block leading-5 truncate">
|
||||
<span :class="`${compactGrid ? 'text-base' : 'text-lg'} font-bold font-mono leading-5 tracking-tight`">{{ progress.email.split('@')[0] }}</span>
|
||||
<span :class="`${compactGrid ? 'text-xs' : 'text-xs'} font-mono tracking-tight`">@{{ progress.email.split('@')[1] }}</span>
|
||||
</span>
|
||||
<LiveLogsUserActivityGraph
|
||||
:user_id="progress.user_id"
|
||||
:compact_view="compactGrid"
|
||||
:ultra_compact_view="false"
|
||||
></LiveLogsUserActivityGraph>
|
||||
</span>
|
||||
</span>
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
</template>
|
|
@ -1,27 +1,25 @@
|
|||
<script setup>
|
||||
import { ref, computed } from "vue";
|
||||
import { active_exercises as exercises, progresses, setCompletedState } from "@/socket";
|
||||
import { active_exercises as exercises } from "@/socket";
|
||||
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome'
|
||||
import { faCheck, faTimes, faGraduationCap, faMedal, faHourglassHalf } from '@fortawesome/free-solid-svg-icons'
|
||||
|
||||
const collapsed_panels = ref([])
|
||||
|
||||
function toggleCompleted(completed, user_id, exec_uuid, task_uuid) {
|
||||
setCompletedState(completed, user_id, exec_uuid, task_uuid)
|
||||
}
|
||||
|
||||
function collapse(exercise_index) {
|
||||
const index = collapsed_panels.value.indexOf(exercise_index)
|
||||
if (index >= 0) {
|
||||
collapsed_panels.value.splice(index, 1)
|
||||
} else {
|
||||
collapsed_panels.value.push(exercise_index)
|
||||
}
|
||||
}
|
||||
import { faGraduationCap, faUpRightAndDownLeftFromCenter, faDownLeftAndUpRightToCenter, faWarning } from '@fortawesome/free-solid-svg-icons'
|
||||
import TheScoreTable from "./scoreViews/TheScoreTable.vue"
|
||||
import TheFullScreenScoreGrid from "./scoreViews/TheFullScreenScoreGrid.vue"
|
||||
import ThePlayerGrid from "./ThePlayerGrid.vue"
|
||||
import { fullscreenModeOn } from "@/settings.js"
|
||||
|
||||
const hasExercises = computed(() => exercises.value.length > 0)
|
||||
const hasProgress = computed(() => Object.keys(progresses.value).length > 0)
|
||||
const fullscreen_panel = ref(false)
|
||||
|
||||
function toggleFullScreen(exercise_index) {
|
||||
if (fullscreen_panel.value === exercise_index) {
|
||||
fullscreen_panel.value = false
|
||||
fullscreenModeOn.value = false
|
||||
} else {
|
||||
fullscreen_panel.value = exercise_index
|
||||
fullscreenModeOn.value = true
|
||||
}
|
||||
}
|
||||
</script>
|
||||
|
||||
<template>
|
||||
|
@ -32,117 +30,56 @@
|
|||
|
||||
<div
|
||||
v-if="!hasExercises"
|
||||
class="text-center text-slate-600 dark:text-slate-400 p-3 pl-6"
|
||||
class="text-slate-600 dark:text-slate-400 p-3 pl-6"
|
||||
>
|
||||
<i>- No Exercise available -</i>
|
||||
<div class="
|
||||
p-2 border-l-4 text-left rounded
|
||||
dark:bg-yellow-300 dark:text-slate-900 dark:border-yellow-700
|
||||
bg-yellow-200 text-slate-900 border-yellow-700
|
||||
">
|
||||
<FontAwesomeIcon :icon="faWarning" class="text-yellow-700 text-lg mx-3"></FontAwesomeIcon>
|
||||
<strong class="">No Exercise available.</strong>
|
||||
<span class="ml-1">Select an exercise in the <i class="underline">Admin panel</i>.</span>
|
||||
</div>
|
||||
<table
|
||||
|
||||
<ThePlayerGrid></ThePlayerGrid>
|
||||
</div>
|
||||
|
||||
<template
|
||||
v-for="(exercise, exercise_index) in exercises"
|
||||
:key="exercise.name"
|
||||
class="bg-white dark:bg-slate-800 rounded-lg shadow-xl w-full mb-4"
|
||||
>
|
||||
<thead>
|
||||
<tr @click="collapse(exercise_index)" class="cursor-pointer">
|
||||
<th :colspan="2 + exercise.tasks.length" class="rounded-t-lg border-b border-slate-100 dark:border-slate-700 text-md p-3 pl-6 text-center dark:bg-blue-800 bg-blue-500 dark:text-slate-300 text-slate-100">
|
||||
<div class="flex justify-between items-center">
|
||||
<span class="dark:text-blue-200 text-slate-200 "># {{ exercise_index + 1 }}</span>
|
||||
<span class="text-lg">{{ exercise.name }}</span>
|
||||
<span class="">
|
||||
Level: <span :class="{
|
||||
'rounded-lg px-1 ml-2': true,
|
||||
'dark:bg-sky-400 bg-sky-400 text-neutral-950': exercise.level == 'beginner',
|
||||
'dark:bg-orange-400 bg-orange-400 text-neutral-950': exercise.level == 'advanced',
|
||||
'dark:bg-red-600 bg-red-600 text-neutral-950': exercise.level == 'expert',
|
||||
}">{{ exercise.level }}</span>
|
||||
</span>
|
||||
</div>
|
||||
</th>
|
||||
</tr>
|
||||
<tr :class="`font-medium text-slate-600 dark:text-slate-200 ${collapsed_panels.includes(exercise_index) ? 'hidden' : ''}`">
|
||||
<th class="border-b border-slate-100 dark:border-slate-700 p-3 pl-6 text-left">User</th>
|
||||
<th
|
||||
v-for="(task, task_index) in exercise.tasks"
|
||||
:key="task.name"
|
||||
class="border-b border-slate-100 dark:border-slate-700 p-3"
|
||||
:title="task.description"
|
||||
>
|
||||
<div class="flex flex-col">
|
||||
<span class="text-center font-normal text-sm dark:text-blue-200 text-slate-500">Task {{ task_index + 1 }}</span>
|
||||
<i class="text-center">{{ task.name }}</i>
|
||||
</div>
|
||||
</th>
|
||||
<th class="border-b border-slate-100 dark:border-slate-700 p-3 text-left">Progress</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody :class="`${collapsed_panels.includes(exercise_index) ? 'hidden' : ''}`">
|
||||
<tr v-if="!hasProgress">
|
||||
<td
|
||||
:colspan="2 + exercise.tasks.length"
|
||||
class="text-center border-b border-slate-100 dark:border-slate-700 text-slate-600 dark:text-slate-400 p-3 pl-6"
|
||||
>
|
||||
<i>- No user yet -</i>
|
||||
</td>
|
||||
</tr>
|
||||
<template v-else>
|
||||
<tr v-for="(progress, user_id) in progresses" :key="user_id" class="bg-slate-100 dark:bg-slate-900">
|
||||
<td class="border-b border-slate-200 dark:border-slate-700 text-slate-600 dark:text-slate-400 p-3 pl-6">
|
||||
<span :title="user_id" class="text-nowrap">
|
||||
<FontAwesomeIcon v-if="progress.exercises[exercise.uuid].score / progress.exercises[exercise.uuid].max_score == 1" :icon="faMedal" class="mr-1 text-amber-300"></FontAwesomeIcon>
|
||||
<span class="text-lg font-bold font-mono">{{ progress.email.split('@')[0] }}</span>
|
||||
<span class="text-xs font-mono">@{{ progress.email.split('@')[1] }}</span>
|
||||
</span>
|
||||
</td>
|
||||
<td
|
||||
v-for="(task, task_index) in exercise.tasks"
|
||||
:key="task_index"
|
||||
class="text-center border-b border-slate-200 dark:border-slate-700 text-slate-500 dark:text-slate-400 p-2"
|
||||
>
|
||||
<div :class="fullscreen_panel === false ? 'relative min-w-fit' : ''">
|
||||
<span
|
||||
class="select-none cursor-pointer flex justify-center content-center flex-wrap h-9"
|
||||
@click="toggleCompleted(progress.exercises[exercise.uuid].tasks_completion[task.uuid], user_id, exercise.uuid, task.uuid)"
|
||||
v-show="fullscreen_panel === false || fullscreen_panel === exercise_index"
|
||||
:class="['inline-block absolute shadow-lg z-50', fullscreen_panel === false ? 'top-0 -right-7' : 'top-2 right-2']"
|
||||
>
|
||||
<span class="flex flex-col">
|
||||
<span class="text-nowrap">
|
||||
<FontAwesomeIcon
|
||||
v-if="progress.exercises[exercise.uuid].tasks_completion[task.uuid]"
|
||||
:icon="faCheck"
|
||||
:class="`text-xl ${progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'}`"
|
||||
/>
|
||||
<FontAwesomeIcon
|
||||
v-else-if="task.requirements?.inject_uuid !== undefined && !progress.exercises[exercise.uuid].tasks_completion[task.requirements.inject_uuid]"
|
||||
title="All requirements for that task haven't been fullfilled yet"
|
||||
:icon="faHourglassHalf"
|
||||
:class="`text-lg ${progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'}`"
|
||||
/>
|
||||
<FontAwesomeIcon
|
||||
v-else
|
||||
:icon="faTimes"
|
||||
:class="`text-xl ${progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'}`"
|
||||
/>
|
||||
<small :class="progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'"> (+{{ task.score }})</small>
|
||||
</span>
|
||||
<span class="text-sm leading-3">
|
||||
<span
|
||||
v-if="progress.exercises[exercise.uuid].tasks_completion[task.uuid].timestamp"
|
||||
:class="progress.exercises[exercise.uuid].tasks_completion[task.uuid].first_completion ? 'font-bold' : 'font-extralight'"
|
||||
<button
|
||||
@click="toggleFullScreen(exercise_index)"
|
||||
title="Toggle fullscreen mode"
|
||||
:class="`
|
||||
w-7 p-1 focus-outline font-semibold
|
||||
text-slate-800 bg-slate-100 hover:bg-slate-200 dark:text-slate-200 dark:bg-slate-800 dark:hover:bg-slate-900
|
||||
${fullscreen_panel === false ? 'rounded-r-md' : 'rounded-bl-md'}
|
||||
`"
|
||||
>
|
||||
{{ (new Date(progress.exercises[exercise.uuid].tasks_completion[task.uuid].timestamp * 1000)).toTimeString().split(' ', 1)[0] }}
|
||||
<FontAwesomeIcon :icon="fullscreen_panel !== exercise_index ? faUpRightAndDownLeftFromCenter : faDownLeftAndUpRightToCenter" fixed-width></FontAwesomeIcon>
|
||||
</button>
|
||||
</span>
|
||||
<span v-else></span>
|
||||
</span>
|
||||
</span>
|
||||
</span>
|
||||
</td>
|
||||
<td class="border-b border-slate-200 dark:border-slate-700 text-slate-500 dark:text-slate-400 p-3">
|
||||
<div class="flex w-full h-2 bg-gray-200 rounded-full overflow-hidden dark:bg-neutral-600" role="progressbar" :aria-valuenow="progress.exercises[exercise.uuid].score" :aria-valuemin="0" aria-valuemax="100">
|
||||
<div
|
||||
class="flex flex-col justify-center rounded-full overflow-hidden bg-green-600 text-xs text-white text-center whitespace-nowrap transition duration-500 dark:bg-green-500 transition-width transition-slowest ease"
|
||||
:style="`width: ${100 * (progress.exercises[exercise.uuid].score / progress.exercises[exercise.uuid].max_score)}%`"
|
||||
></div>
|
||||
<KeepAlive>
|
||||
<TheScoreTable
|
||||
v-show="fullscreen_panel === false"
|
||||
:exercise="exercise"
|
||||
:exercise_index="exercise_index"
|
||||
></TheScoreTable>
|
||||
</KeepAlive>
|
||||
<KeepAlive>
|
||||
<TheFullScreenScoreGrid
|
||||
v-if="fullscreen_panel !== false"
|
||||
:exercise="exercises[fullscreen_panel]"
|
||||
:exercise_index="exercise_index"
|
||||
></TheFullScreenScoreGrid>
|
||||
</KeepAlive>
|
||||
</div>
|
||||
</td>
|
||||
</tr>
|
||||
</template>
|
||||
</tbody>
|
||||
</table>
|
||||
</template>
|
|
@ -2,10 +2,12 @@
|
|||
import { ref, watch } from 'vue'
|
||||
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome'
|
||||
import { faMoon, faSun } from '@fortawesome/free-solid-svg-icons'
|
||||
import { darkModeOn } from "@/settings.js"
|
||||
|
||||
const darkMode = ref(true)
|
||||
const darkMode = ref(darkModeOn.value)
|
||||
|
||||
watch(darkMode, (newValue) => {
|
||||
darkModeOn.value = newValue
|
||||
if (newValue) {
|
||||
document.getElementsByTagName('body')[0].classList.add('dark')
|
||||
} else {
|
||||
|
|
0
src/components/elements/SettingIndicator.vue
Normal file
0
src/components/elements/SettingIndicator.vue
Normal file
251
src/components/scoreViews/TheFullScreenScoreGrid.vue
Normal file
251
src/components/scoreViews/TheFullScreenScoreGrid.vue
Normal file
|
@ -0,0 +1,251 @@
|
|||
<script setup>
|
||||
import { ref, computed } from "vue";
|
||||
import { active_exercises as exercises, progresses, userCount, setCompletedState } from "@/socket";
|
||||
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome'
|
||||
import { faCheck, faTimes, faMedal, faHourglassHalf } from '@fortawesome/free-solid-svg-icons'
|
||||
import { faCircleCheck } from '@fortawesome/free-regular-svg-icons'
|
||||
import { darkModeEnabled } from "@/settings.js"
|
||||
import LiveLogsUserActivityGraph from "../LiveLogsUserActivityGraph.vue"
|
||||
|
||||
const props = defineProps(['exercise', 'exercise_index'])
|
||||
const collapsed_panels = ref([])
|
||||
|
||||
const chartOptions = computed(() => {
|
||||
return {
|
||||
chart: {
|
||||
type: 'radialBar',
|
||||
height: 120,
|
||||
sparkline: {
|
||||
enabled: true
|
||||
},
|
||||
animations: {
|
||||
enabled: false,
|
||||
easing: 'easeinout',
|
||||
speed: 200,
|
||||
},
|
||||
},
|
||||
colors: [darkModeEnabled.value ? '#008ffb' : '#1f9eff'],
|
||||
plotOptions: {
|
||||
radialBar: {
|
||||
startAngle: -110,
|
||||
endAngle: 110,
|
||||
hollow: {
|
||||
margin: 0,
|
||||
size: '30%',
|
||||
background: '#64748b',
|
||||
position: 'front',
|
||||
dropShadow: {
|
||||
enabled: true,
|
||||
top: 3,
|
||||
left: 0,
|
||||
blur: 4,
|
||||
opacity: 0.24
|
||||
}
|
||||
},
|
||||
track: {
|
||||
background: '#475569',
|
||||
strokeWidth: '97%',
|
||||
margin: 0,
|
||||
dropShadow: {
|
||||
enabled: true,
|
||||
top: 3,
|
||||
left: 0,
|
||||
blur: 3,
|
||||
opacity: 0.35
|
||||
}
|
||||
},
|
||||
dataLabels: {
|
||||
show: true,
|
||||
name: {
|
||||
show: false,
|
||||
},
|
||||
value: {
|
||||
formatter: function(val) {
|
||||
return parseInt(val*userCount.value / 100);
|
||||
},
|
||||
offsetY: 7,
|
||||
color: darkModeEnabled.value ? '#cbd5e1' : '#f1f5f9',
|
||||
fontSize: '1.25rem',
|
||||
show: true,
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
stroke: {
|
||||
lineCap: 'smooth'
|
||||
},
|
||||
colors: [darkModeEnabled.value ? '#008ffb' : '#1f9eff'],
|
||||
labels: ['Progress'],
|
||||
tooltip: {
|
||||
enabled: false,
|
||||
},
|
||||
}
|
||||
})
|
||||
|
||||
function toggleCompleted(completed, user_id, exec_uuid, task_uuid) {
|
||||
setCompletedState(completed, user_id, exec_uuid, task_uuid)
|
||||
}
|
||||
|
||||
function collapse(exercise_index) {
|
||||
const index = collapsed_panels.value.indexOf(exercise_index)
|
||||
if (index >= 0) {
|
||||
collapsed_panels.value.splice(index, 1)
|
||||
} else {
|
||||
collapsed_panels.value.push(exercise_index)
|
||||
}
|
||||
}
|
||||
|
||||
const compactGrid = computed(() => { return userCount.value > 70 })
|
||||
const ultraCompactGrid = computed(() => { return userCount.value > 100 })
|
||||
const hasProgress = computed(() => Object.keys(progresses.value).length > 0)
|
||||
const sortedProgress = computed(() => Object.values(progresses.value).sort((a, b) => {
|
||||
if (a.email < b.email) {
|
||||
return -1;
|
||||
}
|
||||
if (a.email > b.email) {
|
||||
return 1;
|
||||
}
|
||||
return 0;
|
||||
}))
|
||||
|
||||
const taskCompletionPercentages = computed(() => {
|
||||
const completions = {}
|
||||
Object.values(props.exercise.tasks).forEach(task => {
|
||||
completions[task.uuid] = 0
|
||||
})
|
||||
|
||||
sortedProgress.value.forEach(progress => {
|
||||
for (const [taskUuid, taskCompletion] of Object.entries(progress.exercises[props.exercise.uuid].tasks_completion)) {
|
||||
if (taskCompletion !== false) {
|
||||
completions[taskUuid] += 1
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
for (const [taskUuid, taskCompletionSum] of Object.entries(completions)) {
|
||||
completions[taskUuid] = 100 * (taskCompletionSum / userCount.value)
|
||||
}
|
||||
return completions
|
||||
})
|
||||
|
||||
</script>
|
||||
|
||||
<template>
|
||||
<div class="
|
||||
fixed inset-2 z-40 h-100 overflow-x-hidden
|
||||
rounded-lg bg-slate-300 dark:bg-slate-800 border border-slate-400 dark:border-slate-800
|
||||
">
|
||||
|
||||
<div
|
||||
class="
|
||||
rounded-t-lg text-md p-3 pl-6 text-center
|
||||
dark:bg-blue-800 bg-blue-500 dark:text-slate-300 text-slate-100
|
||||
"
|
||||
>
|
||||
<!-- Modal header -->
|
||||
<div class="flex justify-between items-center">
|
||||
<span class="text-lg font-semibold">{{ exercise.name }}</span>
|
||||
<span class="mr-8">
|
||||
Level: <span :class="{
|
||||
'rounded-lg px-1 ml-2': true,
|
||||
'dark:bg-sky-400 bg-sky-400 text-neutral-950': exercise.level == 'beginner',
|
||||
'dark:bg-orange-400 bg-orange-400 text-neutral-950': exercise.level == 'advanced',
|
||||
'dark:bg-red-600 bg-red-600 text-neutral-950': exercise.level == 'expert',
|
||||
}">{{ exercise.level }}</span>
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Tasks name and pie charts -->
|
||||
<div class="p-2">
|
||||
<div class="flex justify-between mb-3">
|
||||
<span
|
||||
v-for="(task, task_index) in exercise.tasks"
|
||||
:key="task.name"
|
||||
class="p-1 inline-block"
|
||||
:title="task.description"
|
||||
>
|
||||
<span class="flex flex-col">
|
||||
<span class="text-center font-normal text-sm dark:text-blue-200 text-slate-800 text-nowrap">Task {{ task_index + 1 }}</span>
|
||||
<i class="text-center leading-4 text-slate-600 dark:text-slate-400">{{ task.name }}</i>
|
||||
<span class="inline-block h-18 -mt-4 mx-auto">
|
||||
<apexchart
|
||||
ref="theChart" class="" height="120" width="100"
|
||||
:options="chartOptions"
|
||||
:series="[taskCompletionPercentages[task.uuid]]"
|
||||
></apexchart>
|
||||
</span>
|
||||
</span>
|
||||
</span>
|
||||
</div>
|
||||
|
||||
<!-- User grid -->
|
||||
<div :class="`flex flex-wrap ${compactGrid ? 'gap-1' : 'gap-2'}`">
|
||||
<span
|
||||
v-for="(progress) in sortedProgress"
|
||||
:key="progress.user_id"
|
||||
:class="[
|
||||
'bg-slate-200 dark:bg-slate-900 rounded border drop-shadow-lg',
|
||||
progress.exercises[exercise.uuid].score / progress.exercises[exercise.uuid].max_score == 1 ? 'border-green-700' : 'border-slate-700',
|
||||
]"
|
||||
>
|
||||
<span class="
|
||||
flex p-2 mb-1
|
||||
text-slate-600 dark:text-slate-400
|
||||
">
|
||||
<span :class="`flex flex-col ${compactGrid ? 'w-[120px]' : 'w-60'} ${compactGrid ? '' : 'mb-1'}`">
|
||||
<span :title="progress.user_id" class="text-nowrap inline-block leading-5 truncate mb-1">
|
||||
<FontAwesomeIcon
|
||||
v-if="progress.exercises[exercise.uuid].score / progress.exercises[exercise.uuid].max_score == 1"
|
||||
:icon="faMedal" class="mr-1 text-amber-300"
|
||||
></FontAwesomeIcon>
|
||||
<span :class="`${compactGrid ? 'text-base' : 'text-lg'} font-bold font-mono leading-5 tracking-tight`">{{ progress.email.split('@')[0] }}</span>
|
||||
<span :class="`${compactGrid ? 'text-xs' : 'text-xs'} font-mono tracking-tight`">@{{ progress.email.split('@')[1] }}</span>
|
||||
</span>
|
||||
<LiveLogsUserActivityGraph
|
||||
:user_id="progress.user_id"
|
||||
:compact_view="compactGrid"
|
||||
:ultra_compact_view="ultraCompactGrid"
|
||||
></LiveLogsUserActivityGraph>
|
||||
</span>
|
||||
</span>
|
||||
|
||||
<span class="
|
||||
flex flex-row justify-between px-2
|
||||
text-slate-500 dark:text-slate-400
|
||||
">
|
||||
<span
|
||||
v-for="(task, task_index) in exercise.tasks"
|
||||
:key="task_index"
|
||||
class="select-none cursor-pointer"
|
||||
@click="toggleCompleted(progress.exercises[exercise.uuid].tasks_completion[task.uuid], progress.user_id, exercise.uuid, task.uuid)"
|
||||
:title="task.name"
|
||||
>
|
||||
<span class="text-nowrap">
|
||||
<FontAwesomeIcon
|
||||
v-if="progress.exercises[exercise.uuid].tasks_completion[task.uuid]"
|
||||
:icon="(progress.exercises[exercise.uuid].tasks_completion[task.uuid] && progress.exercises[exercise.uuid].tasks_completion[task.uuid].first_completion) ? faCircleCheck : faCheck"
|
||||
:class="`${compactGrid ? 'text-xs' : 'text-xl'} dark:text-green-400 text-green-600`"
|
||||
fixed-width
|
||||
/>
|
||||
<FontAwesomeIcon
|
||||
v-else-if="task.requirements?.inject_uuid !== undefined && !progress.exercises[exercise.uuid].tasks_completion[task.requirements.inject_uuid]"
|
||||
title="All requirements for that task haven't been fullfilled yet"
|
||||
:icon="faHourglassHalf"
|
||||
:class="`${compactGrid ? 'text-xs' : 'text-lg'} dark:text-slate-500 text-slate-400`"
|
||||
fixed-width
|
||||
/>
|
||||
<FontAwesomeIcon
|
||||
v-else
|
||||
:icon="faTimes"
|
||||
:class="`${compactGrid ? 'text-xs' : 'text-xl'} dark:text-slate-500 text-slate-400`"
|
||||
fixed-width
|
||||
/>
|
||||
</span>
|
||||
</span>
|
||||
</span>
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</template>
|
186
src/components/scoreViews/TheScoreTable.vue
Normal file
186
src/components/scoreViews/TheScoreTable.vue
Normal file
|
@ -0,0 +1,186 @@
|
|||
<script setup>
|
||||
import { ref, computed } from "vue";
|
||||
import { active_exercises as exercises, progresses, userCount, setCompletedState } from "@/socket";
|
||||
import { FontAwesomeIcon } from '@fortawesome/vue-fontawesome'
|
||||
import { faCheck, faTimes, faMedal, faHourglassHalf } from '@fortawesome/free-solid-svg-icons'
|
||||
import { faCircleCheck } from '@fortawesome/free-regular-svg-icons'
|
||||
import LiveLogsUserActivityGraph from "../LiveLogsUserActivityGraph.vue"
|
||||
|
||||
const props = defineProps(['exercise', 'exercise_index'])
|
||||
const collapsed_panels = ref([])
|
||||
|
||||
function toggleCompleted(completed, user_id, exec_uuid, task_uuid) {
|
||||
setCompletedState(completed, user_id, exec_uuid, task_uuid)
|
||||
}
|
||||
|
||||
function collapse(exercise_index) {
|
||||
const index = collapsed_panels.value.indexOf(exercise_index)
|
||||
if (index >= 0) {
|
||||
collapsed_panels.value.splice(index, 1)
|
||||
} else {
|
||||
collapsed_panels.value.push(exercise_index)
|
||||
}
|
||||
}
|
||||
|
||||
const compactTable = computed(() => { return userCount.value > 20 })
|
||||
const hasProgress = computed(() => Object.keys(progresses.value).length > 0)
|
||||
const sortedProgress = computed(() => Object.values(progresses.value).sort((a, b) => {
|
||||
if (a.email < b.email) {
|
||||
return -1;
|
||||
}
|
||||
if (a.email > b.email) {
|
||||
return 1;
|
||||
}
|
||||
return 0;
|
||||
}))
|
||||
|
||||
const taskCompletionPercentages = computed(() => {
|
||||
const completions = {}
|
||||
Object.values(props.exercise.tasks).forEach(task => {
|
||||
completions[task.uuid] = 0
|
||||
})
|
||||
|
||||
sortedProgress.value.forEach(progress => {
|
||||
for (const [taskUuid, taskCompletion] of Object.entries(progress.exercises[props.exercise.uuid].tasks_completion)) {
|
||||
if (taskCompletion !== false) {
|
||||
completions[taskUuid] += 1
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
for (const [taskUuid, taskCompletionSum] of Object.entries(completions)) {
|
||||
completions[taskUuid] = 100 * (taskCompletionSum / userCount.value)
|
||||
}
|
||||
return completions
|
||||
})
|
||||
|
||||
</script>
|
||||
|
||||
<template>
|
||||
<table
|
||||
class="bg-white dark:bg-slate-800 rounded-lg shadow-xl w-full mb-4"
|
||||
>
|
||||
<thead>
|
||||
<tr @click="collapse(exercise_index)" class="cursor-pointer">
|
||||
<th :colspan="2 + exercise.tasks.length" class="rounded-tl-lg border-b border-slate-100 dark:border-slate-700 text-md p-3 pl-6 text-center dark:bg-blue-800 bg-blue-500 dark:text-slate-300 text-slate-100">
|
||||
<div class="flex justify-between items-center">
|
||||
<span class="dark:text-blue-200 text-slate-200 "># {{ exercise_index + 1 }}</span>
|
||||
<span class="text-lg">{{ exercise.name }}</span>
|
||||
<span class="">
|
||||
Level: <span :class="{
|
||||
'rounded-lg px-1 ml-2': true,
|
||||
'dark:bg-sky-400 bg-sky-400 text-neutral-950': exercise.level == 'beginner',
|
||||
'dark:bg-orange-400 bg-orange-400 text-neutral-950': exercise.level == 'advanced',
|
||||
'dark:bg-red-600 bg-red-600 text-neutral-950': exercise.level == 'expert',
|
||||
}">{{ exercise.level }}</span>
|
||||
</span>
|
||||
</div>
|
||||
</th>
|
||||
</tr>
|
||||
<tr :class="`font-medium text-slate-600 dark:text-slate-200 ${collapsed_panels.includes(exercise_index) ? 'hidden' : ''}`">
|
||||
<th class="border-b border-slate-100 dark:border-slate-700 p-3 pl-6 text-left">User</th>
|
||||
<th
|
||||
v-for="(task, task_index) in exercise.tasks"
|
||||
:key="task.name"
|
||||
class="border-b border-slate-100 dark:border-slate-700 p-3 align-top"
|
||||
:title="task.description"
|
||||
>
|
||||
<div class="flex flex-col">
|
||||
<span class="text-center font-normal text-sm dark:text-blue-200 text-slate-500 text-nowrap">Task {{ task_index + 1 }}</span>
|
||||
<i class="text-center">{{ task.name }}</i>
|
||||
<div
|
||||
role="progressbar"
|
||||
class="flex w-full h-1 bg-gray-200 rounded-full overflow-hidden dark:bg-neutral-600"
|
||||
:aria-valuenow="taskCompletionPercentages[task.uuid]" :aria-valuemin="0" aria-valuemax="100"
|
||||
:title="`${taskCompletionPercentages[task.uuid].toFixed(0)}%`"
|
||||
>
|
||||
<div
|
||||
class="flex flex-col justify-center rounded-full overflow-hidden bg-blue-600 text-xs text-white text-center whitespace-nowrap transition duration-500 dark:bg-blue-500 transition-width transition-slowest ease"
|
||||
:style="`width: ${taskCompletionPercentages[task.uuid]}%`"
|
||||
></div>
|
||||
</div>
|
||||
</div>
|
||||
</th>
|
||||
<th class="border-b border-slate-100 dark:border-slate-700 p-3 text-left">Progress</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody :class="`${collapsed_panels.includes(exercise_index) ? 'hidden' : ''}`">
|
||||
<tr v-if="!hasProgress">
|
||||
<td
|
||||
:colspan="2 + exercise.tasks.length"
|
||||
class="text-center border-b border-slate-100 dark:border-slate-700 text-slate-600 dark:text-slate-400 p-3 pl-6"
|
||||
>
|
||||
<i>- No user yet -</i>
|
||||
</td>
|
||||
</tr>
|
||||
<template v-else>
|
||||
<tr v-for="(progress) in sortedProgress" :key="progress.user_id" class="bg-slate-100 dark:bg-slate-900">
|
||||
<td class="border-b border-slate-200 dark:border-slate-700 text-slate-600 dark:text-slate-400 p-0 pl-2 relative">
|
||||
<span class="flex flex-col max-w-60">
|
||||
<span :title="progress.user_id" class="text-nowrap inline-block leading-5 truncate">
|
||||
<FontAwesomeIcon v-if="progress.exercises[exercise.uuid].score / progress.exercises[exercise.uuid].max_score == 1" :icon="faMedal" class="mr-1 text-amber-300"></FontAwesomeIcon>
|
||||
<span class="text-lg font-bold font-mono leading-5 tracking-tight">{{ progress.email.split('@')[0] }}</span>
|
||||
<span class="text-xs font-mono tracking-tight">@{{ progress.email.split('@')[1] }}</span>
|
||||
</span>
|
||||
<LiveLogsUserActivityGraph
|
||||
:user_id="progress.user_id"
|
||||
:compact_view="compactTable"
|
||||
></LiveLogsUserActivityGraph>
|
||||
</span>
|
||||
</td>
|
||||
<td
|
||||
v-for="(task, task_index) in exercise.tasks"
|
||||
:key="task_index"
|
||||
:class="`text-center border-b border-slate-200 dark:border-slate-700 text-slate-500 dark:text-slate-400 ${compactTable ? 'p-0' : 'p-2'}`"
|
||||
>
|
||||
<span
|
||||
class="select-none cursor-pointer flex justify-center content-center flex-wrap h-9"
|
||||
@click="toggleCompleted(progress.exercises[exercise.uuid].tasks_completion[task.uuid], progress.user_id, exercise.uuid, task.uuid)"
|
||||
>
|
||||
<span class="flex flex-col">
|
||||
<span class="text-nowrap">
|
||||
<FontAwesomeIcon
|
||||
v-if="progress.exercises[exercise.uuid].tasks_completion[task.uuid]"
|
||||
:icon="progress.exercises[exercise.uuid].tasks_completion[task.uuid].first_completion ? faCircleCheck : faCheck"
|
||||
:class="`
|
||||
${progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'}
|
||||
${progress.exercises[exercise.uuid].tasks_completion[task.uuid].first_completion ? 'text-lg' : 'text-xl'}
|
||||
`"
|
||||
/>
|
||||
<FontAwesomeIcon
|
||||
v-else-if="task.requirements?.inject_uuid !== undefined && !progress.exercises[exercise.uuid].tasks_completion[task.requirements.inject_uuid]"
|
||||
title="All requirements for that task haven't been fullfilled yet"
|
||||
:icon="faHourglassHalf"
|
||||
:class="`text-lg ${progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'}`"
|
||||
/>
|
||||
<FontAwesomeIcon
|
||||
v-else
|
||||
:icon="faTimes"
|
||||
:class="`text-xl ${progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'}`"
|
||||
/>
|
||||
<small :class="progress.exercises[exercise.uuid].tasks_completion[task.uuid] ? 'dark:text-green-400 text-green-600' : 'dark:text-slate-500 text-slate-400'"> (+{{ task.score }})</small>
|
||||
</span>
|
||||
<span :class="['leading-3', !compactTable ? 'text-sm' : 'text-xs']">
|
||||
<span
|
||||
v-if="progress.exercises[exercise.uuid].tasks_completion[task.uuid].timestamp"
|
||||
:class="progress.exercises[exercise.uuid].tasks_completion[task.uuid].first_completion ? 'font-bold' : 'font-extralight'"
|
||||
>
|
||||
{{ (new Date(progress.exercises[exercise.uuid].tasks_completion[task.uuid].timestamp * 1000)).toTimeString().split(' ', 1)[0] }}
|
||||
</span>
|
||||
</span>
|
||||
</span>
|
||||
</span>
|
||||
</td>
|
||||
<td class="border-b border-slate-200 dark:border-slate-700 text-slate-500 dark:text-slate-400 p-3">
|
||||
<div class="flex w-full h-2 bg-gray-200 rounded-full overflow-hidden dark:bg-neutral-600" role="progressbar" :aria-valuenow="progress.exercises[exercise.uuid].score" :aria-valuemin="0" aria-valuemax="100">
|
||||
<div
|
||||
class="flex flex-col justify-center rounded-full overflow-hidden bg-green-600 text-xs text-white text-center whitespace-nowrap transition duration-500 dark:bg-green-500 transition-width transition-slowest ease"
|
||||
:style="`width: ${100 * (progress.exercises[exercise.uuid].score / progress.exercises[exercise.uuid].max_score)}%`"
|
||||
></div>
|
||||
</div>
|
||||
</td>
|
||||
</tr>
|
||||
</template>
|
||||
</tbody>
|
||||
</table>
|
||||
</template>
|
|
@ -1,6 +1,10 @@
|
|||
import './assets/main.css'
|
||||
import VueApexCharts from "vue3-apexcharts";
|
||||
|
||||
import { createApp } from 'vue'
|
||||
import App from './App.vue'
|
||||
|
||||
createApp(App).mount('#app')
|
||||
const app = createApp(App)
|
||||
app.use(VueApexCharts)
|
||||
|
||||
app.mount('#app')
|
6
src/settings.js
Normal file
6
src/settings.js
Normal file
|
@ -0,0 +1,6 @@
|
|||
import { ref, computed } from 'vue'
|
||||
|
||||
export const darkModeOn = ref(true)
|
||||
export const darkModeEnabled = computed(() => darkModeOn.value)
|
||||
|
||||
export const fullscreenModeOn = ref(false)
|
|
@ -3,13 +3,17 @@ import { io } from "socket.io-client";
|
|||
import debounce from 'lodash.debounce'
|
||||
|
||||
// "undefined" means the URL will be computed from the `window.location` object
|
||||
const URL = process.env.NODE_ENV === "production" ? undefined : "http://localhost:4000";
|
||||
const URL = process.env.NODE_ENV === "production" ? undefined : "http://localhost:40001";
|
||||
const MAX_LIVE_LOG = 30
|
||||
|
||||
const initial_state = {
|
||||
notificationEvents: [],
|
||||
notificationCounter: 0,
|
||||
notificationAPICounter: 0,
|
||||
notificationHistory: [],
|
||||
notificationHistoryConfig: {},
|
||||
userActivity: {},
|
||||
userActivityConfig: {},
|
||||
exercises: [],
|
||||
selected_exercises: [],
|
||||
progresses: {},
|
||||
|
@ -40,6 +44,10 @@ export const notificationCounter = computed(() => state.notificationCounter)
|
|||
export const notificationAPICounter = computed(() => state.notificationAPICounter)
|
||||
export const userCount = computed(() => Object.keys(state.progresses).length)
|
||||
export const diagnostic = computed(() => state.diagnostic)
|
||||
export const notificationHistory = computed(() => state.notificationHistory)
|
||||
export const notificationHistoryConfig = computed(() => state.notificationHistoryConfig)
|
||||
export const userActivity = computed(() => state.userActivity)
|
||||
export const userActivityConfig = computed(() => state.userActivityConfig)
|
||||
export const socketConnected = computed(() => connectionState.connected)
|
||||
export const zmqLastTime = computed(() => connectionState.zmq_last_time)
|
||||
|
||||
|
@ -52,6 +60,7 @@ export function fullReload() {
|
|||
getSelectedExercises()
|
||||
getNotifications()
|
||||
getProgress()
|
||||
getUsersActivity()
|
||||
}
|
||||
|
||||
export function setCompletedState(completed, user_id, exec_uuid, task_uuid) {
|
||||
|
@ -67,6 +76,10 @@ export function resetAllExerciseProgress() {
|
|||
sendResetAllExerciseProgress()
|
||||
}
|
||||
|
||||
export function resetAll() {
|
||||
sendResetAll()
|
||||
}
|
||||
|
||||
export function resetLiveLogs() {
|
||||
sendResetLiveLogs()
|
||||
}
|
||||
|
@ -87,6 +100,17 @@ export function toggleApiQueryMode(enabled) {
|
|||
sendToggleApiQueryMode(enabled)
|
||||
}
|
||||
|
||||
export function remediateSetting(setting) {
|
||||
sendRemediateSetting(setting, (result) => {
|
||||
if (result.success) {
|
||||
state.diagnostic['settings'][setting].value = state.diagnostic['settings'][setting].expected_value
|
||||
} else {
|
||||
state.diagnostic['settings'][setting].error = true
|
||||
state.diagnostic['settings'][setting].errorMessage = result.message
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
export const debouncedGetProgress = debounce(getProgress, 200, {leading: true})
|
||||
export const debouncedGetDiangostic = debounce(getDiangostic, 1000, {leading: true})
|
||||
|
||||
|
@ -118,6 +142,14 @@ function getProgress() {
|
|||
})
|
||||
}
|
||||
|
||||
function getUsersActivity() {
|
||||
socket.emit("get_users_activity", (user_activity_bundle) => {
|
||||
state.userActivity = user_activity_bundle.activity
|
||||
state.userActivityConfig = user_activity_bundle.config
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
function getDiangostic() {
|
||||
state.diagnostic = {}
|
||||
socket.emit("get_diagnostic", (diagnostic) => {
|
||||
|
@ -138,6 +170,12 @@ function sendResetAllExerciseProgress() {
|
|||
})
|
||||
}
|
||||
|
||||
function sendResetAll() {
|
||||
socket.emit("reset_all", () => {
|
||||
getProgress()
|
||||
})
|
||||
}
|
||||
|
||||
function sendResetLiveLogs() {
|
||||
socket.emit("reset_notifications", () => {
|
||||
getNotifications()
|
||||
|
@ -164,6 +202,15 @@ function sendToggleApiQueryMode(enabled) {
|
|||
socket.emit("toggle_apiquery_mode", payload, () => {})
|
||||
}
|
||||
|
||||
function sendRemediateSetting(setting, cb) {
|
||||
const payload = {
|
||||
name: setting
|
||||
}
|
||||
socket.emit("remediate_setting", payload, (result) => {
|
||||
cb(result)
|
||||
})
|
||||
}
|
||||
|
||||
/* Event listener */
|
||||
|
||||
socket.on("connect", () => {
|
||||
|
@ -194,6 +241,16 @@ socket.on("keep_alive", (keep_alive) => {
|
|||
connectionState.zmq_last_time = keep_alive['zmq_last_time']
|
||||
});
|
||||
|
||||
socket.on("update_notification_history", (notification_history_bundle) => {
|
||||
state.notificationHistory = notification_history_bundle.history
|
||||
state.notificationHistoryConfig = notification_history_bundle.config
|
||||
});
|
||||
|
||||
socket.on("update_users_activity", (user_activity_bundle) => {
|
||||
state.userActivity = user_activity_bundle.activity
|
||||
state.userActivityConfig = user_activity_bundle.config
|
||||
});
|
||||
|
||||
function addLimited(target, message, maxCount) {
|
||||
target.unshift(message)
|
||||
if (target.length > maxCount) {
|
||||
|
|
|
@ -4,14 +4,22 @@ export default {
|
|||
"./index.html",
|
||||
"./src/**/*.{vue,js,ts,jsx,tsx}",
|
||||
],
|
||||
safelist: [
|
||||
{
|
||||
pattern: /bg-blue+/, // Includes bg of all colors and shades
|
||||
},
|
||||
],
|
||||
theme: {
|
||||
extend: {
|
||||
transitionProperty: {
|
||||
'width': 'width'
|
||||
} ,
|
||||
},
|
||||
screens: {
|
||||
'3xl': '1800px',
|
||||
}
|
||||
},
|
||||
fontSize: {
|
||||
'xxs': '0.6rem',
|
||||
},
|
||||
},
|
||||
},
|
||||
plugins: [
|
||||
|
|
Loading…
Reference in a new issue