import DataRepository from "businesslogic/DataRepository";
import DbContext from "models/DbContext";
import { create } from "zustand";

type UseDBContext = {
  dbContext: DbContext | null;
  initialized: boolean;
  init: () => Promise<void>;
};
export const useDBContext = create<UseDBContext>((set, get) => ({
  dbContext: null,
  initialized: false,
  init: async () => {
    let context = await DataRepository.initialize();
    set({ dbContext: context, initialized: true });
  },
}));

import DataRepository from "businesslogic/DataRepository";
import DbContext from "models/DbContext";
import { create } from "zustand";

type UseDBContext = {
  dbContext: DbContext | null;
  initialized: boolean;
  init: () => Promise<void>;
};
export const useDBContext = create<UseDBContext>((set, get) => ({
  dbContext: null,
  initialized: false,
  init: async () => {
    let context = await DataRepository.initialize();
    set({ dbContext: context, initialized: true });
  },
}));

function createDBContextStore(dbContext: DB Context) {
  return create((set) => ({
    dbContext,
  }));
}

function createDBContextStore(dbContext: DB Context) {
  return create((set) => ({
    dbContext,
  }));
}

  onMessage: (topic, buffer) => {
    if (!get().mqttData.get(topic)) return;

    if (start == 0) start = new Date().getTime();

    get().mqttBuffData.set(topic, buffer);

    // if its been 500 ms call handle buffers
    if (new Date().getTime() - start > 100) {
      get().handleBuffers();
    }
  },
  handleBuffers: () => {
    start = 0;
    for (let [key, value] of get().mqttBuffData) {
      get().mqttData.set(key, JSON.parse(value.toString()));
    }

    set((state) => ({
      mqttBuffData: new Map(),
    }));
  },

  onMessage: (topic, buffer) => {
    if (!get().mqttData.get(topic)) return;

    if (start == 0) start = new Date().getTime();

    get().mqttBuffData.set(topic, buffer);

    // if its been 500 ms call handle buffers
    if (new Date().getTime() - start > 100) {
      get().handleBuffers();
    }
  },
  handleBuffers: () => {
    start = 0;
    for (let [key, value] of get().mqttBuffData) {
      get().mqttData.set(key, JSON.parse(value.toString()));
    }

    set((state) => ({
      mqttBuffData: new Map(),
    }));
  },

@acme/db:db:push: error: Environment variable not found: DATABASE_URL.
@acme/db:db:push:   -->  schema.prisma:10
@acme/db:db:push:    |
@acme/db:db:push:  9 |   provider = "mysql"
@acme/db:db:push: 10 |   url = env("DATABASE_URL")

@acme/db:db:push: error: Environment variable not found: DATABASE_URL.
@acme/db:db:push:   -->  schema.prisma:10
@acme/db:db:push:    |
@acme/db:db:push:  9 |   provider = "mysql"
@acme/db:db:push: 10 |   url = env("DATABASE_URL")

const MqttProvider = ({ children, options }: Props) => {
  const [mqtt, setMqtt] = useState<MqttClient>();
  const [connected, setConnected] = useState(false);

  const onConnect = () => {
    setConnected(true);
  };

  const onClose = () => {
    setConnected(false);
  };

  const initMqtt = async () => {
    try {
      const broker = await getBroker();

      const newMqtt = connect(broker, options);
      newMqtt.setMaxListeners(0);
      newMqtt.on("connect", onConnect);
      newMqtt.on("close", onClose);
      newMqtt.on("error", onClose);
      setMqtt(newMqtt);
    } catch (e) {
      console.error(e);
    }
  };

  useEffect(() => {
    initMqtt();
  }, []);

  useEffect(() => {
    console.log(mqtt?.connected);
  }, [mqtt?.connected]);

  return (
    <MqttContext.Provider value={{ mqtt }}>{children}</MqttContext.Provider>
  );
};

const MqttProvider = ({ children, options }: Props) => {
  const [mqtt, setMqtt] = useState<MqttClient>();
  const [connected, setConnected] = useState(false);

  const onConnect = () => {
    setConnected(true);
  };

  const onClose = () => {
    setConnected(false);
  };

  const initMqtt = async () => {
    try {
      const broker = await getBroker();

      const newMqtt = connect(broker, options);
      newMqtt.setMaxListeners(0);
      newMqtt.on("connect", onConnect);
      newMqtt.on("close", onClose);
      newMqtt.on("error", onClose);
      setMqtt(newMqtt);
    } catch (e) {
      console.error(e);
    }
  };

  useEffect(() => {
    initMqtt();
  }, []);

  useEffect(() => {
    console.log(mqtt?.connected);
  }, [mqtt?.connected]);

  return (
    <MqttContext.Provider value={{ mqtt }}>{children}</MqttContext.Provider>
  );
};

