Compare commits
2 Commits
changedete
...
custom-ais
Author | SHA1 | Date | |
---|---|---|---|
![]() |
74494989d2 | ||
![]() |
e122ad4178 |
@@ -28,7 +28,7 @@ cd packages/web
|
|||||||
rm -rf .env
|
rm -rf .env
|
||||||
echo "
|
echo "
|
||||||
PORT=$WEB_PORT
|
PORT=$WEB_PORT
|
||||||
REACT_APP_BACKEND_URL=http://localhost:$BACKEND_PORT
|
REACT_APP_GRAPHQL_URL=http://localhost:$BACKEND_PORT/graphql
|
||||||
" >> .env
|
" >> .env
|
||||||
cd $CURRENT_DIR
|
cd $CURRENT_DIR
|
||||||
|
|
||||||
|
@@ -8,7 +8,7 @@
|
|||||||
"version": "latest"
|
"version": "latest"
|
||||||
},
|
},
|
||||||
"ghcr.io/devcontainers/features/node:1": {
|
"ghcr.io/devcontainers/features/node:1": {
|
||||||
"version": 18
|
"version": 16
|
||||||
},
|
},
|
||||||
"ghcr.io/devcontainers/features/common-utils:1": {
|
"ghcr.io/devcontainers/features/common-utils:1": {
|
||||||
"username": "vscode",
|
"username": "vscode",
|
||||||
|
@@ -36,6 +36,7 @@ services:
|
|||||||
keycloak:
|
keycloak:
|
||||||
image: quay.io/keycloak/keycloak:21.1
|
image: quay.io/keycloak/keycloak:21.1
|
||||||
restart: always
|
restart: always
|
||||||
|
container_name: keycloak
|
||||||
environment:
|
environment:
|
||||||
- KEYCLOAK_ADMIN=admin
|
- KEYCLOAK_ADMIN=admin
|
||||||
- KEYCLOAK_ADMIN_PASSWORD=admin
|
- KEYCLOAK_ADMIN_PASSWORD=admin
|
||||||
|
@@ -4,9 +4,5 @@
|
|||||||
**/.devcontainer
|
**/.devcontainer
|
||||||
**/.github
|
**/.github
|
||||||
**/.vscode
|
**/.vscode
|
||||||
**/.env
|
|
||||||
**/.env.test
|
|
||||||
**/.env.production
|
|
||||||
**/yarn-error.log
|
|
||||||
packages/docs
|
packages/docs
|
||||||
packages/e2e-test
|
packages/e2e-test
|
||||||
|
18
.eslintrc.js
Normal file
18
.eslintrc.js
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
module.exports = {
|
||||||
|
root: true,
|
||||||
|
parser: '@typescript-eslint/parser',
|
||||||
|
plugins: ['@typescript-eslint'],
|
||||||
|
extends: [
|
||||||
|
'eslint:recommended',
|
||||||
|
'plugin:@typescript-eslint/recommended',
|
||||||
|
'prettier',
|
||||||
|
],
|
||||||
|
overrides: [
|
||||||
|
{
|
||||||
|
files: ['**/*.test.ts', '**/test/**/*.ts'],
|
||||||
|
rules: {
|
||||||
|
'@typescript-eslint/ban-ts-comment': ['off'],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
],
|
||||||
|
};
|
53
.github/workflows/ci.yml
vendored
53
.github/workflows/ci.yml
vendored
@@ -16,15 +16,15 @@ jobs:
|
|||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
- uses: actions/setup-node@v2
|
- uses: actions/setup-node@v2
|
||||||
with:
|
with:
|
||||||
node-version: '18'
|
node-version: '16'
|
||||||
cache: 'yarn'
|
cache: 'yarn'
|
||||||
cache-dependency-path: yarn.lock
|
cache-dependency-path: yarn.lock
|
||||||
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
||||||
- run: echo "🖥️ The workflow is now ready to test your code on the runner."
|
- run: echo "🖥️ The workflow is now ready to test your code on the runner."
|
||||||
- run: yarn --frozen-lockfile
|
- run: yarn --frozen-lockfile
|
||||||
- run: cd packages/backend && yarn lint
|
- run: yarn lint
|
||||||
- run: echo "🍏 This job's status is ${{ job.status }}."
|
- run: echo "🍏 This job's status is ${{ job.status }}."
|
||||||
start-backend-server:
|
build-backend:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- run: echo "🎉 The job was automatically triggered by a ${{ github.event_name }} event."
|
- run: echo "🎉 The job was automatically triggered by a ${{ github.event_name }} event."
|
||||||
@@ -33,36 +33,13 @@ jobs:
|
|||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
- uses: actions/setup-node@v2
|
- uses: actions/setup-node@v2
|
||||||
with:
|
with:
|
||||||
node-version: '18'
|
node-version: '16'
|
||||||
cache: 'yarn'
|
cache: 'yarn'
|
||||||
cache-dependency-path: yarn.lock
|
cache-dependency-path: yarn.lock
|
||||||
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
||||||
- run: echo "🖥️ The workflow is now ready to test your code on the runner."
|
- run: echo "🖥️ The workflow is now ready to test your code on the runner."
|
||||||
- run: yarn --frozen-lockfile && yarn lerna bootstrap
|
- run: yarn --frozen-lockfile && yarn lerna bootstrap
|
||||||
- run: cd packages/backend && yarn start
|
- run: cd packages/backend && yarn build
|
||||||
env:
|
|
||||||
ENCRYPTION_KEY: sample_encryption_key
|
|
||||||
WEBHOOK_SECRET_KEY: sample_webhook_secret_key
|
|
||||||
- run: echo "🍏 This job's status is ${{ job.status }}."
|
|
||||||
start-backend-worker:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- run: echo "🎉 The job was automatically triggered by a ${{ github.event_name }} event."
|
|
||||||
- run: echo "🐧 This job is now running on a ${{ runner.os }} server hosted by GitHub!"
|
|
||||||
- run: echo "🔎 The name of your branch is ${{ github.ref }} and your repository is ${{ github.repository }}."
|
|
||||||
- uses: actions/checkout@v2
|
|
||||||
- uses: actions/setup-node@v2
|
|
||||||
with:
|
|
||||||
node-version: '18'
|
|
||||||
cache: 'yarn'
|
|
||||||
cache-dependency-path: yarn.lock
|
|
||||||
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
|
||||||
- run: echo "🖥️ The workflow is now ready to test your code on the runner."
|
|
||||||
- run: yarn --frozen-lockfile && yarn lerna bootstrap
|
|
||||||
- run: cd packages/backend && yarn start:worker
|
|
||||||
env:
|
|
||||||
ENCRYPTION_KEY: sample_encryption_key
|
|
||||||
WEBHOOK_SECRET_KEY: sample_webhook_secret_key
|
|
||||||
- run: echo "🍏 This job's status is ${{ job.status }}."
|
- run: echo "🍏 This job's status is ${{ job.status }}."
|
||||||
build-web:
|
build-web:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
@@ -73,7 +50,7 @@ jobs:
|
|||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
- uses: actions/setup-node@v2
|
- uses: actions/setup-node@v2
|
||||||
with:
|
with:
|
||||||
node-version: '18'
|
node-version: '16'
|
||||||
cache: 'yarn'
|
cache: 'yarn'
|
||||||
cache-dependency-path: yarn.lock
|
cache-dependency-path: yarn.lock
|
||||||
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
||||||
@@ -83,3 +60,21 @@ jobs:
|
|||||||
env:
|
env:
|
||||||
CI: false
|
CI: false
|
||||||
- run: echo "🍏 This job's status is ${{ job.status }}."
|
- run: echo "🍏 This job's status is ${{ job.status }}."
|
||||||
|
build-cli:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- run: echo "🎉 The job was automatically triggered by a ${{ github.event_name }} event."
|
||||||
|
- run: echo "🐧 This job is now running on a ${{ runner.os }} server hosted by GitHub!"
|
||||||
|
- run: echo "🔎 The name of your branch is ${{ github.ref }} and your repository is ${{ github.repository }}."
|
||||||
|
- uses: actions/checkout@v2
|
||||||
|
- uses: actions/setup-node@v2
|
||||||
|
with:
|
||||||
|
node-version: '16'
|
||||||
|
cache: 'yarn'
|
||||||
|
cache-dependency-path: yarn.lock
|
||||||
|
- run: echo "💡 The ${{ github.repository }} repository has been cloned to the runner."
|
||||||
|
- run: echo "🖥️ The workflow is now ready to test your code on the runner."
|
||||||
|
- run: yarn --frozen-lockfile && yarn lerna bootstrap
|
||||||
|
- run: cd packages/backend && yarn build
|
||||||
|
- run: cd packages/cli && yarn build
|
||||||
|
- run: echo "🍏 This job's status is ${{ job.status }}."
|
||||||
|
32
.github/workflows/docs-change.yml
vendored
32
.github/workflows/docs-change.yml
vendored
@@ -1,32 +0,0 @@
|
|||||||
name: Automatisch Docs Change
|
|
||||||
on:
|
|
||||||
pull_request:
|
|
||||||
paths:
|
|
||||||
- 'packages/docs/**'
|
|
||||||
jobs:
|
|
||||||
label:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Checkout repository
|
|
||||||
uses: actions/checkout@v3
|
|
||||||
- name: Label PR
|
|
||||||
uses: actions/github-script@v6
|
|
||||||
with:
|
|
||||||
script: |
|
|
||||||
const { pull_request } = context.payload;
|
|
||||||
|
|
||||||
const label = 'documentation-change';
|
|
||||||
const hasLabel = pull_request.labels.some(({ name }) => name === label);
|
|
||||||
|
|
||||||
if (!hasLabel) {
|
|
||||||
await github.rest.issues.addLabels({
|
|
||||||
owner: context.repo.owner,
|
|
||||||
repo: context.repo.repo,
|
|
||||||
issue_number: pull_request.number,
|
|
||||||
labels: [label],
|
|
||||||
});
|
|
||||||
|
|
||||||
console.log(`Label "${label}" added to PR #${pull_request.number}`);
|
|
||||||
} else {
|
|
||||||
console.log(`Label "${label}" already exists on PR #${pull_request.number}`);
|
|
||||||
}
|
|
9
.github/workflows/playwright.yml
vendored
9
.github/workflows/playwright.yml
vendored
@@ -62,15 +62,14 @@ jobs:
|
|||||||
run: yarn && yarn lerna bootstrap
|
run: yarn && yarn lerna bootstrap
|
||||||
- name: Install Playwright Browsers
|
- name: Install Playwright Browsers
|
||||||
run: yarn playwright install --with-deps
|
run: yarn playwright install --with-deps
|
||||||
- name: Build Automatisch web
|
- name: Build Automatisch
|
||||||
working-directory: ./packages/web
|
run: yarn lerna run --scope=@*/{web,backend,cli} build
|
||||||
run: yarn build
|
|
||||||
env:
|
env:
|
||||||
# Keep this until we clean up warnings in build processes
|
# Keep this until we clean up warnings in build processes
|
||||||
CI: false
|
CI: false
|
||||||
- name: Migrate database
|
- name: Migrate database
|
||||||
working-directory: ./packages/backend
|
working-directory: ./packages/backend
|
||||||
run: yarn db:migrate
|
run: yarn db:migrate --migrations-directory ./dist/src/db/migrations
|
||||||
- name: Seed user
|
- name: Seed user
|
||||||
working-directory: ./packages/backend
|
working-directory: ./packages/backend
|
||||||
run: yarn db:seed:user &
|
run: yarn db:seed:user &
|
||||||
@@ -97,7 +96,7 @@ jobs:
|
|||||||
run: yarn start &
|
run: yarn start &
|
||||||
working-directory: ./packages/backend
|
working-directory: ./packages/backend
|
||||||
- name: Run Automatisch worker
|
- name: Run Automatisch worker
|
||||||
run: yarn start:worker &
|
run: node dist/src/worker.js &
|
||||||
working-directory: ./packages/backend
|
working-directory: ./packages/backend
|
||||||
- name: Setup upterm session
|
- name: Setup upterm session
|
||||||
if: false
|
if: false
|
||||||
|
@@ -1 +1 @@
|
|||||||
18.19.0
|
16.15.0
|
||||||
|
@@ -1,25 +1,14 @@
|
|||||||
# syntax=docker/dockerfile:1
|
# syntax=docker/dockerfile:1
|
||||||
FROM node:18-alpine
|
FROM node:16-alpine
|
||||||
|
|
||||||
ENV PORT 3000
|
|
||||||
|
|
||||||
RUN \
|
|
||||||
apk --no-cache add --virtual build-dependencies python3 build-base git
|
|
||||||
|
|
||||||
WORKDIR /automatisch
|
WORKDIR /automatisch
|
||||||
|
|
||||||
# copy the app, note .dockerignore
|
|
||||||
COPY . /automatisch
|
|
||||||
|
|
||||||
RUN yarn
|
|
||||||
|
|
||||||
RUN cd packages/web && yarn build
|
|
||||||
|
|
||||||
RUN \
|
RUN \
|
||||||
|
apk --no-cache add --virtual build-dependencies python3 build-base && \
|
||||||
|
yarn global add @automatisch/cli@0.10.0 --network-timeout 1000000 && \
|
||||||
rm -rf /usr/local/share/.cache/ && \
|
rm -rf /usr/local/share/.cache/ && \
|
||||||
apk del build-dependencies
|
apk del build-dependencies
|
||||||
|
|
||||||
COPY ./docker/entrypoint.sh /entrypoint.sh
|
COPY ./entrypoint.sh /entrypoint.sh
|
||||||
|
|
||||||
EXPOSE 3000
|
EXPOSE 3000
|
||||||
ENTRYPOINT ["sh", "/entrypoint.sh"]
|
ENTRYPOINT ["sh", "/entrypoint.sh"]
|
||||||
|
19
docker/Dockerfile.cloud
Normal file
19
docker/Dockerfile.cloud
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
# syntax=docker/dockerfile:1
|
||||||
|
FROM node:16-alpine
|
||||||
|
WORKDIR /automatisch
|
||||||
|
|
||||||
|
ENV PORT 3000
|
||||||
|
|
||||||
|
RUN ls -lna
|
||||||
|
|
||||||
|
# copy the app, note .dockerignore
|
||||||
|
COPY . ./
|
||||||
|
|
||||||
|
RUN yarn
|
||||||
|
RUN yarn lerna bootstrap
|
||||||
|
RUN yarn lerna run --scope=@*/{web,backend,cli} build
|
||||||
|
|
||||||
|
COPY ./docker/entrypoint-cloud.sh /entrypoint-cloud.sh
|
||||||
|
|
||||||
|
EXPOSE 3000
|
||||||
|
ENTRYPOINT ["sh", "/entrypoint-cloud.sh"]
|
@@ -1,5 +1,5 @@
|
|||||||
# syntax=docker/dockerfile:1
|
# syntax=docker/dockerfile:1
|
||||||
FROM automatischio/automatisch:latest
|
FROM automatischio/automatisch:0.10.0
|
||||||
WORKDIR /automatisch
|
WORKDIR /automatisch
|
||||||
|
|
||||||
RUN apk add --no-cache openssl dos2unix
|
RUN apk add --no-cache openssl dos2unix
|
||||||
|
9
docker/entrypoint-cloud.sh
Executable file
9
docker/entrypoint-cloud.sh
Executable file
@@ -0,0 +1,9 @@
|
|||||||
|
#!/bin/sh
|
||||||
|
|
||||||
|
set -e
|
||||||
|
|
||||||
|
if [ -n "$WORKER" ]; then
|
||||||
|
yarn automatisch start-worker
|
||||||
|
else
|
||||||
|
yarn automatisch start
|
||||||
|
fi
|
@@ -2,12 +2,8 @@
|
|||||||
|
|
||||||
set -e
|
set -e
|
||||||
|
|
||||||
cd packages/backend
|
|
||||||
|
|
||||||
if [ -n "$WORKER" ]; then
|
if [ -n "$WORKER" ]; then
|
||||||
yarn start:worker
|
automatisch start-worker
|
||||||
else
|
else
|
||||||
yarn db:migrate
|
automatisch start
|
||||||
yarn db:seed:user
|
|
||||||
yarn start
|
|
||||||
fi
|
fi
|
||||||
|
@@ -6,6 +6,8 @@
|
|||||||
"start": "lerna run --stream --parallel --scope=@*/{web,backend} dev",
|
"start": "lerna run --stream --parallel --scope=@*/{web,backend} dev",
|
||||||
"start:web": "lerna run --stream --scope=@*/web dev",
|
"start:web": "lerna run --stream --scope=@*/web dev",
|
||||||
"start:backend": "lerna run --stream --scope=@*/backend dev",
|
"start:backend": "lerna run --stream --scope=@*/backend dev",
|
||||||
|
"lint": "lerna run --no-bail --stream --parallel --scope=@*/{web,backend,cli} lint",
|
||||||
|
"build:watch": "lerna run --no-bail --stream --parallel --scope=@*/{web,backend,cli} build:watch",
|
||||||
"build:docs": "cd ./packages/docs && yarn install && yarn build"
|
"build:docs": "cd ./packages/docs && yarn install && yarn build"
|
||||||
},
|
},
|
||||||
"workspaces": {
|
"workspaces": {
|
||||||
@@ -16,10 +18,13 @@
|
|||||||
"**/babel-loader",
|
"**/babel-loader",
|
||||||
"**/webpack",
|
"**/webpack",
|
||||||
"**/@automatisch/web",
|
"**/@automatisch/web",
|
||||||
|
"**/@automatisch/types",
|
||||||
"**/ajv"
|
"**/ajv"
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
|
"@typescript-eslint/eslint-plugin": "^5.9.1",
|
||||||
|
"@typescript-eslint/parser": "^5.9.1",
|
||||||
"eslint": "^8.13.0",
|
"eslint": "^8.13.0",
|
||||||
"eslint-config-prettier": "^8.3.0",
|
"eslint-config-prettier": "^8.3.0",
|
||||||
"eslint-plugin-prettier": "^4.0.0",
|
"eslint-plugin-prettier": "^4.0.0",
|
||||||
|
@@ -1,12 +0,0 @@
|
|||||||
{
|
|
||||||
"root": true,
|
|
||||||
"env": {
|
|
||||||
"node": true,
|
|
||||||
"es6": true
|
|
||||||
},
|
|
||||||
"extends": ["eslint:recommended", "prettier"],
|
|
||||||
"parserOptions": {
|
|
||||||
"ecmaVersion": "latest",
|
|
||||||
"sourceType": "module"
|
|
||||||
}
|
|
||||||
}
|
|
@@ -1,9 +0,0 @@
|
|||||||
import pg from 'pg';
|
|
||||||
|
|
||||||
const client = new pg.Client({
|
|
||||||
host: 'localhost',
|
|
||||||
user: 'postgres',
|
|
||||||
port: 5432,
|
|
||||||
});
|
|
||||||
|
|
||||||
export default client;
|
|
9
packages/backend/bin/database/client.ts
Normal file
9
packages/backend/bin/database/client.ts
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
import { Client } from 'pg';
|
||||||
|
|
||||||
|
const client = new Client({
|
||||||
|
host: 'localhost',
|
||||||
|
user: 'postgres',
|
||||||
|
port: 5432,
|
||||||
|
});
|
||||||
|
|
||||||
|
export default client;
|
@@ -1,31 +0,0 @@
|
|||||||
import appConfig from '../../src/config/app.js';
|
|
||||||
import logger from '../../src/helpers/logger.js';
|
|
||||||
import '../../src/config/orm.js';
|
|
||||||
import { client as knex } from '../../src/config/database.js';
|
|
||||||
|
|
||||||
export const renameMigrationsAsJsFiles = async () => {
|
|
||||||
if (!appConfig.isDev) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
const tableExists = await knex.schema.hasTable('knex_migrations');
|
|
||||||
|
|
||||||
if (tableExists) {
|
|
||||||
await knex('knex_migrations')
|
|
||||||
.where('name', 'like', '%.ts')
|
|
||||||
.update({
|
|
||||||
name: knex.raw("REPLACE(name, '.ts', '.js')"),
|
|
||||||
});
|
|
||||||
logger.info(
|
|
||||||
`Migration file names with typescript renamed as JS file names!`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
logger.error(err.message);
|
|
||||||
}
|
|
||||||
|
|
||||||
await knex.destroy();
|
|
||||||
};
|
|
||||||
|
|
||||||
renameMigrationsAsJsFiles();
|
|
@@ -1,3 +0,0 @@
|
|||||||
import { createDatabaseAndUser } from './utils.js';
|
|
||||||
|
|
||||||
createDatabaseAndUser();
|
|
3
packages/backend/bin/database/create.ts
Normal file
3
packages/backend/bin/database/create.ts
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
import { createDatabaseAndUser } from './utils';
|
||||||
|
|
||||||
|
createDatabaseAndUser();
|
@@ -1,3 +0,0 @@
|
|||||||
import { dropDatabase } from './utils.js';
|
|
||||||
|
|
||||||
dropDatabase();
|
|
3
packages/backend/bin/database/drop.ts
Normal file
3
packages/backend/bin/database/drop.ts
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
import { dropDatabase } from './utils';
|
||||||
|
|
||||||
|
dropDatabase();
|
@@ -1,3 +0,0 @@
|
|||||||
import { createUser } from './utils.js';
|
|
||||||
|
|
||||||
createUser();
|
|
3
packages/backend/bin/database/seed-user.ts
Normal file
3
packages/backend/bin/database/seed-user.ts
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
import { createUser } from './utils';
|
||||||
|
|
||||||
|
createUser();
|
@@ -1,145 +0,0 @@
|
|||||||
import appConfig from '../../src/config/app.js';
|
|
||||||
import logger from '../../src/helpers/logger.js';
|
|
||||||
import client from './client.js';
|
|
||||||
import User from '../../src/models/user.js';
|
|
||||||
import Config from '../../src/models/config.js';
|
|
||||||
import Role from '../../src/models/role.js';
|
|
||||||
import '../../src/config/orm.js';
|
|
||||||
import process from 'process';
|
|
||||||
|
|
||||||
async function fetchAdminRole() {
|
|
||||||
const role = await Role.query()
|
|
||||||
.where({
|
|
||||||
key: 'admin',
|
|
||||||
})
|
|
||||||
.limit(1)
|
|
||||||
.first();
|
|
||||||
|
|
||||||
return role;
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function createUser(
|
|
||||||
email = 'user@automatisch.io',
|
|
||||||
password = 'sample'
|
|
||||||
) {
|
|
||||||
if (appConfig.disableSeedUser) {
|
|
||||||
logger.info('Seed user is disabled.');
|
|
||||||
|
|
||||||
process.exit(0);
|
|
||||||
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const UNIQUE_VIOLATION_CODE = '23505';
|
|
||||||
|
|
||||||
const role = await fetchAdminRole();
|
|
||||||
const userParams = {
|
|
||||||
email,
|
|
||||||
password,
|
|
||||||
fullName: 'Initial admin',
|
|
||||||
roleId: role.id,
|
|
||||||
};
|
|
||||||
|
|
||||||
try {
|
|
||||||
const userCount = await User.query().resultSize();
|
|
||||||
|
|
||||||
if (userCount === 0) {
|
|
||||||
const user = await User.query().insertAndFetch(userParams);
|
|
||||||
logger.info(`User has been saved: ${user.email}`);
|
|
||||||
|
|
||||||
await Config.markInstallationCompleted();
|
|
||||||
} else {
|
|
||||||
logger.info('No need to seed a user.');
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
if (err.nativeError.code !== UNIQUE_VIOLATION_CODE) {
|
|
||||||
throw err;
|
|
||||||
}
|
|
||||||
|
|
||||||
logger.info(`User already exists: ${email}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
process.exit(0);
|
|
||||||
}
|
|
||||||
|
|
||||||
export const createDatabaseAndUser = async (
|
|
||||||
database = appConfig.postgresDatabase,
|
|
||||||
user = appConfig.postgresUsername
|
|
||||||
) => {
|
|
||||||
await client.connect();
|
|
||||||
await createDatabase(database);
|
|
||||||
await createDatabaseUser(user);
|
|
||||||
await grantPrivileges(database, user);
|
|
||||||
|
|
||||||
await client.end();
|
|
||||||
process.exit(0);
|
|
||||||
};
|
|
||||||
|
|
||||||
export const createDatabase = async (database = appConfig.postgresDatabase) => {
|
|
||||||
const DUPLICATE_DB_CODE = '42P04';
|
|
||||||
|
|
||||||
try {
|
|
||||||
await client.query(`CREATE DATABASE ${database}`);
|
|
||||||
logger.info(`Database: ${database} created!`);
|
|
||||||
} catch (err) {
|
|
||||||
if (err.code !== DUPLICATE_DB_CODE) {
|
|
||||||
throw err;
|
|
||||||
}
|
|
||||||
|
|
||||||
logger.info(`Database: ${database} already exists!`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
export const createDatabaseUser = async (user = appConfig.postgresUsername) => {
|
|
||||||
const DUPLICATE_OBJECT_CODE = '42710';
|
|
||||||
|
|
||||||
try {
|
|
||||||
const result = await client.query(`CREATE USER ${user}`);
|
|
||||||
logger.info(`Database User: ${user} created!`);
|
|
||||||
|
|
||||||
return result;
|
|
||||||
} catch (err) {
|
|
||||||
if (err.code !== DUPLICATE_OBJECT_CODE) {
|
|
||||||
throw err;
|
|
||||||
}
|
|
||||||
|
|
||||||
logger.info(`Database User: ${user} already exists!`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
export const grantPrivileges = async (
|
|
||||||
database = appConfig.postgresDatabase,
|
|
||||||
user = appConfig.postgresUsername
|
|
||||||
) => {
|
|
||||||
await client.query(
|
|
||||||
`GRANT ALL PRIVILEGES ON DATABASE ${database} TO ${user};`
|
|
||||||
);
|
|
||||||
|
|
||||||
logger.info(`${user} has granted all privileges on ${database}!`);
|
|
||||||
};
|
|
||||||
|
|
||||||
export const dropDatabase = async () => {
|
|
||||||
if (appConfig.appEnv != 'development' && appConfig.appEnv != 'test') {
|
|
||||||
const errorMessage =
|
|
||||||
'Drop database command can be used only with development or test environments!';
|
|
||||||
|
|
||||||
logger.error(errorMessage);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await client.connect();
|
|
||||||
await dropDatabaseAndUser();
|
|
||||||
|
|
||||||
await client.end();
|
|
||||||
};
|
|
||||||
|
|
||||||
export const dropDatabaseAndUser = async (
|
|
||||||
database = appConfig.postgresDatabase,
|
|
||||||
user = appConfig.postgresUsername
|
|
||||||
) => {
|
|
||||||
await client.query(`DROP DATABASE IF EXISTS ${database}`);
|
|
||||||
logger.info(`Database: ${database} removed!`);
|
|
||||||
|
|
||||||
await client.query(`DROP USER IF EXISTS ${user}`);
|
|
||||||
logger.info(`Database User: ${user} removed!`);
|
|
||||||
};
|
|
131
packages/backend/bin/database/utils.ts
Normal file
131
packages/backend/bin/database/utils.ts
Normal file
@@ -0,0 +1,131 @@
|
|||||||
|
import appConfig from '../../src/config/app';
|
||||||
|
import logger from '../../src/helpers/logger';
|
||||||
|
import client from './client';
|
||||||
|
import User from '../../src/models/user';
|
||||||
|
import Role from '../../src/models/role';
|
||||||
|
import '../../src/config/orm';
|
||||||
|
|
||||||
|
async function fetchAdminRole() {
|
||||||
|
const role = await Role
|
||||||
|
.query()
|
||||||
|
.where({
|
||||||
|
key: 'admin'
|
||||||
|
})
|
||||||
|
.limit(1)
|
||||||
|
.first();
|
||||||
|
|
||||||
|
return role;
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function createUser(
|
||||||
|
email = 'user@automatisch.io',
|
||||||
|
password = 'sample'
|
||||||
|
) {
|
||||||
|
const UNIQUE_VIOLATION_CODE = '23505';
|
||||||
|
|
||||||
|
const role = await fetchAdminRole();
|
||||||
|
const userParams = {
|
||||||
|
email,
|
||||||
|
password,
|
||||||
|
fullName: 'Initial admin',
|
||||||
|
roleId: role.id,
|
||||||
|
};
|
||||||
|
|
||||||
|
try {
|
||||||
|
const userCount = await User.query().resultSize();
|
||||||
|
|
||||||
|
if (userCount === 0) {
|
||||||
|
const user = await User.query().insertAndFetch(userParams);
|
||||||
|
logger.info(`User has been saved: ${user.email}`);
|
||||||
|
} else {
|
||||||
|
logger.info('No need to seed a user.');
|
||||||
|
}
|
||||||
|
} catch (err) {
|
||||||
|
if ((err as any).nativeError.code !== UNIQUE_VIOLATION_CODE) {
|
||||||
|
throw err;
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.info(`User already exists: ${email}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export const createDatabaseAndUser = async (
|
||||||
|
database = appConfig.postgresDatabase,
|
||||||
|
user = appConfig.postgresUsername
|
||||||
|
) => {
|
||||||
|
await client.connect();
|
||||||
|
await createDatabase(database);
|
||||||
|
await createDatabaseUser(user);
|
||||||
|
await grantPrivileges(database, user);
|
||||||
|
|
||||||
|
await client.end();
|
||||||
|
};
|
||||||
|
|
||||||
|
export const createDatabase = async (database = appConfig.postgresDatabase) => {
|
||||||
|
const DUPLICATE_DB_CODE = '42P04';
|
||||||
|
|
||||||
|
try {
|
||||||
|
await client.query(`CREATE DATABASE ${database}`);
|
||||||
|
logger.info(`Database: ${database} created!`);
|
||||||
|
} catch (err) {
|
||||||
|
if ((err as any).code !== DUPLICATE_DB_CODE) {
|
||||||
|
throw err;
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.info(`Database: ${database} already exists!`);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const createDatabaseUser = async (user = appConfig.postgresUsername) => {
|
||||||
|
const DUPLICATE_OBJECT_CODE = '42710';
|
||||||
|
|
||||||
|
try {
|
||||||
|
const result = await client.query(`CREATE USER ${user}`);
|
||||||
|
logger.info(`Database User: ${user} created!`);
|
||||||
|
|
||||||
|
return result;
|
||||||
|
} catch (err) {
|
||||||
|
if ((err as any).code !== DUPLICATE_OBJECT_CODE) {
|
||||||
|
throw err;
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.info(`Database User: ${user} already exists!`);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export const grantPrivileges = async (
|
||||||
|
database = appConfig.postgresDatabase,
|
||||||
|
user = appConfig.postgresUsername
|
||||||
|
) => {
|
||||||
|
await client.query(
|
||||||
|
`GRANT ALL PRIVILEGES ON DATABASE ${database} TO ${user};`
|
||||||
|
);
|
||||||
|
|
||||||
|
logger.info(`${user} has granted all privileges on ${database}!`);
|
||||||
|
};
|
||||||
|
|
||||||
|
export const dropDatabase = async () => {
|
||||||
|
if (appConfig.appEnv != 'development' && appConfig.appEnv != 'test') {
|
||||||
|
const errorMessage =
|
||||||
|
'Drop database command can be used only with development or test environments!';
|
||||||
|
|
||||||
|
logger.error(errorMessage);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
await client.connect();
|
||||||
|
await dropDatabaseAndUser();
|
||||||
|
|
||||||
|
await client.end();
|
||||||
|
};
|
||||||
|
|
||||||
|
export const dropDatabaseAndUser = async (
|
||||||
|
database = appConfig.postgresDatabase,
|
||||||
|
user = appConfig.postgresUsername
|
||||||
|
) => {
|
||||||
|
await client.query(`DROP DATABASE IF EXISTS ${database}`);
|
||||||
|
logger.info(`Database: ${database} removed!`);
|
||||||
|
|
||||||
|
await client.query(`DROP USER IF EXISTS ${user}`);
|
||||||
|
logger.info(`Database User: ${user} removed!`);
|
||||||
|
};
|
1
packages/backend/database-utils.d.ts
vendored
Normal file
1
packages/backend/database-utils.d.ts
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
export * from './dist/bin/database/utils';
|
2
packages/backend/database-utils.js
Normal file
2
packages/backend/database-utils.js
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
/* eslint-disable */
|
||||||
|
module.exports = require('./dist/bin/database/utils');
|
1
packages/backend/database.d.ts
vendored
Normal file
1
packages/backend/database.d.ts
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
export * from './dist/src/config/database';
|
2
packages/backend/database.js
Normal file
2
packages/backend/database.js
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
/* eslint-disable */
|
||||||
|
module.exports = require('./dist/src/config/database');
|
9
packages/backend/jest.config.js
Normal file
9
packages/backend/jest.config.js
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
/** @type {import('ts-jest').JestConfigWithTsJest} */
|
||||||
|
module.exports = {
|
||||||
|
preset: 'ts-jest',
|
||||||
|
testEnvironment: 'node',
|
||||||
|
setupFilesAfterEnv: ['./test/setup/global-hooks.ts'],
|
||||||
|
globalTeardown: './test/setup/global-teardown.ts',
|
||||||
|
collectCoverage: true,
|
||||||
|
collectCoverageFrom: ['src/graphql/queries/*.ts'],
|
||||||
|
};
|
@@ -1,33 +0,0 @@
|
|||||||
import { knexSnakeCaseMappers } from 'objection';
|
|
||||||
import appConfig from './src/config/app.js';
|
|
||||||
import path from 'path';
|
|
||||||
import { fileURLToPath } from 'url';
|
|
||||||
|
|
||||||
const fileExtension = 'js';
|
|
||||||
const __dirname = path.dirname(fileURLToPath(import.meta.url));
|
|
||||||
|
|
||||||
const knexConfig = {
|
|
||||||
client: 'pg',
|
|
||||||
connection: {
|
|
||||||
host: appConfig.postgresHost,
|
|
||||||
port: appConfig.postgresPort,
|
|
||||||
user: appConfig.postgresUsername,
|
|
||||||
password: appConfig.postgresPassword,
|
|
||||||
database: appConfig.postgresDatabase,
|
|
||||||
ssl: appConfig.postgresEnableSsl,
|
|
||||||
},
|
|
||||||
asyncStackTraces: appConfig.isDev,
|
|
||||||
searchPath: [appConfig.postgresSchema],
|
|
||||||
pool: { min: 0, max: 20 },
|
|
||||||
migrations: {
|
|
||||||
directory: __dirname + '/src/db/migrations',
|
|
||||||
extension: fileExtension,
|
|
||||||
loadExtensions: [`.${fileExtension}`],
|
|
||||||
},
|
|
||||||
seeds: {
|
|
||||||
directory: __dirname + '/src/db/seeds',
|
|
||||||
},
|
|
||||||
...(appConfig.isTest ? knexSnakeCaseMappers() : {}),
|
|
||||||
};
|
|
||||||
|
|
||||||
export default knexConfig;
|
|
30
packages/backend/knexfile.ts
Normal file
30
packages/backend/knexfile.ts
Normal file
@@ -0,0 +1,30 @@
|
|||||||
|
import { knexSnakeCaseMappers } from 'objection';
|
||||||
|
import appConfig from './src/config/app';
|
||||||
|
|
||||||
|
const fileExtension = appConfig.isDev || appConfig.isTest ? 'ts' : 'js';
|
||||||
|
|
||||||
|
const knexConfig = {
|
||||||
|
client: 'pg',
|
||||||
|
connection: {
|
||||||
|
host: appConfig.postgresHost,
|
||||||
|
port: appConfig.postgresPort,
|
||||||
|
user: appConfig.postgresUsername,
|
||||||
|
password: appConfig.postgresPassword,
|
||||||
|
database: appConfig.postgresDatabase,
|
||||||
|
ssl: appConfig.postgresEnableSsl,
|
||||||
|
},
|
||||||
|
asyncStackTraces: appConfig.isDev,
|
||||||
|
searchPath: [appConfig.postgresSchema],
|
||||||
|
pool: { min: 0, max: 20 },
|
||||||
|
migrations: {
|
||||||
|
directory: __dirname + '/src/db/migrations',
|
||||||
|
extension: fileExtension,
|
||||||
|
loadExtensions: [`.${fileExtension}`],
|
||||||
|
},
|
||||||
|
seeds: {
|
||||||
|
directory: __dirname + '/src/db/seeds',
|
||||||
|
},
|
||||||
|
...(appConfig.isTest ? knexSnakeCaseMappers() : {}),
|
||||||
|
};
|
||||||
|
|
||||||
|
export default knexConfig;
|
1
packages/backend/logger.d.ts
vendored
Normal file
1
packages/backend/logger.d.ts
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
export * from './dist/src/helpers/logger';
|
2
packages/backend/logger.js
Normal file
2
packages/backend/logger.js
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
/* eslint-disable */
|
||||||
|
module.exports = require('./dist/src/helpers/logger');
|
@@ -3,23 +3,27 @@
|
|||||||
"version": "0.10.0",
|
"version": "0.10.0",
|
||||||
"license": "See LICENSE file",
|
"license": "See LICENSE file",
|
||||||
"description": "The open source Zapier alternative. Build workflow automation without spending time and money.",
|
"description": "The open source Zapier alternative. Build workflow automation without spending time and money.",
|
||||||
"type": "module",
|
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"dev": "nodemon --watch 'src/**/*.js' --exec 'node' src/server.js",
|
"dev": "ts-node-dev --watch 'src/graphql/schema.graphql' --exit-child src/server.ts",
|
||||||
"worker": "nodemon --watch 'src/**/*.js' --exec 'node' src/worker.js",
|
"worker": "nodemon --watch 'src/**/*.ts' --exec 'ts-node' src/worker.ts",
|
||||||
"start": "node src/server.js",
|
"build": "tsc && yarn copy-statics",
|
||||||
"start:worker": "node src/worker.js",
|
"build:watch": "nodemon --watch 'src/**/*.ts' --watch 'bin/**/*.ts' --exec yarn build --ext ts",
|
||||||
"pretest": "APP_ENV=test node ./test/setup/prepare-test-env.js",
|
"start": "node dist/src/server.js",
|
||||||
"test": "APP_ENV=test vitest run",
|
"pretest": "APP_ENV=test ts-node ./test/setup/prepare-test-env.ts",
|
||||||
"lint": "eslint .",
|
"test": "APP_ENV=test jest --verbose",
|
||||||
"db:create": "node ./bin/database/create.js",
|
"lint": "eslint . --ignore-path ../../.eslintignore",
|
||||||
"db:seed:user": "node ./bin/database/seed-user.js",
|
"db:create": "ts-node ./bin/database/create.ts",
|
||||||
"db:drop": "node ./bin/database/drop.js",
|
"db:seed:user": "ts-node ./bin/database/seed-user.ts",
|
||||||
|
"db:drop": "ts-node ./bin/database/drop.ts",
|
||||||
"db:migration:create": "knex migrate:make",
|
"db:migration:create": "knex migrate:make",
|
||||||
"db:rollback": "knex migrate:rollback",
|
"db:rollback": "knex migrate:rollback",
|
||||||
"db:migrate": "node ./bin/database/convert-migrations.js && knex migrate:latest"
|
"db:migrate": "knex migrate:latest",
|
||||||
|
"copy-statics": "copyfiles src/**/*.{graphql,json,svg,hbs} dist",
|
||||||
|
"prepack": "yarn build",
|
||||||
|
"prebuild": "rm -rf ./dist"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
"@automatisch/web": "^0.10.0",
|
||||||
"@bull-board/express": "^3.10.1",
|
"@bull-board/express": "^3.10.1",
|
||||||
"@casl/ability": "^6.5.0",
|
"@casl/ability": "^6.5.0",
|
||||||
"@graphql-tools/graphql-file-loader": "^7.3.4",
|
"@graphql-tools/graphql-file-loader": "^7.3.4",
|
||||||
@@ -28,23 +32,28 @@
|
|||||||
"@rudderstack/rudder-sdk-node": "^1.1.2",
|
"@rudderstack/rudder-sdk-node": "^1.1.2",
|
||||||
"@sentry/node": "^7.42.0",
|
"@sentry/node": "^7.42.0",
|
||||||
"@sentry/tracing": "^7.42.0",
|
"@sentry/tracing": "^7.42.0",
|
||||||
|
"@types/accounting": "^0.4.2",
|
||||||
|
"@types/luxon": "^2.3.1",
|
||||||
|
"@types/passport": "^1.0.12",
|
||||||
|
"@types/xmlrpc": "^1.3.7",
|
||||||
"accounting": "^0.4.1",
|
"accounting": "^0.4.1",
|
||||||
"ajv-formats": "^2.1.1",
|
"ajv-formats": "^2.1.1",
|
||||||
"axios": "1.6.0",
|
"axios": "1.6.0",
|
||||||
"bcrypt": "^5.1.0",
|
"bcrypt": "^5.0.1",
|
||||||
"bullmq": "^3.0.0",
|
"bullmq": "^3.0.0",
|
||||||
|
"copyfiles": "^2.4.1",
|
||||||
"cors": "^2.8.5",
|
"cors": "^2.8.5",
|
||||||
"crypto-js": "^4.1.1",
|
"crypto-js": "^4.1.1",
|
||||||
"debug": "~2.6.9",
|
"debug": "~2.6.9",
|
||||||
"dotenv": "^10.0.0",
|
"dotenv": "^10.0.0",
|
||||||
"express": "~4.18.2",
|
"express": "~4.18.2",
|
||||||
"express-async-handler": "^1.2.0",
|
|
||||||
"express-basic-auth": "^1.2.1",
|
"express-basic-auth": "^1.2.1",
|
||||||
"express-graphql": "^0.12.0",
|
"express-graphql": "^0.12.0",
|
||||||
"fast-xml-parser": "^4.0.11",
|
"fast-xml-parser": "^4.0.11",
|
||||||
"graphql-middleware": "^6.1.15",
|
"graphql-middleware": "^6.1.15",
|
||||||
"graphql-shield": "^7.5.0",
|
"graphql-shield": "^7.5.0",
|
||||||
"graphql-tools": "^8.2.0",
|
"graphql-tools": "^8.2.0",
|
||||||
|
"graphql-type-json": "^0.3.2",
|
||||||
"handlebars": "^4.7.7",
|
"handlebars": "^4.7.7",
|
||||||
"http-errors": "~1.6.3",
|
"http-errors": "~1.6.3",
|
||||||
"http-proxy-agent": "^7.0.0",
|
"http-proxy-agent": "^7.0.0",
|
||||||
@@ -67,7 +76,7 @@
|
|||||||
"pluralize": "^8.0.0",
|
"pluralize": "^8.0.0",
|
||||||
"raw-body": "^2.5.2",
|
"raw-body": "^2.5.2",
|
||||||
"showdown": "^2.1.0",
|
"showdown": "^2.1.0",
|
||||||
"uuid": "^9.0.1",
|
"stripe": "^11.13.0",
|
||||||
"winston": "^3.7.1",
|
"winston": "^3.7.1",
|
||||||
"xmlrpc": "^1.3.2"
|
"xmlrpc": "^1.3.2"
|
||||||
},
|
},
|
||||||
@@ -78,15 +87,26 @@
|
|||||||
}
|
}
|
||||||
],
|
],
|
||||||
"homepage": "https://github.com/automatisch/automatisch#readme",
|
"homepage": "https://github.com/automatisch/automatisch#readme",
|
||||||
"main": "src/server",
|
"main": "dist/src/app",
|
||||||
"directories": {
|
"directories": {
|
||||||
"bin": "bin",
|
"bin": "bin",
|
||||||
"src": "src",
|
"src": "src",
|
||||||
"test": "__tests__"
|
"test": "__tests__"
|
||||||
},
|
},
|
||||||
"files": [
|
"files": [
|
||||||
|
"dist",
|
||||||
"bin",
|
"bin",
|
||||||
"src"
|
"src",
|
||||||
|
"server.js",
|
||||||
|
"server.d.ts",
|
||||||
|
"worker.js",
|
||||||
|
"worker.d.ts",
|
||||||
|
"logger.js",
|
||||||
|
"logger.d.ts",
|
||||||
|
"database.js",
|
||||||
|
"database.d.ts",
|
||||||
|
"database-utils.js",
|
||||||
|
"database-utils.d.ts"
|
||||||
],
|
],
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@@ -96,10 +116,34 @@
|
|||||||
"url": "https://github.com/automatisch/automatisch/issues"
|
"url": "https://github.com/automatisch/automatisch/issues"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"node-gyp": "^10.1.0",
|
"@automatisch/types": "^0.10.0",
|
||||||
|
"@faker-js/faker": "^8.1.0",
|
||||||
|
"@types/bcrypt": "^5.0.0",
|
||||||
|
"@types/bull": "^3.15.8",
|
||||||
|
"@types/cors": "^2.8.12",
|
||||||
|
"@types/crypto-js": "^4.0.2",
|
||||||
|
"@types/express": "^4.17.15",
|
||||||
|
"@types/http-errors": "^1.8.1",
|
||||||
|
"@types/jest": "^29.5.5",
|
||||||
|
"@types/jsonwebtoken": "^8.5.8",
|
||||||
|
"@types/lodash.get": "^4.4.6",
|
||||||
|
"@types/memory-cache": "^0.2.2",
|
||||||
|
"@types/morgan": "^1.9.3",
|
||||||
|
"@types/multer": "1.4.7",
|
||||||
|
"@types/node": "^16.10.2",
|
||||||
|
"@types/nodemailer": "^6.4.4",
|
||||||
|
"@types/pg": "^8.6.1",
|
||||||
|
"@types/pino": "^7.0.5",
|
||||||
|
"@types/pluralize": "^0.0.30",
|
||||||
|
"@types/showdown": "^2.0.1",
|
||||||
|
"@types/supertest": "^2.0.14",
|
||||||
|
"jest": "^29.7.0",
|
||||||
"nodemon": "^2.0.13",
|
"nodemon": "^2.0.13",
|
||||||
|
"sinon": "^11.1.2",
|
||||||
"supertest": "^6.3.3",
|
"supertest": "^6.3.3",
|
||||||
"vitest": "^1.1.3"
|
"ts-jest": "^29.1.1",
|
||||||
|
"ts-node": "^10.2.1",
|
||||||
|
"ts-node-dev": "^1.1.8"
|
||||||
},
|
},
|
||||||
"publishConfig": {
|
"publishConfig": {
|
||||||
"access": "public"
|
"access": "public"
|
||||||
|
1
packages/backend/server.d.ts
vendored
Normal file
1
packages/backend/server.d.ts
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
export * from './dist/src/server';
|
2
packages/backend/server.js
Normal file
2
packages/backend/server.js
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
/* eslint-disable */
|
||||||
|
module.exports = require('./dist/src/server.js');
|
@@ -1,70 +0,0 @@
|
|||||||
import createError from 'http-errors';
|
|
||||||
import express from 'express';
|
|
||||||
import cors from 'cors';
|
|
||||||
|
|
||||||
import appConfig from './config/app.js';
|
|
||||||
import corsOptions from './config/cors-options.js';
|
|
||||||
import morgan from './helpers/morgan.js';
|
|
||||||
import * as Sentry from './helpers/sentry.ee.js';
|
|
||||||
import appAssetsHandler from './helpers/app-assets-handler.js';
|
|
||||||
import webUIHandler from './helpers/web-ui-handler.js';
|
|
||||||
import errorHandler from './helpers/error-handler.js';
|
|
||||||
import './config/orm.js';
|
|
||||||
import {
|
|
||||||
createBullBoardHandler,
|
|
||||||
serverAdapter,
|
|
||||||
} from './helpers/create-bull-board-handler.js';
|
|
||||||
import injectBullBoardHandler from './helpers/inject-bull-board-handler.js';
|
|
||||||
import router from './routes/index.js';
|
|
||||||
import configurePassport from './helpers/passport.js';
|
|
||||||
|
|
||||||
createBullBoardHandler(serverAdapter);
|
|
||||||
|
|
||||||
const app = express();
|
|
||||||
|
|
||||||
Sentry.init(app);
|
|
||||||
|
|
||||||
Sentry.attachRequestHandler(app);
|
|
||||||
Sentry.attachTracingHandler(app);
|
|
||||||
|
|
||||||
injectBullBoardHandler(app, serverAdapter);
|
|
||||||
|
|
||||||
appAssetsHandler(app);
|
|
||||||
|
|
||||||
app.use(morgan);
|
|
||||||
|
|
||||||
app.use(
|
|
||||||
express.json({
|
|
||||||
limit: appConfig.requestBodySizeLimit,
|
|
||||||
verify(req, res, buf) {
|
|
||||||
req.rawBody = buf;
|
|
||||||
},
|
|
||||||
})
|
|
||||||
);
|
|
||||||
app.use(
|
|
||||||
express.urlencoded({
|
|
||||||
extended: true,
|
|
||||||
limit: appConfig.requestBodySizeLimit,
|
|
||||||
verify(req, res, buf) {
|
|
||||||
req.rawBody = buf;
|
|
||||||
},
|
|
||||||
})
|
|
||||||
);
|
|
||||||
app.use(cors(corsOptions));
|
|
||||||
|
|
||||||
configurePassport(app);
|
|
||||||
|
|
||||||
app.use('/', router);
|
|
||||||
|
|
||||||
webUIHandler(app);
|
|
||||||
|
|
||||||
// catch 404 and forward to error handler
|
|
||||||
app.use(function (req, res, next) {
|
|
||||||
next(createError(404));
|
|
||||||
});
|
|
||||||
|
|
||||||
Sentry.attachErrorHandler(app);
|
|
||||||
|
|
||||||
app.use(errorHandler);
|
|
||||||
|
|
||||||
export default app;
|
|
71
packages/backend/src/app.ts
Normal file
71
packages/backend/src/app.ts
Normal file
@@ -0,0 +1,71 @@
|
|||||||
|
import createError from 'http-errors';
|
||||||
|
import express from 'express';
|
||||||
|
import cors from 'cors';
|
||||||
|
|
||||||
|
import { IRequest } from '@automatisch/types';
|
||||||
|
import appConfig from './config/app';
|
||||||
|
import corsOptions from './config/cors-options';
|
||||||
|
import morgan from './helpers/morgan';
|
||||||
|
import * as Sentry from './helpers/sentry.ee';
|
||||||
|
import appAssetsHandler from './helpers/app-assets-handler';
|
||||||
|
import webUIHandler from './helpers/web-ui-handler';
|
||||||
|
import errorHandler from './helpers/error-handler';
|
||||||
|
import './config/orm';
|
||||||
|
import {
|
||||||
|
createBullBoardHandler,
|
||||||
|
serverAdapter,
|
||||||
|
} from './helpers/create-bull-board-handler';
|
||||||
|
import injectBullBoardHandler from './helpers/inject-bull-board-handler';
|
||||||
|
import router from './routes';
|
||||||
|
import configurePassport from './helpers/passport';
|
||||||
|
|
||||||
|
createBullBoardHandler(serverAdapter);
|
||||||
|
|
||||||
|
const app = express();
|
||||||
|
|
||||||
|
Sentry.init(app);
|
||||||
|
|
||||||
|
Sentry.attachRequestHandler(app);
|
||||||
|
Sentry.attachTracingHandler(app);
|
||||||
|
|
||||||
|
injectBullBoardHandler(app, serverAdapter);
|
||||||
|
|
||||||
|
appAssetsHandler(app);
|
||||||
|
|
||||||
|
app.use(morgan);
|
||||||
|
|
||||||
|
app.use(
|
||||||
|
express.json({
|
||||||
|
limit: appConfig.requestBodySizeLimit,
|
||||||
|
verify(req, res, buf) {
|
||||||
|
(req as IRequest).rawBody = buf;
|
||||||
|
},
|
||||||
|
})
|
||||||
|
);
|
||||||
|
app.use(
|
||||||
|
express.urlencoded({
|
||||||
|
extended: true,
|
||||||
|
limit: appConfig.requestBodySizeLimit,
|
||||||
|
verify(req, res, buf) {
|
||||||
|
(req as IRequest).rawBody = buf;
|
||||||
|
},
|
||||||
|
})
|
||||||
|
);
|
||||||
|
app.use(cors(corsOptions));
|
||||||
|
|
||||||
|
configurePassport(app);
|
||||||
|
|
||||||
|
app.use('/', router);
|
||||||
|
|
||||||
|
webUIHandler(app);
|
||||||
|
|
||||||
|
// catch 404 and forward to error handler
|
||||||
|
app.use(function (req, res, next) {
|
||||||
|
next(createError(404));
|
||||||
|
});
|
||||||
|
|
||||||
|
Sentry.attachErrorHandler(app);
|
||||||
|
|
||||||
|
app.use(errorHandler);
|
||||||
|
|
||||||
|
export default app;
|
@@ -1,3 +0,0 @@
|
|||||||
import sendPrompt from './send-prompt/index.js';
|
|
||||||
|
|
||||||
export default [sendPrompt];
|
|
3
packages/backend/src/apps/azure-openai/actions/index.ts
Normal file
3
packages/backend/src/apps/azure-openai/actions/index.ts
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
import sendPrompt from './send-prompt';
|
||||||
|
|
||||||
|
export default [sendPrompt];
|
@@ -1,97 +0,0 @@
|
|||||||
import defineAction from '../../../../helpers/define-action.js';
|
|
||||||
|
|
||||||
const castFloatOrUndefined = (value) => {
|
|
||||||
return value === '' ? undefined : parseFloat(value);
|
|
||||||
};
|
|
||||||
|
|
||||||
export default defineAction({
|
|
||||||
name: 'Send prompt',
|
|
||||||
key: 'sendPrompt',
|
|
||||||
description: 'Creates a completion for the provided prompt and parameters.',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Prompt',
|
|
||||||
key: 'prompt',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
variables: true,
|
|
||||||
description: 'The text to analyze.',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Temperature',
|
|
||||||
key: 'temperature',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description:
|
|
||||||
'What sampling temperature to use, between 0 and 2. Higher values means the model will take more risks. Try 0.9 for more creative applications, and 0 (argmax sampling) for ones with a well-defined answer. We generally recommend altering this or Top P but not both.',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Maximum tokens',
|
|
||||||
key: 'maxTokens',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description:
|
|
||||||
'The maximum number of tokens to generate in the completion.',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Stop Sequence',
|
|
||||||
key: 'stopSequence',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description:
|
|
||||||
'Single stop sequence where the API will stop generating further tokens. The returned text will not contain the stop sequence.',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Top P',
|
|
||||||
key: 'topP',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description:
|
|
||||||
'An alternative to sampling with temperature, called nucleus sampling, where the model considers the results of the tokens with top_p probability mass. So 0.1 means only the tokens comprising the top 10% probability mass are considered. We generally recommend altering this or temperature but not both.',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Frequency Penalty',
|
|
||||||
key: 'frequencyPenalty',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description: `Number between -2.0 and 2.0. Positive values penalize new tokens based on their existing frequency in the text so far, decreasing the model's likelihood to repeat the same line verbatim.`,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Presence Penalty',
|
|
||||||
key: 'presencePenalty',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description: `Number between -2.0 and 2.0. Positive values penalize new tokens based on whether they appear in the text so far, increasing the model's likelihood to talk about new topics.`,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const payload = {
|
|
||||||
model: $.step.parameters.model,
|
|
||||||
prompt: $.step.parameters.prompt,
|
|
||||||
temperature: castFloatOrUndefined($.step.parameters.temperature),
|
|
||||||
max_tokens: castFloatOrUndefined($.step.parameters.maxTokens),
|
|
||||||
stop: $.step.parameters.stopSequence || null,
|
|
||||||
top_p: castFloatOrUndefined($.step.parameters.topP),
|
|
||||||
frequency_penalty: castFloatOrUndefined(
|
|
||||||
$.step.parameters.frequencyPenalty
|
|
||||||
),
|
|
||||||
presence_penalty: castFloatOrUndefined($.step.parameters.presencePenalty),
|
|
||||||
};
|
|
||||||
|
|
||||||
const { data } = await $.http.post(
|
|
||||||
`/deployments/${$.auth.data.deploymentId}/completions`,
|
|
||||||
payload
|
|
||||||
);
|
|
||||||
|
|
||||||
$.setActionItem({
|
|
||||||
raw: data,
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
@@ -0,0 +1,87 @@
|
|||||||
|
import defineAction from '../../../../helpers/define-action';
|
||||||
|
|
||||||
|
const castFloatOrUndefined = (value: string | null) => {
|
||||||
|
return value === '' ? undefined : parseFloat(value);
|
||||||
|
}
|
||||||
|
|
||||||
|
export default defineAction({
|
||||||
|
name: 'Send prompt',
|
||||||
|
key: 'sendPrompt',
|
||||||
|
description: 'Creates a completion for the provided prompt and parameters.',
|
||||||
|
arguments: [
|
||||||
|
{
|
||||||
|
label: 'Prompt',
|
||||||
|
key: 'prompt',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
variables: true,
|
||||||
|
description: 'The text to analyze.'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Temperature',
|
||||||
|
key: 'temperature',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: false,
|
||||||
|
variables: true,
|
||||||
|
description: 'What sampling temperature to use, between 0 and 2. Higher values means the model will take more risks. Try 0.9 for more creative applications, and 0 (argmax sampling) for ones with a well-defined answer. We generally recommend altering this or Top P but not both.'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Maximum tokens',
|
||||||
|
key: 'maxTokens',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: false,
|
||||||
|
variables: true,
|
||||||
|
description: 'The maximum number of tokens to generate in the completion.'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Stop Sequence',
|
||||||
|
key: 'stopSequence',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: false,
|
||||||
|
variables: true,
|
||||||
|
description: 'Single stop sequence where the API will stop generating further tokens. The returned text will not contain the stop sequence.'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Top P',
|
||||||
|
key: 'topP',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: false,
|
||||||
|
variables: true,
|
||||||
|
description: 'An alternative to sampling with temperature, called nucleus sampling, where the model considers the results of the tokens with top_p probability mass. So 0.1 means only the tokens comprising the top 10% probability mass are considered. We generally recommend altering this or temperature but not both.'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Frequency Penalty',
|
||||||
|
key: 'frequencyPenalty',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: false,
|
||||||
|
variables: true,
|
||||||
|
description: `Number between -2.0 and 2.0. Positive values penalize new tokens based on their existing frequency in the text so far, decreasing the model's likelihood to repeat the same line verbatim.`
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Presence Penalty',
|
||||||
|
key: 'presencePenalty',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: false,
|
||||||
|
variables: true,
|
||||||
|
description: `Number between -2.0 and 2.0. Positive values penalize new tokens based on whether they appear in the text so far, increasing the model's likelihood to talk about new topics.`
|
||||||
|
},
|
||||||
|
],
|
||||||
|
|
||||||
|
async run($) {
|
||||||
|
const payload = {
|
||||||
|
model: $.step.parameters.model as string,
|
||||||
|
prompt: $.step.parameters.prompt as string,
|
||||||
|
temperature: castFloatOrUndefined($.step.parameters.temperature as string),
|
||||||
|
max_tokens: castFloatOrUndefined($.step.parameters.maxTokens as string),
|
||||||
|
stop: ($.step.parameters.stopSequence as string || null),
|
||||||
|
top_p: castFloatOrUndefined($.step.parameters.topP as string),
|
||||||
|
frequency_penalty: castFloatOrUndefined($.step.parameters.frequencyPenalty as string),
|
||||||
|
presence_penalty: castFloatOrUndefined($.step.parameters.presencePenalty as string),
|
||||||
|
};
|
||||||
|
const { data } = await $.http.post(`/deployments/${$.auth.data.deploymentId}/completions`, payload);
|
||||||
|
|
||||||
|
$.setActionItem({
|
||||||
|
raw: data,
|
||||||
|
});
|
||||||
|
},
|
||||||
|
});
|
@@ -1,58 +0,0 @@
|
|||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
import isStillVerified from './is-still-verified.js';
|
|
||||||
|
|
||||||
export default {
|
|
||||||
fields: [
|
|
||||||
{
|
|
||||||
key: 'screenName',
|
|
||||||
label: 'Screen Name',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description:
|
|
||||||
'Screen name of your connection to be used on Automatisch UI.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'yourResourceName',
|
|
||||||
label: 'Your Resource Name',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'The name of your Azure OpenAI Resource.',
|
|
||||||
docUrl: 'https://automatisch.io/docs/azure-openai#your-resource-name',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'deploymentId',
|
|
||||||
label: 'Deployment ID',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'The deployment name you chose when you deployed the model.',
|
|
||||||
docUrl: 'https://automatisch.io/docs/azure-openai#deployment-id',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'apiKey',
|
|
||||||
label: 'API Key',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'Azure OpenAI API key of your account.',
|
|
||||||
docUrl: 'https://automatisch.io/docs/azure-openai#api-key',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
verifyCredentials,
|
|
||||||
isStillVerified,
|
|
||||||
};
|
|
58
packages/backend/src/apps/azure-openai/auth/index.ts
Normal file
58
packages/backend/src/apps/azure-openai/auth/index.ts
Normal file
@@ -0,0 +1,58 @@
|
|||||||
|
import verifyCredentials from './verify-credentials';
|
||||||
|
import isStillVerified from './is-still-verified';
|
||||||
|
|
||||||
|
export default {
|
||||||
|
fields: [
|
||||||
|
{
|
||||||
|
key: 'screenName',
|
||||||
|
label: 'Screen Name',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description:
|
||||||
|
'Screen name of your connection to be used on Automatisch UI.',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
key: 'yourResourceName',
|
||||||
|
label: 'Your Resource Name',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description: 'The name of your Azure OpenAI Resource.',
|
||||||
|
docUrl: 'https://automatisch.io/docs/azure-openai#your-resource-name',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
key: 'deploymentId',
|
||||||
|
label: 'Deployment ID',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description: 'The deployment name you chose when you deployed the model.',
|
||||||
|
docUrl: 'https://automatisch.io/docs/azure-openai#deployment-id',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
key: 'apiKey',
|
||||||
|
label: 'API Key',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description: 'Azure OpenAI API key of your account.',
|
||||||
|
docUrl: 'https://automatisch.io/docs/azure-openai#api-key',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
|
||||||
|
verifyCredentials,
|
||||||
|
isStillVerified,
|
||||||
|
};
|
@@ -1,6 +0,0 @@
|
|||||||
const isStillVerified = async ($) => {
|
|
||||||
await $.http.get('/fine_tuning/jobs');
|
|
||||||
return true;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default isStillVerified;
|
|
@@ -0,0 +1,8 @@
|
|||||||
|
import { IGlobalVariable } from '@automatisch/types';
|
||||||
|
|
||||||
|
const isStillVerified = async ($: IGlobalVariable) => {
|
||||||
|
await $.http.get('/fine_tuning/jobs');
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default isStillVerified;
|
@@ -1,5 +0,0 @@
|
|||||||
const verifyCredentials = async ($) => {
|
|
||||||
await $.http.get('/fine_tuning/jobs');
|
|
||||||
};
|
|
||||||
|
|
||||||
export default verifyCredentials;
|
|
@@ -0,0 +1,7 @@
|
|||||||
|
import { IGlobalVariable } from '@automatisch/types';
|
||||||
|
|
||||||
|
const verifyCredentials = async ($: IGlobalVariable) => {
|
||||||
|
await $.http.get('/fine_tuning/jobs');
|
||||||
|
};
|
||||||
|
|
||||||
|
export default verifyCredentials;
|
@@ -1,13 +0,0 @@
|
|||||||
const addAuthHeader = ($, requestConfig) => {
|
|
||||||
if ($.auth.data?.apiKey) {
|
|
||||||
requestConfig.headers['api-key'] = $.auth.data.apiKey;
|
|
||||||
}
|
|
||||||
|
|
||||||
requestConfig.params = {
|
|
||||||
'api-version': '2023-10-01-preview',
|
|
||||||
};
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default addAuthHeader;
|
|
@@ -0,0 +1,15 @@
|
|||||||
|
import { TBeforeRequest } from '@automatisch/types';
|
||||||
|
|
||||||
|
const addAuthHeader: TBeforeRequest = ($, requestConfig) => {
|
||||||
|
if ($.auth.data?.apiKey) {
|
||||||
|
requestConfig.headers['api-key'] = $.auth.data.apiKey as string;
|
||||||
|
}
|
||||||
|
|
||||||
|
requestConfig.params = {
|
||||||
|
'api-version': '2023-10-01-preview'
|
||||||
|
}
|
||||||
|
|
||||||
|
return requestConfig;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default addAuthHeader;
|
@@ -1,11 +0,0 @@
|
|||||||
const setBaseUrl = ($, requestConfig) => {
|
|
||||||
const yourResourceName = $.auth.data.yourResourceName;
|
|
||||||
|
|
||||||
if (yourResourceName) {
|
|
||||||
requestConfig.baseURL = `https://${yourResourceName}.openai.azure.com/openai`;
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default setBaseUrl;
|
|
@@ -0,0 +1,13 @@
|
|||||||
|
import { TBeforeRequest } from '@automatisch/types';
|
||||||
|
|
||||||
|
const setBaseUrl: TBeforeRequest = ($, requestConfig) => {
|
||||||
|
const yourResourceName = $.auth.data.yourResourceName as string;
|
||||||
|
|
||||||
|
if (yourResourceName) {
|
||||||
|
requestConfig.baseURL = `https://${yourResourceName}.openai.azure.com/openai`;
|
||||||
|
}
|
||||||
|
|
||||||
|
return requestConfig;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default setBaseUrl;
|
0
packages/backend/src/apps/azure-openai/index.d.ts
vendored
Normal file
0
packages/backend/src/apps/azure-openai/index.d.ts
vendored
Normal file
@@ -1,20 +0,0 @@
|
|||||||
import defineApp from '../../helpers/define-app.js';
|
|
||||||
import setBaseUrl from './common/set-base-url.js';
|
|
||||||
import addAuthHeader from './common/add-auth-header.js';
|
|
||||||
import auth from './auth/index.js';
|
|
||||||
import actions from './actions/index.js';
|
|
||||||
|
|
||||||
export default defineApp({
|
|
||||||
name: 'Azure OpenAI',
|
|
||||||
key: 'azure-openai',
|
|
||||||
baseUrl:
|
|
||||||
'https://azure.microsoft.com/en-us/products/ai-services/openai-service',
|
|
||||||
apiBaseUrl: '',
|
|
||||||
iconUrl: '{BASE_URL}/apps/azure-openai/assets/favicon.svg',
|
|
||||||
authDocUrl: '{DOCS_URL}/apps/azure-openai/connection',
|
|
||||||
primaryColor: '000000',
|
|
||||||
supportsConnections: true,
|
|
||||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
|
||||||
auth,
|
|
||||||
actions,
|
|
||||||
});
|
|
19
packages/backend/src/apps/azure-openai/index.ts
Normal file
19
packages/backend/src/apps/azure-openai/index.ts
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
import defineApp from '../../helpers/define-app';
|
||||||
|
import setBaseUrl from './common/set-base-url';
|
||||||
|
import addAuthHeader from './common/add-auth-header';
|
||||||
|
import auth from './auth';
|
||||||
|
import actions from './actions';
|
||||||
|
|
||||||
|
export default defineApp({
|
||||||
|
name: 'Azure OpenAI',
|
||||||
|
key: 'azure-openai',
|
||||||
|
baseUrl: 'https://azure.microsoft.com/en-us/products/ai-services/openai-service',
|
||||||
|
apiBaseUrl: '',
|
||||||
|
iconUrl: '{BASE_URL}/apps/azure-openai/assets/favicon.svg',
|
||||||
|
authDocUrl: 'https://automatisch.io/docs/apps/azure-openai/connection',
|
||||||
|
primaryColor: '000000',
|
||||||
|
supportsConnections: true,
|
||||||
|
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||||
|
auth,
|
||||||
|
actions,
|
||||||
|
});
|
@@ -1,35 +0,0 @@
|
|||||||
import defineAction from '../../../../helpers/define-action.js';
|
|
||||||
|
|
||||||
export default defineAction({
|
|
||||||
name: 'Add Template',
|
|
||||||
key: 'addTemplate',
|
|
||||||
description:
|
|
||||||
'Creates an attachment of a specified object by given parent ID.',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Templete Data',
|
|
||||||
key: 'templateData',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
variables: true,
|
|
||||||
description: 'The content of your new Template in XML/HTML format.',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const templateData = $.step.parameters.templateData;
|
|
||||||
|
|
||||||
const base64Data = Buffer.from(templateData).toString('base64');
|
|
||||||
const dataURI = `data:application/xml;base64,${base64Data}`;
|
|
||||||
|
|
||||||
const body = JSON.stringify({ template: dataURI });
|
|
||||||
|
|
||||||
const response = await $.http.post('/template', body, {
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/json',
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
$.setActionItem({ raw: response.data });
|
|
||||||
},
|
|
||||||
});
|
|
@@ -0,0 +1,35 @@
|
|||||||
|
import defineAction from '../../../../helpers/define-action';
|
||||||
|
|
||||||
|
export default defineAction({
|
||||||
|
name: 'Add Template',
|
||||||
|
key: 'addTemplate',
|
||||||
|
description:
|
||||||
|
'Creates an attachment of a specified object by given parent ID.',
|
||||||
|
arguments: [
|
||||||
|
{
|
||||||
|
label: 'Templete Data',
|
||||||
|
key: 'templateData',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
variables: true,
|
||||||
|
description: 'The content of your new Template in XML/HTML format.',
|
||||||
|
},
|
||||||
|
],
|
||||||
|
|
||||||
|
async run($) {
|
||||||
|
const templateData = $.step.parameters.templateData as string;
|
||||||
|
|
||||||
|
const base64Data = Buffer.from(templateData).toString('base64');
|
||||||
|
const dataURI = `data:application/xml;base64,${base64Data}`;
|
||||||
|
|
||||||
|
const body = JSON.stringify({ template: dataURI });
|
||||||
|
|
||||||
|
const response = await $.http.post('/template', body, {
|
||||||
|
headers: {
|
||||||
|
'Content-Type': 'application/json',
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
$.setActionItem({ raw: response.data });
|
||||||
|
},
|
||||||
|
});
|
@@ -1,3 +0,0 @@
|
|||||||
import addTemplate from './add-template/index.js';
|
|
||||||
|
|
||||||
export default [addTemplate];
|
|
3
packages/backend/src/apps/carbone/actions/index.ts
Normal file
3
packages/backend/src/apps/carbone/actions/index.ts
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
import addTemplate from './add-template';
|
||||||
|
|
||||||
|
export default [addTemplate];
|
@@ -1,33 +0,0 @@
|
|||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
import isStillVerified from './is-still-verified.js';
|
|
||||||
|
|
||||||
export default {
|
|
||||||
fields: [
|
|
||||||
{
|
|
||||||
key: 'screenName',
|
|
||||||
label: 'Screen Name',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description:
|
|
||||||
'Screen name of your connection to be used on Automatisch UI.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'apiKey',
|
|
||||||
label: 'API Key',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'Carbone API key of your account.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
verifyCredentials,
|
|
||||||
isStillVerified,
|
|
||||||
};
|
|
33
packages/backend/src/apps/carbone/auth/index.ts
Normal file
33
packages/backend/src/apps/carbone/auth/index.ts
Normal file
@@ -0,0 +1,33 @@
|
|||||||
|
import verifyCredentials from './verify-credentials';
|
||||||
|
import isStillVerified from './is-still-verified';
|
||||||
|
|
||||||
|
export default {
|
||||||
|
fields: [
|
||||||
|
{
|
||||||
|
key: 'screenName',
|
||||||
|
label: 'Screen Name',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description:
|
||||||
|
'Screen name of your connection to be used on Automatisch UI.',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
key: 'apiKey',
|
||||||
|
label: 'API Key',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description: 'Carbone API key of your account.',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
|
||||||
|
verifyCredentials,
|
||||||
|
isStillVerified,
|
||||||
|
};
|
@@ -1,8 +0,0 @@
|
|||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
|
|
||||||
const isStillVerified = async ($) => {
|
|
||||||
await verifyCredentials($);
|
|
||||||
return true;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default isStillVerified;
|
|
@@ -0,0 +1,9 @@
|
|||||||
|
import { IGlobalVariable } from '@automatisch/types';
|
||||||
|
import verifyCredentials from './verify-credentials';
|
||||||
|
|
||||||
|
const isStillVerified = async ($: IGlobalVariable) => {
|
||||||
|
await verifyCredentials($);
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default isStillVerified;
|
@@ -1,10 +0,0 @@
|
|||||||
const verifyCredentials = async ($) => {
|
|
||||||
await $.http.get('/templates');
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
screenName: $.auth.data.screenName,
|
|
||||||
apiKey: $.auth.data.apiKey,
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
export default verifyCredentials;
|
|
12
packages/backend/src/apps/carbone/auth/verify-credentials.ts
Normal file
12
packages/backend/src/apps/carbone/auth/verify-credentials.ts
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
import { IGlobalVariable } from '@automatisch/types';
|
||||||
|
|
||||||
|
const verifyCredentials = async ($: IGlobalVariable) => {
|
||||||
|
await $.http.get('/templates');
|
||||||
|
|
||||||
|
await $.auth.set({
|
||||||
|
screenName: $.auth.data.screenName,
|
||||||
|
apiKey: $.auth.data.apiKey,
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
export default verifyCredentials;
|
@@ -1,10 +0,0 @@
|
|||||||
const addAuthHeader = ($, requestConfig) => {
|
|
||||||
if ($.auth.data?.apiKey) {
|
|
||||||
requestConfig.headers.Authorization = `Bearer ${$.auth.data.apiKey}`;
|
|
||||||
requestConfig.headers['carbone-version'] = '4';
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default addAuthHeader;
|
|
12
packages/backend/src/apps/carbone/common/add-auth-header.ts
Normal file
12
packages/backend/src/apps/carbone/common/add-auth-header.ts
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
import { TBeforeRequest } from '@automatisch/types';
|
||||||
|
|
||||||
|
const addAuthHeader: TBeforeRequest = ($, requestConfig) => {
|
||||||
|
if ($.auth.data?.apiKey) {
|
||||||
|
requestConfig.headers.Authorization = `Bearer ${$.auth.data.apiKey}`;
|
||||||
|
requestConfig.headers['carbone-version'] = '4';
|
||||||
|
}
|
||||||
|
|
||||||
|
return requestConfig;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default addAuthHeader;
|
0
packages/backend/src/apps/carbone/index.d.ts
vendored
Normal file
0
packages/backend/src/apps/carbone/index.d.ts
vendored
Normal file
@@ -1,18 +0,0 @@
|
|||||||
import defineApp from '../../helpers/define-app.js';
|
|
||||||
import addAuthHeader from './common/add-auth-header.js';
|
|
||||||
import auth from './auth/index.js';
|
|
||||||
import actions from './actions/index.js';
|
|
||||||
|
|
||||||
export default defineApp({
|
|
||||||
name: 'Carbone',
|
|
||||||
key: 'carbone',
|
|
||||||
iconUrl: '{BASE_URL}/apps/carbone/assets/favicon.svg',
|
|
||||||
authDocUrl: '{DOCS_URL}/apps/carbone/connection',
|
|
||||||
supportsConnections: true,
|
|
||||||
baseUrl: 'https://carbone.io',
|
|
||||||
apiBaseUrl: 'https://api.carbone.io',
|
|
||||||
primaryColor: '6f42c1',
|
|
||||||
beforeRequest: [addAuthHeader],
|
|
||||||
auth,
|
|
||||||
actions,
|
|
||||||
});
|
|
18
packages/backend/src/apps/carbone/index.ts
Normal file
18
packages/backend/src/apps/carbone/index.ts
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
import defineApp from '../../helpers/define-app';
|
||||||
|
import addAuthHeader from './common/add-auth-header';
|
||||||
|
import auth from './auth';
|
||||||
|
import actions from './actions';
|
||||||
|
|
||||||
|
export default defineApp({
|
||||||
|
name: 'Carbone',
|
||||||
|
key: 'carbone',
|
||||||
|
iconUrl: '{BASE_URL}/apps/carbone/assets/favicon.svg',
|
||||||
|
authDocUrl: 'https://automatisch.io/docs/apps/carbone/connection',
|
||||||
|
supportsConnections: true,
|
||||||
|
baseUrl: 'https://carbone.io',
|
||||||
|
apiBaseUrl: 'https://api.carbone.io',
|
||||||
|
primaryColor: '6f42c1',
|
||||||
|
beforeRequest: [addAuthHeader],
|
||||||
|
auth,
|
||||||
|
actions,
|
||||||
|
});
|
File diff suppressed because one or more lines are too long
Before Width: | Height: | Size: 9.9 KiB |
@@ -1,44 +0,0 @@
|
|||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
import isStillVerified from './is-still-verified.js';
|
|
||||||
|
|
||||||
export default {
|
|
||||||
fields: [
|
|
||||||
{
|
|
||||||
key: 'screenName',
|
|
||||||
label: 'Screen Name',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description:
|
|
||||||
'Screen name of your connection to be used on Automatisch UI.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'instanceUrl',
|
|
||||||
label: 'Instance URL',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: null,
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'apiKey',
|
|
||||||
label: 'API Key',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'Changedetection API key of your account.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
verifyCredentials,
|
|
||||||
isStillVerified,
|
|
||||||
};
|
|
@@ -1,8 +0,0 @@
|
|||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
|
|
||||||
const isStillVerified = async ($) => {
|
|
||||||
await verifyCredentials($);
|
|
||||||
return true;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default isStillVerified;
|
|
@@ -1,10 +0,0 @@
|
|||||||
const verifyCredentials = async ($) => {
|
|
||||||
await $.http.get('/v1/systeminfo');
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
screenName: $.auth.data.screenName,
|
|
||||||
apiKey: $.auth.data.apiKey,
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
export default verifyCredentials;
|
|
@@ -1,9 +0,0 @@
|
|||||||
const addAuthHeader = ($, requestConfig) => {
|
|
||||||
if ($.auth.data?.apiKey) {
|
|
||||||
requestConfig.headers['x-api-key'] = $.auth.data.apiKey;
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default addAuthHeader;
|
|
@@ -1,10 +0,0 @@
|
|||||||
const setBaseUrl = ($, requestConfig) => {
|
|
||||||
const instanceUrl = $.auth.data.instanceUrl;
|
|
||||||
if (instanceUrl) {
|
|
||||||
requestConfig.baseURL = `${instanceUrl}/api`;
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default setBaseUrl;
|
|
@@ -1,17 +0,0 @@
|
|||||||
import defineApp from '../../helpers/define-app.js';
|
|
||||||
import addAuthHeader from './common/add-auth-header.js';
|
|
||||||
import auth from './auth/index.js';
|
|
||||||
import setBaseUrl from './common/set-base-url.js';
|
|
||||||
|
|
||||||
export default defineApp({
|
|
||||||
name: 'Changedetection',
|
|
||||||
key: 'changedetection',
|
|
||||||
iconUrl: '{BASE_URL}/apps/changedetection/assets/favicon.svg',
|
|
||||||
authDocUrl: '{DOCS_URL}/apps/changedetection/connection',
|
|
||||||
supportsConnections: true,
|
|
||||||
baseUrl: 'https://changedetection.io',
|
|
||||||
apiBaseUrl: '',
|
|
||||||
primaryColor: '3056d3',
|
|
||||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
|
||||||
auth,
|
|
||||||
});
|
|
@@ -1,27 +0,0 @@
|
|||||||
import defineAction from '../../../../helpers/define-action.js';
|
|
||||||
|
|
||||||
export default defineAction({
|
|
||||||
name: 'Get value',
|
|
||||||
key: 'getValue',
|
|
||||||
description: 'Get value from the persistent datastore.',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Key',
|
|
||||||
key: 'key',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
description: 'The key of your value to get.',
|
|
||||||
variables: true,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const keyValuePair = await $.datastore.get({
|
|
||||||
key: $.step.parameters.key,
|
|
||||||
});
|
|
||||||
|
|
||||||
$.setActionItem({
|
|
||||||
raw: keyValuePair,
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
@@ -1,4 +0,0 @@
|
|||||||
import getValue from './get-value/index.js';
|
|
||||||
import setValue from './set-value/index.js';
|
|
||||||
|
|
||||||
export default [getValue, setValue];
|
|
@@ -1,36 +0,0 @@
|
|||||||
import defineAction from '../../../../helpers/define-action.js';
|
|
||||||
|
|
||||||
export default defineAction({
|
|
||||||
name: 'Set value',
|
|
||||||
key: 'setValue',
|
|
||||||
description: 'Set value to the persistent datastore.',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Key',
|
|
||||||
key: 'key',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
description: 'The key of your value to set.',
|
|
||||||
variables: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Value',
|
|
||||||
key: 'value',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
description: 'The value to set.',
|
|
||||||
variables: true,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const keyValuePair = await $.datastore.set({
|
|
||||||
key: $.step.parameters.key,
|
|
||||||
value: $.step.parameters.value,
|
|
||||||
});
|
|
||||||
|
|
||||||
$.setActionItem({
|
|
||||||
raw: keyValuePair,
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
@@ -1,13 +0,0 @@
|
|||||||
<?xml version="1.0"?>
|
|
||||||
<svg xmlns="http://www.w3.org/2000/svg" fill="#000000" width="800px" height="800px" viewBox="0 0 32 32" id="icon">
|
|
||||||
<defs>
|
|
||||||
<style>.cls-1{fill:none;}</style>
|
|
||||||
</defs>
|
|
||||||
<title>datastore</title>
|
|
||||||
<circle cx="23" cy="23" r="1"/>
|
|
||||||
<rect x="8" y="22" width="12" height="2"/>
|
|
||||||
<circle cx="23" cy="9" r="1"/>
|
|
||||||
<rect x="8" y="8" width="12" height="2"/>
|
|
||||||
<path d="M26,14a2,2,0,0,0,2-2V6a2,2,0,0,0-2-2H6A2,2,0,0,0,4,6v6a2,2,0,0,0,2,2H8v4H6a2,2,0,0,0-2,2v6a2,2,0,0,0,2,2H26a2,2,0,0,0,2-2V20a2,2,0,0,0-2-2H24V14ZM6,6H26v6H6ZM26,26H6V20H26Zm-4-8H10V14H22Z"/>
|
|
||||||
<rect id="_Transparent_Rectangle_" data-name="<Transparent Rectangle>" class="cls-1" width="32" height="32"/>
|
|
||||||
</svg>
|
|
Before Width: | Height: | Size: 704 B |
@@ -1,14 +0,0 @@
|
|||||||
import defineApp from '../../helpers/define-app.js';
|
|
||||||
import actions from './actions/index.js';
|
|
||||||
|
|
||||||
export default defineApp({
|
|
||||||
name: 'Datastore',
|
|
||||||
key: 'datastore',
|
|
||||||
iconUrl: '{BASE_URL}/apps/datastore/assets/favicon.svg',
|
|
||||||
authDocUrl: '{DOCS_URL}/apps/datastore/connection',
|
|
||||||
supportsConnections: false,
|
|
||||||
baseUrl: '',
|
|
||||||
apiBaseUrl: '',
|
|
||||||
primaryColor: '001F52',
|
|
||||||
actions,
|
|
||||||
});
|
|
@@ -1,3 +0,0 @@
|
|||||||
import translateText from './translate-text/index.js';
|
|
||||||
|
|
||||||
export default [translateText];
|
|
3
packages/backend/src/apps/deepl/actions/index.ts
Normal file
3
packages/backend/src/apps/deepl/actions/index.ts
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
import translateText from './translate-text';
|
||||||
|
|
||||||
|
export default [translateText];
|
@@ -1,77 +0,0 @@
|
|||||||
import qs from 'qs';
|
|
||||||
import defineAction from '../../../../helpers/define-action.js';
|
|
||||||
|
|
||||||
export default defineAction({
|
|
||||||
name: 'Translate text',
|
|
||||||
key: 'translateText',
|
|
||||||
description: 'Translates text from one language to another.',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Text',
|
|
||||||
key: 'text',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
description: 'Text to be translated.',
|
|
||||||
variables: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Target Language',
|
|
||||||
key: 'targetLanguage',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
description: 'Language to translate the text to.',
|
|
||||||
variables: true,
|
|
||||||
value: '',
|
|
||||||
options: [
|
|
||||||
{ label: 'Bulgarian', value: 'BG' },
|
|
||||||
{ label: 'Chinese (simplified)', value: 'ZH' },
|
|
||||||
{ label: 'Czech', value: 'CS' },
|
|
||||||
{ label: 'Danish', value: 'DA' },
|
|
||||||
{ label: 'Dutch', value: 'NL' },
|
|
||||||
{ label: 'English', value: 'EN' },
|
|
||||||
{ label: 'English (American)', value: 'EN-US' },
|
|
||||||
{ label: 'English (British)', value: 'EN-GB' },
|
|
||||||
{ label: 'Estonian', value: 'ET' },
|
|
||||||
{ label: 'Finnish', value: 'FI' },
|
|
||||||
{ label: 'French', value: 'FR' },
|
|
||||||
{ label: 'German', value: 'DE' },
|
|
||||||
{ label: 'Greek', value: 'EL' },
|
|
||||||
{ label: 'Hungarian', value: 'HU' },
|
|
||||||
{ label: 'Indonesian', value: 'ID' },
|
|
||||||
{ label: 'Italian', value: 'IT' },
|
|
||||||
{ label: 'Japanese', value: 'JA' },
|
|
||||||
{ label: 'Latvian', value: 'LV' },
|
|
||||||
{ label: 'Lithuanian', value: 'LT' },
|
|
||||||
{ label: 'Polish', value: 'PL' },
|
|
||||||
{ label: 'Portuguese', value: 'PT' },
|
|
||||||
{ label: 'Portuguese (Brazilian)', value: 'PT-BR' },
|
|
||||||
{
|
|
||||||
label:
|
|
||||||
'Portuguese (all Portuguese varieties excluding Brazilian Portuguese)',
|
|
||||||
value: 'PT-PT',
|
|
||||||
},
|
|
||||||
{ label: 'Romanian', value: 'RO' },
|
|
||||||
{ label: 'Russian', value: 'RU' },
|
|
||||||
{ label: 'Slovak', value: 'SK' },
|
|
||||||
{ label: 'Slovenian', value: 'SL' },
|
|
||||||
{ label: 'Spanish', value: 'ES' },
|
|
||||||
{ label: 'Swedish', value: 'SV' },
|
|
||||||
{ label: 'Turkish', value: 'TR' },
|
|
||||||
{ label: 'Ukrainian', value: 'UK' },
|
|
||||||
],
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const stringifiedBody = qs.stringify({
|
|
||||||
text: $.step.parameters.text,
|
|
||||||
target_lang: $.step.parameters.targetLanguage,
|
|
||||||
});
|
|
||||||
|
|
||||||
const response = await $.http.post('/v2/translate', stringifiedBody);
|
|
||||||
|
|
||||||
$.setActionItem({
|
|
||||||
raw: response.data,
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
@@ -0,0 +1,77 @@
|
|||||||
|
import qs from 'qs';
|
||||||
|
import defineAction from '../../../../helpers/define-action';
|
||||||
|
|
||||||
|
export default defineAction({
|
||||||
|
name: 'Translate text',
|
||||||
|
key: 'translateText',
|
||||||
|
description: 'Translates text from one language to another.',
|
||||||
|
arguments: [
|
||||||
|
{
|
||||||
|
label: 'Text',
|
||||||
|
key: 'text',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
description: 'Text to be translated.',
|
||||||
|
variables: true,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Target Language',
|
||||||
|
key: 'targetLanguage',
|
||||||
|
type: 'dropdown' as const,
|
||||||
|
required: true,
|
||||||
|
description: 'Language to translate the text to.',
|
||||||
|
variables: true,
|
||||||
|
value: '',
|
||||||
|
options: [
|
||||||
|
{ label: 'Bulgarian', value: 'BG' },
|
||||||
|
{ label: 'Chinese (simplified)', value: 'ZH' },
|
||||||
|
{ label: 'Czech', value: 'CS' },
|
||||||
|
{ label: 'Danish', value: 'DA' },
|
||||||
|
{ label: 'Dutch', value: 'NL' },
|
||||||
|
{ label: 'English', value: 'EN' },
|
||||||
|
{ label: 'English (American)', value: 'EN-US' },
|
||||||
|
{ label: 'English (British)', value: 'EN-GB' },
|
||||||
|
{ label: 'Estonian', value: 'ET' },
|
||||||
|
{ label: 'Finnish', value: 'FI' },
|
||||||
|
{ label: 'French', value: 'FR' },
|
||||||
|
{ label: 'German', value: 'DE' },
|
||||||
|
{ label: 'Greek', value: 'EL' },
|
||||||
|
{ label: 'Hungarian', value: 'HU' },
|
||||||
|
{ label: 'Indonesian', value: 'ID' },
|
||||||
|
{ label: 'Italian', value: 'IT' },
|
||||||
|
{ label: 'Japanese', value: 'JA' },
|
||||||
|
{ label: 'Latvian', value: 'LV' },
|
||||||
|
{ label: 'Lithuanian', value: 'LT' },
|
||||||
|
{ label: 'Polish', value: 'PL' },
|
||||||
|
{ label: 'Portuguese', value: 'PT' },
|
||||||
|
{ label: 'Portuguese (Brazilian)', value: 'PT-BR' },
|
||||||
|
{
|
||||||
|
label:
|
||||||
|
'Portuguese (all Portuguese varieties excluding Brazilian Portuguese)',
|
||||||
|
value: 'PT-PT',
|
||||||
|
},
|
||||||
|
{ label: 'Romanian', value: 'RO' },
|
||||||
|
{ label: 'Russian', value: 'RU' },
|
||||||
|
{ label: 'Slovak', value: 'SK' },
|
||||||
|
{ label: 'Slovenian', value: 'SL' },
|
||||||
|
{ label: 'Spanish', value: 'ES' },
|
||||||
|
{ label: 'Swedish', value: 'SV' },
|
||||||
|
{ label: 'Turkish', value: 'TR' },
|
||||||
|
{ label: 'Ukrainian', value: 'UK' },
|
||||||
|
],
|
||||||
|
},
|
||||||
|
],
|
||||||
|
|
||||||
|
async run($) {
|
||||||
|
const stringifiedBody = qs.stringify({
|
||||||
|
text: $.step.parameters.text,
|
||||||
|
target_lang: $.step.parameters.targetLanguage,
|
||||||
|
});
|
||||||
|
|
||||||
|
const response = await $.http.post('/v2/translate', stringifiedBody);
|
||||||
|
|
||||||
|
$.setActionItem({
|
||||||
|
raw: response.data,
|
||||||
|
});
|
||||||
|
},
|
||||||
|
});
|
@@ -1,33 +0,0 @@
|
|||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
import isStillVerified from './is-still-verified.js';
|
|
||||||
|
|
||||||
export default {
|
|
||||||
fields: [
|
|
||||||
{
|
|
||||||
key: 'screenName',
|
|
||||||
label: 'Screen Name',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description:
|
|
||||||
'Screen name of your connection to be used on Automatisch UI.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'authenticationKey',
|
|
||||||
label: 'Authentication Key',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'DeepL authentication key of your account.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
verifyCredentials,
|
|
||||||
isStillVerified,
|
|
||||||
};
|
|
33
packages/backend/src/apps/deepl/auth/index.ts
Normal file
33
packages/backend/src/apps/deepl/auth/index.ts
Normal file
@@ -0,0 +1,33 @@
|
|||||||
|
import verifyCredentials from './verify-credentials';
|
||||||
|
import isStillVerified from './is-still-verified';
|
||||||
|
|
||||||
|
export default {
|
||||||
|
fields: [
|
||||||
|
{
|
||||||
|
key: 'screenName',
|
||||||
|
label: 'Screen Name',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description:
|
||||||
|
'Screen name of your connection to be used on Automatisch UI.',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
key: 'authenticationKey',
|
||||||
|
label: 'Authentication Key',
|
||||||
|
type: 'string' as const,
|
||||||
|
required: true,
|
||||||
|
readOnly: false,
|
||||||
|
value: null,
|
||||||
|
placeholder: null,
|
||||||
|
description: 'DeepL authentication key of your account.',
|
||||||
|
clickToCopy: false,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
|
||||||
|
verifyCredentials,
|
||||||
|
isStillVerified,
|
||||||
|
};
|
@@ -1,8 +0,0 @@
|
|||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
|
|
||||||
const isStillVerified = async ($) => {
|
|
||||||
await verifyCredentials($);
|
|
||||||
return true;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default isStillVerified;
|
|
@@ -0,0 +1,9 @@
|
|||||||
|
import { IGlobalVariable } from '@automatisch/types';
|
||||||
|
import verifyCredentials from './verify-credentials';
|
||||||
|
|
||||||
|
const isStillVerified = async ($: IGlobalVariable) => {
|
||||||
|
await verifyCredentials($);
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default isStillVerified;
|
@@ -1,9 +0,0 @@
|
|||||||
const verifyCredentials = async ($) => {
|
|
||||||
await $.http.get('/v2/usage');
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
screenName: $.auth.data.screenName,
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
export default verifyCredentials;
|
|
11
packages/backend/src/apps/deepl/auth/verify-credentials.ts
Normal file
11
packages/backend/src/apps/deepl/auth/verify-credentials.ts
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
import { IGlobalVariable } from '@automatisch/types';
|
||||||
|
|
||||||
|
const verifyCredentials = async ($: IGlobalVariable) => {
|
||||||
|
await $.http.get('/v2/usage');
|
||||||
|
|
||||||
|
await $.auth.set({
|
||||||
|
screenName: $.auth.data.screenName,
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
export default verifyCredentials;
|
@@ -1,10 +0,0 @@
|
|||||||
const addAuthHeader = ($, requestConfig) => {
|
|
||||||
if ($.auth.data?.authenticationKey) {
|
|
||||||
const authorizationHeader = `DeepL-Auth-Key ${$.auth.data.authenticationKey}`;
|
|
||||||
requestConfig.headers.Authorization = authorizationHeader;
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default addAuthHeader;
|
|
12
packages/backend/src/apps/deepl/common/add-auth-header.ts
Normal file
12
packages/backend/src/apps/deepl/common/add-auth-header.ts
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
import { TBeforeRequest } from '@automatisch/types';
|
||||||
|
|
||||||
|
const addAuthHeader: TBeforeRequest = ($, requestConfig) => {
|
||||||
|
if ($.auth.data?.authenticationKey) {
|
||||||
|
const authorizationHeader = `DeepL-Auth-Key ${$.auth.data.authenticationKey}`;
|
||||||
|
requestConfig.headers.Authorization = authorizationHeader;
|
||||||
|
}
|
||||||
|
|
||||||
|
return requestConfig;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default addAuthHeader;
|
0
packages/backend/src/apps/deepl/index.d.ts
vendored
Normal file
0
packages/backend/src/apps/deepl/index.d.ts
vendored
Normal file
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user