2019-01-29 21:59:05 +02:00
|
|
|
part of '../../main.dart';
|
|
|
|
|
|
|
|
class CameraControlsWidget extends StatefulWidget {
|
|
|
|
|
|
|
|
final String url;
|
|
|
|
|
|
|
|
CameraControlsWidget({Key key, @required this.url}) : super(key: key);
|
|
|
|
|
|
|
|
@override
|
|
|
|
_CameraControlsWidgetState createState() => _CameraControlsWidgetState();
|
|
|
|
}
|
|
|
|
|
|
|
|
class _CameraControlsWidgetState extends State<CameraControlsWidget> {
|
|
|
|
|
|
|
|
@override
|
|
|
|
void initState() {
|
|
|
|
super.initState();
|
2019-02-20 13:57:25 +02:00
|
|
|
_connect();
|
2019-01-31 01:04:13 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
http.Client client;
|
|
|
|
http.StreamedResponse response;
|
|
|
|
List<int> binaryImage = [];
|
2019-02-09 02:12:05 +02:00
|
|
|
String cameraState = "Connecting...";
|
|
|
|
bool timeToStop = false;
|
|
|
|
Completer streamCompleter;
|
2019-01-31 01:04:13 +02:00
|
|
|
|
2019-02-20 13:57:25 +02:00
|
|
|
void _connect() async {
|
|
|
|
timeToStop = false;
|
2019-01-31 01:04:13 +02:00
|
|
|
client = new http.Client(); // create a client to make api calls
|
|
|
|
http.Request request = new http.Request("GET", Uri.parse(widget.url)); // create get request
|
2019-02-08 23:59:33 +02:00
|
|
|
Logger.d("[Sending] ==> ${widget.url}");
|
2019-02-09 02:12:05 +02:00
|
|
|
response = await client.send(request);
|
|
|
|
setState(() {
|
|
|
|
cameraState = "Starting...";
|
|
|
|
});
|
2019-02-08 23:59:33 +02:00
|
|
|
Logger.d("[Received] <== ${response.headers}");
|
2019-02-20 12:06:03 +02:00
|
|
|
String frameBoundary = response.headers['content-type'].split('boundary=')[1];
|
|
|
|
final int frameBoundarySize = frameBoundary.length;
|
2019-01-31 01:04:13 +02:00
|
|
|
List<int> primaryBuffer=[];
|
2019-02-20 12:06:03 +02:00
|
|
|
int imageSizeStart = 59;
|
2019-02-08 23:59:33 +02:00
|
|
|
int imageSizeEnd = 0;
|
2019-01-31 01:04:13 +02:00
|
|
|
int imageStart = 0;
|
2019-02-09 02:12:05 +02:00
|
|
|
int imageSize = 0;
|
|
|
|
String strBuffer = "";
|
2019-02-20 12:06:03 +02:00
|
|
|
String contentType = "";
|
2019-02-09 02:12:05 +02:00
|
|
|
streamCompleter = Completer();
|
2019-01-31 01:04:13 +02:00
|
|
|
response.stream.transform(
|
|
|
|
StreamTransformer.fromHandlers(
|
|
|
|
handleData: (data, sink) {
|
|
|
|
primaryBuffer.addAll(data);
|
2019-02-20 12:06:03 +02:00
|
|
|
imageStart = 0;
|
|
|
|
imageSizeEnd = 0;
|
|
|
|
if (primaryBuffer.length >= imageSizeStart + 10) {
|
|
|
|
contentType = utf8.decode(
|
|
|
|
primaryBuffer.sublist(frameBoundarySize+16, imageSizeStart + 10), allowMalformed: true).split("\r\n")[0];
|
2019-02-20 13:57:25 +02:00
|
|
|
//Logger.d("$contentType");
|
2019-02-20 12:06:03 +02:00
|
|
|
imageSizeStart = frameBoundarySize + 16 + contentType.length + 18;
|
2019-02-08 23:59:33 +02:00
|
|
|
for (int i = imageSizeStart; i < primaryBuffer.length - 4; i++) {
|
2019-02-09 02:12:05 +02:00
|
|
|
strBuffer = utf8.decode(
|
2019-02-08 23:59:33 +02:00
|
|
|
primaryBuffer.sublist(i, i + 4), allowMalformed: true);
|
2019-02-09 02:12:05 +02:00
|
|
|
if (strBuffer == "\r\n\r\n") {
|
2019-02-08 23:59:33 +02:00
|
|
|
imageSizeEnd = i;
|
|
|
|
imageStart = i + 4;
|
|
|
|
break;
|
2019-01-31 01:04:13 +02:00
|
|
|
}
|
2019-02-08 23:59:33 +02:00
|
|
|
}
|
2019-02-20 12:06:03 +02:00
|
|
|
if (imageSizeEnd > 0) {
|
|
|
|
imageSize = int.tryParse(utf8.decode(
|
|
|
|
primaryBuffer.sublist(imageSizeStart, imageSizeEnd),
|
|
|
|
allowMalformed: true));
|
2019-02-20 13:57:25 +02:00
|
|
|
//Logger.d("content-length: $imageSize");
|
2019-02-20 12:06:03 +02:00
|
|
|
if (imageSize != null &&
|
|
|
|
primaryBuffer.length >= imageStart + imageSize + 2) {
|
|
|
|
sink.add(
|
|
|
|
primaryBuffer.sublist(
|
|
|
|
imageStart, imageStart + imageSize));
|
|
|
|
primaryBuffer.removeRange(0, imageStart + imageSize + 2);
|
|
|
|
}
|
2019-01-31 01:04:13 +02:00
|
|
|
}
|
|
|
|
}
|
2019-02-09 02:12:05 +02:00
|
|
|
if (timeToStop) {
|
|
|
|
sink?.close();
|
|
|
|
streamCompleter.complete();
|
|
|
|
}
|
|
|
|
},
|
|
|
|
handleError: (error, stack, sink) {
|
|
|
|
Logger.e("Error parsing MJPEG stream: $error");
|
2019-01-31 01:04:13 +02:00
|
|
|
},
|
|
|
|
handleDone: (sink) {
|
2019-02-20 13:57:25 +02:00
|
|
|
Logger.d("Camera stream finished. Reconnecting...");
|
2019-02-09 02:12:05 +02:00
|
|
|
sink?.close();
|
2019-02-20 13:57:25 +02:00
|
|
|
streamCompleter?.complete();
|
|
|
|
_reconnect();
|
2019-01-31 01:04:13 +02:00
|
|
|
},
|
|
|
|
)
|
|
|
|
).listen((d) {
|
2019-02-20 13:57:25 +02:00
|
|
|
if (!timeToStop) {
|
|
|
|
setState(() {
|
|
|
|
binaryImage = d;
|
|
|
|
});
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
void _reconnect() {
|
|
|
|
disconnect().then((_){
|
|
|
|
_connect();
|
2019-01-31 01:04:13 +02:00
|
|
|
});
|
2019-01-29 21:59:05 +02:00
|
|
|
}
|
|
|
|
|
2019-02-20 13:57:25 +02:00
|
|
|
Future disconnect() {
|
|
|
|
Completer disconF = Completer();
|
|
|
|
timeToStop = true;
|
|
|
|
if (streamCompleter != null && !streamCompleter.isCompleted) {
|
|
|
|
streamCompleter.future.then((_) {
|
|
|
|
client?.close();
|
|
|
|
disconF.complete();
|
|
|
|
});
|
|
|
|
} else {
|
|
|
|
client?.close();
|
|
|
|
disconF.complete();
|
|
|
|
}
|
|
|
|
return disconF.future;
|
|
|
|
}
|
|
|
|
|
2019-01-29 21:59:05 +02:00
|
|
|
@override
|
|
|
|
Widget build(BuildContext context) {
|
2019-02-08 23:59:33 +02:00
|
|
|
if (binaryImage.isEmpty) {
|
2019-02-09 02:12:05 +02:00
|
|
|
return Column(
|
|
|
|
children: <Widget>[
|
|
|
|
Text("$cameraState")
|
|
|
|
],
|
|
|
|
);
|
2019-02-08 23:59:33 +02:00
|
|
|
} else {
|
|
|
|
return Column(
|
|
|
|
children: <Widget>[
|
|
|
|
Image.memory(Uint8List.fromList(binaryImage), gaplessPlayback: true),
|
|
|
|
],
|
|
|
|
);
|
|
|
|
}
|
2019-01-29 21:59:05 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
@override
|
|
|
|
void dispose() {
|
2019-02-20 13:57:25 +02:00
|
|
|
disconnect();
|
2019-01-29 21:59:05 +02:00
|
|
|
super.dispose();
|
|
|
|
}
|
|
|
|
}
|