Compare commits
5 Commits
AUT-1005
...
custom-dep
Author | SHA1 | Date | |
---|---|---|---|
![]() |
76296532cf | ||
![]() |
10290ce6e3 | ||
![]() |
a2df7c1e89 | ||
![]() |
b89ba1e623 | ||
![]() |
4d0481a3c6 |
@@ -2,7 +2,6 @@ import appConfig from '../../src/config/app.js';
|
|||||||
import logger from '../../src/helpers/logger.js';
|
import logger from '../../src/helpers/logger.js';
|
||||||
import client from './client.js';
|
import client from './client.js';
|
||||||
import User from '../../src/models/user.js';
|
import User from '../../src/models/user.js';
|
||||||
import Config from '../../src/models/config.js';
|
|
||||||
import Role from '../../src/models/role.js';
|
import Role from '../../src/models/role.js';
|
||||||
import '../../src/config/orm.js';
|
import '../../src/config/orm.js';
|
||||||
import process from 'process';
|
import process from 'process';
|
||||||
@@ -46,8 +45,6 @@ export async function createUser(
|
|||||||
if (userCount === 0) {
|
if (userCount === 0) {
|
||||||
const user = await User.query().insertAndFetch(userParams);
|
const user = await User.query().insertAndFetch(userParams);
|
||||||
logger.info(`User has been saved: ${user.email}`);
|
logger.info(`User has been saved: ${user.email}`);
|
||||||
|
|
||||||
await Config.markInstallationCompleted();
|
|
||||||
} else {
|
} else {
|
||||||
logger.info('No need to seed a user.');
|
logger.info('No need to seed a user.');
|
||||||
}
|
}
|
||||||
|
@@ -1,92 +0,0 @@
|
|||||||
import defineAction from '../../../../helpers/define-action.js';
|
|
||||||
|
|
||||||
export default defineAction({
|
|
||||||
name: 'Create record',
|
|
||||||
key: 'createRecord',
|
|
||||||
description: 'Creates a new record with fields that automatically populate.',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Base',
|
|
||||||
key: 'baseId',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
description: 'Base in which to create the record.',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listBases',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Table',
|
|
||||||
key: 'tableId',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
dependsOn: ['parameters.baseId'],
|
|
||||||
description: '',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listTables',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.baseId',
|
|
||||||
value: '{parameters.baseId}',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
additionalFields: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicFields',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listFields',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.baseId',
|
|
||||||
value: '{parameters.baseId}',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.tableId',
|
|
||||||
value: '{parameters.tableId}',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const { baseId, tableId, ...rest } = $.step.parameters;
|
|
||||||
|
|
||||||
const fields = Object.entries(rest).reduce((result, [key, value]) => {
|
|
||||||
if (Array.isArray(value)) {
|
|
||||||
result[key] = value.map((item) => item.value);
|
|
||||||
} else if (value !== '') {
|
|
||||||
result[key] = value;
|
|
||||||
}
|
|
||||||
return result;
|
|
||||||
}, {});
|
|
||||||
|
|
||||||
const body = {
|
|
||||||
typecast: true,
|
|
||||||
fields,
|
|
||||||
};
|
|
||||||
|
|
||||||
const { data } = await $.http.post(`/v0/${baseId}/${tableId}`, body);
|
|
||||||
|
|
||||||
$.setActionItem({
|
|
||||||
raw: data,
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
@@ -1,174 +0,0 @@
|
|||||||
import defineAction from '../../../../helpers/define-action.js';
|
|
||||||
import { URLSearchParams } from 'url';
|
|
||||||
|
|
||||||
export default defineAction({
|
|
||||||
name: 'Find record',
|
|
||||||
key: 'findRecord',
|
|
||||||
description:
|
|
||||||
"Finds a record using simple field search or use Airtable's formula syntax to find a matching record.",
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Base',
|
|
||||||
key: 'baseId',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
description: 'Base in which to create the record.',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listBases',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Table',
|
|
||||||
key: 'tableId',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
dependsOn: ['parameters.baseId'],
|
|
||||||
description: '',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listTables',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.baseId',
|
|
||||||
value: '{parameters.baseId}',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Search by field',
|
|
||||||
key: 'tableField',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: false,
|
|
||||||
dependsOn: ['parameters.baseId', 'parameters.tableId'],
|
|
||||||
description: '',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listTableFields',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.baseId',
|
|
||||||
value: '{parameters.baseId}',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.tableId',
|
|
||||||
value: '{parameters.tableId}',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Search Value',
|
|
||||||
key: 'searchValue',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description:
|
|
||||||
'The value of unique identifier for the record. For date values, please use the ISO format (e.g., "YYYY-MM-DD").',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Search for exact match?',
|
|
||||||
key: 'exactMatch',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
description: '',
|
|
||||||
variables: true,
|
|
||||||
options: [
|
|
||||||
{ label: 'Yes', value: 'true' },
|
|
||||||
{ label: 'No', value: 'false' },
|
|
||||||
],
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Search Formula',
|
|
||||||
key: 'searchFormula',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
description:
|
|
||||||
'Instead, you have the option to use an Airtable search formula for locating records according to sophisticated criteria and across various fields.',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Limit to View',
|
|
||||||
key: 'limitToView',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: false,
|
|
||||||
dependsOn: ['parameters.baseId', 'parameters.tableId'],
|
|
||||||
description:
|
|
||||||
'You have the choice to restrict the search to a particular view ID if desired.',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listTableViews',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.baseId',
|
|
||||||
value: '{parameters.baseId}',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.tableId',
|
|
||||||
value: '{parameters.tableId}',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const {
|
|
||||||
baseId,
|
|
||||||
tableId,
|
|
||||||
tableField,
|
|
||||||
searchValue,
|
|
||||||
exactMatch,
|
|
||||||
searchFormula,
|
|
||||||
limitToView,
|
|
||||||
} = $.step.parameters;
|
|
||||||
|
|
||||||
let filterByFormula;
|
|
||||||
|
|
||||||
if (tableField && searchValue) {
|
|
||||||
filterByFormula =
|
|
||||||
exactMatch === 'true'
|
|
||||||
? `{${tableField}} = '${searchValue}'`
|
|
||||||
: `LOWER({${tableField}}) = LOWER('${searchValue}')`;
|
|
||||||
} else {
|
|
||||||
filterByFormula = searchFormula;
|
|
||||||
}
|
|
||||||
|
|
||||||
const body = new URLSearchParams({
|
|
||||||
filterByFormula,
|
|
||||||
view: limitToView,
|
|
||||||
});
|
|
||||||
|
|
||||||
const { data } = await $.http.post(
|
|
||||||
`/v0/${baseId}/${tableId}/listRecords`,
|
|
||||||
body
|
|
||||||
);
|
|
||||||
|
|
||||||
$.setActionItem({
|
|
||||||
raw: data,
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
@@ -1,4 +0,0 @@
|
|||||||
import createRecord from './create-record/index.js';
|
|
||||||
import findRecord from './find-record/index.js';
|
|
||||||
|
|
||||||
export default [createRecord, findRecord];
|
|
@@ -1,9 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<svg width="256px" height="215px" viewBox="0 0 256 215" version="1.1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" preserveAspectRatio="xMidYMid">
|
|
||||||
<g>
|
|
||||||
<path d="M114.25873,2.70101695 L18.8604023,42.1756384 C13.5552723,44.3711638 13.6102328,51.9065311 18.9486282,54.0225085 L114.746142,92.0117514 C123.163769,95.3498757 132.537419,95.3498757 140.9536,92.0117514 L236.75256,54.0225085 C242.08951,51.9065311 242.145916,44.3711638 236.83934,42.1756384 L141.442459,2.70101695 C132.738459,-0.900338983 122.961284,-0.900338983 114.25873,2.70101695" fill="#FFBF00"></path>
|
|
||||||
<path d="M136.349071,112.756863 L136.349071,207.659101 C136.349071,212.173089 140.900664,215.263892 145.096461,213.600615 L251.844122,172.166219 C254.281184,171.200072 255.879376,168.845451 255.879376,166.224705 L255.879376,71.3224678 C255.879376,66.8084791 251.327783,63.7176768 247.131986,65.3809537 L140.384325,106.815349 C137.94871,107.781496 136.349071,110.136118 136.349071,112.756863" fill="#26B5F8"></path>
|
|
||||||
<path d="M111.422771,117.65355 L79.742409,132.949912 L76.5257763,134.504714 L9.65047684,166.548104 C5.4112904,168.593211 0.000578531073,165.503855 0.000578531073,160.794612 L0.000578531073,71.7210757 C0.000578531073,70.0173017 0.874160452,68.5463864 2.04568588,67.4384994 C2.53454463,66.9481944 3.08848814,66.5446689 3.66412655,66.2250305 C5.26231864,65.2661153 7.54173107,65.0101153 9.47981017,65.7766689 L110.890522,105.957098 C116.045234,108.002206 116.450206,115.225166 111.422771,117.65355" fill="#ED3049"></path>
|
|
||||||
<path d="M111.422771,117.65355 L79.742409,132.949912 L2.04568588,67.4384994 C2.53454463,66.9481944 3.08848814,66.5446689 3.66412655,66.2250305 C5.26231864,65.2661153 7.54173107,65.0101153 9.47981017,65.7766689 L110.890522,105.957098 C116.045234,108.002206 116.450206,115.225166 111.422771,117.65355" fill-opacity="0.25" fill="#000000"></path>
|
|
||||||
</g>
|
|
||||||
</svg>
|
|
Before Width: | Height: | Size: 1.9 KiB |
@@ -1,38 +0,0 @@
|
|||||||
import crypto from 'crypto';
|
|
||||||
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 = crypto.randomBytes(100).toString('base64url');
|
|
||||||
const codeVerifier = crypto.randomBytes(96).toString('base64url');
|
|
||||||
const codeChallenge = crypto
|
|
||||||
.createHash('sha256')
|
|
||||||
.update(codeVerifier)
|
|
||||||
.digest('base64')
|
|
||||||
.replace(/=/g, '')
|
|
||||||
.replace(/\+/g, '-')
|
|
||||||
.replace(/\//g, '_');
|
|
||||||
|
|
||||||
const searchParams = new URLSearchParams({
|
|
||||||
client_id: $.auth.data.clientId,
|
|
||||||
redirect_uri: redirectUri,
|
|
||||||
response_type: 'code',
|
|
||||||
scope: authScope.join(' '),
|
|
||||||
state,
|
|
||||||
code_challenge: codeChallenge,
|
|
||||||
code_challenge_method: 'S256',
|
|
||||||
});
|
|
||||||
|
|
||||||
const url = `https://airtable.com/oauth2/v1/authorize?${searchParams.toString()}`;
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
url,
|
|
||||||
originalCodeChallenge: codeChallenge,
|
|
||||||
originalState: state,
|
|
||||||
codeVerifier,
|
|
||||||
});
|
|
||||||
}
|
|
@@ -1,48 +0,0 @@
|
|||||||
import generateAuthUrl from './generate-auth-url.js';
|
|
||||||
import verifyCredentials from './verify-credentials.js';
|
|
||||||
import refreshToken from './refresh-token.js';
|
|
||||||
import isStillVerified from './is-still-verified.js';
|
|
||||||
|
|
||||||
export default {
|
|
||||||
fields: [
|
|
||||||
{
|
|
||||||
key: 'oAuthRedirectUrl',
|
|
||||||
label: 'OAuth Redirect URL',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: true,
|
|
||||||
value: '{WEB_APP_URL}/app/airtable/connections/add',
|
|
||||||
placeholder: null,
|
|
||||||
description:
|
|
||||||
'When asked to input a redirect URL in Airtable, enter the URL above.',
|
|
||||||
clickToCopy: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'clientId',
|
|
||||||
label: 'Client ID',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: null,
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'clientSecret',
|
|
||||||
label: 'Client Secret',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: null,
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
generateAuthUrl,
|
|
||||||
verifyCredentials,
|
|
||||||
isStillVerified,
|
|
||||||
refreshToken,
|
|
||||||
};
|
|
@@ -1,8 +0,0 @@
|
|||||||
import getCurrentUser from '../common/get-current-user.js';
|
|
||||||
|
|
||||||
const isStillVerified = async ($) => {
|
|
||||||
const currentUser = await getCurrentUser($);
|
|
||||||
return !!currentUser.id;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default isStillVerified;
|
|
@@ -1,40 +0,0 @@
|
|||||||
import { URLSearchParams } from 'node:url';
|
|
||||||
|
|
||||||
import authScope from '../common/auth-scope.js';
|
|
||||||
|
|
||||||
const refreshToken = async ($) => {
|
|
||||||
const params = new URLSearchParams({
|
|
||||||
client_id: $.auth.data.clientId,
|
|
||||||
grant_type: 'refresh_token',
|
|
||||||
refresh_token: $.auth.data.refreshToken,
|
|
||||||
});
|
|
||||||
|
|
||||||
const basicAuthToken = Buffer.from(
|
|
||||||
$.auth.data.clientId + ':' + $.auth.data.clientSecret
|
|
||||||
).toString('base64');
|
|
||||||
|
|
||||||
const { data } = await $.http.post(
|
|
||||||
'https://airtable.com/oauth2/v1/token',
|
|
||||||
params.toString(),
|
|
||||||
{
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/x-www-form-urlencoded',
|
|
||||||
Authorization: `Basic ${basicAuthToken}`,
|
|
||||||
},
|
|
||||||
additionalProperties: {
|
|
||||||
skipAddingAuthHeader: true,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
accessToken: data.access_token,
|
|
||||||
refreshToken: data.refresh_token,
|
|
||||||
expiresIn: data.expires_in,
|
|
||||||
refreshExpiresIn: data.refresh_expires_in,
|
|
||||||
scope: authScope.join(' '),
|
|
||||||
tokenType: data.token_type,
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
export default refreshToken;
|
|
@@ -1,56 +0,0 @@
|
|||||||
import getCurrentUser from '../common/get-current-user.js';
|
|
||||||
|
|
||||||
const verifyCredentials = async ($) => {
|
|
||||||
if ($.auth.data.originalState !== $.auth.data.state) {
|
|
||||||
throw new Error("The 'state' parameter does not match.");
|
|
||||||
}
|
|
||||||
if ($.auth.data.originalCodeChallenge !== $.auth.data.code_challenge) {
|
|
||||||
throw new Error("The 'code challenge' parameter does not match.");
|
|
||||||
}
|
|
||||||
const oauthRedirectUrlField = $.app.auth.fields.find(
|
|
||||||
(field) => field.key == 'oAuthRedirectUrl'
|
|
||||||
);
|
|
||||||
const redirectUri = oauthRedirectUrlField.value;
|
|
||||||
const basicAuthToken = Buffer.from(
|
|
||||||
$.auth.data.clientId + ':' + $.auth.data.clientSecret
|
|
||||||
).toString('base64');
|
|
||||||
|
|
||||||
const { data } = await $.http.post(
|
|
||||||
'https://airtable.com/oauth2/v1/token',
|
|
||||||
{
|
|
||||||
code: $.auth.data.code,
|
|
||||||
client_id: $.auth.data.clientId,
|
|
||||||
redirect_uri: redirectUri,
|
|
||||||
grant_type: 'authorization_code',
|
|
||||||
code_verifier: $.auth.data.codeVerifier,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/x-www-form-urlencoded',
|
|
||||||
Authorization: `Basic ${basicAuthToken}`,
|
|
||||||
},
|
|
||||||
additionalProperties: {
|
|
||||||
skipAddingAuthHeader: true,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
accessToken: data.access_token,
|
|
||||||
tokenType: data.token_type,
|
|
||||||
});
|
|
||||||
|
|
||||||
const currentUser = await getCurrentUser($);
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
clientId: $.auth.data.clientId,
|
|
||||||
clientSecret: $.auth.data.clientSecret,
|
|
||||||
scope: $.auth.data.scope,
|
|
||||||
expiresIn: data.expires_in,
|
|
||||||
refreshExpiresIn: data.refresh_expires_in,
|
|
||||||
refreshToken: data.refresh_token,
|
|
||||||
screenName: currentUser.email,
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
export default verifyCredentials;
|
|
@@ -1,12 +0,0 @@
|
|||||||
const addAuthHeader = ($, requestConfig) => {
|
|
||||||
if (
|
|
||||||
!requestConfig.additionalProperties?.skipAddingAuthHeader &&
|
|
||||||
$.auth.data?.accessToken
|
|
||||||
) {
|
|
||||||
requestConfig.headers.Authorization = `${$.auth.data.tokenType} ${$.auth.data.accessToken}`;
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default addAuthHeader;
|
|
@@ -1,12 +0,0 @@
|
|||||||
const authScope = [
|
|
||||||
'data.records:read',
|
|
||||||
'data.records:write',
|
|
||||||
'data.recordComments:read',
|
|
||||||
'data.recordComments:write',
|
|
||||||
'schema.bases:read',
|
|
||||||
'schema.bases:write',
|
|
||||||
'user.email:read',
|
|
||||||
'webhook:manage',
|
|
||||||
];
|
|
||||||
|
|
||||||
export default authScope;
|
|
@@ -1,6 +0,0 @@
|
|||||||
const getCurrentUser = async ($) => {
|
|
||||||
const { data: currentUser } = await $.http.get('/v0/meta/whoami');
|
|
||||||
return currentUser;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default getCurrentUser;
|
|
@@ -1,6 +0,0 @@
|
|||||||
import listBases from './list-bases/index.js';
|
|
||||||
import listTableFields from './list-table-fields/index.js';
|
|
||||||
import listTableViews from './list-table-views/index.js';
|
|
||||||
import listTables from './list-tables/index.js';
|
|
||||||
|
|
||||||
export default [listBases, listTableFields, listTableViews, listTables];
|
|
@@ -1,28 +0,0 @@
|
|||||||
export default {
|
|
||||||
name: 'List bases',
|
|
||||||
key: 'listBases',
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const bases = {
|
|
||||||
data: [],
|
|
||||||
};
|
|
||||||
|
|
||||||
const params = {};
|
|
||||||
|
|
||||||
do {
|
|
||||||
const { data } = await $.http.get('/v0/meta/bases', { params });
|
|
||||||
params.offset = data.offset;
|
|
||||||
|
|
||||||
if (data?.bases) {
|
|
||||||
for (const base of data.bases) {
|
|
||||||
bases.data.push({
|
|
||||||
value: base.id,
|
|
||||||
name: base.name,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} while (params.offset);
|
|
||||||
|
|
||||||
return bases;
|
|
||||||
},
|
|
||||||
};
|
|
@@ -1,39 +0,0 @@
|
|||||||
export default {
|
|
||||||
name: 'List table fields',
|
|
||||||
key: 'listTableFields',
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const tableFields = {
|
|
||||||
data: [],
|
|
||||||
};
|
|
||||||
const { baseId, tableId } = $.step.parameters;
|
|
||||||
|
|
||||||
if (!baseId) {
|
|
||||||
return tableFields;
|
|
||||||
}
|
|
||||||
|
|
||||||
const params = {};
|
|
||||||
|
|
||||||
do {
|
|
||||||
const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`, {
|
|
||||||
params,
|
|
||||||
});
|
|
||||||
params.offset = data.offset;
|
|
||||||
|
|
||||||
if (data?.tables) {
|
|
||||||
for (const table of data.tables) {
|
|
||||||
if (table.id === tableId) {
|
|
||||||
table.fields.forEach((field) => {
|
|
||||||
tableFields.data.push({
|
|
||||||
value: field.name,
|
|
||||||
name: field.name,
|
|
||||||
});
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} while (params.offset);
|
|
||||||
|
|
||||||
return tableFields;
|
|
||||||
},
|
|
||||||
};
|
|
@@ -1,39 +0,0 @@
|
|||||||
export default {
|
|
||||||
name: 'List table views',
|
|
||||||
key: 'listTableViews',
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const tableViews = {
|
|
||||||
data: [],
|
|
||||||
};
|
|
||||||
const { baseId, tableId } = $.step.parameters;
|
|
||||||
|
|
||||||
if (!baseId) {
|
|
||||||
return tableViews;
|
|
||||||
}
|
|
||||||
|
|
||||||
const params = {};
|
|
||||||
|
|
||||||
do {
|
|
||||||
const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`, {
|
|
||||||
params,
|
|
||||||
});
|
|
||||||
params.offset = data.offset;
|
|
||||||
|
|
||||||
if (data?.tables) {
|
|
||||||
for (const table of data.tables) {
|
|
||||||
if (table.id === tableId) {
|
|
||||||
table.views.forEach((view) => {
|
|
||||||
tableViews.data.push({
|
|
||||||
value: view.id,
|
|
||||||
name: view.name,
|
|
||||||
});
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} while (params.offset);
|
|
||||||
|
|
||||||
return tableViews;
|
|
||||||
},
|
|
||||||
};
|
|
@@ -1,35 +0,0 @@
|
|||||||
export default {
|
|
||||||
name: 'List tables',
|
|
||||||
key: 'listTables',
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const tables = {
|
|
||||||
data: [],
|
|
||||||
};
|
|
||||||
const baseId = $.step.parameters.baseId;
|
|
||||||
|
|
||||||
if (!baseId) {
|
|
||||||
return tables;
|
|
||||||
}
|
|
||||||
|
|
||||||
const params = {};
|
|
||||||
|
|
||||||
do {
|
|
||||||
const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`, {
|
|
||||||
params,
|
|
||||||
});
|
|
||||||
params.offset = data.offset;
|
|
||||||
|
|
||||||
if (data?.tables) {
|
|
||||||
for (const table of data.tables) {
|
|
||||||
tables.data.push({
|
|
||||||
value: table.id,
|
|
||||||
name: table.name,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} while (params.offset);
|
|
||||||
|
|
||||||
return tables;
|
|
||||||
},
|
|
||||||
};
|
|
@@ -1,3 +0,0 @@
|
|||||||
import listFields from './list-fields/index.js';
|
|
||||||
|
|
||||||
export default [listFields];
|
|
@@ -1,86 +0,0 @@
|
|||||||
const hasValue = (value) => value !== null && value !== undefined;
|
|
||||||
|
|
||||||
export default {
|
|
||||||
name: 'List fields',
|
|
||||||
key: 'listFields',
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const options = [];
|
|
||||||
const { baseId, tableId } = $.step.parameters;
|
|
||||||
|
|
||||||
if (!hasValue(baseId) || !hasValue(tableId)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const { data } = await $.http.get(`/v0/meta/bases/${baseId}/tables`);
|
|
||||||
|
|
||||||
const selectedTable = data.tables.find((table) => table.id === tableId);
|
|
||||||
|
|
||||||
if (!selectedTable) return;
|
|
||||||
|
|
||||||
selectedTable.fields.forEach((field) => {
|
|
||||||
if (field.type === 'singleSelect') {
|
|
||||||
options.push({
|
|
||||||
label: field.name,
|
|
||||||
key: field.name,
|
|
||||||
type: 'dropdown',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
options: field.options.choices.map((choice) => ({
|
|
||||||
label: choice.name,
|
|
||||||
value: choice.id,
|
|
||||||
})),
|
|
||||||
});
|
|
||||||
} else if (field.type === 'multipleSelects') {
|
|
||||||
options.push({
|
|
||||||
label: field.name,
|
|
||||||
key: field.name,
|
|
||||||
type: 'dynamic',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
fields: [
|
|
||||||
{
|
|
||||||
label: 'Value',
|
|
||||||
key: 'value',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
options: field.options.choices.map((choice) => ({
|
|
||||||
label: choice.name,
|
|
||||||
value: choice.id,
|
|
||||||
})),
|
|
||||||
},
|
|
||||||
],
|
|
||||||
});
|
|
||||||
} else if (field.type === 'checkbox') {
|
|
||||||
options.push({
|
|
||||||
label: field.name,
|
|
||||||
key: field.name,
|
|
||||||
type: 'dropdown',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
options: [
|
|
||||||
{
|
|
||||||
label: 'Yes',
|
|
||||||
value: 'true',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'No',
|
|
||||||
value: 'false',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
options.push({
|
|
||||||
label: field.name,
|
|
||||||
key: field.name,
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
variables: true,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
return options;
|
|
||||||
},
|
|
||||||
};
|
|
@@ -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 actions from './actions/index.js';
|
|
||||||
import dynamicData from './dynamic-data/index.js';
|
|
||||||
import dynamicFields from './dynamic-fields/index.js';
|
|
||||||
|
|
||||||
export default defineApp({
|
|
||||||
name: 'Airtable',
|
|
||||||
key: 'airtable',
|
|
||||||
baseUrl: 'https://airtable.com',
|
|
||||||
apiBaseUrl: 'https://api.airtable.com',
|
|
||||||
iconUrl: '{BASE_URL}/apps/airtable/assets/favicon.svg',
|
|
||||||
authDocUrl: '{DOCS_URL}/apps/airtable/connection',
|
|
||||||
primaryColor: 'FFBF00',
|
|
||||||
supportsConnections: true,
|
|
||||||
beforeRequest: [addAuthHeader],
|
|
||||||
auth,
|
|
||||||
actions,
|
|
||||||
dynamicData,
|
|
||||||
dynamicFields,
|
|
||||||
});
|
|
@@ -1 +0,0 @@
|
|||||||
<svg xmlns:xlink="http://www.w3.org/1999/xlink" xmlns="http://www.w3.org/2000/svg" width="132" height="24" fill="none" viewBox="0 0 132 24"><path fill="#19191C" d="M38.557 19.495c2.16 0 3.25-1.113 3.725-1.87h.214c.094.805.664 1.562 1.779 1.562h2.111V16.82h-.545c-.38 0-.57-.213-.57-.545V6.776h-2.8v1.516h-.213c-.545-.758-1.684-1.824-3.772-1.824-3.321 0-5.789 2.748-5.789 6.514s2.515 6.513 5.86 6.513m.498-2.7c-1.969 0-3.51-1.445-3.51-3.79 0-2.297 1.494-3.86 3.487-3.86 1.898 0 3.487 1.397 3.487 3.86 0 2.108-1.352 3.79-3.463 3.79M48.04 24h2.799v-6.376h.213c.522.758 1.637 1.871 3.844 1.871 3.321 0 5.741-2.795 5.741-6.513 0-3.743-2.586-6.514-5.931-6.514-2.135 0-3.18 1.16-3.678 1.8h-.213V6.776h-2.776V24m6.263-7.134c-1.922 0-3.512-1.42-3.512-3.884 0-2.108 1.353-3.885 3.464-3.885 1.97 0 3.511 1.54 3.511 3.885 0 2.297-1.494 3.884-3.463 3.884M62.082 24h2.8v-6.376h.213c.522.758 1.637 1.871 3.843 1.871 3.321 0 5.51-2.795 5.51-6.513 0-3.743-2.355-6.514-5.7-6.514-2.135 0-3.179 1.16-3.677 1.8h-.214V6.776h-2.775zm6.263-7.134c-1.922 0-3.511-1.42-3.511-3.884 0-2.108 1.352-3.885 3.463-3.885 1.97 0 3.512 1.54 3.512 3.885 0 2.297-1.495 3.884-3.464 3.884m9.805 2.61h3.961l2.254-9.735h.143l2.253 9.735H90.7l3.153-12.412h-2.821l-2.254 9.759h-.214l-2.253-9.759h-3.725l-2.278 9.759h-.213l-2.23-9.759h-2.99l3.274 12.412m17.123 0h2.8V13.34c0-2.345 1.09-3.79 3.131-3.79h1.233V6.756h-.925c-1.59 0-2.8 1.09-3.274 2.132h-.19V7.064h-2.775zm21.057 0h2.183v-2.487h-2.159c-.854 0-1.21-.38-1.21-1.256V9.528h3.511V7.064h-3.511V3.582h-2.657v3.482h-2.325v2.464h2.159v6.229c0 2.63 1.589 3.719 4.009 3.719m9.693.019c2.586 0 4.864-1.279 5.67-3.86l-2.562-.616c-.451 1.373-1.755 2.084-3.131 2.084-2.041 0-3.393-1.326-3.417-3.41h9.419v-.782c0-3.695-2.301-6.443-6.097-6.443-3.346 0-6.216 2.63-6.216 6.537 0 3.79 2.538 6.49 6.334 6.49m-3.416-7.84c.166-1.492 1.518-2.747 3.298-2.747 1.708 0 3.108 1.066 3.25 2.747h-6.548"/><path fill="#19191C" fill-rule="evenodd" d="M108.916 19.476h-2.8V9.528h-2.182V7.064h4.982z" clip-rule="evenodd"/><path fill="#19191C" d="M107.309 5.342c1.02 0 1.779-.758 1.779-1.753 0-.971-.759-1.73-1.779-1.73-1.021 0-1.78.759-1.78 1.73 0 .995.759 1.753 1.78 1.753"/><path fill="#FD366E" d="M24.443 16.432v5.478H10.752c-3.989 0-7.472-2.203-9.335-5.478A11.041 11.041 0 0 1 0 11.695v-1.48a10.97 10.97 0 0 1 .381-2.247C1.661 3.368 5.82 0 10.751 0c4.934 0 9.092 3.37 10.371 7.967h-5.854c-.96-1.499-2.624-2.49-4.516-2.49s-3.555.991-4.516 2.49a5.47 5.47 0 0 0-.67 1.494 5.562 5.562 0 0 0-.202 1.494 5.5 5.5 0 0 0 1.69 3.983 5.32 5.32 0 0 0 3.698 1.494h13.69"/><path fill="#FD366E" d="M24.443 9.46v5.478h-9.994a5.5 5.5 0 0 0 1.691-3.983 5.56 5.56 0 0 0-.203-1.494h8.506"/></svg>
|
|
Before Width: | Height: | Size: 2.6 KiB |
@@ -1,65 +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: 'projectId',
|
|
||||||
label: 'Project ID',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'Project ID of your Appwrite project.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'apiKey',
|
|
||||||
label: 'API Key',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'API key of your Appwrite project.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'instanceUrl',
|
|
||||||
label: 'Appwrite instance URL',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
readOnly: false,
|
|
||||||
placeholder: '',
|
|
||||||
description: '',
|
|
||||||
clickToCopy: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'host',
|
|
||||||
label: 'Host Name',
|
|
||||||
type: 'string',
|
|
||||||
required: true,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'Host name of your Appwrite project.',
|
|
||||||
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,5 +0,0 @@
|
|||||||
const verifyCredentials = async ($) => {
|
|
||||||
await $.http.get('/v1/users');
|
|
||||||
};
|
|
||||||
|
|
||||||
export default verifyCredentials;
|
|
@@ -1,16 +0,0 @@
|
|||||||
const addAuthHeader = ($, requestConfig) => {
|
|
||||||
requestConfig.headers['Content-Type'] = 'application/json';
|
|
||||||
|
|
||||||
if ($.auth.data?.apiKey && $.auth.data?.projectId) {
|
|
||||||
requestConfig.headers['X-Appwrite-Project'] = $.auth.data.projectId;
|
|
||||||
requestConfig.headers['X-Appwrite-Key'] = $.auth.data.apiKey;
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($.auth.data?.host) {
|
|
||||||
requestConfig.headers['Host'] = $.auth.data.host;
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default addAuthHeader;
|
|
@@ -1,13 +0,0 @@
|
|||||||
const setBaseUrl = ($, requestConfig) => {
|
|
||||||
const instanceUrl = $.auth.data.instanceUrl;
|
|
||||||
|
|
||||||
if (instanceUrl) {
|
|
||||||
requestConfig.baseURL = instanceUrl;
|
|
||||||
} else if ($.app.apiBaseUrl) {
|
|
||||||
requestConfig.baseURL = $.app.apiBaseUrl;
|
|
||||||
}
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default setBaseUrl;
|
|
@@ -1,4 +0,0 @@
|
|||||||
import listCollections from './list-collections/index.js';
|
|
||||||
import listDatabases from './list-databases/index.js';
|
|
||||||
|
|
||||||
export default [listCollections, listDatabases];
|
|
@@ -1,44 +0,0 @@
|
|||||||
export default {
|
|
||||||
name: 'List collections',
|
|
||||||
key: 'listCollections',
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const collections = {
|
|
||||||
data: [],
|
|
||||||
};
|
|
||||||
const databaseId = $.step.parameters.databaseId;
|
|
||||||
|
|
||||||
if (!databaseId) {
|
|
||||||
return collections;
|
|
||||||
}
|
|
||||||
|
|
||||||
const params = {
|
|
||||||
queries: [
|
|
||||||
JSON.stringify({
|
|
||||||
method: 'orderAsc',
|
|
||||||
attribute: 'name',
|
|
||||||
}),
|
|
||||||
JSON.stringify({
|
|
||||||
method: 'limit',
|
|
||||||
values: [100],
|
|
||||||
}),
|
|
||||||
],
|
|
||||||
};
|
|
||||||
|
|
||||||
const { data } = await $.http.get(
|
|
||||||
`/v1/databases/${databaseId}/collections`,
|
|
||||||
{ params }
|
|
||||||
);
|
|
||||||
|
|
||||||
if (data?.collections) {
|
|
||||||
for (const collection of data.collections) {
|
|
||||||
collections.data.push({
|
|
||||||
value: collection.$id,
|
|
||||||
name: collection.name,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return collections;
|
|
||||||
},
|
|
||||||
};
|
|
@@ -1,36 +0,0 @@
|
|||||||
export default {
|
|
||||||
name: 'List databases',
|
|
||||||
key: 'listDatabases',
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const databases = {
|
|
||||||
data: [],
|
|
||||||
};
|
|
||||||
|
|
||||||
const params = {
|
|
||||||
queries: [
|
|
||||||
JSON.stringify({
|
|
||||||
method: 'orderAsc',
|
|
||||||
attribute: 'name',
|
|
||||||
}),
|
|
||||||
JSON.stringify({
|
|
||||||
method: 'limit',
|
|
||||||
values: [100],
|
|
||||||
}),
|
|
||||||
],
|
|
||||||
};
|
|
||||||
|
|
||||||
const { data } = await $.http.get('/v1/databases', { params });
|
|
||||||
|
|
||||||
if (data?.databases) {
|
|
||||||
for (const database of data.databases) {
|
|
||||||
databases.data.push({
|
|
||||||
value: database.$id,
|
|
||||||
name: database.name,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return databases;
|
|
||||||
},
|
|
||||||
};
|
|
@@ -1,21 +0,0 @@
|
|||||||
import defineApp from '../../helpers/define-app.js';
|
|
||||||
import addAuthHeader from './common/add-auth-header.js';
|
|
||||||
import setBaseUrl from './common/set-base-url.js';
|
|
||||||
import auth from './auth/index.js';
|
|
||||||
import triggers from './triggers/index.js';
|
|
||||||
import dynamicData from './dynamic-data/index.js';
|
|
||||||
|
|
||||||
export default defineApp({
|
|
||||||
name: 'Appwrite',
|
|
||||||
key: 'appwrite',
|
|
||||||
baseUrl: 'https://appwrite.io',
|
|
||||||
apiBaseUrl: 'https://cloud.appwrite.io',
|
|
||||||
iconUrl: '{BASE_URL}/apps/appwrite/assets/favicon.svg',
|
|
||||||
authDocUrl: '{DOCS_URL}/apps/appwrite/connection',
|
|
||||||
primaryColor: 'FD366E',
|
|
||||||
supportsConnections: true,
|
|
||||||
beforeRequest: [setBaseUrl, addAuthHeader],
|
|
||||||
auth,
|
|
||||||
triggers,
|
|
||||||
dynamicData,
|
|
||||||
});
|
|
@@ -1,3 +0,0 @@
|
|||||||
import newDocuments from './new-documents/index.js';
|
|
||||||
|
|
||||||
export default [newDocuments];
|
|
@@ -1,104 +0,0 @@
|
|||||||
import defineTrigger from '../../../../helpers/define-trigger.js';
|
|
||||||
|
|
||||||
export default defineTrigger({
|
|
||||||
name: 'New documents',
|
|
||||||
key: 'newDocuments',
|
|
||||||
pollInterval: 15,
|
|
||||||
description: 'Triggers when a new document is created.',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
label: 'Database',
|
|
||||||
key: 'databaseId',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
description: '',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listDatabases',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Collection',
|
|
||||||
key: 'collectionId',
|
|
||||||
type: 'dropdown',
|
|
||||||
required: true,
|
|
||||||
dependsOn: ['parameters.databaseId'],
|
|
||||||
description: '',
|
|
||||||
variables: true,
|
|
||||||
source: {
|
|
||||||
type: 'query',
|
|
||||||
name: 'getDynamicData',
|
|
||||||
arguments: [
|
|
||||||
{
|
|
||||||
name: 'key',
|
|
||||||
value: 'listCollections',
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: 'parameters.databaseId',
|
|
||||||
value: '{parameters.databaseId}',
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
},
|
|
||||||
],
|
|
||||||
|
|
||||||
async run($) {
|
|
||||||
const { databaseId, collectionId } = $.step.parameters;
|
|
||||||
|
|
||||||
const limit = 1;
|
|
||||||
let lastDocumentId = undefined;
|
|
||||||
let offset = 0;
|
|
||||||
let documentCount = 0;
|
|
||||||
|
|
||||||
do {
|
|
||||||
const params = {
|
|
||||||
queries: [
|
|
||||||
JSON.stringify({
|
|
||||||
method: 'orderDesc',
|
|
||||||
attribute: '$createdAt',
|
|
||||||
}),
|
|
||||||
JSON.stringify({
|
|
||||||
method: 'limit',
|
|
||||||
values: [limit],
|
|
||||||
}),
|
|
||||||
// An invalid cursor shouldn't be sent.
|
|
||||||
lastDocumentId &&
|
|
||||||
JSON.stringify({
|
|
||||||
method: 'cursorAfter',
|
|
||||||
values: [lastDocumentId],
|
|
||||||
}),
|
|
||||||
].filter(Boolean),
|
|
||||||
};
|
|
||||||
|
|
||||||
const { data } = await $.http.get(
|
|
||||||
`/v1/databases/${databaseId}/collections/${collectionId}/documents`,
|
|
||||||
{ params }
|
|
||||||
);
|
|
||||||
|
|
||||||
const documents = data?.documents;
|
|
||||||
documentCount = documents?.length;
|
|
||||||
offset = offset + limit;
|
|
||||||
lastDocumentId = documents[documentCount - 1]?.$id;
|
|
||||||
|
|
||||||
if (!documentCount) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
for (const document of documents) {
|
|
||||||
$.pushTriggerItem({
|
|
||||||
raw: document,
|
|
||||||
meta: {
|
|
||||||
internalId: document.$id,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
}
|
|
||||||
} while (documentCount === limit);
|
|
||||||
},
|
|
||||||
});
|
|
@@ -5,24 +5,11 @@ const formatDateTime = ($) => {
|
|||||||
|
|
||||||
const fromFormat = $.step.parameters.fromFormat;
|
const fromFormat = $.step.parameters.fromFormat;
|
||||||
const fromTimezone = $.step.parameters.fromTimezone;
|
const fromTimezone = $.step.parameters.fromTimezone;
|
||||||
let inputDateTime;
|
|
||||||
|
|
||||||
if (fromFormat === 'X') {
|
const inputDateTime = DateTime.fromFormat(input, fromFormat, {
|
||||||
inputDateTime = DateTime.fromSeconds(Number(input), fromFormat, {
|
zone: fromTimezone,
|
||||||
zone: fromTimezone,
|
setZone: true,
|
||||||
setZone: true,
|
});
|
||||||
});
|
|
||||||
} else if (fromFormat === 'x') {
|
|
||||||
inputDateTime = DateTime.fromMillis(Number(input), fromFormat, {
|
|
||||||
zone: fromTimezone,
|
|
||||||
setZone: true,
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
inputDateTime = DateTime.fromFormat(input, fromFormat, {
|
|
||||||
zone: fromTimezone,
|
|
||||||
setZone: true,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
const toFormat = $.step.parameters.toFormat;
|
const toFormat = $.step.parameters.toFormat;
|
||||||
const toTimezone = $.step.parameters.toTimezone;
|
const toTimezone = $.step.parameters.toTimezone;
|
||||||
|
@@ -1,28 +0,0 @@
|
|||||||
<svg xmlns:xlink="http://www.w3.org/1999/xlink" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:cc="http://creativecommons.org/ns#" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:svg="http://www.w3.org/2000/svg" xmlns="http://www.w3.org/2000/svg" width="187.04305" height="188.81523" viewBox="0 0 49.488472 49.957363" version="1.1" id="svg8">
|
|
||||||
<defs id="defs2">
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect835"/>
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect835-7"/>
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect874"/>
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect923"/>
|
|
||||||
</defs>
|
|
||||||
<metadata id="metadata5">
|
|
||||||
<rdf:RDF>
|
|
||||||
<cc:Work rdf:about="">
|
|
||||||
<dc:format>image/svg+xml</dc:format>
|
|
||||||
<dc:type rdf:resource="http://purl.org/dc/dcmitype/StillImage"/>
|
|
||||||
<dc:title/>
|
|
||||||
</cc:Work>
|
|
||||||
</rdf:RDF>
|
|
||||||
</metadata>
|
|
||||||
<g id="layer1" transform="translate(-23.040803,-26.932047)">
|
|
||||||
<g id="g861" transform="translate(-42.114518,-17.993737)" style="fill:#000000">
|
|
||||||
<g aria-label="众" transform="matrix(4.3205134,0,0,4.3205134,-37.271798,-327.6536)" id="text833" style="font-style:normal;font-weight:normal;font-size:10.5833px;line-height:1.25;font-family:sans-serif;letter-spacing:0px;word-spacing:0px;white-space:pre;shape-inside:url(#rect835);fill:#000000;fill-opacity:1;stroke:none">
|
|
||||||
<path d="m 34.996103,90.121035 -0.614947,0.759641 q -2.754346,-1.41593 -3.948067,-2.950715 -1.167884,1.617467 -3.7672,2.888703 L 26.0096,90.084861 q 3.457142,-1.601964 4.283963,-3.849882 l 0.878496,0.273884 q -0.175699,0.516763 -0.232543,0.604613 1.116207,1.596797 4.056587,3.007559 z m 0.165364,4.91958 -0.676959,0.645954 q -1.514115,-1.157549 -2.346102,-2.826692 -0.547769,1.550288 -2.268589,2.806021 l -0.676959,-0.625283 q 1.19889,-0.795814 1.798334,-1.875848 0.599445,-1.080034 0.682127,-3.079906 l 0.909502,0.07751 q 0,0.268716 -0.04134,0.671791 l -0.03617,0.361734 q 0,0.273884 0.30489,1.033525 0.310058,0.754474 0.899167,1.467606 0.594277,0.707965 1.452103,1.343583 z m -4.800725,-1.374588 -0.702797,0.63045 q -0.594277,-0.780312 -1.162716,-1.276404 -0.651121,1.421098 -2.020542,2.676831 l -0.687295,-0.614948 q 1.229895,-1.095537 1.767329,-2.201409 0.5426,-1.105872 0.697629,-2.795686 l 0.919838,0.09819 q -0.103353,0.940508 -0.366902,1.91719 1.00252,0.862993 1.555456,1.565791 z" style="font-style:normal;font-variant:normal;font-weight:bold;font-stretch:normal;font-family:'Adobe Garamond Pro';-inkscape-font-specification:'Adobe Garamond Pro Bold';fill:#00000" id="path961"/>
|
|
||||||
</g>
|
|
||||||
<g aria-label="L" id="text841" style="font-style:normal;font-weight:normal;font-size:43.3964px;line-height:1.25;font-family:sans-serif;letter-spacing:0px;word-spacing:0px;fill:#000000;fill-opacity:1;stroke:none;stroke-width:1.08492">
|
|
||||||
<path d="M 84.81389,94.883148 V 91.324643 H 69.191186 V 63.247172 h -4.035865 v 31.635976 z" style="fill:#000000;stroke-width:1.08492" id="path964"/>
|
|
||||||
</g>
|
|
||||||
</g>
|
|
||||||
<g id="g921" transform="translate(29.198135,-14.725175)"/>
|
|
||||||
</g>
|
|
||||||
</svg>
|
|
Before Width: | Height: | Size: 3.1 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: false,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'For the self hosted version.',
|
|
||||||
clickToCopy: false,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
key: 'apiKey',
|
|
||||||
label: 'API Key',
|
|
||||||
type: 'string',
|
|
||||||
required: false,
|
|
||||||
readOnly: false,
|
|
||||||
value: null,
|
|
||||||
placeholder: null,
|
|
||||||
description: 'LibreTranslate 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,14 +0,0 @@
|
|||||||
const verifyCredentials = async ($) => {
|
|
||||||
const body = {
|
|
||||||
q: 'Hi!',
|
|
||||||
};
|
|
||||||
|
|
||||||
await $.http.post('/detect', body);
|
|
||||||
|
|
||||||
await $.auth.set({
|
|
||||||
screenName: $.auth.data.screenName,
|
|
||||||
apiKey: $.auth.data.apiKey,
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
export default verifyCredentials;
|
|
@@ -1,9 +0,0 @@
|
|||||||
const addApiKey = ($, requestConfig) => {
|
|
||||||
const apiKey = $.auth.data.apiKey;
|
|
||||||
|
|
||||||
requestConfig.data = { api_key: apiKey, ...(requestConfig.data || {}) };
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default addApiKey;
|
|
@@ -1,16 +0,0 @@
|
|||||||
const setBaseUrl = ($, requestConfig) => {
|
|
||||||
const instanceUrl = $.auth.data.instanceUrl;
|
|
||||||
const apiKey = $.auth.data.apiKey;
|
|
||||||
|
|
||||||
if (instanceUrl) {
|
|
||||||
requestConfig.baseURL = instanceUrl;
|
|
||||||
} else if ($.app.apiBaseUrl) {
|
|
||||||
requestConfig.baseURL = $.app.apiBaseUrl;
|
|
||||||
}
|
|
||||||
|
|
||||||
requestConfig.data = { api_key: apiKey, ...(requestConfig.data || {}) };
|
|
||||||
|
|
||||||
return requestConfig;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default setBaseUrl;
|
|
@@ -1,17 +0,0 @@
|
|||||||
import defineApp from '../../helpers/define-app.js';
|
|
||||||
import auth from './auth/index.js';
|
|
||||||
import addApiKey from './common/add-api-key.js';
|
|
||||||
import setBaseUrl from './common/set-base-url.js';
|
|
||||||
|
|
||||||
export default defineApp({
|
|
||||||
name: 'LibreTranslate',
|
|
||||||
key: 'libretranslate',
|
|
||||||
iconUrl: '{BASE_URL}/apps/libretranslate/assets/favicon.svg',
|
|
||||||
authDocUrl: '{DOCS_URL}/apps/libretranslate/connection',
|
|
||||||
supportsConnections: true,
|
|
||||||
baseUrl: 'https://libretranslate.com',
|
|
||||||
apiBaseUrl: 'https://libretranslate.com',
|
|
||||||
primaryColor: 'ffffff',
|
|
||||||
beforeRequest: [setBaseUrl, addApiKey],
|
|
||||||
auth,
|
|
||||||
});
|
|
@@ -52,7 +52,7 @@ const appConfig = {
|
|||||||
isDev: appEnv === 'development',
|
isDev: appEnv === 'development',
|
||||||
isTest: appEnv === 'test',
|
isTest: appEnv === 'test',
|
||||||
isProd: appEnv === 'production',
|
isProd: appEnv === 'production',
|
||||||
version: '0.12.0',
|
version: '0.11.0',
|
||||||
postgresDatabase: process.env.POSTGRES_DATABASE || 'automatisch_development',
|
postgresDatabase: process.env.POSTGRES_DATABASE || 'automatisch_development',
|
||||||
postgresSchema: process.env.POSTGRES_SCHEMA || 'public',
|
postgresSchema: process.env.POSTGRES_SCHEMA || 'public',
|
||||||
postgresPort: parseInt(process.env.POSTGRES_PORT || '5432'),
|
postgresPort: parseInt(process.env.POSTGRES_PORT || '5432'),
|
||||||
|
@@ -1,10 +1,11 @@
|
|||||||
import { describe, it, expect, beforeEach } from 'vitest';
|
import { vi, describe, it, expect, beforeEach } from 'vitest';
|
||||||
import request from 'supertest';
|
import request from 'supertest';
|
||||||
import app from '../../../../../app';
|
import app from '../../../../../app';
|
||||||
import createAuthTokenByUserId from '../../../../../helpers/create-auth-token-by-user-id';
|
import createAuthTokenByUserId from '../../../../../helpers/create-auth-token-by-user-id';
|
||||||
import { createRole } from '../../../../../../test/factories/role';
|
import { createRole } from '../../../../../../test/factories/role';
|
||||||
import { createUser } from '../../../../../../test/factories/user';
|
import { createUser } from '../../../../../../test/factories/user';
|
||||||
import getUsersMock from '../../../../../../test/mocks/rest/api/v1/admin/users/get-users.js';
|
import getUsersMock from '../../../../../../test/mocks/rest/api/v1/admin/users/get-users.js';
|
||||||
|
import * as license from '../../../../../helpers/license.ee.js';
|
||||||
|
|
||||||
describe('GET /api/v1/admin/users', () => {
|
describe('GET /api/v1/admin/users', () => {
|
||||||
let currentUser, currentUserRole, anotherUser, anotherUserRole, token;
|
let currentUser, currentUserRole, anotherUser, anotherUserRole, token;
|
||||||
@@ -31,6 +32,8 @@ describe('GET /api/v1/admin/users', () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it('should return users data', async () => {
|
it('should return users data', async () => {
|
||||||
|
vi.spyOn(license, 'hasValidLicense').mockResolvedValue(true);
|
||||||
|
|
||||||
const response = await request(app)
|
const response = await request(app)
|
||||||
.get('/api/v1/admin/users')
|
.get('/api/v1/admin/users')
|
||||||
.set('Authorization', token)
|
.set('Authorization', token)
|
||||||
|
@@ -10,7 +10,7 @@ describe('GET /api/v1/automatisch/version', () => {
|
|||||||
|
|
||||||
const expectedPayload = {
|
const expectedPayload = {
|
||||||
data: {
|
data: {
|
||||||
version: '0.12.0',
|
version: '0.11.0',
|
||||||
},
|
},
|
||||||
meta: {
|
meta: {
|
||||||
count: 1,
|
count: 1,
|
||||||
|
@@ -1,9 +1,12 @@
|
|||||||
import User from '../../../../../models/user.js';
|
import User from '../../../../../models/user.js';
|
||||||
|
import Config from '../../../../../models/config.js';
|
||||||
|
|
||||||
export default async (request, response) => {
|
export default async (request, response) => {
|
||||||
const { email, password, fullName } = request.body;
|
const { email, password, fullName } = request.body;
|
||||||
|
|
||||||
await User.createAdmin({ email, password, fullName });
|
await User.createAdminUser({ email, password, fullName });
|
||||||
|
|
||||||
|
await Config.markInstallationCompleted();
|
||||||
|
|
||||||
response.status(204).end();
|
response.status(204).end();
|
||||||
};
|
};
|
||||||
|
@@ -4,7 +4,6 @@ import app from '../../../../../app.js';
|
|||||||
import Config from '../../../../../models/config.js';
|
import Config from '../../../../../models/config.js';
|
||||||
import User from '../../../../../models/user.js';
|
import User from '../../../../../models/user.js';
|
||||||
import { createRole } from '../../../../../../test/factories/role';
|
import { createRole } from '../../../../../../test/factories/role';
|
||||||
import { createUser } from '../../../../../../test/factories/user';
|
|
||||||
import { createInstallationCompletedConfig } from '../../../../../../test/factories/config';
|
import { createInstallationCompletedConfig } from '../../../../../../test/factories/config';
|
||||||
|
|
||||||
describe('POST /api/v1/installation/users', () => {
|
describe('POST /api/v1/installation/users', () => {
|
||||||
@@ -18,7 +17,7 @@ describe('POST /api/v1/installation/users', () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
describe('for incomplete installations', () => {
|
describe('for incomplete installations', () => {
|
||||||
it('should respond with HTTP 204 with correct payload when no user', async () => {
|
it('should respond with HTTP 204 with correct payload', async () => {
|
||||||
expect(await Config.isInstallationCompleted()).toBe(false);
|
expect(await Config.isInstallationCompleted()).toBe(false);
|
||||||
|
|
||||||
await request(app)
|
await request(app)
|
||||||
@@ -35,27 +34,6 @@ describe('POST /api/v1/installation/users', () => {
|
|||||||
expect(user.roleId).toBe(adminRole.id);
|
expect(user.roleId).toBe(adminRole.id);
|
||||||
expect(await Config.isInstallationCompleted()).toBe(true);
|
expect(await Config.isInstallationCompleted()).toBe(true);
|
||||||
});
|
});
|
||||||
|
|
||||||
it('should respond with HTTP 403 with correct payload when one user exists at least', async () => {
|
|
||||||
expect(await Config.isInstallationCompleted()).toBe(false);
|
|
||||||
|
|
||||||
await createUser();
|
|
||||||
|
|
||||||
const usersCountBefore = await User.query().resultSize();
|
|
||||||
|
|
||||||
await request(app)
|
|
||||||
.post('/api/v1/installation/users')
|
|
||||||
.send({
|
|
||||||
email: 'user@automatisch.io',
|
|
||||||
password: 'password',
|
|
||||||
fullName: 'Initial admin'
|
|
||||||
})
|
|
||||||
.expect(403);
|
|
||||||
|
|
||||||
const usersCountAfter = await User.query().resultSize();
|
|
||||||
|
|
||||||
expect(usersCountBefore).toEqual(usersCountAfter);
|
|
||||||
});
|
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('for completed installations', () => {
|
describe('for completed installations', () => {
|
||||||
|
@@ -1,11 +0,0 @@
|
|||||||
export async function up(knex) {
|
|
||||||
return knex.schema.alterTable('datastore', (table) => {
|
|
||||||
table.text('value').alter();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function down(knex) {
|
|
||||||
return knex.schema.alterTable('datastore', (table) => {
|
|
||||||
table.string('value').alter();
|
|
||||||
});
|
|
||||||
}
|
|
@@ -1,16 +0,0 @@
|
|||||||
import Config from '../models/config.js';
|
|
||||||
import User from '../models/user.js';
|
|
||||||
|
|
||||||
export async function allowInstallation(request, response, next) {
|
|
||||||
if (await Config.isInstallationCompleted()) {
|
|
||||||
return response.status(403).end();
|
|
||||||
}
|
|
||||||
|
|
||||||
const hasAnyUsers = await User.query().resultSize() > 0;
|
|
||||||
|
|
||||||
if (hasAnyUsers) {
|
|
||||||
return response.status(403).end();
|
|
||||||
}
|
|
||||||
|
|
||||||
next();
|
|
||||||
};
|
|
9
packages/backend/src/helpers/authorize-installation.js
Normal file
9
packages/backend/src/helpers/authorize-installation.js
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
import Config from '../models/config.js';
|
||||||
|
|
||||||
|
export async function authorizeInstallation(request, response, next) {
|
||||||
|
if (await Config.isInstallationCompleted()) {
|
||||||
|
return response.status(403).end();
|
||||||
|
} else {
|
||||||
|
next();
|
||||||
|
}
|
||||||
|
};
|
@@ -10,7 +10,6 @@ import Base from './base.js';
|
|||||||
import App from './app.js';
|
import App from './app.js';
|
||||||
import AccessToken from './access-token.js';
|
import AccessToken from './access-token.js';
|
||||||
import Connection from './connection.js';
|
import Connection from './connection.js';
|
||||||
import Config from './config.js';
|
|
||||||
import Execution from './execution.js';
|
import Execution from './execution.js';
|
||||||
import Flow from './flow.js';
|
import Flow from './flow.js';
|
||||||
import Identity from './identity.ee.js';
|
import Identity from './identity.ee.js';
|
||||||
@@ -374,7 +373,7 @@ class User extends Base {
|
|||||||
return apps;
|
return apps;
|
||||||
}
|
}
|
||||||
|
|
||||||
static async createAdmin({ email, password, fullName }) {
|
static async createAdminUser({ email, password, fullName }) {
|
||||||
const adminRole = await Role.findAdmin();
|
const adminRole = await Role.findAdmin();
|
||||||
|
|
||||||
const adminUser = await this.query().insert({
|
const adminUser = await this.query().insert({
|
||||||
@@ -384,8 +383,6 @@ class User extends Base {
|
|||||||
roleId: adminRole.id
|
roleId: adminRole.id
|
||||||
});
|
});
|
||||||
|
|
||||||
await Config.markInstallationCompleted();
|
|
||||||
|
|
||||||
return adminUser;
|
return adminUser;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -2,17 +2,25 @@ import { Router } from 'express';
|
|||||||
import asyncHandler from 'express-async-handler';
|
import asyncHandler from 'express-async-handler';
|
||||||
import { authenticateUser } from '../../../../helpers/authentication.js';
|
import { authenticateUser } from '../../../../helpers/authentication.js';
|
||||||
import { authorizeAdmin } from '../../../../helpers/authorization.js';
|
import { authorizeAdmin } from '../../../../helpers/authorization.js';
|
||||||
|
import { checkIsEnterprise } from '../../../../helpers/check-is-enterprise.js';
|
||||||
import getUsersAction from '../../../../controllers/api/v1/admin/users/get-users.ee.js';
|
import getUsersAction from '../../../../controllers/api/v1/admin/users/get-users.ee.js';
|
||||||
import getUserAction from '../../../../controllers/api/v1/admin/users/get-user.ee.js';
|
import getUserAction from '../../../../controllers/api/v1/admin/users/get-user.ee.js';
|
||||||
|
|
||||||
const router = Router();
|
const router = Router();
|
||||||
|
|
||||||
router.get('/', authenticateUser, authorizeAdmin, asyncHandler(getUsersAction));
|
router.get(
|
||||||
|
'/',
|
||||||
|
authenticateUser,
|
||||||
|
authorizeAdmin,
|
||||||
|
checkIsEnterprise,
|
||||||
|
asyncHandler(getUsersAction)
|
||||||
|
);
|
||||||
|
|
||||||
router.get(
|
router.get(
|
||||||
'/:userId',
|
'/:userId',
|
||||||
authenticateUser,
|
authenticateUser,
|
||||||
authorizeAdmin,
|
authorizeAdmin,
|
||||||
|
checkIsEnterprise,
|
||||||
asyncHandler(getUserAction)
|
asyncHandler(getUserAction)
|
||||||
);
|
);
|
||||||
|
|
||||||
|
@@ -1,13 +1,13 @@
|
|||||||
import { Router } from 'express';
|
import { Router } from 'express';
|
||||||
import asyncHandler from 'express-async-handler';
|
import asyncHandler from 'express-async-handler';
|
||||||
import { allowInstallation } from '../../../../helpers/allow-installation.js';
|
import { authorizeInstallation } from '../../../../helpers/authorize-installation.js';
|
||||||
import createUserAction from '../../../../controllers/api/v1/installation/users/create-user.js';
|
import createUserAction from '../../../../controllers/api/v1/installation/users/create-user.js';
|
||||||
|
|
||||||
const router = Router();
|
const router = Router();
|
||||||
|
|
||||||
router.post(
|
router.post(
|
||||||
'/',
|
'/',
|
||||||
allowInstallation,
|
authorizeInstallation,
|
||||||
asyncHandler(createUserAction)
|
asyncHandler(createUserAction)
|
||||||
);
|
);
|
||||||
|
|
||||||
|
@@ -26,30 +26,12 @@ export default defineConfig({
|
|||||||
},
|
},
|
||||||
{
|
{
|
||||||
text: 'Apps',
|
text: 'Apps',
|
||||||
link: '/apps/airtable/connection',
|
link: '/apps/carbone/connection',
|
||||||
activeMatch: '/apps/',
|
activeMatch: '/apps/',
|
||||||
},
|
},
|
||||||
],
|
],
|
||||||
sidebar: {
|
sidebar: {
|
||||||
'/apps/': [
|
'/apps/': [
|
||||||
{
|
|
||||||
text: 'Airtable',
|
|
||||||
collapsible: true,
|
|
||||||
collapsed: true,
|
|
||||||
items: [
|
|
||||||
{ text: 'Actions', link: '/apps/airtable/actions' },
|
|
||||||
{ text: 'Connection', link: '/apps/airtable/connection' },
|
|
||||||
],
|
|
||||||
},
|
|
||||||
{
|
|
||||||
text: 'Appwrite',
|
|
||||||
collapsible: true,
|
|
||||||
collapsed: true,
|
|
||||||
items: [
|
|
||||||
{ text: 'Triggers', link: '/apps/appwrite/triggers' },
|
|
||||||
{ text: 'Connection', link: '/apps/appwrite/connection' },
|
|
||||||
],
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
text: 'Carbone',
|
text: 'Carbone',
|
||||||
collapsible: true,
|
collapsible: true,
|
||||||
@@ -243,14 +225,6 @@ export default defineConfig({
|
|||||||
{ text: 'Connection', link: '/apps/invoice-ninja/connection' },
|
{ text: 'Connection', link: '/apps/invoice-ninja/connection' },
|
||||||
],
|
],
|
||||||
},
|
},
|
||||||
{
|
|
||||||
text: 'LibreTranslate',
|
|
||||||
collapsible: true,
|
|
||||||
collapsed: true,
|
|
||||||
items: [
|
|
||||||
{ text: 'Connection', link: '/apps/libretranslate/connection' },
|
|
||||||
],
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
text: 'Mattermost',
|
text: 'Mattermost',
|
||||||
collapsible: true,
|
collapsible: true,
|
||||||
|
@@ -1,14 +0,0 @@
|
|||||||
---
|
|
||||||
favicon: /favicons/airtable.svg
|
|
||||||
items:
|
|
||||||
- name: Create record
|
|
||||||
desc: Creates a new record with fields that automatically populate.
|
|
||||||
- name: Find record
|
|
||||||
desc: Finds a record using simple field search or use Airtable's formula syntax to find a matching record.
|
|
||||||
---
|
|
||||||
|
|
||||||
<script setup>
|
|
||||||
import CustomListing from '../../components/CustomListing.vue'
|
|
||||||
</script>
|
|
||||||
|
|
||||||
<CustomListing />
|
|
@@ -1,19 +0,0 @@
|
|||||||
# Airtable
|
|
||||||
|
|
||||||
:::info
|
|
||||||
This page explains the steps you need to follow to set up the Airtable
|
|
||||||
connection in Automatisch. If any of the steps are outdated, please let us know!
|
|
||||||
:::
|
|
||||||
|
|
||||||
1. Login to your [Airtable account](https://www.airtable.com/).
|
|
||||||
2. Go to this [link](https://airtable.com/create/oauth) and click on the **Register new OAuth integration**.
|
|
||||||
3. Fill the name field.
|
|
||||||
4. Copy **OAuth Redirect URL** from Automatisch to **OAuth redirect URL** field.
|
|
||||||
5. Click on the **Register integration** button.
|
|
||||||
6. In **Developer Details** section, click on the **Generate client secret**.
|
|
||||||
7. Check the checkboxes of **Scopes** section.
|
|
||||||
8. Click on the **Save changes** button.
|
|
||||||
9. Copy **Client ID** to **Client ID** field on Automatisch.
|
|
||||||
10. Copy **Client secret** to **Client secret** field on Automatisch.
|
|
||||||
11. Click **Submit** button on Automatisch.
|
|
||||||
12. Congrats! Start using your new Airtable connection within the flows.
|
|
@@ -1,20 +0,0 @@
|
|||||||
# Appwrite
|
|
||||||
|
|
||||||
:::info
|
|
||||||
This page explains the steps you need to follow to set up the Appwrite
|
|
||||||
connection in Automatisch. If any of the steps are outdated, please let us know!
|
|
||||||
:::
|
|
||||||
|
|
||||||
1. Login to your Appwrite account: [https://appwrite.io/](https://appwrite.io/).
|
|
||||||
2. Go to your project's **Settings**.
|
|
||||||
3. In the Settings, click on the **View API Keys** button in **API credentials** section.
|
|
||||||
4. Click on the **Create API Key** button.
|
|
||||||
5. Fill the name field and select **Never** for the expiration date.
|
|
||||||
6. Click on the **Next** button.
|
|
||||||
7. Click on the **Select all** and then click on the **Create** button.
|
|
||||||
8. Now, copy your **API key secret** and paste the key into the **API Key** field in Automatisch.
|
|
||||||
9. Write any screen name to be displayed in Automatisch.
|
|
||||||
10. You can find your project ID next to your project name. Paste the id into **Project ID** field in Automatsich.
|
|
||||||
11. If you are using self-hosted Appwrite project, you can paste the instace url into **Appwrite instance URL** field in Automatisch.
|
|
||||||
12. Fill the host name field with the hostname of your instance URL. It's either `cloud.appwrite.io` or hostname of your instance URL.
|
|
||||||
13. Start using Appwrite integration with Automatisch!
|
|
@@ -1,12 +0,0 @@
|
|||||||
---
|
|
||||||
favicon: /favicons/appwrite.svg
|
|
||||||
items:
|
|
||||||
- name: New documets
|
|
||||||
desc: Triggers when a new document is created.
|
|
||||||
---
|
|
||||||
|
|
||||||
<script setup>
|
|
||||||
import CustomListing from '../../components/CustomListing.vue'
|
|
||||||
</script>
|
|
||||||
|
|
||||||
<CustomListing />
|
|
@@ -1,12 +0,0 @@
|
|||||||
# LibreTranslate
|
|
||||||
|
|
||||||
:::info
|
|
||||||
This page explains the steps you need to follow to set up the LibreTranslate
|
|
||||||
connection in Automatisch. If any of the steps are outdated, please let us know!
|
|
||||||
:::
|
|
||||||
|
|
||||||
1. Login to your LibreTranslate account.
|
|
||||||
2. Copy your `API key` from the page to the `API Key` field on Automatisch.
|
|
||||||
3. If you are using a self hosted version of LibreTranslate, copy your `Instance URl` to the `Instance URL` field on Automatisch.
|
|
||||||
4. Write any screen name to be displayed in Automatisch.
|
|
||||||
5. Now, you can start using the LibreTranslate connection with Automatisch.
|
|
@@ -2,8 +2,6 @@
|
|||||||
|
|
||||||
The following integrations are currently supported by Automatisch.
|
The following integrations are currently supported by Automatisch.
|
||||||
|
|
||||||
- [Airtable](/apps/airtable/actions)
|
|
||||||
- [Appwrite](/apps/appwrite/triggers)
|
|
||||||
- [Carbone](/apps/carbone/actions)
|
- [Carbone](/apps/carbone/actions)
|
||||||
- [Datastore](/apps/datastore/actions)
|
- [Datastore](/apps/datastore/actions)
|
||||||
- [DeepL](/apps/deepl/actions)
|
- [DeepL](/apps/deepl/actions)
|
||||||
|
@@ -1,9 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<svg width="256px" height="215px" viewBox="0 0 256 215" version="1.1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" preserveAspectRatio="xMidYMid">
|
|
||||||
<g>
|
|
||||||
<path d="M114.25873,2.70101695 L18.8604023,42.1756384 C13.5552723,44.3711638 13.6102328,51.9065311 18.9486282,54.0225085 L114.746142,92.0117514 C123.163769,95.3498757 132.537419,95.3498757 140.9536,92.0117514 L236.75256,54.0225085 C242.08951,51.9065311 242.145916,44.3711638 236.83934,42.1756384 L141.442459,2.70101695 C132.738459,-0.900338983 122.961284,-0.900338983 114.25873,2.70101695" fill="#FFBF00"></path>
|
|
||||||
<path d="M136.349071,112.756863 L136.349071,207.659101 C136.349071,212.173089 140.900664,215.263892 145.096461,213.600615 L251.844122,172.166219 C254.281184,171.200072 255.879376,168.845451 255.879376,166.224705 L255.879376,71.3224678 C255.879376,66.8084791 251.327783,63.7176768 247.131986,65.3809537 L140.384325,106.815349 C137.94871,107.781496 136.349071,110.136118 136.349071,112.756863" fill="#26B5F8"></path>
|
|
||||||
<path d="M111.422771,117.65355 L79.742409,132.949912 L76.5257763,134.504714 L9.65047684,166.548104 C5.4112904,168.593211 0.000578531073,165.503855 0.000578531073,160.794612 L0.000578531073,71.7210757 C0.000578531073,70.0173017 0.874160452,68.5463864 2.04568588,67.4384994 C2.53454463,66.9481944 3.08848814,66.5446689 3.66412655,66.2250305 C5.26231864,65.2661153 7.54173107,65.0101153 9.47981017,65.7766689 L110.890522,105.957098 C116.045234,108.002206 116.450206,115.225166 111.422771,117.65355" fill="#ED3049"></path>
|
|
||||||
<path d="M111.422771,117.65355 L79.742409,132.949912 L2.04568588,67.4384994 C2.53454463,66.9481944 3.08848814,66.5446689 3.66412655,66.2250305 C5.26231864,65.2661153 7.54173107,65.0101153 9.47981017,65.7766689 L110.890522,105.957098 C116.045234,108.002206 116.450206,115.225166 111.422771,117.65355" fill-opacity="0.25" fill="#000000"></path>
|
|
||||||
</g>
|
|
||||||
</svg>
|
|
Before Width: | Height: | Size: 1.9 KiB |
@@ -1 +0,0 @@
|
|||||||
<svg xmlns:xlink="http://www.w3.org/1999/xlink" xmlns="http://www.w3.org/2000/svg" width="132" height="24" fill="none" viewBox="0 0 132 24"><path fill="#19191C" d="M38.557 19.495c2.16 0 3.25-1.113 3.725-1.87h.214c.094.805.664 1.562 1.779 1.562h2.111V16.82h-.545c-.38 0-.57-.213-.57-.545V6.776h-2.8v1.516h-.213c-.545-.758-1.684-1.824-3.772-1.824-3.321 0-5.789 2.748-5.789 6.514s2.515 6.513 5.86 6.513m.498-2.7c-1.969 0-3.51-1.445-3.51-3.79 0-2.297 1.494-3.86 3.487-3.86 1.898 0 3.487 1.397 3.487 3.86 0 2.108-1.352 3.79-3.463 3.79M48.04 24h2.799v-6.376h.213c.522.758 1.637 1.871 3.844 1.871 3.321 0 5.741-2.795 5.741-6.513 0-3.743-2.586-6.514-5.931-6.514-2.135 0-3.18 1.16-3.678 1.8h-.213V6.776h-2.776V24m6.263-7.134c-1.922 0-3.512-1.42-3.512-3.884 0-2.108 1.353-3.885 3.464-3.885 1.97 0 3.511 1.54 3.511 3.885 0 2.297-1.494 3.884-3.463 3.884M62.082 24h2.8v-6.376h.213c.522.758 1.637 1.871 3.843 1.871 3.321 0 5.51-2.795 5.51-6.513 0-3.743-2.355-6.514-5.7-6.514-2.135 0-3.179 1.16-3.677 1.8h-.214V6.776h-2.775zm6.263-7.134c-1.922 0-3.511-1.42-3.511-3.884 0-2.108 1.352-3.885 3.463-3.885 1.97 0 3.512 1.54 3.512 3.885 0 2.297-1.495 3.884-3.464 3.884m9.805 2.61h3.961l2.254-9.735h.143l2.253 9.735H90.7l3.153-12.412h-2.821l-2.254 9.759h-.214l-2.253-9.759h-3.725l-2.278 9.759h-.213l-2.23-9.759h-2.99l3.274 12.412m17.123 0h2.8V13.34c0-2.345 1.09-3.79 3.131-3.79h1.233V6.756h-.925c-1.59 0-2.8 1.09-3.274 2.132h-.19V7.064h-2.775zm21.057 0h2.183v-2.487h-2.159c-.854 0-1.21-.38-1.21-1.256V9.528h3.511V7.064h-3.511V3.582h-2.657v3.482h-2.325v2.464h2.159v6.229c0 2.63 1.589 3.719 4.009 3.719m9.693.019c2.586 0 4.864-1.279 5.67-3.86l-2.562-.616c-.451 1.373-1.755 2.084-3.131 2.084-2.041 0-3.393-1.326-3.417-3.41h9.419v-.782c0-3.695-2.301-6.443-6.097-6.443-3.346 0-6.216 2.63-6.216 6.537 0 3.79 2.538 6.49 6.334 6.49m-3.416-7.84c.166-1.492 1.518-2.747 3.298-2.747 1.708 0 3.108 1.066 3.25 2.747h-6.548"/><path fill="#19191C" fill-rule="evenodd" d="M108.916 19.476h-2.8V9.528h-2.182V7.064h4.982z" clip-rule="evenodd"/><path fill="#19191C" d="M107.309 5.342c1.02 0 1.779-.758 1.779-1.753 0-.971-.759-1.73-1.779-1.73-1.021 0-1.78.759-1.78 1.73 0 .995.759 1.753 1.78 1.753"/><path fill="#FD366E" d="M24.443 16.432v5.478H10.752c-3.989 0-7.472-2.203-9.335-5.478A11.041 11.041 0 0 1 0 11.695v-1.48a10.97 10.97 0 0 1 .381-2.247C1.661 3.368 5.82 0 10.751 0c4.934 0 9.092 3.37 10.371 7.967h-5.854c-.96-1.499-2.624-2.49-4.516-2.49s-3.555.991-4.516 2.49a5.47 5.47 0 0 0-.67 1.494 5.562 5.562 0 0 0-.202 1.494 5.5 5.5 0 0 0 1.69 3.983 5.32 5.32 0 0 0 3.698 1.494h13.69"/><path fill="#FD366E" d="M24.443 9.46v5.478h-9.994a5.5 5.5 0 0 0 1.691-3.983 5.56 5.56 0 0 0-.203-1.494h8.506"/></svg>
|
|
Before Width: | Height: | Size: 2.6 KiB |
@@ -1,28 +0,0 @@
|
|||||||
<svg xmlns:xlink="http://www.w3.org/1999/xlink" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:cc="http://creativecommons.org/ns#" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:svg="http://www.w3.org/2000/svg" xmlns="http://www.w3.org/2000/svg" width="187.04305" height="188.81523" viewBox="0 0 49.488472 49.957363" version="1.1" id="svg8">
|
|
||||||
<defs id="defs2">
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect835"/>
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect835-7"/>
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect874"/>
|
|
||||||
<rect x="25.162016" y="84.327377" width="71.115189" height="52.835255" id="rect923"/>
|
|
||||||
</defs>
|
|
||||||
<metadata id="metadata5">
|
|
||||||
<rdf:RDF>
|
|
||||||
<cc:Work rdf:about="">
|
|
||||||
<dc:format>image/svg+xml</dc:format>
|
|
||||||
<dc:type rdf:resource="http://purl.org/dc/dcmitype/StillImage"/>
|
|
||||||
<dc:title/>
|
|
||||||
</cc:Work>
|
|
||||||
</rdf:RDF>
|
|
||||||
</metadata>
|
|
||||||
<g id="layer1" transform="translate(-23.040803,-26.932047)">
|
|
||||||
<g id="g861" transform="translate(-42.114518,-17.993737)" style="fill:#000000">
|
|
||||||
<g aria-label="众" transform="matrix(4.3205134,0,0,4.3205134,-37.271798,-327.6536)" id="text833" style="font-style:normal;font-weight:normal;font-size:10.5833px;line-height:1.25;font-family:sans-serif;letter-spacing:0px;word-spacing:0px;white-space:pre;shape-inside:url(#rect835);fill:#000000;fill-opacity:1;stroke:none">
|
|
||||||
<path d="m 34.996103,90.121035 -0.614947,0.759641 q -2.754346,-1.41593 -3.948067,-2.950715 -1.167884,1.617467 -3.7672,2.888703 L 26.0096,90.084861 q 3.457142,-1.601964 4.283963,-3.849882 l 0.878496,0.273884 q -0.175699,0.516763 -0.232543,0.604613 1.116207,1.596797 4.056587,3.007559 z m 0.165364,4.91958 -0.676959,0.645954 q -1.514115,-1.157549 -2.346102,-2.826692 -0.547769,1.550288 -2.268589,2.806021 l -0.676959,-0.625283 q 1.19889,-0.795814 1.798334,-1.875848 0.599445,-1.080034 0.682127,-3.079906 l 0.909502,0.07751 q 0,0.268716 -0.04134,0.671791 l -0.03617,0.361734 q 0,0.273884 0.30489,1.033525 0.310058,0.754474 0.899167,1.467606 0.594277,0.707965 1.452103,1.343583 z m -4.800725,-1.374588 -0.702797,0.63045 q -0.594277,-0.780312 -1.162716,-1.276404 -0.651121,1.421098 -2.020542,2.676831 l -0.687295,-0.614948 q 1.229895,-1.095537 1.767329,-2.201409 0.5426,-1.105872 0.697629,-2.795686 l 0.919838,0.09819 q -0.103353,0.940508 -0.366902,1.91719 1.00252,0.862993 1.555456,1.565791 z" style="font-style:normal;font-variant:normal;font-weight:bold;font-stretch:normal;font-family:'Adobe Garamond Pro';-inkscape-font-specification:'Adobe Garamond Pro Bold';fill:#00000" id="path961"/>
|
|
||||||
</g>
|
|
||||||
<g aria-label="L" id="text841" style="font-style:normal;font-weight:normal;font-size:43.3964px;line-height:1.25;font-family:sans-serif;letter-spacing:0px;word-spacing:0px;fill:#000000;fill-opacity:1;stroke:none;stroke-width:1.08492">
|
|
||||||
<path d="M 84.81389,94.883148 V 91.324643 H 69.191186 V 63.247172 h -4.035865 v 31.635976 z" style="fill:#000000;stroke-width:1.08492" id="path964"/>
|
|
||||||
</g>
|
|
||||||
</g>
|
|
||||||
<g id="g921" transform="translate(29.198135,-14.725175)"/>
|
|
||||||
</g>
|
|
||||||
</svg>
|
|
Before Width: | Height: | Size: 3.1 KiB |
@@ -61,7 +61,7 @@ test.describe('Apps page', () => {
|
|||||||
|
|
||||||
await applicationsPage.page.getByTestId('app-list-item').first().click();
|
await applicationsPage.page.getByTestId('app-list-item').first().click();
|
||||||
await expect(applicationsPage.page).toHaveURL(
|
await expect(applicationsPage.page).toHaveURL(
|
||||||
'/app/airtable/connections/add?shared=false'
|
'/app/azure-openai/connections/add?shared=false'
|
||||||
);
|
);
|
||||||
await expect(
|
await expect(
|
||||||
applicationsPage.page.getByTestId('add-app-connection-dialog')
|
applicationsPage.page.getByTestId('add-app-connection-dialog')
|
||||||
@@ -75,14 +75,14 @@ test.describe('Apps page', () => {
|
|||||||
}) => {
|
}) => {
|
||||||
await applicationsPage.page.getByTestId('app-list-item').first().click();
|
await applicationsPage.page.getByTestId('app-list-item').first().click();
|
||||||
await expect(applicationsPage.page).toHaveURL(
|
await expect(applicationsPage.page).toHaveURL(
|
||||||
'/app/airtable/connections/add?shared=false'
|
'/app/azure-openai/connections/add?shared=false'
|
||||||
);
|
);
|
||||||
await expect(
|
await expect(
|
||||||
applicationsPage.page.getByTestId('add-app-connection-dialog')
|
applicationsPage.page.getByTestId('add-app-connection-dialog')
|
||||||
).toBeVisible();
|
).toBeVisible();
|
||||||
await applicationsPage.clickAway();
|
await applicationsPage.clickAway();
|
||||||
await expect(applicationsPage.page).toHaveURL(
|
await expect(applicationsPage.page).toHaveURL(
|
||||||
'/app/airtable/connections'
|
'/app/azure-openai/connections'
|
||||||
);
|
);
|
||||||
await expect(
|
await expect(
|
||||||
applicationsPage.page.getByTestId('add-app-connection-dialog')
|
applicationsPage.page.getByTestId('add-app-connection-dialog')
|
||||||
|
@@ -36,7 +36,7 @@ function AdminApplicationSettings(props) {
|
|||||||
|
|
||||||
const handleSubmit = async (values) => {
|
const handleSubmit = async (values) => {
|
||||||
try {
|
try {
|
||||||
if (!appConfig?.data) {
|
if (!appConfig.data) {
|
||||||
await createAppConfig({
|
await createAppConfig({
|
||||||
variables: {
|
variables: {
|
||||||
input: { key: props.appKey, ...values },
|
input: { key: props.appKey, ...values },
|
||||||
@@ -69,7 +69,6 @@ function AdminApplicationSettings(props) {
|
|||||||
}),
|
}),
|
||||||
[appConfig?.data],
|
[appConfig?.data],
|
||||||
);
|
);
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<Form
|
<Form
|
||||||
defaultValues={defaultValues}
|
defaultValues={defaultValues}
|
||||||
|
@@ -28,12 +28,9 @@ function ContextMenu(props) {
|
|||||||
variables: { input: { id: flowId } },
|
variables: { input: { id: flowId } },
|
||||||
});
|
});
|
||||||
|
|
||||||
if (appKey) {
|
await queryClient.invalidateQueries({
|
||||||
await queryClient.invalidateQueries({
|
queryKey: ['apps', appKey, 'flows'],
|
||||||
queryKey: ['apps', appKey, 'flows'],
|
});
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
enqueueSnackbar(formatMessage('flow.successfullyDuplicated'), {
|
enqueueSnackbar(formatMessage('flow.successfullyDuplicated'), {
|
||||||
variant: 'success',
|
variant: 'success',
|
||||||
SnackbarProps: {
|
SnackbarProps: {
|
||||||
@@ -59,12 +56,9 @@ function ContextMenu(props) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
if (appKey) {
|
await queryClient.invalidateQueries({
|
||||||
await queryClient.invalidateQueries({
|
queryKey: ['apps', appKey, 'flows'],
|
||||||
queryKey: ['apps', appKey, 'flows'],
|
});
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
enqueueSnackbar(formatMessage('flow.successfullyDeleted'), {
|
enqueueSnackbar(formatMessage('flow.successfullyDeleted'), {
|
||||||
variant: 'success',
|
variant: 'success',
|
||||||
});
|
});
|
||||||
@@ -116,7 +110,7 @@ ContextMenu.propTypes = {
|
|||||||
]).isRequired,
|
]).isRequired,
|
||||||
onDeleteFlow: PropTypes.func,
|
onDeleteFlow: PropTypes.func,
|
||||||
onDuplicateFlow: PropTypes.func,
|
onDuplicateFlow: PropTypes.func,
|
||||||
appKey: PropTypes.string,
|
appKey: PropTypes.string.isRequired,
|
||||||
};
|
};
|
||||||
|
|
||||||
export default ContextMenu;
|
export default ContextMenu;
|
||||||
|
@@ -38,24 +38,20 @@ function FlowRow(props) {
|
|||||||
const contextButtonRef = React.useRef(null);
|
const contextButtonRef = React.useRef(null);
|
||||||
const [anchorEl, setAnchorEl] = React.useState(null);
|
const [anchorEl, setAnchorEl] = React.useState(null);
|
||||||
const { flow, onDuplicateFlow, onDeleteFlow, appKey } = props;
|
const { flow, onDuplicateFlow, onDeleteFlow, appKey } = props;
|
||||||
|
|
||||||
const handleClose = () => {
|
const handleClose = () => {
|
||||||
setAnchorEl(null);
|
setAnchorEl(null);
|
||||||
};
|
};
|
||||||
|
|
||||||
const onContextMenuClick = (event) => {
|
const onContextMenuClick = (event) => {
|
||||||
event.preventDefault();
|
event.preventDefault();
|
||||||
event.stopPropagation();
|
event.stopPropagation();
|
||||||
event.nativeEvent.stopImmediatePropagation();
|
event.nativeEvent.stopImmediatePropagation();
|
||||||
setAnchorEl(contextButtonRef.current);
|
setAnchorEl(contextButtonRef.current);
|
||||||
};
|
};
|
||||||
|
|
||||||
const createdAt = DateTime.fromMillis(parseInt(flow.createdAt, 10));
|
const createdAt = DateTime.fromMillis(parseInt(flow.createdAt, 10));
|
||||||
const updatedAt = DateTime.fromMillis(parseInt(flow.updatedAt, 10));
|
const updatedAt = DateTime.fromMillis(parseInt(flow.updatedAt, 10));
|
||||||
const isUpdated = updatedAt > createdAt;
|
const isUpdated = updatedAt > createdAt;
|
||||||
const relativeCreatedAt = createdAt.toRelative();
|
const relativeCreatedAt = createdAt.toRelative();
|
||||||
const relativeUpdatedAt = updatedAt.toRelative();
|
const relativeUpdatedAt = updatedAt.toRelative();
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<>
|
<>
|
||||||
<Card sx={{ mb: 1 }} data-test="flow-row">
|
<Card sx={{ mb: 1 }} data-test="flow-row">
|
||||||
@@ -131,7 +127,7 @@ FlowRow.propTypes = {
|
|||||||
flow: FlowPropType.isRequired,
|
flow: FlowPropType.isRequired,
|
||||||
onDeleteFlow: PropTypes.func,
|
onDeleteFlow: PropTypes.func,
|
||||||
onDuplicateFlow: PropTypes.func,
|
onDuplicateFlow: PropTypes.func,
|
||||||
appKey: PropTypes.string,
|
appKey: PropTypes.string.isRequired,
|
||||||
};
|
};
|
||||||
|
|
||||||
export default FlowRow;
|
export default FlowRow;
|
||||||
|
@@ -1,4 +1,3 @@
|
|||||||
import PropTypes from 'prop-types';
|
|
||||||
import * as React from 'react';
|
import * as React from 'react';
|
||||||
import { v4 as uuidv4 } from 'uuid';
|
import { v4 as uuidv4 } from 'uuid';
|
||||||
import { useFormContext, useWatch } from 'react-hook-form';
|
import { useFormContext, useWatch } from 'react-hook-form';
|
||||||
@@ -12,18 +11,15 @@ import AddIcon from '@mui/icons-material/Add';
|
|||||||
import useFormatMessage from 'hooks/useFormatMessage';
|
import useFormatMessage from 'hooks/useFormatMessage';
|
||||||
import InputCreator from 'components/InputCreator';
|
import InputCreator from 'components/InputCreator';
|
||||||
import { EditorContext } from 'contexts/Editor';
|
import { EditorContext } from 'contexts/Editor';
|
||||||
|
|
||||||
const createGroupItem = () => ({
|
const createGroupItem = () => ({
|
||||||
key: '',
|
key: '',
|
||||||
operator: operators[0].value,
|
operator: operators[0].value,
|
||||||
value: '',
|
value: '',
|
||||||
id: uuidv4(),
|
id: uuidv4(),
|
||||||
});
|
});
|
||||||
|
|
||||||
const createGroup = () => ({
|
const createGroup = () => ({
|
||||||
and: [createGroupItem()],
|
and: [createGroupItem()],
|
||||||
});
|
});
|
||||||
|
|
||||||
const operators = [
|
const operators = [
|
||||||
{
|
{
|
||||||
label: 'Equal',
|
label: 'Equal',
|
||||||
@@ -58,7 +54,6 @@ const operators = [
|
|||||||
value: 'not_contains',
|
value: 'not_contains',
|
||||||
},
|
},
|
||||||
];
|
];
|
||||||
|
|
||||||
const createStringArgument = (argumentOptions) => {
|
const createStringArgument = (argumentOptions) => {
|
||||||
return {
|
return {
|
||||||
...argumentOptions,
|
...argumentOptions,
|
||||||
@@ -67,7 +62,6 @@ const createStringArgument = (argumentOptions) => {
|
|||||||
variables: true,
|
variables: true,
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|
||||||
const createDropdownArgument = (argumentOptions) => {
|
const createDropdownArgument = (argumentOptions) => {
|
||||||
return {
|
return {
|
||||||
...argumentOptions,
|
...argumentOptions,
|
||||||
@@ -75,35 +69,28 @@ const createDropdownArgument = (argumentOptions) => {
|
|||||||
type: 'dropdown',
|
type: 'dropdown',
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|
||||||
function FilterConditions(props) {
|
function FilterConditions(props) {
|
||||||
const { stepId } = props;
|
const { stepId } = props;
|
||||||
const formatMessage = useFormatMessage();
|
const formatMessage = useFormatMessage();
|
||||||
const { control, setValue, getValues } = useFormContext();
|
const { control, setValue, getValues } = useFormContext();
|
||||||
const groups = useWatch({ control, name: 'parameters.or' });
|
const groups = useWatch({ control, name: 'parameters.or' });
|
||||||
const editorContext = React.useContext(EditorContext);
|
const editorContext = React.useContext(EditorContext);
|
||||||
|
|
||||||
React.useEffect(function addInitialGroupWhenEmpty() {
|
React.useEffect(function addInitialGroupWhenEmpty() {
|
||||||
const groups = getValues('parameters.or');
|
const groups = getValues('parameters.or');
|
||||||
|
|
||||||
if (!groups) {
|
if (!groups) {
|
||||||
setValue('parameters.or', [createGroup()]);
|
setValue('parameters.or', [createGroup()]);
|
||||||
}
|
}
|
||||||
}, []);
|
}, []);
|
||||||
|
|
||||||
const appendGroup = React.useCallback(() => {
|
const appendGroup = React.useCallback(() => {
|
||||||
const values = getValues('parameters.or');
|
const values = getValues('parameters.or');
|
||||||
setValue('parameters.or', values.concat(createGroup()));
|
setValue('parameters.or', values.concat(createGroup()));
|
||||||
}, []);
|
}, []);
|
||||||
|
|
||||||
const appendGroupItem = React.useCallback((index) => {
|
const appendGroupItem = React.useCallback((index) => {
|
||||||
const group = getValues(`parameters.or.${index}.and`);
|
const group = getValues(`parameters.or.${index}.and`);
|
||||||
setValue(`parameters.or.${index}.and`, group.concat(createGroupItem()));
|
setValue(`parameters.or.${index}.and`, group.concat(createGroupItem()));
|
||||||
}, []);
|
}, []);
|
||||||
|
|
||||||
const removeGroupItem = React.useCallback((groupIndex, groupItemIndex) => {
|
const removeGroupItem = React.useCallback((groupIndex, groupItemIndex) => {
|
||||||
const group = getValues(`parameters.or.${groupIndex}.and`);
|
const group = getValues(`parameters.or.${groupIndex}.and`);
|
||||||
|
|
||||||
if (group.length === 1) {
|
if (group.length === 1) {
|
||||||
const groups = getValues('parameters.or');
|
const groups = getValues('parameters.or');
|
||||||
setValue(
|
setValue(
|
||||||
@@ -117,7 +104,6 @@ function FilterConditions(props) {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
}, []);
|
}, []);
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<React.Fragment>
|
<React.Fragment>
|
||||||
<Stack sx={{ width: '100%' }} direction="column" spacing={2} mt={2}>
|
<Stack sx={{ width: '100%' }} direction="column" spacing={2} mt={2}>
|
||||||
@@ -233,9 +219,4 @@ function FilterConditions(props) {
|
|||||||
</React.Fragment>
|
</React.Fragment>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
FilterConditions.propTypes = {
|
|
||||||
stepId: PropTypes.string.isRequired,
|
|
||||||
};
|
|
||||||
|
|
||||||
export default FilterConditions;
|
export default FilterConditions;
|
||||||
|
@@ -1,4 +1,3 @@
|
|||||||
import PropTypes from 'prop-types';
|
|
||||||
import * as React from 'react';
|
import * as React from 'react';
|
||||||
import { useFormContext } from 'react-hook-form';
|
import { useFormContext } from 'react-hook-form';
|
||||||
import Collapse from '@mui/material/Collapse';
|
import Collapse from '@mui/material/Collapse';
|
||||||
@@ -9,8 +8,6 @@ import { EditorContext } from 'contexts/Editor';
|
|||||||
import FlowSubstepTitle from 'components/FlowSubstepTitle';
|
import FlowSubstepTitle from 'components/FlowSubstepTitle';
|
||||||
import InputCreator from 'components/InputCreator';
|
import InputCreator from 'components/InputCreator';
|
||||||
import FilterConditions from './FilterConditions';
|
import FilterConditions from './FilterConditions';
|
||||||
import { StepPropType, SubstepPropType } from 'propTypes/propTypes';
|
|
||||||
|
|
||||||
function FlowSubstep(props) {
|
function FlowSubstep(props) {
|
||||||
const {
|
const {
|
||||||
substep,
|
substep,
|
||||||
@@ -25,7 +22,6 @@ function FlowSubstep(props) {
|
|||||||
const formContext = useFormContext();
|
const formContext = useFormContext();
|
||||||
const validationStatus = formContext.formState.isValid;
|
const validationStatus = formContext.formState.isValid;
|
||||||
const onToggle = expanded ? onCollapse : onExpand;
|
const onToggle = expanded ? onCollapse : onExpand;
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<React.Fragment>
|
<React.Fragment>
|
||||||
<FlowSubstepTitle
|
<FlowSubstepTitle
|
||||||
@@ -77,14 +73,4 @@ function FlowSubstep(props) {
|
|||||||
</React.Fragment>
|
</React.Fragment>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
FlowSubstep.propTypes = {
|
|
||||||
substep: SubstepPropType.isRequired,
|
|
||||||
expanded: PropTypes.bool,
|
|
||||||
onExpand: PropTypes.func.isRequired,
|
|
||||||
onCollapse: PropTypes.func.isRequired,
|
|
||||||
onSubmit: PropTypes.func.isRequired,
|
|
||||||
step: StepPropType.isRequired,
|
|
||||||
};
|
|
||||||
|
|
||||||
export default FlowSubstep;
|
export default FlowSubstep;
|
||||||
|
@@ -1,20 +1,15 @@
|
|||||||
import PropTypes from 'prop-types';
|
|
||||||
import * as React from 'react';
|
import * as React from 'react';
|
||||||
import ExpandLessIcon from '@mui/icons-material/ExpandLess';
|
import ExpandLessIcon from '@mui/icons-material/ExpandLess';
|
||||||
import ExpandMoreIcon from '@mui/icons-material/ExpandMore';
|
import ExpandMoreIcon from '@mui/icons-material/ExpandMore';
|
||||||
import ErrorIcon from '@mui/icons-material/Error';
|
import ErrorIcon from '@mui/icons-material/Error';
|
||||||
import CheckCircleIcon from '@mui/icons-material/CheckCircle';
|
import CheckCircleIcon from '@mui/icons-material/CheckCircle';
|
||||||
import { ListItemButton, Typography } from './style';
|
import { ListItemButton, Typography } from './style';
|
||||||
|
|
||||||
const validIcon = <CheckCircleIcon color="success" />;
|
const validIcon = <CheckCircleIcon color="success" />;
|
||||||
|
|
||||||
const errorIcon = <ErrorIcon color="error" />;
|
const errorIcon = <ErrorIcon color="error" />;
|
||||||
|
|
||||||
function FlowSubstepTitle(props) {
|
function FlowSubstepTitle(props) {
|
||||||
const { expanded = false, onClick = () => null, valid = null, title } = props;
|
const { expanded = false, onClick = () => null, valid = null, title } = props;
|
||||||
const hasValidation = valid !== null;
|
const hasValidation = valid !== null;
|
||||||
const validationStatusIcon = valid ? validIcon : errorIcon;
|
const validationStatusIcon = valid ? validIcon : errorIcon;
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<ListItemButton onClick={onClick} selected={expanded} divider>
|
<ListItemButton onClick={onClick} selected={expanded} divider>
|
||||||
<Typography variant="body2">
|
<Typography variant="body2">
|
||||||
@@ -26,12 +21,4 @@ function FlowSubstepTitle(props) {
|
|||||||
</ListItemButton>
|
</ListItemButton>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
FlowSubstepTitle.propTypes = {
|
|
||||||
expanded: PropTypes.bool,
|
|
||||||
onClick: PropTypes.func.isRequired,
|
|
||||||
valid: PropTypes.bool,
|
|
||||||
title: PropTypes.string.isRequired,
|
|
||||||
};
|
|
||||||
|
|
||||||
export default FlowSubstepTitle;
|
export default FlowSubstepTitle;
|
||||||
|
@@ -7,11 +7,9 @@ import { FORGOT_PASSWORD } from 'graphql/mutations/forgot-password.ee';
|
|||||||
import Form from 'components/Form';
|
import Form from 'components/Form';
|
||||||
import TextField from 'components/TextField';
|
import TextField from 'components/TextField';
|
||||||
import useFormatMessage from 'hooks/useFormatMessage';
|
import useFormatMessage from 'hooks/useFormatMessage';
|
||||||
|
|
||||||
export default function ForgotPasswordForm() {
|
export default function ForgotPasswordForm() {
|
||||||
const formatMessage = useFormatMessage();
|
const formatMessage = useFormatMessage();
|
||||||
const [forgotPassword, { data, loading }] = useMutation(FORGOT_PASSWORD);
|
const [forgotPassword, { data, loading }] = useMutation(FORGOT_PASSWORD);
|
||||||
|
|
||||||
const handleSubmit = async (values) => {
|
const handleSubmit = async (values) => {
|
||||||
await forgotPassword({
|
await forgotPassword({
|
||||||
variables: {
|
variables: {
|
||||||
@@ -19,7 +17,6 @@ export default function ForgotPasswordForm() {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<Paper sx={{ px: 2, py: 4 }}>
|
<Paper sx={{ px: 2, py: 4 }}>
|
||||||
<Typography
|
<Typography
|
||||||
|
Reference in New Issue
Block a user