// tables
campaigns: {
  id,
  name, 
}
campaign_members: {
  id,
  user_id, 
  campaign_id,
  status: active, paused, completed, exited...etc
}
// aggregate
export const campaign_members_aggregate = new TableAggregate<{
  Key: number;
  Namespace: Id<"campaigns"> | undefined;
  DataModel: DataModel;
  TableName: "campaign_members";
}>(components.campaign_members_agg, {
  namespace: doc => doc.campaign_id,
  sortKey: doc => doc._creationTime,
});

// tables
campaigns: {
  id,
  name, 
}
campaign_members: {
  id,
  user_id, 
  campaign_id,
  status: active, paused, completed, exited...etc
}
// aggregate
export const campaign_members_aggregate = new TableAggregate<{
  Key: number;
  Namespace: Id<"campaigns"> | undefined;
  DataModel: DataModel;
  TableName: "campaign_members";
}>(components.campaign_members_agg, {
  namespace: doc => doc.campaign_id,
  sortKey: doc => doc._creationTime,
});

export const members_of_campaign = query({
 args: {
  campaign_id: v.id("campaigns"),
  offset: v.number(),  
  status: // optional status passed from client UI
 },
 handler: async (ctx, { campaign_id, offset, status }) => {
   // what's the approach to further filter by status
   const {} = await aggregate.at(ctx, offset, { namespace: campaign_id } )
 } 
})

export const members_of_campaign = query({
 args: {
  campaign_id: v.id("campaigns"),
  offset: v.number(),  
  status: // optional status passed from client UI
 },
 handler: async (ctx, { campaign_id, offset, status }) => {
   // what's the approach to further filter by status
   const {} = await aggregate.at(ctx, offset, { namespace: campaign_id } )
 } 
})

app.use(aggregate, { name: "partners_payments" });

app.use(aggregate, { name: "partners_payments" });

export const partnerPaymentsAggregate = new TableAggregate<{
  Key: number;
  Namespace: Id<"partners"> | undefined;
  DataModel: DataModel;
  TableName: "payments";
}>(components.partners_payments, {
  namespace: doc => doc.partner_id,
  sortKey: doc => doc._creationTime,
});

export const partnerPaymentsAggregate = new TableAggregate<{
  Key: number;
  Namespace: Id<"partners"> | undefined;
  DataModel: DataModel;
  TableName: "payments";
}>(components.partners_payments, {
  namespace: doc => doc.partner_id,
  sortKey: doc => doc._creationTime,
});

const count = await partnerPaymentsAggregate.count(ctx, {
   namespace: partner_id,
});

const count = await partnerPaymentsAggregate.count(ctx, {
   namespace: partner_id,
});

Property 'bounds' is missing in type '{ namespace: Id<"partners">; }' but required in type '{ bounds: Bounds<number, Id<"payments">>; }'.

Property 'bounds' is missing in type '{ namespace: Id<"partners">; }' but required in type '{ bounds: Bounds<number, Id<"payments">>; }'.

 _id,
 campaign_name

 _id,
 campaign_name

_id,
campaign_id,
user_id

_id,
campaign_id,
user_id

