Bugfix/signal schema

src/dispatch/signal/flows.py

@@ -4,6 +4,7 @@
 from dispatch.case import service as case_service
 from dispatch.case import flows as case_flows
 from dispatch.signal import service as signal_service
+from dispatch.tag import service as tag_service
 from dispatch.signal.models import SignalInstanceCreate, RawSignal
 
 
@@ -27,6 +28,9 @@ def create_signal_instance(
         db_session=db_session, signal_instance_in=signal_instance_in
     )
 
+    # associate any known tags with the signal
+    tag = tag_service.get_by_name(db_session=db_session, project_id=project.id, name="foo")
+
     signal_instance.signal = signal
     db_session.commit()
 

src/dispatch/signal/models.py

@@ -215,14 +215,21 @@ class SignalPagination(DispatchBase):
     total: int
 
 
+class AdditionalMetadata(DispatchBase):
+    name: Optional[str]
+    value: Optional[str]
+    type: Optional[str]
+    important: Optional[bool]
+
+
 class RawSignal(DispatchBase):
     action: Optional[List[Dict]] = []
-    additional_metadata: Optional[List[Dict]] = Field([])
+    additional_metadata: Optional[List[AdditionalMetadata]] = Field([], alias="additionalMetadata")
     asset: Optional[List[Dict]] = []
     identity: Optional[Dict] = {}
-    origin_location: Optional[List[Dict]] = Field([])
+    origin_location: Optional[List[Dict]] = Field([], alias="originLocation")
     variant: Optional[str] = None
-    created_at: Optional[datetime] = Field(None)
+    created_at: Optional[datetime] = Field(None, fields="createdAt")
     id: Optional[str]
 
 

src/dispatch/signal/scheduled.py

@@ -35,7 +35,6 @@ def consume_signals(db_session: SessionLocal, project: Project):
     for plugin in plugins:
         log.debug(f"Consuming signals. Signal Consumer: {plugin.plugin.slug}")
         signal_instances = plugin.instance.consume()
-
         for signal_instance_data in signal_instances:
             try:
                 signal_flows.create_signal_instance(