Compare commits
34 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
3e6f22748b | ||
![]() |
fbd62d8635 | ||
![]() |
b8ac73478b | ||
![]() |
f8018ca384 | ||
![]() |
99025c6a7c | ||
![]() |
788530be45 | ||
![]() |
7ed392e854 | ||
![]() |
3932e554da | ||
![]() |
1a21624618 | ||
![]() |
9f292ff018 | ||
![]() |
dbb24b3a9b | ||
![]() |
35b2639837 | ||
![]() |
35951199cd | ||
![]() |
79af909c51 | ||
![]() |
3482aa7b76 | ||
![]() |
5dbc1f59ef | ||
![]() |
2166a3220e | ||
![]() |
24a7d1ef10 | ||
![]() |
18ffbb7317 | ||
![]() |
363874de6a | ||
![]() |
68d1719b11 | ||
![]() |
1a75d81268 | ||
![]() |
2163be4227 | ||
![]() |
b54afcd922 | ||
![]() |
0a86641a0f | ||
![]() |
18464c746a | ||
![]() |
ba92cddae1 | ||
![]() |
2a4f8ed45f | ||
![]() |
135a0028be | ||
![]() |
4da6e8372f | ||
![]() |
6a7cdf2570 | ||
![]() |
73c929f25e | ||
![]() |
754c2d41c2 | ||
![]() |
7201e48111 |
@@ -4,5 +4,9 @@
|
||||
**/.devcontainer
|
||||
**/.github
|
||||
**/.vscode
|
||||
**/.env
|
||||
**/.env.test
|
||||
**/.env.production
|
||||
**/yarn-error.log
|
||||
packages/docs
|
||||
packages/e2e-test
|
||||
|
@@ -1,14 +1,25 @@
|
||||
# syntax=docker/dockerfile:1
|
||||
FROM node:18-alpine
|
||||
WORKDIR /automatisch
|
||||
|
||||
ENV PORT 3000
|
||||
|
||||
RUN \
|
||||
apk --no-cache add --virtual build-dependencies python3 build-base git
|
||||
|
||||
WORKDIR /automatisch
|
||||
|
||||
# copy the app, note .dockerignore
|
||||
COPY . /automatisch
|
||||
|
||||
RUN yarn
|
||||
|
||||
RUN cd packages/web && yarn build
|
||||
|
||||
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/ && \
|
||||
apk del build-dependencies
|
||||
|
||||
COPY ./entrypoint.sh /entrypoint.sh
|
||||
COPY ./docker/entrypoint.sh /entrypoint.sh
|
||||
|
||||
EXPOSE 3000
|
||||
ENTRYPOINT ["sh", "/entrypoint.sh"]
|
||||
|
@@ -2,8 +2,12 @@
|
||||
|
||||
set -e
|
||||
|
||||
cd packages/backend
|
||||
|
||||
if [ -n "$WORKER" ]; then
|
||||
automatisch start-worker
|
||||
yarn start:worker
|
||||
else
|
||||
automatisch start
|
||||
yarn db:migrate
|
||||
yarn db:seed:user
|
||||
yarn start
|
||||
fi
|
||||
|
@@ -31,7 +31,7 @@
|
||||
"accounting": "^0.4.1",
|
||||
"ajv-formats": "^2.1.1",
|
||||
"axios": "1.6.0",
|
||||
"bcrypt": "^5.0.1",
|
||||
"bcrypt": "^5.1.0",
|
||||
"bullmq": "^3.0.0",
|
||||
"cors": "^2.8.5",
|
||||
"crypto-js": "^4.1.1",
|
||||
@@ -95,6 +95,7 @@
|
||||
"url": "https://github.com/automatisch/automatisch/issues"
|
||||
},
|
||||
"devDependencies": {
|
||||
"node-gyp": "^10.1.0",
|
||||
"nodemon": "^2.0.13",
|
||||
"supertest": "^6.3.3",
|
||||
"vitest": "^1.1.3"
|
||||
|
@@ -11,7 +11,7 @@ export default defineApp({
|
||||
'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',
|
||||
authDocUrl: '{DOCS_URL}/apps/azure-openai/connection',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Carbone',
|
||||
key: 'carbone',
|
||||
iconUrl: '{BASE_URL}/apps/carbone/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/carbone/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/carbone/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://carbone.io',
|
||||
apiBaseUrl: 'https://api.carbone.io',
|
||||
|
@@ -5,7 +5,7 @@ export default defineApp({
|
||||
name: 'Datastore',
|
||||
key: 'datastore',
|
||||
iconUrl: '{BASE_URL}/apps/datastore/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/datastore/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/datastore/connection',
|
||||
supportsConnections: false,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'DeepL',
|
||||
key: 'deepl',
|
||||
iconUrl: '{BASE_URL}/apps/deepl/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/deepl/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/deepl/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://deepl.com',
|
||||
apiBaseUrl: 'https://api.deepl.com',
|
||||
|
@@ -5,7 +5,7 @@ export default defineApp({
|
||||
name: 'Delay',
|
||||
key: 'delay',
|
||||
iconUrl: '{BASE_URL}/apps/delay/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/delay/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/delay/connection',
|
||||
supportsConnections: false,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
name: 'Discord',
|
||||
key: 'discord',
|
||||
iconUrl: '{BASE_URL}/apps/discord/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/discord/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/discord/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://discord.com',
|
||||
apiBaseUrl: 'https://discord.com/api',
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Dropbox',
|
||||
key: 'dropbox',
|
||||
iconUrl: '{BASE_URL}/apps/dropbox/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/dropbox/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/dropbox/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://dropbox.com',
|
||||
apiBaseUrl: 'https://api.dropboxapi.com',
|
||||
|
@@ -5,7 +5,7 @@ export default defineApp({
|
||||
name: 'Filter',
|
||||
key: 'filter',
|
||||
iconUrl: '{BASE_URL}/apps/filter/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/filter/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/filter/connection',
|
||||
supportsConnections: false,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -8,7 +8,7 @@ export default defineApp({
|
||||
name: 'Flickr',
|
||||
key: 'flickr',
|
||||
iconUrl: '{BASE_URL}/apps/flickr/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/flickr/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/flickr/connection',
|
||||
docUrl: 'https://automatisch.io/docs/flickr',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Flowers Software',
|
||||
key: 'flowers-software',
|
||||
iconUrl: '{BASE_URL}/apps/flowers-software/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/flowers-software/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/flowers-software/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://flowers-software.com',
|
||||
apiBaseUrl: 'https://webapp.flowers-software.com/api',
|
||||
|
@@ -6,7 +6,7 @@ export default defineApp({
|
||||
name: 'Formatter',
|
||||
key: 'formatter',
|
||||
iconUrl: '{BASE_URL}/apps/formatter/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/formatter/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/formatter/connection',
|
||||
supportsConnections: false,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://ghost.org',
|
||||
apiBaseUrl: '',
|
||||
iconUrl: '{BASE_URL}/apps/ghost/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/ghost/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/ghost/connection',
|
||||
primaryColor: '15171A',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
|
1
packages/backend/src/apps/gitea/assets/favicon.svg
Normal file
1
packages/backend/src/apps/gitea/assets/favicon.svg
Normal file
@@ -0,0 +1 @@
|
||||
<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 640 640" style="enable-background:new 0 0 640 640" xml:space="preserve" width="32" height="32"><path style="fill:#fff" d="m395.9 484.2-126.9-61c-12.5-6-17.9-21.2-11.8-33.8l61-126.9c6-12.5 21.2-17.9 33.8-11.8 17.2 8.3 27.1 13 27.1 13l-.1-109.2 16.7-.1.1 117.1s57.4 24.2 83.1 40.1c3.7 2.3 10.2 6.8 12.9 14.4 2.1 6.1 2 13.1-1 19.3l-61 126.9c-6.2 12.7-21.4 18.1-33.9 12z"/><path style="fill:#609926" d="M622.7 149.8c-4.1-4.1-9.6-4-9.6-4s-117.2 6.6-177.9 8c-13.3.3-26.5.6-39.6.7v117.2c-5.5-2.6-11.1-5.3-16.6-7.9 0-36.4-.1-109.2-.1-109.2-29 .4-89.2-2.2-89.2-2.2s-141.4-7.1-156.8-8.5c-9.8-.6-22.5-2.1-39 1.5-8.7 1.8-33.5 7.4-53.8 26.9C-4.9 212.4 6.6 276.2 8 285.8c1.7 11.7 6.9 44.2 31.7 72.5 45.8 56.1 144.4 54.8 144.4 54.8s12.1 28.9 30.6 55.5c25 33.1 50.7 58.9 75.7 62 63 0 188.9-.1 188.9-.1s12 .1 28.3-10.3c14-8.5 26.5-23.4 26.5-23.4S547 483 565 451.5c5.5-9.7 10.1-19.1 14.1-28 0 0 55.2-117.1 55.2-231.1-1.1-34.5-9.6-40.6-11.6-42.6zM125.6 353.9c-25.9-8.5-36.9-18.7-36.9-18.7S69.6 321.8 60 295.4c-16.5-44.2-1.4-71.2-1.4-71.2s8.4-22.5 38.5-30c13.8-3.7 31-3.1 31-3.1s7.1 59.4 15.7 94.2c7.2 29.2 24.8 77.7 24.8 77.7s-26.1-3.1-43-9.1zm300.3 107.6s-6.1 14.5-19.6 15.4c-5.8.4-10.3-1.2-10.3-1.2s-.3-.1-5.3-2.1l-112.9-55s-10.9-5.7-12.8-15.6c-2.2-8.1 2.7-18.1 2.7-18.1L322 273s4.8-9.7 12.2-13c.6-.3 2.3-1 4.5-1.5 8.1-2.1 18 2.8 18 2.8L467.4 315s12.6 5.7 15.3 16.2c1.9 7.4-.5 14-1.8 17.2-6.3 15.4-55 113.1-55 113.1z"/><path style="fill:#609926" d="M326.8 380.1c-8.2.1-15.4 5.8-17.3 13.8-1.9 8 2 16.3 9.1 20 7.7 4 17.5 1.8 22.7-5.4 5.1-7.1 4.3-16.9-1.8-23.1l24-49.1c1.5.1 3.7.2 6.2-.5 4.1-.9 7.1-3.6 7.1-3.6 4.2 1.8 8.6 3.8 13.2 6.1 4.8 2.4 9.3 4.9 13.4 7.3.9.5 1.8 1.1 2.8 1.9 1.6 1.3 3.4 3.1 4.7 5.5 1.9 5.5-1.9 14.9-1.9 14.9-2.3 7.6-18.4 40.6-18.4 40.6-8.1-.2-15.3 5-17.7 12.5-2.6 8.1 1.1 17.3 8.9 21.3 7.8 4 17.4 1.7 22.5-5.3 5-6.8 4.6-16.3-1.1-22.6 1.9-3.7 3.7-7.4 5.6-11.3 5-10.4 13.5-30.4 13.5-30.4.9-1.7 5.7-10.3 2.7-21.3-2.5-11.4-12.6-16.7-12.6-16.7-12.2-7.9-29.2-15.2-29.2-15.2s0-4.1-1.1-7.1c-1.1-3.1-2.8-5.1-3.9-6.3 4.7-9.7 9.4-19.3 14.1-29-4.1-2-8.1-4-12.2-6.1-4.8 9.8-9.7 19.7-14.5 29.5-6.7-.1-12.9 3.5-16.1 9.4-3.4 6.3-2.7 14.1 1.9 19.8l-24.6 50.4z"/></svg>
|
After Width: | Height: | Size: 2.2 KiB |
@@ -1,23 +1,24 @@
|
||||
import { URLSearchParams } from 'url';
|
||||
import authScope from '../common/auth-scope.js';
|
||||
|
||||
export default async function generateAuthUrl($) {
|
||||
const oauthRedirectUrlField = $.app.auth.fields.find(
|
||||
(field) => field.key == 'oAuthRedirectUrl'
|
||||
);
|
||||
const redirectUri = oauthRedirectUrlField.value;
|
||||
const state = Math.random().toString();
|
||||
const searchParams = new URLSearchParams({
|
||||
client_id: $.auth.data.clientId,
|
||||
redirect_uri: redirectUri,
|
||||
prompt: 'select_account',
|
||||
scope: authScope.join(' '),
|
||||
response_type: 'code',
|
||||
access_type: 'offline',
|
||||
state: state,
|
||||
});
|
||||
|
||||
const url = `https://accounts.google.com/o/oauth2/v2/auth?${searchParams.toString()}`;
|
||||
const url = `${
|
||||
$.auth.data.instanceUrl
|
||||
}/login/oauth/authorize?${searchParams.toString()}`;
|
||||
|
||||
await $.auth.set({
|
||||
url,
|
||||
originalState: state,
|
||||
});
|
||||
}
|
@@ -11,12 +11,23 @@ export default {
|
||||
type: 'string',
|
||||
required: true,
|
||||
readOnly: true,
|
||||
value: '{WEB_APP_URL}/app/gmail/connections/add',
|
||||
value: '{WEB_APP_URL}/app/gitea/connections/add',
|
||||
placeholder: null,
|
||||
description:
|
||||
'When asked to input a redirect URL in Google Cloud, enter the URL above.',
|
||||
'When asked to input a redirect URL in Gitea, enter the URL above.',
|
||||
clickToCopy: true,
|
||||
},
|
||||
{
|
||||
key: 'instanceUrl',
|
||||
label: 'Instance URL',
|
||||
type: 'string',
|
||||
required: true,
|
||||
readOnly: false,
|
||||
value: null,
|
||||
placeholder: null,
|
||||
description: null,
|
||||
clickToCopy: false,
|
||||
},
|
||||
{
|
||||
key: 'clientId',
|
||||
label: 'Client ID',
|
@@ -2,7 +2,7 @@ import getCurrentUser from '../common/get-current-user.js';
|
||||
|
||||
const isStillVerified = async ($) => {
|
||||
const currentUser = await getCurrentUser($);
|
||||
return !!currentUser.resourceName;
|
||||
return !!currentUser.email;
|
||||
};
|
||||
|
||||
export default isStillVerified;
|
@@ -1,7 +1,5 @@
|
||||
import { URLSearchParams } from 'node:url';
|
||||
|
||||
import authScope from '../common/auth-scope.js';
|
||||
|
||||
const refreshToken = async ($) => {
|
||||
const params = new URLSearchParams({
|
||||
client_id: $.auth.data.clientId,
|
||||
@@ -11,15 +9,20 @@ const refreshToken = async ($) => {
|
||||
});
|
||||
|
||||
const { data } = await $.http.post(
|
||||
'https://oauth2.googleapis.com/token',
|
||||
params.toString()
|
||||
`${$.auth.data.instanceUrl}/login/oauth/access_token`,
|
||||
params.toString(),
|
||||
{
|
||||
additionalProperties: {
|
||||
skipAddingBaseUrl: true,
|
||||
},
|
||||
}
|
||||
);
|
||||
|
||||
await $.auth.set({
|
||||
accessToken: data.access_token,
|
||||
expiresIn: data.expires_in,
|
||||
scope: authScope.join(' '),
|
||||
tokenType: data.token_type,
|
||||
refreshToken: data.refresh_token,
|
||||
});
|
||||
};
|
||||
|
@@ -1,11 +1,15 @@
|
||||
import getCurrentUser from '../common/get-current-user.js';
|
||||
import { URLSearchParams } from 'url';
|
||||
|
||||
const verifyCredentials = async ($) => {
|
||||
if ($.auth.data.originalState !== $.auth.data.state) {
|
||||
throw new Error(`The 'state' parameter does not match.`);
|
||||
}
|
||||
const oauthRedirectUrlField = $.app.auth.fields.find(
|
||||
(field) => field.key == 'oAuthRedirectUrl'
|
||||
);
|
||||
const redirectUri = oauthRedirectUrlField.value;
|
||||
const { data } = await $.http.post(`https://oauth2.googleapis.com/token`, {
|
||||
const params = new URLSearchParams({
|
||||
client_id: $.auth.data.clientId,
|
||||
client_secret: $.auth.data.clientSecret,
|
||||
code: $.auth.data.code,
|
||||
@@ -13,30 +17,33 @@ const verifyCredentials = async ($) => {
|
||||
redirect_uri: redirectUri,
|
||||
});
|
||||
|
||||
const { data } = await $.http.post(
|
||||
`${$.auth.data.instanceUrl}/login/oauth/access_token`,
|
||||
params.toString(),
|
||||
{
|
||||
additionalProperties: {
|
||||
skipAddingBaseUrl: true,
|
||||
},
|
||||
}
|
||||
);
|
||||
|
||||
await $.auth.set({
|
||||
accessToken: data.access_token,
|
||||
tokenType: data.token_type,
|
||||
});
|
||||
|
||||
const currentUser = await getCurrentUser($);
|
||||
|
||||
const { displayName } = currentUser.names.find(
|
||||
(name) => name.metadata.primary
|
||||
);
|
||||
const { value: email } = currentUser.emailAddresses.find(
|
||||
(emailAddress) => emailAddress.metadata.primary
|
||||
);
|
||||
const screenName = [currentUser.username, currentUser.email]
|
||||
.filter(Boolean)
|
||||
.join(' @ ');
|
||||
|
||||
await $.auth.set({
|
||||
clientId: $.auth.data.clientId,
|
||||
clientSecret: $.auth.data.clientSecret,
|
||||
scope: $.auth.data.scope,
|
||||
idToken: data.id_token,
|
||||
expiresIn: data.expires_in,
|
||||
refreshToken: data.refresh_token,
|
||||
resourceName: currentUser.resourceName,
|
||||
screenName: `${displayName} - ${email}`,
|
||||
userId: email,
|
||||
repoOwner: currentUser.username,
|
||||
screenName,
|
||||
});
|
||||
};
|
||||
|
@@ -0,0 +1,6 @@
|
||||
const getCurrentUser = async ($) => {
|
||||
const { data: currentUser } = await $.http.get(`/user`);
|
||||
return currentUser;
|
||||
};
|
||||
|
||||
export default getCurrentUser;
|
14
packages/backend/src/apps/gitea/common/set-base-url.js
Normal file
14
packages/backend/src/apps/gitea/common/set-base-url.js
Normal file
@@ -0,0 +1,14 @@
|
||||
const setBaseUrl = ($, requestConfig) => {
|
||||
if (requestConfig.additionalProperties?.skipAddingBaseUrl)
|
||||
return requestConfig;
|
||||
|
||||
const instanceUrl = $.auth.data.instanceUrl;
|
||||
|
||||
if (instanceUrl) {
|
||||
requestConfig.baseURL = `${instanceUrl}/api/v1`;
|
||||
}
|
||||
|
||||
return requestConfig;
|
||||
};
|
||||
|
||||
export default setBaseUrl;
|
4
packages/backend/src/apps/gitea/dynamic-data/index.js
Normal file
4
packages/backend/src/apps/gitea/dynamic-data/index.js
Normal file
@@ -0,0 +1,4 @@
|
||||
import listLabels from './list-labels/index.js';
|
||||
import listRepos from './list-repos/index.js';
|
||||
|
||||
export default [listLabels, listRepos];
|
@@ -0,0 +1,40 @@
|
||||
export default {
|
||||
name: 'List labels',
|
||||
key: 'listLabels',
|
||||
|
||||
async run($) {
|
||||
const labels = {
|
||||
data: [],
|
||||
};
|
||||
const repoOwner = $.auth.data.repoOwner;
|
||||
const repo = $.step.parameters.repo;
|
||||
|
||||
const params = {
|
||||
page: 1,
|
||||
limit: 100,
|
||||
};
|
||||
|
||||
let totalCount;
|
||||
let totalRequestedCount;
|
||||
do {
|
||||
const { data, headers } = await $.http.get(
|
||||
`/repos/${repoOwner}/${repo}/labels`,
|
||||
{ params }
|
||||
);
|
||||
params.page = params.page + 1;
|
||||
totalCount = Number(headers['x-total-count']);
|
||||
totalRequestedCount = params.page * params.limit;
|
||||
|
||||
if (data?.length) {
|
||||
for (const label of data) {
|
||||
labels.data.push({
|
||||
value: label.name,
|
||||
name: label.name,
|
||||
});
|
||||
}
|
||||
}
|
||||
} while (totalRequestedCount <= totalCount);
|
||||
|
||||
return labels;
|
||||
},
|
||||
};
|
@@ -0,0 +1,35 @@
|
||||
export default {
|
||||
name: 'List repos',
|
||||
key: 'listRepos',
|
||||
|
||||
async run($) {
|
||||
const repos = {
|
||||
data: [],
|
||||
};
|
||||
|
||||
const params = {
|
||||
page: 1,
|
||||
limit: 100,
|
||||
};
|
||||
|
||||
let totalCount;
|
||||
let totalRequestedCount;
|
||||
do {
|
||||
const { data, headers } = await $.http.get('/user/repos', { params });
|
||||
params.page = params.page + 1;
|
||||
totalCount = Number(headers['x-total-count']);
|
||||
totalRequestedCount = params.page * params.limit;
|
||||
|
||||
if (data?.length) {
|
||||
for (const repo of data) {
|
||||
repos.data.push({
|
||||
value: repo.name,
|
||||
name: repo.name,
|
||||
});
|
||||
}
|
||||
}
|
||||
} while (totalRequestedCount <= totalCount);
|
||||
|
||||
return repos;
|
||||
},
|
||||
};
|
21
packages/backend/src/apps/gitea/index.js
Normal file
21
packages/backend/src/apps/gitea/index.js
Normal file
@@ -0,0 +1,21 @@
|
||||
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';
|
||||
import triggers from './triggers/index.js';
|
||||
import dynamicData from './dynamic-data/index.js';
|
||||
|
||||
export default defineApp({
|
||||
name: 'Gitea',
|
||||
key: 'gitea',
|
||||
iconUrl: '{BASE_URL}/apps/gitea/assets/favicon.svg',
|
||||
authDocUrl: '{DOCS_URL}/apps/gitea/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
primaryColor: '609926',
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
auth,
|
||||
triggers,
|
||||
dynamicData,
|
||||
});
|
5
packages/backend/src/apps/gitea/triggers/index.js
Normal file
5
packages/backend/src/apps/gitea/triggers/index.js
Normal file
@@ -0,0 +1,5 @@
|
||||
import newIssues from './new-issues/index.js';
|
||||
import newStargazers from './new-stargazers/index.js';
|
||||
import newWatchers from './new-watchers/index.js';
|
||||
|
||||
export default [newIssues, newStargazers, newWatchers];
|
121
packages/backend/src/apps/gitea/triggers/new-issues/index.js
Normal file
121
packages/backend/src/apps/gitea/triggers/new-issues/index.js
Normal file
@@ -0,0 +1,121 @@
|
||||
import defineTrigger from '../../../../helpers/define-trigger.js';
|
||||
|
||||
export default defineTrigger({
|
||||
name: 'New issues',
|
||||
key: 'newIssues',
|
||||
pollInterval: 15,
|
||||
description: 'Triggers when a new issue is created.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Repo',
|
||||
key: 'repo',
|
||||
type: 'dropdown',
|
||||
required: true,
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listRepos',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'Which types of issues should this trigger on?',
|
||||
key: 'issueType',
|
||||
type: 'dropdown',
|
||||
description: 'Defaults to any issue you can see.',
|
||||
required: true,
|
||||
variables: true,
|
||||
value: 'all',
|
||||
options: [
|
||||
{
|
||||
label: 'Closed',
|
||||
value: 'closed',
|
||||
},
|
||||
{
|
||||
label: 'Open',
|
||||
value: 'open',
|
||||
},
|
||||
{
|
||||
label: 'All',
|
||||
value: 'all',
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'Labels',
|
||||
key: 'labels',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
fields: [
|
||||
{
|
||||
label: 'Label',
|
||||
key: 'label',
|
||||
type: 'dropdown',
|
||||
description: 'Only trigger on issues when this label is added.',
|
||||
required: false,
|
||||
variables: true,
|
||||
dependsOn: ['parameters.repo'],
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listLabels',
|
||||
},
|
||||
{
|
||||
name: 'parameters.repo',
|
||||
value: '{parameters.repo}',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const repo = $.step.parameters.repo;
|
||||
const issueType = $.step.parameters.issueType;
|
||||
const allLabels = $.step.parameters.labels;
|
||||
const formattedAllLabels = allLabels.map((label) => label.label).join(',');
|
||||
const repoOwner = $.auth.data.repoOwner;
|
||||
|
||||
const params = {
|
||||
page: 1,
|
||||
limit: 100,
|
||||
state: issueType,
|
||||
labels: formattedAllLabels,
|
||||
};
|
||||
|
||||
let totalCount;
|
||||
let totalRequestedCount;
|
||||
do {
|
||||
const { data, headers } = await $.http.get(
|
||||
`/repos/${repoOwner}/${repo}/issues`,
|
||||
{
|
||||
params,
|
||||
}
|
||||
);
|
||||
params.page = params.page + 1;
|
||||
totalCount = Number(headers['x-total-count']);
|
||||
totalRequestedCount = params.page * params.limit;
|
||||
|
||||
if (data?.length) {
|
||||
for (const issue of data) {
|
||||
$.pushTriggerItem({
|
||||
raw: issue,
|
||||
meta: {
|
||||
internalId: issue.id.toString(),
|
||||
},
|
||||
});
|
||||
}
|
||||
}
|
||||
} while (totalRequestedCount <= totalCount);
|
||||
},
|
||||
});
|
@@ -0,0 +1,61 @@
|
||||
import defineTrigger from '../../../../helpers/define-trigger.js';
|
||||
|
||||
export default defineTrigger({
|
||||
name: 'New stargazers',
|
||||
key: 'newStargazers',
|
||||
pollInterval: 15,
|
||||
description: 'Triggers when a user stars a repository.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Repo',
|
||||
key: 'repo',
|
||||
type: 'dropdown',
|
||||
required: true,
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listRepos',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const repo = $.step.parameters.repo;
|
||||
const repoOwner = $.auth.data.repoOwner;
|
||||
const params = {
|
||||
page: 1,
|
||||
limit: 100,
|
||||
};
|
||||
|
||||
let totalCount;
|
||||
let totalRequestedCount;
|
||||
do {
|
||||
const { data, headers } = await $.http.get(
|
||||
`/repos/${repoOwner}/${repo}/stargazers`,
|
||||
{
|
||||
params,
|
||||
}
|
||||
);
|
||||
params.page = params.page + 1;
|
||||
totalCount = Number(headers['x-total-count']);
|
||||
totalRequestedCount = params.page * params.limit;
|
||||
|
||||
if (data?.length) {
|
||||
for (const stargazer of data) {
|
||||
$.pushTriggerItem({
|
||||
raw: stargazer,
|
||||
meta: {
|
||||
internalId: stargazer.id.toString(),
|
||||
},
|
||||
});
|
||||
}
|
||||
}
|
||||
} while (totalRequestedCount <= totalCount);
|
||||
},
|
||||
});
|
@@ -0,0 +1,61 @@
|
||||
import defineTrigger from '../../../../helpers/define-trigger.js';
|
||||
|
||||
export default defineTrigger({
|
||||
name: 'New watchers',
|
||||
key: 'newWatchers',
|
||||
pollInterval: 15,
|
||||
description: 'Triggers when a user watches a repository.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Repo',
|
||||
key: 'repo',
|
||||
type: 'dropdown',
|
||||
required: true,
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listRepos',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const repo = $.step.parameters.repo;
|
||||
const repoOwner = $.auth.data.repoOwner;
|
||||
const params = {
|
||||
page: 1,
|
||||
limit: 100,
|
||||
};
|
||||
|
||||
let totalCount;
|
||||
let totalRequestedCount;
|
||||
do {
|
||||
const { data, headers } = await $.http.get(
|
||||
`/repos/${repoOwner}/${repo}/subscribers`,
|
||||
{
|
||||
params,
|
||||
}
|
||||
);
|
||||
params.page = params.page + 1;
|
||||
totalCount = Number(headers['x-total-count']);
|
||||
totalRequestedCount = params.page * params.limit;
|
||||
|
||||
if (data?.length) {
|
||||
for (const subscriber of data) {
|
||||
$.pushTriggerItem({
|
||||
raw: subscriber,
|
||||
meta: {
|
||||
internalId: subscriber.id.toString(),
|
||||
},
|
||||
});
|
||||
}
|
||||
}
|
||||
} while (totalRequestedCount <= totalCount);
|
||||
},
|
||||
});
|
@@ -11,7 +11,7 @@ export default defineApp({
|
||||
baseUrl: 'https://github.com',
|
||||
apiBaseUrl: 'https://api.github.com',
|
||||
iconUrl: '{BASE_URL}/apps/github/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/github/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/github/connection',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -11,7 +11,7 @@ export default defineApp({
|
||||
baseUrl: 'https://gitlab.com',
|
||||
apiBaseUrl: 'https://gitlab.com',
|
||||
iconUrl: '{BASE_URL}/apps/gitlab/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/gitlab/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/gitlab/connection',
|
||||
primaryColor: 'FC6D26',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
|
@@ -1,204 +0,0 @@
|
||||
import defineAction from '../../../../helpers/define-action.js';
|
||||
|
||||
export default defineAction({
|
||||
name: 'Create draft',
|
||||
key: 'createDraft',
|
||||
description: 'Create a new draft email message.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Subject',
|
||||
key: 'subject',
|
||||
type: 'string',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'TOs',
|
||||
key: 'tos',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description: '',
|
||||
fields: [
|
||||
{
|
||||
label: 'To',
|
||||
key: 'to',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'CCs',
|
||||
key: 'ccs',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description: '',
|
||||
fields: [
|
||||
{
|
||||
label: 'CC',
|
||||
key: 'cc',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'BCCs',
|
||||
key: 'bccs',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description: '',
|
||||
fields: [
|
||||
{
|
||||
label: 'BCC',
|
||||
key: 'bcc',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'From',
|
||||
key: 'from',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description:
|
||||
'Select an email address or alias from your Gmail Account. Defaults to the primary email address.',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listEmails',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'From Name',
|
||||
key: 'fromName',
|
||||
type: 'string',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Body Type',
|
||||
key: 'bodyType',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
options: [
|
||||
{
|
||||
label: 'plain',
|
||||
value: 'plain',
|
||||
},
|
||||
{
|
||||
label: 'html',
|
||||
value: 'html',
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'Body',
|
||||
key: 'emailBody',
|
||||
type: 'string',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Signature',
|
||||
key: 'signature',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listSignatures',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const {
|
||||
tos,
|
||||
ccs,
|
||||
bccs,
|
||||
from,
|
||||
fromName,
|
||||
subject,
|
||||
bodyType,
|
||||
emailBody,
|
||||
signature,
|
||||
} = $.step.parameters;
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const allTos = tos?.map((entry) => entry.to);
|
||||
const allCcs = ccs?.map((entry) => entry.cc);
|
||||
const allBccs = bccs?.map((entry) => entry.bcc);
|
||||
const contentType =
|
||||
bodyType === 'html'
|
||||
? 'text/html; charset="UTF-8"'
|
||||
: 'text/plain; charset="UTF-8"';
|
||||
|
||||
const email =
|
||||
'From: ' +
|
||||
fromName +
|
||||
' <' +
|
||||
from +
|
||||
'>' +
|
||||
'\r\n' +
|
||||
'To: ' +
|
||||
allTos.join(',') +
|
||||
'\r\n' +
|
||||
'Cc: ' +
|
||||
allCcs.join(',') +
|
||||
'\r\n' +
|
||||
'Bcc: ' +
|
||||
allBccs.join(',') +
|
||||
'\r\n' +
|
||||
'Subject: ' +
|
||||
subject +
|
||||
'\r\n' +
|
||||
'Content-Type: ' +
|
||||
contentType +
|
||||
'\r\n' +
|
||||
'\r\n' +
|
||||
emailBody +
|
||||
'\r\n' +
|
||||
'\r\n' +
|
||||
signature;
|
||||
|
||||
const base64EncodedEmailBody = Buffer.from(email).toString('base64');
|
||||
|
||||
const body = {
|
||||
message: {
|
||||
raw: base64EncodedEmailBody,
|
||||
},
|
||||
};
|
||||
|
||||
const { data } = await $.http.post(
|
||||
`/gmail/v1/users/${userId}/drafts`,
|
||||
body
|
||||
);
|
||||
|
||||
$.setActionItem({
|
||||
raw: data,
|
||||
});
|
||||
},
|
||||
});
|
@@ -1,7 +0,0 @@
|
||||
import createDraft from './create-draft/index.js';
|
||||
import replyToEmail from './reply-to-email/index.js';
|
||||
import sendEmail from './send-email/index.js';
|
||||
import sendToTrash from './send-to-trash/index.js';
|
||||
import starEmail from './star-email/index.js';
|
||||
|
||||
export default [createDraft, replyToEmail, sendEmail, sendToTrash, starEmail];
|
@@ -1,228 +0,0 @@
|
||||
import defineAction from '../../../../helpers/define-action.js';
|
||||
|
||||
export default defineAction({
|
||||
name: 'Reply to email',
|
||||
key: 'replyToEmail',
|
||||
description: 'Respond to an email.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Thread',
|
||||
key: 'threadId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listThreads',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'TOs',
|
||||
key: 'tos',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description: 'Who will receive this email?',
|
||||
fields: [
|
||||
{
|
||||
label: 'To',
|
||||
key: 'to',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'CCs',
|
||||
key: 'ccs',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description:
|
||||
'Who else needs to be included in the CC field of this email?',
|
||||
fields: [
|
||||
{
|
||||
label: 'CC',
|
||||
key: 'cc',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'BCCs',
|
||||
key: 'bccs',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description:
|
||||
'Who else needs to be included in the BCC field of this email?',
|
||||
fields: [
|
||||
{
|
||||
label: 'BCC',
|
||||
key: 'bcc',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'From',
|
||||
key: 'from',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description:
|
||||
'Choose an email address or alias from your Gmail Account. This defaults to the primary email address.',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listEmails',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'From Name',
|
||||
key: 'fromName',
|
||||
type: 'string',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Reply To',
|
||||
key: 'replyTo',
|
||||
type: 'string',
|
||||
required: false,
|
||||
description: 'Specify a single reply address other than your own.',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Body Type',
|
||||
key: 'bodyType',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
options: [
|
||||
{
|
||||
label: 'plain',
|
||||
value: 'plain',
|
||||
},
|
||||
{
|
||||
label: 'html',
|
||||
value: 'html',
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'Body',
|
||||
key: 'emailBody',
|
||||
type: 'string',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Label',
|
||||
key: 'labelId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listLabels',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const {
|
||||
tos,
|
||||
ccs,
|
||||
bccs,
|
||||
from,
|
||||
fromName,
|
||||
replyTo,
|
||||
threadId,
|
||||
bodyType,
|
||||
emailBody,
|
||||
labelId,
|
||||
} = $.step.parameters;
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const allTos = tos?.map((entry) => entry.to);
|
||||
const allCcs = ccs?.map((entry) => entry.cc);
|
||||
const allBccs = bccs?.map((entry) => entry.bcc);
|
||||
const contentType =
|
||||
bodyType === 'html'
|
||||
? 'text/html; charset="UTF-8"'
|
||||
: 'text/plain; charset="UTF-8"';
|
||||
|
||||
const email =
|
||||
'From: ' +
|
||||
fromName +
|
||||
' <' +
|
||||
from +
|
||||
'>' +
|
||||
'\r\n' +
|
||||
'In-Reply-To: ' +
|
||||
threadId +
|
||||
'\r\n' +
|
||||
'References: ' +
|
||||
threadId +
|
||||
'\r\n' +
|
||||
'Reply-To: ' +
|
||||
replyTo +
|
||||
'\r\n' +
|
||||
'To: ' +
|
||||
allTos.join(',') +
|
||||
'\r\n' +
|
||||
'Cc: ' +
|
||||
allCcs.join(',') +
|
||||
'\r\n' +
|
||||
'Bcc: ' +
|
||||
allBccs.join(',') +
|
||||
'\r\n' +
|
||||
'Content-Type: ' +
|
||||
contentType +
|
||||
'\r\n' +
|
||||
'\r\n' +
|
||||
emailBody;
|
||||
|
||||
const base64EncodedEmailBody = Buffer.from(email).toString('base64');
|
||||
|
||||
const body = {
|
||||
threadId: threadId,
|
||||
labelIds: [labelId],
|
||||
raw: base64EncodedEmailBody,
|
||||
};
|
||||
|
||||
const { data } = await $.http.post(
|
||||
`/gmail/v1/users/${userId}/messages/send`,
|
||||
body
|
||||
);
|
||||
|
||||
$.setActionItem({
|
||||
raw: data,
|
||||
});
|
||||
},
|
||||
});
|
@@ -1,234 +0,0 @@
|
||||
import defineAction from '../../../../helpers/define-action.js';
|
||||
|
||||
export default defineAction({
|
||||
name: 'Send email',
|
||||
key: 'sendEmail',
|
||||
description: 'Send a new email message.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'TOs',
|
||||
key: 'tos',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description: '',
|
||||
fields: [
|
||||
{
|
||||
label: 'To',
|
||||
key: 'to',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'CCs',
|
||||
key: 'ccs',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description: '',
|
||||
fields: [
|
||||
{
|
||||
label: 'CC',
|
||||
key: 'cc',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'BCCs',
|
||||
key: 'bccs',
|
||||
type: 'dynamic',
|
||||
required: false,
|
||||
description: '',
|
||||
fields: [
|
||||
{
|
||||
label: 'BCC',
|
||||
key: 'bcc',
|
||||
type: 'string',
|
||||
required: false,
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'From',
|
||||
key: 'from',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description:
|
||||
'Select an email address or alias from your Gmail Account. Defaults to the primary email address.',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listEmails',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'From Name',
|
||||
key: 'fromName',
|
||||
type: 'string',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Reply To',
|
||||
key: 'replyTo',
|
||||
type: 'string',
|
||||
required: false,
|
||||
description: 'Specify a single reply address other than your own.',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Subject',
|
||||
key: 'subject',
|
||||
type: 'string',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Body Type',
|
||||
key: 'bodyType',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
options: [
|
||||
{
|
||||
label: 'plain',
|
||||
value: 'plain',
|
||||
},
|
||||
{
|
||||
label: 'html',
|
||||
value: 'html',
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
label: 'Body',
|
||||
key: 'emailBody',
|
||||
type: 'string',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
{
|
||||
label: 'Signature',
|
||||
key: 'signature',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listSignatures',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
{
|
||||
label: 'Label',
|
||||
key: 'labelId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listLabels',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const {
|
||||
tos,
|
||||
ccs,
|
||||
bccs,
|
||||
from,
|
||||
fromName,
|
||||
replyTo,
|
||||
subject,
|
||||
bodyType,
|
||||
emailBody,
|
||||
signature,
|
||||
labelId,
|
||||
} = $.step.parameters;
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const allTos = tos?.map((entry) => entry.to);
|
||||
const allCcs = ccs?.map((entry) => entry.cc);
|
||||
const allBccs = bccs?.map((entry) => entry.bcc);
|
||||
const contentType =
|
||||
bodyType === 'html'
|
||||
? 'text/html; charset="UTF-8"'
|
||||
: 'text/plain; charset="UTF-8"';
|
||||
|
||||
const email =
|
||||
'From: ' +
|
||||
fromName +
|
||||
' <' +
|
||||
from +
|
||||
'>' +
|
||||
'\r\n' +
|
||||
'Reply-To: ' +
|
||||
replyTo +
|
||||
'\r\n' +
|
||||
'To: ' +
|
||||
allTos.join(',') +
|
||||
'\r\n' +
|
||||
'Cc: ' +
|
||||
allCcs.join(',') +
|
||||
'\r\n' +
|
||||
'Bcc: ' +
|
||||
allBccs.join(',') +
|
||||
'\r\n' +
|
||||
'Subject: ' +
|
||||
subject +
|
||||
'\r\n' +
|
||||
'Content-Type: ' +
|
||||
contentType +
|
||||
'\r\n' +
|
||||
'\r\n' +
|
||||
emailBody +
|
||||
'\r\n' +
|
||||
'\r\n' +
|
||||
signature;
|
||||
|
||||
const base64EncodedEmailBody = Buffer.from(email).toString('base64');
|
||||
|
||||
const body = {
|
||||
labelIds: [labelId],
|
||||
raw: base64EncodedEmailBody,
|
||||
};
|
||||
|
||||
const { data } = await $.http.post(
|
||||
`/gmail/v1/users/${userId}/messages/send`,
|
||||
body
|
||||
);
|
||||
|
||||
$.setActionItem({
|
||||
raw: data,
|
||||
});
|
||||
},
|
||||
});
|
@@ -1,30 +0,0 @@
|
||||
import defineAction from '../../../../helpers/define-action.js';
|
||||
|
||||
export default defineAction({
|
||||
name: 'Send to trash',
|
||||
key: 'sendToTrash',
|
||||
description: 'Send an existing email message to the trash.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Message ID',
|
||||
key: 'messageId',
|
||||
type: 'string',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const { messageId } = $.step.parameters;
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const { data } = await $.http.post(
|
||||
`/gmail/v1/users/${userId}/messages/${messageId}/trash`
|
||||
);
|
||||
|
||||
$.setActionItem({
|
||||
raw: data,
|
||||
});
|
||||
},
|
||||
});
|
@@ -1,45 +0,0 @@
|
||||
import defineAction from '../../../../helpers/define-action.js';
|
||||
|
||||
export default defineAction({
|
||||
name: 'Star an email',
|
||||
key: 'starEmail',
|
||||
description: 'Star an email message.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Message ID',
|
||||
key: 'messageId',
|
||||
type: 'dropdown',
|
||||
required: true,
|
||||
description: '',
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listMessages',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const { messageId } = $.step.parameters;
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const body = {
|
||||
addLabelIds: ['STARRED'],
|
||||
};
|
||||
|
||||
const { data } = await $.http.post(
|
||||
`/gmail/v1/users/${userId}/messages/${messageId}/modify`,
|
||||
body
|
||||
);
|
||||
|
||||
$.setActionItem({
|
||||
raw: data,
|
||||
});
|
||||
},
|
||||
});
|
@@ -1,11 +0,0 @@
|
||||
<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 49.4 512 399.42">
|
||||
<g fill="none" fill-rule="evenodd">
|
||||
<g fill-rule="nonzero">
|
||||
<path fill="#4285f4" d="M34.91 448.818h81.454V251L0 163.727V413.91c0 19.287 15.622 34.91 34.91 34.91z"/>
|
||||
<path fill="#34a853" d="M395.636 448.818h81.455c19.287 0 34.909-15.622 34.909-34.909V163.727L395.636 251z"/>
|
||||
<path fill="#fbbc04" d="M395.636 99.727V251L512 163.727v-46.545c0-43.142-49.25-67.782-83.782-41.891z"/>
|
||||
</g>
|
||||
<path fill="#ea4335" d="M116.364 251V99.727L256 204.455 395.636 99.727V251L256 355.727z"/>
|
||||
<path fill="#c5221f" fill-rule="nonzero" d="M0 117.182v46.545L116.364 251V99.727L83.782 75.291C49.25 49.4 0 74.04 0 117.18z"/>
|
||||
</g>
|
||||
</svg>
|
Before Width: | Height: | Size: 720 B |
@@ -1,8 +0,0 @@
|
||||
const authScope = [
|
||||
'https://www.googleapis.com/auth/gmail.compose',
|
||||
'https://www.googleapis.com/auth/gmail.modify',
|
||||
'https://www.googleapis.com/auth/userinfo.email',
|
||||
'https://www.googleapis.com/auth/userinfo.profile',
|
||||
];
|
||||
|
||||
export default authScope;
|
@@ -1,8 +0,0 @@
|
||||
const getCurrentUser = async ($) => {
|
||||
const { data: currentUser } = await $.http.get(
|
||||
'https://people.googleapis.com/v1/people/me?personFields=names,emailAddresses'
|
||||
);
|
||||
return currentUser;
|
||||
};
|
||||
|
||||
export default getCurrentUser;
|
@@ -1,13 +0,0 @@
|
||||
import listEmails from './list-emails/index.js';
|
||||
import listLabels from './list-labels/index.js';
|
||||
import listMessages from './list-messages/index.js';
|
||||
import listSignatures from './list-signatures/index.js';
|
||||
import listThreads from './list-threads/index.js';
|
||||
|
||||
export default [
|
||||
listEmails,
|
||||
listLabels,
|
||||
listMessages,
|
||||
listSignatures,
|
||||
listThreads,
|
||||
];
|
@@ -1,23 +0,0 @@
|
||||
import getCurrentUser from '../../common/get-current-user.js';
|
||||
|
||||
export default {
|
||||
name: 'List emails',
|
||||
key: 'listEmails',
|
||||
|
||||
async run($) {
|
||||
const emails = {
|
||||
data: [],
|
||||
};
|
||||
|
||||
const currentUser = await getCurrentUser($);
|
||||
|
||||
for (const emailAddress of currentUser.emailAddresses) {
|
||||
emails.data.push({
|
||||
value: emailAddress.value,
|
||||
name: emailAddress.value,
|
||||
});
|
||||
}
|
||||
|
||||
return emails;
|
||||
},
|
||||
};
|
@@ -1,22 +0,0 @@
|
||||
export default {
|
||||
name: 'List labels',
|
||||
key: 'listLabels',
|
||||
|
||||
async run($) {
|
||||
const labels = {
|
||||
data: [],
|
||||
};
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const { data } = await $.http.get(`/gmail/v1/users/${userId}/labels`);
|
||||
|
||||
for (const label of data.labels) {
|
||||
labels.data.push({
|
||||
value: label.id,
|
||||
name: label.name,
|
||||
});
|
||||
}
|
||||
|
||||
return labels;
|
||||
},
|
||||
};
|
@@ -1,31 +0,0 @@
|
||||
export default {
|
||||
name: 'List messages',
|
||||
key: 'listMessages',
|
||||
|
||||
async run($) {
|
||||
const messages = {
|
||||
data: [],
|
||||
};
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const { data } = await $.http.get(`/gmail/v1/users/${userId}/messages`);
|
||||
|
||||
if (data.messages) {
|
||||
for (const message of data.messages) {
|
||||
const { data: messageData } = await $.http.get(
|
||||
`/gmail/v1/users/${userId}/messages/${message.id}`
|
||||
);
|
||||
const subject = messageData.payload.headers.find(
|
||||
(header) => header.name === 'Subject'
|
||||
);
|
||||
|
||||
messages.data.push({
|
||||
value: message.id,
|
||||
name: subject?.value,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
return messages;
|
||||
},
|
||||
};
|
@@ -1,24 +0,0 @@
|
||||
export default {
|
||||
name: 'List signatures',
|
||||
key: 'listSignatures',
|
||||
|
||||
async run($) {
|
||||
const signatures = {
|
||||
data: [],
|
||||
};
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const { data } = await $.http.get(
|
||||
`/gmail/v1/users/${userId}/settings/sendAs`
|
||||
);
|
||||
|
||||
for (const sendAs of data.sendAs) {
|
||||
signatures.data.push({
|
||||
value: sendAs.signature,
|
||||
name: sendAs.sendAsEmail,
|
||||
});
|
||||
}
|
||||
|
||||
return signatures;
|
||||
},
|
||||
};
|
@@ -1,31 +0,0 @@
|
||||
export default {
|
||||
name: 'List threads',
|
||||
key: 'listThreads',
|
||||
|
||||
async run($) {
|
||||
const threads = {
|
||||
data: [],
|
||||
};
|
||||
const userId = $.auth.data.userId;
|
||||
|
||||
const { data } = await $.http.get(`/gmail/v1/users/${userId}/threads`);
|
||||
|
||||
if (data.threads) {
|
||||
for (const thread of data.threads) {
|
||||
const { data: threadData } = await $.http.get(
|
||||
`/gmail/v1/users/${userId}/threads/${thread.id}`
|
||||
);
|
||||
const subject = threadData.messages[0].payload.headers.find(
|
||||
(header) => header.name === 'Subject'
|
||||
);
|
||||
|
||||
threads.data.push({
|
||||
value: thread.id,
|
||||
name: subject?.value,
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
return threads;
|
||||
},
|
||||
};
|
@@ -1,22 +0,0 @@
|
||||
import defineApp from '../../helpers/define-app.js';
|
||||
import addAuthHeader from './common/add-auth-header.js';
|
||||
import auth from './auth/index.js';
|
||||
import triggers from './triggers/index.js';
|
||||
import dynamicData from './dynamic-data/index.js';
|
||||
import actions from './actions/index.js';
|
||||
|
||||
export default defineApp({
|
||||
name: 'Gmail',
|
||||
key: 'gmail',
|
||||
baseUrl: 'https://mail.google.com',
|
||||
apiBaseUrl: 'https://gmail.googleapis.com',
|
||||
iconUrl: '{BASE_URL}/apps/gmail/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/gmail/connection',
|
||||
primaryColor: 'ea4335',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
auth,
|
||||
triggers,
|
||||
dynamicData,
|
||||
actions,
|
||||
});
|
@@ -1,3 +0,0 @@
|
||||
import newEmails from './new-emails/index.js';
|
||||
|
||||
export default [newEmails];
|
@@ -1,68 +0,0 @@
|
||||
import defineTrigger from '../../../../helpers/define-trigger.js';
|
||||
|
||||
export default defineTrigger({
|
||||
name: 'New emails',
|
||||
key: 'newEmails',
|
||||
pollInterval: 15,
|
||||
description:
|
||||
'Triggers when a new email is received in the specified mailbox.',
|
||||
arguments: [
|
||||
{
|
||||
label: 'Label',
|
||||
key: 'labelId',
|
||||
type: 'dropdown',
|
||||
required: false,
|
||||
description:
|
||||
"If you don't choose a label, this Zap will trigger for all emails, including Drafts.",
|
||||
variables: true,
|
||||
source: {
|
||||
type: 'query',
|
||||
name: 'getDynamicData',
|
||||
arguments: [
|
||||
{
|
||||
name: 'key',
|
||||
value: 'listLabels',
|
||||
},
|
||||
],
|
||||
},
|
||||
},
|
||||
],
|
||||
|
||||
async run($) {
|
||||
const userId = $.auth.data.userId;
|
||||
const labelId = $.step.parameters.labelId;
|
||||
|
||||
const params = {
|
||||
maxResults: 500,
|
||||
pageToken: undefined,
|
||||
};
|
||||
|
||||
if (labelId) {
|
||||
params.labelIds = labelId;
|
||||
}
|
||||
|
||||
do {
|
||||
const { data } = await $.http.get(`/gmail/v1/users/${userId}/messages`, {
|
||||
params,
|
||||
});
|
||||
params.pageToken = data.nextPageToken;
|
||||
|
||||
if (!data?.messages?.length) {
|
||||
return;
|
||||
}
|
||||
|
||||
for (const message of data.messages) {
|
||||
const { data: messageData } = await $.http.get(
|
||||
`/gmail/v1/users/${userId}/messages/${message.id}`
|
||||
);
|
||||
|
||||
$.pushTriggerItem({
|
||||
raw: messageData,
|
||||
meta: {
|
||||
internalId: messageData.id,
|
||||
},
|
||||
});
|
||||
}
|
||||
} while (params.pageToken);
|
||||
},
|
||||
});
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://calendar.google.com',
|
||||
apiBaseUrl: 'https://www.googleapis.com/calendar',
|
||||
iconUrl: '{BASE_URL}/apps/google-calendar/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/google-calendar/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/google-calendar/connection',
|
||||
primaryColor: '448AFF',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://drive.google.com',
|
||||
apiBaseUrl: 'https://www.googleapis.com/drive',
|
||||
iconUrl: '{BASE_URL}/apps/google-drive/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/google-drive/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/google-drive/connection',
|
||||
primaryColor: '1FA463',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://docs.google.com/forms',
|
||||
apiBaseUrl: 'https://forms.googleapis.com',
|
||||
iconUrl: '{BASE_URL}/apps/google-forms/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/google-forms/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/google-forms/connection',
|
||||
primaryColor: '673AB7',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -12,7 +12,7 @@ export default defineApp({
|
||||
baseUrl: 'https://docs.google.com/spreadsheets',
|
||||
apiBaseUrl: 'https://sheets.googleapis.com',
|
||||
iconUrl: '{BASE_URL}/apps/google-sheets/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/google-sheets/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/google-sheets/connection',
|
||||
primaryColor: '0F9D58',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://tryhelix.ai',
|
||||
apiBaseUrl: 'https://app.tryhelix.ai',
|
||||
iconUrl: '{BASE_URL}/apps/helix/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/helix/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/helix/connection',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
|
@@ -5,7 +5,7 @@ export default defineApp({
|
||||
name: 'HTTP Request',
|
||||
key: 'http-request',
|
||||
iconUrl: '{BASE_URL}/apps/http-request/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/http-request/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/http-request/connection',
|
||||
supportsConnections: false,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'HubSpot',
|
||||
key: 'hubspot',
|
||||
iconUrl: '{BASE_URL}/apps/hubspot/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/hubspot/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/hubspot/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://www.hubspot.com',
|
||||
apiBaseUrl: 'https://api.hubapi.com',
|
||||
|
@@ -12,7 +12,7 @@ export default defineApp({
|
||||
baseUrl: 'https://invoiceninja.com',
|
||||
apiBaseUrl: 'https://invoicing.co/api',
|
||||
iconUrl: '{BASE_URL}/apps/invoice-ninja/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/invoice-ninja/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/invoice-ninja/connection',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
name: 'Mattermost',
|
||||
key: 'mattermost',
|
||||
iconUrl: '{BASE_URL}/apps/mattermost/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/mattermost/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/mattermost/connection',
|
||||
baseUrl: 'https://mattermost.com',
|
||||
apiBaseUrl: '', // there is no cloud version of this app, user always need to provide address of own instance when creating connection
|
||||
primaryColor: '4a154b',
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://miro.com',
|
||||
apiBaseUrl: 'https://api.miro.com',
|
||||
iconUrl: '{BASE_URL}/apps/miro/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/miro/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/miro/connection',
|
||||
primaryColor: 'F2CA02',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -12,7 +12,7 @@ export default defineApp({
|
||||
baseUrl: 'https://notion.com',
|
||||
apiBaseUrl: 'https://api.notion.com',
|
||||
iconUrl: '{BASE_URL}/apps/notion/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/notion/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/notion/connection',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader, addNotionVersionHeader],
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Ntfy',
|
||||
key: 'ntfy',
|
||||
iconUrl: '{BASE_URL}/apps/ntfy/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/ntfy/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/ntfy/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://ntfy.sh',
|
||||
apiBaseUrl: 'https://ntfy.sh',
|
||||
|
@@ -6,7 +6,7 @@ export default defineApp({
|
||||
name: 'Odoo',
|
||||
key: 'odoo',
|
||||
iconUrl: '{BASE_URL}/apps/odoo/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/odoo/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/odoo/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://odoo.com',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://openai.com',
|
||||
apiBaseUrl: 'https://api.openai.com',
|
||||
iconUrl: '{BASE_URL}/apps/openai/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/openai/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/openai/connection',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -12,7 +12,7 @@ export default defineApp({
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
iconUrl: '{BASE_URL}/apps/pipedrive/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/pipedrive/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/pipedrive/connection',
|
||||
primaryColor: 'FFFFFF',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
|
@@ -8,7 +8,7 @@ export default defineApp({
|
||||
name: 'Placetel',
|
||||
key: 'placetel',
|
||||
iconUrl: '{BASE_URL}/apps/placetel/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/placetel/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/placetel/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://placetel.de',
|
||||
apiBaseUrl: 'https://api.placetel.de',
|
||||
|
@@ -6,7 +6,7 @@ export default defineApp({
|
||||
name: 'PostgreSQL',
|
||||
key: 'postgresql',
|
||||
iconUrl: '{BASE_URL}/apps/postgresql/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/postgresql/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/postgresql/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
baseUrl: 'https://pushover.net',
|
||||
apiBaseUrl: 'https://api.pushover.net',
|
||||
iconUrl: '{BASE_URL}/apps/pushover/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/pushover/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/pushover/connection',
|
||||
primaryColor: '249DF1',
|
||||
supportsConnections: true,
|
||||
auth,
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://www.reddit.com',
|
||||
apiBaseUrl: 'https://oauth.reddit.com',
|
||||
iconUrl: '{BASE_URL}/apps/reddit/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/reddit/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/reddit/connection',
|
||||
primaryColor: 'FF4500',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Remove.bg',
|
||||
key: 'removebg',
|
||||
iconUrl: '{BASE_URL}/apps/removebg/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/removebg/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/removebg/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://www.remove.bg',
|
||||
apiBaseUrl: 'https://api.remove.bg/v1.0',
|
||||
|
@@ -5,7 +5,7 @@ export default defineApp({
|
||||
name: 'RSS',
|
||||
key: 'rss',
|
||||
iconUrl: '{BASE_URL}/apps/rss/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/rss/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/rss/connection',
|
||||
supportsConnections: false,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
name: 'Salesforce',
|
||||
key: 'salesforce',
|
||||
iconUrl: '{BASE_URL}/apps/salesforce/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/connections/salesforce',
|
||||
authDocUrl: '{DOCS_URL}/connections/salesforce',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://salesforce.com',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -6,7 +6,7 @@ export default defineApp({
|
||||
key: 'scheduler',
|
||||
iconUrl: '{BASE_URL}/apps/scheduler/assets/favicon.svg',
|
||||
docUrl: 'https://automatisch.io/docs/scheduler',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/scheduler/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/scheduler/connection',
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
primaryColor: '0059F7',
|
||||
|
@@ -11,7 +11,7 @@ export default defineApp({
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
iconUrl: '{BASE_URL}/apps/self-hosted-llm/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/self-hosted-llm/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/self-hosted-llm/connection',
|
||||
primaryColor: '000000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
name: 'SignalWire',
|
||||
key: 'signalwire',
|
||||
iconUrl: '{BASE_URL}/apps/signalwire/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/signalwire/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/signalwire/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://signalwire.com',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
name: 'Slack',
|
||||
key: 'slack',
|
||||
iconUrl: '{BASE_URL}/apps/slack/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/slack/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/slack/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://slack.com',
|
||||
apiBaseUrl: 'https://slack.com/api',
|
||||
|
@@ -6,7 +6,7 @@ export default defineApp({
|
||||
name: 'SMTP',
|
||||
key: 'smtp',
|
||||
iconUrl: '{BASE_URL}/apps/smtp/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/smtp/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/smtp/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Spotify',
|
||||
key: 'spotify',
|
||||
iconUrl: '{BASE_URL}/apps/spotify/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/spotify/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/spotify/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://spotify.com',
|
||||
apiBaseUrl: 'https://api.spotify.com',
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Strava',
|
||||
key: 'strava',
|
||||
iconUrl: '{BASE_URL}/apps/strava/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/connections/strava',
|
||||
authDocUrl: '{DOCS_URL}/connections/strava',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://www.strava.com',
|
||||
apiBaseUrl: 'https://www.strava.com/api',
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Stripe',
|
||||
key: 'stripe',
|
||||
iconUrl: '{BASE_URL}/apps/stripe/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/stripe/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/stripe/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://stripe.com',
|
||||
apiBaseUrl: 'https://api.stripe.com',
|
||||
|
@@ -7,7 +7,7 @@ export default defineApp({
|
||||
name: 'Telegram',
|
||||
key: 'telegram-bot',
|
||||
iconUrl: '{BASE_URL}/apps/telegram-bot/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/telegram-bot/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/telegram-bot/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://telegram.org',
|
||||
apiBaseUrl: 'https://api.telegram.org',
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
name: 'Todoist',
|
||||
key: 'todoist',
|
||||
iconUrl: '{BASE_URL}/apps/todoist/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/todoist/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/todoist/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://todoist.com',
|
||||
apiBaseUrl: 'https://api.todoist.com/rest/v2',
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://trello.com/',
|
||||
apiBaseUrl: 'https://api.trello.com',
|
||||
iconUrl: '{BASE_URL}/apps/trello/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/trello/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/trello/connection',
|
||||
supportsConnections: true,
|
||||
primaryColor: '0079bf',
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
name: 'Twilio',
|
||||
key: 'twilio',
|
||||
iconUrl: '{BASE_URL}/apps/twilio/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/twilio/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/twilio/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://twilio.com',
|
||||
apiBaseUrl: 'https://api.twilio.com',
|
||||
|
@@ -8,7 +8,7 @@ export default defineApp({
|
||||
name: 'Twitter',
|
||||
key: 'twitter',
|
||||
iconUrl: '{BASE_URL}/apps/twitter/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/twitter/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/twitter/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://twitter.com',
|
||||
apiBaseUrl: 'https://api.twitter.com',
|
||||
|
@@ -8,7 +8,7 @@ export default defineApp({
|
||||
name: 'Typeform',
|
||||
key: 'typeform',
|
||||
iconUrl: '{BASE_URL}/apps/typeform/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/typeform/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/typeform/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://typeform.com',
|
||||
apiBaseUrl: 'https://api.typeform.com',
|
||||
|
@@ -6,7 +6,7 @@ export default defineApp({
|
||||
name: 'Webhook',
|
||||
key: 'webhook',
|
||||
iconUrl: '{BASE_URL}/apps/webhook/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/webhook/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/webhook/connection',
|
||||
supportsConnections: false,
|
||||
baseUrl: '',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
name: 'WordPress',
|
||||
key: 'wordpress',
|
||||
iconUrl: '{BASE_URL}/apps/wordpress/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/wordpress/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/wordpress/connection',
|
||||
supportsConnections: true,
|
||||
baseUrl: 'https://wordpress.com',
|
||||
apiBaseUrl: '',
|
||||
|
@@ -10,7 +10,7 @@ export default defineApp({
|
||||
baseUrl: 'https://go.xero.com',
|
||||
apiBaseUrl: 'https://api.xero.com',
|
||||
iconUrl: '{BASE_URL}/apps/xero/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/xero/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/xero/connection',
|
||||
primaryColor: '13B5EA',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -9,7 +9,7 @@ export default defineApp({
|
||||
baseUrl: 'https://www.youtube.com/',
|
||||
apiBaseUrl: 'https://www.googleapis.com/youtube',
|
||||
iconUrl: '{BASE_URL}/apps/youtube/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/youtube/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/youtube/connection',
|
||||
primaryColor: 'FF0000',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -11,7 +11,7 @@ export default defineApp({
|
||||
baseUrl: 'https://zendesk.com/',
|
||||
apiBaseUrl: '',
|
||||
iconUrl: '{BASE_URL}/apps/zendesk/assets/favicon.svg',
|
||||
authDocUrl: 'https://automatisch.io/docs/apps/zendesk/connection',
|
||||
authDocUrl: '{DOCS_URL}/apps/zendesk/connection',
|
||||
primaryColor: '17494d',
|
||||
supportsConnections: true,
|
||||
beforeRequest: [addAuthHeader],
|
||||
|
@@ -38,6 +38,9 @@ if (process.env.WEB_APP_URL) {
|
||||
let webhookUrl = new URL(process.env.WEBHOOK_URL || apiUrl).toString();
|
||||
webhookUrl = webhookUrl.substring(0, webhookUrl.length - 1);
|
||||
|
||||
const publicDocsUrl = 'https://automatisch.io/docs';
|
||||
const docsUrl = process.env.DOCS_URL || publicDocsUrl;
|
||||
|
||||
const appEnv = process.env.APP_ENV || 'development';
|
||||
|
||||
const appConfig = {
|
||||
@@ -73,6 +76,7 @@ const appConfig = {
|
||||
baseUrl: apiUrl,
|
||||
webAppUrl,
|
||||
webhookUrl,
|
||||
docsUrl,
|
||||
telemetryEnabled: process.env.TELEMETRY_ENABLED === 'false' ? false : true,
|
||||
requestBodySizeLimit: '1mb',
|
||||
smtpHost: process.env.SMTP_HOST,
|
||||
|
@@ -2,7 +2,7 @@ import appConfig from './app.js';
|
||||
|
||||
const corsOptions = {
|
||||
origin: appConfig.webAppUrl,
|
||||
methods: 'POST',
|
||||
methods: 'GET,HEAD,POST,DELETE',
|
||||
credentials: true,
|
||||
optionsSuccessStatus: 200,
|
||||
};
|
||||
|
@@ -0,0 +1,15 @@
|
||||
export default async (request, response) => {
|
||||
const token = request.params.token;
|
||||
|
||||
const accessToken = await request.currentUser
|
||||
.$relatedQuery('accessTokens')
|
||||
.findOne({
|
||||
token,
|
||||
revoked_at: null,
|
||||
})
|
||||
.throwIfNotFound();
|
||||
|
||||
await accessToken.revoke();
|
||||
|
||||
response.status(204).send();
|
||||
};
|
@@ -0,0 +1,54 @@
|
||||
import { expect, describe, it, beforeEach } from 'vitest';
|
||||
import request from 'supertest';
|
||||
import app from '../../../../app.js';
|
||||
import createAuthTokenByUserId from '../../../../helpers/create-auth-token-by-user-id';
|
||||
import { createUser } from '../../../../../test/factories/user.js';
|
||||
import AccessToken from '../../../../models/access-token.js';
|
||||
|
||||
describe('DELETE /api/v1/access-tokens/:token', () => {
|
||||
let token;
|
||||
|
||||
beforeEach(async () => {
|
||||
const currentUser = await createUser({
|
||||
email: 'user@automatisch.io',
|
||||
password: 'password',
|
||||
});
|
||||
token = await createAuthTokenByUserId(currentUser.id);
|
||||
});
|
||||
|
||||
it('should respond with HTTP 204 with correct token', async () => {
|
||||
await request(app)
|
||||
.delete(`/api/v1/access-tokens/${token}`)
|
||||
.set('Authorization', token)
|
||||
.expect(204);
|
||||
|
||||
const revokedToken = await AccessToken.query().findOne({ token });
|
||||
|
||||
expect(revokedToken).toBeDefined();
|
||||
expect(revokedToken.revokedAt).not.toBeNull();
|
||||
});
|
||||
|
||||
it('should respond with HTTP 401 with incorrect credentials', async () => {
|
||||
await request(app)
|
||||
.delete(`/api/v1/access-tokens/${token}`)
|
||||
.set('Authorization', 'wrong-token')
|
||||
.expect(401);
|
||||
|
||||
const unrevokedToken = await AccessToken.query().findOne({ token });
|
||||
|
||||
expect(unrevokedToken).toBeDefined();
|
||||
expect(unrevokedToken.revokedAt).toBeNull();
|
||||
});
|
||||
|
||||
it('should respond with HTTP 404 with correct credentials, but non-valid token', async () => {
|
||||
await request(app)
|
||||
.delete('/api/v1/access-tokens/wrong-token')
|
||||
.set('Authorization', token)
|
||||
.expect(404);
|
||||
|
||||
const unrevokedToken = await AccessToken.query().findOne({ token });
|
||||
|
||||
expect(unrevokedToken).toBeDefined();
|
||||
expect(unrevokedToken.revokedAt).toBeNull();
|
||||
});
|
||||
});
|
@@ -22,7 +22,7 @@ describe('GET /api/v1/admin/apps/:appKey/auth-clients/:appAuthClientId', () => {
|
||||
appKey: 'deepl',
|
||||
});
|
||||
|
||||
token = createAuthTokenByUserId(currentUser.id);
|
||||
token = await createAuthTokenByUserId(currentUser.id);
|
||||
});
|
||||
|
||||
it('should return specified app auth client', async () => {
|
||||
|
@@ -17,7 +17,7 @@ describe('GET /api/v1/admin/apps/:appKey/auth-clients', () => {
|
||||
adminRole = await createRole({ key: 'admin' });
|
||||
currentUser = await createUser({ roleId: adminRole.id });
|
||||
|
||||
token = createAuthTokenByUserId(currentUser.id);
|
||||
token = await createAuthTokenByUserId(currentUser.id);
|
||||
});
|
||||
|
||||
it('should return specified app auth client info', async () => {
|
||||
|
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user