Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove rest-hooks for specifications load #10764

Merged
merged 4 commits into from
Mar 22, 2022
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 0 additions & 22 deletions airbyte-webapp/package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 0 additions & 1 deletion airbyte-webapp/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
"@fortawesome/free-solid-svg-icons": "^5.15.4",
"@fortawesome/react-fontawesome": "^0.1.16",
"@fullstory/browser": "^1.4.9",
"@rest-hooks/legacy": "^2.0.5",
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🎉

"@sentry/react": "^6.11.0",
"@sentry/tracing": "^6.11.0",
"dayjs": "^1.8.35",
Expand Down
2 changes: 1 addition & 1 deletion airbyte-webapp/src/core/ApiServices.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import { useConfig } from "config";
import { RequestMiddleware } from "./request/RequestMiddleware";
import { SourceDefinitionService } from "./domain/connector/SourceDefinitionService";
import { DestinationDefinitionService } from "./domain/connector/DestinationDefinitionService";
import { DeploymentService } from "./resources/DeploymentService";
import { DeploymentService } from "./domain/DeploymentService";
import { OperationService } from "./domain/connection";
import { HealthService } from "./health/HealthService";
import { useGetService, useInjectServices } from "./servicesProvider";
Expand Down
2 changes: 1 addition & 1 deletion airbyte-webapp/src/core/domain/catalog/api.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { JSONSchema7 } from "json-schema";
import { JobInfo } from "../job/Job";
import { JobInfo } from "../job";

