rayepps / exobase-js Goto Github PK

export const handler = _.compose(
  useLambda(),
  useCatch((props, error) => {
    if (error.error instanceof ExobaseError) {
      const ret = {
        ...props.response,
        status: error.error.status,
        body: { message: error.error.message },
        key: error.error.key,
      };
      return ret;
    }
    throw error;
  }),
  useCors(),
 ...
);

export const useQueryString: <TArgs extends {}, TProps extends Props = Props>(
  shapeMaker: (z: Zod) => KeyOfType<TArgs, any>,
  strict?: boolean
) => (
  func: Handler<
    TProps & {
      args: TProps['args'] & TArgs;
    }
  >
) => Handler<TProps> = (shapeMaker, strict) => (func) => {
  let model: AnyZodObject;
  if (strict) {
    model = zod.object(shapeMaker(zod)).strict();
  } else {
    model = zod.object(shapeMaker(zod));
  }
  return (props) => withQueryString(func as Handler, model, null, props);
};

import type { Props } from '@exobase/core';
import makeStorageService, {
  StorageService,
} from '../storage-service';
import { useService } from '@exobase/hooks';
import _ from 'radash';
import config from '../config';

interface Args {
  listThingsArgs: any;
}

interface Services {
  storage: StorageService;
}

type Response = Array<string>;

async function listThings({args, services}: Props<Args, Services>): Promise<Response> {
  return this.services.storage.listThings(args.listThingsArgs)
}

export default _.compose(
  useService<Services>({
    storage: await makeStorageService(config.storageService)
  }),
  listThings
);

export { useJsonArgs, useQueryArgs, useHeaderArgs } from '@exobase/hooks';
import { partial } from 'radash';
import { useValidation } from '@exobase/hooks';
import { Props, ApiFunction, Request } from '@exobase/core';
import { APIGatewayProxyEvent } from 'aws-lambda';
import * as yup from 'yup';

type APIGatewayProxyRequest = Request & { event: APIGatewayProxyEvent };
type Yup = typeof yup;
type KeyOfType<T, Value> = { [P in keyof T]: Value };

/**
 * Get args from the parsed path parameters (AWS API Gateway-specific)
 */
export const useLambdaPathArgs = partial(
  useValidation,
  (props: Props<any, any, any, APIGatewayProxyRequest>) =>
    props.req.event.pathParameters
) as <TArgs = any>(
  shapeMaker: (yup: Yup) => KeyOfType<TArgs, any>
) => (func: ApiFunction) => ApiFunction;