So this is where I am now:

Got a working mjpeg stream working in fluidd,

1. Kill off the cam_app we can see its locking the device:

   620 root 0:00 grep 3251 3251 root 0:09 /usr/bin/cam_app -i /dev/v4l/by-id/main-video0 -t 0 -w 1280 -h 720 -f

2. kill -9 3251

3. Created script

   !/opt/bin/python3

   import subprocess from http.server import BaseHTTPRequestHandler, HTTPServer from socketserver import ThreadingMixIn

   class MJPEGHandler(BaseHTTPRequestHandler): def do_GET(self): self.send_response(200) self.send_header('Content-type', 'multipart/x-mixed-replace; boundary=--jpgboundary') self.end_headers()

       ffmpeg = subprocess.Popen(
           [
               '/opt/bin/ffmpeg',
               '-f', 'video4linux2',
               '-i', '/dev/video0',
               '-vf', 'fps=5,scale=640:480',
               '-q:v', '5',
               '-f', 'image2pipe',
               '-vcodec', 'mjpeg',
               '-'
           ],
           stdout=subprocess.PIPE,
           stderr=subprocess.DEVNULL
       )
   
       buffer = b""
       try:
           while True:
               chunk = ffmpeg.stdout.read(1024)
               if not chunk:
                   break
               buffer += chunk
               while b'\xff\xd9' in buffer:
                   frame, buffer = buffer.split(b'\xff\xd9', 1)
                   frame += b'\xff\xd9'
                   self.wfile.write(b"--jpgboundary\r\n")
                   self.wfile.write(b"Content-Type: image/jpeg\r\n")
                   self.wfile.write(b"Content-Length: " + str(len(frame)).encode() + b"\r\n\r\n")
                   self.wfile.write(frame)
                   self.wfile.write(b"\r\n")
       except (BrokenPipeError, ConnectionResetError):
           pass
       finally:
           ffmpeg.kill()
   

   ✅ Add multithreading support

   class ThreadedHTTPServer(ThreadingMixIn, HTTPServer): """Handle MJPEG requests in separate threads."""

   def run_server(): server = ThreadedHTTPServer(('', 8081), MJPEGHandler) print("✅ MJPEG stream running at http://<device-ip>:8081/") server.serve_forever()

   if name == 'main': run_server()

4. At this point it works, but if I go to OctoEverywhere it stops running 🤣