projects/tentacles/config.toml

@@ -1,5 +1,4 @@
 SECRET_KEY = "SgvzxsO5oPBGInmqsyyGQWAJXkS9"
-UPLOAD_FOLDER = "/home/arrdem/Documents/hobby/programming/source/projects/tentacles/tmp"
 
 [db]
 uri = "/home/arrdem/Documents/hobby/programming/source/projects/tentacles/tentacles.sqlite3"

projects/tentacles/src/python/tentacles/__main__.py

@@ -8,7 +8,7 @@ from flask import Flask, request
 import tomllib
 from datetime import datetime
 
-from tentacles.blueprints import user_ui, printer_ui, job_ui, file_ui, api
+from tentacles.blueprints import user_ui, printer_ui, api
 from tentacles.store import Store
 from tentacles.globals import _ctx, Ctx, ctx
 from tentacles.workers import create_workers
@@ -78,8 +78,6 @@ def serve(hostname: str, port: int, config: Path):
     # Blueprints
     app.register_blueprint(user_ui.BLUEPRINT)
     app.register_blueprint(printer_ui.BLUEPRINT)
-    app.register_blueprint(job_ui.BLUEPRINT)
-    app.register_blueprint(file_ui.BLUEPRINT)
     app.register_blueprint(api.BLUEPRINT)
 
     # Shove our middleware in there

projects/tentacles/src/python/tentacles/blueprints/api.py

@@ -2,14 +2,8 @@
 
 """API endpoints supporting the 'ui'."""
 
-import os
-from typing import Optional
 
-from tentacles.globals import ctx
+from flask import Blueprint
-from tentacles.blueprints.util import requires_admin, requires_auth
-
-from flask import Blueprint, request, current_app
-from hashlib import sha3_256
 
 BLUEPRINT = Blueprint("api", __name__, url_prefix="/api")
 
@@ -18,25 +12,17 @@ BLUEPRINT = Blueprint("api", __name__, url_prefix="/api")
 # Printers
 #
 # The trick here is handling multipart uploads.
-@requires_admin
+@BLUEPRINT.route("/printer", methods=["POST"])
-@BLUEPRINT.route("/printers", methods=["POST"])
 def create_printer():
     pass
 
 
-@requires_auth
+@BLUEPRINT.route("/printer", methods=["GET"])
-@BLUEPRINT.route("/printers", methods=["GET"])
-@BLUEPRINT.route("/printers/", methods=["GET"])
 def list_printers():
-    return {
+    pass
-        "printers": [
-            {"id": p.id, "name": p.name, "url": p.url} for p in ctx.db.list_printers()
-        ]
-    }, 200
 
 
-@requires_admin
+@BLUEPRINT.route("/printer", methods=["DELETE"])
-@BLUEPRINT.route("/printers", methods=["DELETE"])
 def delete_printer():
     pass
 
@@ -45,100 +31,40 @@ def delete_printer():
 # Files
 #
 # The trick here is handling multipart uploads.
-@requires_auth
+@BLUEPRINT.route("/file", methods=["POST"])
-@BLUEPRINT.route("/files", methods=["POST"])
+def create_file():
-@BLUEPRINT.route("/files/<location>", methods=["POST"])
+    pass
-def create_file(location: Optional[str] = None):
-    # This is the important one, because it's the one that PrusaSlicer et all use to upload jobs.
-
-    print(request)
-    print(request.headers)
-    print(request.files)
-    print(request.form)
-
-    if "file" not in request.files:
-        return {"status": "error", "error": "No file to upload"}, 400
-
-    file = request.files["file"]
-    # If the user does not select a file, the browser submits an
-    # empty file without a filename.
-    if not file.filename:
-        return {"status": "error", "error": "No filename provided"}, 400
-
-    elif not file.filename.endswith(".gcode"):
-        return {"status": "error", "error": "Non-gcode file specified"}, 400
-
-    else:
-        digest = sha3_256()
-        digest.update(file.filename.encode())
-        sanitized_filename = digest.hexdigest() + ".gcode"
-        sanitized_path = os.path.join(
-            current_app.config["UPLOAD_FOLDER"], sanitized_filename
-        )
-        file.save(sanitized_path)
-        ctx.db.create_file(ctx.uid, file.filename, sanitized_path)
-
-        return {"status": "ok"}, 202
 
 
-@requires_auth
+@BLUEPRINT.route("/file", methods=["GET"])
-@BLUEPRINT.route("/files", methods=["GET"])
-@BLUEPRINT.route("/files/", methods=["GET"])
 def get_files():
