@dozerjs/dozer-react

Connect any data source, combine them in real-time and instantly get low-latency gRPC and REST APIs.
⚡ All with just a simple configuration! ⚡️

Overview

This repository is a react helpers for using Dozer as data provider.

Installation

# npm
npm install @dozerjs/dozer-react
# yarn
yarn add @dozerjs/dozer-react
# pnpm
pnpm add @dozerjs/dozer-react

Usage

Provider

import { DozerProvider } from "@dozerjs/dozer-react";

function App() {
  return (
    <DozerProvider value={{
      serverAddress: 'http://localhost:50051',
    }}>
      {/* ... */}
    </DozerProvider>
  )
}

query

useDozerQuery(endpoint: string, query?: DozerQuery)

This hook can be used for getting data from cache. It allows to pass query. Query is json object serialized as string.

import { Order } from '@dozerjs/dozer';
import { useDozerQuery } from "@dozerjs/dozer-react";

function AirportComponent() {
  let query = {
    orderBy: {
      start: Order.ASC
    }
  }
  const { records, fields } = useDozerQuery('airports', query);

  return <>{records.map(record => <div key={record.__dozer_record_id}>{JSON.stringify(record)}</div>)}</>
}

count

useDozerCount(endpoint: string, query?: DozerQuery)

This hook returns number of records in endpoint.

import { useDozerCount } from "@dozerjs/dozer-react";

const AirportComponent = () => {
  const { count } = useDozerEndpointCount('airports');

  return <span>Total airports count: {count}</span>
}

event

useDozerEvent(options: DozerOnEventOption[])

This hook can create a gRPC stream to monitor real-time store modifications for multiple endpoints.

import { types_pb } from '@dozerjs/dozer';
import { useDozerEvent } from "@dozerjs/dozer-react";
import { useState } from 'react';

const AirportComponent = () => {

  const [count, setCount] = useState(0);

  const { stream } = useDozerEvent([
    {
      endpoint: 'airports',
      eventType: types_pb.EventType.All,
    }
  ]);

  stream.on('data', (operation: types_pb.Operation) => {
    setNum(pre => prev + 1);
  });

  return <span>Total event count: {count}</span>
}

Advantage

connect stream

Here a connect function exported from useDozerQuery and useDozerCount, it can monitor gRPC stream exported from useDozerEvent and automagically updates.

import { types_pb } from '@dozerjs/dozer';
import { useDozerCount, useDozerEvent } from "@dozerjs/dozer-react";
import { ClientReadableStream } from "grpc-web";

const CountComponent = (props: { stream?: ClientReadableStream<types_pb.Operation> }) => {
  const { count, connect } = useDozerCount('airports');
  connect(stream);
  return (
    <div>
      <h3>Total count: <small>* automagic updates</small></h3>
      <div>{count}</div>
    </div>
  )
}
const QueryComponent = (props: { stream?: ClientReadableStream<types_pb.Operation> }) => {
  const { records, connect } = useDozerQuery('airports');
  connect(stream);
  return (
    <div>
      <h3>Records length: <small>* automagic updates</small></h3>
      <div>{records.map(record => <div key={record.__dozer_record_id}>{JSON.stringify(record)}</div>)}</div>
    </div>
  )
}

const AirportComponent = () => {
  const { stream } = useDozerEvent([
    {
      endpoint: 'airports',
      eventType: types_pb.EventType.ALL
    },
  ]);

  return (
    <div>
      <CountComponent stream={stream} />
      <QueryComponent stream={stream} />
    </div>
  )
}

consume operation

The connect function will consume all the operations of gRPC stream, if you want to filter, you can use consume funtion.

import { types_pb } from '@dozerjs/dozer';
import { useDozerCount, useDozerEvent } from "@dozerjs/dozer-react";
import { ClientReadableStream } from "grpc-web";

const CountComponent = (props: { stream?: ClientReadableStream<types_pb.Operation> }) => {
  const { count, consume } = useDozerCount('airports');

  useEffect(() => {
    const cb = ((operation: types_pb.Operation) => {
      consume(operation);
    })
    props.stream?.on('data', cb);
    return () => {
      props.stream?.removeListener('data', cb);
    }
  }, [props.stream]);

  return (
    <div>
      <h3>Total count: <small>* automagic updates</small></h3>
      <div>{count}</div>
    </div>
  )
}
const QueryComponent = (props: { stream?: ClientReadableStream<types_pb.Operation> }) => {
  const { records, consume } = useDozerQuery('airports');

  useEffect(() => {
    const cb = ((operation: types_pb.Operation) => {
      consume(operation);
    })
    props.stream?.on('data', cb);
    return () => {
      props.stream?.removeListener('data', cb);
    }
  }, [props.stream]);

  return (
    <div>
      <h3>Records length: <small>* automagic updates</small></h3>
      <div>{records.map(record => <div key={record.__dozer_record_id}>{JSON.stringify(record)}</div>)}</div>
    </div>
  )
}

const AirportComponent = () => {
  const { stream } = useDozerEvent({
    endpoint: 'airports',
    eventType: types_pb.EventType.ALL
  });

  return (
    <div>
      <CountComponent stream={stream} />
      <QueryComponent stream={stream} />
    </div>
  )
}

multiple endpoints with event

useDozerEndpoints(options: DozerOnEventOption[])

This hook can get data for multiple endpoints. Can also automagic updates if you set eventType.

import { types_pb } from '@dozerjs/dozer';
import { useDozerEndpoints } from "@dozerjs/dozer-react";

const AirportsComponent = () => {
  const options = [
    {
      endpoint: 'airports',
      eventType: types_pb.EventType.All,
    },
    {
      endpoint: 'airports_count',
      eventType: types_pb.EventType.All,
    },
  ];

  const data = useDozerEndpoints(options);

  return options.map((option, index) => (
    <>
      <h3>Endpoint: {option.endpoint}</h3>
      <div>
        {
          data[index].records?.map((record) => <div key={record.__dozer_record_id}>{JSON.stringify(record)}</div>)
        }
      </div>
    </>
  ))
}