export interface SourceDiscoverSchemaRead {
catalog: SyncSchema;
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
import { AirbyteRequestService } from "core/request/AirbyteRequestService";
import { DestinationDefinitionSpecification } from "./types";

class DestinationDefinitionSpecificationService extends AirbyteRequestService {
get url(): string {
return "destination_definition_specifications";
}

public get(
destinationDefinitionId: string
): Promise<DestinationDefinitionSpecification> {
return this.fetch<DestinationDefinitionSpecification>(`${this.url}/get`, {
destinationDefinitionId,
});
}
}

export { DestinationDefinitionSpecificationService };
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
import { AirbyteRequestService } from "core/request/AirbyteRequestService";
import { SourceDefinitionSpecification } from "./types";

class SourceDefinitionSpecificationService extends AirbyteRequestService {
get url(): string {
return "source_definition_specifications";
}

public get(
sourceDefinitionId: string
): Promise<SourceDefinitionSpecification> {
return this.fetch<SourceDefinitionSpecification>(`${this.url}/get`, {
sourceDefinitionId,
});
}
}

export { SourceDefinitionSpecificationService };

This file was deleted.

2 changes: 1 addition & 1 deletion airbyte-webapp/src/core/resources/Schema.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ import { ReadShape, Resource, SchemaDetail } from "rest-hooks";
import BaseResource from "./BaseResource";
import { SourceDiscoverSchemaRead, SyncSchema } from "core/domain/catalog";
import { toInnerModel } from "core/domain/catalog/fieldUtil";
import { JobInfo } from "../domain/job/Job";
import { JobInfo } from "core/domain/job";

export interface Schema extends SourceDiscoverSchemaRead {
id: string;
Expand Down
30 changes: 0 additions & 30 deletions airbyte-webapp/src/core/resources/SourceDefinitionSpecification.ts

This file was deleted.

47 changes: 1 addition & 46 deletions airbyte-webapp/src/hooks/services/useDestinationHook.tsx
Original file line number Diff line number Diff line change
@@ -1,20 +1,15 @@
import { useCallback } from "react";
import { useFetcher, useResource } from "rest-hooks";
import { useStatefulResource } from "@rest-hooks/legacy";

import DestinationResource from "core/resources/Destination";
import ConnectionResource, { Connection } from "core/resources/Connection";
import { RoutePaths } from "pages/routes";
import useRouter from "../useRouter";
import DestinationDefinitionSpecificationResource from "core/resources/DestinationDefinitionSpecification";
import SchedulerResource, { Scheduler } from "core/resources/Scheduler";
import { ConnectionConfiguration } from "core/domain/connection";
import useWorkspace from "./useWorkspace";
import { useAnalyticsService } from "hooks/services/Analytics/useAnalyticsService";
import {
Destination,
DestinationDefinitionSpecification,
} from "core/domain/connector";
import { Destination } from "core/domain/connector";

type ValuesProps = {
name: string;
Expand All @@ -24,46 +19,6 @@ type ValuesProps = {

type ConnectorProps = { name: string; destinationDefinitionId: string };

export const useDestinationDefinitionSpecificationLoad = (
destinationDefinitionId: string | null
): {
isLoading: boolean;
destinationDefinitionSpecification?: DestinationDefinitionSpecification;
sourceDefinitionError?: Error;
} => {
const {
loading: isLoading,
error,
data: destinationDefinitionSpecification,
} = useStatefulResource(
DestinationDefinitionSpecificationResource.detailShape(),
destinationDefinitionId
? {
destinationDefinitionId,
}
: null
);

return {
destinationDefinitionSpecification,
sourceDefinitionError: error,
isLoading,
};
};

export const useDestinationDefinitionSpecificationLoadAsync = (
destinationDefinitionId: string
): DestinationDefinitionSpecification => {
const definition = useResource(
DestinationDefinitionSpecificationResource.detailShape(),
{
destinationDefinitionId,
}
);

return definition;
};

type DestinationService = {
checkDestinationConnection: ({
destinationId,
Expand Down
27 changes: 1 addition & 26 deletions airbyte-webapp/src/hooks/services/useSourceHook.tsx
Original file line number Diff line number Diff line change
@@ -1,18 +1,16 @@
import { useCallback } from "react";
import { useFetcher, useResource } from "rest-hooks";
import { useStatefulResource } from "@rest-hooks/legacy";

import SourceResource from "core/resources/Source";
import { RoutePaths } from "pages/routes";
import ConnectionResource, { Connection } from "core/resources/Connection";
import SourceDefinitionSpecificationResource from "core/resources/SourceDefinitionSpecification";
import SchedulerResource, { Scheduler } from "core/resources/Scheduler";
import { ConnectionConfiguration } from "core/domain/connection";
import useWorkspace from "./useWorkspace";

import useRouter from "hooks/useRouter";
import { useAnalyticsService } from "hooks/services/Analytics/useAnalyticsService";
import { Source, SourceDefinitionSpecification } from "core/domain/connector";
import { Source } from "core/domain/connector";

type ValuesProps = {
name: string;
Expand All @@ -23,29 +21,6 @@ type ValuesProps = {

type ConnectorProps = { name: string; sourceDefinitionId: string };

export const useSourceDefinitionSpecificationLoad = (
sourceDefinitionId: string
): {
isLoading: boolean;
sourceDefinitionError?: Error;
sourceDefinitionSpecification?: SourceDefinitionSpecification;
} => {
const {
loading: isLoading,
error: sourceDefinitionError,
data: sourceDefinitionSpecification,
} = useStatefulResource(
SourceDefinitionSpecificationResource.detailShape(),
sourceDefinitionId
? {
sourceDefinitionId,
}
: null
);

return { sourceDefinitionSpecification, sourceDefinitionError, isLoading };
};

type SourceService = {
recreateSource: (recreateSourcePayload: {
values: ValuesProps;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,13 +1,14 @@
import React, { useState } from "react";
import { FormattedMessage } from "react-intl";

import useRouter from "hooks/useRouter";
import { useDestinationDefinitionSpecificationLoad } from "hooks/services/useDestinationHook";
import { createFormErrorMessage } from "utils/errorStatusMessage";
import { ConnectionConfiguration } from "core/domain/connection";
import { useAnalyticsService } from "hooks/services/Analytics/useAnalyticsService";
import { LogsRequestError } from "core/request/LogsRequestError";
import { ConnectorCard } from "views/Connector/ConnectorCard";
import { DestinationDefinition } from "core/domain/connector";
import { useGetDestinationDefinitionSpecificationAsync } from "../../../../../services/connector/DestinationDefinitionSpecificationService";

type IProps = {
onSubmit: (values: {
Expand Down Expand Up @@ -36,10 +37,10 @@ const DestinationForm: React.FC<IProps> = ({
location.state?.destinationDefinitionId || ""
);
const {
destinationDefinitionSpecification,
data: destinationDefinitionSpecification,
isLoading,
sourceDefinitionError,
} = useDestinationDefinitionSpecificationLoad(destinationDefinitionId);
error: destinationDefinitionError,
} = useGetDestinationDefinitionSpecificationAsync(destinationDefinitionId);

const onDropDownSelect = (destinationDefinitionId: string) => {
setDestinationDefinitionId(destinationDefinitionId);
Expand Down Expand Up @@ -74,7 +75,7 @@ const DestinationForm: React.FC<IProps> = ({
return (
<ConnectorCard
onServiceSelect={onDropDownSelect}
fetchingConnectorError={sourceDefinitionError}
fetchingConnectorError={destinationDefinitionError}
onSubmit={onSubmitForm}
formType="destination"
availableServices={destinationDefinitions}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,7 @@ import styled from "styled-components";
import { useResource } from "rest-hooks";

import DeleteBlock from "components/DeleteBlock";
import useDestination, {
useDestinationDefinitionSpecificationLoadAsync,
} from "hooks/services/useDestinationHook";
import useDestination from "hooks/services/useDestinationHook";
import { Connection } from "core/resources/Connection";
import { ConnectionConfiguration } from "core/domain/connection";
import DestinationDefinitionResource from "core/resources/DestinationDefinition";
Expand All @@ -15,6 +13,7 @@ import { createFormErrorMessage } from "utils/errorStatusMessage";
import { LogsRequestError } from "core/request/LogsRequestError";
import { ConnectorCard } from "views/Connector/ConnectorCard";
import { Connector, Destination } from "core/domain/connector";
import { useGetDestinationDefinitionSpecification } from "services/connector/DestinationDefinitionSpecificationService";

const Content = styled.div`
width: 100%;
Expand All @@ -36,7 +35,7 @@ const DestinationsSettings: React.FC<IProps> = ({
null
);

const destinationSpecification = useDestinationDefinitionSpecificationLoadAsync(
const destinationSpecification = useGetDestinationDefinitionSpecification(
currentDestination.destinationDefinitionId
);

Expand Down
Loading