Coffee11 Posts - Answer Overflow

Coffee11

Explore posts from servers

CDCloudflare Developers KKysely Ttamagui CCConvex Community DTDrizzle Team

•Created by Coffee11 on 8/6/2024 in #help

Mysql Geo index

export const property = mysqlTable(
  "properties",
  {
    id: int("id").primaryKey().autoincrement(),
    longitude: float("longitude").notNull(),
    latitude: float("latitude").notNull(),
    primaryImageUrl: varchar("primary_image_url", { length: 255 }),
    jsonData: json("json").$type<{ foo: string }>(),
    createdAt: timestamp("created_at", { mode: "string" }).defaultNow(),
  },
  (table) => ({
    latIndex: index("lat").on(table.latitude),
    longIndex: index("long").on(table.longitude),
  })
);

export const property = mysqlTable(
  "properties",
  {
    id: int("id").primaryKey().autoincrement(),
    longitude: float("longitude").notNull(),
    latitude: float("latitude").notNull(),
    primaryImageUrl: varchar("primary_image_url", { length: 255 }),
    jsonData: json("json").$type<{ foo: string }>(),
    createdAt: timestamp("created_at", { mode: "string" }).defaultNow(),
  },
  (table) => ({
    latIndex: index("lat").on(table.latitude),
    longIndex: index("long").on(table.longitude),
  })
);

this is what I generated

CREATE INDEX `lat` ON `properties` (`latitude`);--> statement-breakpoint
CREATE INDEX `long` ON `properties` (`longitude`);

CREATE INDEX `lat` ON `properties` (`latitude`);--> statement-breakpoint
CREATE INDEX `long` ON `properties` (`longitude`);

any idea how can I make drizzle generate this kind of index?

 alter table properties add index lat(latitude);
 alter table properties add index long(longitude);

 alter table properties add index lat(latitude);
 alter table properties add index long(longitude);

thank you

1 replies

CDCloudflare Developers

•Created by Coffee11 on 7/16/2024 in #pages-help

@cloudflare/puppeteer access?

I'm in a paid subscription, but I can't use @Cloudflare/puppeteer TypeError: Cannot read properties of undefined (reading 'fetch') I'm trying to take screenshot of a specific website.

5 replies

CCConvex Community

•Created by Coffee11 on 6/22/2024 in #support-community

Image compression integration

Has anyone implemented a middleware to optimize images before uploading to Convex, for example, using the TinyPNG API?

11 replies

CCConvex Community

•Created by Coffee11 on 6/21/2024 in #support-community

Dynamic query

Is this how we create dynamic query in convex?

  let baseQuery = ctx.db
    .query("property_listings")
    .filter((q) => q.eq(q.field("listingType"), args.listingTypeId))

  if (args?.minPrice !== undefined && args.minPrice >= 0) {
    baseQuery = baseQuery.filter((q) =>
      q.gte(q.field("price"), Number(args.minPrice))
    );
  }

  if (args?.maxPrice !== undefined && args.maxPrice >= 0) {
    baseQuery = baseQuery.filter((q) =>
      q.lte(q.field("price"), Number(args.maxPrice))
    );
  }

  const results = await baseQuery.order("desc").paginate(args.paginationOpts);

  const updatedPage = await Promise.all(
    results.page.map(async (propertyListing) => ({
      ...propertyListing,
    }))
  );

  let baseQuery = ctx.db
    .query("property_listings")
    .filter((q) => q.eq(q.field("listingType"), args.listingTypeId))

  if (args?.minPrice !== undefined && args.minPrice >= 0) {
    baseQuery = baseQuery.filter((q) =>
      q.gte(q.field("price"), Number(args.minPrice))
    );
  }

  if (args?.maxPrice !== undefined && args.maxPrice >= 0) {
    baseQuery = baseQuery.filter((q) =>
      q.lte(q.field("price"), Number(args.maxPrice))
    );
  }

  const results = await baseQuery.order("desc").paginate(args.paginationOpts);

  const updatedPage = await Promise.all(
    results.page.map(async (propertyListing) => ({
      ...propertyListing,
    }))
  );