-    return {
+    pass
-        "files": [
-            {
-                "id": f.id,
-                "filename": f.filename,
-                "path": f.path,
-                "owner": ctx.uid,
-                "upload_date": f.upload_date,
-            }
-            for f in ctx.db.list_files(ctx.uid)
-        ]
-    }, 200
 
 
-@requires_auth
+@BLUEPRINT.route("/file", methods=["DELETE"])
-@BLUEPRINT.route("/files", methods=["DELETE"])
 def delete_file():
     pass
 
 
 ####################################################################################################
 # Jobs
-@requires_auth
+@BLUEPRINT.route("/job", methods=["POST"])
-@BLUEPRINT.route("/jobs", methods=["POST"])
 def create_job():
     pass
 
 
-@requires_auth
+@BLUEPRINT.route("/job", methods=["GET"])
-@BLUEPRINT.route("/jobs", methods=["GET"])
 def get_jobs():
-    return {
+    pass
-        "jobs": [
-            {
-                "id": j.id,
-                "file_id": j.file_id,
-                "started_at": j.started_at,
-                "finished_at": j.finished_at,
-                "printer_id": j.printer_id,
-            }
-            for j in ctx.db.list_jobs()
-        ]
-    }, 200
 
 
-@requires_auth
+@BLUEPRINT.route("/job", methods=["DELETE"])
-@BLUEPRINT.route("/jobs", methods=["DELETE"])
 def delete_job():
     pass
 
 
 ####################################################################################################
 # API tokens
-@requires_auth
+@BLUEPRINT.route("/token", methods=["GET"])
-@BLUEPRINT.route("/tokens", methods=["GET"])
 def get_tokens():
     pass

projects/tentacles/src/python/tentacles/blueprints/file_ui.py

@@ -1,31 +0,0 @@
-#!/usr/bin/env python3
-
-import logging
-from datetime import timedelta
-import re
-
-from tentacles.globals import ctx
-from .util import requires_auth
-
-from flask import (
-    Blueprint,
-    current_app,
-    request,
-    redirect,
-    render_template,
-    flash,
-)
-
-from .util import salt, is_logged_in
-
-log = logging.getLogger(__name__)
-BLUEPRINT = Blueprint("files", __name__)
-
-
-@requires_auth
-@BLUEPRINT.route("/files", methods=["GET", "POST"])
-def files():
-    if request.method == "POST":
-        flash("Not supported yet", category="warning")
-
-    return render_template("files.html.j2")

projects/tentacles/src/python/tentacles/blueprints/job_ui.py

@@ -1,32 +0,0 @@
-#!/usr/bin/env python3
-
-import logging
-from datetime import timedelta
-import re
-
-from tentacles.globals import ctx
-from .util import requires_auth
-
-from flask import (
-    Blueprint,
-    current_app,
-    request,
-    redirect,
-    render_template,
-    flash,
-)
-
-from .util import salt, is_logged_in
-
-log = logging.getLogger(__name__)
-BLUEPRINT = Blueprint("jobs", __name__)
-
-
-@requires_auth
-@BLUEPRINT.route("/jobs", methods=["GET", "POST"])
-def jobs():
-    if request.method == "POST":
-        ctx.db.create_job(ctx.uid, int(request.form.get("file_id")))
-        flash("Job created!", category="info")
-
-    return redirect("/")

projects/tentacles/src/python/tentacles/blueprints/printer_ui.py

@@ -1,7 +1,10 @@
 #!/usr/bin/env python3
 
