Infrastructure/logto
0
Fork 0
mirror of https://github.com/logto-io/logto.git synced 2025-02-17 22:04:19 -05:00
Code Issues Activity

feat: updateConnectorConfig (#168)

Browse source 
* feat: updateConnectorConfig

* fix: throw RequestError

* feat: template
This commit is contained in:
Wang Sijie 2022-01-12 16:58:07 +08:00 • committed by GitHub
parent 6e9cabe50b
commit 59cd617b2b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 35 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
packages/core/src/connectors/utils.ts Normal file
View file

@ -0,0 +1,32 @@
import { ConnectorConfig, ConnectorType } from '@logto/schemas';
import RequestError from '@/errors/RequestError';
import { findConnectorByIdAndType, updateConnector } from '@/queries/connector';
export const getConnectorConfig = async <T extends ConnectorConfig>(
id: string,
type: ConnectorType
): Promise<T> => {
const connector = await findConnectorByIdAndType(id, type);
if (!connector) {
throw new RequestError({
code: 'entity.not_exists_with_id',
name: 'connector',
id,
status: 404,
});
}
return connector.config as T;
};
export const updateConnectorConfig = async <T extends ConnectorConfig>(
id: string,
type: ConnectorType,
config: T
): Promise<void> => {
await updateConnector({
where: { id, type },
set: { config },
});
};

3
packages/core/src/queries/connector.ts
View file

@ -3,6 +3,7 @@ import { sql } from 'slonik';
import { buildInsertInto } from '@/database/insert-into';
import pool from '@/database/pool';
import { buildUpdateWhere } from '@/database/update-where';
import { convertToIdentifiers } from '@/database/utils';
const { table, fields } = convertToIdentifiers(Connectors);
@ -17,3 +18,5 @@ export const findConnectorByIdAndType = async (id: string, type: ConnectorType)
export const insertConnector = buildInsertInto<ConnectorUpdate, Connector>(pool, Connectors, {
returning: true,
});
export const updateConnector = buildUpdateWhere<ConnectorUpdate>(pool, Connectors);