it's working as expected but getting a typescript warning.

  const { isLoading, results, loadMore } = usePaginatedQuery(
    api.propertyListings.getPropertyListings, // <- on this part
    {
      listingTypeId: filters.listingTypeId as Id<"listing_types">,
      properTypeId: filters.propertyTypeId as Id<"property_types">,
      minPrice: filters.minPrice,
      maxPrice: filters.maxPrice,
    },
    {
      initialNumItems: 10,
    }
  );

  const { isLoading, results, loadMore } = usePaginatedQuery(
    api.propertyListings.getPropertyListings, // <- on this part
    {
      listingTypeId: filters.listingTypeId as Id<"listing_types">,
      properTypeId: filters.propertyTypeId as Id<"property_types">,
      minPrice: filters.minPrice,
      maxPrice: filters.maxPrice,
    },
    {
      initialNumItems: 10,
    }
  );

Argument of type 'FunctionReference<"query", "public", { minPrice?: number | undefined; maxPrice?: number | undefined; listingTypeId: Id<"listing_types">; properTypeId: Id<"property_types">; paginationOpts: { ...; }; }, { ...; }>' is not assignable to parameter of type 'PaginatedQueryReference'.
  Types of property '_returnType' are incompatible.
    Type '{ page: { listingType: string | undefined; propertyType: string | undefined; favorite: boolean; _id: Id<"property_listings">; _creationTime: number; pricePerSqm?: number | undefined; ... 22 more ...; description: string; }[]; ... 10 more ...; [Symbol.asyncIterator](): AsyncIterator<...>; }' is missing the following properties from type 'PaginationResult<any>': isDone, continueCursorts(2345)

Argument of type 'FunctionReference<"query", "public", { minPrice?: number | undefined; maxPrice?: number | undefined; listingTypeId: Id<"listing_types">; properTypeId: Id<"property_types">; paginationOpts: { ...; }; }, { ...; }>' is not assignable to parameter of type 'PaginatedQueryReference'.
  Types of property '_returnType' are incompatible.
    Type '{ page: { listingType: string | undefined; propertyType: string | undefined; favorite: boolean; _id: Id<"property_listings">; _creationTime: number; pricePerSqm?: number | undefined; ... 22 more ...; description: string; }[]; ... 10 more ...; [Symbol.asyncIterator](): AsyncIterator<...>; }' is missing the following properties from type 'PaginationResult<any>': isDone, continueCursorts(2345)

8 replies

CCConvex Community

•Created by Coffee11 on 6/21/2024 in #support-community

Need guidance on return types of query

Hi, I need help understanding why the return type of the given query contains null in the object return of get despite having a null check?

  const userFavoriteCollections = await ctx.db
    .query("favorite_listings")
    .withIndex("by_user_id")
    .filter((q) => q.eq(q.field("userId"), user._id))
    .collect();

  const userFavorites = await Promise.all(
    userFavoriteCollections.map(async (userFavorite) => {
      const propertyListing = await ctx.db.get(
        userFavorite.propertyListingId
      );

      if (!propertyListing) {
        return null;
      }

      return { ...propertyListing, favorite: true };
    })
  );

  return userFavorites.filter((userFavorite) => userFavorite !== null);

  const userFavoriteCollections = await ctx.db
    .query("favorite_listings")
    .withIndex("by_user_id")
    .filter((q) => q.eq(q.field("userId"), user._id))
    .collect();

  const userFavorites = await Promise.all(
    userFavoriteCollections.map(async (userFavorite) => {
      const propertyListing = await ctx.db.get(
        userFavorite.propertyListingId
      );

      if (!propertyListing) {
        return null;
      }

      return { ...propertyListing, favorite: true };
    })
  );

  return userFavorites.filter((userFavorite) => userFavorite !== null);

return type

const getFavoritePropertyListings: RegisteredQuery<"public", EmptyObject, Promise<({
    favorite: boolean;
    _id: Id<"property_listings">;
    _creationTime: number;
    pricePerSqm?: number | undefined;
    buildingName?: string | undefined;
    ... 23 more ...;
    description: string;
} | null)[]>>

const getFavoritePropertyListings: RegisteredQuery<"public", EmptyObject, Promise<({
    favorite: boolean;
    _id: Id<"property_listings">;
    _creationTime: number;
    pricePerSqm?: number | undefined;
    buildingName?: string | undefined;
    ... 23 more ...;
    description: string;
} | null)[]>>

