'use server';

import { z } from 'zod';
import { AppcondaException } from '../../client';
import { getSDKForCurrentUser } from '../../getSDKForCurrentUser';
import { CreateColumnSchema, CreateDatabaseSchema, CreateDataSourceSchema, CreateTableSchema, GetColumnSchema, GetDatabaseSchema, GetDataSourceSchema, GetTableSchema, ListColumnsSchema, ListDatabasesSchema, ListDataSourcesSchema, ListTablesSchema } from './schema';
import { getSDKForService } from '../../getSDKForService';

export const CreateDataSource = async (parsedInput: z.infer<typeof CreateDataSourceSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.CreateDataSource(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const GetDataSource = async (parsedInput: z.infer<typeof GetDataSourceSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.GetDataSource(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};


export const ListDataSources = async (parsedInput: z.infer<typeof ListDataSourcesSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.ListDataSources(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const CreateDatabase = async (parsedInput: z.infer<typeof CreateDatabaseSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.CreateDatabase(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const GetDatabase = async (parsedInput: z.infer<typeof GetDatabaseSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.GetDatabase(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const ListDatabases = async (parsedInput: z.infer<typeof ListDatabasesSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.ListDatabases(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const CreateTable = async (parsedInput: z.infer<typeof CreateTableSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.CreateTable(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const GetTable = async (parsedInput: z.infer<typeof GetTableSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.GetTable(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const ListTables = async (parsedInput: z.infer<typeof ListTablesSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.ListTables(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const CreateColumn = async (parsedInput: z.infer<typeof CreateColumnSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.CreateColumn(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const GetColumn = async (parsedInput: z.infer<typeof GetColumnSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.GetColumn(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};

export const ListColumns = async (parsedInput: z.infer<typeof ListColumnsSchema>) => {
    try {
        const { datasource } = await getSDKForService();
        //@ts-ignore
        const app = await datasource.ListColumns(parsedInput);
        return app;
    } catch (error) {
        if (error instanceof AppcondaException) {
            throw new Error(error.message);
        }

        throw error;
    }
};