> yarn add @shopify/[email protected] [email protected]
yarn add v1.22.19
warning package-lock.json found. Your project contains lock files generated by tools other than Yarn. It is advised not to mix package managers in order to avoid resolution inconsistencies caused by unsynchronized lock files. To clear this warning, remove package-lock.json.
[1/4] Resolving packages...
warning @shopify/flash-list > recyclerlistview > prop-types > fbjs > [email protected]: core-js@<3.23.3 is no longer maintained and not recommended for usage due to the number of issues. Because of the V8 engine whims, feature detection in old core-js versions could cause a slowdown up to 100x even if nothing is polyfilled. Some versions have web compatibility issues. Please, upgrade your dependencies to the actual version of core-js.
[2/4] Fetching packages...
[3/4] Linking dependencies...
[4/4] Building fresh packages...
[6/6] ⠄ @acme/db
[-/6] ⠄ waiting...
[-/6] ⠄ waiting...
[-/6] ⠄ waiting...
info Visit https://yarnpkg.com/en/docs/cli/add for documentation about this command.
error C:\......\node_modules\@acme\db: Command failed.
Exit code: 1
Command: prisma generate
Arguments:

> yarn add @shopify/[email protected] [email protected]
yarn add v1.22.19
warning package-lock.json found. Your project contains lock files generated by tools other than Yarn. It is advised not to mix package managers in order to avoid resolution inconsistencies caused by unsynchronized lock files. To clear this warning, remove package-lock.json.
[1/4] Resolving packages...
warning @shopify/flash-list > recyclerlistview > prop-types > fbjs > [email protected]: core-js@<3.23.3 is no longer maintained and not recommended for usage due to the number of issues. Because of the V8 engine whims, feature detection in old core-js versions could cause a slowdown up to 100x even if nothing is polyfilled. Some versions have web compatibility issues. Please, upgrade your dependencies to the actual version of core-js.
[2/4] Fetching packages...
[3/4] Linking dependencies...
[4/4] Building fresh packages...
[6/6] ⠄ @acme/db
[-/6] ⠄ waiting...
[-/6] ⠄ waiting...
[-/6] ⠄ waiting...
info Visit https://yarnpkg.com/en/docs/cli/add for documentation about this command.
error C:\......\node_modules\@acme\db: Command failed.
Exit code: 1
Command: prisma generate
Arguments:

        String head = "--PotWatcher\r\nContent-Disposition: form-data; name=\"image\"; filename=\"PotWatcherImage.jpg\"\r\nContent-Type: image/jpeg\r\n\r\n";
        String tail = "\r\n--PotWatcher--\r\n";
        // Make a HTTP GET request:
        Serial.println("Performing HTTP POST request...");
        client.print(String("POST ") + resource + " HTTP/1.1\r\n");
        client.print(String("Host: ") + host + "\r\n");
        client.print(String("Authorization: ") + uuid + "\r\n");
        client.println("Connection: Keep-Alive");
        client.println("Content-Length: " + String(length));
        client.println("Content-Type: multipart/form-data;boundary=PotWatcher");
        client.println();
        client.print(head);

        uint8_t *fbBuf = payload;
        for (size_t n = 0; n < length; n = n + PACKET_SIZE)
        {
            if (n + PACKET_SIZE < length)
            {
                client.write(fbBuf, PACKET_SIZE);
                fbBuf += PACKET_SIZE;
            }
            else if (length % PACKET_SIZE > 0)
            {
                size_t remainder = length % PACKET_SIZE;
                client.write(fbBuf, remainder);
            }
        }

        client.print(tail);

        String head = "--PotWatcher\r\nContent-Disposition: form-data; name=\"image\"; filename=\"PotWatcherImage.jpg\"\r\nContent-Type: image/jpeg\r\n\r\n";
        String tail = "\r\n--PotWatcher--\r\n";
        // Make a HTTP GET request:
        Serial.println("Performing HTTP POST request...");
        client.print(String("POST ") + resource + " HTTP/1.1\r\n");
        client.print(String("Host: ") + host + "\r\n");
        client.print(String("Authorization: ") + uuid + "\r\n");
        client.println("Connection: Keep-Alive");
        client.println("Content-Length: " + String(length));
        client.println("Content-Type: multipart/form-data;boundary=PotWatcher");
        client.println();
        client.print(head);

        uint8_t *fbBuf = payload;
        for (size_t n = 0; n < length; n = n + PACKET_SIZE)
        {
            if (n + PACKET_SIZE < length)
            {
                client.write(fbBuf, PACKET_SIZE);
                fbBuf += PACKET_SIZE;
            }
            else if (length % PACKET_SIZE > 0)
            {
                size_t remainder = length % PACKET_SIZE;
                client.write(fbBuf, remainder);
            }
        }

        client.print(tail);