Compare commits
9
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3ac164ab65 | ||
|
|
4fc569f4a3 | ||
|
|
2c5821e434 | ||
|
|
cbfd6e20bc | ||
|
|
34da664af0 | ||
|
|
c6c44afb76 | ||
|
|
c2d8239911 | ||
|
|
bec6494697 | ||
|
|
29a6b000ac |
@@ -125,9 +125,6 @@ dmypy.json
|
|||||||
# Pyre type checker
|
# Pyre type checker
|
||||||
.pyre/
|
.pyre/
|
||||||
|
|
||||||
# IDE
|
|
||||||
.vscode/
|
|
||||||
|
|
||||||
# logging
|
# logging
|
||||||
nextcord.log
|
nextcord.log
|
||||||
|
|
||||||
|
|||||||
Vendored
+9
@@ -0,0 +1,9 @@
|
|||||||
|
{
|
||||||
|
"recommendations": [
|
||||||
|
"ms-python.vscode-pylance",
|
||||||
|
"ms-python.python",
|
||||||
|
"ms-python.debugpy",
|
||||||
|
"charliermarsh.ruff",
|
||||||
|
"alexcvzz.vscode-sqlite"
|
||||||
|
]
|
||||||
|
}
|
||||||
Vendored
+15
@@ -0,0 +1,15 @@
|
|||||||
|
{
|
||||||
|
// Use IntelliSense to learn about possible attributes.
|
||||||
|
// Hover to view descriptions of existing attributes.
|
||||||
|
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
|
||||||
|
"version": "0.2.0",
|
||||||
|
"configurations": [
|
||||||
|
{
|
||||||
|
"name": "Python: Module",
|
||||||
|
"type": "debugpy",
|
||||||
|
"request": "launch",
|
||||||
|
"module": "main",
|
||||||
|
"justMyCode": true
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
+16
-4
@@ -7,7 +7,7 @@ from discord import TextInputStyle
|
|||||||
from nextcord.ext import commands
|
from nextcord.ext import commands
|
||||||
|
|
||||||
from config import DakinyConfig
|
from config import DakinyConfig
|
||||||
from utils import record_event_host, record_event_participation
|
from utils import record_event_points
|
||||||
|
|
||||||
|
|
||||||
class RecordCog(commands.Cog, name="Record Commands"):
|
class RecordCog(commands.Cog, name="Record Commands"):
|
||||||
@@ -129,14 +129,26 @@ class EventView(nextcord.ui.View):
|
|||||||
discord_users_list: list[str] = [
|
discord_users_list: list[str] = [
|
||||||
str(user.id) for user in discord_users if user.id is not self.host_id
|
str(user.id) for user in discord_users if user.id is not self.host_id
|
||||||
]
|
]
|
||||||
record_event_participation(self.config, discord_users_list, True)
|
record_event_points(
|
||||||
|
self.config,
|
||||||
|
discord_users_list,
|
||||||
|
True,
|
||||||
|
self.config.params.event_participate_points,
|
||||||
|
)
|
||||||
|
|
||||||
non_discord_users = interaction.message.embeds[0].fields[1].value
|
non_discord_users = interaction.message.embeds[0].fields[1].value
|
||||||
if non_discord_users:
|
if non_discord_users:
|
||||||
non_discord_users_list: list[str] = non_discord_users.split("\n")
|
non_discord_users_list: list[str] = non_discord_users.split("\n")
|
||||||
record_event_participation(self.config, non_discord_users_list, False)
|
record_event_points(
|
||||||
|
self.config,
|
||||||
|
non_discord_users_list,
|
||||||
|
False,
|
||||||
|
self.config.params.event_participate_points,
|
||||||
|
)
|
||||||
|
|
||||||
record_event_host(self.config, self.host_id)
|
record_event_points(
|
||||||
|
self.config, [self.host_id], True, self.config.params.event_host_points
|
||||||
|
)
|
||||||
|
|
||||||
event_channel: nextcord.TextChannel = interaction.guild.get_channel(
|
event_channel: nextcord.TextChannel = interaction.guild.get_channel(
|
||||||
self.config.params.event_post_channel_id
|
self.config.params.event_post_channel_id
|
||||||
|
|||||||
@@ -21,6 +21,7 @@ class Params:
|
|||||||
event_host_points: int
|
event_host_points: int
|
||||||
event_host_role_id: int
|
event_host_role_id: int
|
||||||
event_participate_points: int
|
event_participate_points: int
|
||||||
|
event_points_weekly_limit: int
|
||||||
event_post_channel_id: int
|
event_post_channel_id: int
|
||||||
general_channel_id: int
|
general_channel_id: int
|
||||||
git_branch: str
|
git_branch: str
|
||||||
|
|||||||
@@ -52,4 +52,11 @@ CREATE TABLE ParticipationPoints (
|
|||||||
CREATE TABLE Messages (
|
CREATE TABLE Messages (
|
||||||
Path varchar(100) PRIMARY KEY,
|
Path varchar(100) PRIMARY KEY,
|
||||||
Id bigint unsigned not null
|
Id bigint unsigned not null
|
||||||
|
);
|
||||||
|
|
||||||
|
CREATE TABLE EventPointsLimit (
|
||||||
|
UserId varchar(32) not null,
|
||||||
|
Points int unsigned DEFAULT 0,
|
||||||
|
Week varchar(7) not null,
|
||||||
|
PRIMARY KEY (UserId, Week)
|
||||||
);
|
);
|
||||||
@@ -14,6 +14,7 @@ Base.prepare(autoload_with=engine)
|
|||||||
# define the classes
|
# define the classes
|
||||||
CouncilMembers = Base.classes.CouncilMembers
|
CouncilMembers = Base.classes.CouncilMembers
|
||||||
ElectionInformation = Base.classes.ElectionInformation
|
ElectionInformation = Base.classes.ElectionInformation
|
||||||
|
EventPointsLimit = Base.classes.EventPointsLimit
|
||||||
Messages = Base.classes.Messages
|
Messages = Base.classes.Messages
|
||||||
ParticipationPoints = Base.classes.ParticipationPoints
|
ParticipationPoints = Base.classes.ParticipationPoints
|
||||||
Presences = Base.classes.Presences
|
Presences = Base.classes.Presences
|
||||||
|
|||||||
@@ -20,3 +20,82 @@ sqlalchemy = "1.4.46"
|
|||||||
[build-system]
|
[build-system]
|
||||||
requires = ["poetry-core"]
|
requires = ["poetry-core"]
|
||||||
build-backend = "poetry.core.masonry.api"
|
build-backend = "poetry.core.masonry.api"
|
||||||
|
|
||||||
|
[tool.ruff]
|
||||||
|
# Exclude a variety of commonly ignored directories.
|
||||||
|
exclude = [
|
||||||
|
".bzr",
|
||||||
|
".direnv",
|
||||||
|
".eggs",
|
||||||
|
".git",
|
||||||
|
".git-rewrite",
|
||||||
|
".hg",
|
||||||
|
".ipynb_checkpoints",
|
||||||
|
".mypy_cache",
|
||||||
|
".nox",
|
||||||
|
".pants.d",
|
||||||
|
".pyenv",
|
||||||
|
".pytest_cache",
|
||||||
|
".pytype",
|
||||||
|
".ruff_cache",
|
||||||
|
".svn",
|
||||||
|
".tox",
|
||||||
|
".venv",
|
||||||
|
".vscode",
|
||||||
|
"__pypackages__",
|
||||||
|
"_build",
|
||||||
|
"buck-out",
|
||||||
|
"build",
|
||||||
|
"dist",
|
||||||
|
"node_modules",
|
||||||
|
"site-packages",
|
||||||
|
"venv",
|
||||||
|
]
|
||||||
|
|
||||||
|
# Same as Black.
|
||||||
|
line-length = 120
|
||||||
|
indent-width = 4
|
||||||
|
|
||||||
|
# Assume Python 3.8
|
||||||
|
target-version = "py38"
|
||||||
|
|
||||||
|
[tool.ruff.lint]
|
||||||
|
# Enable Pyflakes (`F`) and a subset of the pycodestyle (`E`) codes by default.
|
||||||
|
# Unlike Flake8, Ruff doesn't enable pycodestyle warnings (`W`) or
|
||||||
|
# McCabe complexity (`C901`) by default.
|
||||||
|
select = ["E4", "E7", "E9", "F", "D100", "D1"]
|
||||||
|
ignore = ["D107"]
|
||||||
|
|
||||||
|
# Allow fix for all enabled rules (when `--fix`) is provided.
|
||||||
|
fixable = ["ALL"]
|
||||||
|
unfixable = []
|
||||||
|
|
||||||
|
# Allow unused variables when underscore-prefixed.
|
||||||
|
dummy-variable-rgx = "^(_+|(_+[a-zA-Z0-9_]*[a-zA-Z0-9]+?))$"
|
||||||
|
|
||||||
|
[tool.ruff.format]
|
||||||
|
# Like Black, use double quotes for strings.
|
||||||
|
quote-style = "double"
|
||||||
|
|
||||||
|
# Like Black, indent with spaces, rather than tabs.
|
||||||
|
indent-style = "space"
|
||||||
|
|
||||||
|
# Like Black, respect magic trailing commas.
|
||||||
|
skip-magic-trailing-comma = false
|
||||||
|
|
||||||
|
# Like Black, automatically detect the appropriate line ending.
|
||||||
|
line-ending = "auto"
|
||||||
|
|
||||||
|
# Enable auto-formatting of code examples in docstrings. Markdown,
|
||||||
|
# reStructuredText code/literal blocks and doctests are all supported.
|
||||||
|
#
|
||||||
|
# This is currently disabled by default, but it is planned for this
|
||||||
|
# to be opt-out in the future.
|
||||||
|
docstring-code-format = true
|
||||||
|
|
||||||
|
# Set the line length limit used when formatting code snippets in
|
||||||
|
# docstrings.
|
||||||
|
#
|
||||||
|
# This only has an effect when the `docstring-code-format` setting is
|
||||||
|
# enabled.
|
||||||
|
docstring-code-line-length = "dynamic"
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ File contains util functions.
|
|||||||
import os
|
import os
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from enum import StrEnum
|
from enum import StrEnum
|
||||||
from typing import Iterable
|
from typing import Sequence
|
||||||
|
|
||||||
import nextcord
|
import nextcord
|
||||||
from sqlalchemy import select, true, update
|
from sqlalchemy import select, true, update
|
||||||
@@ -14,6 +14,7 @@ from sqlalchemy.orm import Session
|
|||||||
from config import DakinyConfig
|
from config import DakinyConfig
|
||||||
from database_setup.sql_data_classes import (
|
from database_setup.sql_data_classes import (
|
||||||
CouncilMembers,
|
CouncilMembers,
|
||||||
|
EventPointsLimit,
|
||||||
Messages,
|
Messages,
|
||||||
ParticipationPoints,
|
ParticipationPoints,
|
||||||
Votes,
|
Votes,
|
||||||
@@ -317,76 +318,98 @@ def decorate_dm_nomination(user_id: int, speech: str) -> str:
|
|||||||
return msg
|
return msg
|
||||||
|
|
||||||
|
|
||||||
def record_event_participation(config: DakinyConfig, users: list[str], is_member: bool):
|
def record_event_points(
|
||||||
|
config: DakinyConfig, users: Sequence[str], is_member: bool, add_points: int
|
||||||
|
):
|
||||||
"""
|
"""
|
||||||
Adds participation points to all users listed. Checks if they don't exist in order to make a new entry, otherwise
|
Adds event points to all users listed. Checks if they don't exist in order to make a new entry, otherwise
|
||||||
adds points to the existing value.
|
adds points to the existing value. Can be used for hosting or participating.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
config (DakinyConfig): Dakiny config for getting points
|
config (DakinyConfig): Dakiny config for getting points
|
||||||
users (list[int]): users that participated and need points.
|
users (Sequence[int]): users that participated and need points.
|
||||||
is_member (bool): whether the users are a discord member or not
|
is_member (bool): whether the users are a discord member or not
|
||||||
|
points (int): number of points to add
|
||||||
"""
|
"""
|
||||||
|
|
||||||
cycle = get_quarter_name(config)
|
quarter_name = get_quarter_name(config)
|
||||||
participation_point_value = config.params.event_participate_points
|
|
||||||
with Session(engine) as session:
|
with Session(engine) as session:
|
||||||
for user in users:
|
for user in users:
|
||||||
stmt = (
|
stmt = (
|
||||||
select(ParticipationPoints)
|
select(ParticipationPoints)
|
||||||
.where(ParticipationPoints.UserId == user)
|
.where(ParticipationPoints.UserId == user)
|
||||||
.where(ParticipationPoints.Cycle == cycle)
|
.where(ParticipationPoints.Cycle == quarter_name)
|
||||||
)
|
)
|
||||||
|
|
||||||
points = session.scalar(stmt)
|
points = session.scalar(stmt)
|
||||||
if points is None:
|
if points is None:
|
||||||
|
add_points = get_allowed_points(
|
||||||
|
session, config.params.event_points_weekly_limit, user, add_points
|
||||||
|
)
|
||||||
new_points = ParticipationPoints(
|
new_points = ParticipationPoints(
|
||||||
Cycle=cycle,
|
Cycle=quarter_name,
|
||||||
UserId=user,
|
UserId=user,
|
||||||
DiscordMember=is_member,
|
DiscordMember=is_member,
|
||||||
Points=participation_point_value,
|
Points=add_points,
|
||||||
)
|
)
|
||||||
session.add(new_points)
|
session.add(new_points)
|
||||||
else:
|
else:
|
||||||
points.Points += participation_point_value
|
add_points = get_allowed_points(
|
||||||
|
session, config.params.event_points_weekly_limit, user, add_points
|
||||||
|
)
|
||||||
|
points.Points += add_points
|
||||||
|
|
||||||
session.commit()
|
session.commit()
|
||||||
|
|
||||||
|
|
||||||
def record_event_host(config: DakinyConfig, user: int):
|
def get_allowed_points(
|
||||||
|
session: Session, points_limit: int, user: str, points: int
|
||||||
|
) -> int:
|
||||||
"""
|
"""
|
||||||
Adds host points to the given user. Checks if they don't exist in order to make a new entry, otherwise adds points
|
Gets the maximum number of points a user can be given. Searches how many points they have been given
|
||||||
to the existing value.
|
this week and subtracts that from the weekly limit. If under, returns up to "points" number of points (will not
|
||||||
|
go over points_limit) otherwise returns 0. Updates the limit object or creates a new one if one isn't found.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
config (DakinyConfig): Dakiny config for getting points
|
session (Session): Open connection to database.
|
||||||
user (int): Id of user that hosted.
|
points_limit (int): Maximum number of points a user can be given in a week.
|
||||||
|
user (str): user to be given points. Used to check a user's limit.
|
||||||
|
points (int): maximum number of points to give to user.
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
int: how many points are allowed to be given to the user.
|
||||||
"""
|
"""
|
||||||
cycle = get_quarter_name(config)
|
# check for limit
|
||||||
host_point_value = config.params.event_host_points
|
this_week = (
|
||||||
with Session(engine) as session:
|
f"{datetime.today().isocalendar().year}-{datetime.today().isocalendar().week}"
|
||||||
stmt = (
|
)
|
||||||
select(ParticipationPoints)
|
stmt = (
|
||||||
.where(ParticipationPoints.UserId == str(user))
|
select(EventPointsLimit)
|
||||||
.where(ParticipationPoints.Cycle == cycle)
|
.where(EventPointsLimit.UserId == user)
|
||||||
|
.where(EventPointsLimit.Week == this_week)
|
||||||
|
)
|
||||||
|
|
||||||
|
# if under limit, can add up to however many points would make the current limit equal to the
|
||||||
|
# allowed limit.
|
||||||
|
limit = session.scalar(stmt)
|
||||||
|
if limit is None:
|
||||||
|
new_limit = EventPointsLimit(UserId=user, Points=points, Week=this_week)
|
||||||
|
add_points = points
|
||||||
|
session.add(new_limit)
|
||||||
|
else:
|
||||||
|
add_points = (
|
||||||
|
points
|
||||||
|
if limit.Points + points <= points_limit
|
||||||
|
else (points_limit - limit.Points if points_limit - limit.Points > 0 else 0)
|
||||||
)
|
)
|
||||||
|
limit.Points += add_points
|
||||||
|
|
||||||
points = session.scalar(stmt)
|
session.commit()
|
||||||
if points is None:
|
|
||||||
new_points = ParticipationPoints(
|
|
||||||
Cycle=cycle,
|
|
||||||
UserId=str(user),
|
|
||||||
DiscordMember=True,
|
|
||||||
Points=host_point_value,
|
|
||||||
)
|
|
||||||
session.add(new_points)
|
|
||||||
else:
|
|
||||||
points.Points += host_point_value
|
|
||||||
|
|
||||||
session.commit()
|
return add_points
|
||||||
|
|
||||||
|
|
||||||
async def update_clan_messages(guild: nextcord.Guild, channel_updates: Iterable[str]):
|
async def update_clan_messages(guild: nextcord.Guild, channel_updates: Sequence[str]):
|
||||||
"""
|
"""
|
||||||
Updates all clan messages to contents in MESSAGES_DIR.
|
Updates all clan messages to contents in MESSAGES_DIR.
|
||||||
Does not to any git work. Is expected to be called after git is pulled.
|
Does not to any git work. Is expected to be called after git is pulled.
|
||||||
@@ -398,6 +421,7 @@ async def update_clan_messages(guild: nextcord.Guild, channel_updates: Iterable[
|
|||||||
|
|
||||||
Args:
|
Args:
|
||||||
guild (nextcord.Guild): Guild object that all channels and messages belong to.
|
guild (nextcord.Guild): Guild object that all channels and messages belong to.
|
||||||
|
channel_updates: (Sequence[str]): a sequence of the channels to update.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
dirs = [
|
dirs = [
|
||||||
|
|||||||
Reference in New Issue
Block a user