ITEP-68945 ITEP-68944 Using WebRTC for frames streaming

dlstreamer-pipeline-server/queuing-config-webrtc.json

@@ -0,0 +1,77 @@
+{
+  "config": {
+    "logging": {
+      "C_LOG_LEVEL": "INFO",
+      "PY_LOG_LEVEL": "INFO"
+    },
+    "pipelines": [
+      {
+        "name": "qcam2",
+        "source": "gstreamer",
+        "pipeline": "multifilesrc loop=TRUE location=/home/pipeline-server/videos/qcam2.ts name=source ! decodebin ! videoconvert ! video/x-raw,format=BGR ! gvapython class=PostDecodeTimestampCapture function=processFrame module=/home/pipeline-server/user_scripts/gvapython/sscape/sscape_adapter.py name=timesync ! gvadetect model=/home/pipeline-server/models/intel/person-detection-retail-0013/FP32/person-detection-retail-0013.xml model-proc=/home/pipeline-server/models/object_detection/person/person-detection-retail-0013.json ! gvametaconvert add-tensor-data=true name=metaconvert ! gvametapublish name=destination ! appsink sync=true",
+        "auto_start": true,
+        "parameters": {
+          "type": "object",
+          "properties": {
+            "ntp_config": {
+              "element": {
+                "name": "timesync",
+                "property": "kwarg",
+                "format": "json"
+              },
+              "type": "object",
+              "properties": {
+                "ntpServer": {
+                  "type": "string"
+                }
+              }
+            },
+            "camera_config": {
+              "element": {
+                "name": "datapublisher",
+                "property": "kwarg",
+                "format": "json"
+              },
+              "type": "object",
+              "properties": {
+                "cameraid": {
+                  "type": "string"
+                },
+                "metadatagenpolicy": {
+                  "type": "string",
+                  "description": "Meta data generation policy, one of detectionPolicy(default),reidPolicy,classificationPolicy"
+                },
+                "publish_frame": {
+                  "type": "boolean",
+                  "description": "Publish frame to mqtt"
+                }
+              }
+            }
+          }
+        },
+        "payload": {
+          "destination": {
+            "metadata": {
+              "type": "file",
+              "path": "/tmp/results.jsonl",
+              "format": "json-lines"
+            },
+            "frame": {
+              "type": "webrtc",
+              "peer-id": "cam"
+            }
+          },
+          "parameters": {
+            "ntp_config": {
+              "ntpServer": "ntpserv"
+            },
+            "camera_config": {
+              "cameraid": "atag-qcam2",
+              "metadatagenpolicy": "detectionPolicy"
+            }
+          }
+        }
+      }
+    ]
+  }
+}

dlstreamer-pipeline-server/queuing-config.json

@@ -119,4 +119,4 @@
       }
     ]
   }
-}
+}

manager/config/000-default.conf

@@ -56,6 +56,6 @@ ServerTokens Prod
 ServerSignature Off
 TraceEnable Off
 
-Header set Content-Security-Policy "frame-ancestors 'none'; form-action 'self'; script-src 'self' 'sha256-opencv' 'unsafe-eval'; style-src 'self' 'unsafe-inline'; frame-src 'none';"
+Header set Content-Security-Policy "frame-ancestors 'none'; form-action 'self'; script-src 'self' 'sha256-opencv' 'sha256-reader' 'unsafe-eval'; style-src 'self' 'unsafe-inline'; frame-src 'self' https://10.123.233.203:8889; upgrade-insecure-requests;"
 Header set Strict-Transport-Security "max-age=1024000; includeSubDomains"
 

manager/config/database-init

@@ -146,6 +146,7 @@ BROKERROOTCERT=${BROKERROOTCERT:-${RUNSECRETS}/scenescape-ca.pem}
 BROKERAUTH=${BROKERAUTH:-${RUNSECRETS}/controller.auth}
 if [ -e ${BROKERAUTH} -a -e ${BROKERROOTCERT} ] ; then
     AUTH=($(python3 -c "import sys, json; auth=json.load(sys.stdin); print(auth['user'], auth['password'])" < ${BROKERAUTH}))
+    echo $AUTH
     mosquitto_pub --tls-version tlsv1.3 --cafile ${BROKERROOTCERT} -h ${HOST} -p ${PORT} \
                 -u ${AUTH[0]} -P ${AUTH[1]} -t scenescape/cmd/database -m "update" &
 fi

manager/src/django/settings.py

@@ -17,7 +17,7 @@
 # See https://docs.djangoproject.com/en/2.0/howto/deployment/checklist/
 
 # SECURITY WARNING: don't run with debug turned on in production!
-DEBUG = os.getenv('DJANGO_DEBUG', 'False').lower() in ['true', '1', 't']
+DEBUG = True
 
 ALLOWED_HOSTS = ['*']
 DEFAULT_CHARSET = "utf-8"

manager/src/management/commands/createuser.py

@@ -34,13 +34,17 @@
           data = json.load(json_file)
         user = data.get('user')
         pw = data.get('password')
+        print(user)
+        print(pw)
       else:
         sep = auth.find(':')
         if sep < 0:
           log.error(f"Invalid user/password format in {auth}")
           continue
         user = auth[:sep]
         pw = auth[sep+1:]
+        print(user)
+        print(pw)
 
       if User.objects.filter(username=user).exists():
         if not options['skip_existing']:

manager/src/management/commands/waitfordb.py

@@ -20,6 +20,11 @@
   def handle(self, *args, **options):
     while True:
       try:
+        print("dbname='" + settings.DATABASES['default']['NAME']
+                                + "' user='" + settings.DATABASES['default']['USER']
+                                + "' host='" + settings.DATABASES['default']['HOST']
+                                + "' password='" + settings.DATABASES['default']['PASSWORD']
+                                + "'")
         conn = psycopg2.connect("dbname='" + settings.DATABASES['default']['NAME']
                                 + "' user='" + settings.DATABASES['default']['USER']
                                 + "' host='" + settings.DATABASES['default']['HOST']
@@ -58,8 +63,8 @@
         log.info("Database ready")
         break
 
-      except psycopg2.OperationalError:
-        log.error("Server not online")
+      except psycopg2.OperationalError as er:
+        log.error("Server not online", er)
         time.sleep(2)
 
       except Exception as ex: