Legend-State plugin for local-first

TS2322: Type
ReactMutation<FunctionReference<"mutation", "public", {   text: string; }, null, string | undefined>>
is not assignable to type MutationFunction<any[], void>
Types of parameters args and variables are incompatible.
Type void is not assignable to type { text: string; }

TS2322: Type
ReactMutation<FunctionReference<"mutation", "public", {   text: string; }, null, string | undefined>>
is not assignable to type MutationFunction<any[], void>
Types of parameters args and variables are incompatible.
Type void is not assignable to type { text: string; }

const convex = new ConvexClient(import.meta.env.VITE_CONVEX_URL as string);

const obs$ = observable(() =>
  syncedConvex({
    convex,
    query: api.messages.list,
  }),
);

observe(() => {
  console.log("obs value", obs$.get());
});

const convex = new ConvexClient(import.meta.env.VITE_CONVEX_URL as string);

const obs$ = observable(() =>
  syncedConvex({
    convex,
    query: api.messages.list,
  }),
);

observe(() => {
  console.log("obs value", obs$.get());
});

// Observable in JS
const convex = new ConvexClient(import.meta.env.VITE_CONVEX_URL as string);
const obs$ = observable(() =>
  syncedConvex({
    convex,
    query: api.messages.list,
  }),
);

function Component() {
    // Observable in React
    const convex = useConvex();
    const obs$ = useObservable(() =>
      syncedConvex({
        convex,
        query: api.messages.list,
      }),
    );
}

// Observable in JS
const convex = new ConvexClient(import.meta.env.VITE_CONVEX_URL as string);
const obs$ = observable(() =>
  syncedConvex({
    convex,
    query: api.messages.list,
  }),
);

function Component() {
    // Observable in React
    const convex = useConvex();
    const obs$ = useObservable(() =>
      syncedConvex({
        convex,
        query: api.messages.list,
      }),
    );
}

const convex = useConvex();
const watch = convex.watchQuery(api.messages.list, {});
watch.onUpdate(() => {
    const value = watch.localQueryResult();
    // ...
});

const convex = useConvex();
const watch = convex.watchQuery(api.messages.list, {});
watch.onUpdate(() => {
    const value = watch.localQueryResult();
    // ...
});

const id = generateId();
messages$[id].set({ _id: id, body: "hello", author: "world" });

const id = generateId();
messages$[id].set({ _id: id, body: "hello", author: "world" });

  const sendMessage = useMutation(api.messages.send).withOptimisticUpdate(
    (localStore, args) => {
      const { channel, body } = args;
      const existingMessages = localStore.getQuery(api.messages.list, {
        channel,
      });
      // If we've loaded the api.messages.list query, push an optimistic message
      // onto the list.
      if (existingMessages !== undefined) {
        const now = Date.now();
        const newMessage = {
          _id: crypto.randomUUID() as Id<"messages">,
          _creationTime: now,
          channel,
          body,
        };
        localStore.setQuery(api.messages.list, { channel }, [
          ...existingMessages,
          newMessage,
        ]);
      }
    },
  );

  const sendMessage = useMutation(api.messages.send).withOptimisticUpdate(
    (localStore, args) => {
      const { channel, body } = args;
      const existingMessages = localStore.getQuery(api.messages.list, {
        channel,
      });
      // If we've loaded the api.messages.list query, push an optimistic message
      // onto the list.
      if (existingMessages !== undefined) {
        const now = Date.now();
        const newMessage = {
          _id: crypto.randomUUID() as Id<"messages">,
          _creationTime: now,
          channel,
          body,
        };
        localStore.setQuery(api.messages.list, { channel }, [
          ...existingMessages,
          newMessage,
        ]);
      }
    },
  );

const record = await ctx.db.query("users")
  .withIndex("myId")
  .filter((q) => q.eq(q.field("name"), myId))
  .unique();
await ctx.db.replace(record._id, { foo: 1, ...record });

const record = await ctx.db.query("users")
  .withIndex("myId")
  .filter((q) => q.eq(q.field("name"), myId))
  .unique();
await ctx.db.replace(record._id, { foo: 1, ...record });

    mutation: {
      mutationFn: async (variables) => {
//    ^^^^^^^^^^ TS2322: Type (variables: void) => Promise<Response> // is not assignable to type MutationFunction<any[], void>
// Type Promise<Response> is not assignable to type Promise<any[]>
// Type Response is missing the following properties from type any[]: // length, pop, push, concat, and 29 more.
        return fetch("https://reqres.in/api/users/1", {
          body: JSON.stringify(variables),
          method: "POST",
        });
      },
    },

    mutation: {
      mutationFn: async (variables) => {
//    ^^^^^^^^^^ TS2322: Type (variables: void) => Promise<Response> // is not assignable to type MutationFunction<any[], void>
// Type Promise<Response> is not assignable to type Promise<any[]>
// Type Response is missing the following properties from type any[]: // length, pop, push, concat, and 29 more.
        return fetch("https://reqres.in/api/users/1", {
          body: JSON.stringify(variables),
          method: "POST",
        });
      },
    },

    const state$ = useObservableSyncedQuery({
        query: {
            queryKey: ['user'],
            queryFn: async () => {
                return fetch('https://reqres.in/api/users/1').then((v) => v.json())
            },
        },
        mutation: {
            mutationFn: async (variables) => {
                return fetch(
                    'https://reqres.in/api/users/1',
                    { body: JSON.stringify(variables), method: 'POST' }
                )
            },
        },
    })

    const state$ = useObservableSyncedQuery({
        query: {
            queryKey: ['user'],
            queryFn: async () => {
                return fetch('https://reqres.in/api/users/1').then((v) => v.json())
            },
        },
        mutation: {
            mutationFn: async (variables) => {
                return fetch(
                    'https://reqres.in/api/users/1',
                    { body: JSON.stringify(variables), method: 'POST' }
                )
            },
        },
    })