Remove override values

Author: TarikGul

backend/src/db/schema.ts

@@ -108,7 +108,6 @@ export const queuePriorityConfigs = sqliteTable('queue_priority_configs', {
   id: integer('id').primaryKey({ autoIncrement: true }),
   queueType: text('queue_type').notNull().unique(), // 'ump' or 'dmp'
   priorityType: text('priority_type').notNull(), // 'Config', 'OverrideConfig', or 'Disabled'
-  overrideValues: text('override_values'), // JSON stringified [threshold, drop_threshold] for OverrideConfig, null otherwise
   lastUpdated: integer('last_updated', { mode: 'timestamp' })
     .notNull()
     .$defaultFn(() => new Date()),

backend/src/services/BlockProcessor.ts

@@ -1031,42 +1031,51 @@ export class BlockProcessor {
   ): Promise<void> {
     try {
       const priorityType = queuePriority.type;
-      const overrideValues = priorityType === 'OverrideConfig'
-        ? JSON.stringify(queuePriority.value)
-        : null;
 
-      // Upsert to database
       const existing = await db.query.queuePriorityConfigs.findFirst({
         where: eq(queuePriorityConfigs.queueType, 'ump'),
       });
 
-      if (existing) {
+      // Only update if this is the first time, or if the priority type has actually changed
+      if (!existing) {
+        // First time - insert new record
+        await db.insert(queuePriorityConfigs).values({
+          queueType: 'ump',
+          priorityType,
+          lastUpdated: new Date(item.timestamp!),
+        });
+
+        eventService.emit('umpQueuePriority', {
+          type: priorityType,
+          timestamp: new Date(item.timestamp!).toISOString(),
+        });
+
+        Log.service({
+          service: 'UMP Queue Priority',
+          action: 'UMP queue priority config initialized',
+          details: { type: priorityType },
+        });
+      } else if (existing.priorityType !== priorityType) {
+        // Priority type has changed - update existing record
         await db.update(queuePriorityConfigs)
           .set({
             priorityType,
-            overrideValues,
             lastUpdated: new Date(item.timestamp!),
           })
           .where(eq(queuePriorityConfigs.queueType, 'ump'));
-      } else {
-        await db.insert(queuePriorityConfigs).values({
-          queueType: 'ump',
-          priorityType,
-          overrideValues,
-          lastUpdated: new Date(item.timestamp!),
-        });
-      }
 
-      eventService.emit('umpQueuePriority', {
-        type: priorityType,
-        timestamp: new Date(item.timestamp!).toISOString(),
-      });
+        eventService.emit('umpQueuePriority', {
+          type: priorityType,
+          timestamp: new Date(item.timestamp!).toISOString(),
+        });
 
-      Log.service({
-        service: 'UMP Queue Priority',
-        action: 'UMP queue priority config retrieved',
-        details: { type: priorityType },
-      });
+        Log.service({
+          service: 'UMP Queue Priority',
+          action: 'UMP queue priority config changed',
+          details: { type: priorityType },
+        });
+      }
+      // else: priority type hasn't changed, do nothing
     } catch (error) {
       Log.service({
         service: 'UMP Queue Priority',
@@ -1082,42 +1091,51 @@ export class BlockProcessor {
   ): Promise<void> {
     try {
       const priorityType = queuePriority.type;
-      const overrideValues = priorityType === 'OverrideConfig'
-        ? JSON.stringify(queuePriority.value)
-        : null;
 
-      // Upsert to database
       const existing = await db.query.queuePriorityConfigs.findFirst({
         where: eq(queuePriorityConfigs.queueType, 'dmp'),
       });
 
-      if (existing) {
+      // Only update if this is the first time, or if the priority type has actually changed
+      if (!existing) {
+        // First time - insert new record
+        await db.insert(queuePriorityConfigs).values({
+          queueType: 'dmp',
+          priorityType,
+          lastUpdated: new Date(item.timestamp!),
+        });
+
+        eventService.emit('dmpQueuePriority', {
+          type: priorityType,
+          timestamp: new Date(item.timestamp!).toISOString(),
+        });
+
+        Log.service({
+          service: 'DMP Queue Priority',
+          action: 'DMP queue priority config initialized',
+          details: { type: priorityType },
+        });
+      } else if (existing.priorityType !== priorityType) {
+        // Priority type has changed - update existing record
         await db.update(queuePriorityConfigs)
           .set({
             priorityType,
-            overrideValues,
             lastUpdated: new Date(item.timestamp!),
           })
           .where(eq(queuePriorityConfigs.queueType, 'dmp'));
-      } else {
-        await db.insert(queuePriorityConfigs).values({
-          queueType: 'dmp',
-          priorityType,
-          overrideValues,
-          lastUpdated: new Date(item.timestamp!),
-        });
-      }
 
-      eventService.emit('dmpQueuePriority', {
-        type: priorityType,
-        timestamp: new Date(item.timestamp!).toISOString(),
-      });
+        eventService.emit('dmpQueuePriority', {
+          type: priorityType,
+          timestamp: new Date(item.timestamp!).toISOString(),
+        });
 
-      Log.service({
-        service: 'DMP Queue Priority',
-        action: 'DMP queue priority config retrieved',
-        details: { type: priorityType },
-      });
+        Log.service({
+          service: 'DMP Queue Priority',
+          action: 'DMP queue priority config changed',
+          details: { type: priorityType },
+        });
+      }
+      // else: priority type hasn't changed, do nothing
     } catch (error) {
       Log.service({
         service: 'DMP Queue Priority',