Improvements and optimizations

akamai-guardicore-centra/config.json

@@ -0,0 +1 @@
+{ "name": "Akamai Guardicore Centra", "type": "inbound" }

akamai_guardicore_centra/centrav4.star → akamai-guardicore-centra/custom-integration-centra-v4-api.star

@@ -9,12 +9,13 @@ load('uuid', 'new_uuid')
 CENTRA_BASE_URL = 'https://<Guardicore Centra URL>'
 RUNZERO_REDIRECT = 'https://console.runzero.com/'
 
-def build_assets(assets):
+def build_assets(assets, token):
     assets_import = []
+    label_mapping = {}
     for asset in assets:
         agent_info = asset.get('agent', {})
         os_info = asset.get('os_info', {})
-        asset_id = agent_info.get('id', '')
+        asset_id = agent_info.get('id', str(new_uuid))
         hostname = asset.get('name', '')
         os = os_info.get('type', '')
         first_seen = asset.get('first_seen', '')
@@ -39,9 +40,8 @@ def build_assets(assets):
         agent_last_seen = agent_info.get('agent_last_seen', '')
         #reformat agent_last_seen timestamp for runZero parsing
         if agent_last_seen != '':
-            strip_ms = agent_last_seen.split('.')
-            split_space = strip_ms[0].split(' ')
-            agent_last_seen = parse_time(split_space[0] + 'T' + split_space[1] + 'Z')
+            split_space = agent_last_seen.split(' ')
+            agent_last_seen = parse_time(split_space[0] + 'T' + split_space[1] + 'Z').unix
         agent_version = agent_info.get('agent_version', '')
         asset_type = asset.get('asset_type', '')
         bios_uuid = asset.get('bios_uuid', '')
@@ -51,7 +51,7 @@ def build_assets(assets):
         #reformat last_seen timestamp for runZero parsing
         if last_seen != '':
             split_space = last_seen.split(' ')
-            last_seen = parse_time(split_space[0] + 'T' + split_space[1] + 'Z')
+            last_seen = parse_time(split_space[0] + 'T' + split_space[1] + 'Z').unix
         mssp_tenant = asset.get('mssp_tenant_name', '')
         orc_asset_type = orchestration_metadata.get('asset_type', '')
         orc_dev_name = orchestration_metadata.get('f5_device_hostname', '')
@@ -61,6 +61,18 @@ def build_assets(assets):
         status = asset.get('status', '')
         worksite_mod = scoping_details.get('modified', '')
         worksite_name = scoping_details.get('name', '')
+
+        labels = asset.get('labels', [])
+        label_guids = [v for item in labels for k,v in item.items() if k == 'id']
+        label_names = []
+        for guid in label_guids:
+            name = label_mapping.get(guid, None)
+            if not name:
+                new_mapping = get_labels(guid, token)
+                for k, v in new_mapping.items():
+                    label_mapping[k] = v
+                name = label_mapping.get(guid, '')
+            label_names.append(name)
 
 
         custom_attributes = {
@@ -71,6 +83,7 @@ def build_assets(assets):
             'biosUuid': bios_uuid,
             'comments': comments,
             'instanceId': instance_id,
+            'labels': label_names,
             'lastSeenTS': last_seen,
             'msspTenantName': mssp_tenant,
             'osInfo.fullKernelVersion': os_kernel,
@@ -83,10 +96,6 @@ def build_assets(assets):
             'orchestrationMetadata.vsName': orc_vs_name
         }
 
-        labels = asset.get('labels', [])
-        for item in labels:
-            for k, v in item.items():
-                custom_attributes['label.' + str(labels.index(item)) + '.' + k] = v
         label_groups = asset.get('label_groups', [])
         for group in label_groups:
             for k, v in group.items():
@@ -125,6 +134,21 @@ def build_network_interface(ips, mac):
     else:
         return NetworkInterface(macAddress=mac, ipv4Addresses=ip4s, ipv6Addresses=ip6s)
 
+def get_labels(guid, token):
+    url = CENTRA_BASE_URL + '/api/v4.0/labels/' + guid + '?'
+    headers = {'Accept': 'application/json',
+            'Authorization': 'Bearer ' + token}
+    params = {'asset_limit': 1}
+    response = http_get(url, headers=headers, params=params)
+    if response.status_code != 200:
+        print('failed to retrieve label info for  ' + guid, 'status code: ' + str(response.status_code))
+    data = json_decode(response.body)
+    label_info = data['objects']
+    label_key = label_info[0].get('key', '')
+    label_value = label_info[0].get('value', '')
+    label_mapping = { guid: label_key + ': ' + label_value }
+    return label_mapping
+
 def get_assets(token):
     assets_all = []
     results_per_page = 1000
@@ -203,7 +227,7 @@ def main(*args, **kwargs):
     assets = get_assets(token)
 
     # Format asset list for import into runZero
-    import_assets = build_assets(assets)
+    import_assets = build_assets(assets, token)
     if not import_assets:
         print('no assets')
         return None

docs/integrations.json

@@ -1,5 +1,5 @@
 {
-  "lastUpdated": "2025-11-03T16:43:06.308528Z",
+  "lastUpdated": "2025-11-10T18:36:52.667035Z",
   "totalIntegrations": 28,
   "integrationDetails": [
     {