args: {
 user_id: v.id("members),
 paginationOpts: paginationOptsValidator,
},
handler: async (ctx, { user_id, paginationOpts }) => {
  // first I find all records from table "members" for user "user_id"
  const members = await ctx.db.query("members").withIndex("by_user_id", ...);

  // then paginated query of campaigns using the 'filter' method from `convex-helpers`
  const result = await filter(ctx.db.query("campaigns"), (cp) => members.some((mem) => mem.campaign_id === cp._id)).paginate(paginationOpts)
...
}

args: {
 user_id: v.id("members),
 paginationOpts: paginationOptsValidator,
},
handler: async (ctx, { user_id, paginationOpts }) => {
  // first I find all records from table "members" for user "user_id"
  const members = await ctx.db.query("members").withIndex("by_user_id", ...);

  // then paginated query of campaigns using the 'filter' method from `convex-helpers`
  const result = await filter(ctx.db.query("campaigns"), (cp) => members.some((mem) => mem.campaign_id === cp._id)).paginate(paginationOpts)
...
}

defineSchema({
   groups: defineTable({
      group_name: v.string(),
   }),
   members: defineTable({
      group_id: v.id("groups),
      user_id: v.id("users") 
   })
})

defineSchema({
   groups: defineTable({
      group_name: v.string(),
   }),
   members: defineTable({
      group_id: v.id("groups),
      user_id: v.id("users") 
   })
})

SELECT G.* FROM groups G
JOIN members M ON G._id = M.group_id
WHERE M.user_id = 'A'
LIMIT 10 OFFSET __page_offset__

SELECT G.* FROM groups G
JOIN members M ON G._id = M.group_id
WHERE M.user_id = 'A'
LIMIT 10 OFFSET __page_offset__

export default mutation({
  handler: async (ctx) => {
    const identity = await ctx.auth.getUserIdentity();
    ...
  }
})

export default mutation({
  handler: async (ctx) => {
    const identity = await ctx.auth.getUserIdentity();
    ...
  }
})

export const SmsOTP = Phone({
  id: "sms-otp",
  maxAge: 1000 * 60 * 5, // 5 minutes
  async generateVerificationToken() {
    return generateRandomString(6, alphabet("0-9"));
  },
  async sendVerificationRequest({ identifier: phone, token }, ctx) {
    if (phone === undefined) {
      throw new ConvexError("Invalid phone number");
    }
    // send sms otp with a third-party service
  },
});

export const SmsOTP = Phone({
  id: "sms-otp",
  maxAge: 1000 * 60 * 5, // 5 minutes
  async generateVerificationToken() {
    return generateRandomString(6, alphabet("0-9"));
  },
  async sendVerificationRequest({ identifier: phone, token }, ctx) {
    if (phone === undefined) {
      throw new ConvexError("Invalid phone number");
    }
    // send sms otp with a third-party service
  },
});

export function SmsOTPVerify() {
  return ConvexCredentials<DataModel>({
    id: "sms-otp",
    authorize: async (params) => {
      const _params = params as unknown as { code: string; phone: string };
      if (_params.phone === undefined) {
        throw new Error("`phone` param is missing");
      }
      ...
      const user = "fetch user based on phone"
      return { userId: user._id };
    },
  });
}

export function SmsOTPVerify() {
  return ConvexCredentials<DataModel>({
    id: "sms-otp",
    authorize: async (params) => {
      const _params = params as unknown as { code: string; phone: string };
      if (_params.phone === undefined) {
        throw new Error("`phone` param is missing");
      }
      ...
      const user = "fetch user based on phone"
      return { userId: user._id };
    },
  });
}

{
  tokenIdentifier: 'https://xxx.convex.site|j97f82wcsk9m3zp81s5taen2jn6znhtp|n5753jkhrdgymmy0e3rsp6891x70a96b',
  issuer: 'https://xxx.convex.site',
  subject: 'j97f82wcsk9m3zp81s5taen2jn6znhtp|n5753jkhrdgymmy0e3rsp6891x70a96b'
}

{
  tokenIdentifier: 'https://xxx.convex.site|j97f82wcsk9m3zp81s5taen2jn6znhtp|n5753jkhrdgymmy0e3rsp6891x70a96b',
  issuer: 'https://xxx.convex.site',
  subject: 'j97f82wcsk9m3zp81s5taen2jn6znhtp|n5753jkhrdgymmy0e3rsp6891x70a96b'
}

export default query({
  args: {
    paginatedOpts: paginationOptsValidator,
  },
  handler: async (ctx) => {
    ...
  }
});

export default query({
  args: {
    paginatedOpts: paginationOptsValidator,
  },
  handler: async (ctx) => {
    ...
  }
});

import Resend from "@auth/core/providers/resend";
import { convexAuth } from "@convex-dev/auth/server";

export const { auth, signIn, signOut, store } = convexAuth({
  providers: [
    Resend({
      apiKey: process.env.RESEND_API_KEY,
      from: "noreply@myapp.com",
    }),
  ],
});

"convex": "^1.13.2",

import Resend from "@auth/core/providers/resend";
import { convexAuth } from "@convex-dev/auth/server";

export const { auth, signIn, signOut, store } = convexAuth({
  providers: [
    Resend({
      apiKey: process.env.RESEND_API_KEY,
      from: "noreply@myapp.com",
    }),
  ],
});

"convex": "^1.13.2",

export default {
  providers: [
    {
      domain: process.env.CONVEX_AUTH_PROVIDER_DOMAIN,// <-- for clerk
      applicationID: "convex",
    },
    {
      domain: process.env.CONVEX_SITE_URL, // <-- for convex auth
      applicationID: "convex",
    },
  ],
};

export default {
  providers: [
    {
      domain: process.env.CONVEX_AUTH_PROVIDER_DOMAIN,// <-- for clerk
      applicationID: "convex",
    },
    {
      domain: process.env.CONVEX_SITE_URL, // <-- for convex auth
      applicationID: "convex",
    },
  ],
};

error Error: [CONVEX A(auth:signIn)] [Request ID: 09412de9cb7c47e3] Server Error
Uncaught Error: Uncaught Error: Index users.email not found.
    at uniqueUserWithVerifiedEmail (../../../../node_modules/@convex-dev/auth/dist/server/implementation.js:881:43)

error Error: [CONVEX A(auth:signIn)] [Request ID: 09412de9cb7c47e3] Server Error
Uncaught Error: Uncaught Error: Index users.email not found.
    at uniqueUserWithVerifiedEmail (../../../../node_modules/@convex-dev/auth/dist/server/implementation.js:881:43)

export default {
  providers: [
    {
      // old setup used before advent of "convex auth"
      domain: process.env.CONVEX_AUTH_PROVIDER_DOMAIN,
      applicationID: "convex",
    },
    {
      // new setup from auth tutorial
      domain: process.env.CONVEX_SITE_URL, // <-- new config
      applicationID: "convex",
    },
  ],
};

export default {
  providers: [
    {
      // old setup used before advent of "convex auth"
      domain: process.env.CONVEX_AUTH_PROVIDER_DOMAIN,
      applicationID: "convex",
    },
    {
      // new setup from auth tutorial
      domain: process.env.CONVEX_SITE_URL, // <-- new config
      applicationID: "convex",
    },
  ],
};

jobs:
  convex_deploy:
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v4

      - name: Setup
        uses: ./tooling/github/setup

      - name: Convex Deploy
        working-directory: apps/api
        run: pnpm run build
        env:
            CONVEX_DEPLOY_KEY: ${{ secrets.CONVEX_DEPLOY_KEY }}
            CONVEX_URL: ${{ secrets.CONVEX_URL }}

jobs:
  convex_deploy:
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v4

      - name: Setup
        uses: ./tooling/github/setup

      - name: Convex Deploy
        working-directory: apps/api
        run: pnpm run build
        env:
            CONVEX_DEPLOY_KEY: ${{ secrets.CONVEX_DEPLOY_KEY }}
            CONVEX_URL: ${{ secrets.CONVEX_URL }}