feat(rc_site): add tracking fields for registration and synchronization status

Author: prathameshkurunkar7

raven_cloud/api/notification.py

@@ -5,6 +5,7 @@
 import frappe
 from firebase_admin import messaging
 from frappe import _
+from frappe.utils import now_datetime
 from frappe.utils.response import Response
 
 from raven_cloud.utils.fcm import get_app
@@ -27,6 +28,16 @@ def register_site(site_name: str):
             }
         ).insert()
 
+    # update the last registered on and last registered by fields - to keep track of the last time the site was registered and by whom
+    frappe.db.set_value(
+        'RC Site',
+        site_name,
+        {
+            'last_registered_on': now_datetime(),
+            'last_registered_by': frappe.session.user,
+        }
+    )
+
     fcm_settings = frappe.get_doc('RC FCM Settings')
 
     return {
@@ -495,26 +506,34 @@ def import_user_tokens(site_name: str, tokens: str):
     Tokens for users NOT in the incoming payload are left untouched,
     making this safe to call with partial/chunked token lists.
     """
-
-    if isinstance(tokens, str):
-        tokens = json.loads(tokens)
-
-    # if no tokens are present, return
-    if not tokens:
-        return {
-            "status": "success",
-        }
-
     check_if_site_exists(site_name)
 
-    # building an incoming set for faster lookup
-    incoming_users = list({token.get("user") for token in tokens})
-    incoming_tokens = {(token.get("user"), token.get("fcm_token")) for token in tokens}
+    try:
+        if isinstance(tokens, str):
+            tokens = json.loads(tokens)
+
+        # if no tokens are present, return
+        if not tokens:
+            frappe.db.set_value(
+                "RC Site",
+                site_name,
+                {
+                    "last_synced_on": now_datetime(),
+                    "last_synced_status": "Success",
+                    "last_sync_error": None,
+                },
+                update_modified=False,
+            )
+            return {
+                "status": "success",
+            }
 
-    rc_site_user = frappe.qb.DocType("RC Site User")
-    rc_site_user_token = frappe.qb.DocType("RC Site User Token")
+        # building an incoming set for faster lookup
+        incoming_users = list({token.get("user") for token in tokens})
+        incoming_tokens = {(token.get("user"), token.get("fcm_token")) for token in tokens}
 
-    try:
+        rc_site_user = frappe.qb.DocType("RC Site User")
+        rc_site_user_token = frappe.qb.DocType("RC Site User Token")
 
         # fetching all the existing tokens on RC for this site
         existing_tokens_query = (
@@ -569,7 +588,29 @@ def import_user_tokens(site_name: str, tokens: str):
                 "user": user_map[user_id],
                 "fcm_token": fcm_token,
             }).insert()
+
+        frappe.db.set_value(
+            "RC Site",
+            site_name,
+            {
+                "last_synced_on": now_datetime(),
+                "last_synced_status": "Success",
+                "last_sync_error": None,
+                "last_synced_by": frappe.session.user,
+            },
+            update_modified=False,
+        )
     except Exception as e:
+        frappe.db.set_value(
+            "RC Site",
+            site_name,
+            {
+                "last_synced_status": "Failed",
+                "last_sync_error": str(e),
+                "last_synced_by": frappe.session.user,
+            },
+            update_modified=False,
+        )
         frappe.log_error(title=f"Error syncing user tokens for {site_name}", message=frappe.get_traceback())
         frappe.throw(_(f"Error syncing user tokens for {site_name} - {str(e)}"))
 

raven_cloud/raven_cloud/doctype/rc_site/rc_site.json

@@ -6,7 +6,15 @@
  "doctype": "DocType",
  "engine": "InnoDB",
  "field_order": [
-  "site"
+  "site",
+  "section_break_mqcc",
+  "last_registered_on",
+  "last_registered_by",
+  "column_break_brfq",
+  "last_synced_on",
+  "last_synced_by",
+  "last_synced_status",
+  "last_sync_error"
  ],
  "fields": [
   {
@@ -17,12 +25,53 @@
    "length": 300,
    "reqd": 1,
    "unique": 1
+  },
+  {
+   "fieldname": "section_break_mqcc",
+   "fieldtype": "Section Break"
+  },
+  {
+   "fieldname": "last_registered_on",
+   "fieldtype": "Datetime",
+   "label": "Last Registered On"
+  },
+  {
+   "fieldname": "last_synced_on",
+   "fieldtype": "Datetime",
+   "label": "Last Synced On"
+  },
+  {
+   "fieldname": "column_break_brfq",
+   "fieldtype": "Column Break"
+  },
+  {
+   "fieldname": "last_synced_status",
+   "fieldtype": "Select",
+   "label": "Last Synced Status",
+   "options": "\nFailed\nSuccess"
+  },
+  {
+   "fieldname": "last_sync_error",
+   "fieldtype": "Small Text",
+   "label": "Last Sync Error"
+  },
+  {
+   "fieldname": "last_registered_by",
+   "fieldtype": "Link",
+   "label": "Last Registered By",
+   "options": "User"
+  },
+  {
+   "fieldname": "last_synced_by",
+   "fieldtype": "Link",
+   "label": "Last Synced By",
+   "options": "User"
   }
  ],
  "grid_page_length": 50,
  "index_web_pages_for_search": 1,
  "links": [],
- "modified": "2025-04-29 16:08:43.664813",
+ "modified": "2026-03-30 21:03:45.519167",
  "modified_by": "Administrator",
  "module": "Raven Cloud",
  "name": "RC Site",
@@ -59,4 +108,4 @@
  "sort_field": "creation",
  "sort_order": "DESC",
  "states": []
-}
+}

raven_cloud/raven_cloud/doctype/rc_site/rc_site.py

@@ -16,6 +16,12 @@ class RCSite(Document):
 	if TYPE_CHECKING:
 		from frappe.types import DF
 
+		last_registered_by: DF.Link | None
+		last_registered_on: DF.Datetime | None
+		last_sync_error: DF.SmallText | None
+		last_synced_by: DF.Link | None
+		last_synced_on: DF.Datetime | None
+		last_synced_status: DF.Literal["", "Failed", "Success"]
 		site: DF.Data
 	# ruff: noqa
 	# end: auto-generated types