HerrHase
/
tellme-bot
1
0
Fork 0
Code Issues Pull Requests Projects Releases 3 Wiki Activity

Compare commits

base: HerrHase:main
Branches Tags
HerrHase:main
HerrHase:develop
..
compare: HerrHase:develop
Branches Tags
HerrHase:main
HerrHase:develop

No commits in common. 'main' and 'develop' have entirely different histories.
main ... develop

16 changed files with 4561 additions and 12892 deletions
Show Stats

2
README.md
Unescape View File

@ -12,7 +12,7 @@ yarn start
or
pm2 --name=tellme-bot start npm -- start
pm2 start yarn start --name=tellme-bot
```
## Konfiguration

6272
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

88
packages/server/_bootstrap.js
Unescape View File

@ -1,88 +0,0 @@
import fastify from 'fastify'
import dotenv from 'dotenv'
import path from 'path'
import { EventEmitter } from 'events'
import formBody from '@fastify/formbody'
// getting .env
dotenv.config({ path: path.join(path.resolve(), '/../../.env') })
// create server
const server = fastify()
// adding eventEmitter
server.decorate('eventEmitter', new EventEmitter())
// adding formBody
server.register(formBody)
/**
* add xmpp
*
*/
import xmpp from './plugins/xmpp.js'
server.register(xmpp, {
service: process.env.XMPP_SERVICE,
domain: process.env.XMPP_DOMAIN,
username: process.env.XMPP_USERNAME,
password: process.env.XMPP_PASSWORD,
to: process.env.XMPP_TO
})
/**
* add helmet
*
*/
import helmet from '@fastify/helmet'
/***
server.register(
helmet, {
referrerPolicy: {
policy: ['origin']
}
}
)*/
/**
* add rateLimit
*
*/
import rateLimit from '@fastify/rate-limit'
const rateLimitSettings = {
max: 100,
timeWindow: 60000
}
if (process.env.APP_RATE_LIMIT_MAX) {
rateLimitSettings.max = process.env.APP_RATE_LIMIT_MAX
}
if (process.env.APP_RATE_LIMIT_TIMEWINDOW) {
rateLimitSettings.timeWindow = process.env.APP_RATE_LIMIT_TIMEWINDOW
}
server.register(rateLimit, rateLimitSettings)
/**
* add routes
*
*
*/
import webhookHttp from './http/api/webhook.js'
import healthHttp from './http/api/health.js'
server
.register(webhookHttp, {
'prefix': '/api/webhook'
})
.register(healthHttp, {
'prefix': '/api/health'
})
export default server

41
packages/server/bootstrap.js vendored
Unescape View File

@ -0,0 +1,41 @@
import fastify from 'fastify'
import dotenv from 'dotenv'
import path from 'path'
import { EventEmitter } from 'events'
// getting .env
dotenv.config({ path: path.join(path.resolve(), '/../../.env') })
// create server
const server = fastify()
// adding eventEmitter
server.decorate('eventEmitter', new EventEmitter())
// adding xmpp
import xmpp from './plugins/xmpp.js'
server.register(xmpp, {
service: process.env.XMPP_SERVICE,
domain: process.env.XMPP_DOMAIN,
username: process.env.XMPP_USERNAME,
password: process.env.XMPP_PASSWORD
})
/**
* add routes
*
*
*/
import webhookHttp from './http/api/webhook.js'
import healthHttp from './http/api/health.js'
server
.register(webhookHttp, {
'prefix': '/api/webhook'
})
.register(healthHttp, {
'prefix': '/api/health'
})
export default server

40
packages/server/handlers/parser.js
Unescape View File

@ -1,40 +0,0 @@
import DOMPurify from 'isomorphic-dompurify'
/**
*
* handle parser
*
*
* @author Björn Hase <me@herr-hase.wtf>
* @license http://opensource.org/licenses/MIT The MIT License
* @link https://gitea.node001.net/HerrHase/super-fastify-directus.git
*
*/
async function parserHandler(request, response) {
// getting allowed parsers from .env as array
const allowedParsers = process.env.APP_API_ALLOWED_PARSERS.split(',')
// getting name from request
const parserName = DOMPurify.sanitize(request.params.parser)
// if parser not found send 404
if (allowedParsers.indexOf(parserName) === -1) {
console.log('Parsers: "' + parserName + '" not found!')
return response
.code(404)
.send()
}
// getting parser and set body to parser
const Parser = await import('./../parsers/' + parserName + '.js')
response.locals = {
parser: new Parser.default(request.body)
}
}
export default parserHandler

23
packages/server/handlers/token.js
Unescape View File

@ -1,23 +0,0 @@
import DOMPurify from 'isomorphic-dompurify'
/**
* handle token
*
* @author Björn Hase <me@herr-hase.wtf>
* @license http://opensource.org/licenses/MIT The MIT License
* @link https://gitea.node001.net/HerrHase/super-fastify-directus.git
*
*/
async function tokenHandler(request, response) {
const token = DOMPurify.sanitize(request.params.token)
if (token !== process.env.APP_API_TOKEN) {
return response
.code(401)
.send()
}
}
export default tokenHandler

9
packages/server/http/api/health.js
Unescape View File

@ -7,8 +7,8 @@
*
*/
export default async function(fastify, opts) {
export default async function(fastify, opts)
{
/**
* getting post getting allowed parser class and send over xmpp
*
@ -16,8 +16,9 @@ export default async function(fastify, opts) {
* @param {object} response
*
*/
fastify.get('/v1', async function (request, response) {
response
fastify.get('/v1', async function (request, reply)
{
reply
.code(200)
.send()
})

37
packages/server/http/api/webhook.js
Unescape View File

@ -1,6 +1,3 @@
import tokenHandler from './../../handlers/token.js'
import parserHandler from './../../handlers/parser.js'
/**
* handle webhook
*
@ -10,11 +7,8 @@ import parserHandler from './../../handlers/parser.js'
*
*/
export default async function(fastify, options) {
fastify.addHook('preHandler', tokenHandler)
fastify.addHook('preHandler', parserHandler)
export default async function(fastify, opts)
{
/**
* getting post getting allowed parser class and send over xmpp
*
@ -22,19 +16,36 @@ export default async function(fastify, options) {
* @param {object} response
*
*/
fastify.post('/v1/:parser/:token', async function (request, response) {
fastify.post('/v1/:parser([a-zA-Z0-9]{0,255})/:token([a-zA-Z0-9])', async function (request, reply)
{
if (request.params.token !== process.env.APP_API_TOKEN) {
return reply
.code(401)
.send()
}
// getting allowed parsers from .env as array
const allowedParsers = process.env.APP_API_ALLOWED_PARSERS.split(',')
// getting parser from preHandler: parserHandler
const result = response.locals.parser.run()
if (allowedParsers.indexOf(request.params.parser) === -1) {
return reply
.code(404)
.send()
}
// getting parser and set body to parser
const Parser = await import('./../../parsers/' + request.params.parser + '.js')
const parser = new Parser.default(request.body)
const result = parser.run()
// send event for send xmpp
fastify.eventEmitter.emit('send-message', {
'message': result
})
response
reply
.code(200)
.send()
})
}

10
packages/server/index.js
Unescape View File

@ -1,14 +1,10 @@
import server from './_bootstrap.js'
import server from './bootstrap.js'
// let it rain
const start = async () => {
try {
await server.listen({
port: process.env.APP_PORT
})
console.log('Server: start')
console.log('Server: running on port ' + process.env.APP_PORT)
await server.listen(process.env.APP_PORT)
console.log('Server is running on port ' + process.env.APP_PORT)
} catch (error) {
console.log(error)
process.exit(1)

2381
packages/server/package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

13
packages/server/package.json
Unescape View File

@ -1,19 +1,16 @@
{
"private": true,
"name": "server",
"version": "0.1.0",
"version": "0.1.1",
"scripts": {
"start": "node index.js"
},
"type": "module",
"dependencies": {
"@fastify/formbody": "^7.4.0",
"@fastify/helmet": "^11.0.0",
"@fastify/rate-limit": "^8.0.1",
"@xmpp/client": "^0.13.1",
"@xmpp/client": "^0.13.0",
"dotenv": "^10.0.0",
"fastify": "^4.19.2",
"fastify-plugin": "^4.5.0",
"isomorphic-dompurify": "^1.7.0"
"fastify": "^3.24.0",
"fastify-formbody": "^5.2.0",
"isomorphic-dompurify": "^0.16.0"
}
}

14
packages/server/parsers/kuma.js
Unescape View File

@ -1,4 +1,4 @@
import Parser from './_parser.js'
import Parser from './parser.js'
import DOMPurify from 'isomorphic-dompurify'
/**
@ -9,14 +9,10 @@ import DOMPurify from 'isomorphic-dompurify'
* @link https://gitea.node001.net/HerrHase/tellme-bot.git
*
*/
class Kuma extends Parser {
/**
*
*
*/
parse() {
class Kuma extends Parser
{
parse()
{
// check for msg and clean it
if (this.body.msg) {
this.message = DOMPurify.sanitize(this.body.msg)

11
packages/server/parsers/_parser.js → packages/server/parsers/parser.js
Unescape View File

@ -7,14 +7,14 @@
* @link https://gitea.node001.net/HerrHase/tellme-bot.git
*
*/
class Parser {
class Parser
{
/**
*
*
*/
constructor(body) {
constructor(body)
{
// body from webhook
this.body = body
@ -28,7 +28,8 @@ class Parser {
* @return string
*
*/
run() {
run()
{
this.parse()
return this.message
}

14
packages/server/parsers/text.js
Unescape View File

@ -1,4 +1,4 @@
import Parser from './_parser.js'
import Parser from './parser.js'
import DOMPurify from 'isomorphic-dompurify'
/**
@ -9,14 +9,10 @@ import DOMPurify from 'isomorphic-dompurify'
* @link https://gitea.node001.net/HerrHase/tellme-bot.git
*
*/
class Text extends Parser {
/**
*
*
*/
parse() {
class Text extends Parser
{
parse()
{
// check for msg and clean it
if (this.body.text) {
this.message = DOMPurify.sanitize(this.body.text)

16
packages/server/plugins/xmpp.js
Unescape View File

@ -21,22 +21,17 @@ export default function (fastify, options, done) {
*/
async function handleSendMessage(data) {
let send = false
// Sends a chat message to itself
const message = xml(
'message', {
'message',
{
type: 'chat',
to: options.to
},
xml('body', {}, data.message)
)
try {
await xmpp.send(message)
} catch (error) {
console.log(error)
}
await xmpp.send(message)
}
const xmpp = client({
@ -52,8 +47,9 @@ export default function (fastify, options, done) {
})
// handle if client goes online
xmpp.on('online', (address) => {
console.log('Xmpp: connected to ' + address)
xmpp.on('online', (address) =>
{
console.log('connected to ' + address)
// check for event and remove it
if (fastify.eventEmitter.listeners('send-message').length > 0) {

8468
yarn.lock
View File

File diff suppressed because it is too large Load Diff
Write Preview
Loading…
Cancel
Save