but putting "!" solves the issue?

  const userFavoriteCollections = await ctx.db
    .query("favorite_listings")
    .withIndex("by_user_id")
    .filter((q) => q.eq(q.field("userId"), user._id))
    .collect();

  const userFavorites = await Promise.all(
    userFavoriteCollections.map(async (userFavorite) => {
      const propertyListing = await ctx.db.get(
        userFavorite.propertyListingId
      );

      return { **...propertyListing!**, favorite: true };
    })
  );

  return userFavorites.filter((userFavorite) => userFavorite !== null);

  const userFavoriteCollections = await ctx.db
    .query("favorite_listings")
    .withIndex("by_user_id")
    .filter((q) => q.eq(q.field("userId"), user._id))
    .collect();

  const userFavorites = await Promise.all(
    userFavoriteCollections.map(async (userFavorite) => {
      const propertyListing = await ctx.db.get(
        userFavorite.propertyListingId
      );

      return { **...propertyListing!**, favorite: true };
    })
  );

  return userFavorites.filter((userFavorite) => userFavorite !== null);

return type

const getFavoritePropertyListings: RegisteredQuery<"public", EmptyObject, Promise<{
    favorite: boolean;
    _id: Id<"property_listings">;
    _creationTime: number;
    pricePerSqm?: number | undefined;
    buildingName?: string | undefined;
    ... 23 more ...;
    description: string;
}[]>>

const getFavoritePropertyListings: RegisteredQuery<"public", EmptyObject, Promise<{
    favorite: boolean;
    _id: Id<"property_listings">;
    _creationTime: number;
    pricePerSqm?: number | undefined;
    buildingName?: string | undefined;
    ... 23 more ...;
    description: string;
}[]>>

7 replies

CCConvex Community

•Created by Coffee11 on 6/20/2024 in #support-community

"in" filter keyword

How to achieve this in convex?

SELECT 
    employee_id,
    first_name,
    last_name,
    department,
    salary,
    hire_date
FROM 
    employees
WHERE 
    employee_id IN (101, 102, 105);

SELECT 
    employee_id,
    first_name,
    last_name,
    department,
    salary,
    hire_date
FROM 
    employees
WHERE 
    employee_id IN (101, 102, 105);

10 replies

CCConvex Community

•Created by Coffee11 on 6/19/2024 in #support-community

Drop table property with index

Hi how to delete a property that has an index and data? Document with ID "k970fhqa6pzjy3cxx04esrty4s6v7bsf" in table "property_features" does not match the schema: Object contains extra field tag that is not in the validator. Object: {category: "amenities", name: "Big roads", slug: "motor-way", tag: "amenities", tags: ["condominium", "house-and-lot", "warehouse", "land"]} Validator: v.object({category: v.optional(v.string()), name: v.string(), slug: v.string(), tags: v.optional(v.array(v.string()))})

3 replies

CCConvex Community

•Created by Coffee11 on 6/12/2024 in #support-community

Production with react-native?

Any tutorial similar to nextjs deployment?

11 replies

CCConvex Community

•Created by Coffee11 on 6/11/2024 in #support-community

Query caching in react-native

Can the useQuery be like tanstak/react-query?

2 replies

CCConvex Community

•Created by Coffee11 on 6/9/2024 in #support-community

status: Exhausted when using paginated query?

Why?

3 replies

CCConvex Community

•Created by Coffee11 on 6/9/2024 in #support-community

Promise {} is not a supported Convex type in paginated query with join

Working

export const getPropertyListings = query({
  args: {
    listingTypeId: v.id("listing_types"),
    properTypeId: v.id("property_types"),
    paginationOpts: paginationOptsValidator,
  },
  handler: async (ctx, args) => {
    const identity = await ctx.auth.getUserIdentity();

    if (identity === null) {
      throw new Error("Not authenticated");
    }

    const results = await ctx.db
      .query("property_listings")
      .filter((q) => q.eq(q.field("listingType"), args.listingTypeId))
      .filter((q) => q.eq(q.field("propertyType"), args.properTypeId))
      .order("desc")
      .paginate(args.paginationOpts);

    return {
      ...results,
      page: results.page.map((propertyListing) => ({
        ...propertyListing,
      })),
    };
  },
});

export const getPropertyListings = query({
  args: {
    listingTypeId: v.id("listing_types"),
    properTypeId: v.id("property_types"),
    paginationOpts: paginationOptsValidator,
  },
  handler: async (ctx, args) => {
    const identity = await ctx.auth.getUserIdentity();

    if (identity === null) {
      throw new Error("Not authenticated");
    }

    const results = await ctx.db
      .query("property_listings")
      .filter((q) => q.eq(q.field("listingType"), args.listingTypeId))
      .filter((q) => q.eq(q.field("propertyType"), args.properTypeId))
      .order("desc")
      .paginate(args.paginationOpts);

    return {
      ...results,
      page: results.page.map((propertyListing) => ({
        ...propertyListing,
      })),
    };
  },
});

Not working

export const getPropertyListings = query({
  args: {
    listingTypeId: v.id("listing_types"),
    properTypeId: v.id("property_types"),
    paginationOpts: paginationOptsValidator,
  },
  handler: async (ctx, args) => {
    const identity = await ctx.auth.getUserIdentity();

    if (identity === null) {
      throw new Error("Not authenticated");
    }

    const results = await ctx.db
      .query("property_listings")
      .filter((q) => q.eq(q.field("listingType"), args.listingTypeId))
      .filter((q) => q.eq(q.field("propertyType"), args.properTypeId))
      .order("desc")
      .paginate(args.paginationOpts);

    return {
      ...results,
      page: results.page.map(async (propertyListing) => ({
        ...propertyListing,
        listingType: await ctx.db.get(propertyListing.listingType),
        propertyType: await ctx.db.get(propertyListing.propertyType),
      })),
    };
  },
});

export const getPropertyListings = query({
  args: {
    listingTypeId: v.id("listing_types"),
    properTypeId: v.id("property_types"),
    paginationOpts: paginationOptsValidator,
  },
  handler: async (ctx, args) => {
    const identity = await ctx.auth.getUserIdentity();

    if (identity === null) {
      throw new Error("Not authenticated");
    }

    const results = await ctx.db
      .query("property_listings")
      .filter((q) => q.eq(q.field("listingType"), args.listingTypeId))
      .filter((q) => q.eq(q.field("propertyType"), args.properTypeId))
      .order("desc")
      .paginate(args.paginationOpts);

    return {
      ...results,
      page: results.page.map(async (propertyListing) => ({
        ...propertyListing,
        listingType: await ctx.db.get(propertyListing.listingType),
        propertyType: await ctx.db.get(propertyListing.propertyType),
      })),
    };
  },
});

4 replies

CCConvex Community

•Created by Coffee11 on 6/9/2024 in #support-community

Dynamic filters?

Hi any tips how to make a dynamic query?

3 replies

CCConvex Community

•Created by Coffee11 on 6/2/2024 in #support-community

Mobile and web app project

What is the best strategy if I want to use 1 convex project for my react-native and nextjs project?

18 replies

CCConvex Community

•Created by Coffee11 on 6/1/2024 in #support-community

Null user in convex function when using fetchQuery

Does ctx.auth only works with client components? I'm using clerkjs Clerkjs middleware

import { clerkMiddleware, createRouteMatcher } from '@clerk/nextjs/server';

const isPublicRoute = createRouteMatcher(['/sign-in(.*)', '/sign-up(.*)']);

export default clerkMiddleware(
  (auth, request) => {
    if (!isPublicRoute(request)) {
      auth().protect();
    }
  },
  {
    debug: false,
  }
);

export const config = {
  matcher: ['/((?!.*\\..*|_next).*)', '/', '/(api|trpc)(.*)'],
};

import { clerkMiddleware, createRouteMatcher } from '@clerk/nextjs/server';

const isPublicRoute = createRouteMatcher(['/sign-in(.*)', '/sign-up(.*)']);

export default clerkMiddleware(
  (auth, request) => {
    if (!isPublicRoute(request)) {
      auth().protect();
    }
  },
  {
    debug: false,
  }
);

export const config = {
  matcher: ['/((?!.*\\..*|_next).*)', '/', '/(api|trpc)(.*)'],
};

SSR

  const convexUser = await fetchQuery(api.users.getUser, {
    clerkId: clerkUserId!,
  });

  const convexUser = await fetchQuery(api.users.getUser, {
    clerkId: clerkUserId!,
  });

Convex function

export const getUser = query({
  args: {
    clerkId: v.string(),
  },
  handler: async (ctx, args) => {
    const identity = await ctx.auth.getUserIdentity();

    // This is null
    console.log(identity);

    return await ctx.db
      .query('users')
      .filter((q) => q.eq(q.field('clerkId'), args.clerkId))
      .first();
  },
});

export const getUser = query({
  args: {
    clerkId: v.string(),
  },
  handler: async (ctx, args) => {
    const identity = await ctx.auth.getUserIdentity();

    // This is null
    console.log(identity);

    return await ctx.db
      .query('users')
      .filter((q) => q.eq(q.field('clerkId'), args.clerkId))
      .first();
  },
});

3 replies

KKysely

•Created by Coffee11 on 9/28/2023 in #help

ts_rank in select

still not possible?

 .select([
          'finance_reimbursement_requests.reimbursement_request_id',
          'finance_reimbursement_requests.reference_no',
          'finance_reimbursement_request_types.request_type',
          'finance_reimbursement_expense_types.expense_type',
          'main_request_status.request_status as requestor_request_status',
          'hrbp_status.request_status as hrbp_request_status',
          'finance_status.request_status as finance_request_status',
          'finance_reimbursement_requests.amount',
          'finance_reimbursement_requests.attachment',
          'finance_reimbursement_requests.attachment_mask_name',
          'finance_reimbursement_requests.remarks',
          'users.full_name',
          'users.email',
          'users.employee_id',
          'users.client_name',
          'users.hrbp_approver_email',
          'users.payroll_account',
          'finance_reimbursement_requests.created_at',
          sql<number>`ts_rank(to_tsvector('english', users.email, websearch_to_tsquery('R2023-185')) as rank`,
        ])

 .select([
          'finance_reimbursement_requests.reimbursement_request_id',
          'finance_reimbursement_requests.reference_no',
          'finance_reimbursement_request_types.request_type',
          'finance_reimbursement_expense_types.expense_type',
          'main_request_status.request_status as requestor_request_status',
          'hrbp_status.request_status as hrbp_request_status',
          'finance_status.request_status as finance_request_status',
          'finance_reimbursement_requests.amount',
          'finance_reimbursement_requests.attachment',
          'finance_reimbursement_requests.attachment_mask_name',
          'finance_reimbursement_requests.remarks',
          'users.full_name',
          'users.email',
          'users.employee_id',
          'users.client_name',
          'users.hrbp_approver_email',
          'users.payroll_account',
          'finance_reimbursement_requests.created_at',
          sql<number>`ts_rank(to_tsvector('english', users.email, websearch_to_tsquery('R2023-185')) as rank`,
        ])

8 replies

KKysely

•Created by Coffee11 on 9/28/2023 in #help

How to convert this raw query to kysely?

UPDATE finance_reimbursement_approval_matrix
SET has_approved = true
WHERE approval_matrix_id = 'c78f11f0-7014-47cf-82b7-838a43b34b20'
AND reimbursement_request_id IN (
    SELECT reimbursement_request_id
    FROM finance_reimbursement_requests
    WHERE reimbursement_request_id = 'e1dafc7e-a54f-4888-95f1-8cb57f22dfba'
    AND request_status_id = '33bfa3b3-1dfa-471f-a7bb-80a9a8842fc5'
);

UPDATE finance_reimbursement_approval_matrix
SET has_approved = true
WHERE approval_matrix_id = 'c78f11f0-7014-47cf-82b7-838a43b34b20'
AND reimbursement_request_id IN (
    SELECT reimbursement_request_id
    FROM finance_reimbursement_requests
    WHERE reimbursement_request_id = 'e1dafc7e-a54f-4888-95f1-8cb57f22dfba'
    AND request_status_id = '33bfa3b3-1dfa-471f-a7bb-80a9a8842fc5'
);

as of now, this is what I have done.

await trx
      .updateTable('finance_reimbursement_approval_matrix')
      .set({
        has_approved: true,
        performed_by_user_id: user.original_user_id,
        updated_at: new Date(),
      })
      .where((eb) =>
        eb
          .selectFrom('finance_reimbursement_requests')
          .innerJoin(
            'finance_reimbursement_approval_matrix',
            'finance_reimbursement_approval_matrix.reimbursement_request_id',
            'finance_reimbursement_requests.reimbursement_request_id',
          )
          .where(
            'finance_reimbursement_approval_matrix.approval_matrix_id',
            '=',
            approval_matrix_id,
          )
           .where(
                'finance_reimbursement_requests.request_status_id',
                '=',
              PENDING_REQUEST)

await trx
      .updateTable('finance_reimbursement_approval_matrix')
      .set({
        has_approved: true,
        performed_by_user_id: user.original_user_id,
        updated_at: new Date(),
      })
      .where((eb) =>
        eb
          .selectFrom('finance_reimbursement_requests')
          .innerJoin(
            'finance_reimbursement_approval_matrix',
            'finance_reimbursement_approval_matrix.reimbursement_request_id',
            'finance_reimbursement_requests.reimbursement_request_id',
          )
          .where(
            'finance_reimbursement_approval_matrix.approval_matrix_id',
            '=',
            approval_matrix_id,
          )
           .where(
                'finance_reimbursement_requests.request_status_id',
                '=',
              PENDING_REQUEST)

7 replies

Gaming

Programming