mirror of
https://github.com/dgtlmoon/changedetection.io.git
synced 2026-05-04 08:40:53 +00:00
dgtlmoon
30dc4ac23b
Build and push containers / metadata (push) Has been cancelled
Build and push containers / build-push-containers (push) Has been cancelled
Publish Python 🐍distribution 📦 to PyPI and TestPyPI / Build distribution 📦 (push) Has been cancelled
Publish Python 🐍distribution 📦 to PyPI and TestPyPI / Test the built package works basically. (push) Has been cancelled
Publish Python 🐍distribution 📦 to PyPI and TestPyPI / Publish Python 🐍 distribution 📦 to PyPI (push) Has been cancelled
ChangeDetection.io App Test / lint-code (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-10 (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-11 (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-12 (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-13 (push) Has been cancelled
ChangeDetection.io Container Build Test / Build linux/amd64 (alpine) (push) Has been cancelled
ChangeDetection.io Container Build Test / Build linux/arm64 (alpine) (push) Has been cancelled
ChangeDetection.io Container Build Test / Build linux/amd64 (main) (push) Has been cancelled
ChangeDetection.io Container Build Test / Build linux/arm/v7 (main) (push) Has been cancelled
ChangeDetection.io Container Build Test / Build linux/arm/v8 (main) (push) Has been cancelled
ChangeDetection.io Container Build Test / Build linux/arm64 (main) (push) Has been cancelled
36 lines
1.4 KiB
Python
36 lines
1.4 KiB
Python
|
|
from changedetectionio.strtobool import strtobool
|
|
from flask import Blueprint, flash, redirect, url_for
|
|
from flask_login import login_required
|
|
from changedetectionio.store import ChangeDetectionStore
|
|
from changedetectionio import queuedWatchMetaData
|
|
from changedetectionio import worker_pool
|
|
from queue import PriorityQueue
|
|
|
|
PRICE_DATA_TRACK_ACCEPT = 'accepted'
|
|
PRICE_DATA_TRACK_REJECT = 'rejected'
|
|
|
|
def construct_blueprint(datastore: ChangeDetectionStore, update_q: PriorityQueue):
|
|
|
|
price_data_follower_blueprint = Blueprint('price_data_follower', __name__)
|
|
|
|
@login_required
|
|
@price_data_follower_blueprint.route("/<string:uuid>/accept", methods=['GET'])
|
|
def accept(uuid):
|
|
datastore.data['watching'][uuid]['track_ldjson_price_data'] = PRICE_DATA_TRACK_ACCEPT
|
|
datastore.data['watching'][uuid]['processor'] = 'restock_diff'
|
|
datastore.data['watching'][uuid].clear_watch()
|
|
worker_pool.queue_item_async_safe(update_q, queuedWatchMetaData.PrioritizedItem(priority=1, item={'uuid': uuid}))
|
|
return redirect(url_for("watchlist.index"))
|
|
|
|
@login_required
|
|
@price_data_follower_blueprint.route("/<string:uuid>/reject", methods=['GET'])
|
|
def reject(uuid):
|
|
datastore.data['watching'][uuid]['track_ldjson_price_data'] = PRICE_DATA_TRACK_REJECT
|
|
return redirect(url_for("watchlist.index"))
|
|
|
|
|
|
return price_data_follower_blueprint
|
|
|
|
|