mirror of
https://github.com/stefanpejcic/openpanel
synced 2025-06-26 18:28:26 +00:00
cleaner
This commit is contained in:
Stefan Pejcic
@@ -1,359 +0,0 @@
|
||||
import { DataProvider, BaseRecord } from "@refinedev/core";
|
||||
import { GraphQLClient } from "graphql-request";
|
||||
import * as gql from "gql-query-builder";
|
||||
import pluralize from "pluralize";
|
||||
import camelCase from "camelcase";
|
||||
import { generateFilter, generateSort } from "../utils";
|
||||
|
||||
const dataProvider = (client: GraphQLClient): Required<DataProvider> => {
|
||||
return {
|
||||
getList: async ({ resource, pagination, sorters, filters, meta }) => {
|
||||
const {
|
||||
current = 1,
|
||||
pageSize = 10,
|
||||
mode = "server",
|
||||
} = pagination ?? {};
|
||||
|
||||
const sortBy = generateSort(sorters);
|
||||
const filterBy = generateFilter(filters);
|
||||
|
||||
const camelResource = camelCase(resource);
|
||||
|
||||
const operation = meta?.operation ?? camelResource;
|
||||
|
||||
const { query, variables } = gql.query({
|
||||
operation,
|
||||
variables: {
|
||||
...meta?.variables,
|
||||
sort: sortBy,
|
||||
where: { value: filterBy, type: "JSON" },
|
||||
...(mode === "server"
|
||||
? {
|
||||
start: (current - 1) * pageSize,
|
||||
limit: pageSize,
|
||||
}
|
||||
: {}),
|
||||
},
|
||||
fields: meta?.fields,
|
||||
});
|
||||
|
||||
const response = await client.request<BaseRecord>(query, variables);
|
||||
|
||||
return {
|
||||
data: response[operation],
|
||||
total: response[operation].count,
|
||||
};
|
||||
},
|
||||
|
||||
getMany: async ({ resource, ids, meta }) => {
|
||||
const camelResource = camelCase(resource);
|
||||
|
||||
const operation = meta?.operation ?? camelResource;
|
||||
|
||||
const { query, variables } = gql.query({
|
||||
operation,
|
||||
variables: {
|
||||
where: {
|
||||
value: { id_in: ids },
|
||||
type: "JSON",
|
||||
},
|
||||
},
|
||||
fields: meta?.fields,
|
||||
});
|
||||
|
||||
const response = await client.request<BaseRecord>(query, variables);
|
||||
|
||||
return {
|
||||
data: response[operation],
|
||||
};
|
||||
},
|
||||
|
||||
create: async ({ resource, variables, meta }) => {
|
||||
const singularResource = pluralize.singular(resource);
|
||||
const camelCreateName = camelCase(`create-${singularResource}`);
|
||||
|
||||
const operation = meta?.operation ?? camelCreateName;
|
||||
const inputType = meta?.inputType ?? `${camelCreateName}Input`;
|
||||
|
||||
const { query, variables: gqlVariables } = gql.mutation({
|
||||
operation,
|
||||
variables: {
|
||||
input: {
|
||||
value: { data: variables },
|
||||
type: inputType,
|
||||
},
|
||||
},
|
||||
fields: meta?.fields ?? [
|
||||
{
|
||||
operation: singularResource,
|
||||
fields: ["id"],
|
||||
variables: {},
|
||||
},
|
||||
],
|
||||
});
|
||||
const response = await client.request<BaseRecord>(
|
||||
query,
|
||||
gqlVariables,
|
||||
);
|
||||
|
||||
return {
|
||||
data: response[operation][singularResource],
|
||||
};
|
||||
},
|
||||
|
||||
createMany: async ({ resource, variables, meta }) => {
|
||||
const singularResource = pluralize.singular(resource);
|
||||
const camelCreateName = camelCase(`create-${singularResource}`);
|
||||
|
||||
const operation = meta?.operation ?? camelCreateName;
|
||||
const inputType = meta?.operation ?? `${camelCreateName}Input`;
|
||||
|
||||
const response = await Promise.all(
|
||||
variables.map(async (param) => {
|
||||
const { query, variables: gqlVariables } = gql.mutation({
|
||||
operation,
|
||||
variables: {
|
||||
input: {
|
||||
value: { data: param },
|
||||
type: inputType,
|
||||
},
|
||||
},
|
||||
fields: meta?.fields ?? [
|
||||
{
|
||||
operation: singularResource,
|
||||
fields: ["id"],
|
||||
variables: {},
|
||||
},
|
||||
],
|
||||
});
|
||||
const result = await client.request<BaseRecord>(
|
||||
query,
|
||||
gqlVariables,
|
||||
);
|
||||
|
||||
return result[operation][singularResource];
|
||||
}),
|
||||
);
|
||||
return {
|
||||
data: response,
|
||||
};
|
||||
},
|
||||
|
||||
update: async ({ resource, id, variables, meta }) => {
|
||||
const singularResource = pluralize.singular(resource);
|
||||
const camelUpdateName = camelCase(`update-${singularResource}`);
|
||||
|
||||
const operation = meta?.operation ?? camelUpdateName;
|
||||
const inputType = meta?.operation ?? `${camelUpdateName}Input`;
|
||||
|
||||
const { query, variables: gqlVariables } = gql.mutation({
|
||||
operation,
|
||||
variables: {
|
||||
input: {
|
||||
value: { where: { id }, data: variables },
|
||||
type: inputType,
|
||||
},
|
||||
},
|
||||
fields: meta?.fields ?? [
|
||||
{
|
||||
operation: singularResource,
|
||||
fields: ["id"],
|
||||
variables: {},
|
||||
},
|
||||
],
|
||||
});
|
||||
const response = await client.request<BaseRecord>(
|
||||
query,
|
||||
gqlVariables,
|
||||
);
|
||||
|
||||
return {
|
||||
data: response[operation][singularResource],
|
||||
};
|
||||
},
|
||||
|
||||
updateMany: async ({ resource, ids, variables, meta }) => {
|
||||
const singularResource = pluralize.singular(resource);
|
||||
const camelUpdateName = camelCase(`update-${singularResource}`);
|
||||
|
||||
const operation = meta?.operation ?? camelUpdateName;
|
||||
const inputType = meta?.operation ?? `${camelUpdateName}Input`;
|
||||
|
||||
const response = await Promise.all(
|
||||
ids.map(async (id) => {
|
||||
const { query, variables: gqlVariables } = gql.mutation({
|
||||
operation,
|
||||
variables: {
|
||||
input: {
|
||||
value: { where: { id }, data: variables },
|
||||
type: inputType,
|
||||
},
|
||||
},
|
||||
fields: meta?.fields ?? [
|
||||
{
|
||||
operation: singularResource,
|
||||
fields: ["id"],
|
||||
variables: {},
|
||||
},
|
||||
],
|
||||
});
|
||||
const result = await client.request<BaseRecord>(
|
||||
query,
|
||||
gqlVariables,
|
||||
);
|
||||
|
||||
return result[operation][singularResource];
|
||||
}),
|
||||
);
|
||||
return {
|
||||
data: response,
|
||||
};
|
||||
},
|
||||
|
||||
getOne: async ({ resource, id, meta }) => {
|
||||
const singularResource = pluralize.singular(resource);
|
||||
const camelResource = camelCase(singularResource);
|
||||
|
||||
const operation = meta?.operation ?? camelResource;
|
||||
|
||||
const { query, variables } = gql.query({
|
||||
operation,
|
||||
variables: {
|
||||
id: { value: id, type: "ID", required: true },
|
||||
},
|
||||
fields: meta?.fields,
|
||||
});
|
||||
|
||||
const response = await client.request<BaseRecord>(query, variables);
|
||||
|
||||
return {
|
||||
data: response[operation],
|
||||
};
|
||||
},
|
||||
|
||||
deleteOne: async ({ resource, id, meta }) => {
|
||||
const singularResource = pluralize.singular(resource);
|
||||
const camelDeleteName = camelCase(`delete-${singularResource}`);
|
||||
|
||||
const operation = meta?.operation ?? camelDeleteName;
|
||||
const inputType = meta?.operation ?? `${camelDeleteName}Input`;
|
||||
|
||||
const { query, variables } = gql.mutation({
|
||||
operation,
|
||||
variables: {
|
||||
input: {
|
||||
value: { where: { id } },
|
||||
type: inputType,
|
||||
},
|
||||
},
|
||||
fields: meta?.fields ?? [
|
||||
{
|
||||
operation: singularResource,
|
||||
fields: ["id"],
|
||||
variables: {},
|
||||
},
|
||||
],
|
||||
});
|
||||
|
||||
const response = await client.request<BaseRecord>(query, variables);
|
||||
|
||||
return {
|
||||
data: response[operation][singularResource],
|
||||
};
|
||||
},
|
||||
|
||||
deleteMany: async ({ resource, ids, meta }) => {
|
||||
const singularResource = pluralize.singular(resource);
|
||||
const camelDeleteName = camelCase(`delete-${singularResource}`);
|
||||
|
||||
const operation = meta?.operation ?? camelDeleteName;
|
||||
const inputType = meta?.operation ?? `${camelDeleteName}Input`;
|
||||
|
||||
const response = await Promise.all(
|
||||
ids.map(async (id) => {
|
||||
const { query, variables: gqlVariables } = gql.mutation({
|
||||
operation,
|
||||
variables: {
|
||||
input: {
|
||||
value: { where: { id } },
|
||||
type: inputType,
|
||||
},
|
||||
},
|
||||
fields: meta?.fields ?? [
|
||||
{
|
||||
operation: singularResource,
|
||||
fields: ["id"],
|
||||
variables: {},
|
||||
},
|
||||
],
|
||||
});
|
||||
const result = await client.request<BaseRecord>(
|
||||
query,
|
||||
gqlVariables,
|
||||
);
|
||||
|
||||
return result[operation][singularResource];
|
||||
}),
|
||||
);
|
||||
return {
|
||||
data: response,
|
||||
};
|
||||
},
|
||||
|
||||
getApiUrl: () => {
|
||||
throw Error("Not implemented on refine-graphql data provider.");
|
||||
},
|
||||
|
||||
custom: async ({ url, method, headers, meta }) => {
|
||||
let gqlClient = client;
|
||||
|
||||
if (url) {
|
||||
gqlClient = new GraphQLClient(url, { headers });
|
||||
}
|
||||
|
||||
if (meta) {
|
||||
if (meta.operation) {
|
||||
if (method === "get") {
|
||||
const { query, variables } = gql.query({
|
||||
operation: meta.operation,
|
||||
fields: meta.fields,
|
||||
variables: meta.variables,
|
||||
});
|
||||
|
||||
const response = await gqlClient.request<BaseRecord>(
|
||||
query,
|
||||
variables,
|
||||
);
|
||||
|
||||
return {
|
||||
data: response[meta.operation],
|
||||
};
|
||||
} else {
|
||||
const { query, variables } = gql.mutation({
|
||||
operation: meta.operation,
|
||||
fields: meta.fields,
|
||||
variables: meta.variables,
|
||||
});
|
||||
|
||||
const response = await gqlClient.request<BaseRecord>(
|
||||
query,
|
||||
variables,
|
||||
);
|
||||
|
||||
return {
|
||||
data: response[meta.operation],
|
||||
};
|
||||
}
|
||||
} else {
|
||||
throw Error("GraphQL operation name required.");
|
||||
}
|
||||
} else {
|
||||
throw Error(
|
||||
"GraphQL need to operation, fields and variables values in meta object.",
|
||||
);
|
||||
}
|
||||
},
|
||||
};
|
||||
};
|
||||
|
||||
export default dataProvider;
|
||||
Reference in New Issue
Block a user