alerte-secours/as-services
3
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore: clean
All checks were successful
/ build (map[dockerfile:./services/app/Dockerfile name:app]) (push) Successful in 1m56s
Details
/ build (map[dockerfile:./services/web/Dockerfile name:web]) (push) Successful in 2m26s
Details
/ build (map[dockerfile:./services/api/Dockerfile name:api]) (push) Successful in 2m7s
Details
/ build (map[dockerfile:./services/files/Dockerfile name:files]) (push) Successful in 1m47s
Details
/ build (map[dockerfile:./services/tasks/Dockerfile name:tasks]) (push) Successful in 2m12s
Details
/ build (map[dockerfile:./services/hasura/Dockerfile name:hasura]) (push) Successful in 2m27s
Details
/ build (map[dockerfile:./services/watchers/Dockerfile name:watchers]) (push) Successful in 2m35s
Details
/ deploy (push) Successful in 16s
Details

Browse source
This commit is contained in:
devthejo 2025-05-30 18:17:28 +02:00
parent e40b939144
commit 096314c14c
1 changed files with 0 additions and 54 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
services/watchers/src/watchers/alert-table-follow-location.js
View file

@ -1,54 +0,0 @@
const async = require("async")
const { gql } = require("@apollo/client/core")
const { ctx } = require("@modjo/core")
// const watcherCtx = require("modjo-plugins/core/ctx/watcher")
// const tasks = require("~/tasks")
const ALERT_FOLLOW_LOCATION_SUBSCRIPTION = gql`
subscription onAlertFollowLocation($limit: Int) {
selectManyAlert(
where: { _and: { state: { _eq: "open" }, followLocation: { _eq: true } } }
limit: $limit
order_by: { id: asc }
) {
id
}
}
`
module.exports = async function () {
const logger = ctx.require("logger")
const apolloClient = ctx.require("apolloClient")
// const { addTask } = ctx.require("amqp")
// const QUEUE_BATCH_SIZE = null
const QUEUE_BATCH_SIZE = 1000
return async function alertTableFollowLocation() {
logger.info("watcher alertTableFollowLocation: daemon started")
const observable = apolloClient.subscribe({
query: ALERT_FOLLOW_LOCATION_SUBSCRIPTION,
variables: {
limit: QUEUE_BATCH_SIZE,
},
})
observable.subscribe({
next: async ({ data }) => {
const { selectManyAlert } = data
await async.eachOf(selectManyAlert, async ({ id: _id }) => {
// TODO
})
},
error: (error) => {
logger.error(
{ error, watcher: "alertTableFollowLocation" },
`subscription error`
)
throw error
},
})
}
}