last_started_at, reformat package name

Author: Peter-Sh

src/redis_release/bht/state.py

@@ -90,7 +90,6 @@ class Workflow(BaseModel):
     inputs: Dict[str, str] = Field(default_factory=dict)
     uuid: Optional[str] = None
     triggered_at: Optional[datetime] = None
-    started_at: Optional[datetime] = None
     run_id: Optional[int] = None
     url: Optional[str] = None
     timeout_minutes: int = 45
@@ -145,6 +144,7 @@ class ReleaseMeta(BaseModel):
 
     tag: Optional[str] = None
     release_type: Optional[ReleaseType] = None
+    last_started_at: Optional[datetime] = None
     ephemeral: ReleaseMetaEphemeral = Field(default_factory=ReleaseMetaEphemeral)
 
 

src/redis_release/bht/tree.py

@@ -7,6 +7,7 @@
 import logging
 import os
 from contextlib import contextmanager
+from datetime import datetime, timezone
 from typing import Any, Iterator, List, Optional, Set, Tuple, Union
 
 from py_trees.behaviour import Behaviour
@@ -118,6 +119,9 @@ def initialize_tree_and_state(
         )
         tree = BehaviourTree(root)
 
+        if not read_only:
+            state_syncer.state.meta.last_started_at = datetime.now(tz=timezone.utc)
+
         # Add snapshot visitor to track visited nodes
         snapshot_visitor = SnapshotVisitor()
         tree.visitors.append(snapshot_visitor)

src/redis_release/slack_bot.py

@@ -183,7 +183,7 @@ async def _post_status(
                 state = state_syncer.state
 
                 # Check if state exists (has any data beyond defaults)
-                if not state.packages:
+                if not state.meta.last_started_at:
                     if self.reply_in_thread:
                         await self.app.client.chat_postMessage(
                             channel=channel,

src/redis_release/state_slack.py

@@ -75,6 +75,26 @@ def __init__(self, slack_token: str, slack_channel_id: str):
         self.last_blocks_json: Optional[str] = None
         self.started_at = datetime.now(timezone.utc)
 
+    def format_package_name(self, package_name: str, state: ReleaseState) -> str:
+        """Format package name with capital letter and release type.
+
+        Args:
+            package_name: The raw package name
+            state: The ReleaseState to get release type from
+
+        Returns:
+            Formatted package name with capital letter and release type in parentheses
+        """
+        # Capitalize first letter of package name
+        formatted = package_name.capitalize()
+
+        # Add release type if available
+        if state.meta.release_type:
+            release_type_str = state.meta.release_type.value
+            formatted = f"{formatted} ({release_type_str})"
+
+        return formatted
+
     def update_message(self, state: ReleaseState) -> bool:
         """Post or update Slack message with release state.
 
@@ -148,19 +168,20 @@ def _make_blocks(self, state: ReleaseState) -> List[Dict[str, Any]]:
             }
         )
 
-        # Show started date (when SlackStatePrinter was created)
-        started_str = self.started_at.strftime("%Y-%m-%d %H:%M:%S %Z")
-        blocks.append(
-            {
-                "type": "context",
-                "elements": [
-                    {
-                        "type": "mrkdwn",
-                        "text": f"*Started:* {started_str}",
-                    }
-                ],
-            }
-        )
+        # Show started date from state.meta.last_started_at if available
+        if state.meta.last_started_at:
+            started_str = state.meta.last_started_at.strftime("%Y-%m-%d %H:%M:%S %Z")
+            blocks.append(
+                {
+                    "type": "context",
+                    "elements": [
+                        {
+                            "type": "mrkdwn",
+                            "text": f"*Started:* {started_str}",
+                        }
+                    ],
+                }
+            )
 
         # Legend with two columns
         blocks.append(
@@ -183,6 +204,9 @@ def _make_blocks(self, state: ReleaseState) -> List[Dict[str, Any]]:
 
         # Process each package
         for package_name, package in sorted(state.packages.items()):
+            # Format package name with capital letter and release type
+            formatted_name = self.format_package_name(package_name, state)
+
             # Get workflow statuses
             build_status_emoji = self._get_status_emoji(package, package.build)
             publish_status_emoji = self._get_status_emoji(package, package.publish)
@@ -193,7 +217,7 @@ def _make_blocks(self, state: ReleaseState) -> List[Dict[str, Any]]:
                     "type": "section",
                     "text": {
                         "type": "mrkdwn",
-                        "text": f"*{package_name}*\n*Build:* {build_status_emoji}   |   *Publish:* {publish_status_emoji}",
+                        "text": f"*{formatted_name}*\n*Build:* {build_status_emoji}   |   *Publish:* {publish_status_emoji}",
                     },
                 }
             )