+"""Blueprints for HTML serving 'ui'."""
+
 import logging
 
+
 from flask import (
     Blueprint,
     request,

projects/tentacles/src/python/tentacles/blueprints/user_ui.py

@@ -1,5 +1,7 @@
 #!/usr/bin/env python3
 
+"""Blueprints for HTML serving 'ui'."""
+
 import logging
 from datetime import timedelta
 import re

projects/tentacles/src/python/tentacles/blueprints/util.py

@@ -31,14 +31,3 @@ def requires_admin(f):
             return f(*args, **kwargs)
 
     return _helper
-
-
-def requires_auth(f):
-    def _helper(*args, **kwargs):
-        if not ctx.uid:
-            flash("Please log in first", category="error")
-            redirect("/")
-        else:
-            return f(*args, **kwargs)
-
-    return _helper

projects/tentacles/src/python/tentacles/schema.sql

@@ -71,7 +71,6 @@ CREATE TABLE IF NOT EXISTS files (
    id INTEGER PRIMARY KEY AUTOINCREMENT
  , user_id INTEGER
  , filename TEXT
- , path TEXT
  , upload_date TEXT
  , FOREIGN KEY(user_id) REFERENCES user(id)
 );

projects/tentacles/src/python/tentacles/store.py

@@ -274,7 +274,7 @@ class Store(object):
             """
             SELECT p.id
             FROM printers p
-            LEFT JOIN (SELECT id, printer_id FROM jobs WHERE finished_at IS NULL) j ON p.id = j.printer_id
+            LEFT JOIN jobs j ON p.id = j.printer_id
             WHERE j.id IS NULL
             """
         ).fetchall()
@@ -298,8 +298,8 @@ class Store(object):
     @requires_conn
     def create_file(self, uid: int, name: str, path: Path) -> int:
         return self._conn.execute(
-            "INSERT INTO files (user_id, filename, path, upload_date) VALUES (?, ?, ?, datetime('now')) RETURNING (id)",
+            "INSERT INTO files (user_id, filename, upload_date) VALUES (?, ?, datetime('now')) RETURNING (id)",
-            [uid, name, path],
+            [uid, name],
         ).fetchone()
 
     @requires_conn
@@ -341,11 +341,11 @@ class Store(object):
     @requires_conn
     def list_jobs(self, uid: Optional[int] = None):
         """Enumerate jobs in priority order."""
-        cond = f"user_id = {uid}" if uid else "TRUE"
+        cond = f"AND user_id = {uid}" if uid else ""
         return self._conn.execute(
             f"""
             SELECT * FROM jobs
-            WHERE {cond}
+            WHERE started_at IS NULL AND printer_id IS NULL {cond}
             ORDER BY priority DESC
             """,
             [],
@@ -377,7 +377,6 @@ class Store(object):
             [],
         ).fetchall()
 
