mirror of
https://github.com/Sea-Haven-Industries/afterhours-shift-manager.git
synced 2026-09-30 11:23:12 +00:00
Compare commits
No commits in common. "main" and "v1.18.0" have entirely different histories.
19 changed files with 24 additions and 134 deletions
6
.github/workflows/ci.yaml
vendored
6
.github/workflows/ci.yaml
vendored
|
|
@ -13,7 +13,7 @@ permissions:
|
|||
jobs:
|
||||
autofix:
|
||||
if: github.event_name == 'pull_request' && !github.event.pull_request.head.repo.fork
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/ci-autofix.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/ci-autofix.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16
|
||||
permissions:
|
||||
contents: write
|
||||
secrets: inherit
|
||||
|
|
@ -24,7 +24,7 @@ jobs:
|
|||
lint:
|
||||
needs: autofix
|
||||
if: always() && !cancelled() && (needs.autofix.result == 'skipped' || needs.autofix.outputs.committed != 'true')
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/ci-python-app.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/ci-python-app.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16
|
||||
with:
|
||||
python-version: "3.12"
|
||||
|
||||
|
|
@ -59,7 +59,7 @@ jobs:
|
|||
terraform:
|
||||
needs: autofix
|
||||
if: always() && !cancelled() && (needs.autofix.result == 'skipped' || needs.autofix.outputs.committed != 'true')
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/ci-terraform.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/ci-terraform.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16
|
||||
with:
|
||||
terraform-version: "1.16.0"
|
||||
|
||||
|
|
|
|||
2
.github/workflows/dependency-review.yml
vendored
2
.github/workflows/dependency-review.yml
vendored
|
|
@ -7,4 +7,4 @@ permissions:
|
|||
|
||||
jobs:
|
||||
review:
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/callable-dependency-review.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/callable-dependency-review.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16
|
||||
|
|
|
|||
4
.github/workflows/deploy-api.yaml
vendored
4
.github/workflows/deploy-api.yaml
vendored
|
|
@ -43,7 +43,7 @@ jobs:
|
|||
deploy-dev:
|
||||
name: Deploy API to dev
|
||||
if: github.event_name == 'push' || (github.event_name == 'workflow_dispatch' && inputs.environment == 'dev')
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/cd-hcp-fargate.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/cd-hcp-fargate.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16
|
||||
permissions:
|
||||
contents: read
|
||||
id-token: write
|
||||
|
|
@ -57,7 +57,7 @@ jobs:
|
|||
deploy-prod:
|
||||
name: Deploy API to prod
|
||||
if: github.event_name == 'release' || (github.event_name == 'workflow_dispatch' && inputs.environment == 'prod')
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/cd-hcp-fargate.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/cd-hcp-fargate.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16
|
||||
permissions:
|
||||
contents: read
|
||||
id-token: write
|
||||
|
|
|
|||
2
.github/workflows/labeler.yml
vendored
2
.github/workflows/labeler.yml
vendored
|
|
@ -10,4 +10,4 @@ permissions:
|
|||
|
||||
jobs:
|
||||
label:
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/callable-labeler.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19
|
||||
uses: Sea-Haven-Industries/.github/.github/workflows/callable-labeler.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16
|
||||
|
|
|
|||
|
|
@ -12,6 +12,10 @@ Use one of: `feature/`, `fix/`, `hotfix/`, `chore/`, `docs/`, `refactor/`, `rele
|
|||
- **Body sections** (exactly, in order): `Summary`, `Validation`, `Tests`, `Notes`. Use "None." under Notes when empty.
|
||||
- State verifiable facts only. Do not justify changes by citing the handbook. No AI-attribution footers.
|
||||
|
||||
## Security and Cross-Review
|
||||
- Sensitive surfaces (payment flows, authentication, secrets handling, untrusted input) require security review.
|
||||
- IAM role, policy, or resource-permission changes require cross-family review. Lambda handler signature changes alone do not.
|
||||
|
||||
## CI and Workflow References
|
||||
- CI must pass before merge.
|
||||
- Org-level reusable workflow refs must be pinned to a full commit SHA with a `# vX.Y.Z` comment.
|
||||
|
|
|
|||
8
package-lock.json
generated
8
package-lock.json
generated
|
|
@ -8,13 +8,13 @@
|
|||
"name": "afterhours-shift-manager",
|
||||
"version": "1.0.0",
|
||||
"devDependencies": {
|
||||
"@redocly/cli": "2.54.2"
|
||||
"@redocly/cli": "2.53.3"
|
||||
}
|
||||
},
|
||||
"node_modules/@redocly/cli": {
|
||||
"version": "2.54.2",
|
||||
"resolved": "https://registry.npmjs.org/@redocly/cli/-/cli-2.54.2.tgz",
|
||||
"integrity": "sha512-YQ53kSQV/zpYSdY3WiQvf7JxuVLD8jTEX37YOY6MS+G3tyHDCeONpUkAt6qr9n2/nmGm6m+A+PB/mGFvhkt1uQ==",
|
||||
"version": "2.53.3",
|
||||
"resolved": "https://registry.npmjs.org/@redocly/cli/-/cli-2.53.3.tgz",
|
||||
"integrity": "sha512-hzNAWzHCOZ05vwRx0ehTxNeJaxxizjGV505eKtfs9MR/8ieD/8lYhAK4GF5FaqRRwOEpLO0PvzQwBSKYXmxhRA==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"bin": {
|
||||
|
|
|
|||
|
|
@ -6,6 +6,6 @@
|
|||
"openapi:lint": "redocly lint --config .redocly.yaml openapi.yaml"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@redocly/cli": "2.54.2"
|
||||
"@redocly/cli": "2.53.3"
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -38,10 +38,6 @@ def _deactivate(schedule: ShiftSchedule, date: str) -> dict:
|
|||
|
||||
|
||||
def handler(event, context):
|
||||
if os.environ.get("STAGE", "prod") != "prod":
|
||||
logger.info("Skipping holiday router because STAGE is not prod")
|
||||
return {"skipped": "non_prod"}
|
||||
|
||||
action = event.get("action")
|
||||
date = event.get("date")
|
||||
logger.info("Holiday router invoked: action=%s date=%s", action, date)
|
||||
|
|
|
|||
|
|
@ -27,10 +27,6 @@ EASTERN = ZoneInfo("America/New_York")
|
|||
|
||||
|
||||
def handler(event, context):
|
||||
if os.environ.get("STAGE", "prod") != "prod":
|
||||
logger.info("Skipping 3CX queue scheduler because STAGE is not prod")
|
||||
return {"skipped": "non_prod"}
|
||||
|
||||
now = datetime.now(EASTERN)
|
||||
current_hour = now.hour
|
||||
day_name = now.strftime("%A")
|
||||
|
|
|
|||
|
|
@ -24,10 +24,6 @@ EXCLUDE_NAMES = {"Voicemail", "IVR", "Fax"}
|
|||
|
||||
|
||||
def handler(event, context):
|
||||
if os.environ.get("STAGE", "prod") != "prod":
|
||||
logger.info("Skipping roster sync because STAGE is not prod")
|
||||
return {"skipped": "non_prod"}
|
||||
|
||||
now = datetime.now(EASTERN)
|
||||
|
||||
# DST guard — two EventBridge rules fire, only one is at 6am ET
|
||||
|
|
|
|||
|
|
@ -67,8 +67,6 @@ def create_app() -> Flask:
|
|||
|
||||
@app.route("/slack/events", methods=["POST"])
|
||||
def slack_events():
|
||||
if os.environ.get("STAGE", "prod") != "prod":
|
||||
return jsonify({"error": "slack_disabled"}), 404
|
||||
return _get_slack_handler().handle(request)
|
||||
|
||||
@app.route("/api/shifts", methods=["GET", "POST", "DELETE", "OPTIONS"])
|
||||
|
|
|
|||
|
|
@ -1,14 +0,0 @@
|
|||
"""External side effects. Only production may call Slack or 3CX.
|
||||
|
||||
A missing STAGE is treated as prod so a task that lost its environment
|
||||
variable does not silently drop production notifications. Dev and any
|
||||
other named stage skip Slack and 3CX entirely.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import os
|
||||
|
||||
|
||||
def prod_side_effects_enabled() -> bool:
|
||||
return os.environ.get("STAGE", "prod") == "prod"
|
||||
|
|
@ -5,7 +5,6 @@ from __future__ import annotations
|
|||
import logging
|
||||
import os
|
||||
|
||||
from shared.effects import prod_side_effects_enabled
|
||||
from shared.schedule import FALLBACK_EXTENSION, ShiftSchedule
|
||||
from shared.secrets import get_secret
|
||||
from shared.three_cx_client import ThreeCXClient, oauth_client
|
||||
|
|
@ -29,9 +28,6 @@ def holiday_extensions(holiday: dict) -> list[str]:
|
|||
|
||||
|
||||
def activate(schedule: ShiftSchedule, date: str, client_factory=None) -> dict:
|
||||
if not prod_side_effects_enabled():
|
||||
logger.info("Skipping holiday activate because STAGE is not prod")
|
||||
return {"action": "activate", "date": date, "skipped": "non_prod"}
|
||||
holiday = schedule.get_holiday(date)
|
||||
if holiday is None:
|
||||
logger.info("No holiday record for %s — nothing to activate", date)
|
||||
|
|
@ -81,9 +77,6 @@ def activate(schedule: ShiftSchedule, date: str, client_factory=None) -> dict:
|
|||
|
||||
|
||||
def deactivate(schedule: ShiftSchedule, date: str, client_factory=None) -> dict:
|
||||
if not prod_side_effects_enabled():
|
||||
logger.info("Skipping holiday deactivate because STAGE is not prod")
|
||||
return {"action": "deactivate", "date": date, "skipped": "non_prod"}
|
||||
holiday = schedule.get_holiday(date)
|
||||
if holiday is None:
|
||||
logger.info("No holiday record for %s — nothing to deactivate", date)
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ from shared.blocks import (
|
|||
build_swap_request_blocks,
|
||||
build_week_schedule,
|
||||
)
|
||||
from shared.effects import prod_side_effects_enabled
|
||||
from shared.ring_scheduler import update_queue_routing
|
||||
from shared.schedule import FALLBACK_EXTENSION, week_start
|
||||
from shared.secrets import get_secret
|
||||
|
|
@ -32,8 +31,6 @@ SLACK_API = "https://slack.com/api"
|
|||
|
||||
|
||||
def slack_token() -> str | None:
|
||||
if not prod_side_effects_enabled():
|
||||
return None
|
||||
secret_id = os.environ.get("SLACK_BOT_TOKEN_SECRET")
|
||||
if not secret_id:
|
||||
return None
|
||||
|
|
@ -45,9 +42,6 @@ def slack_token() -> str | None:
|
|||
|
||||
|
||||
def slack_call(method: str, token: str, **payload) -> bool:
|
||||
if not prod_side_effects_enabled():
|
||||
logger.info("Skipping Slack %s because STAGE is not prod", method)
|
||||
return False
|
||||
try:
|
||||
response = requests.post(
|
||||
f"{SLACK_API}/{method}",
|
||||
|
|
@ -69,9 +63,6 @@ def slack_call(method: str, token: str, **payload) -> bool:
|
|||
|
||||
|
||||
def update_3cx_routing(extension: str) -> None:
|
||||
if not prod_side_effects_enabled():
|
||||
logger.info("Skipping 3CX routing because STAGE is not prod")
|
||||
return
|
||||
queue_number = os.environ.get("QUEUE_NUMBER")
|
||||
secret_prefix = os.environ.get("TCX_SECRET_PREFIX")
|
||||
if not queue_number or not secret_prefix:
|
||||
|
|
@ -98,8 +89,6 @@ def maybe_repoint_today(date_str: str, shift_type: str, extension: str) -> bool:
|
|||
|
||||
def make_3cx_client() -> ThreeCXClient | None:
|
||||
"""Return the process OAuth client, refreshing it when the token or secret changed."""
|
||||
if not prod_side_effects_enabled():
|
||||
return None
|
||||
secret_prefix = os.environ.get("TCX_SECRET_PREFIX")
|
||||
if not secret_prefix:
|
||||
logger.warning("3CX env vars not set — skipping 3CX call")
|
||||
|
|
|
|||
|
|
@ -289,10 +289,6 @@ def _send_checkcomponents(pay_record: dict) -> bool:
|
|||
|
||||
|
||||
def handler(event, context):
|
||||
if os.environ.get("STAGE", "prod") != "prod":
|
||||
logger.info("Skipping weekly post because STAGE is not prod")
|
||||
return {"skipped": "non_prod"}
|
||||
|
||||
now = datetime.now(EASTERN)
|
||||
|
||||
# DST guard — same pattern as the 3CX scheduler
|
||||
|
|
|
|||
|
|
@ -10,16 +10,6 @@ check "correct_account" {
|
|||
}
|
||||
}
|
||||
|
||||
check "dev_has_no_external_side_effects" {
|
||||
assert {
|
||||
condition = local.is_prod || alltrue([
|
||||
for name in ["SHIFT_CHANNEL", "QUEUE_NUMBER", "PAY_REPORT_USER", "TCX_SECRET_PREFIX"] :
|
||||
one([for env in local.api_environment : env.value if env.name == name]) == ""
|
||||
])
|
||||
error_message = "Non-prod must leave SHIFT_CHANNEL, QUEUE_NUMBER, PAY_REPORT_USER, and TCX_SECRET_PREFIX empty so the task cannot post to Slack or move the production phone queue."
|
||||
}
|
||||
}
|
||||
|
||||
check "dev_has_no_paychex" {
|
||||
assert {
|
||||
condition = local.is_prod || var.checkcomponents_queue_url == ""
|
||||
|
|
|
|||
|
|
@ -182,9 +182,9 @@ locals {
|
|||
{ name = "SHIFT_TABLE", value = aws_dynamodb_table.shifts.name },
|
||||
{ name = "SLACK_BOT_TOKEN_SECRET", value = "afterhours-shift-manager/slack-bot-token" },
|
||||
{ name = "SLACK_SIGNING_SECRET", value = "afterhours-shift-manager/slack-signing-secret" },
|
||||
{ name = "SHIFT_CHANNEL", value = local.is_prod ? var.shift_channel : "" },
|
||||
{ name = "TCX_SECRET_PREFIX", value = local.is_prod ? "afterhours-shift-manager/3cx-" : "" },
|
||||
{ name = "QUEUE_NUMBER", value = local.is_prod ? var.queue_number : "" },
|
||||
{ name = "SHIFT_CHANNEL", value = var.shift_channel },
|
||||
{ name = "TCX_SECRET_PREFIX", value = "afterhours-shift-manager/3cx-" },
|
||||
{ name = "QUEUE_NUMBER", value = var.queue_number },
|
||||
{ name = "TZ", value = var.timezone },
|
||||
{ name = "HOLIDAY_SCHEDULER_ROLE_ARN", value = local.holiday_scheduler_role_arn },
|
||||
{ name = "HOLIDAY_SCHEDULE_GROUP", value = "default" },
|
||||
|
|
@ -195,7 +195,7 @@ locals {
|
|||
var.portal_cognito_issuer != "" && var.portal_cognito_audience != "" ? [{ issuer = var.portal_cognito_issuer, audience = var.portal_cognito_audience }] : [],
|
||||
var.portal_cognito_extra_trust,
|
||||
)) },
|
||||
{ name = "PAY_REPORT_USER", value = local.is_prod ? var.pay_report_user : "" },
|
||||
{ name = "PAY_REPORT_USER", value = var.pay_report_user },
|
||||
{ name = "CHECKCOMPONENTS_QUEUE_URL", value = var.checkcomponents_queue_url },
|
||||
{ name = "ROSTER_API_TOKEN_SECRET", value = "afterhours-shift-manager/roster-api-token" },
|
||||
{ name = "SYNC_GROUP", value = "DEFAULT" },
|
||||
|
|
|
|||
|
|
@ -101,7 +101,7 @@ def test_ecs_task_boundary_uses_static_arns():
|
|||
|
||||
def test_deploy_api_workflow_exists():
|
||||
deploy_api = (ROOT / ".github" / "workflows" / "deploy-api.yaml").read_text()
|
||||
pin = "cd-hcp-fargate.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19"
|
||||
pin = "cd-hcp-fargate.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16"
|
||||
assert deploy_api.count(pin) == 2
|
||||
assert "ssm-prefix: /afterhours-shift-manager/deploy" in deploy_api
|
||||
assert "docker-platform: linux/arm64" in deploy_api
|
||||
|
|
@ -119,9 +119,9 @@ def test_in_repo_hcptf_roles():
|
|||
|
||||
def test_ci_runs_pytest_and_terraform_validate():
|
||||
assert "ci-python-sam" not in CI
|
||||
assert "ci-python-app.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19" in CI
|
||||
assert "ci-terraform.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19" in CI
|
||||
assert "ci-autofix.yaml@0a1010e63248c9ca9f042c870eb2c579ba6b9455 # v1.0.19" in CI
|
||||
assert "ci-python-app.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16" in CI
|
||||
assert "ci-terraform.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16" in CI
|
||||
assert "ci-autofix.yaml@2e2b3a282fbd148352a2b7433b58668a47e6bfeb # v1.0.16" in CI
|
||||
assert "name: ci-complete" in CI
|
||||
assert "pytest" in CI
|
||||
assert "terraform fmt -check" not in CI
|
||||
|
|
|
|||
|
|
@ -1,54 +0,0 @@
|
|||
"""Non-prod must not call Slack or 3CX."""
|
||||
|
||||
from unittest.mock import MagicMock
|
||||
|
||||
from shared.effects import prod_side_effects_enabled
|
||||
from shared.holiday_flow import activate
|
||||
from shared.side_effects import slack_call, slack_token, update_3cx_routing
|
||||
|
||||
|
||||
def test_missing_stage_keeps_prod_effects(monkeypatch):
|
||||
monkeypatch.delenv("STAGE", raising=False)
|
||||
assert prod_side_effects_enabled() is True
|
||||
|
||||
|
||||
def test_dev_stage_disables_effects(monkeypatch):
|
||||
monkeypatch.setenv("STAGE", "dev")
|
||||
assert prod_side_effects_enabled() is False
|
||||
|
||||
|
||||
def test_dev_slack_token_does_not_read_secrets(monkeypatch):
|
||||
monkeypatch.setenv("STAGE", "dev")
|
||||
monkeypatch.setenv(
|
||||
"SLACK_BOT_TOKEN_SECRET", "afterhours-shift-manager/slack-bot-token"
|
||||
)
|
||||
read = MagicMock(side_effect=AssertionError("secret read"))
|
||||
monkeypatch.setattr("shared.side_effects.get_secret", read)
|
||||
assert slack_token() is None
|
||||
read.assert_not_called()
|
||||
|
||||
|
||||
def test_dev_slack_call_does_not_post(monkeypatch):
|
||||
monkeypatch.setenv("STAGE", "dev")
|
||||
post = MagicMock(side_effect=AssertionError("slack post"))
|
||||
monkeypatch.setattr("shared.side_effects.requests.post", post)
|
||||
assert slack_call("chat.postMessage", "xoxb-token", channel="C0APATP612N") is False
|
||||
post.assert_not_called()
|
||||
|
||||
|
||||
def test_dev_skips_3cx_even_when_queue_is_configured(monkeypatch):
|
||||
monkeypatch.setenv("STAGE", "dev")
|
||||
monkeypatch.setenv("QUEUE_NUMBER", "801")
|
||||
monkeypatch.setenv("TCX_SECRET_PREFIX", "afterhours-shift-manager/3cx-")
|
||||
route = MagicMock(side_effect=AssertionError("3cx"))
|
||||
monkeypatch.setattr("shared.side_effects.update_queue_routing", route)
|
||||
update_3cx_routing("101")
|
||||
route.assert_not_called()
|
||||
|
||||
|
||||
def test_dev_holiday_activate_does_not_build_a_client(monkeypatch):
|
||||
monkeypatch.setenv("STAGE", "dev")
|
||||
factory = MagicMock(side_effect=AssertionError("3cx client"))
|
||||
result = activate(MagicMock(), "2026-07-04", client_factory=factory)
|
||||
assert result["skipped"] == "non_prod"
|
||||
factory.assert_not_called()
|
||||
Loading…
Add table
Reference in a new issue