Add collections/groups and update LinkedIn import

Read queue: query DISTINCT collection and group values and include them in the response (collections, groups). Rename response keys for clarity (queued -> in_queue, most_recent -> example and return only the first example).

Import LinkedIn CSV: normalize CSV-to-DB mapping (url -> linkedin, email_address -> email), update batch tuple order and INSERT column list to match the renamed columns.

Delete rename.py: remove the /queue/alter/rename_column route (runtime column rename endpoint) for safety. These changes expose more queue metadata for the UI and standardize field names used by the LinkedIn importer.

Author: goldlabelapps

app/api/queue/routes/get.py

@@ -33,14 +33,22 @@ def read_queue() -> dict:
         rows = cursor.fetchall()
         most_recent = [dict(zip(columns, row)) for row in rows] if rows and columns else []
 
+        # 4. Get unique values from collection and group columns
+        cursor.execute("SELECT DISTINCT collection FROM queue WHERE collection IS NOT NULL;")
+        collections = [row[0] for row in cursor.fetchall()]
+        cursor.execute('SELECT DISTINCT "group" FROM queue WHERE "group" IS NOT NULL;')
+        groups = [row[0] for row in cursor.fetchall()]
+
         conn.close()
 
         return {
             "meta": make_meta("success", "Queue table info"),
             "data": {
-                "queued": record_count,
-                "most_recent": most_recent,
-                # "schema": schema
+                "in_queue": record_count,
+                "collections": collections,
+                "groups": groups,
+                "example": most_recent[:1],
+                # "queue_schema": schema
             }
         }
     except Exception as e:

app/api/queue/routes/import_linkedin.py

@@ -47,30 +47,30 @@ def import_linkedin_csv() -> dict:
                     first_row = row.copy()
                     print("DEBUG: First parsed row from CSV:", first_row)
                 batch.append([
-                    row.get('First Name'),
-                    row.get('Last Name'),
-                    row.get('URL'),
-                    row.get('Email Address'),
-                    row.get('Company'),
-                    row.get('Position'),
-                    row.get('Connected On'),
-                    now,
-                    now,
-                    False,
-                    'prospects',
-                    'linkedin'
+                    row.get('First Name'),                # first_name
+                    row.get('Last Name'),                 # last_name
+                    row.get('URL'),                       # linkedin
+                    row.get('Email Address'),             # email
+                    row.get('Company'),                   # company
+                    row.get('Position'),                  # position
+                    row.get('Connected On'),              # connected_on
+                    now,                                  # created
+                    now,                                  # updated
+                    False,                                # hidden
+                    'prospects',                          # collection
+                    'linkedin'                            # group
                 ])
                 imported_count += 1
                 if len(batch) >= batch_size:
                     cursor.executemany(
-                        '''INSERT INTO queue (first_name, last_name, url, email_address, company, position, connected_on, created, updated, hidden, collection, "group")
+                        '''INSERT INTO queue (first_name, last_name, linkedin, email, company, position, connected_on, created, updated, hidden, collection, "group")
                         VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)''',
                         batch
                     )
                     batch = []
             if batch:
                 cursor.executemany(
-                    '''INSERT INTO queue (first_name, last_name, url, email_address, company, position, connected_on, created, updated, hidden, collection, "group")
+                    '''INSERT INTO queue (first_name, last_name, linkedin, email, company, position, connected_on, created, updated, hidden, collection, "group")
                     VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)''',
                     batch
                 )