-    @fmap(one)
     @requires_conn
     def poll_job_queue(self):
         return self._conn.execute(

projects/tentacles/src/python/tentacles/templates/files_list.html.j2

@@ -1,31 +0,0 @@
-{% import "macros.html.j2" as macros %}
-<div class="panel files">
-  <h2>Files</h2>
-  {% with files = ctx.db.list_files(uid=ctx.uid) %}
-    {% if files %}
-      <ul>
-        {% for file in files %}
-          <li class="file">
-            <span class="file-name">{{ file.filename }}</span>
-            <span class="file-controls">
-              {{ macros.start_job(file.id) }}
-              {{ macros.delete_file(file.id) }}
-            </span>
-          </li>
-        {% endfor %}
-      </ul>
-    {% else %}
-      You don't have any files. Upload something!
-    {% endif %}
-  {% endwith %}
-</div>
-
-<div class="panel file-upload">
-  <h2>Upload a file</h2>
-  <form method="post" action="/api/files/local" enctype="multipart/form-data">
-    <input type="hidden" name="select" value="false" />
-    <input type="hidden" name="start" value="false" />
-    <input type="file" name="file" accept=".gcode,text/plain" />
-    <span><input id="submit" type="submit" value="Upload"/></span>
-  </form>
-</div>

projects/tentacles/src/python/tentacles/templates/index.html.j2

@@ -1,8 +1,34 @@
 {% extends "base.html.j2" %}
 {% block content %}
-  {% include "jobs_list.html.j2" %}
+  <div class="panel queue">
+    <h2>Queue</h2>
+    {% with jobs = ctx.db.list_jobs(uid=request.uid) %}
+    {% if jobs %}
+    <ul>
+      {% for job in jobs %}
+      <li></li>
+      {% endfor %}
+    </ul>
+  {% else %}
+    No pending tasks. {% if request.uid %}Start something!{% endif %}
+  {% endif %}
+  {% endwith %}
+  </div>
 
-  {% if ctx.uid %}
+  {% if request.uid %}
-  {% include "files_list.html.j2" %}
+  <div class="panel files">
+    <h2>Files</h2>
+    {% with files = ctx.db.list_files(uid=request.uid) %}
+    {% if files %}
+    <ul>
+      {% for file in files %}
+      <li></li>
+      {% endfor %}
+    </ul>
+    {% else %}
+      You don't have any files. Upload something!
+    {% endif %}
+    {% endwith %}
+  </div>
   {% endif %}
 {% endblock %}

projects/tentacles/src/python/tentacles/templates/jobs.html.j2

@@ -1,4 +0,0 @@
-{% extends "base.html.j2" %}
-{% block content %}
-{% include "jobs_list.html.j2" %}
-{% endblock %}

projects/tentacles/src/python/tentacles/templates/jobs_list.html.j2

@@ -1,18 +0,0 @@
-<div class="panel queue">
-  <h2>Job queue</h2>
-  {% with jobs = ctx.db.list_jobs(uid=ctx.uid) %}
-    {% if jobs %}
-      <ul>
-        {% for job in jobs %}
-          <li class="job">
-            <span class="job-id">{{job.id}}</span>
-            <span class="job-filename">{{ctx.db.fetch_file(job.file_id).filename}}</span>
-            <span class="job-status">{{ 'pending' if not job.printer_id else 'uploading' if not job.started_at else 'running' if not job.finished_at else job.state }}
-          </li>
-        {% endfor %}
-      </ul>
-    {% else %}
-      No pending tasks. {% if ctx.uid %}Start something!{% endif %}
-    {% endif %}
-  {% endwith %}
-</div>

projects/tentacles/src/python/tentacles/templates/macros.html.j2

@@ -1,15 +0,0 @@
-{% macro start_job(id) %}
-<form method="post" action="/jobs">
-  <input type="hidden" name="action" value="queue" />
-  <input type="hidden" name="file_id" value="{{ id }}" />
-  <span><input id="submit" type="submit" value="Queue"/></span>
-</form>
-{% endmacro %}
-
-{% macro delete_file(id) %}
-<form method="post" action="/files">
-  <input type="hidden" name="action" value="delete" />
-  <input type="hidden" name="id" value="{{ id }}" />
-  <span><input id="submit" type="submit" value="Delete"/></span>
-</form>
-{% endmacro %}

projects/tentacles/src/python/tentacles/templates/printers.html.j2

@@ -1,4 +1,31 @@
 {% extends "base.html.j2" %}
 {% block content %}
-{% include "printers_list.html.j2" %}
+  <div class="printers">
+    <h2>Printers</h2>
+    {% with printers = ctx.db.list_printers() %}
+    {% if printers %}
+    <ul>
+      {% for printer in printers %}
+      {% with id, name, url, _api_key, last_poll, status = printer %}
+      <li class="printer row">
+        <span class="printer-name">{{name}}</span>
+        <span class="printer-url"><code>{{url}}</code></span>
+        <span class="printer-status">{{status}}</span>
+        <span class="printer-date">{{last_poll}}</span>
+        {# FIXME: How should these action buttons work? #}
+        <span class="printer-controls ml-auto">
+          <a class="button" href="/printers/test?id={{id}}">Test</a>
+          <a class="button" href="/printers/edit?id={{id}}">Edit</a>
+          <a class="button" href="/printers/delete?id={{id}}">Remove</a>
+        </span>
+      </li>
+      {% endwith %}
+      {% endfor %}
+    </ul>
+    {% if ctx.is_admin %}<a class="button" href="/printers/add">Add a printer</a>{% endif %}
+    {% else %}
+      No printers available. {% if ctx.is_admin %}<a href="/printers/add">Configure one!</a>{% else %}Ask the admin to configure one!{% endif %}
+    {% endif %}
+    {% endwith %}
+  </div>
 {% endblock %}

projects/tentacles/src/python/tentacles/templates/printers_list.html.j2

@@ -1,28 +0,0 @@
-<div class="printers">
-  <h2>Printers</h2>
-  {% with printers = ctx.db.list_printers() %}
-    {% if printers %}
-      <ul>
-        {% for printer in printers %}
-          {% with id, name, url, _api_key, last_poll, status = printer %}
-            <li class="printer row">
-              <span class="printer-name">{{name}}</span>
-              <span class="printer-url"><code>{{url}}</code></span>
-              <span class="printer-status">{{status}}</span>
-              <span class="printer-date">{{last_poll}}</span>
-              {# FIXME: How should these action buttons work? #}
-              <span class="printer-controls ml-auto">
-                <a class="button" href="/printers/test?id={{id}}">Test</a>
-                <a class="button" href="/printers/edit?id={{id}}">Edit</a>
-                <a class="button" href="/printers/delete?id={{id}}">Remove</a>
-              </span>
-            </li>
-          {% endwith %}
-        {% endfor %}
-      </ul>
-      {% if ctx.is_admin %}<a class="button" href="/printers/add">Add a printer</a>{% endif %}
-    {% else %}
-      No printers available. {% if ctx.is_admin %}<a href="/printers/add">Configure one!</a>{% else %}Ask the admin to configure one!{% endif %}
-    {% endif %}
-  {% endwith %}
-</div>

projects/tentacles/src/python/tentacles/workers.py

@@ -15,7 +15,6 @@ import logging
 from contextlib import closing
 from urllib import parse as urlparse
 from tentacles.store import Store
-from pathlib import Path
 
 from octorest import OctoRest as _OR
 from requests import Response
@@ -101,9 +100,12 @@ def assign_jobs(db_factory: Callable[[], Store]) -> None:
 
     with closing(db_factory()) as db:
         for printer_id in db.list_idle_printers():
-            if job_id := db.poll_job_queue():
+            printer = db.fetch_printer(printer_id)
-                db.assign_job(job_id, printer_id)
+            if printer.status != "idle":
-                print(f"Mapped job {job_id} to printer {printer_id}")
+                continue
+
+            if next_job_id := db.poll_job_queue():
+                db.assign_job(next_job_id, printer_id)
 
 
 @corn_job(timedelta(seconds=5))
@@ -115,21 +117,9 @@ def push_jobs(db_factory: Callable[[], Store]) -> None:
             printer = db.fetch_printer(job.printer_id)
             file = db.fetch_file(job.file_id)
             try:
-                client = OctoRest(url=printer.url, apikey=printer.api_key)
+                client = OctoRest(printer.url, printer.api_key)
-                try:
+                client.upload(file.filename, select=True, print=True)
-                    client.upload(file.path)
-                except HTTPError as e:
-                    if e.response.status_code == 409:
-                        pass
-                    else:
-                        raise
-
-                client.select(Path(file.path).name)
-                client.start()
                 db.start_job(job.id)
-            except TimeoutError:
-                pass
-
             except Exception:
                 log.exception("Oop")
 
@@ -142,7 +132,6 @@ def pull_jobs(db_factory: Callable[[], Store]) -> None:
         for job in db.list_running_jobs():
             printer = db.fetch_printer(job.printer_id)
             if printer.status != "running":
-                print(f"Job {job.id} finished {printer.status}")
                 db.finish_job(job.id, printer.status)