Skip to content
This repository was archived by the owner on Dec 5, 2025. It is now read-only.

Commit 18acbef

Browse files
committed
[client] Fix get stream collection
1 parent aacf970 commit 18acbef

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

pycti/connector/opencti_connector_helper.py

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -640,14 +640,21 @@ def stop(self) -> None:
640640
def get_name(self) -> Optional[Union[bool, int, str]]:
641641
return self.connect_name
642642

643-
def get_stream_name(self):
643+
def get_stream_collection(self):
644644
if self.connect_live_stream_id is not None:
645645
if self.connect_live_stream_id in ["live", "raw"]:
646-
return self.connect_live_stream_id
646+
return {
647+
"id": self.connect_live_stream_id,
648+
"name": self.connect_live_stream_id,
649+
"description": self.connect_live_stream_id,
650+
"stream_live": True,
651+
"stream_public": False,
652+
}
647653
else:
648654
query = """
649655
query StreamCollection($id: String!) {
650656
streamCollection(id: $id) {
657+
id
651658
name
652659
description
653660
stream_live

0 commit comments

Comments
 (0)