diff --git a/src/processor/app.py b/src/processor/app.py index 6aa152c..6591f5a 100644 --- a/src/processor/app.py +++ b/src/processor/app.py @@ -11,8 +11,10 @@ _cached_token: str | None = None SLACK_BOT_TOKEN_SECRET_ARN = os.environ["SLACK_BOT_TOKEN_SECRET_ARN"] +SUBMITTED_CHANNEL = "C0AQ2AWLNEN" + STAGES = { - "C0AQ2AWLNEN": {"next": "C0APLSGABAB", "label": "Processed"}, + SUBMITTED_CHANNEL: {"next": "C0APLSGABAB", "label": "Processed"}, "C0APLSGABAB": {"next": "C0AQ09CDJH4", "label": "Authorized"}, "C0AQ09CDJH4": {"next": "C0APYUM1JFP", "label": "Matched"}, } @@ -35,6 +37,7 @@ def handler(event, context): to_channel = route["next"] label = route["label"] + is_origin = from_channel == SUBMITTED_CHANNEL token = get_bot_token() history = slack_get("conversations.history", token, { @@ -57,7 +60,7 @@ def handler(event, context): react_line = f"\n\n_React_ :white_check_mark: _to advance to {next_label}_" if next_label else "" permalink_line = ( f"\n\n📎 *Original Submission:* <{permalink}|View Original Message>" - if to_channel == "C0APLSGABAB" + if is_origin else "" ) full_text = f"{text}{permalink_line}{react_line}" @@ -70,11 +73,19 @@ def handler(event, context): "unfurl_media": False, }) - slack_post("chat.postMessage", token, { - "channel": from_channel, - "thread_ts": message_ts, - "text": f"➡️ Advanced to {label}", - }) + if is_origin: + slack_post("chat.postMessage", token, { + "channel": from_channel, + "thread_ts": message_ts, + "text": f"➡️ Advanced to {label}", + }) + print(f"Advanced user submission to {label} (origin preserved)") + else: + slack_post("chat.delete", token, { + "channel": from_channel, + "ts": message_ts, + }) + print(f"Advanced to {label} and deleted previous copy") def get_bot_token() -> str: