Compare commits

...

4 Commits

Author SHA1 Message Date
Nicolas Bertrand 7c5ab98553 Working 2025-10-10 00:42:36 +02:00
Nicolas Bertrand 5fba1ce900 First version running with One led 2025-10-09 20:01:45 +02:00
Nicolas Bertrand 35b039a39a update calibration 2025-10-09 19:44:31 +02:00
Nicolas Bertrand 80d259e519 1st version with led driver 2025-10-09 19:44:26 +02:00
9 changed files with 101 additions and 84 deletions

View File

@ -2,6 +2,8 @@ from flask import Flask, send_from_directory, session
import os
from . import db, config, routes, utils, leds
leds.get().enter()
app = Flask(__name__)
# Manage secret key

View File

@ -28,7 +28,7 @@ def calibrate(input_dir: str):
# Camera parameters
nu, nv, nc = images[0].shape
nspheres = 5
nspheres = 4
focal_mm = 35
matrix_size = 24
focal_pix = nu * focal_mm / matrix_size
@ -41,14 +41,15 @@ def calibrate(input_dir: str):
pixels = np.reshape(max_image / 255.0, (-1, 3))
# Initialize parameters for GMM
init_params = np.ones(2), np.broadcast_to(np.eye(3) * 0.1, (2, 3, 3)), np.asarray([[0, 0, 0], [1, 1, 1]])
# init_params = np.ones(2), np.broadcast_to(np.eye(3) * 0.1, (2, 3, 3)), np.asarray([[0, 0, 0], [1, 1, 1]])
# Estimate GMM parameters and classify pixels
estimated_params = math_utils.gaussian_mixture_estimation(pixels, init_params, it=10)
classif = np.asarray(math_utils.maximum_likelihood(pixels, estimated_params), dtype=bool)
# estimated_params = math_utils.gaussian_mixture_estimation(pixels, init_params, it=10)
# classif = np.asarray(math_utils.maximum_likelihood(pixels, estimated_params), dtype=bool)
# Refine classification to select the appropriate binary mask
rectified_classif = math_utils.select_binary_mask(classif, lambda mask: np.mean(pixels[mask]))
# rectified_classif = math_utils.select_binary_mask(classif, lambda mask: np.mean(pixels[mask]))
rectified_classif = np.mean(pixels, axis=-1) > 0.03
# Identify the largest connected components (spheres) and extract their borders
sphere_masks = math_utils.get_greatest_components(np.reshape(rectified_classif, (nu, nv)), nspheres)
@ -79,7 +80,7 @@ def calibrate(input_dir: str):
# Load grey values from images for the identified sphere regions
def to_grayscale(image):
return [np.mean(image, axis=-1)[sphere_geometric_masks[i]] / 255.0 for i in range(nspheres)]
return [np.power(np.mean(image, axis=-1)[sphere_geometric_masks[i]] / 255.0, 1.0) for i in range(nspheres)]
grey_values = np.asarray(list(map(to_grayscale, images)), dtype=object)

View File

@ -6,6 +6,8 @@ import shutil
from . import leds, config
import subprocess
import json
from PIL import Image
import io
def parse_config(lines):
@ -62,14 +64,18 @@ class Camera:
class RealCamera(Camera):
def __init__(self):
self._entered = False
self.inner = gp.Camera()
def __enter__(self):
self.inner.init()
if not self._entered:
self._entered = True
self.inner.init()
return self
def __exit__(self, *args):
self.inner.exit()
# self.inner.exit()
pass
def capture(self):
try:
@ -79,14 +85,11 @@ class RealCamera(Camera):
return None
def capture_preview(self):
try:
subprocess.run(
"gphoto2 --capture-preview --stdout > src/nenuscanner/static/feed.jpg",
shell=True, check=True
)
except subprocess.CalledProcessError as e:
print('An error occured when capturing photo', e)
raise CameraException(f"Erreur lors de la capture de l'image: {e}")
capture = gp.check_result(gp.gp_camera_capture_preview(self.inner))
file_data = gp.check_result(gp.gp_file_get_data_and_size(capture))
data = memoryview(file_data)
image = Image.open(io.BytesIO(file_data))
image.save("src/nenuscanner/static/feed.jpg")
def save(self, capture, output_file):
preview = self.inner.file_get(capture.folder, capture.name[:-3] + 'JPG', gp.GP_FILE_TYPE_NORMAL)
@ -97,8 +100,17 @@ class RealCamera(Camera):
raw.save(output_file + '.cr2')
def config(self):
was_entered = self._entered
if self._entered:
self._entered = False
self.inner.exit()
res = subprocess.run(["gphoto2", "--list-all-config"], capture_output=True, encoding="utf-8")
if was_entered:
self.__enter__()
# print(res.stdout[:200])
configs = res.stdout.split("\n")

View File

@ -35,10 +35,10 @@ class GpioLed:
self.led = None
def on(self):
self.led.set_value(1)
self.led.set_value(0)
def off(self):
self.led.set_value(0)
self.led.set_value(1)
def __str__(self):
return f'LED{self.gpio_pin:02}'
@ -46,19 +46,25 @@ class GpioLed:
class GpioLeds(Leds):
def __init__(self, chip: str, gpio_pins: list[int]):
self._entered = False
self.chip = gpiod.Chip(chip)
self.leds = []
for pin in gpio_pins:
self.leds.append(GpioLed(pin))
def __enter__(self):
for led in self.leds:
led.enter(self.chip)
if not self._entered:
self._entered = True
for led in self.leds:
led.enter(self.chip)
return self
def __exit__(self, *args):
for led in self.leds:
led.exit()
# for led in self.leds:
# led.exit()
# self._entered = False
pass
def off(self):
for led in self.leds:

View File

@ -1,3 +1,4 @@
import subprocess
from flask import Blueprint, render_template
from .. import db
@ -16,6 +17,21 @@ def index():
projects = db.Object.all_by_project(conn)
return render_template('index.html', projects=projects)
# Route that restarts the server
@blueprint.route("/restart")
def restart():
"""
Serves the index of nenuscanner.
"""
subprocess.Popen(
["bash", "-c", "sleep 1 && systemctl restart nenuscanner --user"],
stdout=subprocess.DEVNULL,
stderr=subprocess.DEVNULL,
start_new_session=True
)
return render_template('restart.html')
blueprint.register_blueprint(object.blueprint, url_prefix='/object')
blueprint.register_blueprint(calibration.blueprint, url_prefix='/calibration')

View File

@ -44,13 +44,11 @@ def set_camera_settings():
return {'status': 'ok', **updated}
@blueprint.route('/feed.jpg')
@blueprint.route('/feed.jpg', methods=['GET'])
def camera_feed():
capture_preview()
return send_file('static/feed.jpg', mimetype='image/jpeg')
@blueprint.route('/config', methods=['GET'])
def get_camera_config():
"""
@ -96,14 +94,14 @@ def get_camera_config():
return jsonify(grouped_params)
@blueprint.route('/capture_preview', methods=['POST'])
# @blueprint.route('/capture_preview', methods=['POST'])
def capture_preview():
"""
Capture un aperçu avec gphoto2 et sauvegarde dans static/feed.jpg
"""
try:
cam = C.get()
cam.capture_preview()
return jsonify({'status': 'ok'})
with C.get() as cam:
cam.capture_preview()
return jsonify({'status': 'ok'})
except C.CameraException as e:
return jsonify({'status': 'error', 'error': str(e)}), 500

View File

@ -2,58 +2,21 @@ from flask import Blueprint, render_template, request, send_file, jsonify, sessi
import json
import subprocess
import gpiod
from .. import camera as C
from .. import leds,config
blueprint = Blueprint('leds', __name__)
# WARNING: This is a temporary global variable to hold the state of the GPIO LEDs.
# This is necessary because the LED state must persist across multiple requests,
# and Flask does not maintain state between requests.
# A better solution would be to implement a proper state management system.
def _get_gpio_leds():
"""Return a singleton leds controller stored in app.extensions."""
app = current_app._get_current_object()
ext_key = 'nenuscanner_gpio_leds'
if ext_key not in app.extensions:
# create and store the resource
app.extensions[ext_key] = leds.get().enter()
return app.extensions[ext_key]
@blueprint.record_once
def _register_cleanup(state):
"""
Register a teardown handler on the app that will try to exit the leds controller
when the app context is torn down.
"""
app = state.app
ext_key = 'nenuscanner_gpio_leds'
@app.teardown_appcontext
def _cleanup(exception=None):
gpio = app.extensions.get(ext_key)
if gpio:
try:
gpio.exit()
except Exception:
# best effort cleanup, don't raise during teardown
pass
# Routes for object management
@blueprint.route('/')
def get():
"""
Returns the pages showing all leds.
"""
gpio_leds = _get_gpio_leds()
print(gpio_leds)
for i, led in enumerate(gpio_leds.leds):
print(f"LED {i}: {led}, is_on={led.is_on}")
return render_template(
'leds.html', leds= config.LEDS_UUIDS)
@ -62,23 +25,30 @@ def get():
def set_led():
"""
Reçoit une commande pour allumer ou éteindre une LED.
Attend un JSON : { "led": "led1", "state": "on" } ou { "led": "led2", "state": "off" }
Attend un JSON : { "led": "14", "state": "on" } ou { "led": "15, "state": "off" }
"""
data = request.get_json()
led = data.get('led')
state = data.get('state')
# get the controller (lazy, stored on app.extensions)
gpio_leds = _get_gpio_leds()
gpio_leds = leds.get()
try:
# parse led id/name according to your naming convention
print([x.gpio_pin for x in gpio_leds.leds])
gpio_led = gpio_leds.get_by_uuid(int(led))
print(f"Setting {led} / {gpio_led} to {state}")
if state == "on":
gpio_led.on()
else:
gpio_led.off()
except Exception as e:
return jsonify({'status': 'error', 'error': str(e)}), 400
raise
print(f'{e}')
return jsonify({'status': 'error', 'error': 'error'}), 400
print(f"Commande reçue pour {led} : {state}")
return jsonify({'status': 'ok', 'led': led, 'state': state})

View File

@ -23,7 +23,12 @@
</a>
</div>
<div id="navbarBasicExample" class="navbar-menu">
<div class="navbar-start">
<a class="navbar-item" href="/camera">Caméra</a>
<a class="navbar-item" href="/leds">Leds</a>
</div>
<div class="navbar-end">
<a class="navbar-item" href="/restart">Redémarrer le serveur</a>
<a id="calibration-tag-0" class="calibration-tag navbar-item" href="/calibration/calibrate" {% if calibration.state != 0 %}style="display: none;"{% endif %}>
<span id="calibration-tag-0" class="tags has-addons">
<span class="tag is-dark">étalonnage</span>

View File

@ -11,7 +11,7 @@
</div>
<div class="column is-half has-text-centered">
<figure class="image is-4by3" style="max-width: 480px; margin: auto;">
<img class="preview" id="camera-preview" src="/static/feed.jpg?{{ range(1000000)|random }}" alt="Camera Preview"
<img class="preview" id="camera-preview" alt="Camera Preview"
style="border: 1px solid #ccc;">
</figure>
<button class="button is-small is-info mt-2" type="button" onclick="refreshPreview()">Rafraîchir
@ -65,12 +65,15 @@
}).then(() => location.reload());
}
window.refreshPreview = function () {
const img = document.getElementById('camera-preview');
const url = '/static/feed.jpg?' + new Date().getTime();
const img = document.getElementById('camera-preview');
img.onload = function() {
requestAnimationFrame(refreshPreview);
}
function refreshPreview() {
const url = '/camera/feed.jpg?' + new Date().getTime();
img.src = url;
}
setInterval(window.refreshPreview, 1000); // Refresh every second
document.addEventListener('DOMContentLoaded', function () {
fetch('/camera/config')
@ -146,7 +149,11 @@
});
container.appendChild(box);
});
});
// When ready, load preview
refreshPreview();
});
});
function CapturePreview() {
fetch('/camera/capture_preview', {method: 'POST'})